Package | Description |
---|---|
org.jlab.coda.hipo |
Modifier and Type | Method and Description |
---|---|
RecordRingItem |
RecordSupply.get()
Get the next available record item from the ring buffer.
|
RecordRingItem |
RecordSupply.getToCompress(int threadNumber)
Get the next available record item from the ring buffer
in order to compress the data already in it.
|
RecordRingItem |
RecordSupply.getToWrite()
Get the next available record item from the ring buffer
in order to write data into it.
|
Modifier and Type | Method and Description |
---|---|
void |
RecordSupply.publish(RecordRingItem item)
Tell consumers that the record item is ready for consumption.
|
void |
RecordSupply.releaseCompressor(RecordRingItem item)
A compressing thread releases its claim on the given ring buffer item
so it becomes available for use by writing thread behind the write barrier.
|
boolean |
RecordSupply.releaseWriter(RecordRingItem item)
A writer thread releases its claim on the given ring buffer item
so it becomes available for reuse by the producer.
|
boolean |
RecordSupply.releaseWriterSequential(RecordRingItem item)
A writer thread releases its claim on the given ring buffer item
so it becomes available for reuse by the producer.
|
Constructor and Description |
---|
RecordRingItem(RecordRingItem item)
Copy constructor (sort of).
|