Method Write

repo/object/object_writer.go:113–139

(data []byte)

}

func (w *objectWriter) Write(data []byte) (n int, err error) {
	w.mu.Lock()
	defer w.mu.Unlock()

	dataLen := len(data)
	w.totalLength += int64(dataLen)

	for len(data) > 0 {
		n := w.splitter.NextSplitPoint(data)
		if n < 0 {
			// no split points in the buffer
			w.buffer.Append(data)
			break
		}

		// found a split point after `n` bytes, write first n bytes then flush and repeat with the remainder.
		w.buffer.Append(data[0:n])

		if err := w.flushBufferLocked(); err != nil {
			return 0, err
		}

		data = data[n:]
	}

	return dataLen, nil
}

// +checklocks:w.mu
func (w *objectWriter) flushBufferLocked() error {