Lines Matching refs:u32
47 pub file_cnt: u32,
56 pub fn new(_session_id: u32, _channel_id: u32) -> Self {
64 type FileTaskMap_ = Arc<Mutex<HashMap<(u32, u32), HdcFile_>>>;
75 pub async fn put(session_id: u32, channel_id: u32, value: HdcFile) {
81 pub async fn exsit(session_id: u32, channel_id: u32) -> bool {
88 pub async fn remove(session_id: u32, channel_id: u32) -> Option<HdcFile_> {
94 pub async fn get(session_id: u32, channel_id: u32) -> Option<HdcFile_> {
101 async fn stop_task(session_id: u32) {
136 async fn check_local_path(session_id: u32, channel_id: u32) -> bool {
180 async fn echo_finish(session_id: u32, channel_id: u32, msg: String) {
191 pub async fn begin_transfer(session_id: u32, channel_id: u32, command: &String) -> bool {
231 session_id: u32,
232 channel_id: u32,
234 argc: u32,
245 let mut src_argv_index = 0u32;
336 async fn put_file_check(session_id: u32, channel_id: u32) {
349 pub async fn check_slaver(session_id: u32, channel_id: u32, _payload: &[u8]) -> Result<bool, Error> {
393 pub async fn wake_up_slaver(session_id: u32, channel_id: u32) {
402 async fn put_file_begin(session_id: u32, channel_id: u32) {
411 async fn transfer_next(session_id: u32, channel_id: u32) -> bool {
435 async fn on_all_transfer_finish(session_id: u32, channel_id: u32) {
499 async fn is_task_queue_empty(session_id: u32, channel_id: u32) -> bool {
510 async fn do_file_finish(session_id: u32, channel_id: u32, _payload: &[u8]) {
534 async fn put_file_finish(session_id: u32, channel_id: u32) {
554 session_id: u32,
555 channel_id: u32,
622 async fn put_file_mode(session_id: u32, channel_id: u32) {
631 async fn task_finish(session_id: u32, channel_id: u32) {
635 pub async fn stop_task(session_id: u32) {
643 pub async fn echo_fail(session_id: u32, channel_id: u32, error: Error, is_checked: bool) {