package sjc;
import java.net.*;
import javax.net.ssl.*;

public class ManagerThread extends Thread {
	public static Object YES = new Object();
	public static Object NO = new Object();
	public static Object CONNECT = new Object();
	private ObjectQueue queue = new ObjectQueue();
	private ListenThread lthread = new ListenThread(this);
	private InterfaceThread ithread = new InterfaceThread(this);
	public ObjectQueue getQueue() {
		return queue;
	}
	public void run() {
		lthread.start();
		ithread.start();
		//lthread.getQueue().put(new Object());
		//ithread.getQueue().put(new Object());
		while (!isInterrupted()) {
			proceed(queue.get());
		}
	}
	private void proceed(Object obj) {
		if (obj instanceof SSLSocket) {
			ithread.getQueue().put(obj);
		} else {
			if (obj == NO) {
				lthread.getQueue().put(new Object());
			} else if (obj == YES) {
				ithread.getQueue().put(CONNECT);
			}
		}
	}
}