Mirror/betaflight
1
0
Fork 0
mirror of https://github.com/betaflight/betaflight.git synced 2025-07-15 04:15:44 +03:00
Code Issues Wiki Activity

use array to store the port1&port2 config

Browse source
This commit is contained in:
azolyoung 2019-06-13 12:24:42 +08:00
parent b7270917c8
commit 568dc62087
1 changed files with 49 additions and 66 deletions
Download patch file Download diff file Expand all files Collapse all files

115
src/main/cli/cli.c
View file

@ -168,6 +168,13 @@ extern uint8_t __config_end;
#include "cli.h" #include "cli.h"
typedef struct serialPassthroughPort_e {
int id;
uint32_t baud;
unsigned mode;
serialPort_t *port;
} serialPassthroughPort_t;
static serialPort_t *cliPort; static serialPort_t *cliPort;
#ifdef STM32F1 #ifdef STM32F1
@ -1256,12 +1263,7 @@ static void cliSerialPassthrough(char *cmdline)
return; return;
} }
int port1Id = -1; serialPassthroughPort_t ports[2] = { {SERIAL_PORT_NONE, 0, 0, NULL}, { SERIAL_PORT_USB_VCP, 0, 0, cliPort} };
uint32_t port1Baud = 0;
unsigned port1Mode = 0;
int port2Id = -1;
uint32_t port2Baud = 0;
int port2Mode = 0;
bool enableBaudCb = false; bool enableBaudCb = false;
int port1PinioDtr = 0; int port1PinioDtr = 0;
bool port1ResetOnDtr = false; bool port1ResetOnDtr = false;
@ -1272,13 +1274,13 @@ static void cliSerialPassthrough(char *cmdline)
while (tok != NULL) { while (tok != NULL) {
switch (index) { switch (index) {
case 0: case 0:
port1Id = atoi(tok); ports[0].id = atoi(tok);
break; break;
case 1: case 1:
port1Baud = atoi(tok); ports[0].baud = atoi(tok);
break; break;
case 2: case 2:
port1Mode = cliParseSerialMode(tok); ports[0].mode = cliParseSerialMode(tok);
break; break;
case 3: case 3:
if (strncasecmp(tok, "reset", strlen(tok)) == 0) { if (strncasecmp(tok, "reset", strlen(tok)) == 0) {
@ -1288,88 +1290,69 @@ static void cliSerialPassthrough(char *cmdline)
port1PinioDtr = 0; port1PinioDtr = 0;
} else { } else {
port1PinioDtr = atoi(tok); port1PinioDtr = atoi(tok);
if (port1PinioDtr < 0 || port1PinioDtr > PINIO_COUNT) {
cliPrintLinef("Invalid PinIO number %d", port1PinioDtr);
return ;
}
#endif /* USE_PINIO */ #endif /* USE_PINIO */
} }
break; break;
case 4: case 4:
port2Id = atoi(tok); ports[1].id = atoi(tok);
ports[1].port = NULL;
break; break;
case 5: case 5:
port2Baud = atoi(tok); ports[1].baud = atoi(tok);
break; break;
case 6: case 6:
port2Mode = cliParseSerialMode(tok); ports[1].mode = cliParseSerialMode(tok);
break; break;
} }
index++; index++;
tok = strtok_r(NULL, " ", &saveptr); tok = strtok_r(NULL, " ", &saveptr);
} }
if (port1Baud == 0 && port2Id == -1) { // Port checks
enableBaudCb = true; if (ports[0].id == ports[1].id) {
} cliPrintLinef("Port1 and port2 are same");
if (port1PinioDtr < 0 || port1PinioDtr > PINIO_COUNT) {
cliPrintLinef("Invalid PinIO number %d", port1PinioDtr);
return ; return ;
} }
// Port checks for (int i = 0; i < 2; i++) {
if (findSerialPortIndexByIdentifier(port1Id) == -1) { if (findSerialPortIndexByIdentifier(ports[i].id) == -1) {
cliPrintLinef("Invalid port1 %d", port1Id); cliPrintLinef("Invalid port%d %d", i + 1, ports[i].id);
} else {
cliPrintLinef("Port1: %d ", port1Id);
}
if (port2Id != -1) {
if (findSerialPortIndexByIdentifier(port2Id) == -1) {
cliPrintLinef("Invalid port2 %d", port2Id);
} if (port2Id == port1Id) {
cliPrintLinef("Port1 and port2 are same");
return ; return ;
} else { } else {
cliPrintLinef("Port2: %d", port2Id); cliPrintLinef("Port%d: %d ", i + 1, ports[i].id);
} }
} else {
cliPrintLine("Port2: VCP port");
} }
serialPort_t *port1 = NULL; if (ports[0].baud == 0 && ports[1].id == SERIAL_PORT_USB_VCP) {
serialPort_t *port2 = cliPort; enableBaudCb = true;
serialPort_t **passthroughPorts[2] = { &port1, &port2 };
int portIds[2] = { port1Id, 0 };
uint32_t bauds[2] = { port1Baud, 0 };
unsigned modes[2] = { port1Mode, 0 };
if (port2Id != -1) {
*(passthroughPorts[1]) = NULL;
portIds[1] = port2Id;
bauds[1] = port2Baud;
modes[1] = port2Mode;
} }
for (int i = 0; i < 2; i++) { for (int i = 0; i < 2; i++) {
serialPort_t **port = passthroughPorts[i]; serialPort_t **port = &(ports[i].port);
if (*port != NULL) { if (*port != NULL) {
continue; continue;
} }
int portIndex = i + 1; int portIndex = i + 1;
serialPortUsage_t *portUsage = findSerialPortUsageByIdentifier(portIds[i]); serialPortUsage_t *portUsage = findSerialPortUsageByIdentifier(ports[i].id);
if (!portUsage || portUsage->serialPort == NULL) { if (!portUsage || portUsage->serialPort == NULL) {
bool isUseDefaultBaud = false; bool isUseDefaultBaud = false;
if (bauds[i] == 0) { if (ports[i].baud == 0) {
// Set default baud // Set default baud
bauds[i] = 57600; ports[i].baud = 57600;
isUseDefaultBaud = true; isUseDefaultBaud = true;
} }
if (!modes[i]) { if (!ports[i].mode) {
modes[i] = MODE_RXTX; ports[i].mode = MODE_RXTX;
} }
*port = openSerialPort(portIds[i], FUNCTION_NONE, NULL, NULL, *port = openSerialPort(ports[i].id, FUNCTION_NONE, NULL, NULL,
bauds[i], modes[i], ports[i].baud, ports[i].mode,
SERIAL_NOT_INVERTED); SERIAL_NOT_INVERTED);
if (!*port) { if (!*port) {
cliPrintLinef("Port%d could not be opened.", portIndex); cliPrintLinef("Port%d could not be opened.", portIndex);
@ -1377,26 +1360,26 @@ static void cliSerialPassthrough(char *cmdline)
} }
if (isUseDefaultBaud) { if (isUseDefaultBaud) {
cliPrintf("Port%d opened, default baud = %d.\r\n", portIndex, bauds[i]); cliPrintf("Port%d opened, default baud = %d.\r\n", portIndex, ports[i].baud);
} else { } else {
cliPrintf("Port%d opened, baud = %d.\r\n", portIndex, bauds[i]); cliPrintf("Port%d opened, baud = %d.\r\n", portIndex, ports[i].baud);
} }
} else { } else {
*port = portUsage->serialPort; *port = portUsage->serialPort;
// If the user supplied a mode, override the port's mode, otherwise // If the user supplied a mode, override the port's mode, otherwise
// leave the mode unchanged. serialPassthrough() handles one-way ports. // leave the mode unchanged. serialPassthrough() handles one-way ports.
// Set the baud rate if specified // Set the baud rate if specified
if (bauds[i]) { if (ports[i].baud) {
cliPrintf("Port%d is already open, setting baud = %d.\n\r", portIndex, bauds[i]); cliPrintf("Port%d is already open, setting baud = %d.\n\r", portIndex, ports[i].baud);
serialSetBaudRate(*port, bauds[i]); serialSetBaudRate(*port, ports[i].baud);
} else { } else {
cliPrintf("Port%d is already open, baud = %d.\n\r", portIndex, (*port)->baudRate); cliPrintf("Port%d is already open, baud = %d.\n\r", portIndex, (*port)->baudRate);
} }
if (modes[i] && (*port)->mode != modes[i]) { if (ports[i].mode && (*port)->mode != ports[i].mode) {
cliPrintf("Port%d mode changed from %d to %d.\r\n", cliPrintf("Port%d mode changed from %d to %d.\r\n",
portIndex, (*port)->mode, modes[i]); portIndex, (*port)->mode, ports[i].mode);
serialSetMode(*port, modes[i]); serialSetMode(*port, ports[i].mode);
} }
// If this port has a rx callback associated we need to remove it now. // If this port has a rx callback associated we need to remove it now.
@ -1412,26 +1395,26 @@ static void cliSerialPassthrough(char *cmdline)
cliPrintLine("Port1 baud rate change over USB enabled."); cliPrintLine("Port1 baud rate change over USB enabled.");
// Register the right side baud rate setting routine with the left side which allows setting of the UART // Register the right side baud rate setting routine with the left side which allows setting of the UART
// baud rate over USB without setting it using the serialpassthrough command // baud rate over USB without setting it using the serialpassthrough command
serialSetBaudRateCb(*(passthroughPorts[0]), serialSetBaudRate, *(passthroughPorts[1])); serialSetBaudRateCb(ports[0].port, serialSetBaudRate, ports[1].port);
} }
char *resetMessage = ""; char *resetMessage = "";
if (port1ResetOnDtr) { if (port1ResetOnDtr && ports[1].id == SERIAL_PORT_USB_VCP) {
resetMessage = "or drop DTR "; resetMessage = "or drop DTR ";
} }
cliPrintLinef("Forwarding, power cycle %sto exit.", resetMessage); cliPrintLinef("Forwarding, power cycle %sto exit.", resetMessage);
if ((port2Id == -1) && (port1ResetOnDtr if ((ports[1].id == SERIAL_PORT_USB_VCP) && (port1ResetOnDtr
#ifdef USE_PINIO #ifdef USE_PINIO
|| port1PinioDtr || port1PinioDtr
#endif /* USE_PINIO */ #endif /* USE_PINIO */
)) { )) {
// Register control line state callback // Register control line state callback
serialSetCtrlLineStateCb(*(passthroughPorts[0]), cbCtrlLine, (void *)(intptr_t)(port1PinioDtr)); serialSetCtrlLineStateCb(ports[0].port, cbCtrlLine, (void *)(intptr_t)(port1PinioDtr));
} }
serialPassthrough(*(passthroughPorts[0]), *(passthroughPorts[1]), NULL, NULL); serialPassthrough(ports[0].port, ports[1].port, NULL, NULL);
} }
#endif #endif