Mercurial > stress-tester

changeset 1281:b181731fc098

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
DPDK emitter - workaround crash in DpdkAO.sendPackets0 / rte_pktmbuf_alloc(mempool)
author Devel 1
date Thu, 09 Jul 2020 11:39:10 +0200
parents f5ba6579b526
children 636f73c0cb9f
files stress-tester/src/main/java/com/passus/st/emitter/raw/DpdkUnidirectionalRawPacketWorker.java
diffstat 1 files changed, 3 insertions(+), 2 deletions(-) [+]
line wrap: on
line diff
--- a/stress-tester/src/main/java/com/passus/st/emitter/raw/DpdkUnidirectionalRawPacketWorker.java	Thu Jul 09 11:34:40 2020 +0200
+++ b/stress-tester/src/main/java/com/passus/st/emitter/raw/DpdkUnidirectionalRawPacketWorker.java	Thu Jul 09 11:39:10 2020 +0200
@@ -132,8 +132,8 @@
                 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();
             }
         }
     }
@@ -175,6 +175,7 @@
 
     @Override
     protected void doClose0(UnidirectionalRawPacketChannelContext<DpdkAO> channelContext) {
+        flushBuffer();
         synchronized (DpdkAO.class) {
             if (dpdkInitCalls > 0) {
                 dpdkInitCalls--;