RanchiMall/blockbook
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Suppress logging of MQ errors

Browse Source
This commit is contained in:
Martin Boehm 2020-05-24 19:18:23 +02:00
parent 3be3bb5c3d
commit dd7964297d
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
bchain/mq.go
View File

@ -73,15 +73,24 @@ func (mq *MQ) run(callback func(NotificationType)) {
mq.finished <- nil mq.finished <- nil
}() }()
mq.isRunning = true mq.isRunning = true
repeatedError := false
for { for {
msg, err := mq.socket.RecvMessageBytes(0) msg, err := mq.socket.RecvMessageBytes(0)
if err != nil { if err != nil {
if zmq.AsErrno(err) == zmq.Errno(zmq.ETERM) || err.Error() == "Socket is closed" { if zmq.AsErrno(err) == zmq.Errno(zmq.ETERM) || err.Error() == "Socket is closed" {
break break
} }
glog.Error("MQ RecvMessageBytes error ", err, ", ", zmq.AsErrno(err)) // suppress logging of error for the first time
// programs built with Go 1.14 will receive more signals
// the error should be resolved by retrying the call
// see https://golang.org/doc/go1.14#runtime
if repeatedError {
glog.Error("MQ RecvMessageBytes error ", err, ", ", zmq.AsErrno(err))
}
repeatedError = true
time.Sleep(100 * time.Millisecond) time.Sleep(100 * time.Millisecond)
} }
repeatedError = false
if msg != nil && len(msg) >= 3 { if msg != nil && len(msg) >= 3 {
var nt NotificationType var nt NotificationType
switch string(msg[0]) { switch string(msg[0]) {