Lines Matching refs:u32
55 type AuthStatusMap_ = Arc<RwLock<HashMap<u32, AuthStatus>>>;
68 pub async fn get(session_id: u32) -> AuthStatus {
76 async fn put(session_id: u32, auth_status: AuthStatus) {
87 pub async fn remove(session_id: u32) {
98 pub async fn handshake_init(task_message: TaskMessage) -> io::Result<(u32, TaskMessage)> {
164 async fn make_sign_message(session_id: u32, token: String, channel_id: u32) -> TaskMessage {
180 async fn make_bypass_message(session_id: u32, channel_id: u32, host_ver: &str) -> TaskMessage {
207 async fn create_basic_channel(session_id: u32, channel_id: u32, host_ver: &str) {
228 async fn make_emg_message(session_id: u32, channel_id: u32, emgmsg: &str) -> TaskMessage {
252 session_id: u32,
253 channel_id: u32,
281 async fn send_reject_message(session_id: u32, channel_id: u32, host_ver: &str) {
293 async fn make_ok_message(session_id: u32, channel_id: u32) -> TaskMessage {
342 pub async fn get_auth_msg(session_id: u32) -> String {
358 pub async fn make_channel_close_message(channel_id: u32) -> TaskMessage {
374 pub async fn get_session_id_from_msg(task_message: &TaskMessage) -> io::Result<u32> {
380 pub async fn handshake_init_new(session_id: u32, channel_id: u32) -> io::Result<()> {
405 session_id: u32,
406 channel_id: u32,
534 session_id: u32,
535 channel_id: u32,
556 pub async fn handshake_task(task_message: TaskMessage, session_id: u32) -> io::Result<()> {
829 async fn handshake_fail(session_id: u32, channel_id: u32, msg: String) {