adam/LoRa_APRS_iGate
1
0
Fork 0
mirror of https://github.com/richonguzman/LoRa_APRS_iGate.git synced 2026-08-07 01:13:28 +02:00
Code Issues Packages Projects Releases Wiki Activity

small code cleaning on 25SecBuffer

Browse Source
This commit is contained in:
richonguzman
2024-11-16 08:02:15 -03:00
parent 3d01ea03c0
commit 57f720b0d1
2 changed files with 9 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/station_utils.cpp
+8 -19
View File
@@ -72,32 +72,21 @@ namespace STATION_Utils {
}
void clean25SegBuffer() {
if (!packet25SegBuffer.empty()) {
if ((millis() - packet25SegBuffer[0].receivedTime) > 25 * 1000) {
packet25SegBuffer.erase(packet25SegBuffer.begin());
}
}
if (!packet25SegBuffer.empty() && (millis() - packet25SegBuffer[0].receivedTime) > 25 * 1000) packet25SegBuffer.erase(packet25SegBuffer.begin());
}
bool check25SegBuffer(const String& station, const String& textMessage) {
bool shouldBeIgnored = false;
if (!packet25SegBuffer.empty()) {
for (int i = 0; i < packet25SegBuffer.size(); i++) {
if (packet25SegBuffer[i].station == station && packet25SegBuffer[i].payload == textMessage) {
shouldBeIgnored = true;
}
if (packet25SegBuffer[i].station == station && packet25SegBuffer[i].payload == textMessage) return false;
}
}
if (shouldBeIgnored) {
return false;
} else {
Packet25SegBuffer packet;
packet.receivedTime = millis();
packet.station = station;
packet.payload = textMessage;
packet25SegBuffer.push_back(packet);
return true;
}
Packet25SegBuffer packet;
packet.receivedTime = millis();
packet.station = station;
packet.payload = textMessage;
packet25SegBuffer.push_back(packet);
return true;
}
void processOutputPacketBuffer() {