bin/fbm

   1 #!/usr/bin/perl -w
   2
   3 # F*EX benchmark
   4 #
   5 # Author: Ulli Horlacher <framstag@rus.uni-stuttgart.de>
   6 #
   7 # Copyright: Perl Artistic
   8
   9 use 5.006;
  10 use strict qw'vars subs';
  11 use Config;
  12 use Socket;
  13 use IO::Handle;
  14 use IO::Socket::INET;
  15 use Getopt::Std;
  16 use Time::HiRes qw'time';
  17 # use Smart::Comments;
  18 use constant k => 2**10;
  19 use constant M => 2**20;
  20
  21 our ($SH,$windoof,$sigpipe,$useragent);
  22 our ($FEXSERVER);
  23 our $version = 20150120;
  24
  25 # server defaults
  26 my $server = 'fex.rus.uni-stuttgart.de';
  27 my $port = 80;
  28 my $proxy = '';
  29
  30 my $from = 'nettest';
  31 my $to = $from;
  32 my $id = $from;
  33 my $proxy_prefix = '';
  34 my $mb;
  35 my (@r,$r);
  36 my $bs = 2**16;
  37 my $timeout = 30;       # server timeout
  38
  39 $version ||= mtime($0);
  40 $0 =~ s:.*/::;
  41
  42 my $usage = <<EOD;
  43 usage: $0 [-n] [-s server] [-P proxy] #MB
  44 options: -n  do not store on server
  45          -s  use alternative F*EX server:port
  46          -P  use proxy server:port
  47 examples: $0 1000
  48 EOD
  49
  50 if ($Config{osname} =~ /^mswin/i) {
  51   $windoof = $Config{osname};
  52   $useragent = sprintf("fbm-$version (%s %s)",
  53                        $Config{osname},$Config{archname});
  54 } else {
  55   $0 =~ s:.*/::;
  56   $_ = `(lsb_release -d||uname -a)2>/dev/null`||'';
  57   chomp;
  58   s/^Description:\s+//;
  59   $useragent = "fbm-$version ($_)";
  60 }
  61
  62 $| = 1;
  63
  64 autoflush STDERR;
  65
  66 my @_ARGV = @ARGV; # save arguments
  67
  68 our $opt_n = 0;
  69 our $opt_v = 0;
  70 our $opt_h = 0;
  71 our $opt_s = '';
  72 our $opt_P = '';
  73
  74 getopts('hvnP:s:') or die $usage;
  75
  76 if ($opt_h) {
  77   print $usage;
  78   exit;
  79 }
  80
  81 if ($opt_P) {
  82   if ($opt_P =~ /^[\w.-]+:\d+/) {
  83     $proxy = $opt_P;
  84   } else {
  85     die "$0: proxy must be: SERVER:PORT\n";
  86   }
  87 }
  88
  89 $mb = shift    or die $usage;
  90 $mb =~ /^\d+$/ or die $usage;
  91
  92 # $port = $1  if $server =~ s/:(\d+)//;
  93
  94 if ($opt_s) {
  95   ($server,$port) = split /:/,$opt_s;
  96   $port = 80 unless $port;
  97 }
  98 $server =~ s{http://}{};
  99 $server =~ s{/.*}{};
 100
 101 if ($proxy) {
 102   if ($port == 80)  { $proxy_prefix = "http://$server" }
 103   else              { $proxy_prefix = "http://$server:$port" }
 104 }
 105
 106 print "Testing $server:\n";
 107
 108 @r = formdatapost(
 109   from          => $from,
 110   to            => $to,
 111   id            => $id,
 112   comment       => $opt_n ? 'NOSTORE' : 'NOMAIL',
 113   keep          => 1,
 114   autodelete    => 'YES',
 115 );
 116
 117 if (not @r or not grep /\w/,@r) {
 118   die "$0: no response from server\n";
 119 }
 120
 121 if (($r) = grep /ERROR:/,@r) {
 122   $r =~ s/.*?:\s*//;
 123   $r =~ s/<.*//;
 124   die "$0: server error: $r\n";
 125 }
 126
 127 if (($r) = grep /^Location: http/,@r) {
 128   $r =~ s:.*(/fop/\w+/.+$):$1:;
 129   download($r);
 130 } else {
 131   download("/ddd/$mb");
 132 }
 133
 134 exit;
 135
 136
 137 sub formdatapost {
 138   my %P = @_;
 139   my ($boundary,$filename,$filesize,$length);
 140   my (@hh,@hb,@r,@pv);
 141   my ($t,$bt,$t0,$t1,$t2,$tt);
 142   my $buf = '#' x $bs;
 143   local $_;
 144
 145
 146   @hh = (); # HTTP header
 147   @hb = (); # HTTP body
 148   @r = ();
 149
 150   serverconnect($server,$port);
 151
 152   $boundary = randstring(48);
 153   $P{command} = 'CHECKRECIPIENT';
 154
 155   # HTTP POST variables
 156   @pv = qw'from to id command';
 157   foreach my $v (@pv) {
 158     if ($P{$v}) {
 159       my $name = uc($v);
 160       push @hb,"--$boundary";
 161       push @hb,"Content-Disposition: form-data; name=\"$name\"";
 162       push @hb,"";
 163       push @hb,$P{$v};
 164     }
 165   }
 166   push @hb,"--$boundary--";
 167
 168   $length = length(join('',@hb)) + scalar(@hb)*2 + $mb*M;
 169
 170   # HTTP header
 171   push @hh,"POST $proxy_prefix/fup HTTP/1.1";
 172   push @hh,"Host: $server:$port";
 173   push @hh,"User-Agent: $useragent";
 174   push @hh,"Content-Length: $length";
 175   push @hh,"Content-Type: multipart/form-data; boundary=$boundary";
 176   push @hh,"Connection: close";
 177   push @hh,'';
 178
 179   if ($opt_v) {
 180     printf "--> $_\n" foreach (@hh,@hb);
 181   }
 182
 183   nvtsend(@hh,@hb) or die "$0: server has closed the connection\n";
 184
 185   while (<$SH>) {
 186     s/[\r\n]+//;
 187     print "<-- $_\n" if $opt_v;
 188     push @r,$_;
 189     last if /^$/;
 190   }
 191
 192   unless (@r and $r[0] =~ / 204 /) {
 193     $_ = $r[0] || '';
 194     s/^HTTP.[.\d\s]+//;
 195     die "$0: server error: $_\n";
 196   }
 197
 198   @hh = (); # HTTP header
 199   @hb = (); # HTTP body
 200   @r = ();
 201   $filename = 'test_'.int(time*1000);
 202
 203   serverconnect($server,$port);
 204
 205   # HTTP POST variables
 206   @pv = qw'from to id keep autodelete comment filesize';
 207   foreach my $v (@pv) {
 208     if ($P{$v}) {
 209       my $name = uc($v);
 210       push @hb,"--$boundary";
 211       push @hb,"Content-Disposition: form-data; name=\"$name\"";
 212       push @hb,"";
 213       push @hb,$P{$v};
 214     }
 215   }
 216
 217   # at last, the file
 218   push @hb,"--$boundary";
 219   push @hb,"Content-Disposition: form-data; name=\"FILE\"; filename=\"$filename\"";
 220   push @hb,"Content-Type: application/octet-stream";
 221   push @hb,"";
 222   push @hb,"";
 223   push @hb,"--$boundary--";
 224
 225   $length = length(join('',@hb)) + scalar(@hb)*2 + $mb*M;
 226
 227   $hb[-2] = '(file content)';
 228
 229   # HTTP header
 230   push @hh,"POST $proxy_prefix/fup HTTP/1.1";
 231   push @hh,"Host: $server:$port";
 232   push @hh,"User-Agent: $useragent";
 233   push @hh,"Content-Length: $length";
 234   push @hh,"Content-Type: multipart/form-data; boundary=$boundary";
 235   push @hh,"Connection: close";
 236   push @hh,'';
 237
 238   if ($opt_v) {
 239     printf "--> $_\n" foreach (@hh,@hb);
 240   }
 241
 242   pop @hb;
 243   pop @hb;
 244   nvtsend(@hh,@hb) or die "$0: server has closed the connection\n";
 245
 246   $t0 = $t2 = int(time);
 247   $t1 = 0;
 248
 249   autoflush $SH 0;
 250
 251   for (;;) {
 252     print {$SH} $buf or die "$0: server has closed the connection\n";
 253     $b += $bs;
 254     $bt += $bs;
 255     $t2 = time;
 256     if (-t STDOUT and $t2-$t1>1) {
 257       # smaller block size is better on slow links
 258       if ($t1 and $bs>4096 and $bt/($t2-$t0)<65536) {
 259         $bs = 4096;
 260         $buf = '#' x $bs;
 261       }
 262       if ($bs>4096) {
 263         printf STDERR "upload: %s MB of %d MB, %d kB/s        \r",
 264           int($bt/M),
 265           $mb,
 266           int($b/k/($t2-$t1));
 267       } else {
 268         printf STDERR "upload: %s kB of %d MB, %d kB/s        \r",
 269           int($bt/k),
 270           $mb,
 271           int($b/k/($t2-$t1));
 272       }
 273       $t1 = $t2;
 274       $b = 0;
 275     }
 276     last if $bt >= $mb*M;
 277   }
 278
 279   autoflush $SH 1;
 280   print {$SH} "\r\n--$boundary--\r\n";
 281
 282   while (<$SH>) {
 283     s/[\r\n]+//;
 284     print "<-- $_\n" if $opt_v;
 285     last if @r and $r[0] =~ / 204 / and /^$/ or /<\/html>/i;
 286     push @r,$_;
 287   }
 288
 289   $tt = (time-$t0)||1;
 290   printf STDERR "upload: %d MB in %d s, %d kB/s        \n",
 291                 int($bt/M),$tt,int($bt/k/$tt);
 292
 293   close $SH;
 294   undef $SH;
 295
 296   return @r;
 297 }
 298
 299
 300 sub randstring {
 301     my $n = shift;
 302     my @rc = ('A'..'Z','a'..'z',0..9 );
 303     my $rn = @rc;
 304     my $rs;
 305
 306     for (1..$n) { $rs .= $rc[int(rand($rn))] };
 307     return $rs;
 308 }
 309
 310
 311 sub serverconnect {
 312   my ($server,$port) = @_;
 313   my $connect = "CONNECT $server:$port HTTP/1.1";
 314   local $_;
 315
 316   if ($proxy) {
 317     tcpconnect(split(':',$proxy));
 318     if ($port == 443) {
 319       printf "--> %s\n",$connect if $opt_v;
 320       nvtsend($connect,"");
 321       $_ = <$SH>;
 322       s/\r//;
 323       printf "<-- $_"if $opt_v;
 324       unless (/^HTTP.1.. 200/) {
 325         die "$0: proxy error : $_";
 326       }
 327       eval "use IO::Socket::SSL";
 328       die "$0: cannot load IO::Socket::SSL\n" if $@;
 329       $SH = IO::Socket::SSL->start_SSL($SH);
 330     }
 331   } else {
 332     tcpconnect($server,$port);
 333   }
 334 }
 335
 336
 337 # set up tcp/ip connection
 338 sub tcpconnect {
 339   my ($server,$port) = @_;
 340
 341   if ($SH) {
 342     close $SH;
 343     undef $SH;
 344   }
 345
 346   if ($port == 443) {
 347     eval "use IO::Socket::SSL";
 348     die "$0: cannot load IO::Socket::SSL\n" if $@;
 349     $SH = IO::Socket::SSL->new(
 350       PeerAddr => $server,
 351       PeerPort => $port,
 352       Proto    => 'tcp',
 353     );
 354   } else {
 355     $SH = IO::Socket::INET->new(
 356       PeerAddr => $server,
 357       PeerPort => $port,
 358       Proto    => 'tcp',
 359     );
 360   }
 361
 362   if ($SH) {
 363     autoflush $SH 1;
 364   } else {
 365     die "$0: cannot connect $server:$port - $@\n";
 366   }
 367
 368   print "TCPCONNECT to $server:$port\n" if $opt_v;
 369 }
 370
 371
 372 sub nvtsend {
 373   local $SIG{PIPE} = sub { $sigpipe = "@_" };
 374
 375   $sigpipe = '';
 376
 377   die "$0: internal error: no active network handle\n" unless $SH;
 378   die "$0: remote host has closed the link\n" unless $SH->connected;
 379
 380   foreach my $line (@_) {
 381     print {$SH} $line,"\r\n";
 382     if ($sigpipe) {
 383       undef $SH;
 384       return 0;
 385     }
 386   }
 387
 388   return 1;
 389 }
 390
 391
 392 sub mtime {
 393   my @d = localtime((stat shift)[9]);
 394   return sprintf('%d%02d%02d',$d[5]+1900,$d[4]+1,$d[3]);
 395 }
 396
 397
 398 sub download {
 399   my $fop = shift;
 400   my ($file);
 401   my ($t0,$t1,$t2,$tt,$kBs,$b,$bt,$tb,$B,$buf);
 402   my $length = 0;
 403   local $_;
 404
 405   serverconnect($server,$port);
 406
 407   sendheader(
 408     "GET $proxy_prefix$fop HTTP/1.1",
 409     "User-Agent: $useragent",
 410     "Host: $server:$port",
 411   );
 412
 413   $_ = <$SH>;
 414   die "$0: no response from fex server $server\n" unless $_;
 415   s/\r//;
 416
 417   if (/^HTTP\/[\d.]+ 2/) {
 418     warn "<-- $_" if $opt_v;
 419     while (<$SH>) {
 420       s/\r//;
 421       print "<-- $_" if $opt_v;
 422       last if /^\r?\n/;
 423       if (/^Content-length:\s*(\d+)/i) {
 424         $length = $1;
 425       }
 426     }
 427   } else {
 428     s/HTTP\/[\d.]+ \d+ //;
 429     die "$0: bad server reply: $_";
 430   }
 431
 432   $t0 = $t1 = $t2 = int(time);
 433   $tb = $B = 0;
 434   while ($B < $length and $b = read $SH,$buf,$bs) {
 435     $B += $b;
 436     $tb += $b;
 437     $bt += $b;
 438     $t2 = time;
 439     if (int($t2) > $t1) {
 440       $kBs = int($bt/k/($t2-$t1));
 441       $kBs = int($tb/k/($t2-$t0)) if $kBs < 10;
 442       $t1 = $t2;
 443       $bt = 0;
 444       # smaller block size is better on slow links
 445       $bs = 4096 if $bs>4096 and $tb/($t2-$t0)<65536;
 446       printf STDERR "download: %d MB in %d s, %d kB/s        \r",
 447                     int($tb/M),$t2-$t0,$kBs;
 448     }
 449   }
 450   close $SH;
 451
 452   $tt = $t2-$t0;
 453   $kBs = int($tb/k/($tt||1));
 454   printf STDERR "download: %d MB in %d s, %d kB/s        \n",
 455                 int($tb/M),$tt,$kBs;
 456 }
 457
 458
 459 sub sendheader {
 460   my @head = @_;
 461   my $head;
 462
 463   foreach $head (@head) {
 464     print "--> $head\n" if $opt_v;
 465     print {$SH} $head,"\r\n";
 466   }
 467   print "-->\n" if $opt_v;
 468   print {$SH} "\r\n";
 469 }