mirror of
				https://github.com/Telecominfraproject/wlan-cloud-ucentralsec.git
				synced 2025-10-30 18:27:49 +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) | ||||
| project(owsec VERSION 4.1.0) | ||||
| project(owsec VERSION 3.2.0) | ||||
|  | ||||
| set(CMAKE_CXX_STANDARD 17) | ||||
|  | ||||
|   | ||||
| @@ -9,7 +9,7 @@ fullnameOverride: "" | ||||
| images: | ||||
|   owsec: | ||||
|     repository: tip-tip-wlan-cloud-ucentral.jfrog.io/owsec | ||||
|     tag: v4.1.0-RC1 | ||||
|     tag: v4.0.0 | ||||
|     pullPolicy: Always | ||||
| #    regcred: | ||||
| #      registry: tip-tip-wlan-cloud-ucentral.jfrog.io | ||||
|   | ||||
| @@ -118,10 +118,6 @@ 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())); | ||||
| @@ -130,6 +126,10 @@ 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(); | ||||
|   | ||||
		Reference in New Issue
	
	Block a user