mirror of
https://github.com/zrepl/zrepl.git
synced 2024-11-22 00:13:52 +01:00
parent
0b48ba54f8
commit
2d545c87cd
@ -144,6 +144,7 @@ func (c *Conn) ReadStream(frameType uint32, closeConnOnClose bool) (_ *StreamRea
|
|||||||
|
|
||||||
c.readMtx.Lock()
|
c.readMtx.Lock()
|
||||||
if !c.readClean {
|
if !c.readClean {
|
||||||
|
c.readMtx.Unlock()
|
||||||
return nil, errWriteStreamToErrorUnknownState
|
return nil, errWriteStreamToErrorUnknownState
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user