()
| 40 | } |
| 41 | |
| 42 | func (c *Controller) processStrategyEventForever() { |
| 43 | c.eventQueuesMutex.RLock() |
| 44 | defer c.eventQueuesMutex.RUnlock() |
| 45 | for _, queue := range c.eventQueues { |
| 46 | lg.Info("process queue event %s", queue.name) |
| 47 | go processSingleQueue(queue) |
| 48 | } |
| 49 | } |
| 50 | |
| 51 | //TODO: fix when product delete, goroutine leak |
| 52 | func processSingleQueue(queue *EventPool) { |
no test coverage detected