diff options
| author | Drew DeVault <sir@cmpwn.com> | 2018-02-01 18:59:13 -0500 |
|---|---|---|
| committer | Drew DeVault <sir@cmpwn.com> | 2018-02-01 18:59:13 -0500 |
| commit | 1767e4fab515cefba08345e6eb2c84f46daf4be1 (patch) | |
| tree | 562b1f2269df58b4c783a771ac0324ce32ec7bb1 /worker | |
| parent | d24e4712a45e03d79fa1ccb71d00c5b830d5a305 (diff) | |
Improve logging
Diffstat (limited to 'worker')
| -rw-r--r-- | worker/types/worker.go | 26 |
1 files changed, 20 insertions, 6 deletions
diff --git a/worker/types/worker.go b/worker/types/worker.go index a99d432..1ff16a4 100644 --- a/worker/types/worker.go +++ b/worker/types/worker.go @@ -19,7 +19,11 @@ type Worker struct { func (worker *Worker) PostAction(msg WorkerMessage, cb func(msg WorkerMessage)) { - worker.Logger.Printf("=> %T\n", msg) + if resp := msg.InResponseTo(); resp != nil { + worker.Logger.Printf("(ui)=> %T:%T\n", msg, resp) + } else { + worker.Logger.Printf("(ui)=> %T\n", msg) + } worker.Actions <- msg if cb != nil { @@ -30,7 +34,11 @@ func (worker *Worker) PostAction(msg WorkerMessage, func (worker *Worker) PostMessage(msg WorkerMessage, cb func(msg WorkerMessage)) { - worker.Logger.Printf("-> %T\n", msg) + if resp := msg.InResponseTo(); resp != nil { + worker.Logger.Printf("->(ui) %T:%T\n", msg, resp) + } else { + worker.Logger.Printf("->(ui) %T\n", msg) + } worker.Messages <- msg if cb != nil { @@ -39,8 +47,11 @@ func (worker *Worker) PostMessage(msg WorkerMessage, } func (worker *Worker) ProcessMessage(msg WorkerMessage) WorkerMessage { - - worker.Logger.Printf("<= %T\n", msg) + if resp := msg.InResponseTo(); resp != nil { + worker.Logger.Printf("(ui)<= %T:%T\n", msg, resp) + } else { + worker.Logger.Printf("(ui)<= %T\n", msg) + } if cb, ok := worker.Callbacks[msg.InResponseTo()]; ok { cb(msg) delete(worker.Callbacks, msg) @@ -49,8 +60,11 @@ func (worker *Worker) ProcessMessage(msg WorkerMessage) WorkerMessage { } func (worker *Worker) ProcessAction(msg WorkerMessage) WorkerMessage { - - worker.Logger.Printf("<- %T\n", msg) + if resp := msg.InResponseTo(); resp != nil { + worker.Logger.Printf("<-(ui) %T:%T\n", msg, resp) + } else { + worker.Logger.Printf("<-(ui) %T\n", msg) + } if cb, ok := worker.Callbacks[msg.InResponseTo()]; ok { cb(msg) delete(worker.Callbacks, msg) |