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:38:11 +08:00
parent d2e1840f13
commit a46ba7699b
2 changed files with 1 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
client.go
View File

@ -15,7 +15,7 @@ func getLockedClient(id int64, createMissing bool) (*ChirpClient, bool) {
c := new(ChirpClient) c := new(ChirpClient)
c.TGUserID64 = id c.TGUserID64 = id
c.Active = false c.Active = false
c.Lock() c.Mux.Lock()
muxClients.RUnlock() muxClients.RUnlock()
muxClients.Lock() muxClients.Lock()
clients[id] = c clients[id] = c

4
main.go
View File

@ -151,10 +151,6 @@ 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)
clientsQueue = make(map[int64]*MQClient)
clientsCW = new(sync.Map)
clientsKeepAlive = new(sync.Map)
for w := 1; w <= MQGetMsgWorkers; w++ { for w := 1; w <= MQGetMsgWorkers; w++ {
go MQGetMsgWorker(w, MQCWMsgQueue) go MQGetMsgWorker(w, MQCWMsgQueue)