package jp.ac.u_ryukyu.treevnc;
import java.net.Socket;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

import jp.ac.u_ryukyu.treevnc.server.MyRfbProtoProxy;
import jp.ac.u_ryukyu.treevnc.test.MyRfbProto;

import com.glavsoft.transport.Reader;
import com.glavsoft.transport.Writer;

public class AcceptThread implements Runnable {
        MyRfbProto rfb = null;
        byte[] imageBytes;
        int port;
        
        public AcceptThread(MyRfbProto _rfb) {
                rfb = _rfb;
        }


        public AcceptThread(MyRfbProto _rfb, int p) {
            rfb = _rfb;
            port = p;
        }
       
	public void changeRfb(MyRfbProto _rfb) {
		rfb = _rfb;
	}

	public void run() {
		rfb.selectPort(port);

		while (true) {
			try {
				Socket newCli = rfb.accept();

				OutputStream os = newCli.getOutputStream();
				InputStream is = newCli.getInputStream();
				rfb.newClient(this, newCli, new Writer(os), new Reader(is));
			} catch (IOException e) {
				e.printStackTrace();
				System.out.println(e);
			}
		}
	}
}