IntenseWebs/mattermost
3
0
Fork 0
mirror of https://github.com/mattermost/mattermost.git synced 2025-02-25 18:55:24 -06:00
Code Issues Packages Projects Releases Wiki Activity

Fixing websocket unregister so it unregisters from the correct hub. (#4452)

Browse Source
This commit is contained in:
Christopher Speller
2016-11-04 13:43:49 -04:00
committed by Harrison Healey
parent e63e80dee0
commit ec7f3ceee8
1 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
api/web_hub.go
View File

@@ -69,17 +69,19 @@ func HubStop() {
hubs = make([]*Hub, 0)
}
func HubRegister(webConn *WebConn) {
func GetHubForUserId(userId string) *Hub {
hash := fnv.New32a()
hash.Write([]byte(webConn.UserId))
hash.Write([]byte(userId))
index := hash.Sum32() % uint32(len(hubs))
hubs[index].Register(webConn)
return hubs[index]
}
func HubRegister(webConn *WebConn) {
GetHubForUserId(webConn.UserId).Register(webConn)
}
func HubUnregister(webConn *WebConn) {
for _, hub := range hubs {
hub.Unregister(webConn)
}
GetHubForUserId(webConn.UserId).Unregister(webConn)
}
func Publish(message *model.WebSocketEvent) {
@@ -111,9 +113,7 @@ func InvalidateCacheForUser(userId string) {
func InvalidateCacheForUserSkipClusterSend(userId string) {
Srv.Store.Channel().InvalidateAllChannelMembersForUser(userId)
for _, hub := range hubs {
hub.InvalidateUser(userId)
}
GetHubForUserId(userId).InvalidateUser(userId)
}
func (h *Hub) Register(webConn *WebConn) {