Mercurial > stress-tester

changeset 1278:d07d00c530e8

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
minor
author Devel 1
date Thu, 09 Jul 2020 10:41:37 +0200
parents ad2aad6439da
children 895cbec4d75c
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 10:23:22 2020 +0200
+++ b/stress-tester/src/main/java/com/passus/st/emitter/raw/DpdkUnidirectionalRawPacketWorker.java	Thu Jul 09 10:41:37 2020 +0200
@@ -11,6 +11,7 @@
 
 import java.io.IOException;
 import java.net.NetworkInterface;
+import java.util.Arrays;
 
 import static com.passus.st.emitter.EmitterUtils.getConnectionParams;
 
@@ -96,7 +97,8 @@
         }
 
         MACAddress remoteMac = macResolver.resolve(remoteAddress.getIp());
-        UnidirectionalRawPacketChannelContext<DpdkAO> channelContext = new UnidirectionalRawPacketChannelContext(this, handler, sessionInfo, localAddress, remoteAddress, localMac, remoteMac);
+        UnidirectionalRawPacketChannelContext<DpdkAO> channelContext = new UnidirectionalRawPacketChannelContext(
+                this, handler, sessionInfo, localAddress, remoteAddress, localMac, remoteMac);
         prepareFrameTemplate(channelContext);
         sessions.put(sessionInfo, channelContext);
         try {
@@ -163,7 +165,6 @@
                 }
             }
         } else {
-            System.out.println("xxx " + length + " " + frame.length);
             int res = DpdkAO.sendPacket(length, frame);
             if (res < 0) {
                 throw new IOException("Unable to send packet. DPDK error.");