Mercurial > hg > Database > Alice

comparison src/main/java/alice/codesegment/OutputDataSegment.java @ 526:928907206d21 dispose

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
remove CompressedRDSM & CompressedLDSM class
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Sat, 18 Apr 2015 19:09:15 +0900
parents 30a74eee59c7
children bfec2c3ff1b8
comparison
equal deleted inserted replaced
525:30a74eee59c7 526:928907206d21
91 public void put(String managerKey, String key, Object val) { 91 public void put(String managerKey, String key, Object val) {
92 put(managerKey, key, val, false); 92 put(managerKey, key, val, false);
93 } 93 }
94 94
95 public void put(String managerKey, String key, Object val, boolean cFlag) {//追加 95 public void put(String managerKey, String key, Object val, boolean cFlag) {//追加
96 if (!managerKey.equals("local") && DataSegment.contains(managerKey)){ 96 System.out.println("in PUT");
97 ReceiveData rData = new ReceiveData(val); 97 ReceiveData rData = new ReceiveData(val);
98 rData.setCompressFlag(cFlag); 98 rData.setCompressFlag(cFlag);
99
100 if (!managerKey.equals("local") && DataSegment.contains(managerKey)){///if remote
99 if (cFlag){ 101 if (cFlag){
100 DataSegment.get(managerKey + "!").put(key, rData, false); 102 DataSegment.get(managerKey + "!").put(key, rData, false);
101 } else { 103 } else {
102 DataSegment.get(managerKey).put(key, rData, false); 104 DataSegment.get(managerKey).put(key, rData, false);
103 } 105 }
104 } else { 106 } else {// if local
105 put(key, val); 107 if (cFlag){
106 } 108 DataSegment.getCompressedLocal().put(key, rData, false);
109 } else {
110 put(key, val);
111 }
112 }
113
114
115
107 } 116 }
108 117
109 public void quickPut(String managerKey, String key, ReceiveData rData) { 118 public void quickPut(String managerKey, String key, ReceiveData rData) {
110 if (!managerKey.equals("local") && DataSegment.contains(managerKey)){ 119 if (!managerKey.equals("local") && DataSegment.contains(managerKey)){
111 if (rData.compressed()){ 120 if (rData.compressed()){