mirror of
				https://github.com/Telecominfraproject/wlan-cloud-ucentralsec.git
				synced 2025-10-31 18:57:51 +00:00 
			
		
		
		
	Compare commits
	
		
			7 Commits
		
	
	
		
			release/v4
			...
			v4.1.0
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
|   | 65a8fd866b | ||
|   | 57198903cd | ||
|   | 7ebb9dbe14 | ||
|   | b51148e9c6 | ||
|   | 966ddd3cbf | ||
|   | 2781342aa5 | ||
|   | 9d3fe561a4 | 
| @@ -1,5 +1,5 @@ | |||||||
| cmake_minimum_required(VERSION 3.13) | cmake_minimum_required(VERSION 3.13) | ||||||
| project(owsec VERSION 3.2.0) | project(owsec VERSION 4.1.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: main |     tag: v4.1.0 | ||||||
|     pullPolicy: Always |     pullPolicy: Always | ||||||
| #    regcred: | #    regcred: | ||||||
| #      registry: tip-tip-wlan-cloud-ucentral.jfrog.io | #      registry: tip-tip-wlan-cloud-ucentral.jfrog.io | ||||||
|   | |||||||
| @@ -118,6 +118,10 @@ 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())); | ||||||
| @@ -126,10 +130,6 @@ 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