mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2025-03-31 01:24:31 +00:00
Code Activity

added logDebug to errSend method to print all errors also to console

Browse source
This commit is contained in:
postmannen 2025-01-06 16:28:15 +01:00
parent b93be49ef9
commit 2d14ce3303
2 changed files with 11 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
errorkernel.go
View file

@ -205,7 +205,6 @@ func (e *errorKernel) start(ringBufferBulkInCh chan<- Message) error {
}() }()
default: default:
// fmt.Printf(" * case default\n")
} }
} }
} }
@ -254,6 +253,17 @@ func (e *errorKernel) errSend(proc process, msg Message, err error, logLevel log
} }
e.errorCh <- ev e.errorCh <- ev
switch logLevel {
case logError:
e.logError(err)
case logInfo:
e.logInfo(err)
case logWarning:
e.logWarn(err)
case logDebug:
e.logDebug(err)
}
} }
// infoSend will just send an info message to the errorCentral. // infoSend will just send an info message to the errorCentral.

5
process.go
View file

@ -196,7 +196,6 @@ func (p process) startSubscriber() {
if err != nil { if err != nil {
er := fmt.Errorf("error: spawnWorker: got <-ctx.Done, but unable to unsubscribe natsSubscription failed: %v", err) er := fmt.Errorf("error: spawnWorker: got <-ctx.Done, but unable to unsubscribe natsSubscription failed: %v", err)
p.errorKernel.errSend(p, Message{}, er, logError) p.errorKernel.errSend(p, Message{}, er, logError)
p.errorKernel.logDebug(er)
} }
p.processes.active.mu.Lock() p.processes.active.mu.Lock()
@ -531,7 +530,6 @@ func (p process) callHandler(message Message, thisNode string) {
// ACL/Signature checking failed. // ACL/Signature checking failed.
er := fmt.Errorf("error: subscriberHandler: ACL were verified not-OK, doing nothing") er := fmt.Errorf("error: subscriberHandler: ACL were verified not-OK, doing nothing")
p.errorKernel.errSend(p, message, er, logWarning) p.errorKernel.errSend(p, message, er, logWarning)
p.errorKernel.logDebug(er)
} }
}() }()
@ -566,7 +564,6 @@ func executeHandler(p process, message Message, thisNode string) {
if err != nil { if err != nil {
er := fmt.Errorf("error: subscriberHandler: handler method failed: %v", err) er := fmt.Errorf("error: subscriberHandler: handler method failed: %v", err)
p.errorKernel.errSend(p, message, er, logError) p.errorKernel.errSend(p, message, er, logError)
p.errorKernel.logDebug(er)
} }
}() }()
@ -583,7 +580,6 @@ func executeHandler(p process, message Message, thisNode string) {
if err != nil { if err != nil {
er := fmt.Errorf("error: subscriberHandler: handler method failed: %v", err) er := fmt.Errorf("error: subscriberHandler: handler method failed: %v", err)
p.errorKernel.errSend(p, message, er, logError) p.errorKernel.errSend(p, message, er, logError)
p.errorKernel.logDebug(er)
} }
}() }()
@ -609,7 +605,6 @@ func executeHandler(p process, message Message, thisNode string) {
if err != nil { if err != nil {
er := fmt.Errorf("error: subscriberHandler: handler method failed: %v", err) er := fmt.Errorf("error: subscriberHandler: handler method failed: %v", err)
p.errorKernel.errSend(p, message, er, logError) p.errorKernel.errSend(p, message, er, logError)
p.errorKernel.logDebug(er)
} }
}() }()
} }