mirror of
				https://github.com/Telecominfraproject/wlan-cloud-ucentralsec.git
				synced 2025-10-31 02:37:56 +00:00 
			
		
		
		
	Compare commits
	
		
			9 Commits
		
	
	
		
			release/v3
			...
			release/v3
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
|   | 85e24b430d | ||
|   | d5b54a67f4 | ||
|   | cb5dcde0ca | ||
|   | 1977ecdfb7 | ||
|   | 7be170a0bd | ||
|   | 1d703e1737 | ||
|   | 22ddb40d4c | ||
|   | 791b72aec4 | ||
|   | bb09f919e6 | 
| @@ -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.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: main |     tag: v3.2.0 | ||||||
|     pullPolicy: Always |     pullPolicy: Always | ||||||
| #    regcred: | #    regcred: | ||||||
| #      registry: tip-tip-wlan-cloud-ucentral.jfrog.io | #      registry: tip-tip-wlan-cloud-ucentral.jfrog.io | ||||||
|   | |||||||
| @@ -107,7 +107,16 @@ 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); | 					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) { | 			} catch (const cppkafka::HandleException &E) { | ||||||
| 				poco_warning(Logger_, | 				poco_warning(Logger_, | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user