Loading mb/mb.go +0 −60 Original line number Diff line number Diff line Loading @@ -21,63 +21,3 @@ func (mb *MutexBuffer) Write(p []byte) (n int, err error) { defer mb.mutex.Unlock() 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) //} Loading
mb/mb.go +0 −60 Original line number Diff line number Diff line Loading @@ -21,63 +21,3 @@ func (mb *MutexBuffer) Write(p []byte) (n int, err error) { defer mb.mutex.Unlock() 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) //}