1
0
Fork 0
mirror of https://github.com/betaflight/betaflight.git synced 2025-07-20 14:55:21 +03:00

Eliminated inefficient serial function calls at runtime.

This commit is contained in:
mikeller 2018-05-10 01:32:36 +12:00
parent 3af1610d0b
commit 032f3b501b
5 changed files with 14 additions and 23 deletions

View file

@ -72,7 +72,7 @@ static bool rcdeviceIsCameraControlEnabled(void)
bool rcdeviceIsEnabled(void) bool rcdeviceIsEnabled(void)
{ {
return findSerialPortConfig(FUNCTION_RCDEVICE) != NULL; return camDevice->serialPort != NULL;
} }
static bool rcdeviceIs5KeyEnabled(void) static bool rcdeviceIs5KeyEnabled(void)

View file

@ -221,10 +221,6 @@ serialPortConfig_t *findNextSerialPortConfig(serialPortFunction_e function)
return NULL; return NULL;
} }
typedef struct findSharedSerialPortState_s {
uint8_t lastIndex;
} findSharedSerialPortState_t;
portSharing_e determinePortSharing(const serialPortConfig_t *portConfig, serialPortFunction_e function) portSharing_e determinePortSharing(const serialPortConfig_t *portConfig, serialPortFunction_e function)
{ {
if (!portConfig || (portConfig->functionMask & function) == 0) { if (!portConfig || (portConfig->functionMask & function) == 0) {
@ -238,19 +234,10 @@ bool isSerialPortShared(const serialPortConfig_t *portConfig, uint16_t functionM
return (portConfig) && (portConfig->functionMask & sharedWithFunction) && (portConfig->functionMask & functionMask); return (portConfig) && (portConfig->functionMask & sharedWithFunction) && (portConfig->functionMask & functionMask);
} }
static findSharedSerialPortState_t findSharedSerialPortState;
serialPort_t *findSharedSerialPort(uint16_t functionMask, serialPortFunction_e sharedWithFunction) serialPort_t *findSharedSerialPort(uint16_t functionMask, serialPortFunction_e sharedWithFunction)
{ {
memset(&findSharedSerialPortState, 0, sizeof(findSharedSerialPortState)); for (unsigned i = 0; i < SERIAL_PORT_COUNT; i++) {
const serialPortConfig_t *candidate = &serialConfig()->portConfigs[i];
return findNextSharedSerialPort(functionMask, sharedWithFunction);
}
serialPort_t *findNextSharedSerialPort(uint16_t functionMask, serialPortFunction_e sharedWithFunction)
{
while (findSharedSerialPortState.lastIndex < SERIAL_PORT_COUNT) {
const serialPortConfig_t *candidate = &serialConfig()->portConfigs[findSharedSerialPortState.lastIndex++];
if (isSerialPortShared(candidate, functionMask, sharedWithFunction)) { if (isSerialPortShared(candidate, functionMask, sharedWithFunction)) {
const serialPortUsage_t *serialPortUsage = findSerialPortUsageByIdentifier(candidate->identifier); const serialPortUsage_t *serialPortUsage = findSerialPortUsageByIdentifier(candidate->identifier);

View file

@ -107,7 +107,6 @@ typedef struct serialPortUsage_s {
} serialPortUsage_t; } serialPortUsage_t;
serialPort_t *findSharedSerialPort(uint16_t functionMask, serialPortFunction_e sharedWithFunction); serialPort_t *findSharedSerialPort(uint16_t functionMask, serialPortFunction_e sharedWithFunction);
serialPort_t *findNextSharedSerialPort(uint16_t functionMask, serialPortFunction_e sharedWithFunction);
// //
// configuration // configuration

View file

@ -41,11 +41,12 @@
static mspPort_t mspPorts[MAX_MSP_PORT_COUNT]; static mspPort_t mspPorts[MAX_MSP_PORT_COUNT];
static void resetMspPort(mspPort_t *mspPortToReset, serialPort_t *serialPort) static void resetMspPort(mspPort_t *mspPortToReset, serialPort_t *serialPort, bool sharedWithTelemetry)
{ {
memset(mspPortToReset, 0, sizeof(mspPort_t)); memset(mspPortToReset, 0, sizeof(mspPort_t));
mspPortToReset->port = serialPort; mspPortToReset->port = serialPort;
mspPortToReset->sharedWithTelemetry = sharedWithTelemetry;
} }
void mspSerialAllocatePorts(void) void mspSerialAllocatePorts(void)
@ -61,7 +62,8 @@ void mspSerialAllocatePorts(void)
serialPort_t *serialPort = openSerialPort(portConfig->identifier, FUNCTION_MSP, NULL, NULL, baudRates[portConfig->msp_baudrateIndex], MODE_RXTX, SERIAL_NOT_INVERTED); serialPort_t *serialPort = openSerialPort(portConfig->identifier, FUNCTION_MSP, NULL, NULL, baudRates[portConfig->msp_baudrateIndex], MODE_RXTX, SERIAL_NOT_INVERTED);
if (serialPort) { if (serialPort) {
resetMspPort(mspPort, serialPort); bool sharedWithTelemetry = isSerialPortShared(portConfig, FUNCTION_MSP, TELEMETRY_PORT_FUNCTIONS_MASK);
resetMspPort(mspPort, serialPort, sharedWithTelemetry);
portIndex++; portIndex++;
} }
@ -82,10 +84,12 @@ void mspSerialReleasePortIfAllocated(serialPort_t *serialPort)
#if defined(USE_TELEMETRY) #if defined(USE_TELEMETRY)
void mspSerialReleaseSharedTelemetryPorts(void) { void mspSerialReleaseSharedTelemetryPorts(void) {
serialPort_t *sharedPort = findSharedSerialPort(TELEMETRY_PORT_FUNCTIONS_MASK, FUNCTION_MSP); for (uint8_t portIndex = 0; portIndex < MAX_MSP_PORT_COUNT; portIndex++) {
while (sharedPort) { mspPort_t *candidateMspPort = &mspPorts[portIndex];
mspSerialReleasePortIfAllocated(sharedPort); if (candidateMspPort->sharedWithTelemetry) {
sharedPort = findNextSharedSerialPort(TELEMETRY_PORT_FUNCTIONS_MASK, FUNCTION_MSP); closeSerialPort(candidateMspPort->port);
memset(candidateMspPort, 0, sizeof(mspPort_t));
}
} }
} }
#endif #endif

View file

@ -96,6 +96,7 @@ typedef struct __attribute__((packed)) {
struct serialPort_s; struct serialPort_s;
typedef struct mspPort_s { typedef struct mspPort_s {
struct serialPort_s *port; // null when port unused. struct serialPort_s *port; // null when port unused.
bool sharedWithTelemetry;
timeMs_t lastActivityMs; timeMs_t lastActivityMs;
mspPendingSystemRequest_e pendingRequest; mspPendingSystemRequest_e pendingRequest;
mspState_e c_state; mspState_e c_state;