test
This commit is contained in:
parent
3798ef3d8e
commit
aeccb45fee
6
job.go
6
job.go
@ -694,12 +694,6 @@ func jobMsgRefresh(j Job) {
|
||||
err = setJobDone(j.ID64)
|
||||
logOnError(err, "joMsgClient : setJobDone")
|
||||
return
|
||||
} else {
|
||||
/* logOnError(err, "jobMsgRefresh : getObjMsg")
|
||||
err = setJobDone(j.ID64)
|
||||
logOnError(err, "joMsgClient : setJobDone")
|
||||
return
|
||||
*/
|
||||
}
|
||||
|
||||
err = delObj(p.ObjID64)
|
||||
|
1
obj.go
1
obj.go
@ -447,7 +447,6 @@ func delObj(objId int64) error {
|
||||
return errors.New("Can only delete cacheObjSubType[`msg_auction_announce`].")
|
||||
}
|
||||
|
||||
log.Printf("delObj(%d)\n", objId)
|
||||
cacheObjMsg.Delete(objId) // better delete from cache before, worst case we reload after
|
||||
|
||||
stmt, err := db.Prepare(`DELETE FROM obj WHERE id = ?`)
|
||||
|
@ -263,7 +263,7 @@ func MQTGCmdWorker(id int, cmds <-chan TGCommand) {
|
||||
if clt, ok := getLockedClient(c.FromUserID64, false); ok {
|
||||
j, err := json.Marshal(c)
|
||||
logOnError(err, "MQTGCmdWorker["+strconv.Itoa(id)+"] : Marshal(c)")
|
||||
log.Printf("MQTGCmdWorker["+strconv.Itoa(id)+"] : new command.\n%s\n", string(j))
|
||||
//log.Printf("MQTGCmdWorker["+strconv.Itoa(id)+"] : new command.\n%s\n", string(j))
|
||||
for clt.MQ.Connection == nil || clt.MQ.Connection.IsClosed() {
|
||||
clt.Active = false
|
||||
log.Printf("MQTGCmdWorker : Resetting MQ connection for #%d.\n", c.FromUserID64)
|
||||
|
Loading…
Reference in New Issue
Block a user