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

Method query

ZezeJava/ZezeJava/src/main/java/Zeze/Dbh2/CommitAgent.java:57–64  ·  view source on GitHub ↗
(String host, int port, long tid, int rpcTimeout)

Source from the content-addressed store, hash-verified

55 }
56
57 public BTransactionState.Data query(String host, int port, long tid, int rpcTimeout) {
58 var r = new Query();
59 r.Argument.setTid(tid);
60 r.SendForWait(connect(host, port), rpcTimeout).await();
61 if (r.getResultCode() != 0)
62 throw new RuntimeException("query state error=" + IModule.getErrorCode(r.getResultCode()));
63 return r.Result;
64 }
65
66 public void commit(String host, int port, BPrepareBatches.Data batches, int rpcTimeout) {
67 var r = new Commit();

Callers 2

ProcessQueryRequestMethod · 0.45
onTimerMethod · 0.45

Calls 6

connectMethod · 0.95
getErrorCodeMethod · 0.95
awaitMethod · 0.65
setTidMethod · 0.45
SendForWaitMethod · 0.45
getResultCodeMethod · 0.45

Tested by

no test coverage detected