Lines Matching refs:msg

102         msg: &Message,  in perform_transaction()
106 let tr_key = base64::encode(msg.transaction_id.0); in perform_transaction()
110 raw: msg.raw.clone(), in perform_transaction()
117 log::trace!("start {} transaction {} to {}", msg.typ, tr_key, tr.to); in perform_transaction()
124 .send_to(&msg.raw, SocketAddr::from_str(to)?) in perform_transaction()
310 let mut msg = Message::new(); in handle_stun_message() localVariable
311 msg.raw = data.to_vec(); in handle_stun_message()
312 msg.decode()?; in handle_stun_message()
314 if msg.typ.class == CLASS_REQUEST { in handle_stun_message()
318 msg in handle_stun_message()
322 if msg.typ.class == CLASS_INDICATION { in handle_stun_message()
323 if msg.typ.method == METHOD_DATA { in handle_stun_message()
325 peer_addr.get_from(&msg)?; in handle_stun_message()
329 data.get_from(&msg)?; in handle_stun_message()
344 let tr_key = base64::encode(msg.transaction_id.0); in handle_stun_message()
349 log::debug!("no transaction for {}", msg); in handle_stun_message()
359 msg, in handle_stun_message()
438 let msg = { in send_binding_request_to() localVariable
449 let mut msg = Message::new(); in send_binding_request_to() localVariable
450 msg.build(&attrs)?; in send_binding_request_to()
451 msg in send_binding_request_to()
455 let tr_res = self.perform_transaction(&msg, to, false).await?; in send_binding_request_to()
458 refl_addr.get_from(&tr_res.msg)?; in send_binding_request_to()
493 let mut msg = Message::new(); in allocate() localVariable
494 msg.build(&[ in allocate()
505 .perform_transaction(&msg, &self.turn_serv_addr.clone(), false) in allocate()
507 let res = tr_res.msg; in allocate()
520 msg.build(&[ in allocate()
535 .perform_transaction(&msg, &self.turn_serv_addr.clone(), false) in allocate()
537 let res = tr_res.msg; in allocate()