mirrors/unleashed-firmware
1
Fork 0
mirror of https://github.com/DarkFlippers/unleashed-firmware.git synced 2025-12-12 12:42:30 +04:00
Code Issues Activity

Merge remote-tracking branch 'OFW/porta/3979-usb-uart-vcp-fix' into dev

Browse Source
This commit is contained in:
MX
2025-04-15 03:05:16 +03:00
parent e8e87c66e3 086a9185fc
commit 5f3d510f34
2 changed files with 23 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
applications/main/gpio/usb_uart_bridge.c
View File

@@ -60,6 +60,8 @@ struct UsbUartBridge {
FuriApiLock cfg_lock; FuriApiLock cfg_lock;
CliVcp* cli_vcp;
uint8_t rx_buf[USB_CDC_PKT_LEN]; uint8_t rx_buf[USB_CDC_PKT_LEN];
}; };
@@ -105,15 +107,11 @@ static void usb_uart_on_irq_rx_dma_cb(
static void usb_uart_vcp_init(UsbUartBridge* usb_uart, uint8_t vcp_ch) { static void usb_uart_vcp_init(UsbUartBridge* usb_uart, uint8_t vcp_ch) {
furi_hal_usb_unlock(); furi_hal_usb_unlock();
if(vcp_ch == 0) { if(vcp_ch == 0) {
CliVcp* cli_vcp = furi_record_open(RECORD_CLI_VCP); cli_vcp_disable(usb_uart->cli_vcp);
cli_vcp_disable(cli_vcp);
furi_record_close(RECORD_CLI_VCP);
furi_check(furi_hal_usb_set_config(&usb_cdc_single, NULL) == true); furi_check(furi_hal_usb_set_config(&usb_cdc_single, NULL) == true);
} else { } else {
furi_check(furi_hal_usb_set_config(&usb_cdc_dual, NULL) == true); furi_check(furi_hal_usb_set_config(&usb_cdc_dual, NULL) == true);
CliVcp* cli_vcp = furi_record_open(RECORD_CLI_VCP); cli_vcp_enable(usb_uart->cli_vcp);
cli_vcp_enable(cli_vcp);
furi_record_close(RECORD_CLI_VCP);
} }
furi_hal_cdc_set_callbacks(vcp_ch, (CdcCallbacks*)&cdc_cb, usb_uart); furi_hal_cdc_set_callbacks(vcp_ch, (CdcCallbacks*)&cdc_cb, usb_uart);
} }
@@ -122,9 +120,7 @@ static void usb_uart_vcp_deinit(UsbUartBridge* usb_uart, uint8_t vcp_ch) {
UNUSED(usb_uart); UNUSED(usb_uart);
furi_hal_cdc_set_callbacks(vcp_ch, NULL, NULL); furi_hal_cdc_set_callbacks(vcp_ch, NULL, NULL);
if(vcp_ch != 0) { if(vcp_ch != 0) {
CliVcp* cli_vcp = furi_record_open(RECORD_CLI_VCP); cli_vcp_disable(usb_uart->cli_vcp);
cli_vcp_disable(cli_vcp);
furi_record_close(RECORD_CLI_VCP);
} }
} }
@@ -176,6 +172,8 @@ static int32_t usb_uart_worker(void* context) {
memcpy(&usb_uart->cfg, &usb_uart->cfg_new, sizeof(UsbUartConfig)); memcpy(&usb_uart->cfg, &usb_uart->cfg_new, sizeof(UsbUartConfig));
usb_uart->cli_vcp = furi_record_open(RECORD_CLI_VCP);
usb_uart->rx_stream = furi_stream_buffer_alloc(USB_UART_RX_BUF_SIZE, 1); usb_uart->rx_stream = furi_stream_buffer_alloc(USB_UART_RX_BUF_SIZE, 1);
usb_uart->tx_sem = furi_semaphore_alloc(1, 1); usb_uart->tx_sem = furi_semaphore_alloc(1, 1);
@@ -308,8 +306,8 @@ static int32_t usb_uart_worker(void* context) {
furi_hal_usb_unlock(); furi_hal_usb_unlock();
furi_check(furi_hal_usb_set_config(&usb_cdc_single, NULL) == true); furi_check(furi_hal_usb_set_config(&usb_cdc_single, NULL) == true);
CliVcp* cli_vcp = furi_record_open(RECORD_CLI_VCP); cli_vcp_enable(usb_uart->cli_vcp);
cli_vcp_enable(cli_vcp);
furi_record_close(RECORD_CLI_VCP); furi_record_close(RECORD_CLI_VCP);
return 0; return 0;

16
applications/services/cli/cli_vcp.c
View File

@@ -5,6 +5,7 @@
#include <stdint.h> #include <stdint.h>
#include <toolbox/pipe.h> #include <toolbox/pipe.h>
#include <toolbox/cli/shell/cli_shell.h> #include <toolbox/cli/shell/cli_shell.h>
#include <toolbox/api_lock.h>
#include "cli_main_shell.h" #include "cli_main_shell.h"
#include "cli_main_commands.h" #include "cli_main_commands.h"
@@ -26,6 +27,7 @@ typedef struct {
CliVcpMessageTypeEnable, CliVcpMessageTypeEnable,
CliVcpMessageTypeDisable, CliVcpMessageTypeDisable,
} type; } type;
FuriApiLock api_lock;
union {}; union {};
} CliVcpMessage; } CliVcpMessage;
@@ -182,6 +184,8 @@ static void cli_vcp_message_received(FuriEventLoopObject* object, void* context)
furi_hal_usb_set_config(cli_vcp->previous_interface, NULL); furi_hal_usb_set_config(cli_vcp->previous_interface, NULL);
break; break;
} }
api_lock_unlock(message.api_lock);
} }
/** /**
@@ -300,16 +304,24 @@ int32_t cli_vcp_srv(void* p) {
// Public API // Public API
// ========== // ==========
static void cli_vcp_synchronous_request(CliVcp* cli_vcp, CliVcpMessage* message) {
message->api_lock = api_lock_alloc_locked();
furi_message_queue_put(cli_vcp->message_queue, message, FuriWaitForever);
api_lock_wait_unlock_and_free(message->api_lock);
}
void cli_vcp_enable(CliVcp* cli_vcp) { void cli_vcp_enable(CliVcp* cli_vcp) {
furi_check(cli_vcp);
CliVcpMessage message = { CliVcpMessage message = {
.type = CliVcpMessageTypeEnable, .type = CliVcpMessageTypeEnable,
}; };
furi_message_queue_put(cli_vcp->message_queue, &message, FuriWaitForever); cli_vcp_synchronous_request(cli_vcp, &message);
} }
void cli_vcp_disable(CliVcp* cli_vcp) { void cli_vcp_disable(CliVcp* cli_vcp) {
furi_check(cli_vcp);
CliVcpMessage message = { CliVcpMessage message = {
.type = CliVcpMessageTypeDisable, .type = CliVcpMessageTypeDisable,
}; };
furi_message_queue_put(cli_vcp->message_queue, &message, FuriWaitForever); cli_vcp_synchronous_request(cli_vcp, &message);
} }