forked from mirror/redis
Remove unused code
This commit is contained in:
parent
33287c7c34
commit
8ebf0b7750
|
@ -40,13 +40,6 @@ func (b *ElasticBufReader) ResetBuffer(buf []byte) {
|
||||||
b.err = nil
|
b.err = nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (b *ElasticBufReader) reset(buf []byte, rd io.Reader) {
|
|
||||||
*b = ElasticBufReader{
|
|
||||||
buf: buf,
|
|
||||||
rd: rd,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Buffered returns the number of bytes that can be read from the current buffer.
|
// Buffered returns the number of bytes that can be read from the current buffer.
|
||||||
func (b *ElasticBufReader) Buffered() int {
|
func (b *ElasticBufReader) Buffered() int {
|
||||||
return b.w - b.r
|
return b.w - b.r
|
||||||
|
|
|
@ -8,8 +8,6 @@ import (
|
||||||
"github.com/go-redis/redis/internal/util"
|
"github.com/go-redis/redis/internal/util"
|
||||||
)
|
)
|
||||||
|
|
||||||
const bytesAllocLimit = 1024 * 1024 // 1mb
|
|
||||||
|
|
||||||
const (
|
const (
|
||||||
ErrorReply = '-'
|
ErrorReply = '-'
|
||||||
StatusReply = '+'
|
StatusReply = '+'
|
||||||
|
|
Loading…
Reference in New Issue