|
@@ -352,11 +352,14 @@ func hostStatusLoop() {
|
|
|
for {
|
|
for {
|
|
|
select {
|
|
select {
|
|
|
case <-ticker.C:
|
|
case <-ticker.C:
|
|
|
|
|
+ config.Logger.Info("host bstate updating")
|
|
|
update := constructSystemInfo()
|
|
update := constructSystemInfo()
|
|
|
err := UpdateBroadcastState(update)
|
|
err := UpdateBroadcastState(update)
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
config.Logger.Warn(fmt.Sprintf("Error updating system status: %v", err))
|
|
config.Logger.Warn(fmt.Sprintf("Error updating system status: %v", err))
|
|
|
}
|
|
}
|
|
|
|
|
+
|
|
|
|
|
+ config.Logger.Info("host bstate updated")
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
@@ -367,6 +370,7 @@ func shipStatusLoop() {
|
|
|
for {
|
|
for {
|
|
|
select {
|
|
select {
|
|
|
case <-ticker.C:
|
|
case <-ticker.C:
|
|
|
|
|
+ config.Logger.Info("ship bstate updating")
|
|
|
conf := config.Conf()
|
|
conf := config.Conf()
|
|
|
piers := conf.Piers
|
|
piers := conf.Piers
|
|
|
updates, err := constructPierInfo(piers)
|
|
updates, err := constructPierInfo(piers)
|
|
@@ -382,6 +386,7 @@ func shipStatusLoop() {
|
|
|
errmsg := fmt.Sprintf("Unable to update ship state: %v", err)
|
|
errmsg := fmt.Sprintf("Unable to update ship state: %v", err)
|
|
|
config.Logger.Error(errmsg)
|
|
config.Logger.Error(errmsg)
|
|
|
}
|
|
}
|
|
|
|
|
+ config.Logger.Info("ship bstate updated")
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|