[BACK]Return to telnetbbs.pl CVS log [TXT] [DIR] Up to [Local Repository] / telnetbbs

Diff for /telnetbbs/telnetbbs.pl between versions 1.2 and 1.6

version 1.2, 2010/01/06 13:33:19 version 1.6, 2010/12/14 20:32:49
Line 13  BEGIN { Line 13  BEGIN {
         delete @ENV{qw(IFS CDPATH ENV BASH_ENV PATH)};          delete @ENV{qw(IFS CDPATH ENV BASH_ENV PATH)};
         $ENV{PATH} = "/bin:/usr/bin";          $ENV{PATH} = "/bin:/usr/bin";
         $|++;          $|++;
 # Flip this back on for more detailed error reporting          $SIG{__DIE__} = sub { require Carp; Carp::confess(@_); }
 #        $SIG{__DIE__} = sub { require Carp; Carp::confess(@_); }  
       }        }
   
 use strict;  use strict;
Line 30  use threads; Line 29  use threads;
 use threads::shared;  use threads::shared;
   
 ##  ##
 ## Fetch our command line options  ## Fetch our command line and configuration options
 ##  ##
 my %opts    = &fetchOptions( );  my %opts    = &fetchOptions( );
 my $pidFile = "/var/run/telnetbbs.pid";  my %cfg     = &fetchConfig( );
 my $EOL     = "\015\012";  my $EOL     = "\015\012";
 my $BBS_NAME = "Hell's Dominion BBS";  
   ## 
   ## These will be moved in to a config file
   ##
   my $BBS_NODE  = 0;
   my $pidFile   = $cfg{'pidfile'}    || "/tmp/telnetbbs.pid";
   my $port      = $opts{'port'}      || $cfg{'port'} || 23;
   my $DISPLAY   = $cfg{'display'}    || ":0.0";
   my $BBS_NAME  = $cfg{'bbs_name'}   || "Hell's Dominion BBS";
   my $DBCONF    = $cfg{'dosbox_cfg'} || "/tmp/dosbox-__NODE__.conf";
   my $BBS_CMD   = $cfg{'bbs_cmd'}    || "DISPLAY=$DISPLAY /usr/bin/dosbox -conf ";
   my $LOGGING   = $cfg{'logging'}    || 0;
   my $LOG       = $cfg{'log_path'}   || "/tmp/bbs.log";
   my $MAX_NODE  = $cfg{'nodes'}      || 1;
   my $DOSBOXT   = $cfg{'dosboxt'}    || "dosbox.conf.template";
   my $BASE_PORT = $cfg{'base_port'}  || 7000;
   my $LOCK_PATH = $cfg{'lock_path'}  || "/tmp";
   
 ##  ##
 ## Check that we are 'root'   ## Check that we are 'root' 
 ##  ##
 die( "Must be root user to run this.\n" )  die( "Must be root user to run this.\n" )
         if ( getpwuid( $> ) ne "root" );          if ( getpwuid( $> ) ne "root" && $port < 1023 );
   
 ##  ##
 ## Check for a PID  ## Check for a PID
Line 60  $SIG{CHLD} = 'IGNORE'; Line 75  $SIG{CHLD} = 'IGNORE';
 local $SIG{HUP}  = $SIG{INT} = $SIG{TERM} = \&shutdown;  local $SIG{HUP}  = $SIG{INT} = $SIG{TERM} = \&shutdown;
   
 ##  ##
   ## Open the Log
   ##
   open LOG, ">>$LOG" if ( $LOGGING );
   &logmsg( "Starting telnetbbs server" );
   
   ##
   ## Display running information
   ##
   &display_config_and_options( \%opts, "Options" );
   &display_config_and_options( \%cfg, "Configuration" );
   
   ##
 ## Start the network server  ## Start the network server
 ##  ##
 my $netThread = threads->create( \&startNetServer );  my $netThread = threads->create( \&startNetServer( ) );
   
   
 while( 1 ) { sleep 1; }  while( 1 ) { sleep 1; }
   
Line 79  while( 1 ) { sleep 1; } Line 107  while( 1 ) { sleep 1; }
 ###############################################################################  ###############################################################################
 ###############################################################################  ###############################################################################
   
 sub logmsg { print "$0 $$: @_ at ", scalar localtime, "\n" }  sub logmsg 
   { 
           my $message = "$0 $$ " . scalar( localtime( ) ) . ":@_\n";
           print STDOUT $message;
           print LOG $message if ( $LOGGING );
   }
   
   
   ###############################################################################
   ###############################################################################
   sub display_config_and_options
   {
           my $hr    = shift || 0;
           my $name  = shift || "Unknown";
           my $title = "Displaying $name\n";
   
           return $hr if ( ! $hr );
   
           print LOG $title . Dumper( $hr ) if ( $LOGGING );
           print STDOUT $title . Dumper( $hr ) if ( $opts{'verbose'});
   }
   
 ###############################################################################  ###############################################################################
 ## startNetServer( );  ## startNetServer( );
Line 92  sub startNetServer Line 140  sub startNetServer
 {  {
         my $hostConnection;          my $hostConnection;
         my $childPID;          my $childPID;
         my $port = $opts{'port'} || 23;          my @nodes = ( );
         my $node = 1;  
   
         my $server = IO::Socket::INET->new(           my $server = IO::Socket::INET->new( 
                         LocalPort => $port,                          LocalPort => $port,
Line 111  sub startNetServer Line 158  sub startNetServer
         ##          ##
         REQUEST: while( $hostConnection = $server->accept( ) )          REQUEST: while( $hostConnection = $server->accept( ) )
         {          {
                   ## 
                   ## Find the next available node
                   ##
                   my $node = 0;
                   my $lock_file = "";
                   foreach (1 .. $MAX_NODE)
                   {
   print "Searching for lock: " . $LOCK_PATH."/".$BBS_NAME."_node".$_.".lock\n";
                           next if ( -f $LOCK_PATH."/".$BBS_NAME."_node".$_.".lock" );
   
                           ##
                           ## Create node lock file
                           ##
                           $lock_file = $LOCK_PATH."/".$BBS_NAME."_node".$_.".lock";
                           open LOCK, ">$lock_file";
                           close( LOCK );
                           $node = $BBS_NODE = $_;
                   }
   print "Using lock: " . $LOCK_PATH."/".$BBS_NAME."_node".$node.".lock\n";
   
                   ##
                   ## Create our dosbox config
                   ##
                   open( DBT, "<$DOSBOXT" );
                           my @dbt = <DBT>;
                   close( DBT );
                   
                   my $bpn = $BASE_PORT + $BBS_NODE;
                   $DBCONF =~ s/__NODE__/$BBS_NODE/g;
                   open( DBC, ">$DBCONF" );
                   foreach( @dbt ) 
                   {
                           $_ =~ s/__NODE__/$BBS_NODE/g;
                           $_ =~ s/__LISTEN_PORT__/$bpn/g;
                           print DBC $_;
                   }
                   close( DBC );
   
                   &logmsg( "Connecting on node $BBS_NODE\n" );
   
                 my $kidpid;                  my $kidpid;
                 my $line;                  my $line;
   
Line 120  sub startNetServer Line 207  sub startNetServer
                 }                  }
                 defined( $childPID ) || die( "Cannot fork: $!\n" );                  defined( $childPID ) || die( "Cannot fork: $!\n" );
   
                   select $hostConnection;
   
                 ##                  ##
                 ## Default file descriptor to the client and turn on autoflush                  ## Default file descriptor to the client and turn on autoflush
                 ##                  ##
                 $hostConnection->autoflush( 1 );                  $hostConnection->autoflush( 1 );
   
                 print $hostConnection "Welcome to $BBS_NAME!" . $EOL;                  print "Welcome to $BBS_NAME!" . $EOL;
                 print $hostConnection "Starting BBS on node $node...$EOL";  
                   ##
                   if ( ! $lock_file ) 
                   {
                           print "No available nodes.  Try again later.".$EOL;
                           exit;
                   }
   
                   print "Starting BBS on node $BBS_NODE...$EOL";
   
                 ##                  ##
                 ## Launch BBS via dosbox                  ## Launch BBS via dosbox
Line 134  sub startNetServer Line 231  sub startNetServer
                 my $bbsPID = fork( );                  my $bbsPID = fork( );
                 if ( $bbsPID )                   if ( $bbsPID ) 
                 {                  {
                         exec( "dosbox" );                          select STDOUT;
                           my $cmd = $BBS_CMD . $DBCONF;
                           system( $cmd );
                           print "Shutting down node $BBS_NODE\n";
                           ##
                           ## Remove Lock
                           ##      
                           unlink( $lock_file );
                           unlink( $DBCONF );
                         exit;                          exit;
                 }                  }
                 sleep 10;  
                   ##
                   ## We wait for dosbox to start and the BBS to start
                   ## There really should be a better way to determine this
                   ##
                   sleep 5;
   
                 ##                  ##
                 ## Create connection to BBS                  ## Create connection to BBS
                 ##                  ##
                 my $bbs = IO::Socket::INET->new (                  my $bbs = IO::Socket::INET->new (
                                 PeerAddr        => 'localhost',                                  PeerAddr        => 'localhost',
                                 Type      => SOCK_STREAM,                                  Type            => SOCK_STREAM,
                                 PeerPort        => 5000,                                  PeerPort        => $bpn,
                                 Proto           => 'tcp',                                  Proto           => 'tcp',
                         ) || die "Could not open BBS socket: $!\n";                          ) || die "Could not open BBS socket: $!\n";
                 $bbs->autoflush( 1 );                  $bbs->autoflush( 1 );
Line 159  sub startNetServer Line 269  sub startNetServer
                         {                          {
                                 print $hostConnection $byte;                                  print $hostConnection $byte;
                         }                          }
                         kill( "TERM" => $childPID );                          $nodes[$BBS_NODE] = 0;
                           kill( "TERM" => $kidpid );
                 }                  }
                 else                   else 
                 {                  {
Line 169  sub startNetServer Line 280  sub startNetServer
                                 print $bbs $byte;                                  print $bbs $byte;
                         }                          }
                 }                  }
   
                   unlink( $DBCONF );
         }          }
         close( $hostConnection );          close( $hostConnection );
         exit;          exit;
   
         close( $server );  #       close( $server );
 }  }
   
 ###############################################################################  ###############################################################################
Line 189  sub shutdown Line 302  sub shutdown
 {  {
         my $signame = shift || 0;          my $signame = shift || 0;
   
         print "$0: Shutdown (SIG$signame) received.\n"          select STDOUT;
   
           &logmsg( "$0: Shutdown (SIG$signame) received.\n" )
                 if( $signame );                  if( $signame );
                   
           ##
           ## Close Log
           ##
           close( LOG ) if ( $LOGGING );
   
         ##                ##      
         ## Remove the PID          ## Remove the PID
         ##          ##
Line 306  sub processExists Line 426  sub processExists
         return 0;          return 0;
 }  }
   
   ###############################################################################
   ###############################################################################
   sub fetchConfig 
   {
           my %conf = ( );
           my $cf   = &findConfig;
   
           if ( $cf ) 
           {
                   open( CONF, "<$cf" ) or die ( "Error opening $cf: $!\n" );
                           while( <CONF> ) 
                           {
                                   next if ( $_ =~ m/^#/ );
                                   if ( $_ =~ m/(.*?)=(.*)/ )
                                   {
                                           my $k = $1; my $v = $2;
                                           $k =~ s/\s+//;
                                           $v =~ s/\s+//;
                                           $conf{$k} = $v;
                                   }
                           }
                   close( CONF );
           }
   
           return %conf;
   }
   
   ###############################################################################
   ###############################################################################
   sub findConfig
   {
           my $cf    = 0;
           my @paths = qw| ./ ./.telnetbbs /etc /usr/local/etc |;
   
           foreach ( @paths ) 
           {
                   my $fn = $_ . "/telnetbbs.conf";
                   return $fn if ( -f $fn );
           }
   
           return $cf;
   }
   
 ###############################################################################  ###############################################################################
 ##  ##
Line 321  sub fetchOptions { Line 483  sub fetchOptions {
                         "help|?"        => \$opts{'help'},                          "help|?"        => \$opts{'help'},
                         "man"           => \$opts{'man'},                          "man"           => \$opts{'man'},
                         "port:i"        => \$opts{'port'},                          "port:i"        => \$opts{'port'},
                           "verbose"       => \$opts{'verbose'},
                    ) || &pod2usage( );                     ) || &pod2usage( );
         &pod2usage( ) if defined $opts{'help'};          &pod2usage( ) if defined $opts{'help'};
         &pod2usage( { -verbose => 2, -input => \*DATA } ) if defined $opts{'man'};          &pod2usage( { -verbose => 2, -input => \*DATA } ) if defined $opts{'man'};
Removed from v.1.2  
changed lines
  Added in v.1.6

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>