gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #280 from znly/master

Browse Source 
Concurrent map access in server/route.go
This commit is contained in:
Derek Collison
2016-05-20 09:16:14 -07:00
parent 074c8ce9f4 1eb12a1501
commit 68e8b83fcd
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
server/route.go
View File

@@ -423,7 +423,10 @@ func (s *Server) routeSidQueueSubscriber(rsid []byte) (*subscription, bool) {
}
sid := matches[RSID_SID_INDEX]
if sub, ok := client.subs[string(sid)]; ok {
client.mu.Lock()
sub, ok := client.subs[string(sid)]
client.mu.Unlock()
if ok {
return sub, true
}
return nil, true