Lines Matching refs:recv
103 let mut recv = native_struct::SessionHandShake::default();
104 recv.parse(task_message.payload)?;
106 crate::info!("recv handshake: {:#?}", recv);
107 if recv.banner != HANDSHAKE_MESSAGE {
111 let session_id = recv.session_id;
113 let host_ver = recv.version.as_str();
122 recv.session_id
126 recv.session_id,
133 recv.session_id
136 recv.session_id,
375 let mut recv = native_struct::SessionHandShake::default();
376 recv.parse(task_message.payload.clone())?;
377 Ok(recv.session_id)
562 let mut recv = native_struct::SessionHandShake::default();
563 recv.parse(task_message.payload)?;
564 crate::info!("recv handshake: {:?}", recv);
565 if recv.banner != HANDSHAKE_MESSAGE {
569 let session_id = recv.session_id;
571 let host_ver = recv.version.as_str();
586 recv.session_id
607 if recv.auth_type != AuthType::Publickey as u8 {
613 handshake_deal_pubkey(session_id, channel_id, token, recv.buf).await
621 if recv.auth_type != AuthType::Signature as u8 {
627 handshake_deal_signature(session_id, channel_id, token, pubkey, recv.buf).await