oss/FrankerFaceZ
oss/FrankerFaceZ
1
0
Fork 0
mirror of https://github.com/FrankerFaceZ/FrankerFaceZ.git synced 2025-08-05 22:00:54 +00:00
Code Wiki Activity

lock once during multichan publish

Browse source
This commit is contained in:
Kane York 2016-01-27 19:40:17 -08:00
parent af19d5f30a
commit 1113c3a766
1 changed files with 4 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

5
socketserver/server/publisher.go
View file

@ -230,9 +230,12 @@ func HTTPBackendCachedPublish(w http.ResponseWriter, r *http.Request) {
count = PublishToChannel(channel, msg) count = PublishToChannel(channel, msg)
} else if cacheinfo.Caching == CacheTypeLastOnly && cacheinfo.Target == MsgTargetTypeMultichat { } else if cacheinfo.Caching == CacheTypeLastOnly && cacheinfo.Target == MsgTargetTypeMultichat {
channels := strings.Split(channel, ",") channels := strings.Split(channel, ",")
var dummyLock sync.Mutex
CachedLSMLock.Lock()
for _, channel := range channels { for _, channel := range channels {
SaveLastMessage(CachedLastMessages, &CachedLSMLock, cmd, channel, timestamp, json, deleteMode) SaveLastMessage(CachedLastMessages, &dummyLock, cmd, channel, timestamp, json, deleteMode)
} }
CachedLSMLock.Unlock()
count = PublishToMultiple(channels, msg) count = PublishToMultiple(channels, msg)
} }