Browse Source

Limit the number of inflight items to the number of items.

cypherpunks 8 years ago
parent
commit
c68b341882
1 changed files with 5 additions and 0 deletions
  1. 5 0
      src/test/test_workqueue.c

+ 5 - 0
src/test/test_workqueue.c

@@ -353,6 +353,7 @@ main(int argc, char **argv)
       return 1;
     }
   }
+
   if (opt_n_threads < 1 ||
       opt_n_items < 1 || opt_n_inflight < 1 || opt_n_lowwater < 0 ||
       opt_n_cancel > opt_n_inflight || opt_n_inflight > MAX_INFLIGHT ||
@@ -361,6 +362,10 @@ main(int argc, char **argv)
     return 1;
   }
 
+  if (opt_n_inflight > opt_n_items) {
+      opt_n_inflight = opt_n_items;
+  }
+
   init_logging(1);
   crypto_global_init(1, NULL, NULL);
   crypto_seed_rng();