Use Select signal handling in mosh-{client,server}

src/frontend/mosh-server.cc

@@ -44,7 +44,6 @@
 #include <paths.h>
 #endif
 
-#include "sigfd.h"
 #include "completeterminal.h"
 #include "swrite.h"
 #include "user.h"
@@ -471,21 +470,12 @@ int run_server( const char *desired_ip, const char *desired_port,
 
 void serve( int host_fd, Terminal::Complete &terminal, ServerConnection &network )
 {
-  /* establish fd for shutdown signals */
-  int signal_fd = sigfd_init();
-  if ( signal_fd < 0 ) {
-    perror( "sigfd_init" );
-    return;
-  }
-
-  fatal_assert( sigfd_trap( SIGTERM ) == 0 );
-  fatal_assert( sigfd_trap( SIGINT ) == 0 );
-
   /* prepare to poll for events */
   Select &sel = Select::get_instance();
   sel.add_fd( network.fd() );
   sel.add_fd( host_fd );
-  sel.add_fd( signal_fd );
+  sel.add_signal( SIGTERM );
+  sel.add_signal( SIGINT );
 
   uint64_t last_remote_num = network.get_remote_state_num();
 
@@ -507,9 +497,7 @@ void serve( int host_fd, Terminal::Complete &terminal, ServerConnection &network
       }
 
       int active_fds = sel.select( timeout );
-      if ( active_fds < 0 && errno == EINTR ) {
+      if ( active_fds < 0 ) {
-	continue;
-      } else if ( active_fds < 0 ) {
 	perror( "select" );
 	break;
       }
@@ -614,16 +602,8 @@ void serve( int host_fd, Terminal::Complete &terminal, ServerConnection &network
 	}
       }
 
-      if ( sel.read( signal_fd ) ) {
+      if ( sel.any_signal() ) {
 	/* shutdown signal */
-	int signo = sigfd_read();
-	if ( signo == 0 ) {
-	  break;
-	} else if ( signo < 0 ) {
-	  perror( "sigfd_read" );
-	  break;
-	}
-
 	if ( network.has_remote_addr() && (!network.shutdown_in_progress()) ) {
 	  network.start_shutdown();
 	} else {

src/frontend/stmclient.cc

@@ -36,7 +36,6 @@
 #include <util.h>
 #endif
 
-#include "sigfd.h"
 #include "stmclient.h"
 #include "swrite.h"
 #include "completeterminal.h"
@@ -125,20 +124,14 @@ void STMClient::shutdown( void )
 
 void STMClient::main_init( void )
 {
-  /* establish a fd for signals */
+  Select &sel = Select::get_instance();
-  signal_fd = sigfd_init();
+  sel.add_signal( SIGWINCH );
-  if ( signal_fd < 0 ) {
+  sel.add_signal( SIGTERM );
-    perror( "sigfd_init" );
+  sel.add_signal( SIGINT );
-    return;
+  sel.add_signal( SIGHUP );
-  }
+  sel.add_signal( SIGPIPE );
-
+  sel.add_signal( SIGTSTP );
-  fatal_assert( sigfd_trap( SIGWINCH ) == 0 );
+  sel.add_signal( SIGCONT );
-  fatal_assert( sigfd_trap( SIGTERM ) == 0 );
-  fatal_assert( sigfd_trap( SIGINT ) == 0 );
-  fatal_assert( sigfd_trap( SIGHUP ) == 0 );
-  fatal_assert( sigfd_trap( SIGPIPE ) == 0 );
-  fatal_assert( sigfd_trap( SIGTSTP ) == 0 );
-  fatal_assert( sigfd_trap( SIGCONT ) == 0 );
 
   /* get initial window size */
   if ( ioctl( STDIN_FILENO, TIOCGWINSZ, &window_size ) < 0 ) {
@@ -302,7 +295,6 @@ void STMClient::main( void )
   Select &sel = Select::get_instance();
   sel.add_fd( network->fd() );
   sel.add_fd( STDIN_FILENO );
-  sel.add_fd( signal_fd );
 
   while ( 1 ) {
     try {
@@ -316,9 +308,7 @@ void STMClient::main( void )
       }
 
       int active_fds = sel.select( wait_time );
-      if ( active_fds < 0 && errno == EINTR ) {
+      if ( active_fds < 0 ) {
-	continue;
-      } else if ( active_fds < 0 ) {
 	perror( "select" );
 	break;
       }
@@ -340,22 +330,24 @@ void STMClient::main( void )
 	}
       }
 
-      if ( sel.read( signal_fd ) ) {
+      if ( sel.signal( SIGWINCH ) ) {
-	int signo = sigfd_read();
+        /* resize */
+        if ( !process_resize() ) { return; }
+      }
 
-	if ( signo == SIGWINCH ) {
+      if ( sel.signal( SIGTERM )
-	  /* resize */
+           || sel.signal( SIGINT )
-	  if ( !process_resize() ) { return; }
+           || sel.signal( SIGHUP )
-	} else if ( signo > 0 ) {
+           || sel.signal( SIGPIPE )
-	  /* shutdown signal */
+           || sel.signal( SIGTSTP )
-
+           || sel.signal( SIGCONT ) ) {
-	  if ( !network->has_remote_addr() ) {
+        /* shutdown signal */
-	    break;
+        if ( !network->has_remote_addr() ) {
-	  } else if ( !network->shutdown_in_progress() ) {
+          break;
-	    overlays.get_notification_engine().set_notification_string( wstring( L"Signal received, shutting down..." ), true );
+        } else if ( !network->shutdown_in_progress() ) {
-	    network->start_shutdown();
+          overlays.get_notification_engine().set_notification_string( wstring( L"Signal received, shutting down..." ), true );
-	  }
+          network->start_shutdown();
-	}
+        }
       }
 
       if ( sel.error( network->fd() ) ) {

src/frontend/stmclient.h

@@ -36,7 +36,6 @@ private:
 
   struct termios saved_termios, raw_termios;
 
-  int signal_fd;
   struct winsize window_size;
 
   Terminal::Framebuffer *local_framebuffer, *new_state;
@@ -65,7 +64,6 @@ public:
   STMClient( const char *s_ip, int s_port, const char *s_key, const char *predict_mode )
     : ip( s_ip ), port( s_port ), key( s_key ),
       saved_termios(), raw_termios(),
-      signal_fd(),
       window_size(),
       local_framebuffer( NULL ),
       new_state( NULL ),