do nothing on default case in processPodEvent
This commit is contained in:
		
							parent
							
								
									bcd34c3110
								
							
						
					
					
						commit
						cc4920fb5d
					
				| 
						 | 
					@ -1046,8 +1046,8 @@ func (c *Cluster) processPodEvent(obj interface{}) error {
 | 
				
			||||||
		select {
 | 
							select {
 | 
				
			||||||
		case <-subscriber.stopEvent:
 | 
							case <-subscriber.stopEvent:
 | 
				
			||||||
			c.unregisterPodSubscriber(podName)
 | 
								c.unregisterPodSubscriber(podName)
 | 
				
			||||||
 | 
							case subscriber.podEvents <- event:
 | 
				
			||||||
		default:
 | 
							default:
 | 
				
			||||||
			subscriber.podEvents <- event
 | 
					 | 
				
			||||||
		}
 | 
							}
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
	// hold lock for the time of processing the event to avoid race condition
 | 
						// hold lock for the time of processing the event to avoid race condition
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
		Loading…
	
		Reference in New Issue