task.rs - OpenGrok cross reference for /developtools/hdc/hdc

Lines Matching refs:transfer
26 use hdc::transfer;
27 use hdc::transfer::send_channel_data;
86             transfer::TcpMap::end(task_info.channel_id).await;
149             task.transfer.server_or_daemon = true;
182         let _ = transfer::send_channel_msg(
184             transfer::EchoLevel::FAIL,
188         transfer::TcpMap::end(task_info.channel_id).await;
201     transfer::TcpMap::end(task_info.channel_id).await;
209         transfer::TcpMap::end(task_info.channel_id).await;
237     transfer::TcpMap::end(task_info.channel_id).await;
248     transfer::put(
268     transfer::put(
283     transfer::put(
324                 task.transfer.server_or_daemon = true;
359     transfer::put(
369         transfer::TcpMap::end(task_info.channel_id).await;
385     transfer::put(
408             transfer::put(
419             transfer::put(
431             transfer::put(
450         let ret = transfer::send_channel_msg(
452             transfer::EchoLevel::INFO,
456         transfer::TcpMap::end(task_info.channel_id).await;
502             let ret = transfer::send_channel_msg(
504                 transfer::EchoLevel::FAIL,
508             transfer::TcpMap::end(task_info.channel_id).await;
514             transfer::TcpMap::start(session_id, wr).await;
518             transfer::send_channel_msg(
520                 transfer::EchoLevel::INFO,
524             transfer::TcpMap::end(task_info.channel_id).await;
538     transfer::send_channel_msg(task_info.channel_id, transfer::EchoLevel::RAW, msg).await?;
539     transfer::TcpMap::end(task_info.channel_id).await;
549         transfer::send_channel_msg(task_info.channel_id, transfer::EchoLevel::RAW, msg).await?;
553         transfer::send_channel_msg(task_info.channel_id, transfer::EchoLevel::RAW, msg).await?;
554         transfer::TcpMap::end(task_info.channel_id).await;
563             transfer::send_channel_msg(task_info.channel_id, transfer::EchoLevel::RAW, msg).await?;
564             transfer::TcpMap::end(task_info.channel_id).await;
568             transfer::send_channel_msg(task_info.channel_id, transfer::EchoLevel::RAW, msg).await?;
580         match transfer::tcp::unpack_task_message(&mut rd).await {
604             let level_result = transfer::EchoLevel::convert_from_message_level(task_message.payload[0]);
608                         if let Err(e) = transfer::send_channel_msg(
623             transfer::send_channel_data(task_message.channel_id, task_message.payload).await;
648                 task.transfer.server_or_daemon = true;
693                 task.transfer.server_or_daemon = true;
744                 task.transfer.server_or_daemon = true;
749                 task.transfer.server_or_daemon = true;
772         transfer::put(session_id, message).await;
775     transfer::TcpMap::end(task_message.channel_id).await;
785     transfer::send_channel_data(task_info.channel_id, payload).await;
938             transfer::send_channel_msg(
940                 transfer::EchoLevel::FAIL,
944             transfer::TcpMap::end(channel_id).await;