commit 82445bc1cbc2e169e4bcfe78ad5ce4f610a56529
author Weicai Yang <weicai@google.com> Thu Apr 02 13:38:02 2020 -0700
committer sriyerg <46467186+sriyerg@users.noreply.github.com> Tue Apr 07 01:36:26 2020 -0700
tree edbc3745f780f28498e3f8fb6658a8d2120a38db
parent 09e0f1deb5455eb7b756bb9fb185fecea0c8262c

[dvsim] Add control of max job submission per second

default is up to 20 jobs per second
Signed-off-by: Weicai Yang <weicai@google.com>

util/dvsim/Deploy.py

diff --git a/util/dvsim/Deploy.py b/util/dvsim/Deploy.py
index d7e2a68..44d2a5d 100644
--- a/util/dvsim/Deploy.py
+++ b/util/dvsim/Deploy.py
@@ -39,6 +39,8 @@
     print_interval = 5
     max_parallel = 16
     max_odirs = 5
+    # Max jobs dispatched in one go.
+    slot_limit = 20
 
     def __self_str__(self):
         if log.getLogger().isEnabledFor(VERBOSE):
@@ -460,6 +462,8 @@
             all_done = (len(queued_items) == 0)
             if not all_done:
                 num_slots = Deploy.max_parallel - Deploy.dispatch_counter
+                if num_slots > Deploy.slot_limit:
+                    num_slots = Deploy.slot_limit
                 if num_slots > 0:
                     if len(queued_items) > num_slots:
                         dispatch_items(queued_items[0:num_slots])