comparison src/main/java/alice/datasegment/DataSegmentKey.java @ 575:fe55be1ce12d dispose

add ids compress local
author Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date Tue, 15 Dec 2015 16:46:24 +0900
parents b6049fb123d8
children 2df12c110ebc
comparison
equal deleted inserted replaced
574:ea21af9a4762 575:fe55be1ce12d
1 package alice.datasegment; 1 package alice.datasegment;
2 2
3 import java.io.IOException;
3 import java.util.ArrayList; 4 import java.util.ArrayList;
4 import java.util.Iterator; 5 import java.util.Iterator;
5 6
6 import alice.datasegment.Command; 7 import alice.datasegment.Command;
7 8
83 } 84 }
84 85
85 } 86 }
86 87
87 public void replyValue(Command cmd, DataSegmentValue data, boolean cFlag){ 88 public void replyValue(Command cmd, DataSegmentValue data, boolean cFlag){
89 if (cFlag){
90 try {
91 data.rData.zip();
92 } catch (IOException e) {
93 e.printStackTrace();
94 }
95 }
88 Command rCmd = new Command(CommandType.REPLY, null, null, data.rData, data.index, cmd.seq, null, null, data.from); 96 Command rCmd = new Command(CommandType.REPLY, null, null, data.rData, data.index, cmd.seq, null, null, data.from);
89 rCmd.setCompressFlag(cFlag); 97 rCmd.setCompressFlag(cFlag);
90 98
91 if (cmd.cs!=null){ // if cmd has cs-instance, it means Command from local. 99 if (cmd.cs!=null){ // if cmd has cs-instance, it means Command from local.
92 cmd.cs.ids.reply(cmd.receiver, rCmd); 100 cmd.cs.ids.reply(cmd.receiver, rCmd);