only use required interface functions (814d0734) · Commits · bsmrgo / get

mb/mb.go

+59 −53

Original line number	Diff line number	Diff line
		@@ -22,56 +22,62 @@ func (mb *MutexBuffer) Write(p []byte) (n int, err error) {
		return mb.buffer.Write(p)
		}

		func (mb *MutexBuffer) String() string {
		mb.mutex.Lock()
		defer mb.mutex.Unlock()
		return mb.buffer.String()
		}

		func (mb *MutexBuffer) Reset() {
		mb.mutex.Lock()
		defer mb.mutex.Unlock()
		mb.buffer.Reset()
		}

		func (mb *MutexBuffer) Truncate(n int) {
		mb.mutex.Lock()
		defer mb.mutex.Unlock()
		mb.buffer.Truncate(n)
		}

		func (mb *MutexBuffer) Bytes() []byte {
		mb.mutex.Lock()
		defer mb.mutex.Unlock()
		return mb.buffer.Bytes()
		}
		func (b *MutexBuffer) Cap() int {
		b.mutex.Lock()
		defer b.mutex.Unlock()
		return b.buffer.Cap()
		}
		func (mb *MutexBuffer) Grow(n int) {
		mb.mutex.Lock()
		defer mb.mutex.Unlock()
		mb.buffer.Grow(n)
		}
		func (mb *MutexBuffer) Len() int {
		mb.mutex.Lock()
		defer mb.mutex.Unlock()
		return mb.buffer.Len()
		}
		func (mb *MutexBuffer) Next(n int) []byte {
		mb.mutex.Lock()
		defer mb.mutex.Unlock()
		return mb.buffer.Next(n)
		}
		func (mb *MutexBuffer) ReadByte() (c byte, err error) {
		mb.mutex.Lock()
		defer mb.mutex.Unlock()
		return mb.buffer.ReadByte()
		}
		func (mb *MutexBuffer) ReadBytes(delim byte) (line []byte, err error) {
		mb.mutex.Lock()
		defer mb.mutex.Unlock()
		return mb.buffer.ReadBytes(delim)
		}
		//func (mb *MutexBuffer) String() string {
		// mb.mutex.Lock()
		// defer mb.mutex.Unlock()
		// return mb.buffer.String()
		//}
		//
		//func (mb *MutexBuffer) Reset() {
		// mb.mutex.Lock()
		// defer mb.mutex.Unlock()
		// mb.buffer.Reset()
		//}
		//
		//func (mb *MutexBuffer) Truncate(n int) {
		// mb.mutex.Lock()
		// defer mb.mutex.Unlock()
		// mb.buffer.Truncate(n)
		//}
		//
		//func (mb *MutexBuffer) Bytes() []byte {
		// mb.mutex.Lock()
		// defer mb.mutex.Unlock()
		// return mb.buffer.Bytes()
		//}
		//
		//func (b *MutexBuffer) Cap() int {
		// b.mutex.Lock()
		// defer b.mutex.Unlock()
		// return b.buffer.Cap()
		//}
		//
		//func (mb *MutexBuffer) Grow(n int) {
		// mb.mutex.Lock()
		// defer mb.mutex.Unlock()
		// mb.buffer.Grow(n)
		//}
		//
		//func (mb *MutexBuffer) Len() int {
		// mb.mutex.Lock()
		// defer mb.mutex.Unlock()
		// return mb.buffer.Len()
		//}
		//
		//func (mb *MutexBuffer) Next(n int) []byte {
		// mb.mutex.Lock()
		// defer mb.mutex.Unlock()
		// return mb.buffer.Next(n)
		//}
		//
		//func (mb *MutexBuffer) ReadByte() (c byte, err error) {
		// mb.mutex.Lock()
		// defer mb.mutex.Unlock()
		// return mb.buffer.ReadByte()
		//}
		//
		//func (mb *MutexBuffer) ReadBytes(delim byte) (line []byte, err error) {
		// mb.mutex.Lock()
		// defer mb.mutex.Unlock()
		// return mb.buffer.ReadBytes(delim)
		//}