mirror of
				https://github.com/Telecominfraproject/wlan-cloud-ucentralsec.git
				synced 2025-10-31 18:57:51 +00:00 
			
		
		
		
	Compare commits
	
		
			4 Commits
		
	
	
		
			fix_improv
			...
			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: | ||||
|   docker: | ||||
|     runs-on: ubuntu-latest | ||||
|     runs-on: ubuntu-20.04 | ||||
|     env: | ||||
|       DOCKER_REGISTRY_URL: tip-tip-wlan-cloud-ucentral.jfrog.io | ||||
|       DOCKER_REGISTRY_USERNAME: ucentral | ||||
|   | ||||
| @@ -9,7 +9,7 @@ fullnameOverride: "" | ||||
| images: | ||||
|   owsec: | ||||
|     repository: tip-tip-wlan-cloud-ucentral.jfrog.io/owsec | ||||
|     tag: main | ||||
|     tag: v3.2.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