#!/usr/bin/perl -w
# FILE: chatserver_02.pl
# FROM: http://manpages.ubuntu.com/manpages/maverick/man3/IO::Multiplex.3pm.html
use IO::Socket;
use IO::Multiplex;

my $mux  = new IO::Multiplex;

# Create a listening socket
my $sock = new IO::Socket::INET(Proto     => 'tcp',
                                LocalPort => shift || 2300,
                                Listen    => 4)
               or die "socket: $@";

# We use the listen method instead of the add method.
$mux->listen($sock);

$mux->set_callback_object(__PACKAGE__);
$mux->loop;

sub mux_input 
{
   my $package = shift;
   my $mux     = shift;
   my $fh      = shift;
   my $input   = shift;

   # The handles method returns a list of references to handles which
   # we have registered, except for listen sockets.
   foreach $c ($mux->handles) 
   {
      print $c $$input;
   }
   $$input = '';
}


##</code><code>##

#!/usr/bin/perl -w
# FILE: chatclient_02.pl
# FROM: http://manpages.ubuntu.com/manpages/maverick/man3/IO::Multiplex.3pm.html
 use IO::Socket;
           use IO::Multiplex;

           # Create a multiplex object
           my $mux  = new IO::Multiplex;
           # Connect to the host/port specified on the command line,
           # or localhost:23
           my $sock = new IO::Socket::INET(Proto    => 'tcp',
                                           PeerAddr => shift || 'localhost',
                                           PeerPort => shift || 23)
               or die "socket: $@";

           # add the relevant file handles to the mux
           $mux->add($sock);
           $mux->add(\*STDIN);
           # We want to buffer output to the terminal.  This prevents the program
           # from blocking if the user hits CTRL-S for example.
           $mux->add(\*STDOUT);

           # We're not object oriented, so just request callbacks to the
           # current package
           $mux->set_callback_object(__PACKAGE__);

           # Enter the main mux loop.
           $mux->loop;

           # mux_input is called when input is available on one of
           # the descriptors.
           sub mux_input {
               my $package = shift;
               my $mux     = shift;
               my $fh      = shift;
               my $input   = shift;

               # Figure out whence the input came, and send it on to the
               # other place.
               if ($fh == $sock) {
                   print STDOUT $$input;
               } else {
                   print $sock $$input;
               }
               # Remove the input from the input buffer.
               $$input = '';
           }

           # This gets called if the other end closes the connection.
           sub mux_close {
               print STDERR "Connection Closed\n";
               exit;
           }