Mercurial > stress-tester

changeset 1165:f04a0325dc2c

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
bugfixes
author Devel 2
date Tue, 16 Jun 2020 10:18:57 +0200
parents 1ddc11cdcb31
children 6b12314c35e5
files stress-tester/src/main/java/com/passus/st/client/SynchFlowWorker.java stress-tester/src/main/java/com/passus/st/emitter/socket/SocketConnection.java
diffstat 2 files changed, 3 insertions(+), 3 deletions(-) [+]
line wrap: on
line diff
--- a/stress-tester/src/main/java/com/passus/st/client/SynchFlowWorker.java	Tue Jun 16 08:07:00 2020 +0200
+++ b/stress-tester/src/main/java/com/passus/st/client/SynchFlowWorker.java	Tue Jun 16 10:18:57 2020 +0200
@@ -26,13 +26,15 @@
 
     protected final Logger logger = LogManager.getLogger(getClass());
 
+    private final int DEFAULT_QUEUE_CAPACITY = 1000;
+
     public static final String TYPE = "synch";
 
     private volatile boolean working = false;
 
     protected final Map<SessionInfo, FlowContext> sessions = new ConcurrentHashMap<>();
 
-    private final LinkedBlockingDeque<Event> eventsQueue = new LinkedBlockingDeque<>();
+    private final LinkedBlockingDeque<Event> eventsQueue = new LinkedBlockingDeque<>(DEFAULT_QUEUE_CAPACITY);
 
     private final PerNameMetricsContainer deferredMetrics = new PerNameMetricsContainer();
 
--- a/stress-tester/src/main/java/com/passus/st/emitter/socket/SocketConnection.java	Tue Jun 16 08:07:00 2020 +0200
+++ b/stress-tester/src/main/java/com/passus/st/emitter/socket/SocketConnection.java	Tue Jun 16 10:18:57 2020 +0200
@@ -38,8 +38,6 @@
 
     private OutputStream out;
 
-    private SocketAddress remoteAddress;
-
     private int bufferSize = DEFAULT_BUFFER_SIZE;
 
     private byte[] readBuffer = new byte[bufferSize];