From fbd01cf7ab11a3b8bf71556985a58dad68b56e84 Mon Sep 17 00:00:00 2001
From: Martin Geno <geno+dev@fireorbit.de>
Date: Thu, 6 Jul 2017 09:57:25 +0200
Subject: [PATCH] mux on ssh

---
 ssh/run.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/ssh/run.go b/ssh/run.go
index d3e65f5..02c75ad 100644
--- a/ssh/run.go
+++ b/ssh/run.go
@@ -47,7 +47,9 @@ func (m *Manager) run(host string, client *ssh.Client, cmd string) ([]byte, erro
 
 	if err != nil {
 		log.Log.Warnf("can not create session on %s: %s", host, err)
+		m.clientsMUX.Lock()
 		delete(m.clients, host)
+		m.clientsMUX.Unlock()
 		return nil, err
 	}
 	stdout, err := session.StdoutPipe()