()
| 459 | } |
| 460 | |
| 461 | func (l *LogSender) hasPendingWorkLocked() bool { |
| 462 | for _, q := range l.queues { |
| 463 | if time.Since(q.lastFlush) > flushInterval { |
| 464 | return true |
| 465 | } |
| 466 | if q.flushRequested { |
| 467 | return true |
| 468 | } |
| 469 | } |
| 470 | return false |
| 471 | } |
| 472 | |
| 473 | func (l *LogSender) getPendingWorkLocked() (src uuid.UUID, q *logQueue) { |
| 474 | // take the one it's been the longest since we've flushed, so that we have some sense of |