testsuite/XmlSocketServer.pl

   1 use IO::Socket;
   2 use IO::Socket::INET6;
   3 use IO::Select;
   4 use Time::HiRes;
   5
   6 $SIG{PIPE}='IGNORE';
   7
   8 my $m;
   9 %socketArgs = (Listen=>1,LocalPort=>2229,Reuse=>1,Proto=>'tcp');
  10 $m = IO::Socket::INET6->new(%socketArgs)
  11    or $m = IO::Socket::INET->new(%socketArgs)
  12       or die ("Socket creation failed: $!\n");
  13
  14 my $O = new IO::Select($m) or die ("Select failed: $!\n");
  15
  16 $verbose = ( $ARGV[0] eq '-v' ) ? 1 : 0;
  17
  18 $/ = "\0";
  19
  20 while (@S = $O->can_read) {
  21     foreach (@S) {
  22         if ($_==$m) {
  23             $C=$m->accept;
  24             $O->add($C);
  25         }
  26         else {
  27             my $R=sysread($_, $i, 16000);
  28
  29             # Log message received:
  30             print "XmlSocketServer: received \"$i\"\n" if $verbose;
  31
  32             if ($R==0) {
  33                 $T=syswrite($_, "\n", 16000);
  34                 if ($T==undef) {
  35                     $O->remove($_);
  36                 }
  37             }
  38             else {
  39
  40                 # Sleep a bit before sending a reply to mimic web traffic
  41                 # (well, sort of).
  42                 Time::HiRes::sleep(0.1);
  43                 print "XmlSocketServer: sending \"$i\" \n" if $verbose;
  44
  45                 $i =~ s/\*NEWLINE\*/\n/g;
  46                 $i =~ s/\*NULL\*/\0/g;
  47
  48                 $T=syswrite($_, $i, 16000);
  49             }
  50
  51             if ($i =~ m/closeNow/) {
  52                 print("XmlSocketServer: closing...\n") if $verbose;
  53                 close($C) || die "Could not close reading Socket";
  54             }
  55         }
  56     }
  57 }
  58
  59 close($m) || die "Could not close server Socket";
  60 print("XmlSocketServer: salut!\n") if $verbose;
  61