Searched refs:commitEntry (Results 1 – 8 of 8) sorted by relevance
172 CommitLogEntry commitEntry = new CommitLogEntry(commit); in writeLogEntries() local173 logManager.log(commitEntry, ReplicationContext.NO_REPLICATE); in writeLogEntries()176 commitEntry = new CommitLogEntry(commit); in writeLogEntries()179 logManager.log(commitEntry, ReplicationContext.MASTER); in writeLogEntries()210 CommitLogEntry commitEntry = new CommitLogEntry(commit); in writeLogEntries() local212 logManager.log(commitEntry, ReplicationContext.MASTER); in writeLogEntries()215 commitEntry = new CommitLogEntry(new TxnCommit(20, 0, 1)); in writeLogEntries()216 logManager.log(commitEntry, ReplicationContext.MASTER); in writeLogEntries()
112 (commitEntry) => commitEntry.fileName === fileName && commitEntry.type === type,
278 final LogEntry commitEntry = instantiateEntry(); in getCommitTxnId() local279 return commitEntry.getTransactionId(); in getCommitTxnId()
86 bool commitEntry();
131 connect(this, SIGNAL(apply()), SLOT(commitEntry())); in EditEntryWidget()1007 bool EditEntryWidget::commitEntry() in commitEntry() function in EditEntryWidget1074 if (commitEntry()) { in acceptEntry()1165 if (!commitEntry()) { in cancel()
488 Protocol.Commit commitEntry = (Protocol.Commit) entry; in replayEntry() local490 final boolean needsAck = commitEntry.getNeedsAck(); in replayEntry()492 commitEntry.getReplicaSyncPolicy(); in replayEntry()
964 final CommitLogEntry commitEntry = in logCommitEntry() local970 item.entry = commitEntry; in logCommitEntry()
2646 Protocol.Commit commitEntry = (Protocol.Commit) e; in doHook() local2647 final boolean needsAck = commitEntry.getNeedsAck(); in doHook()