scottk/wlan-cloud-ucentralgw
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-ucentralgw.git synced 2025-10-29 09:52:27 +00:00
Code Issues Packages Projects Releases 10 Wiki Activity

Merge pull request #246 from Telecominfraproject/WIFI-10846

Browse Source 
https://telecominfraproject.atlassian.net/browse/WIFI-10846
This commit is contained in:
Stephane Bourque
2022-09-29 12:31:54 -07:00
committed by GitHub
parent 08b2d7a278 c31ea8f632
commit 9c08f5194b
3 changed files with 17 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
build
View File

@@ -1 +1 @@
124
125

22
src/CommandManager.cpp
View File

@@ -130,6 +130,16 @@ namespace OpenWifi {
fmt::format("Outstanding-requests {}", OutStandingRequests_.size()));
}
bool CommandManager::IsCommandRunning(const std::string &C) {
std::shared_lock Lock(LocalMutex_);
for (const auto &request : OutStandingRequests_) {
if (request.second.UUID == C) {
return true;
}
}
return false;
}
void CommandManager::onCommandRunnerTimer([[maybe_unused]] Poco::Timer &timer) {
Utils::SetThreadName("cmd:schdlr");
Poco::Logger &MyLogger = Poco::Logger::get("CMD-MGR-SCHEDULER");
@@ -153,14 +163,10 @@ namespace OpenWifi {
MyLogger, fmt::format("{}: Serial={} Command={} Starting processing.",
Cmd.UUID, Cmd.SerialNumber, Cmd.Command));
try {
{
std::shared_lock Lock(LocalMutex_);
for (const auto &request : OutStandingRequests_) {
if (request.second.UUID == Cmd.UUID) {
continue;
}
}
}
// Skip an already running command
if(IsCommandRunning(Cmd.UUID))
continue;
auto now = OpenWifi::Now();
// 2 hour timeout for commands

2
src/CommandManager.h
View File

@@ -132,6 +132,8 @@ namespace OpenWifi {
false, Sent );
}
bool IsCommandRunning(const std::string &C);
void run() override;
static auto instance() {