diff --git a/client.go b/client.go index a114bd3..e9904e6 100644 --- a/client.go +++ b/client.go @@ -88,7 +88,6 @@ func setClientIdle(userID64 int64, from time.Time) error { } func getLockedIdleClient() (*ChirpClient, error) { - fmt.Printf("getLockedIdleClient : starting.\n") muxClients.RLock() ids := make([]int64, 0) for _, c := range clients { @@ -104,7 +103,7 @@ func getLockedIdleClient() (*ChirpClient, error) { RndMux.Lock() id := RndSrc.Intn(len(ids)) - fmt.Printf("getLockedIdleClient : pulled (%d).\n", id) + fmt.Printf("getLockedIdleClient : pulled %s.\n", clients[ids[id]].Login) RndMux.Unlock() clients[ids[id]].Mux.Lock() diff --git a/job.go b/job.go index e1edfba..395c8e5 100644 --- a/job.go +++ b/job.go @@ -593,13 +593,11 @@ func jobMsgDelete(j Job) { err := setJobStart(j.ID64) logOnError(err, "jobMsgDel : setJobStart") - log.Printf("jobMsgDelete[%d] : Starting.\n", j.ID64) - err = json.Unmarshal(j.Payload, &p) logOnError(err, "jobMsgDel : Unmarshal payload") b, _ := json.Marshal(p) - log.Printf("jobMsgDelete[%d] : Payload => %s.\n", j.ID64, string(b)) + log.Printf("jobMsgDelete[%d] : %d : Payload => %s.\n", j.ID64, j.UserID64, string(b)) if j.Trigger != 0 && p.MsgTypeID64 != 0 { logOnError(err, "jobMsgDel : getObjMsg msg")