Blame vendor/github.com/valyala/bytebufferpool/bytebuffer.go

Packit Service 509fd4
package bytebufferpool
Packit Service 509fd4
Packit Service 509fd4
import "io"
Packit Service 509fd4
Packit Service 509fd4
// ByteBuffer provides byte buffer, which can be used for minimizing
Packit Service 509fd4
// memory allocations.
Packit Service 509fd4
//
Packit Service 509fd4
// ByteBuffer may be used with functions appending data to the given []byte
Packit Service 509fd4
// slice. See example code for details.
Packit Service 509fd4
//
Packit Service 509fd4
// Use Get for obtaining an empty byte buffer.
Packit Service 509fd4
type ByteBuffer struct {
Packit Service 509fd4
Packit Service 509fd4
	// B is a byte buffer to use in append-like workloads.
Packit Service 509fd4
	// See example code for details.
Packit Service 509fd4
	B []byte
Packit Service 509fd4
}
Packit Service 509fd4
Packit Service 509fd4
// Len returns the size of the byte buffer.
Packit Service 509fd4
func (b *ByteBuffer) Len() int {
Packit Service 509fd4
	return len(b.B)
Packit Service 509fd4
}
Packit Service 509fd4
Packit Service 509fd4
// ReadFrom implements io.ReaderFrom.
Packit Service 509fd4
//
Packit Service 509fd4
// The function appends all the data read from r to b.
Packit Service 509fd4
func (b *ByteBuffer) ReadFrom(r io.Reader) (int64, error) {
Packit Service 509fd4
	p := b.B
Packit Service 509fd4
	nStart := int64(len(p))
Packit Service 509fd4
	nMax := int64(cap(p))
Packit Service 509fd4
	n := nStart
Packit Service 509fd4
	if nMax == 0 {
Packit Service 509fd4
		nMax = 64
Packit Service 509fd4
		p = make([]byte, nMax)
Packit Service 509fd4
	} else {
Packit Service 509fd4
		p = p[:nMax]
Packit Service 509fd4
	}
Packit Service 509fd4
	for {
Packit Service 509fd4
		if n == nMax {
Packit Service 509fd4
			nMax *= 2
Packit Service 509fd4
			bNew := make([]byte, nMax)
Packit Service 509fd4
			copy(bNew, p)
Packit Service 509fd4
			p = bNew
Packit Service 509fd4
		}
Packit Service 509fd4
		nn, err := r.Read(p[n:])
Packit Service 509fd4
		n += int64(nn)
Packit Service 509fd4
		if err != nil {
Packit Service 509fd4
			b.B = p[:n]
Packit Service 509fd4
			n -= nStart
Packit Service 509fd4
			if err == io.EOF {
Packit Service 509fd4
				return n, nil
Packit Service 509fd4
			}
Packit Service 509fd4
			return n, err
Packit Service 509fd4
		}
Packit Service 509fd4
	}
Packit Service 509fd4
}
Packit Service 509fd4
Packit Service 509fd4
// WriteTo implements io.WriterTo.
Packit Service 509fd4
func (b *ByteBuffer) WriteTo(w io.Writer) (int64, error) {
Packit Service 509fd4
	n, err := w.Write(b.B)
Packit Service 509fd4
	return int64(n), err
Packit Service 509fd4
}
Packit Service 509fd4
Packit Service 509fd4
// Bytes returns b.B, i.e. all the bytes accumulated in the buffer.
Packit Service 509fd4
//
Packit Service 509fd4
// The purpose of this function is bytes.Buffer compatibility.
Packit Service 509fd4
func (b *ByteBuffer) Bytes() []byte {
Packit Service 509fd4
	return b.B
Packit Service 509fd4
}
Packit Service 509fd4
Packit Service 509fd4
// Write implements io.Writer - it appends p to ByteBuffer.B
Packit Service 509fd4
func (b *ByteBuffer) Write(p []byte) (int, error) {
Packit Service 509fd4
	b.B = append(b.B, p...)
Packit Service 509fd4
	return len(p), nil
Packit Service 509fd4
}
Packit Service 509fd4
Packit Service 509fd4
// WriteByte appends the byte c to the buffer.
Packit Service 509fd4
//
Packit Service 509fd4
// The purpose of this function is bytes.Buffer compatibility.
Packit Service 509fd4
//
Packit Service 509fd4
// The function always returns nil.
Packit Service 509fd4
func (b *ByteBuffer) WriteByte(c byte) error {
Packit Service 509fd4
	b.B = append(b.B, c)
Packit Service 509fd4
	return nil
Packit Service 509fd4
}
Packit Service 509fd4
Packit Service 509fd4
// WriteString appends s to ByteBuffer.B.
Packit Service 509fd4
func (b *ByteBuffer) WriteString(s string) (int, error) {
Packit Service 509fd4
	b.B = append(b.B, s...)
Packit Service 509fd4
	return len(s), nil
Packit Service 509fd4
}
Packit Service 509fd4
Packit Service 509fd4
// Set sets ByteBuffer.B to p.
Packit Service 509fd4
func (b *ByteBuffer) Set(p []byte) {
Packit Service 509fd4
	b.B = append(b.B[:0], p...)
Packit Service 509fd4
}
Packit Service 509fd4
Packit Service 509fd4
// SetString sets ByteBuffer.B to s.
Packit Service 509fd4
func (b *ByteBuffer) SetString(s string) {
Packit Service 509fd4
	b.B = append(b.B[:0], s...)
Packit Service 509fd4
}
Packit Service 509fd4
Packit Service 509fd4
// String returns string representation of ByteBuffer.B.
Packit Service 509fd4
func (b *ByteBuffer) String() string {
Packit Service 509fd4
	return string(b.B)
Packit Service 509fd4
}
Packit Service 509fd4
Packit Service 509fd4
// Reset makes ByteBuffer.B empty.
Packit Service 509fd4
func (b *ByteBuffer) Reset() {
Packit Service 509fd4
	b.B = b.B[:0]
Packit Service 509fd4
}