Commit 373c219f authored by Steven Allen's avatar Steven Allen

also avoid locking while closing the varint reader/writers

parent 47494676
...@@ -49,9 +49,6 @@ func (s *varintWriter) WriteMsg(msg []byte) error { ...@@ -49,9 +49,6 @@ func (s *varintWriter) WriteMsg(msg []byte) error {
} }
func (s *varintWriter) Close() error { func (s *varintWriter) Close() error {
s.lock.Lock()
defer s.lock.Unlock()
if c, ok := s.W.(io.Closer); ok { if c, ok := s.W.(io.Closer); ok {
return c.Close() return c.Close()
} }
...@@ -162,9 +159,6 @@ func (s *varintReader) ReleaseMsg(msg []byte) { ...@@ -162,9 +159,6 @@ func (s *varintReader) ReleaseMsg(msg []byte) {
} }
func (s *varintReader) Close() error { func (s *varintReader) Close() error {
s.lock.Lock()
defer s.lock.Unlock()
if c, ok := s.R.(io.Closer); ok { if c, ok := s.R.(io.Closer); ok {
return c.Close() return c.Close()
} }
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment