# HG changeset patch # User Taninari YU # Date 1344816576 -32400 # Node ID a096a009bbda54a7167387ad37b8641b4dd3c9ef # Parent 30bd62abf424df0c5a3286923cf8c7a9b0357dd3 add AcceptThread.java diff -r 30bd62abf424 -r a096a009bbda src/main/java/ac/ryukyu/treevnc/client/AcceptThread.java --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/main/java/ac/ryukyu/treevnc/client/AcceptThread.java Mon Aug 13 09:09:36 2012 +0900 @@ -0,0 +1,42 @@ +package ac.ryukyu.treevnc.client; +import java.net.Socket; +import java.io.IOException; +import java.io.InputStream; +import java.io.OutputStream; + +public class AcceptThread implements Runnable { + MyRfbProtoClient rfb = null; + byte[] imageBytes; + int port; + + AcceptThread(MyRfbProtoClient _rfb) { + rfb = _rfb; + } + + + AcceptThread(MyRfbProtoClient _rfb, int p) { + rfb = _rfb; + port = p; + } + + public void changeRfb(MyRfbProtoClient _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); + } + } + } +}