Rooba
/
perkeep
mirror of https://github.com/perkeep/perkeep.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

search: fix websocket crash 

Fixes #563

Change-Id: Iff04e4a40406ddd391f3c8fc93dcfe0209806ee3
This commit is contained in:
Brad Fitzpatrick 2015-01-19 09:29:19 -08:00
parent 3026631521
commit 5c2ad4eaae
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/search/websocket.go
View File

@ -57,8 +57,8 @@ type wsHub struct {
func newWebsocketHub(sh *Handler) *wsHub { func newWebsocketHub(sh *Handler) *wsHub {
return &wsHub{ return &wsHub{
sh: sh, sh: sh,
register: make(chan *wsConn, buffered), register: make(chan *wsConn), // unbuffered; issue 563
unregister: make(chan *wsConn, buffered), unregister: make(chan *wsConn), // unbuffered; issue 563
conns: make(map[*wsConn]bool), conns: make(map[*wsConn]bool),
watchReq: make(chan watchReq, buffered), watchReq: make(chan watchReq, buffered),
newBlobRecv: make(chan string, buffered), newBlobRecv: make(chan string, buffered),
@ -173,6 +173,7 @@ type wsConn struct {
send chan []byte // Buffered channel of outbound messages. send chan []byte // Buffered channel of outbound messages.
sh *Handler sh *Handler
// queries is owned by the wsHub.run goroutine.
queries map[string]*watchedQuery // tag -> subscription queries map[string]*watchedQuery // tag -> subscription
} }