| | |
| | | self.device = device_type |
| | | self.device_index = device_index |
| | | self.channel = can_index |
| | | self.timestamp_start = None |
| | | self.laststamp = None |
| | | |
| | | Timing0, Timing1 = TIMING_DICT[bitrate] |
| | | |
| | |
| | | if rtn == 0xFFFFFFFF or rtn == 0: |
| | | return None, False |
| | | else: |
| | | if self.timestamp_start == None: |
| | | self.laststamp = raw_message[0].TimeStamp |
| | | self.timestamp_start = self.laststamp |
| | | for i in range(rtn): |
| | | msg.append( |
| | | Message( |
| | | timestamp=raw_message[i].TimeStamp |
| | | if raw_message[i].TimeFlag else 0.0, |
| | | Message(timestamp=( |
| | | (raw_message[i].TimeStamp - self.timestamp_start) / |
| | | 1000000) if raw_message[i].TimeFlag else 0.0, |
| | | arbitration_id=raw_message[i].ID, |
| | | is_remote_frame=raw_message[i].RemoteFlag, |
| | | channel=0, |
| | | extended_id=raw_message[i].ExternFlag, |
| | | data=raw_message[i].Data, |
| | | )) |
| | | is_error_frame=False)) |
| | | # timestamp = raw_message[i].TimeStamp if raw_message[ |
| | | # i].TimeFlag else 0.0, |
| | | # print(timestamp) |
| | | return (msg, rtn) |
| | | |
| | | def ListeningMsg(self, connectRet, needClose, msgQueue: Queue, |