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

Method process

ZezeJava/ZezeJavaTest/src/Infinite/Tasks.java:186–202  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

184 static final LongAdder commitCount = new LongAdder();
185
186 @Override
187 long process() {
188 var key = Keys.iterator().next();
189 var value = App.demo_Module1.getTable1().getOrAdd(key);
190 var oldV = value.getLong2();
191 value.setLong2(oldV + 1);
192 var newV = value.getLong2();
193 Transaction.whileCommit(() -> {
194 var newV2 = App.demo_Module1.getTable1().getOrAdd(key).getLong2();
195 var level = oldV + 1 != newV || newV != newV2 ? Level.ERROR : Level.INFO;
196 if (level == Level.ERROR || debugTradeSum)
197 Simulate.logger.log(level, "{} --- key:{}, value:{}->{}->{}",
198 App.getZeze().getConfig().getServerId(), key, oldV, newV, newV2);
199 commitCount.increment();
200 });
201 return 0L;
202 }
203
204 @Override
205 void verify() throws Exception {

Callers

nothing calls this directly

Calls 12

whileCommitMethod · 0.95
getZezeMethod · 0.95
getTable1Method · 0.80
getLong2Method · 0.80
setLong2Method · 0.80
nextMethod · 0.65
getServerIdMethod · 0.65
incrementMethod · 0.65
iteratorMethod · 0.45
getOrAddMethod · 0.45
logMethod · 0.45
getConfigMethod · 0.45

Tested by

no test coverage detected