Method writeLoop

io2/pipelined_copy.go:198–239

()

}

func (c *circularBufferCopier) writeLoop() {
	for {
		var buf *buffer
		select {
		case buf = <-c.readyChan:
			// do nothing
		case <-c.earlyExitChan:
			c.errChan <- nil
			return
		}

		if buf.size > 0 {
			written, err := c.dest.Write(buf.array[0:buf.size])

			c.numWritten += int64(written)

			if err != nil {
				c.errChan <- errors.Wrap(
					err,
					"Failed to write to destination: ")
				return
			}

			if written != buf.size {
				c.errChan <- errors.New(
					"Failed to write to destination: short write")
				return
			}

			if fl, ok := c.dest.(http.Flusher); ok {
				fl.Flush()
			}
		}

		if buf.eof {
			c.errChan <- nil
			return
		}

		c.recycleChan <- buf.array
	}
}