Compare commits

...

9 Commits

Author SHA1 Message Date
TIP Automation User
85e24b430d Chg: update image tag in helm values to v3.2.0 2024-10-04 15:54:29 +00:00
TIP Automation User
d5b54a67f4 Chg: update image tag in helm values to v3.2.0-RC2 2024-09-30 23:10:50 +00:00
i-chvets
cb5dcde0ca Merge pull request #114 from Telecominfraproject/version_update
WIFI-14165: release 3.2 version update
2024-09-30 11:02:08 -04:00
Ivan Chvets
1977ecdfb7 fix: release 3.2 version update
https://telecominfraproject.atlassian.net/browse/WIFI-14165

Signed-off-by: Ivan Chvets <ivan.chvets@kinarasystems.com>
2024-09-30 09:35:21 -04:00
TIP Automation User
7be170a0bd Chg: update image tag in helm values to v3.2.0-RC1 2024-09-11 17:50:51 +00:00
i-chvets
1d703e1737 Merge pull request #111 from Telecominfraproject/WIFI-13857-fix-svc-kafka-startup
WIFI-13857: fix: modified code to use flush() when internal queue is not loaded
2024-06-19 16:59:56 -04:00
Ivan Chvets
22ddb40d4c fix: modified code to use flush() when internal queue is not loaded
https://telecominfraproject.atlassian.net/browse/WIFI-13857

NOTE: This is port of https://github.com/Telecominfraproject/wlan-cloud-ucentralgw/pull/362

Signed-off-by: Ivan Chvets <ivan.chvets@kinarasystems.com>
2024-06-19 16:43:47 -04:00
i-chvets
791b72aec4 Merge pull request #110 from Telecominfraproject/WIFI-13597-fix-kafka-producer-using-poll
fix: added flush() for proper shutdown
2024-06-17 09:23:11 -04:00
i-chvets
bb09f919e6 Merge pull request #109 from Telecominfraproject/WIFI-13597-fix-kafka-producer-using-poll
fix: modified kafka manager to use poll in producer
2024-06-13 14:35:18 -04:00
3 changed files with 12 additions and 3 deletions

View File

@@ -1,5 +1,5 @@
cmake_minimum_required(VERSION 3.13)
project(owsec VERSION 3.1.0)
project(owsec VERSION 3.2.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: v3.2.0
pullPolicy: Always
# regcred:
# registry: tip-tip-wlan-cloud-ucentral.jfrog.io

View File

@@ -107,7 +107,16 @@ namespace OpenWifi {
NewMessage.partition(0);
NewMessage.payload(Msg->Payload());
Producer.produce(NewMessage);
Producer.poll((std::chrono::milliseconds) 0);
if (Queue_.size() < 100) {
// use flush when internal queue is lightly loaded, i.e. flush after each
// message
Producer.flush();
}
else {
// use poll when internal queue is loaded to allow messages to be sent in
// batches
Producer.poll((std::chrono::milliseconds) 0);
}
}
} catch (const cppkafka::HandleException &E) {
poco_warning(Logger_,