public abstract class ProxyChannelRingBuffer
extends java.lang.Object
ProxyChannelFactory| Modifier and Type | Field and Description |
|---|---|
static long |
EOF |
| Constructor and Description |
|---|
ProxyChannelRingBuffer() |
| Modifier and Type | Method and Description |
|---|---|
protected abstract long |
consumerReferenceArrayIndex(long offset)
Get the position index of the consumer in the reference array
|
protected abstract long |
producerReferenceArrayIndex(long offset)
Get the position index of the producer in the reference array
|
protected abstract long |
readAcquire()
Acquire an offset to read from
|
protected abstract java.lang.Object |
readReference(long index)
Read a reference from the index of the reference array.
|
protected abstract void |
readRelease(long offset)
Release the offset from reading
|
protected abstract long |
writeAcquire()
Acquire an offset to write to.
|
protected abstract void |
writeReference(long index,
java.lang.Object reference)
Write a reference into the index of the reference array.
|
protected abstract void |
writeRelease(long offset,
int callTypeId)
Ordered store of the callTypeId for the message at offset
|
public static final long EOF
protected abstract long writeAcquire()
EOFprotected abstract void writeRelease(long offset,
int callTypeId)
offset - the offset that was released for writingcallTypeId - A unique ID for the callprotected abstract long readAcquire()
EOFprotected abstract void readRelease(long offset)
offset - the offset to release for readingprotected abstract long consumerReferenceArrayIndex(long offset)
offset - the current offset of the consumer returned from readAcquire()protected abstract long producerReferenceArrayIndex(long offset)
offset - the current offset of the producer returned from writeAcquire()protected abstract void writeReference(long index,
java.lang.Object reference)
index - the index to write toreference - the reference to writeprotected abstract java.lang.Object readReference(long index)
index - the index to read from