Changeset 45d3453 in lab.git for misc

Timestamp:

Mar 6, 2014 5:38:23 PM (10 years ago)

Author:

Ken-ichi Mito <mitty@…>

Branches:

master

Children:

178d578

Parents:

8c96802

Message:

refactor concurrent loops

File:

• misc/httpbench.pl (modified) (1 diff)

misc/httpbench.pl

@@ -49 +49 @@
 
 my ($startsec, $startmicro) = gettimeofday();
-{
+for (my $child = 0; $child < $concurrency; $child++) {
     use bytes;
-    for (my $child = 0; $child < $concurrency; $child++) {
-        if ($pm->start) {
-            warn "forks $child/$concurrency child ...\n";
-            next;
+    if ($pm->start) {
+        # parent
+        warn "forks $child/$concurrency child ...\n";
+    }
+    else {
+        # child
+        my $transfer = 0;
+        for (my $i = 0; $i < $loops; $i++) {
+            print STDERR "processing $i/$loops loop\r";
+            foreach my $url (@urls) {
+                my $res = $ua->get($url);
+                if ($res->is_success) {
+                    $transfer += length($res->content);
+                }
+                else {
+                    print STDERR "\nfail: $url";
+                }
+                sleep($wait);
+            }
         }
-            my $transfer = 0;
-            for (my $i = 0; $i < $loops; $i++) {
-                print STDERR "processing $i/$loops loop\r";
-                foreach my $url (@urls) {
-                    my $res = $ua->get($url);
-                    if ($res->is_success) {
-                        $transfer += length($res->content);
-                    }
-                    else {
-                        print STDERR "\nfail: $url";
-                    }
-                    sleep($wait);
-                }
-            }
         $pm->finish(0, \$transfer);
     }
-    $pm->wait_all_children;
 }
+$pm->wait_all_children;
 my ($endsec, $endmicro) = gettimeofday();
 my $elapsed = ($endsec - $startsec) + ($endmicro - $startmicro) / 10**6;