package alice.datasegment;

import alice.codesegment.CodeSegment;
import org.apache.log4j.Logger;

import java.util.concurrent.ConcurrentHashMap;

/**
 * Created by e125769 on 4/8/15.
 */
public class CompressedLocalDataSegmentManager extends LocalDataSegmentManager{
    private String reverseKey = "compressedLocal";
    //private ConcurrentHashMap<String, DataSegmentKey> dataSegments = new ConcurrentHashMap<String, DataSegmentKey>();
    private Logger logger = Logger.getLogger("compressedLocal");


    @Override
    public void peek(Receiver receiver, CodeSegment cs, boolean quickFlag) {//とりあえずコピペ
        DataSegmentKey dataSegmentKey = getDataSegmentKey(receiver.key);
        int seq = this.seq.getAndIncrement();
        Command cmd = new Command(CommandType.PEEK, receiver, receiver.key, null, receiver.index, seq, replyQueue, cs, null);
        dataSegmentKey.runCommand(cmd);
        if (logger.isDebugEnabled())
            logger.debug(cmd.getCommandString());
    }

}