From 14a1ed561791fbc2357cb37206a1c0e73a97abc2 Mon Sep 17 00:00:00 2001
From: tao_z <tzj0429@163.com>
Date: Wed, 20 Jul 2022 22:56:23 +0800
Subject: [PATCH] 调整支持HEX烧录功能
---
USBCAN.py | 319 ++++++++++++++++++++++++++++++----------------------
1 files changed, 182 insertions(+), 137 deletions(-)
diff --git a/USBCAN.py b/USBCAN.py
index 70248b3..42ee2d2 100644
--- a/USBCAN.py
+++ b/USBCAN.py
@@ -1,3 +1,4 @@
+from asyncio.log import logger
from ctypes import *
from curses import raw
# import platform
@@ -6,7 +7,7 @@
import logging
from can import BusABC, Message
import time
-from multiprocessing import Queue, Value
+from multiprocessing import Queue, Value, Pipe
USBCAN_DEVICE_TYPE = c_uint
@@ -50,7 +51,6 @@
SEND_SINGLE = 1
SELF_SEND_RECV = 2
SELF_SEND_RECV_SINGLE = 3
-
'''
Interface return status
'''
@@ -62,52 +62,84 @@
class VCI_INIT_CONFIG(Structure):
- _fields_ = [("AccCode", c_ulong),
- ("AccMask", c_ulong),
- ("Reserved", c_ulong),
- ("Filter", c_ubyte),
- ("Timing0", c_ubyte),
- ("Timing1", c_ubyte),
- ("Mode", c_ubyte)
- ]
+ _fields_ = [("AccCode", c_ulong), ("AccMask", c_ulong),
+ ("Reserved", c_ulong), ("Filter", c_ubyte),
+ ("Timing0", c_ubyte), ("Timing1", c_ubyte), ("Mode", c_ubyte)]
class VCI_CAN_OBJ(Structure):
- _fields_ = [("ID", c_uint),
- ("TimeStamp", c_uint),
- ("TimeFlag", c_ubyte),
- ("SendType", c_ubyte),
- ("RemoteFlag", c_ubyte),
- ("ExternFlag", c_ubyte),
- ("DataLen", c_ubyte),
- ("Data", c_ubyte*8),
- ("Reserved", c_ubyte*3)
- ]
+ _fields_ = [("ID", c_uint), ("TimeStamp", c_uint), ("TimeFlag", c_ubyte),
+ ("SendType", c_ubyte), ("RemoteFlag", c_ubyte),
+ ("ExternFlag", c_ubyte), ("DataLen", c_ubyte),
+ ("Data", c_ubyte * 8), ("Reserved", c_ubyte * 3)]
class PVCI_ERR_INFO(Structure):
- _fields_ = [("ErrorCode", c_uint),
- ("PassiveErrData", c_ubyte*3),
- ("ArLostErrData", c_ubyte)
- ]
+ _fields_ = [("ErrorCode", c_uint), ("PassiveErrData", c_ubyte * 3),
+ ("ArLostErrData", c_ubyte)]
baudRateConfig = {
- '5Kbps': {'time0': 0xBF, 'time1': 0xFF},
- '10Kbps': {'time0': 0x31, 'time1': 0x1C},
- '20Kbps': {'time0': 0x18, 'time1': 0x1C},
- '40Kbps': {'time0': 0x87, 'time1': 0xFF},
- '50Kbps': {'time0': 0x09, 'time1': 0x1C},
- '80Kbps': {'time0': 0x83, 'time1': 0xFF},
- '100Kbps': {'time0': 0x04, 'time1': 0x1C},
- '125Kbps': {'time0': 0x03, 'time1': 0x1C},
- '200Kbps': {'time0': 0x81, 'time1': 0xFA},
- '250Kbps': {'time0': 0x01, 'time1': 0x1C},
- '400Kbps': {'time0': 0x80, 'time1': 0xFA},
- '500Kbps': {'time0': 0x00, 'time1': 0x1C},
- '666Kbps': {'time0': 0x80, 'time1': 0xB6},
- '800Kbps': {'time0': 0x00, 'time1': 0x16},
- '1000Kbps': {'time0': 0x00, 'time1': 0x14},
+ '5Kbps': {
+ 'time0': 0xBF,
+ 'time1': 0xFF
+ },
+ '10Kbps': {
+ 'time0': 0x31,
+ 'time1': 0x1C
+ },
+ '20Kbps': {
+ 'time0': 0x18,
+ 'time1': 0x1C
+ },
+ '40Kbps': {
+ 'time0': 0x87,
+ 'time1': 0xFF
+ },
+ '50Kbps': {
+ 'time0': 0x09,
+ 'time1': 0x1C
+ },
+ '80Kbps': {
+ 'time0': 0x83,
+ 'time1': 0xFF
+ },
+ '100Kbps': {
+ 'time0': 0x04,
+ 'time1': 0x1C
+ },
+ '125Kbps': {
+ 'time0': 0x03,
+ 'time1': 0x1C
+ },
+ '200Kbps': {
+ 'time0': 0x81,
+ 'time1': 0xFA
+ },
+ '250Kbps': {
+ 'time0': 0x01,
+ 'time1': 0x1C
+ },
+ '400Kbps': {
+ 'time0': 0x80,
+ 'time1': 0xFA
+ },
+ '500Kbps': {
+ 'time0': 0x00,
+ 'time1': 0x1C
+ },
+ '666Kbps': {
+ 'time0': 0x80,
+ 'time1': 0xB6
+ },
+ '800Kbps': {
+ 'time0': 0x00,
+ 'time1': 0x16
+ },
+ '1000Kbps': {
+ 'time0': 0x00,
+ 'time1': 0x14
+ },
}
TIMING_DICT = {
@@ -136,22 +168,20 @@
class USBCAN_DEVICE_INFO(Structure):
- _fields_ = [("hw_Version", c_ushort),
- ("fw_Version", c_ushort),
- ("dr_Version", c_ushort),
- ("in_Version", c_ushort),
- ("irq_Num", c_ushort),
- ("can_Num", c_ubyte),
+ _fields_ = [("hw_Version", c_ushort), ("fw_Version", c_ushort),
+ ("dr_Version", c_ushort), ("in_Version", c_ushort),
+ ("irq_Num", c_ushort), ("can_Num", c_ubyte),
("str_Serial_Num", c_ubyte * 20),
- ("str_hw_Type", c_ubyte * 40),
- ("reserved", c_ushort * 4)]
+ ("str_hw_Type", c_ubyte * 40), ("reserved", c_ushort * 4)]
def __str__(self):
return "Hardware Version:%s\nFirmware Version:%s\nDriver Interface:%s\nInterface Interface:%s\nInterrupt Number:%d\nCAN Number:%d\nSerial:%s\nHardware Type:%s\n" % (
- self.hw_version, self.fw_version, self.dr_version, self.in_version, self.irq_num, self.can_num, self.serial, self.hw_type)
+ self.hw_version, self.fw_version, self.dr_version, self.in_version,
+ self.irq_num, self.can_num, self.serial, self.hw_type)
def _version(self, version):
- return ("V%02x.%02x" if version // 0xFF >= 9 else "V%d.%02x") % (version // 0xFF, version & 0xFF)
+ return ("V%02x.%02x" if version // 0xFF >= 9 else
+ "V%d.%02x") % (version // 0xFF, version & 0xFF)
@property
def hw_version(self):
@@ -199,25 +229,16 @@
class _USBCAN_CHANNEL_CAN_INIT_CONFIG(Structure):
- _fields_ = [("acc_code", c_uint),
- ("acc_mask", c_uint),
- ("reserved", c_uint),
- ("filter", c_ubyte),
- ("timing0", c_ubyte),
- ("timing1", c_ubyte),
- ("mode", c_ubyte)]
+ _fields_ = [("acc_code", c_uint), ("acc_mask", c_uint),
+ ("reserved", c_uint), ("filter", c_ubyte),
+ ("timing0", c_ubyte), ("timing1", c_ubyte), ("mode", c_ubyte)]
class _USBCAN_CHANNEL_CANFD_INIT_CONFIG(Structure):
- _fields_ = [("acc_code", c_uint),
- ("acc_mask", c_uint),
- ("abit_timing", c_uint),
- ("dbit_timing", c_uint),
- ("brp", c_uint),
- ("filter", c_ubyte),
- ("mode", c_ubyte),
- ("pad", c_ushort),
- ("reserved", c_uint)]
+ _fields_ = [("acc_code", c_uint), ("acc_mask", c_uint),
+ ("abit_timing", c_uint), ("dbit_timing", c_uint),
+ ("brp", c_uint), ("filter", c_ubyte), ("mode", c_ubyte),
+ ("pad", c_ushort), ("reserved", c_uint)]
class _USBCAN_CHANNEL_INIT_CONFIG(Union):
@@ -226,26 +247,20 @@
class USBCAN_CHANNEL_INIT_CONFIG(Structure):
- _fields_ = [("can_type", c_uint),
- ("config", _USBCAN_CHANNEL_INIT_CONFIG)]
+ _fields_ = [("can_type", c_uint), ("config", _USBCAN_CHANNEL_INIT_CONFIG)]
class USBCAN_CHANNEL_ERR_INFO(Structure):
- _fields_ = [("error_code", c_uint),
- ("passive_ErrData", c_ubyte * 3),
+ _fields_ = [("error_code", c_uint), ("passive_ErrData", c_ubyte * 3),
("arLost_ErrData", c_ubyte)]
class USBCAN_CHANNEL_STATUS(Structure):
- _fields_ = [("errInterrupt", c_ubyte),
- ("regMode", c_ubyte),
- ("regStatus", c_ubyte),
- ("regALCapture", c_ubyte),
- ("regECCapture", c_ubyte),
- ("regEWLimit", c_ubyte),
- ("regRECounter", c_ubyte),
- ("regTECounter", c_ubyte),
- ("Reserved", c_ubyte)]
+ _fields_ = [("errInterrupt", c_ubyte), ("regMode", c_ubyte),
+ ("regStatus", c_ubyte), ("regALCapture", c_ubyte),
+ ("regECCapture", c_ubyte), ("regEWLimit", c_ubyte),
+ ("regRECounter", c_ubyte), ("regTECounter", c_ubyte),
+ ("Reserved", c_ubyte)]
platformInfo = sys.version
@@ -257,19 +272,28 @@
class USBCAN():
- def __init__(self, device_type=4, device_index=0, can_index=0, bitrate=None, can_filters=None, **kwargs):
+
+ def __init__(self,
+ device_type=4,
+ device_index=0,
+ can_index=0,
+ bitrate=None,
+ can_filters=None,
+ **kwargs):
# super(USBCAN, self).__init__(can_index, can_filters, **kwargs)
- self.logger = logging.getLogger()
- self.logger.setLevel(logging.DEBUG)
+ # self.logger = logging.getLogger()
+ # self.logger.setLevel(logging.DEBUG)
+ self.logger = logger
formatter = logging.Formatter(
'%(asctime)s - %(name)s - %(levelname)s - %(message)s')
# 终端Handler
consoleHandler = logging.StreamHandler()
consoleHandler.setLevel(logging.DEBUG)
# 文件Handler
- fileHandler = logging.FileHandler(
- './log/USBCAN.log', mode='a', encoding='UTF-8')
- fileHandler.setLevel(logging.NOTSET)
+ fileHandler = logging.FileHandler('./log/USBCAN.log',
+ mode='a',
+ encoding='UTF-8')
+ fileHandler.setLevel(logging.DEBUG)
consoleHandler.setFormatter(formatter)
fileHandler.setFormatter(formatter)
@@ -280,27 +304,33 @@
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 Timing0 is None or Timing1 is None:
self.logger.error("Timing registers are not set")
- self.init_config = VCI_INIT_CONFIG(
- 0, 0xFFFFFFFF, 0, 1, Timing0, Timing1, 0)
+ self.init_config = VCI_INIT_CONFIG(0, 0xFFFFFFFF, 0, 1, Timing0,
+ Timing1, 0)
def InitAndStart(self):
- if USBCAN_DLL.VCI_OpenDevice(self.device, self.device_index, 0) == USBCAN_STATUS_ERR:
+ if USBCAN_DLL.VCI_OpenDevice(self.device, self.device_index,
+ 0) == USBCAN_STATUS_ERR:
self.logger.error("VCI_OpenDevice Error")
return False
# for can_index in self.channels:
- if USBCAN_DLL.VCI_InitCAN(self.device, self.device_index, self.channel, byref(self.init_config)) == USBCAN_STATUS_ERR:
+ if USBCAN_DLL.VCI_InitCAN(self.device, self.device_index, self.channel,
+ byref(
+ self.init_config)) == USBCAN_STATUS_ERR:
self.logger.error("VCI_InitCAN Error")
self.CloseDevice()
return False
- if USBCAN_DLL.VCI_StartCAN(self.device, self.device_index, self.channel) == USBCAN_STATUS_ERR:
+ if USBCAN_DLL.VCI_StartCAN(self.device, self.device_index,
+ self.channel) == USBCAN_STATUS_ERR:
self.logger.error("VCI_StartCAN Error")
self.CloseDevice()
return False
@@ -308,7 +338,8 @@
def OpenDevice(self, device_type, device_index, reserved):
try:
- return USBCAN_DLL.VCI_OpenDevice(device_type, device_index, reserved)
+ return USBCAN_DLL.VCI_OpenDevice(device_type, device_index,
+ reserved)
except:
self.logger.error("Exception on OpenDevice!")
raise
@@ -323,44 +354,49 @@
def GetDeviceInf(self):
try:
info = USBCAN_DEVICE_INFO()
- ret = USBCAN_DLL.VCI_ReadBoardInfo(
- self.device, self.device_index, byref(info))
+ ret = USBCAN_DLL.VCI_ReadBoardInfo(self.device, self.device_index,
+ byref(info))
return info if ret == USBCAN_STATUS_OK else None
except:
self.logger.error("Exception on USBCAN_GetDeviceInf")
raise
- def InitCAN(self, device_type, device_index, can_index, init_config):
+ def InitCAN(self, device_type, device_index, can_index, init_config):
try:
- return USBCAN_DLL.VCI_InitCAN(device_type, device_index, can_index, byref(init_config))
+ return USBCAN_DLL.VCI_InitCAN(device_type, device_index, can_index,
+ byref(init_config))
except:
self.logger.error("Exception on USBCAN_InitCAN!")
raise
- def StartCAN(self, device_type, device_index, can_index):
+ def StartCAN(self, device_type, device_index, can_index):
try:
- return USBCAN_DLL.VCI_StartCAN(device_type, device_index, can_index)
+ return USBCAN_DLL.VCI_StartCAN(device_type, device_index,
+ can_index)
except:
self.logger.error("Exception on USBCAN_StartCAN!")
raise
- def ResetCAN(self, device_type, device_index, can_index):
+ def ResetCAN(self, device_type, device_index, can_index):
try:
- return USBCAN_DLL.VCI_ResetCAN(device_type, device_index, can_index)
+ return USBCAN_DLL.VCI_ResetCAN(device_type, device_index,
+ can_index)
except:
self.logger.error("Exception on USBCAN_ResetCAN!")
raise
def ClearBuffer(self):
try:
- return USBCAN_DLL.VCI_ClearBuffer(self.device, self.device_index, self.channel)
+ return USBCAN_DLL.VCI_ClearBuffer(self.device, self.device_index,
+ self.channel)
except:
self.logger.error("Exception on USBCAN_ClearBuffer!")
raise
def GetReceiveNum(self):
try:
- return USBCAN_DLL.VCI_GetReceiveNum(self.device, self.device_index, self.channel)
+ return USBCAN_DLL.VCI_GetReceiveNum(self.device, self.device_index,
+ self.channel)
except:
self.logger.error("Exception on USBCAN_GetReceiveNum!")
raise
@@ -373,65 +409,72 @@
raw_message.TimeStamp = (c_uint)(0)
raw_message.TimeFlag = (c_ubyte)(0)
raw_message.SendType = (c_ubyte)(1)
- raw_message.RemoteFlag = (c_ubyte)(msg.is_remote_frame)
+ raw_message.RemoteFlag = False
raw_message.ExternFlag = (c_ubyte)(msg.is_extended_id)
raw_message.DataLen = (c_ubyte)(msg.dlc)
- raw_message.Data = (c_ubyte * 8)(* [c_ubyte(c) for c in msg.data])
+ raw_message.Data = (c_ubyte * 8)(*[c_ubyte(c) for c in msg.data])
# (msg.arbitration_id, 0, 0, 1, msg.is_remote_frame,
# extern_flag, msg.dlc, (c_ubyte * 8)(*msg.data), (c_ubyte * 3)(*[0, 0, 0]))
- USBCAN_DLL.VCI_Transmit(
- self.device, self.device_index, self.channel, byref(raw_message), 1)
+ USBCAN_DLL.VCI_Transmit(self.device, self.device_index, self.channel,
+ byref(raw_message), 1)
def Receive(self, len=10, timeout=None):
- raw_message = (VCI_CAN_OBJ*len)()
+ raw_message = (VCI_CAN_OBJ * len)()
timeout = -1 if timeout is None else c_int(timeout * 1000)
msg = list()
- rtn = USBCAN_DLL.VCI_Receive(
- self.device, self.device_index, self.channel, byref(raw_message), len, timeout)
+ rtn = USBCAN_DLL.VCI_Receive(self.device,
+ self.device_index, self.channel,
+ byref(raw_message), len, timeout)
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,
- 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,
- ))
+ msg.append(
+ 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, sendQueue: Queue):
+ def ListeningMsg(self, connectRet, needClose, msgQueue: Queue,
+ sendQueue: Queue):
'''call by single process to deal can messages.
Arguments:
connectRet {Value} -- return value of connection
needClose {Value} -- disconnect when needed
msgQueue {Queue} -- received data
'''
- loopCnt = 0
- while connectRet.value == 1:
- # print(connectRet.value, needClose.value, start.value)
- if needClose.value == 1:
- ret = self.CloseDevice()
- if ret == 1:
- needClose.value = 0
- connectRet.value = 0
- return
- msgToSendCnt = sendQueue.qsize()
- if msgToSendCnt > 0:
- msg = Message()
- for i in range(msgToSendCnt):
- msg = sendQueue.get()
- self.send(msg, 1)
- time.sleep(0.001)
- loopCnt += 1
- if loopCnt >= 15:
- loopCnt = 0
- # restNum = self.GetReceiveNum() if self.GetReceiveNum() <= 10 else 10
+ while True:
+ while connectRet.value == 1:
+ # print(connectRet.value, needClose.value, start.value)
+ if needClose.value == 1:
+ ret = self.CloseDevice()
+ if ret == 1:
+ needClose.value = 0
+ connectRet.value = 0
+ return
+ # msgToSendCnt = sendQueue.qsize()
+ # if msgToSendCnt > 0:
+ # msg = Message()
+ # for i in range(msgToSendCnt):
+ # msg = sendQueue.get()
+ # self.send(msg, 1)
+ # time.sleep(0.001)
+ # loopCnt += 1
revRet, num = self.Receive(len=10)
if num == 0:
pass
@@ -439,4 +482,6 @@
for i in range(num):
msgQueue.put(revRet[i])
self.logger.info(
- "received can message.it't id is:{}".format(str(revRet[i].arbitration_id)))
+ "received can message.it't id is:{}".format(
+ str(revRet[i].arbitration_id)))
+ time.sleep(0.05)
--
Gitblit v1.8.0