X-Git-Url: https://git.realraum.at/?a=blobdiff_plain;f=go%2Fr3-netstatus%2Fmain.go;h=0bb8d0e24bf2fc52969d36280fffd4a892c4fa91;hb=4e6f754877a7061afe6ef56b21585c778db5b2c9;hp=66763ff7a816362320c9190f0f8ff811ef81f1a6;hpb=114821ef8e7567df37044ecd77b4d807216b0946;p=svn42.git diff --git a/go/r3-netstatus/main.go b/go/r3-netstatus/main.go index 66763ff..0bb8d0e 100644 --- a/go/r3-netstatus/main.go +++ b/go/r3-netstatus/main.go @@ -120,7 +120,8 @@ func EventToXMPP(bot *r3xmppbot.XmppBot, events <- chan interface{}, xmpp_presen xmpp_presence_events_chan <- present_status last_buttonpress = 0 } - + // Try to XMPP Ping the server and if that fails, quit XMPPBot + if bot.PingServer(900) == false && bot.PingServer(900) == false && bot.PingServer(900) == false && bot.PingServer(900) == false{ return } case r3events.DoorProblemEvent: xmpp_presence_events_chan <- r3xmppbot.XMPPMsgEvent{Msg: fmt.Sprintf("Door Problem: %s. SeverityLevel: %d (%s)",event.Problem, event.Severity, time.Unix(event.Ts,0).String()), DistributeLevel: r3xmppbot.R3OnlineOnlyInfo, RememberAsStatus: false} } @@ -145,7 +146,7 @@ func RunXMPPBot(ps *pubsub.PubSub, zmqctx *zmq.Context) { } else { Syslog_.Printf("Error starting XMPP Bot: %s", xmpperr.Error()) } - time.Sleep(5 * time.Second) + time.Sleep(10 * time.Second) } } @@ -193,7 +194,7 @@ func main() { go RunXMPPBot(ps, zmqctx) // --- receive and distribute events --- - ticker := time.NewTicker(time.Duration(7) * time.Minute) + ticker := time.NewTicker(time.Duration(6) * time.Minute) for { select { case e := <-zmqsub.In():