mirror of
https://github.com/Telecominfraproject/wlan-cloud-ucentralsec.git
synced 2025-10-31 18:57:51 +00:00
Compare commits
1 Commits
v4.1.0-RC1
...
v4.0.0
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
dc7b5e3b9f |
@@ -1,5 +1,5 @@
|
|||||||
cmake_minimum_required(VERSION 3.13)
|
cmake_minimum_required(VERSION 3.13)
|
||||||
project(owsec VERSION 4.1.0)
|
project(owsec VERSION 3.2.0)
|
||||||
|
|
||||||
set(CMAKE_CXX_STANDARD 17)
|
set(CMAKE_CXX_STANDARD 17)
|
||||||
|
|
||||||
|
|||||||
@@ -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: v4.1.0-RC1
|
tag: v4.0.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