test
This commit is contained in:
parent
f45a790ef7
commit
27a5f0f8be
2
main.go
2
main.go
@ -126,7 +126,7 @@ func main() {
|
|||||||
MQTGCmdQueue = make(chan TGCommand, MQTGCmdQueueSize)
|
MQTGCmdQueue = make(chan TGCommand, MQTGCmdQueueSize)
|
||||||
clientsQueue = make(map[int64]*MQClient)
|
clientsQueue = make(map[int64]*MQClient)
|
||||||
clientsKeepAlive = make(map[int64]*MQKeepAlive)
|
clientsKeepAlive = make(map[int64]*MQKeepAlive)
|
||||||
clientsProfile = make(map[int64]*ChatWarsClient)
|
clientsCW = make(map[int64]*ChatWarsClient)
|
||||||
|
|
||||||
for w := 1; w <= MQGetMsgWorkers; w++ {
|
for w := 1; w <= MQGetMsgWorkers; w++ {
|
||||||
go MQGetMsgWorker(w, MQCWMsgQueue)
|
go MQGetMsgWorker(w, MQCWMsgQueue)
|
||||||
|
Loading…
Reference in New Issue
Block a user