()
| 391 | } |
| 392 | |
| 393 | func (s *cappedWriteSyncer) Sync() error { |
| 394 | s.mu.Lock() |
| 395 | defer s.mu.Unlock() |
| 396 | return s.inner.Sync() |
| 397 | } |
| 398 | |
| 399 | func (s *cappedWriteSyncer) Capped() bool { return s.capped.Load() } |
| 400 | func (s *cappedWriteSyncer) Written() int64 { return s.written.Load() } |