From f74c4f040f71c31585ef62e85cbd88a7b17f2359 Mon Sep 17 00:00:00 2001 From: CaiHQ Date: Fri, 27 May 2022 15:27:56 +0800 Subject: [PATCH] add raft --- src/main/base/org/bdware/sc/conn/ServiceServer.java | 1 + src/main/entry/org/bdware/sc/bean/ContractExecType.java | 3 ++- 2 files changed, 3 insertions(+), 1 deletion(-) 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) {