Mercurial > hg > Database > Alice
view src/main/java/alice/daemon/CommandMessage.java @ 612:86b39f5bf1d7 dispose
topologymanager jar execution
author | suruga |
---|---|
date | Wed, 19 Apr 2017 21:36:06 +0900 |
parents | ea21af9a4762 |
children | 3284428f525e |
line wrap: on
line source
package alice.daemon; import org.msgpack.annotation.Message; /** * DSのヘッダー */ @Message public class CommandMessage { public int type;//PUT, PEEKなどのコマンドタイプ public int index;//キューの中でのDSの位置? public int seq;//DSの待ち合わせを行っているCSを表すunique number public String key;//DS key public boolean quickFlag = false;//SEDAを挟まずに処理を行うかどうか public boolean compressed = false;//圧縮されているかどうか public int dataSize = 0;//圧縮前のサイズ //計測用 public boolean setTime = false; public long time; public int depth; public boolean setZepped = false; public int zippedDataSize;//圧縮後のサイズ public CommandMessage() {} public CommandMessage(int type, int index, int seq, String key , boolean qFlag, boolean cFlag, int datasize) { this.type = type; this.index = index; this.seq = seq; this.key = key; this.quickFlag = qFlag; this.compressed = cFlag; this.dataSize = datasize; } }