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

test

Browse Source
This commit is contained in:
shoopea 2020-06-27 14:11:02 +02:00
parent 929d1d0e30
commit e15bef0345
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
workers.go
View File

@ -501,7 +501,7 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) {
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_time_ack`]") logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_time_ack`]")
err = insertMsgTimeAck(cwm) err = insertMsgTimeAck(cwm)
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : insertMsgTimeAck") logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : insertMsgTimeAck")
if cwm.RealTime.After(m.Date.Add(5*time.Minute)) || cwm.RealTime.Before(m.Date.Add(5*time.Minute)) { if cwm.RealTime.After(m.Date.Add(5*time.Minute)) || cwm.RealTime.Before(m.Date.Add(-5*time.Minute)) {
w := TGCommand{ w := TGCommand{
Type: commandSendMsg, Type: commandSendMsg,
Text: fmt.Sprintf("Date drifting %v => %v\n", m.Date, cwm.RealTime.Sub(m.Date)), Text: fmt.Sprintf("Date drifting %v => %v\n", m.Date, cwm.RealTime.Sub(m.Date)),