Lines Matching refs:conn

51     pub conn: Arc<dyn Conn + Send + Sync>,  field
67 conn: Arc<dyn Conn + Send + Sync>, in new()
73 conn, in new()
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()
211 &self.conn, 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()
277 build_and_send(&self.conn, self.src_addr, msg).await in handle_binding_request()
299 dst_addr: self.conn.local_addr()?, in handle_allocate_request()
323 &self.conn, in handle_allocate_request()
347 return build_and_send_err(&self.conn, self.src_addr, bad_request_msg, err.into()) in handle_allocate_request()
359 &self.conn, in handle_allocate_request()
385 &self.conn, in handle_allocate_request()
414 &self.conn, in handle_allocate_request()
446 &self.conn, in handle_allocate_request()
476 Arc::clone(&self.conn), in handle_allocate_request()
494 &self.conn, in handle_allocate_request()
551 build_and_send(&self.conn, self.src_addr, msg).await in handle_allocate_request()
568 dst_addr: self.conn.local_addr()?, in handle_refresh_request()
592 build_and_send(&self.conn, self.src_addr, msg).await in handle_refresh_request()
602 dst_addr: self.conn.local_addr()?, in handle_create_permission_request()
656 build_and_send(&self.conn, self.src_addr, msg).await in handle_create_permission_request()
669 dst_addr: self.conn.local_addr()?, in handle_send_indication()
710 dst_addr: self.conn.local_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()
779 dst_addr: self.conn.local_addr()?, in handle_channel_data()
838 conn: &Arc<dyn Conn + Send + Sync>, in build_and_send()
842 let _ = conn.send_to(&msg.raw, dst).await?; in build_and_send()
848 conn: &Arc<dyn Conn + Send + Sync>, in build_and_send_err()
853 build_and_send(conn, dst, msg).await?; in build_and_send_err()