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

Avoid extra broadcasts

This commit is contained in:
tidwall 2018-11-23 15:38:49 -07:00
parent 8906d8e65a
commit 1197cca40c
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
internal/server/aof.go
View File

@ -172,16 +172,18 @@ func (server *Server) writeAOF(args []string, d *commandDetailsT) error {
// live geofences // live geofences
server.lcond.L.Lock() server.lcond.L.Lock()
if d.parent { if len(server.lives) > 0 {
// queue children if d.parent {
for _, d := range d.children { // queue children
for _, d := range d.children {
server.lstack = append(server.lstack, d)
}
} else {
// queue parent
server.lstack = append(server.lstack, d) server.lstack = append(server.lstack, d)
} }
} else { server.lcond.Broadcast()
// queue parent
server.lstack = append(server.lstack, d)
} }
server.lcond.Broadcast()
server.lcond.L.Unlock() server.lcond.L.Unlock()
} }
return nil return nil