test
This commit is contained in:
parent
8a4fba6ce8
commit
19df6071e7
1
main.go
1
main.go
|
@ -154,7 +154,6 @@ func main() {
|
||||||
MQTGCmdQueue = make(chan TGCommand, MQTGCmdQueueSize)
|
MQTGCmdQueue = make(chan TGCommand, MQTGCmdQueueSize)
|
||||||
JobQueue = make(chan Job, JobQueueSize)
|
JobQueue = make(chan Job, JobQueueSize)
|
||||||
clientsQueue = make(map[int64]*MQClient)
|
clientsQueue = make(map[int64]*MQClient)
|
||||||
clientsKeepAlive = make(map[int64]*MQKeepAlive)
|
|
||||||
|
|
||||||
clientsCW = new(sync.Map)
|
clientsCW = new(sync.Map)
|
||||||
clientsKeepAlive = new(sync.Map)
|
clientsKeepAlive = new(sync.Map)
|
||||||
|
|
Loading…
Reference in New Issue
Block a user