Merge pull request #211 from foutrelis/fix-not-connected-errors

pkg/connector/connection_manager.go

@@ -88,19 +88,19 @@ func (m *SSHConnectionManager) lockForDevice(device *Device) *sync.Mutex {
 // Connect connects to a device or returns an long living connection
 func (m *SSHConnectionManager) Connect(device *Device) (*SSHConnection, error) {
 	if connection, found := m.connections[device.Host]; found {
-		if !connection.isConnected() {
-			return nil, errors.New("not connected")
+		if connection.isConnected() {
+			return connection, nil
 		}
-
-		return connection, nil
 	}
 
 	mu := m.lockForDevice(device)
 	mu.Lock()
 	defer mu.Unlock()
 
 	if connection, found := m.connections[device.Host]; found {
-		return connection, nil
+		if connection.isConnected() {
+			return connection, nil
+		}
 	}
 
 	return m.connect(device)