提交 02fa4208 编写于 作者: S snakejerusalem

Undid changes to BFTMapServer

上级 6c688414
...@@ -30,7 +30,7 @@ import java.util.logging.Logger; ...@@ -30,7 +30,7 @@ import java.util.logging.Logger;
import bftsmart.tom.MessageContext; import bftsmart.tom.MessageContext;
import bftsmart.tom.ServiceReplica; import bftsmart.tom.ServiceReplica;
import bftsmart.tom.server.defaultservices.DefaultRecoverable; import bftsmart.tom.server.defaultservices.DefaultSingleRecoverable;
/** /**
...@@ -40,7 +40,7 @@ import bftsmart.tom.server.defaultservices.DefaultRecoverable; ...@@ -40,7 +40,7 @@ import bftsmart.tom.server.defaultservices.DefaultRecoverable;
* This class will create a ServiceReplica and will initialize * This class will create a ServiceReplica and will initialize
* it with a implementation of Executable and Recoverable interfaces. * it with a implementation of Executable and Recoverable interfaces.
*/ */
public class BFTMapServer extends DefaultRecoverable { public class BFTMapServer extends DefaultSingleRecoverable {
MapOfMaps tableMap = null; MapOfMaps tableMap = null;
ServiceReplica replica = null; ServiceReplica replica = null;
...@@ -60,23 +60,8 @@ public class BFTMapServer extends DefaultRecoverable { ...@@ -60,23 +60,8 @@ public class BFTMapServer extends DefaultRecoverable {
new BFTMapServer(Integer.parseInt(args[0])); new BFTMapServer(Integer.parseInt(args[0]));
} }
@Override @Override
public byte[][] appExecuteBatch(byte[][] commands, MessageContext[] msgCtxs) { public byte[] appExecuteOrdered(byte[] command, MessageContext msgCtx) {
byte [][] replies = new byte[commands.length][];
for (int i = 0; i < commands.length; i++) {
if(msgCtxs != null && msgCtxs[i] != null) {
replies[i] = executeSingle(commands[i],msgCtxs[i]);
}
else executeSingle(commands[i],msgCtxs[i]);
}
return replies;
}
private byte[] executeSingle(byte[] command, MessageContext msgCtx) {
try { try {
ByteArrayInputStream in = new ByteArrayInputStream(command); ByteArrayInputStream in = new ByteArrayInputStream(command);
ByteArrayOutputStream out = null; ByteArrayOutputStream out = null;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册