package myVncProxy;
import java.net.Socket;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

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

        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, os, is);
                        } catch (IOException e) {
                                e.printStackTrace();
                                System.out.println(e);
                        }
                }
        }
}