testsuite/XmlSocketServer.pl

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