summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorEike Stepper2007-08-30 02:34:39 (EDT)
committerEike Stepper2007-08-30 02:34:39 (EDT)
commit6d1a84c908d8be716c62205b08ec9b3865cbbd9c (patch)
tree5bea9de3c4a3d5742f653aa9159c89f81ce18a4a
parentd696795f6cee0998f327657d0ae70b700485822d (diff)
downloadcdo-6d1a84c908d8be716c62205b08ec9b3865cbbd9c.zip
cdo-6d1a84c908d8be716c62205b08ec9b3865cbbd9c.tar.gz
cdo-6d1a84c908d8be716c62205b08ec9b3865cbbd9c.tar.bz2
*** empty log message ***
-rw-r--r--plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/Channel.java18
1 files changed, 9 insertions, 9 deletions
diff --git a/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/Channel.java b/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/Channel.java
index 7dbcd92..dbddb4d 100644
--- a/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/Channel.java
+++ b/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/Channel.java
@@ -173,19 +173,19 @@ public class Channel extends Lifecycle implements IChannel, IBufferProvider
public void handleBufferFromMultiplexer(final IBuffer buffer)
{
- if (receiveHandler == null)
+ if (receiveHandler != null)
{
- OM.LOG.warn("Ignoring buffer because receiveHandler == null: " + this); //$NON-NLS-1$
- buffer.release();
- return;
- }
+ if (TRACER.isEnabled())
+ {
+ TRACER.format("Handling buffer from multiplexer: {0} --> {1}", buffer, this); //$NON-NLS-1$
+ }
- if (TRACER.isEnabled())
+ receiveSerializer.addWork(new ReceiverWork(buffer));
+ }
+ else
{
- TRACER.format("Handling buffer from multiplexer: {0} --> {1}", buffer, this); //$NON-NLS-1$
+ buffer.release();
}
-
- receiveSerializer.addWork(new ReceiverWork(buffer));
}
@Override