()
| 183 | } |
| 184 | |
| 185 | func (s *StackwalkDecorator) doFlush() { |
| 186 | for { |
| 187 | select { |
| 188 | case <-s.flusher.C: |
| 189 | errs := s.flush() |
| 190 | if len(errs) > 0 { |
| 191 | log.Warnf("callstack: unable to flush queued events: %v", multierror.Wrap(errs...)) |
| 192 | } |
| 193 | case <-s.quit: |
| 194 | return |
| 195 | } |
| 196 | } |
| 197 | } |
| 198 | |
| 199 | // flush pushes events to the event queue if they have |
| 200 | // been living in the queue more than the maximum allowed |
no test coverage detected