# HG changeset patch # User sugi # Date 1364384108 -32400 # Node ID d50cddf64396089e7ce26f3493fcfa5c9c359d5c # Parent b5c642ba998e8905274a3cf06a31d67b6337f145 TestRemoteAlice works diff -r b5c642ba998e -r d50cddf64396 src/alice/codesegment/InputDataSegment.java --- a/src/alice/codesegment/InputDataSegment.java Wed Mar 27 20:02:38 2013 +0900 +++ b/src/alice/codesegment/InputDataSegment.java Wed Mar 27 20:35:08 2013 +0900 @@ -59,10 +59,12 @@ public void reply(Receiver receiver, Command reply) { receiver.index = reply.index; receiver.from = reply.reverseKey; - if (!reply.reverseKey.equals("local")) { + if (reply.reverseKey==null){ + receiver.setData(new ReceiveRemoteData(reply.val)); + } else if (!reply.reverseKey.equals("local")) { receiver.setData(new ReceiveRemoteData(reply.val)); } else { - receiver.setData(new ReceiveLocalData(reply.obj)); + receiver.setData(new ReceiveLocalData(reply.obj)); } receive(); } diff -r b5c642ba998e -r d50cddf64396 src/alice/daemon/AliceDaemon.java --- a/src/alice/daemon/AliceDaemon.java Wed Mar 27 20:02:38 2013 +0900 +++ b/src/alice/daemon/AliceDaemon.java Wed Mar 27 20:35:08 2013 +0900 @@ -53,7 +53,6 @@ ss.bind(a); acceptThread = new AcceptThread(ss, "ACCEPT" + conf.localPort); acceptThread.start(); - } catch (IOException e) { e.printStackTrace(); } diff -r b5c642ba998e -r d50cddf64396 src/alice/daemon/OutboundTcpConnection.java --- a/src/alice/daemon/OutboundTcpConnection.java Wed Mar 27 20:02:38 2013 +0900 +++ b/src/alice/daemon/OutboundTcpConnection.java Wed Mar 27 20:35:08 2013 +0900 @@ -15,6 +15,13 @@ } public CommandMessage convert(Command cmd) { + if (cmd.val==null&&cmd.obj!=null){ + try { + cmd.val = SingletonMessage.getInstance().unconvert(cmd.obj); + } catch (IOException e) { + e.printStackTrace(); + } + } return new CommandMessage(cmd.type.id, cmd.index, cmd.seq, cmd.key, cmd.val); } diff -r b5c642ba998e -r d50cddf64396 src/alice/test/codesegment/remote/TestRemoteAlice.java --- a/src/alice/test/codesegment/remote/TestRemoteAlice.java Wed Mar 27 20:02:38 2013 +0900 +++ b/src/alice/test/codesegment/remote/TestRemoteAlice.java Wed Mar 27 20:35:08 2013 +0900 @@ -10,7 +10,6 @@ new AliceDaemon(conf).listen(); DataSegment.connect(conf.key, "", conf.hostname, conf.connectPort); - new RemoteStartCodeSegment().execute(); }