Skip to content

Commit

Permalink
*: refine log message
Browse files Browse the repository at this point in the history
Signed-off-by: Lonng <[email protected]>
  • Loading branch information
lonng committed Jun 30, 2019
1 parent d2d2397 commit a0c7b82
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 4 deletions.
3 changes: 1 addition & 2 deletions cluster/handler.go
Original file line number Diff line number Diff line change
Expand Up @@ -370,10 +370,9 @@ func (h *LocalHandler) localProcess(handler *component.Handler, lastMid uint64,
}

result := handler.Method.Func.Call(args)
// TODO: send error message to client
if len(result) > 0 {
if err := result[0].Interface(); err != nil {
log.Println(err.(error).Error())
log.Println(fmt.Sprintf("Service %s error: %+v", msg.Route, err))
}
}
})
Expand Down
2 changes: 1 addition & 1 deletion scheduler/scheduler.go
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ var (
func try(f func()) {
defer func() {
if err := recover(); err != nil {
log.Println(fmt.Sprintf("%v\n%s", err, debug.Stack()))
log.Println(fmt.Sprintf("Handle message panic: %+v\n%s", err, debug.Stack()))
}
}()
f()
Expand Down
2 changes: 1 addition & 1 deletion scheduler/timer.go
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ func (t *Timer) Stop() {
func safecall(id int64, fn TimerFunc) {
defer func() {
if err := recover(); err != nil {
log.Println(fmt.Sprintf("Call timer function error, TimerID=%d, Error=%v\n%s", id, err, debug.Stack()))
log.Println(fmt.Sprintf("Handle timer panic: %+v\n%s", err, debug.Stack()))
}
}()

Expand Down

0 comments on commit a0c7b82

Please sign in to comment.