package pathfinder.mergetest;


public abstract class NetworkSimulator<P> {
	int logLevel;
	
	public abstract ChannelSimulator<P> connect();
	public abstract ChannelSimulator<P> accept();
	public abstract boolean checkAllCS();
	
	public abstract ChannelSimulator<P> getAcceptedSession(int i);
	
	public void writeLog(String log, int level){
		if ( level<=logLevel )
			System.out.println(log);
	}

	public void setLogLevel(int logLevel) {
		this.logLevel = logLevel;
	}
/*
	synchronized public P read(ChannelSimulator<P> cs){
		try {
			return cs.getReadQ().take();
		} catch (InterruptedException e) {
			e.printStackTrace();
			return null;
		}
	}
	synchronized public boolean write(ChannelSimulator<P> cs, P p){
		try {
			cs.getWriteQ().put(p);
			notifyAll();
			return true;
		} catch (InterruptedException e) {
			e.printStackTrace();
			return false;
		}
	}
*/
}