Lines Matching refs:context_forward
210 context_forward: ContextForward, field
226 context_forward: Default::default(), in new()
453 task.context_forward.id, in deamon_read_socket_msg()
477 task.context_forward.id, 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()
502 let cid = task.context_forward.id; in setup_tcp_point()
526 task.context_forward.fd = fd; in server_socket_bind_listen()
579 let cid = task.context_forward.id; in setup_device_point()
649 let cid = task.context_forward.id; in setup_jdwp_point()
663 task.context_forward.fd = local_fd; in setup_jdwp_point()
769 if !server_socket_bind_listen(session_id, channel_id, s_node_cfg, task.context_forward.id) in setup_file_point()
780 task.context_forward.fd = fd; in setup_file_point()
785 task.context_forward.fd = fd; in setup_file_point()
804 task.context_forward.last_error = String::from("Not support forward-type"); in setup_point()
860 if task.context_forward.check_order { in send_active_master()
868 task.context_forward.id, in send_active_master()
881 task.context_forward.id, in send_active_master()
909 task.context_forward.id = get_id(_payload); in begin_forward()
934 .insert(task.context_forward.id, task.context_forward.clone()); in begin_forward()
954 task.context_forward.id, in begin_forward()
975 task.context_forward.check_order = check_order; in slave_connect()
982 task.context_forward.id = id; in slave_connect()
985 .insert(task.context_forward.id, task.context_forward.clone()); 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()
1007 let cid = task.context_forward.id; in read_data_to_forward()
1015 let fd = task.context_forward.fd; in read_data_to_forward()
1043 let fd = task.context_forward.fd; in write_forward_bufer()
1062 task.context_forward.id = id; in forward_command_dispatch()
1071 ret = write_forward_bufer(session_id, channel_id, task.context_forward.id, send_msg) in forward_command_dispatch()