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

Method dispatchProtocol

ZezeJava/ZezeJava/src/main/java/Zeze/Raft/Server.java:233–239  ·  view source on GitHub ↗

Raft.Server的线程派发模式总是完全

(long typeId, ByteBuffer bb, ProtocolFactoryHandle<?> factoryHandle, AsyncSocket so)

Source from the content-addressed store, hash-verified

231 * Raft.Server的线程派发模式总是完全
232 */
233 @Override
234 public void dispatchProtocol(long typeId, ByteBuffer bb, ProtocolFactoryHandle<?> factoryHandle, AsyncSocket so)
235 throws Exception {
236 // 不支持事务
237 var p = decodeProtocol(typeId, bb, factoryHandle, so);
238 p.dispatch(this, factoryHandle);
239 }
240
241 @Override
242 public void dispatchProtocol(Protocol<?> p, ProtocolFactoryHandle<?> factoryHandle) throws Exception {

Callers 1

ProcessProxyRequestMethod · 0.45

Calls 15

isImportantProtocolMethod · 0.95
executeImportantTaskMethod · 0.95
callMethod · 0.95
dispatchRaftRequestMethod · 0.95
processRequestMethod · 0.95
trySendLeaderIsMethod · 0.95
decodeProtocolMethod · 0.80
isWorkingLeaderMethod · 0.80
getRequestIdMethod · 0.80
getTypeIdMethod · 0.65
handleMethod · 0.65
getNameMethod · 0.65

Tested by

no test coverage detected