Mercurial > stress-tester

changeset 1131:0759f67a8f79

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
SnmpService.initialDelay
author Devel 1
date Mon, 08 Jun 2020 13:10:13 +0200
parents f4b74fec7584
children 04da438495fb
files stress-tester/src/main/java/com/passus/st/emitter/raw/DpdkUnidirectionalRawPacketWorker.java stress-tester/src/main/java/com/passus/st/snmp/SnmpService.java
diffstat 2 files changed, 2 insertions(+), 4 deletions(-) [+]
line wrap: on
line diff
--- a/stress-tester/src/main/java/com/passus/st/emitter/raw/DpdkUnidirectionalRawPacketWorker.java	Mon Jun 08 11:55:22 2020 +0200
+++ b/stress-tester/src/main/java/com/passus/st/emitter/raw/DpdkUnidirectionalRawPacketWorker.java	Mon Jun 08 13:10:13 2020 +0200
@@ -119,8 +119,7 @@
                 bufferPkts = 0;
             }
         }
-        scheduler = new DefaultScheduledTimerService(getClass().getSimpleName() + "-Scheduler", bufferFlushPeriod);
-        scheduler.setCallback(this::flushBuffer);
+        scheduler = new DefaultScheduledTimerService(getClass().getSimpleName() + "-Scheduler", bufferFlushPeriod, this::flushBuffer);
         scheduler.start();
     }
 
--- a/stress-tester/src/main/java/com/passus/st/snmp/SnmpService.java	Mon Jun 08 11:55:22 2020 +0200
+++ b/stress-tester/src/main/java/com/passus/st/snmp/SnmpService.java	Mon Jun 08 13:10:13 2020 +0200
@@ -11,7 +11,6 @@
 import com.passus.config.annotations.NodeDefinitionCreate;
 import com.passus.config.schema.NodeDefinition;
 import com.passus.config.schema.NodeDefinitionCreator;
-import com.passus.st.Log4jConfigurationFactory;
 import com.passus.st.metric.MetricSource;
 import com.passus.st.metric.MetricsContainer;
 import com.passus.st.utils.PeriodValueTransformer;
@@ -107,7 +106,7 @@
                 }
             });
 
-            scheduledTimerService = new DefaultScheduledTimerService("SnmpService.Scheduler", interval, this::sendAll);
+            scheduledTimerService = new DefaultScheduledTimerService("SnmpService.Scheduler", interval, initialDelay, this::sendAll);
             scheduledTimerService.start();
             started = true;
         } catch (IOException e) {