12     def __init__(self, idx, file_path):  argument
13         self.idx = idx
14         self.file_path = file_path
15         self.f = None
16         self.skip_first_line = True
18     def __str__(self):  argument
19         return self.file_path
21     def open(self):  argument
22         self.f = io.open(self.file_path, 'r')
24     def close(self):  argument
25         self.f.close()
27     def decode(self, line):  argument
30     def fetch(self, cnt=-1):  argument
32         self.skip_first_line = True
34             offset = self.f.tell()
35             line = self.f.readline()
41                 self.f.seek(offset, io.SEEK_SET)
45                 if self.skip_first_line:
46                     self.skip_first_line = False
49                 yield self.decode(line.strip())
59     def decode(self, line):  argument
77 …return self.Tx._make((self.idx, start_time, phy_address, center_freq, modulation, memoryview(packe…
83     def decode(self, line):  argument
116         return self.Rx._make((self.idx, rx_time_stamp, phy_address, center_freq, modulation, status,
148 … def __init__(self, direction, idx, ts, aa, channel_num, phy, data, payload_type, header, payload):  argument
149         self.direction = direction
150         self.idx = idx
151         self.ts = ts
152         self.aa = aa
153         self.channel_num = channel_num
154         self.phy = phy
155         self.data = data
156         self.type = payload_type
157         self.header = header
158         self.payload = payload
160     def __len__(self):  argument
161         return len(self.data)
163     def __repr__(self):  argument
442     def __init__(self, interval):  argument
443         self.connection_interval = interval
444         self.cis_to_aa_map = {}
448     def __init__(self):  argument
449         self.__conn_data_by_aa = {}
450         self.__func_by_aa = {
453         self.__aux_ptr_packets = [];
455     def __get_packet(self, direction, idx, ts, aa, channel_num, phy, packet):  argument
456         if aa in self.__func_by_aa:
457             if self.__func_by_aa[aa] == parse_adv_pdu:
458 …return self.__func_by_aa[aa](direction, idx, ts, aa, channel_num, phy, packet, self.__aux_ptr_pack…
459             return self.__func_by_aa[aa](direction, idx, ts, aa, channel_num, phy, packet)
462     def parse(self, dump):  argument
463         packet = self.__get_packet(type(dump).__name__, dump.idx, dump.ts, dump.aa,
464 …                      self.__get_phy_channel_num(dump.freq), self.__get_phy(dump.mod), dump.packet)
466             self.__run_hook(packet)
470     def __run_hook(self, packet):  argument
471         if packet.type in self.__hooks__:
472             self.__hooks__[packet.type](self, packet, self.__conn_data_by_aa.get(packet.aa))
486     def __on_ext_adv_packet(self, packet, _):  argument
489             self.__aux_ptr_packets.append(packet)
491     def __on_connect_ind(self, packet, _):  argument
492         self.__func_by_aa[packet.payload.LLData.AA] = parse_data_pdu
493 …  self.__conn_data_by_aa[packet.payload.LLData.AA] = ConnectionData(packet.payload.LLData.Interval)
495     def __on_terminate_ind(self, packet, conn_data):  argument
496         del self.__func_by_aa[packet.aa]
498             del self.__func_by_aa[cis_aa]
499         del self.__conn_data_by_aa[packet.aa]
501     def __on_cis_req(self, packet, conn_data):  argument
504     def __on_cis_ind(self, packet, conn_data):  argument
507         self.__func_by_aa[cis_aa] = parse_isoc_pdu
511     def __on_cis_terminate_ind(self, packet, conn_data):  argument
515             del self.__func_by_aa[cis_aa]
534         def __init__(self, file):  argument
535             self.file = file
536             self.generator = self.file.fetch()
537             self.dump = None
539     def __init__(self):  argument
540         self.dumps = []
542     def __del__(self):  argument
543         for dump in self.dumps:
546     def __open(self, file):  argument
549             self.dumps.append(self.Dump(file))
554     def add_tx(self, idx, file_path):  argument
555         self.__open(DeviceDumpFileTx(idx, file_path))
557     def add_rx(self, idx, file_path):  argument
561     def flush(self):  argument
562         for dump in self.dumps:
568     def fetch(self):  argument
570             for dump in self.dumps:
578             self.dumps.sort(key=lambda entry: entry.dump.ts if entry.dump else sys.maxsize)
579             dump = self.dumps[0]
588     def __init__(self, dumps):  argument
589         self.__dumps = dumps
590         self.__dumps.flush()
591         self.__parser = PacketParser()
592         self.__packets = []
594     def fetch(self, packet_filter=()):  argument
605             for dump in self.__dumps.fetch():
606                 self.__packets.append(self.__parser.parse(dump))
608             if i < len(self.__packets):
609 …if self.__packets[i] != None and (not packet_filter or self.__packets[i].type.name in packet_filte…
610                     yield self.__packets[i]
615     def find(self, packet_type=None):  argument
617             return next(self.fetch(packet_type))
621     def findLast(self, packet_filter=()):  argument
630         for dump in self.__dumps.fetch():
631             self.__packets.append(self.__parser.parse(dump))
633         for i in reversed(range(len(self.__packets))):
634 …if self.__packets[i] != None and (not packet_filter or self.__packets[i].type.name in packet_filte…
635                 return self.__packets[i]
638     def flush(self):  argument
639         for dump in self.__dumps.fetch():
641         self.__parser = PacketParser()
642         self.__packets = []