bdware/common
2
0
Fork 0
mirror of https://gitee.com/BDWare/common synced 2025-01-26 09:44:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

add raft

Browse Source
This commit is contained in:
CaiHQ 2022-05-27 15:27:56 +08:00
parent 34cedb8a13
commit f74c4f040f
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/main/base/org/bdware/sc/conn/ServiceServer.java
View File

@ -66,6 +66,7 @@ public class ServiceServer extends Thread {
new ChannelInitializer<SocketChannel>() { new ChannelInitializer<SocketChannel>() {
@Override @Override
protected void initChannel(SocketChannel arg0) { protected void initChannel(SocketChannel arg0) {
LOGGER.info("Connected:" + arg0.remoteAddress() + " " + arg0.localAddress());
arg0.pipeline() arg0.pipeline()
.addLast(new LengthFieldBasedFrameCodec()) .addLast(new LengthFieldBasedFrameCodec())
.addLast(new AsyncInboundHandler(ServiceServer.this)); .addLast(new AsyncInboundHandler(ServiceServer.this));

3
src/main/entry/org/bdware/sc/bean/ContractExecType.java
View File

@ -11,7 +11,8 @@ public enum ContractExecType implements Serializable {
RequestAllResponseAll, RequestAllResponseAll,
Sharding,//分片执行模式 Sharding,//分片执行模式
SelfAdaptiveSharding,// self-adaptive sharding SelfAdaptiveSharding,// self-adaptive sharding
PBFT; //PBFT PBFT, //PBFT
RAFT;
public static ContractExecType getContractTypeByInt(int i) { public static ContractExecType getContractTypeByInt(int i) {