package alice.test.codesegment.remote.compress;

import alice.codesegment.CodeSegment;
import alice.datasegment.CommandType;
import alice.datasegment.Receiver;

/**
 * Created by e125769 on 2/9/16.
 */
public class TestCompress extends CodeSegment{
    // create input datasegment arg1
    Receiver info = ids.create(CommandType.TAKE);
    Receiver info2 = ids.create(CommandType.PEEK);
    int num;

    public TestCompress(int num){
        this.num = num;
        info.setKey("data");
        info2.setKey("time");
    }

    @Override
    public void run() {

        if (num == 100){
            long time = System.currentTimeMillis();
            ods.update("time", time);
            System.out.println("zipped size :" + info.getReceiveData().getZippedDataSize());
        } else if (num == 0) {
            long time = System.currentTimeMillis();

            System.out.println("time: " + (time - info2.asClass(long.class)));

            System.exit(0);
            return;
        }

        ods.flip("remote", "data", info);

        TestCompress cs = new TestCompress(--num);

    }
}