Method WriteAt

lib/model/sharedpullerstate.go:108–112

WriteAt itself is goroutine safe, thus just needs to acquire a read-lock to prevent closing concurrently (see SyncClose).

(p []byte, off int64)

// WriteAt itself is goroutine safe, thus just needs to acquire a read-lock to
// prevent closing concurrently (see SyncClose).
func (w *lockedWriterAt) WriteAt(p []byte, off int64) (n int, err error) {
	w.mut.RLock()
	defer w.mut.RUnlock()
	return w.fd.WriteAt(p, off)
}

// SyncClose ensures that no more writes are happening before going ahead and
// syncing and closing the fd, thus needs to acquire a write-lock.