in galog.go [714:731]
func (lg *logger) flushEnqueuedEntries(ctx context.Context, bq *BackendQueue) {
var success int
bq.entriesMutex.Lock()
defer bq.entriesMutex.Unlock()
for _, curr := range bq.entries {
if ctx.Err() != nil {
break
}
if err := bq.backend.Log(curr); err != nil {
break
}
success++
}
if len(bq.entries) > 0 && success > 0 {
bq.entries = bq.entries[success:]
}
}