From 4f49a242ff3b3789b5f3b36fa3f522fd04bb2ade Mon Sep 17 00:00:00 2001
From: Marten Seemann <martenseemann@gmail.com>
Date: Tue, 7 Jun 2016 10:42:30 +0700
Subject: [PATCH] fix race condition in BlockedManager

---
 blocked_manager.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/blocked_manager.go b/blocked_manager.go
index a16f41bd3..f4cc6c21a 100644
--- a/blocked_manager.go
+++ b/blocked_manager.go
@@ -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 {