mirror of
				https://github.com/Telecominfraproject/wlan-cloud-ucentralsec.git
				synced 2025-10-31 02:37:56 +00:00 
			
		
		
		
	Compare commits
	
		
			4 Commits
		
	
	
		
			release/v4
			...
			v3.2.0
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
|   | 85e24b430d | ||
|   | d5b54a67f4 | ||
|   | cb5dcde0ca | ||
|   | 7be170a0bd | 
							
								
								
									
										2
									
								
								.github/workflows/ci.yml
									
									
									
									
										vendored
									
									
								
							
							
						
						
									
										2
									
								
								.github/workflows/ci.yml
									
									
									
									
										vendored
									
									
								
							| @@ -21,7 +21,7 @@ defaults: | |||||||
|  |  | ||||||
| jobs: | jobs: | ||||||
|   docker: |   docker: | ||||||
|     runs-on: ubuntu-latest |     runs-on: ubuntu-20.04 | ||||||
|     env: |     env: | ||||||
|       DOCKER_REGISTRY_URL: tip-tip-wlan-cloud-ucentral.jfrog.io |       DOCKER_REGISTRY_URL: tip-tip-wlan-cloud-ucentral.jfrog.io | ||||||
|       DOCKER_REGISTRY_USERNAME: ucentral |       DOCKER_REGISTRY_USERNAME: ucentral | ||||||
|   | |||||||
| @@ -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 |     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 | ||||||
|   | |||||||
| @@ -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