Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/org.eclipse.net4j.tcp/src/org/eclipse/net4j/internal/tcp/TCPSelector.java')
-rw-r--r--plugins/org.eclipse.net4j.tcp/src/org/eclipse/net4j/internal/tcp/TCPSelector.java11
1 files changed, 6 insertions, 5 deletions
diff --git a/plugins/org.eclipse.net4j.tcp/src/org/eclipse/net4j/internal/tcp/TCPSelector.java b/plugins/org.eclipse.net4j.tcp/src/org/eclipse/net4j/internal/tcp/TCPSelector.java
index 5e7e6ce785..4c989956d1 100644
--- a/plugins/org.eclipse.net4j.tcp/src/org/eclipse/net4j/internal/tcp/TCPSelector.java
+++ b/plugins/org.eclipse.net4j.tcp/src/org/eclipse/net4j/internal/tcp/TCPSelector.java
@@ -146,8 +146,8 @@ public class TCPSelector extends Lifecycle implements ITCPSelector, Runnable
{
try
{
- execute(clientOperations);
- execute(serverOperations);
+ execute(true);
+ execute(false);
if (selector != null && selector.select() > 0)
{
Iterator<SelectionKey> it = selector.selectedKeys().iterator();
@@ -327,7 +327,7 @@ public class TCPSelector extends Lifecycle implements ITCPSelector, Runnable
{
if (TRACER.isEnabled())
{
- TRACER.trace("Ordering operation " + operation);
+ TRACER.format("Ordering {0} operation {1}", client, operation);
}
if (client)
@@ -345,14 +345,15 @@ public class TCPSelector extends Lifecycle implements ITCPSelector, Runnable
}
}
- private void execute(Queue<Runnable> operations)
+ private void execute(boolean client)
{
Runnable operation;
+ Queue<Runnable> operations = client ? clientOperations : serverOperations;
while ((operation = operations.poll()) != null)
{
if (TRACER.isEnabled())
{
- TRACER.trace("Executing operation " + operation);
+ TRACER.format("Ordering {0} operation {1}", client, operation);
}
operation.run();

Back to the top