Mercurial > hg > Database > Alice
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); |