MCPcopy Create free account
hub / github.com/e2wugui/zeze / undo

Method undo

ZezeJava/ZezeJava/src/main/java/Zeze/Dbh2/CommitRocks.java:128–136  ·  view source on GitHub ↗
(long tid, BTransactionState.Data state)

Source from the content-addressed store, hash-verified

126 }
127
128 private void undo(long tid, BTransactionState.Data state) {
129 // undo
130 var futures = new ArrayList<TaskCompletionSource<?>>();
131 for (var e : state.getBuckets()) {
132 futures.add(manager.openBucket(e).undoBatch(tid));
133 }
134 for (var e : futures)
135 e.await();
136 }
137
138 private ArrayList<TaskCompletionSourceX<RaftRpc<BPrepareBatch.Data, BRefused.Data>>> processPrepareFutures(
139 long tid, String queryHost, int queryPort,

Callers 2

prepareMethod · 0.95
commitMethod · 0.95

Calls 5

addMethod · 0.65
awaitMethod · 0.65
getBucketsMethod · 0.45
undoBatchMethod · 0.45
openBucketMethod · 0.45

Tested by

no test coverage detected