Mercurial > hg > Database > Christie
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(); }