Mercurial > stress-tester

changeset 1274:f9f429b781da

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
DpdkUnidirectionalRawPacketWorker - bugfix
author Devel 1
date Tue, 07 Jul 2020 15:14:16 +0200
parents ea44baa39214
children 05273ffd04e1
files stress-tester/src/main/java/com/passus/st/emitter/raw/DpdkUnidirectionalRawPacketWorker.java
diffstat 1 files changed, 4 insertions(+), 4 deletions(-) [+]
line wrap: on
line diff
--- a/stress-tester/src/main/java/com/passus/st/emitter/raw/DpdkUnidirectionalRawPacketWorker.java	Tue Jul 07 15:00:15 2020 +0200
+++ b/stress-tester/src/main/java/com/passus/st/emitter/raw/DpdkUnidirectionalRawPacketWorker.java	Tue Jul 07 15:14:16 2020 +0200
@@ -1,7 +1,6 @@
 package com.passus.st.emitter.raw;
 
 import com.passus.commons.time.DefaultScheduledTimerService;
-import com.passus.commons.time.ScheduledTimerCallback;
 import com.passus.commons.time.ScheduledTimerService;
 import com.passus.dpdk.DpdkAO;
 import com.passus.net.MACAddress;
@@ -18,7 +17,7 @@
 public class DpdkUnidirectionalRawPacketWorker extends UnidirectionalRawPacketWorker<DpdkAO> {
 
     public static final int MAX_BUFFER_SIZE = DpdkAO.sendBuffSize();
-    public static final int DEFAULT_BUFFER_SIZE = MAX_BUFFER_SIZE;
+    public static final int DEFAULT_BUFFER_SIZE = 0;
     public static final long DEFAULT_FLUSH_PERIOD = 50;
 
     private DpdkAO dpdkAO;
@@ -117,10 +116,11 @@
                 bufferBytes = new byte[bufferSize][];
                 bufferLengths = new int[bufferSize];
                 bufferPkts = 0;
+
+                scheduler = new DefaultScheduledTimerService(getClass().getSimpleName() + "-Scheduler", bufferFlushPeriod, this::flushBuffer);
+                scheduler.start();
             }
         }
-        scheduler = new DefaultScheduledTimerService(getClass().getSimpleName() + "-Scheduler", bufferFlushPeriod, this::flushBuffer);
-        scheduler.start();
     }
 
     @Override