package alice.codesegment;

import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicInteger;

import alice.datasegment.DataSegment;
import alice.datasegment.DataSegmentManager;
import alice.datasegment.DataSegmentValue;

public class InputDataSegment {
	
	private ConcurrentHashMap<String, DataSegmentValue> inputDataSegments = new ConcurrentHashMap<String, DataSegmentValue>();
	private CodeSegment cs;
	private AtomicInteger count = new AtomicInteger();
	
	public InputDataSegment(CodeSegment cs) {
		this.cs = cs;
	}
	
	public void peek(String managerKey, String key) {
		peek(managerKey, key, 0);
	}
	
	public void peek(String managerKey, String key, int index) {
		DataSegment.get(managerKey).peek(key, index, cs);
		count.getAndIncrement();
	}

	public void take(String managerKey, String key) {
		take(managerKey, key, 0);
	}
	
	public void take(String managerKey, String key, int index) {
		DataSegment.get(managerKey).take(key, index, cs);
		count.getAndIncrement();
	}
	
}