gr1ffon/quic-go
1
0
Fork 0
forked from quic-go/quic-go
Code Pull Requests Activity

Fix a data race in stream.Read

Browse Source
This commit is contained in:
Lucas Clemente
2017-04-20 17:44:59 +02:00
parent ff42100f1b
commit a7c60e3229
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
stream.go
View File

@@ -69,8 +69,11 @@ func newStream(StreamID protocol.StreamID, onData func(), onReset func(protocol.
// Read implements io.Reader. It is not thread safe! // Read implements io.Reader. It is not thread safe!
func (s *stream) Read(p []byte) (int, error) { func (s *stream) Read(p []byte) (int, error) {
s.mutex.Lock()
err := s.err
s.mutex.Unlock()
if s.cancelled.Get() || s.resetLocally.Get() { if s.cancelled.Get() || s.resetLocally.Get() {
return 0, s.err return 0, err
} }
if s.finishedReading.Get() { if s.finishedReading.Get() {
return 0, io.EOF return 0, io.EOF