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:36:53 +08:00
parent e56a19b494
commit d2e1840f13
3 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
client.go
View File

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

2
job.go
View File

@ -352,7 +352,7 @@ func jobPillage(j Job) {
} }
// is the job outdated now ? // is the job outdated now ?
if r.Date.Before(time.Now().Sub(3*time.Minute + 30*time.Second)) { if time.Now().After(r.Date.Add(time.Minute*3 + time.Second*30)) {
s := TGCommand{ s := TGCommand{
Type: commandSendMsg, Type: commandSendMsg,
Text: fmt.Sprintf("Pillage interception expired"), Text: fmt.Sprintf("Pillage interception expired"),

2
workers.go
View File

@ -403,7 +403,7 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) {
cwm, err := parseSubTypeMessageGoQuestAck(m, r) cwm, err := parseSubTypeMessageGoQuestAck(m, r)
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageGoQuestAck.") logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing objSubTypeMessageGoQuestAck.")
cwm.Msg = m cwm.Msg = m
uid, err := clientGetUserID64(m.UserID64) uid, err := clientGetCWUserID64(m.UserID64)
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Retrieving UserID64.") logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Retrieving UserID64.")
if err != nil { if err != nil {
err = setObjSubTypeId(objId, objSubTypeMessageUnknown) err = setObjSubTypeId(objId, objSubTypeMessageUnknown)