chtwrs/chirpnest
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

client revamping compilation fix

Browse Source
This commit is contained in:
shoopea 2019-07-31 14:50:33 +08:00
parent 3db0777a93
commit d7bcdb0108
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
client.go
View File

@ -23,8 +23,9 @@ func getLockedClient(id int64, createMissing bool) (*ChirpClient, bool) {
return c, true return c, true
} else { } else {
muxClients.RUnlock() muxClients.RUnlock()
c := new(ChirpClient) //c := new(ChirpClient)
return c, false //return c, false
return nil, false
} }
} }

1
main.go
View File

@ -151,6 +151,7 @@ func main() {
TGCmdQueue = make(chan TGCommand, TGCmdQueueSize) TGCmdQueue = make(chan TGCommand, TGCmdQueueSize)
MQTGCmdQueue = make(chan TGCommand, MQTGCmdQueueSize) MQTGCmdQueue = make(chan TGCommand, MQTGCmdQueueSize)
JobQueue = make(chan Job, JobQueueSize) JobQueue = make(chan Job, JobQueueSize)
clients = make(map[int64]*ChirpClient)
for w := 1; w <= MQGetMsgWorkers; w++ { for w := 1; w <= MQGetMsgWorkers; w++ {
go MQGetMsgWorker(w, MQCWMsgQueue) go MQGetMsgWorker(w, MQCWMsgQueue)