Compare commits

...

7 Commits

Author SHA1 Message Date
TIP Automation User
65a8fd866b Chg: update image tag in helm values to v4.1.0 2025-09-08 18:52:24 +00:00
TIP Automation User
57198903cd Chg: update image tag in helm values to v4.1.0-RC1 2025-08-28 12:12:18 +00:00
Carsten Schafer
7ebb9dbe14 Merge pull request #117 from Telecominfraproject/WIFI-13821-bump-versions
WIFI-13821 version set to 4.1.0
2025-08-01 08:58:28 -04:00
Carsten Schafer
b51148e9c6 version set to 4.1.0
Signed-off-by: Carsten Schafer <Carsten.Schafer@kinarasystems.com>
2025-08-01 08:30:47 -04:00
i-chvets
966ddd3cbf Merge pull request #115 from Telecominfraproject/fix_improve_exeception_handling
Exception handling improvement.
2025-05-16 10:05:29 -04:00
Ivan Chvets
2781342aa5 Merge branch 'main' of github.com:Telecominfraproject/wlan-cloud-ucentralsec into fix_improve_exeception_handling 2025-05-02 10:59:09 -04:00
Ivan Chvets
9d3fe561a4 Exception handling improvement. Details in: https://telecominfraproject.atlassian.net/browse/WIFI-14038
Signed-off-by: Ivan Chvets <ivan.chvets@kinarasystems.com>
2025-05-01 17:51:06 -04:00
3 changed files with 6 additions and 6 deletions

View File

@@ -1,5 +1,5 @@
cmake_minimum_required(VERSION 3.13)
project(owsec VERSION 3.2.0)
project(owsec VERSION 4.1.0)
set(CMAKE_CXX_STANDARD 17)

View File

@@ -9,7 +9,7 @@ fullnameOverride: ""
images:
owsec:
repository: tip-tip-wlan-cloud-ucentral.jfrog.io/owsec
tag: main
tag: v4.1.0
pullPolicy: Always
# regcred:
# registry: tip-tip-wlan-cloud-ucentral.jfrog.io

View File

@@ -118,6 +118,10 @@ namespace OpenWifi {
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) {
poco_warning(Logger_,
fmt::format("Caught a Kafka exception (producer): {}", E.what()));
@@ -126,10 +130,6 @@ namespace OpenWifi {
} catch (...) {
poco_error(Logger_, "std::exception");
}
if (Queue_.size() == 0) {
// message queue is empty, flush all previously sent messages
Producer.flush();
}
Note = Queue_.waitDequeueNotification();
}
Producer.flush();