diff --git a/utils/conn.go b/utils/conn.go index 40f658c..f7c9941 100755 --- a/utils/conn.go +++ b/utils/conn.go @@ -113,7 +113,7 @@ func (s *SnappyConn) Read(b []byte) (n int, err error) { n = 0 } }() - if n, err = s.r.Read(b); err != nil { + if n, err = s.r.Read(b); err != nil || err == io.EOF { return } if s.crypt { diff --git a/utils/util.go b/utils/util.go index f631f3a..669bd5a 100755 --- a/utils/util.go +++ b/utils/util.go @@ -153,7 +153,7 @@ func GetIntNoerrByStr(str string) int { var bufPool = sync.Pool{ New: func() interface{} { - return make([]byte, 65535) + return make([]byte, 65536) }, } // io.copy的优化版,读取buffer长度原为32*1024,与snappy不同,导致读取出的内容存在差异,不利于解密,特此修改