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

thread safety

parent d5f4fd71
No related branches found
No related tags found
1 merge request!11Release
...@@ -122,6 +122,8 @@ func (m *Manager) String() string { ...@@ -122,6 +122,8 @@ func (m *Manager) String() string {
var result bytes.Buffer var result bytes.Buffer
i := uint32(0) i := uint32(0)
result.WriteString(fmt.Sprintf("Host Manager Connections\n")) result.WriteString(fmt.Sprintf("Host Manager Connections\n"))
m.mux.RLock()
for k, host := range m.connections { for k, host := range m.connections {
isConnected, _ := host.Connected() isConnected, _ := host.Connected()
if isConnected { if isConnected {
...@@ -130,6 +132,7 @@ func (m *Manager) String() string { ...@@ -130,6 +132,7 @@ func (m *Manager) String() string {
result.WriteString(fmt.Sprintf("[%s] IsConnected: %t\n", result.WriteString(fmt.Sprintf("[%s] IsConnected: %t\n",
(&k).String(), isConnected)) (&k).String(), isConnected))
} }
m.mux.RUnlock()
result.WriteString(fmt.Sprintf("%d/%d Hosts connected", i, len(m.connections))) 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