Lines Matching refs:src_addr

52     pub src_addr: SocketAddr,  field
68 src_addr: SocketAddr, in new()
74 src_addr, in new()
101 log::debug!("received DataPacket from {}", self.src_addr); in handle_data_packet()
165 build_and_send_err(&self.conn, self.src_addr, bad_request_msg, err.into()).await?; in authenticate_request()
195 build_and_send_err(&self.conn, self.src_addr, bad_request_msg, err.into()).await?; in authenticate_request()
199 build_and_send_err(&self.conn, self.src_addr, bad_request_msg, err.into()).await?; in authenticate_request()
206 self.src_addr, in authenticate_request()
212 self.src_addr, in authenticate_request()
223 build_and_send_err(&self.conn, self.src_addr, bad_request_msg, err.into()).await?; in authenticate_request()
260 build_and_send(&self.conn, self.src_addr, msg).await in respond_with_nonce()
264 log::debug!("received BindingRequest from {}", self.src_addr); in handle_binding_request()
266 let (ip, port) = (self.src_addr.ip(), self.src_addr.port()); in handle_binding_request()
277 build_and_send(&self.conn, self.src_addr, msg).await in handle_binding_request()
282 log::debug!("received AllocateRequest from {}", self.src_addr); in handle_allocate_request()
298 src_addr: self.src_addr, in handle_allocate_request()
324 self.src_addr, in handle_allocate_request()
347 return build_and_send_err(&self.conn, self.src_addr, bad_request_msg, err.into()) in handle_allocate_request()
360 self.src_addr, in handle_allocate_request()
386 self.src_addr, in handle_allocate_request()
415 self.src_addr, in handle_allocate_request()
447 self.src_addr, in handle_allocate_request()
495 self.src_addr, in handle_allocate_request()
514 let (src_ip, src_port) = (self.src_addr.ip(), self.src_addr.port()); in handle_allocate_request()
551 build_and_send(&self.conn, self.src_addr, msg).await in handle_allocate_request()
555 log::debug!("received RefreshRequest from {}", self.src_addr); in handle_refresh_request()
567 src_addr: self.src_addr, in handle_refresh_request()
592 build_and_send(&self.conn, self.src_addr, msg).await in handle_refresh_request()
596 log::debug!("received CreatePermission from {}", self.src_addr); in handle_create_permission_request()
601 src_addr: self.src_addr, in handle_create_permission_request()
656 build_and_send(&self.conn, self.src_addr, msg).await in handle_create_permission_request()
663 log::debug!("received SendIndication from {}", self.src_addr); in handle_send_indication()
668 src_addr: self.src_addr, in handle_send_indication()
704 log::debug!("received ChannelBindRequest from {}", self.src_addr); in handle_channel_bind_request()
709 src_addr: self.src_addr, in handle_channel_bind_request()
734 return build_and_send_err(&self.conn, self.src_addr, bad_request_msg, err.into()) in handle_channel_bind_request()
740 return build_and_send_err(&self.conn, self.src_addr, bad_request_msg, err.into()) in handle_channel_bind_request()
758 return build_and_send_err(&self.conn, self.src_addr, bad_request_msg, err).await; in handle_channel_bind_request()
766 build_and_send(&self.conn, self.src_addr, msg).await in handle_channel_bind_request()
773 log::debug!("received ChannelData from {}", self.src_addr); in handle_channel_data()
778 src_addr: self.src_addr, in handle_channel_data()