| /rocksdb-6.9/java/rocksjni/ |
| D | writebatchhandlerjnicallback.h | 47 Status MarkEndPrepare(const Slice& xid);
49 Status MarkRollback(const Slice& xid);
50 Status MarkCommit(const Slice& xid);
|
| D | writebatchhandlerjnicallback.cc | 351 const Slice& xid) { in MarkEndPrepare() argument
359 auto status = WriteBatchHandlerJniCallback::k_op(xid, markEndPrepare); in MarkEndPrepare()
395 const Slice& xid) { in MarkRollback() argument
403 auto status = WriteBatchHandlerJniCallback::k_op(xid, markRollback); in MarkRollback()
414 const Slice& xid) { in MarkCommit() argument
422 auto status = WriteBatchHandlerJniCallback::k_op(xid, markCommit); in MarkCommit()
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/util/ |
| D | WriteBatchGetter.java | 116 public void markEndPrepare(final byte[] xid) throws RocksDBException { in markEndPrepare() argument
126 public void markRollback(final byte[] xid) throws RocksDBException { in markRollback() argument
131 public void markCommit(final byte[] xid) throws RocksDBException { in markCommit() argument
|
| D | CapturingWriteBatchHandler.java | 102 public void markEndPrepare(final byte[] xid) throws RocksDBException { in markEndPrepare() argument
113 public void markRollback(final byte[] xid) throws RocksDBException { in markRollback() argument
118 public void markCommit(final byte[] xid) throws RocksDBException { in markCommit() argument
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | WriteBatch.java | 316 public abstract void markEndPrepare(final byte[] xid) in markEndPrepare() argument
320 public abstract void markRollback(final byte[] xid) in markRollback() argument
322 public abstract void markCommit(final byte[] xid) in markCommit() argument
|
| /rocksdb-6.9/db/ |
| D | write_batch.cc | 494 if (!GetLengthPrefixedSlice(input, xid)) { in ReadRecordFromWriteBatch()
499 if (!GetLengthPrefixedSlice(input, xid)) { in ReadRecordFromWriteBatch()
504 if (!GetLengthPrefixedSlice(input, xid)) { in ReadRecordFromWriteBatch()
534 Slice key, value, blob, xid; in Iterate() local
558 &blob, &xid); in Iterate()
693 handler->MarkEndPrepare(xid); in Iterate()
699 handler->MarkCommit(xid); in Iterate()
705 handler->MarkRollback(xid); in Iterate()
870 PutLengthPrefixedSlice(&b->rep_, xid); in MarkEndPrepare()
885 PutLengthPrefixedSlice(&b->rep_, xid); in MarkCommit()
[all …]
|
| D | write_batch_internal.h | 107 static Status MarkEndPrepare(WriteBatch* batch, const Slice& xid,
111 static Status MarkRollback(WriteBatch* batch, const Slice& xid);
113 static Status MarkCommit(WriteBatch* batch, const Slice& xid);
|
| D | write_batch_test.cc | 298 Status MarkEndPrepare(const Slice& xid) override { in MarkEndPrepare()
299 seen += "MarkEndPrepare(" + xid.ToString() + ")"; in MarkEndPrepare()
306 Status MarkCommit(const Slice& xid) override { in MarkCommit()
307 seen += "MarkCommit(" + xid.ToString() + ")"; in MarkCommit()
310 Status MarkRollback(const Slice& xid) override { in MarkRollback()
311 seen += "MarkRollback(" + xid.ToString() + ")"; in MarkRollback()
|
| D | dbformat.h | 596 Slice* value, Slice* blob, Slice* xid);
|
| /rocksdb-6.9/utilities/write_batch_with_index/ |
| D | write_batch_with_index_internal.cc | 28 Slice* xid) const { in GetEntryFromDataOffset()
30 blob == nullptr || xid == nullptr) { in GetEntryFromDataOffset()
46 blob, xid); in GetEntryFromDataOffset()
|
| D | write_batch_with_index.cc | 404 Slice blob, xid; in Entry() local
410 iter_entry->offset, &ret.type, &ret.key, &ret.value, &blob, &xid); in Entry()
584 Slice key, value, blob, xid; in ReBuildIndex() local
592 &value, &blob, &xid); in ReBuildIndex()
|
| D | write_batch_with_index_internal.h | 93 Slice* value, Slice* blob, Slice* xid) const;
|
| /rocksdb-6.9/tools/ |
| D | ldb_cmd.cc | 2160 Status MarkEndPrepare(const Slice& xid) override { in MarkEndPrepare() argument
2162 row_ << LDBCommand::StringToHex(xid.ToString()) << ") "; in MarkEndPrepare()
2166 Status MarkRollback(const Slice& xid) override { in MarkRollback() argument
2168 row_ << LDBCommand::StringToHex(xid.ToString()) << ") "; in MarkRollback()
2172 Status MarkCommit(const Slice& xid) override { in MarkCommit() argument
2174 row_ << LDBCommand::StringToHex(xid.ToString()) << ") "; in MarkCommit()
|