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

fix race condition in BlockedManager

Browse Source
This commit is contained in:
Marten Seemann
2016-06-07 10:42:30 +07:00
parent 0d6dbfe746
commit 4f49a242ff
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
blocked_manager.go
View File

@@ -9,7 +9,7 @@ import (
type blockedManager struct {
blockedStreams map[protocol.StreamID]protocol.ByteCount
mutex sync.RWMutex
mutex sync.Mutex
}
func newBlockedManager() *blockedManager {
@@ -33,8 +33,8 @@ func (m *blockedManager) RemoveBlockedStream(streamID protocol.StreamID) {
}
func (m *blockedManager) GetBlockedFrame(streamID protocol.StreamID, offset protocol.ByteCount) *frames.BlockedFrame {
m.mutex.RLock()
defer m.mutex.RUnlock()
m.mutex.Lock()
defer m.mutex.Unlock()
blockedOffset, ok := m.blockedStreams[streamID]
if !ok {