Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/buffer/Buffer.java')
-rw-r--r--plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/buffer/Buffer.java21
1 files changed, 19 insertions, 2 deletions
diff --git a/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/buffer/Buffer.java b/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/buffer/Buffer.java
index f58ba8efc0..cef09247ef 100644
--- a/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/buffer/Buffer.java
+++ b/plugins/org.eclipse.net4j/src/org/eclipse/internal/net4j/buffer/Buffer.java
@@ -7,6 +7,7 @@
*
* Contributors:
* Eike Stepper - initial API and implementation
+ * Caspar De Groot - maintenance
*/
package org.eclipse.internal.net4j.buffer;
@@ -31,10 +32,11 @@ import java.text.MessageFormat;
/**
* @author Eike Stepper
+ * @since 4.0
*/
public class Buffer implements InternalBuffer
{
- private static final int EOS_OFFSET = 1;
+ public static final int EOS_OFFSET = 1;
private static final ContextTracer TRACER = new ContextTracer(OM.DEBUG_BUFFER, Buffer.class);
@@ -86,6 +88,11 @@ public class Buffer implements InternalBuffer
return channelID;
}
+ public void setChannelID(short channelID)
+ {
+ this.channelID = channelID;
+ }
+
public short getCapacity()
{
return (short)byteBuffer.capacity();
@@ -96,6 +103,11 @@ public class Buffer implements InternalBuffer
return state;
}
+ public void setState(BufferState state)
+ {
+ this.state = state;
+ }
+
public ByteBuffer getByteBuffer()
{
if (state != BufferState.GETTING && state != BufferState.PUTTING)
@@ -106,6 +118,11 @@ public class Buffer implements InternalBuffer
return byteBuffer;
}
+ public void setByteBuffer(ByteBuffer buffer)
+ {
+ byteBuffer = buffer;
+ }
+
public void clear()
{
state = BufferState.INITIAL;
@@ -389,7 +406,7 @@ public class Buffer implements InternalBuffer
this.errorHandler = errorHandler;
}
- private void handleError(Throwable t)
+ public void handleError(Throwable t)
{
if (errorHandler != null)
{

Back to the top