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()
EOF
protected abstract void writeRelease(long offset, int callTypeId)
offset
- the offset that was released for writingcallTypeId
- A unique ID for the callprotected abstract long readAcquire()
EOF
protected 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