Mercurial > hg > Database > Alice

diff src/main/java/alice/topology/manager/keeparive/RespondPing.java @ 552:767d93626b88 dispose

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add compressed to DSM name
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Mon, 16 Nov 2015 18:33:23 +0900
parents c5072a63b257
children
line wrap: on
line diff
--- a/src/main/java/alice/topology/manager/keeparive/RespondPing.java	Fri Jun 19 14:06:10 2015 +0900
+++ b/src/main/java/alice/topology/manager/keeparive/RespondPing.java	Mon Nov 16 18:33:23 2015 +0900
@@ -9,7 +9,7 @@
 //    private long pingedTime = System.currentTimeMillis();
 
     public RespondPing(String key) {
-        respond.setKey(key);
+        respond.setKey("compressedlocal", key);
     }
 
     @Override
@@ -24,7 +24,7 @@
             task.setInfo(d.from, null, 0);
             if (!exec.compareAndSkip(task)){
                 // case: remove task is still in the waiting queue.
-                ods.put("_REMOVETASK",task);
+                ods.put("compressedlocal", "_REMOVETASK",task);
                 new RemoveTask();
             }
         }