- // Fails all entries, that were flushed in shutdownOffset (became uncompleted)
- // - they will never be completed due to disconnected channel.
- lockedFailSegments(uncompletedSegments.iterator());
- // If no further flush is needed, than we fail all unflushed segments, so that each enqueued entry
- // is reported as unsuccessful due to channel disconnection. No further entries should be enqueued
- // by this time.
- needsFlush = needsFlush();
- if (!needsFlush) {
- lockedFailSegments(unflushedSegments.iterator());
- }