avoid double non-blocking connects

1 files changed, 15 insertions, 13 deletions

diff --git a/src/cssh.c b/src/cssh.c
index 25244b0..03f681c 100644
--- a/src/cssh.c
+++ b/src/cssh.c
@@ -390,20 +390,22 @@ int main( int argc, char *argv[] )
 	memset( is_connected, false, ( nof_sessions + 1 ) * sizeof( bool ) );
 	while( !all_connected ) {
 		for( unsigned int i = 0; i < nof_sessions; i++ ) {
-			rc = ssh_connect( session[i] );
-			if( rc == SSH_OK ) {
-				is_connected[i] = true;
-				//~ ssh_set_blocking( session[i], 1 );
-				if( args_info.verbose_given ) {
-					fprintf( stderr, "Connected to '%s', port %d..\n", host[i], port[i] );
+			if( !is_connected[i] ) {
+				rc = ssh_connect( session[i] );
+				if( rc == SSH_OK ) {
+					is_connected[i] = true;
+					//~ ssh_set_blocking( session[i], 1 );
+					if( args_info.verbose_given ) {
+						fprintf( stderr, "Connected to '%s', port %d..\n", host[i], port[i] );
+					}
+				} else if( rc == SSH_AGAIN ) {
+					// not connected yet
+				} else {
+					fprintf( stderr, "ERROR: error connecting to '%s', port '%d': %s\n",
+						host[i], port[i], ssh_get_error( session[i] ) );
+					cleanup_sessions( &session, NULL, host, port, nof_sessions, args_info.verbose_given > 0 );
+					exit( EXIT_FAILURE );
 				}
-			} else if( rc == SSH_AGAIN ) {
-				// not connected yet
-			} else {
-				fprintf( stderr, "ERROR: error connecting to '%s', port '%d': %s\n",
-					host[i], port[i], ssh_get_error( session[i] ) );
-				cleanup_sessions( &session, NULL, host, port, nof_sessions, args_info.verbose_given > 0 );
-				exit( EXIT_FAILURE );
 			}
 		}