Modifier and Type | Class and Description |
---|---|
class |
DummyCallback |
Modifier and Type | Method and Description |
---|---|
int |
SequentialFile.read(ByteBuffer bytes,
IOCallback callback) |
void |
SequentialFile.write(ActiveMQBuffer bytes,
boolean sync,
IOCallback callback) |
void |
AbstractSequentialFile.write(ActiveMQBuffer bytes,
boolean sync,
IOCallback callback) |
void |
SequentialFile.write(EncodingSupport bytes,
boolean sync,
IOCallback callback) |
void |
AbstractSequentialFile.write(EncodingSupport bytes,
boolean sync,
IOCallback callback) |
void |
SequentialFile.writeDirect(ByteBuffer bytes,
boolean sync,
IOCallback callback)
Write directly to the file without using any buffer
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractSequentialFile.LocalBufferObserver.flushBuffer(ByteBuffer buffer,
boolean requestedSync,
List<IOCallback> callbacks) |
Modifier and Type | Method and Description |
---|---|
AIOSequentialFileFactory.AIOSequentialCallback |
AIOSequentialFileFactory.AIOSequentialCallback.init(long writeSequence,
IOCallback IOCallback,
LibaioFile libaioFile,
AIOSequentialFile sequentialFile,
ByteBuffer usedBuffer) |
int |
AIOSequentialFile.read(ByteBuffer bytes,
IOCallback callback) |
void |
AIOSequentialFile.writeDirect(ByteBuffer bytes,
boolean sync,
IOCallback callback)
Note: Parameter sync is not used on AIO
|
Modifier and Type | Method and Description |
---|---|
void |
TimedBuffer.addBytes(ActiveMQBuffer bytes,
boolean sync,
IOCallback callback) |
void |
TimedBuffer.addBytes(EncodingSupport bytes,
boolean sync,
IOCallback callback) |
Modifier and Type | Method and Description |
---|---|
void |
TimedBufferObserver.flushBuffer(ByteBuffer buffer,
boolean syncRequested,
List<IOCallback> callbacks) |
Modifier and Type | Method and Description |
---|---|
int |
NIOSequentialFile.read(ByteBuffer bytes,
IOCallback callback) |
void |
NIOSequentialFile.writeDirect(ByteBuffer bytes,
boolean sync,
IOCallback callback) |
Modifier and Type | Interface and Description |
---|---|
interface |
IOCompletion |
Modifier and Type | Class and Description |
---|---|
class |
SimpleWaitIOCallback |
class |
SyncIOCompletion
Internal class used to manage explicit syncs on the Journal through callbacks.
|
class |
TransactionCallback |
Modifier and Type | Method and Description |
---|---|
IOCallback |
TransactionCallback.getDelegateCompletion() |
Modifier and Type | Method and Description |
---|---|
void |
TransactionCallback.setDelegateCompletion(IOCallback delegateCompletion) |
Modifier and Type | Interface and Description |
---|---|
interface |
OperationContext
This represents a set of operations done as part of replication.
|
Modifier and Type | Method and Description |
---|---|
void |
StorageManager.afterCompleteOperations(IOCallback run) |
void |
StorageManager.afterStoreOperations(IOCallback run)
This is similar to afterComplete, however this only cares about the journal part.
|
void |
OperationContext.executeOnCompletion(IOCallback runnable)
Execute the task when all IO operations are complete,
Or execute it immediately if nothing is pending.
|
void |
OperationContext.executeOnCompletion(IOCallback runnable,
boolean storeOnly)
Execute the task when all IO operations are complete,
Or execute it immediately if nothing is pending.
|
Modifier and Type | Class and Description |
---|---|
class |
OperationContextImpl
Each instance of OperationContextImpl is associated with an executor (usually an ordered Executor).
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractJournalStorageManager.afterCompleteOperations(IOCallback run) |
void |
AbstractJournalStorageManager.afterStoreOperations(IOCallback run) |
void |
OperationContextImpl.executeOnCompletion(IOCallback runnable) |
void |
OperationContextImpl.executeOnCompletion(IOCallback completion,
boolean storeOnly) |
Modifier and Type | Method and Description |
---|---|
void |
NullStorageManager.afterCompleteOperations(IOCallback run) |
void |
NullStorageManager.afterStoreOperations(IOCallback run) |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQServerLogger.pageSubscriptionError(IOCallback IOCallback,
String error) |
Modifier and Type | Method and Description |
---|---|
int |
JDBCSequentialFile.internalWrite(ActiveMQBuffer buffer,
IOCallback callback) |
int |
JDBCSequentialFile.read(ByteBuffer bytes,
IOCallback callback) |
void |
JDBCSequentialFile.write(ActiveMQBuffer bytes,
boolean sync,
IOCallback callback) |
void |
JDBCSequentialFile.write(EncodingSupport bytes,
boolean sync,
IOCallback callback) |
void |
JDBCSequentialFile.writeDirect(ByteBuffer bytes,
boolean sync,
IOCallback callback) |
Copyright © 2018 JBoss by Red Hat. All rights reserved.