diff options
author | Eike Stepper | 2007-08-30 06:34:39 +0000 |
---|---|---|
committer | Eike Stepper | 2007-08-30 06:34:39 +0000 |
commit | 6d1a84c908d8be716c62205b08ec9b3865cbbd9c (patch) | |
tree | 5bea9de3c4a3d5742f653aa9159c89f81ce18a4a | |
parent | d696795f6cee0998f327657d0ae70b700485822d (diff) | |
download | cdo-6d1a84c908d8be716c62205b08ec9b3865cbbd9c.tar.gz cdo-6d1a84c908d8be716c62205b08ec9b3865cbbd9c.tar.xz cdo-6d1a84c908d8be716c62205b08ec9b3865cbbd9c.zip |
*** empty log message ***
-rw-r--r-- | plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/Channel.java | 18 |
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 7dbcd923f0..dbddb4ddf4 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 |