org.apache.activemq.artemis.core.io.aio

Class AIOSequentialFileFactory.AIOSequentialCallback

java.lang.Object

org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory.AIOSequentialCallback

All Implemented Interfaces:

Comparable<AIOSequentialFileFactory.AIOSequentialCallback>, Runnable, SubmitInfo

Enclosing class:

AIOSequentialFileFactory

public class AIOSequentialFileFactory.AIOSequentialCallback
extends Object
implements SubmitInfo, Runnable, Comparable<AIOSequentialFileFactory.AIOSequentialCallback>

The same callback is used for Runnable executor. This way we can save some memory over the pool.

Constructor Summary

Constructors

Constructor and Description
AIOSequentialCallback()

Method Summary

Modifier and Type	Method and Description
int	compareTo(AIOSequentialFileFactory.AIOSequentialCallback other)
void	done() this is called by libaio.
AIOSequentialFileFactory.AIOSequentialCallback	init(long writeSequence, IOCallback IOCallback, LibaioFile libaioFile, AIOSequentialFile sequentialFile, ByteBuffer usedBuffer)
AIOSequentialFileFactory.AIOSequentialCallback	initWrite(long positionToWrite, int bytesToWrite)
void	onError(int errno, String message)
void	run()
void	sequentialDone() This is callbed by the AIOSequentialFile, after determined the callbacks were returned in sequence
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

AIOSequentialCallback

public AIOSequentialCallback()

Method Detail

toString

public String toString()

Overrides:

toString in class Object

initWrite

public AIOSequentialFileFactory.AIOSequentialCallback initWrite(long positionToWrite,
                                                                int bytesToWrite)

run

public void run()

Specified by:

run in interface Runnable

compareTo

public int compareTo(AIOSequentialFileFactory.AIOSequentialCallback other)

Specified by:

compareTo in interface Comparable<AIOSequentialFileFactory.AIOSequentialCallback>

init

public AIOSequentialFileFactory.AIOSequentialCallback init(long writeSequence,
                                                           IOCallback IOCallback,
                                                           LibaioFile libaioFile,
                                                           AIOSequentialFile sequentialFile,
                                                           ByteBuffer usedBuffer)

onError

public void onError(int errno,
                    String message)

Specified by:

onError in interface SubmitInfo

done

public void done()

this is called by libaio.

Specified by:

done in interface SubmitInfo

sequentialDone

public void sequentialDone()

This is callbed by the AIOSequentialFile, after determined the callbacks were returned in sequence