|
||||||||||
上一个 下一个 | 框架 无框架 |
使用 JournalLocation 的软件包 | |
---|---|
com.taobao.metamorphosis.server.transaction | |
com.taobao.metamorphosis.server.transaction.store |
com.taobao.metamorphosis.server.transaction 中 JournalLocation 的使用 |
---|
参数类型为 JournalLocation 的 com.taobao.metamorphosis.server.transaction 中的方法 | |
---|---|
void |
TransactionStore.addMessage(MessageStore store,
long msgId,
PutCommand cmd,
JournalLocation location)
|
com.taobao.metamorphosis.server.transaction.store 中 JournalLocation 的使用 |
---|
返回 JournalLocation 的 com.taobao.metamorphosis.server.transaction.store 中的方法 | |
---|---|
JournalLocation |
JournalTransactionStore.checkpoint()
|
JournalLocation |
JournalStore.getRecentCheckpoint()
返回最近的checkpoint |
JournalLocation |
Checkpoint.getRecentCheckpoint()
返回最近的checkpoint |
JournalLocation |
JournalStore.write(TransactionCommands.TxCommand msg,
ByteBuffer attachment,
JournalLocation location,
boolean committedOrRollback)
写入命令到事务日志 |
参数类型为 JournalLocation 的 com.taobao.metamorphosis.server.transaction.store 中的方法 | |
---|---|
void |
JournalTransactionStore.addMessage(MessageStore store,
long msgId,
PutCommand putCmd,
JournalLocation location)
添加消息,为了保证添加顺序,这里不得不加锁 |
void |
Checkpoint.check(JournalLocation location)
新设置checkpoint,如果没有改变则不存入磁盘,否则产生一个新的checkpoint文件 |
int |
JournalLocation.compareTo(JournalLocation o)
|
JournalTransactionStore.Tx |
JournalTransactionStore.getTx(Object txid,
JournalLocation location)
|
JournalLocation |
JournalStore.write(TransactionCommands.TxCommand msg,
ByteBuffer attachment,
JournalLocation location,
boolean committedOrRollback)
写入命令到事务日志 |
参数类型为 JournalLocation 的 com.taobao.metamorphosis.server.transaction.store 中的构造方法 | |
---|---|
JournalTransactionStore.Tx(JournalLocation location)
|
|
||||||||||
上一个 下一个 | 框架 无框架 |