Method Stop

zapcore/buffered_write_syncer.go:190–220

Stop closes the buffer, cleans up background goroutines, and flushes remaining unwritten data.

()

// Stop closes the buffer, cleans up background goroutines, and flushes
// remaining unwritten data.
func (s *BufferedWriteSyncer) Stop() (err error) {
	// Critical section.
	stopped := func() bool {
		s.mu.Lock()
		defer s.mu.Unlock()

		if !s.initialized {
			return false
		}

		if s.stopped {
			return false
		}
		s.stopped = true

		s.ticker.Stop()
		close(s.stop) // tell flushLoop to stop
		return true
	}()

	// Not initialized, or already stopped, no need for any cleanup.
	if !stopped {
		return
	}

	// Wait for flushLoop to end outside of the lock, as it may need the lock to complete.
	// See https://github.com/uber-go/zap/issues/1428 for details.
	<-s.done

	return s.Sync()
}