Compare commits

..

7 Commits

Author SHA1 Message Date
TIP Automation User
1527773a7a Chg: update image tag in helm values to v3.0.2-RC1 2024-03-22 13:54:25 +00:00
jaspreetsachdev
f9dd5864fb Merge pull request #108 from Telecominfraproject/WIFI-13542
Wifi 13542
2024-03-22 09:50:09 -04:00
Carsten Schafer
20258c5885 Merge remote-tracking branch 'origin/main' into release/v3.0.0 2024-03-21 16:51:04 -04:00
TIP Automation User
fadb7405c5 Chg: update image tag in helm values to v3.0.0 2023-12-29 15:19:27 +00:00
TIP Automation User
6394fee9c0 Chg: update image tag in helm values to v3.0.0-RC2 2023-12-15 23:03:21 +00:00
Stephane Bourque
8166b75412 Merge pull request #106 from Telecominfraproject/main
https://telecominfraproject.atlassian.net/browse/WIFI-13147
2023-12-15 09:32:38 -08:00
TIP Automation User
1063080859 Chg: update image tag in helm values to v3.0.0-RC1 2023-11-27 17:38:12 +00:00
4 changed files with 5 additions and 10 deletions

View File

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

2
build
View File

@@ -1 +1 @@
1 7

View File

@@ -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: v3.1.0 tag: v3.0.2-RC1
pullPolicy: Always pullPolicy: Always
# regcred: # regcred:
# registry: tip-tip-wlan-cloud-ucentral.jfrog.io # registry: tip-tip-wlan-cloud-ucentral.jfrog.io

View File

@@ -107,7 +107,7 @@ namespace OpenWifi {
NewMessage.partition(0); NewMessage.partition(0);
NewMessage.payload(Msg->Payload()); NewMessage.payload(Msg->Payload());
Producer.produce(NewMessage); Producer.produce(NewMessage);
Producer.poll((std::chrono::milliseconds) 0); Producer.flush();
} }
} catch (const cppkafka::HandleException &E) { } catch (const cppkafka::HandleException &E) {
poco_warning(Logger_, poco_warning(Logger_,
@@ -117,13 +117,8 @@ 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();
poco_information(Logger_, "Stopped..."); poco_information(Logger_, "Stopped...");
} }
@@ -329,4 +324,4 @@ namespace OpenWifi {
partitions.front().get_partition())); partitions.front().get_partition()));
} }
} // namespace OpenWifi } // namespace OpenWifi