类 com.taobao.metamorphosis.server.transaction.store.JournalLocation
的使用

使用 JournalLocation 的软件包
com.taobao.metamorphosis.server.transaction   
com.taobao.metamorphosis.server.transaction.store   
 

com.taobao.metamorphosis.server.transactionJournalLocation 的使用
 

参数类型为 JournalLocationcom.taobao.metamorphosis.server.transaction 中的方法
 void TransactionStore.addMessage(MessageStore store, long msgId, PutCommand cmd, JournalLocation location)
           
 

com.taobao.metamorphosis.server.transaction.storeJournalLocation 的使用
 

返回 JournalLocationcom.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)
          写入命令到事务日志
 

参数类型为 JournalLocationcom.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)
          写入命令到事务日志
 

参数类型为 JournalLocationcom.taobao.metamorphosis.server.transaction.store 中的构造方法
JournalTransactionStore.Tx(JournalLocation location)
           
 



Copyright © 2010–2013. All rights reserved.