HVAC_DEV
/
SerialPortUSB_ARTERY_AT32F435_437
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Начало

This commit is contained in:
cfif 2026-03-12 13:18:21 +03:00
parent 25aeba11b2
commit a5339ade29
2 changed files with 33 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
SerialPort_USB.c
View File

@ -205,6 +205,12 @@ static uint16_t vSerialPortUsbReceive(tSerialPortUsbArtery *env, uint8_t *data,
return vSerialPortReceiveQueue(env, data, size, timeout, env->rxDataQueue); return vSerialPortReceiveQueue(env, data, size, timeout, env->rxDataQueue);
} }
static uint16_t vSerialPortUsbSnifferReceive(tSerialPortUsbArtery *env, uint8_t *data, uint16_t size, uint32_t timeout) {
return env->rxDataSnifferQueue
? vSerialPortReceiveQueue(env, data, size, timeout, env->rxDataSnifferQueue)
: 0;
}
static _Noreturn void UsbDriver_Thread(tSerialPortUsbArtery *env) { static _Noreturn void UsbDriver_Thread(tSerialPortUsbArtery *env) {
for (;;) { for (;;) {
uint16_t data_len = usb_vcp_get_rxdata(&otg_core_struct.dev, env->usb_buffer); uint16_t data_len = usb_vcp_get_rxdata(&otg_core_struct.dev, env->usb_buffer);
@ -212,6 +218,11 @@ static _Noreturn void UsbDriver_Thread(tSerialPortUsbArtery *env) {
if (data_len > 0) { if (data_len > 0) {
for (uint16_t i = 0; i < data_len; ++i) { for (uint16_t i = 0; i < data_len; ++i) {
osMessageQueuePut(env->rxDataQueue, &env->usb_buffer[i], 0x0, 0U); osMessageQueuePut(env->rxDataQueue, &env->usb_buffer[i], 0x0, 0U);
if (env->rxDataSnifferQueue) {
osMessageQueuePut(env->rxDataSnifferQueue, &env->usb_buffer[i], 0x0, 0U);
}
} }
} }
@ -229,10 +240,18 @@ void UsbDriver_StartThread(tSerialPortUsbArtery *env) {
void SerialPortUsb_Init( void SerialPortUsb_Init(
tSerialPortUsbArtery *env, tSerialPortUsbArtery *env,
uint32_t rxBufferLength uint32_t rxBufferLength,
uint32_t rxSnifferLength
) { ) {
env->rxDataQueue = osMessageQueueNew(rxBufferLength, 1, NULL); env->rxDataQueue = osMessageQueueNew(rxBufferLength, 1, NULL);
if (rxSnifferLength) {
env->rxDataSnifferQueue = osMessageQueueNew(rxBufferLength, 1, NULL);
} else {
env->rxDataSnifferQueue = 0;
}
// usb gpio config // usb gpio config
usb_gpio_config(); usb_gpio_config();
@ -272,3 +291,12 @@ tSerialPortIO SerialPortUsb_GetIo(tSerialPortUsbArtery *env) {
}; };
return io; return io;
} }
tSerialPortIO SerialPortUsb_GetSnifferIo(tSerialPortUsbArtery *env) {
tSerialPortIO io = {
.env = env,
.receive = (SerialPortIOTransaction) vSerialPortUsbSnifferReceive,
.transmit = (SerialPortIOTransaction) vSerialPortUsbTransmit
};
return io;
}

5
SerialPort_USB.h
View File

@ -15,6 +15,7 @@
typedef struct { typedef struct {
osMessageQueueId_t rxDataQueue; osMessageQueueId_t rxDataQueue;
osMessageQueueId_t rxDataSnifferQueue;
struct { struct {
osThreadId_t id; osThreadId_t id;
uint32_t stack[1024]; uint32_t stack[1024];
@ -28,9 +29,11 @@ typedef struct {
void SerialPortUsb_Init( void SerialPortUsb_Init(
tSerialPortUsbArtery *env, tSerialPortUsbArtery *env,
uint32_t rxBufferLength uint32_t rxBufferLength,
uint32_t rxSnifferLength
); );
tSerialPortIO SerialPortUsb_GetIo(tSerialPortUsbArtery *env); tSerialPortIO SerialPortUsb_GetIo(tSerialPortUsbArtery *env);
tSerialPortIO SerialPortUsb_GetSnifferIo(tSerialPortUsbArtery *env);
#endif //SERIALPORT_USB_H #endif //SERIALPORT_USB_H