Mercurial > hg > Database > Alice

changeset 534:82cc94d40628 dispose

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
bug
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Mon, 15 Jun 2015 17:21:51 +0900
parents b3c9554ccb1b
children dd20acf579bd
files src/main/java/alice/datasegment/CompressedRemoteDataSegmentManager.java src/main/java/alice/datasegment/DataSegment.java src/main/java/alice/test/codesegment/remote/RemoteIncrement.java src/main/java/alice/test/codesegment/remote/RemoteStartCodeSegment.java
diffstat 4 files changed, 11 insertions(+), 6 deletions(-) [+]
line wrap: on
line diff
--- a/src/main/java/alice/datasegment/CompressedRemoteDataSegmentManager.java	Mon May 04 16:02:22 2015 +0900
+++ b/src/main/java/alice/datasegment/CompressedRemoteDataSegmentManager.java	Mon Jun 15 17:21:51 2015 +0900
@@ -18,6 +18,11 @@
 
     public CompressedRemoteDataSegmentManager(){}
 
+    public CompressedRemoteDataSegmentManager(Connection c) {
+        connection = c;
+        connection.name = "compressed" + c.name;
+    }
+
     public CompressedRemoteDataSegmentManager(String connectionKey, final String reverseKey, final String hostName, final int port) {
         logger = Logger.getLogger(connectionKey);
         connection = new Connection();
--- a/src/main/java/alice/datasegment/DataSegment.java	Mon May 04 16:02:22 2015 +0900
+++ b/src/main/java/alice/datasegment/DataSegment.java	Mon Jun 15 17:21:51 2015 +0900
@@ -41,10 +41,10 @@
             System.exit(0);
         }
         RemoteDataSegmentManager manager = new RemoteDataSegmentManager(connectionKey, reverseKey, hostName, port);
-        CompressedRemoteDataSegmentManager compressedManager = new CompressedRemoteDataSegmentManager(connectionKey + "!", reverseKey, hostName, port);
+        //CompressedRemoteDataSegmentManager compressedManager = new CompressedRemoteDataSegmentManager(manager.connection);
 
         register(connectionKey, manager);
-        register("compressed" + connectionKey, compressedManager);
+        //register("compressed" + connectionKey, compressedManager);
 
         return manager;
     }
--- a/src/main/java/alice/test/codesegment/remote/RemoteIncrement.java	Mon May 04 16:02:22 2015 +0900
+++ b/src/main/java/alice/test/codesegment/remote/RemoteIncrement.java	Mon Jun 15 17:21:51 2015 +0900
@@ -18,9 +18,9 @@
         if (num == 10) System.exit(0);
 
         RemoteIncrement cs = new RemoteIncrement();
-        cs.num.setKey("compressedremote", "num");
+        cs.num.setKey("remote", "num");
 
-        ods.put("compressedlocal", "num", num);
+        ods.put("local", "num", num);
     }
 
 }
\ No newline at end of file
--- a/src/main/java/alice/test/codesegment/remote/RemoteStartCodeSegment.java	Mon May 04 16:02:22 2015 +0900
+++ b/src/main/java/alice/test/codesegment/remote/RemoteStartCodeSegment.java	Mon Jun 15 17:21:51 2015 +0900
@@ -7,8 +7,8 @@
     @Override
     public void run() {
         RemoteIncrement cs = new RemoteIncrement();
-        cs.num.setKey("compressedremote", "num");
+        cs.num.setKey("remote", "num");
 
-        ods.put("compressedlocal", "num", 0);
+        ods.put("local", "num", 0);
     }
 }
\ No newline at end of file