Skip to content
Snippets Groups Projects
Commit 3ff93e9a authored by Jake Taylor's avatar Jake Taylor
Browse files

added manager print on timer

parent d9f2cbc2
No related branches found
No related tags found
1 merge request!11Release
...@@ -170,6 +170,17 @@ listen: ...@@ -170,6 +170,17 @@ listen:
grpc.KeepaliveEnforcementPolicy(KaEnforcement)) grpc.KeepaliveEnforcementPolicy(KaEnforcement))
} }
// Intermittantly print manager connection information
go func() {
ticker := time.NewTicker(60 * time.Second)
for {
select {
case _ = <-ticker.C:
jww.INFO.Printf(pc.Manager.String())
}
}
}()
return pc, lis, nil return pc, lis, nil
} }
......
...@@ -106,9 +106,16 @@ func (m *Manager) DisconnectAll() { ...@@ -106,9 +106,16 @@ func (m *Manager) DisconnectAll() {
// Implements Stringer for debug printing // Implements Stringer for debug printing
func (m *Manager) String() string { func (m *Manager) String() string {
var result bytes.Buffer var result bytes.Buffer
i := uint32(0)
result.WriteString(fmt.Sprintf("Host Manager Connections\n"))
for k, host := range m.connections { for k, host := range m.connections {
result.WriteString(fmt.Sprintf("[%s]: %+v", isConnected, _ := host.Connected()
(&k).String(), host)) if isConnected {
i++
} }
result.WriteString(fmt.Sprintf("[%s] IsConnected: %t\n",
(&k).String(), isConnected))
}
result.WriteString(fmt.Sprintf("%d/%d Hosts connected", i, len(m.connections)))
return result.String() return result.String()
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment