Lines Matching refs:task
190 let task = map.get(&(session_id, channel_id)); in get() localVariable
191 if task.is_none() { in get()
196 Some(task.unwrap().clone()) in get()
269 let task = ForwardTaskMap::get(session_id, channel_id).await; in check_command() localVariable
270 if task.is_none() { in check_command()
273 let task = &mut task.unwrap().clone(); in check_command() localVariable
276 let map_info = String::from(if task.transfer.server_or_daemon { in check_command()
280 }) + &task.task_command; in check_command()
307 let task = ForwardTaskMap::get(session_id, channel_id).await; in detech_forward_type() localVariable
308 if task.is_none() { in detech_forward_type()
311 let task = &mut task.unwrap().clone(); in detech_forward_type() localVariable
313 let type_str = &task.local_args[0]; in detech_forward_type()
317 task.forward_type = ForwardType::Tcp; in detech_forward_type()
320 task.forward_type = ForwardType::Device; in detech_forward_type()
323 task.forward_type = ForwardType::Abstract; in detech_forward_type()
326 task.local_args[1] = HARMONY_RESERVED_SOCKET_PREFIX.to_owned() + &task.local_args[1]; in detech_forward_type()
327 task.forward_type = ForwardType::FileSystem; in detech_forward_type()
330 task.forward_type = ForwardType::Jdwp; in detech_forward_type()
333 task.forward_type = ForwardType::Ark; in detech_forward_type()
336 task.local_args[1] = FILE_SYSTEM_SOCKET_PREFIX.to_owned() + &task.local_args[1]; in detech_forward_type()
337 task.forward_type = ForwardType::Reserved; in detech_forward_type()
341 ForwardTaskMap::update(session_id, channel_id, task.clone()).await; in detech_forward_type()
345 ForwardTaskMap::update(session_id, channel_id, task.clone()).await; in detech_forward_type()
434 let task = ForwardTaskMap::get(session_id, channel_id).await; in deamon_read_socket_msg() localVariable
435 if task.is_none() { in deamon_read_socket_msg()
438 let task = &mut task.unwrap().clone(); in deamon_read_socket_msg() localVariable
453 task.context_forward.id, in deamon_read_socket_msg()
464 let task = ForwardTaskMap::get(session_id, channel_id).await; in free_context() localVariable
465 if task.is_none() { in free_context()
468 let task = &mut task.unwrap().clone(); in free_context() localVariable
477 task.context_forward.id, in free_context()
481 match task.forward_type { in free_context()
483 TcpWriteStreamMap::end(task.context_forward.id).await; in free_context()
486 UdsServer::wrap_close(task.context_forward.fd); in free_context()
492 ForwardTaskMap::update(session_id, channel_id, task.clone()).await; in free_context()
496 let task = ForwardTaskMap::get(session_id, channel_id).await; in setup_tcp_point() localVariable
497 if task.is_none() { in setup_tcp_point()
500 let task = &mut task.unwrap(); in setup_tcp_point() localVariable
501 let port = task.local_args[1].parse::<u32>().unwrap(); in setup_tcp_point()
502 let cid = task.context_forward.id; in setup_tcp_point()
503 if task.is_master { in setup_tcp_point()
504 let parameters = task.remote_parameters.clone(); in setup_tcp_point()
522 let task = ForwardTaskMap::get(session_id, channel_id).await; in server_socket_bind_listen() localVariable
523 let task = &mut task.unwrap().clone(); in server_socket_bind_listen() localVariable
524 let parameters = task.remote_parameters.clone(); in server_socket_bind_listen()
526 task.context_forward.fd = fd; in server_socket_bind_listen()
527 ForwardTaskMap::update(session_id, channel_id, task.clone()).await; in server_socket_bind_listen()
573 let task = ForwardTaskMap::get(session_id, channel_id).await; in setup_device_point() localVariable
574 if task.is_none() { in setup_device_point()
577 let task = &mut task.unwrap().clone(); in setup_device_point() localVariable
578 let s_node_cfg = task.local_args[1].clone(); in setup_device_point()
579 let cid = task.context_forward.id; in setup_device_point()
640 let task: Option<HdcForward> = ForwardTaskMap::get(session_id, channel_id).await; in setup_jdwp_point() localVariable
641 if task.is_none() { in setup_jdwp_point()
644 let task = &mut task.unwrap().clone(); in setup_jdwp_point() localVariable
645 let local_args = task.local_args[1].clone(); in setup_jdwp_point()
647 let style = &task.forward_type; in setup_jdwp_point()
649 let cid = task.context_forward.id; in setup_jdwp_point()
663 task.context_forward.fd = local_fd; in setup_jdwp_point()
664 ForwardTaskMap::update(session_id, channel_id, task.clone()).await; in setup_jdwp_point()
692 let mut param = task.local_args[0].clone(); in setup_jdwp_point()
757 let task: Option<HdcForward> = ForwardTaskMap::get(session_id, channel_id).await; in setup_file_point() localVariable
758 if task.is_none() { in setup_file_point()
761 let task = &mut task.unwrap().clone(); in setup_file_point() localVariable
762 let s_node_cfg = task.local_args[1].clone(); in setup_file_point()
763 if task.is_master { in setup_file_point()
764 if task.forward_type == ForwardType::Reserved in setup_file_point()
765 || task.forward_type == ForwardType::FileSystem in setup_file_point()
769 if !server_socket_bind_listen(session_id, channel_id, s_node_cfg, task.context_forward.id) in setup_file_point()
775 } else if task.forward_type == ForwardType::Abstract { in setup_file_point()
780 task.context_forward.fd = fd; in setup_file_point()
781 ForwardTaskMap::update(session_id, channel_id, task.clone()).await; in setup_file_point()
785 task.context_forward.fd = fd; in setup_file_point()
786 ForwardTaskMap::update(session_id, channel_id, task.clone()).await; in setup_file_point()
789 ForwardTaskMap::update(session_id, channel_id, task.clone()).await; in setup_file_point()
798 let task = ForwardTaskMap::get(session_id, channel_id).await; in setup_point() localVariable
799 if task.is_none() { in setup_point()
802 let task = &mut task.unwrap().clone(); in setup_point() localVariable
803 if cfg!(target_os = "windows") && task.forward_type != ForwardType::Tcp { in setup_point()
804 task.context_forward.last_error = String::from("Not support forward-type"); in setup_point()
807 ForwardTaskMap::update(session_id, channel_id, task.clone()).await; in setup_point()
808 let ret = match task.forward_type { in setup_point()
855 let task = ForwardTaskMap::get(session_id, channel_id).await; in send_active_master() localVariable
856 if task.is_none() { in send_active_master()
859 let task = &mut task.unwrap().clone(); in send_active_master() localVariable
860 if task.context_forward.check_order { in send_active_master()
868 task.context_forward.id, in send_active_master()
872 ForwardTaskMap::update(session_id, channel_id, task.clone()).await; in send_active_master()
881 task.context_forward.id, in send_active_master()
886 ForwardTaskMap::update(session_id, channel_id, task.clone()).await; in send_active_master()
900 let task = ForwardTaskMap::get(session_id, channel_id).await; in begin_forward() localVariable
901 if task.is_none() { in begin_forward()
905 let task = &mut task.unwrap().clone(); in begin_forward() localVariable
909 task.context_forward.id = get_id(_payload); in begin_forward()
910 task.is_master = true; in begin_forward()
918 if !check_node_info(&argv[0], &mut task.local_args).await { in begin_forward()
921 if !check_node_info(&argv[1], &mut task.remote_args).await { in begin_forward()
924 task.remote_parameters = argv[1].clone(); in begin_forward()
925 ForwardTaskMap::update(session_id, channel_id, task.clone()).await; in begin_forward()
931 let task = ForwardTaskMap::get(session_id, channel_id).await; in begin_forward() localVariable
932 let task = &mut task.unwrap().clone(); in begin_forward() localVariable
933 task.map_ctx_point in begin_forward()
934 .insert(task.context_forward.id, task.context_forward.clone()); in begin_forward()
954 task.context_forward.id, in begin_forward()
957 task.task_command = command.clone(); in begin_forward()
958 ForwardTaskMap::update(session_id, channel_id, task.clone()).await; in begin_forward()
969 let task = ForwardTaskMap::get(session_id, channel_id).await; in slave_connect() localVariable
970 if task.is_none() { in slave_connect()
973 let task = &mut task.unwrap().clone(); in slave_connect() localVariable
974 task.is_master = false; in slave_connect()
975 task.context_forward.check_order = check_order; in slave_connect()
978 if !check_node_info(content, &mut task.local_args).await { in slave_connect()
982 task.context_forward.id = id; in slave_connect()
984 task.map_ctx_point in slave_connect()
985 .insert(task.context_forward.id, task.context_forward.clone()); in slave_connect()
986 ForwardTaskMap::update(session_id, channel_id, task.clone()).await; in slave_connect()
993 *error = task.context_forward.last_error.clone(); in slave_connect()
997 *error = task.context_forward.last_error.clone(); in slave_connect()
1002 let task = ForwardTaskMap::get(session_id, channel_id).await; in read_data_to_forward() localVariable
1003 if task.is_none() { in read_data_to_forward()
1006 let task = &mut task.unwrap(); in read_data_to_forward() localVariable
1007 let cid = task.context_forward.id; in read_data_to_forward()
1008 match task.forward_type { in read_data_to_forward()
1015 let fd = task.context_forward.fd; in read_data_to_forward()
1035 let task = ForwardTaskMap::get(session_id, channel_id).await; in write_forward_bufer() localVariable
1036 if task.is_none() { in write_forward_bufer()
1039 let task = &mut task.unwrap(); in write_forward_bufer() localVariable
1040 if task.forward_type == ForwardType::Tcp { in write_forward_bufer()
1043 let fd = task.context_forward.fd; in write_forward_bufer()
1055 let task = ForwardTaskMap::get(session_id, channel_id).await; in forward_command_dispatch() localVariable
1056 if task.is_none() { in forward_command_dispatch()
1059 let task: &mut HdcForward = &mut task.unwrap().clone(); in forward_command_dispatch() localVariable
1062 task.context_forward.id = id; in forward_command_dispatch()
1065 ForwardTaskMap::update(session_id, channel_id, task.clone()).await; in forward_command_dispatch()
1071 ret = write_forward_bufer(session_id, channel_id, task.context_forward.id, send_msg) in forward_command_dispatch()
1084 ForwardTaskMap::update(session_id, channel_id, task.clone()).await; in forward_command_dispatch()