Raft.Server的线程派发模式总是完全
(long typeId, ByteBuffer bb, ProtocolFactoryHandle<?> factoryHandle, AsyncSocket so)
| 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 { |
no test coverage detected