Lines Matching refs:ContextForward
103 pub struct ContextForward {
268 type MapContextForward_ = Arc<Mutex<HashMap<u32, ContextForward>>>;
283 pub async fn update(cid: u32, value: ContextForward) {
290 crate::info!("ContextForward remove, cid:{}", cid);
296 pub async fn get(cid: u32) -> Option<ContextForward> {
303 crate::debug!("ContextForward result:is none,cid={:#?}", cid,);
484 context_forward: ContextForward,
566 ctx: &mut ContextForward,
617 pub async fn detech_forward_type(ctx_point: &mut ContextForward) -> bool {
653 pub async fn forward_tcp_accept(ctx: &mut ContextForward, port: u32) -> io::Result<()> {
750 pub async fn update_context_to_task(session_id: u32, channel_id:u32, ctx: &mut ContextForward) {
874 pub async fn setup_tcp_point(ctx: &mut ContextForward) -> bool {
891 async fn server_socket_bind_listen(ctx: &mut ContextForward, path: String) -> bool {
952 pub async fn setup_device_point(_ctx: &mut ContextForward) -> bool {
957 pub async fn setup_device_point(ctx: &mut ContextForward) -> bool {
1026 pub async fn setup_jdwp_point(_ctx: &mut ContextForward) -> bool {
1032 pub async fn setup_jdwp_point(ctx: &mut ContextForward) -> bool {
1138 pub async fn daemon_connect_pipe(ctx: &mut ContextForward) {
1165 pub async fn setup_file_point(_ctx: &mut ContextForward) -> bool {
1170 pub async fn setup_file_point(ctx: &mut ContextForward) -> bool {
1200 pub async fn setup_point(ctx: &mut ContextForward) -> bool {
1269 pub async fn send_active_master(ctx: &mut ContextForward) -> bool {
1300 pub fn forward_parse_cmd(context_forward: &mut ContextForward) -> bool {
1412 pub async fn read_data_to_forward(ctx: &mut ContextForward) {
1470 pub async fn write_forward_bufer(ctx: &mut ContextForward, content: Vec<u8>) -> bool {
1501 ) -> ContextForward {
1502 let mut ctx = ContextForward {