diff src/main/java/christie/daemon/IncomingTcpConnection.java @ 14:f2b30b47ef67

RemotePutTest is working
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Thu, 11 Jan 2018 18:02:59 +0900
parents bcd4f2c19185
children 186a86dc4c8a
line wrap: on
line diff
--- a/src/main/java/christie/daemon/IncomingTcpConnection.java	Wed Jan 10 20:37:47 2018 +0900
+++ b/src/main/java/christie/daemon/IncomingTcpConnection.java	Thu Jan 11 18:02:59 2018 +0900
@@ -38,7 +38,6 @@
         while (true) {
             try {
                 Command cmd = null;
-                DataGear dg = null;
                 RemoteMessage msg = unpacker.read(RemoteMessage.class);
                 CommandType type = CommandType.getCommandTypeFromId(msg.type);
                 int dataSize = unpacker.readInt();
@@ -47,7 +46,9 @@
                     case PUT:
                         connection.socket.getInputStream().read(data);
                         try {
-                            cgms.get(msg.cgmName).getDGM().put(msg.key, new DataGear(data, Class.forName(msg.clazz)));
+                            DataGear dg = new DataGear();
+                            dg.setMessagePack(data, Class.forName(msg.clazz));
+                            cgms.get(msg.cgmName).getLocalDGM().put(msg.key, dg);
                         } catch (ClassNotFoundException e) {
                             e.printStackTrace();
                         }