Lines Matching refs:packet
148 fn process_classic_connection(&mut self, address: Address, packet: &Packet) { in process_classic_connection()
150 if let Some(p) = self.connection_attempt.insert(address, packet.clone()) { in process_classic_connection()
153 format!("Dangling connection attempt at {:?} replaced with {:?}", p, packet), in process_classic_connection()
165 fn process_sync_connection(&mut self, address: Address, packet: &Packet) { in process_sync_connection()
167 if let Some(p) = self.sco_connection_attempt.insert(address, packet.clone()) { in process_sync_connection()
170 format!("Dangling sco connection attempt at {:?} replaced with {:?}", p, packet), in process_sync_connection()
179 packet: &Packet, in process_le_create_connection()
183 if let Some(p) = self.le_connection_attempt.insert(address, packet.clone()) { in process_le_create_connection()
186 format!("Dangling LE connection attempt at {:?} replaced with {:?}", p, packet), in process_le_create_connection()
218 packet: &Packet, in process_remote_feat_cmd()
220 self.get_feature_pending_map(&feat_type).insert(*handle, packet.ts); in process_remote_feat_cmd()
228 packet: &Packet, in process_disconnect_cmd()
232 self.process_disconn_complete_ev(handle, packet); in process_disconnect_cmd()
237 fn process_command_status(&mut self, status: ErrorCode, opcode: OpCode, packet: &Packet) { in process_command_status()
247 self.process_command_status_conn(status, opcode, packet); in process_command_status()
253 self.process_command_status_feat(status, opcode, packet); in process_command_status()
260 fn process_command_status_conn(&mut self, status: ErrorCode, opcode: OpCode, packet: &Packet) { in process_command_status_conn()
284 packet.ts, in process_command_status_conn()
312 packet.ts, in process_command_status_conn()
319 fn process_command_status_feat(&mut self, status: ErrorCode, opcode: OpCode, packet: &Packet) { in process_command_status_feat()
337 self.process_remote_feat_ev(feat_type, status, handle, packet); in process_command_status_feat()
346 packet: &Packet, in process_conn_complete_ev()
350 self.active_handles.insert(handle, (packet.ts, address)); in process_conn_complete_ev()
354 packet.ts, in process_conn_complete_ev()
363 packet.ts, in process_conn_complete_ev()
372 fn process_disconn_complete_ev(&mut self, handle: ConnectionHandle, packet: &Packet) { in process_disconn_complete_ev()
383 let duration_since_acl = packet.ts.signed_duration_since(acl_front_ts); in process_disconn_complete_ev()
386 index: packet.index, in process_disconn_complete_ev()
387 ts: packet.ts, in process_disconn_complete_ev()
392 packet.ts, in process_disconn_complete_ev()
404 index: packet.index, in process_disconn_complete_ev()
405 ts: packet.ts, in process_disconn_complete_ev()
410 packet.ts, in process_disconn_complete_ev()
419 let elapsed_time_ms = packet.ts.signed_duration_since(ts).num_milliseconds(); in process_disconn_complete_ev()
422 index: packet.index, in process_disconn_complete_ev()
423 ts: packet.ts, in process_disconn_complete_ev()
428 packet.ts, in process_disconn_complete_ev()
446 packet: &Packet, in process_sync_conn_complete_ev()
450 self.active_handles.insert(handle, (packet.ts, address)); in process_sync_conn_complete_ev()
454 packet.ts, in process_sync_conn_complete_ev()
463 packet.ts, in process_sync_conn_complete_ev()
479 packet: &Packet, in process_le_conn_complete_ev()
489 self.active_handles.insert(handle, (packet.ts, address)); in process_le_conn_complete_ev()
500 self.reportable.push((packet.ts, message)); in process_le_conn_complete_ev()
504 packet.ts, in process_le_conn_complete_ev()
513 fn process_acl_tx(&mut self, acl_tx: &Acl, packet: &Packet) { in process_acl_tx()
522 nocp_data.inflight_acl_ts.push_back(packet.ts); in process_acl_tx()
526 fn process_nocp(&mut self, nocp: &NumberOfCompletedPackets, packet: &Packet) { in process_nocp()
527 let ts = &packet.ts; in process_nocp()
541 index: packet.index, in process_nocp()
542 ts: packet.ts, in process_nocp()
546 packet.ts, in process_nocp()
570 packet: &Packet, in process_remote_feat_ev()
576 packet.ts, in process_remote_feat_ev()
583 index: packet.index, in process_remote_feat_ev()
584 ts: packet.ts, in process_remote_feat_ev()
589 packet.ts, in process_remote_feat_ev()
624 fn process(&mut self, packet: &Packet) { in process()
625 match &packet.inner { in process()
628 self.process_classic_connection(cc.get_bd_addr(), packet); in process()
631 self.process_classic_connection(ac.get_bd_addr(), packet); in process()
637 packet, in process()
644 packet, in process()
649 self.process_sync_connection(address, packet); in process()
653 self.process_sync_connection(address, packet); in process()
656 self.process_sync_connection(asc.get_bd_addr(), packet); in process()
659 self.process_sync_connection(easc.get_bd_addr(), packet); in process()
665 packet, in process()
672 packet, in process()
676 self.process_add_accept_list(laac.get_address(), packet); in process()
679 self.process_remove_accept_list(lrac.get_address(), packet); in process()
682 self.process_clear_accept_list(packet); in process()
688 packet, in process()
695 packet, in process()
708 self.process_command_status(cs.get_status(), cs.get_command_op_code(), packet); in process()
715 packet, in process()
719 self.process_disconn_complete_ev(dsc.get_connection_handle(), packet); in process()
726 packet, in process()
730 self.process_nocp(&nocp, packet); in process()
734 self.process_apte(&apte, packet); in process()
741 packet, in process()
749 packet, in process()
758 packet, in process()
766 packet, in process()
774 packet, in process()
787 self.process_acl_tx(&tx, packet); in process()
858 fn process_address_auth(&mut self, status: ErrorCode, address: Address, packet: &Packet) { in process_address_auth()
862 index: packet.index, in process_address_auth()
863 ts: packet.ts, in process_address_auth()
868 packet.ts, in process_address_auth()
880 packet: &Packet, in process_handle_auth()
883 self.process_address_auth(status, *address, packet); in process_handle_auth()
906 packet: &Packet, in process_encryption_change()
914 packet.ts, in process_encryption_change()
920 index: packet.index, in process_encryption_change()
921 ts: packet.ts, in process_encryption_change()
938 fn process(&mut self, packet: &Packet) { in process()
939 match &packet.inner { in process()
950 self.process_address_auth(ev.get_status(), ev.get_bd_addr(), &packet); in process()
953 self.process_handle_auth(ev.get_status(), ev.get_connection_handle(), &packet); in process()
956 self.process_handle_auth(ev.get_status(), ev.get_connection_handle(), &packet); in process()
963 &packet, in process()
994 &packet, in process()
1052 packet: &Packet, in process_connect_complete()
1059 index: packet.index, in process_connect_complete()
1060 ts: packet.ts, in process_connect_complete()
1065 packet.ts, in process_connect_complete()
1073 fn process(&mut self, packet: &Packet) { in process()
1074 match &packet.inner { in process()
1081 packet, in process()