com.caucho.message.journal
Class JournalRingItem
java.lang.Object
com.caucho.util.RingItem
com.caucho.message.journal.JournalRingItem
- Direct Known Subclasses:
- NautilusRingItem
public class JournalRingItem
- extends RingItem
Interface for the transaction log.
MQueueJournal is not thread safe. It is intended to be used by a
single thread.
Method Summary |
void |
freeTempBuffer()
|
long |
getBlockAddr()
|
byte[] |
getBuffer()
|
long |
getCode()
|
int |
getLength()
|
long |
getMid()
|
int |
getOffset()
|
long |
getQid()
|
JournalResult |
getResult()
|
long |
getXid()
|
void |
init(long code,
long qid)
|
void |
init(long code,
long xid,
long qid,
long mid,
byte[] buffer,
int offset,
int length,
TempBuffer tBuf)
|
void |
initCheckpoint(long blockAddr,
int offset,
int length)
|
boolean |
isData()
|
boolean |
isFin()
|
boolean |
isInit()
|
void |
setCode(long code)
|
java.lang.String |
toString()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
JournalRingItem
public JournalRingItem(int index)
init
public final void init(long code,
long xid,
long qid,
long mid,
byte[] buffer,
int offset,
int length,
TempBuffer tBuf)
initCheckpoint
public final void initCheckpoint(long blockAddr,
int offset,
int length)
setCode
public final void setCode(long code)
init
public final void init(long code,
long qid)
isData
public final boolean isData()
isInit
public final boolean isInit()
isFin
public final boolean isFin()
getCode
public final long getCode()
getXid
public final long getXid()
getQid
public final long getQid()
getMid
public final long getMid()
getBuffer
public final byte[] getBuffer()
getOffset
public final int getOffset()
getLength
public final int getLength()
freeTempBuffer
public final void freeTempBuffer()
getResult
public final JournalResult getResult()
getBlockAddr
public final long getBlockAddr()
toString
public java.lang.String toString()
- Overrides:
toString
in class RingItem