diff --git a/src/main/base/org/bdware/sc/conn/ServiceServer.java b/src/main/base/org/bdware/sc/conn/ServiceServer.java index 5b22c0e..db83b34 100644 --- a/src/main/base/org/bdware/sc/conn/ServiceServer.java +++ b/src/main/base/org/bdware/sc/conn/ServiceServer.java @@ -66,6 +66,7 @@ public class ServiceServer extends Thread { new ChannelInitializer() { @Override protected void initChannel(SocketChannel arg0) { + LOGGER.info("Connected:" + arg0.remoteAddress() + " " + arg0.localAddress()); arg0.pipeline() .addLast(new LengthFieldBasedFrameCodec()) .addLast(new AsyncInboundHandler(ServiceServer.this)); diff --git a/src/main/entry/org/bdware/sc/bean/ContractExecType.java b/src/main/entry/org/bdware/sc/bean/ContractExecType.java index 5d198cd..e357cea 100644 --- a/src/main/entry/org/bdware/sc/bean/ContractExecType.java +++ b/src/main/entry/org/bdware/sc/bean/ContractExecType.java @@ -11,7 +11,8 @@ public enum ContractExecType implements Serializable { RequestAllResponseAll, Sharding,//分片执行模式 SelfAdaptiveSharding,// self-adaptive sharding - PBFT; //PBFT + PBFT, //PBFT + RAFT; public static ContractExecType getContractTypeByInt(int i) {