mirror of
https://github.com/Telecominfraproject/wlan-cloud-ucentralsec.git
synced 2025-11-01 11:17:51 +00:00
Compare commits
4 Commits
fix_improv
...
v3.2.0
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
85e24b430d | ||
|
|
d5b54a67f4 | ||
|
|
cb5dcde0ca | ||
|
|
7be170a0bd |
2
.github/workflows/ci.yml
vendored
2
.github/workflows/ci.yml
vendored
@@ -21,7 +21,7 @@ defaults:
|
|||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
docker:
|
docker:
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-20.04
|
||||||
env:
|
env:
|
||||||
DOCKER_REGISTRY_URL: tip-tip-wlan-cloud-ucentral.jfrog.io
|
DOCKER_REGISTRY_URL: tip-tip-wlan-cloud-ucentral.jfrog.io
|
||||||
DOCKER_REGISTRY_USERNAME: ucentral
|
DOCKER_REGISTRY_USERNAME: ucentral
|
||||||
|
|||||||
@@ -9,7 +9,7 @@ fullnameOverride: ""
|
|||||||
images:
|
images:
|
||||||
owsec:
|
owsec:
|
||||||
repository: tip-tip-wlan-cloud-ucentral.jfrog.io/owsec
|
repository: tip-tip-wlan-cloud-ucentral.jfrog.io/owsec
|
||||||
tag: main
|
tag: v3.2.0
|
||||||
pullPolicy: Always
|
pullPolicy: Always
|
||||||
# regcred:
|
# regcred:
|
||||||
# registry: tip-tip-wlan-cloud-ucentral.jfrog.io
|
# registry: tip-tip-wlan-cloud-ucentral.jfrog.io
|
||||||
|
|||||||
@@ -118,10 +118,6 @@ namespace OpenWifi {
|
|||||||
Producer.poll((std::chrono::milliseconds) 0);
|
Producer.poll((std::chrono::milliseconds) 0);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (Queue_.size() == 0) {
|
|
||||||
// message queue is empty, flush all previously sent messages
|
|
||||||
Producer.flush();
|
|
||||||
}
|
|
||||||
} catch (const cppkafka::HandleException &E) {
|
} catch (const cppkafka::HandleException &E) {
|
||||||
poco_warning(Logger_,
|
poco_warning(Logger_,
|
||||||
fmt::format("Caught a Kafka exception (producer): {}", E.what()));
|
fmt::format("Caught a Kafka exception (producer): {}", E.what()));
|
||||||
@@ -130,6 +126,10 @@ namespace OpenWifi {
|
|||||||
} catch (...) {
|
} catch (...) {
|
||||||
poco_error(Logger_, "std::exception");
|
poco_error(Logger_, "std::exception");
|
||||||
}
|
}
|
||||||
|
if (Queue_.size() == 0) {
|
||||||
|
// message queue is empty, flush all previously sent messages
|
||||||
|
Producer.flush();
|
||||||
|
}
|
||||||
Note = Queue_.waitDequeueNotification();
|
Note = Queue_.waitDequeueNotification();
|
||||||
}
|
}
|
||||||
Producer.flush();
|
Producer.flush();
|
||||||
|
|||||||
Reference in New Issue
Block a user