libnicbm: fixes for unsynchronized operation

b6d44191 · Antoine Kaufmann · 0a67f9b1 · b6d44191
Commit b6d44191 authored Sep 16, 2020 by Antoine Kaufmann
Show whitespace changes
Inline Side-by-side

Showing with 4 additions and 1 deletion

libnicbm/nicbm.cc libnicbm/nicbm.cc +4 -1

No files found.
--- a/libnicbm/nicbm.cc
+++ b/libnicbm/nicbm.cc
@@ -332,6 +332,7 @@ Runner::Runner(Device &dev_)
 int Runner::runMain(int argc, char *argv[])
 {
    uint64_t next_ts;
+    uint64_t max_step = 10000;

    if (argc != 4 && argc != 5) {
        fprintf(stderr, "Usage: corundum_bm PCI-SOCKET ETH-SOCKET "
@@ -376,8 +377,10 @@ int Runner::runMain(int argc, char *argv[])

            if (is_sync) {
                next_ts = netsim_next_timestamp(&nsparams);
+                if (next_ts > main_time + max_step)
+                    next_ts = main_time + max_step;
            } else {
-                next_ts = main_time + 100000;
+                next_ts = main_time + max_step;
            }

            uint64_t ev_ts;