Buriburizaemon/nezha_domains
1
0 Fork 0
mirror of https://github.com/Buriburizaem0n/nezha_domains.git synced 2026-11-05 09:00:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

修复添加服务器死锁

Browse Source
This commit is contained in:
奶爸 committed 2019-12-11 14:41:12 +08:00
1 parent 3ede8b18a9
commit 5a8750b065
2 files changed
+3 -3
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

service/rpc/nezha.go
+1 -1
View File
@@ -36,10 +36,10 @@ func (s *NezhaHandler) Heartbeat(r *pb.Beat, stream pb.NezhaService_HeartbeatSer
return err
}
dao.ServerLock.RLock()
defer dao.ServerLock.RUnlock()
closeCh := make(chan error)
dao.ServerList[clientID].StreamClose = closeCh
dao.ServerList[clientID].Stream = stream
dao.ServerLock.RUnlock()
select {
case err = <-closeCh:
return err