Members/nobuyasu/tightVNCClient: src/myVncClient/MyVncClient.java comparison

comparison src/myVncClient/MyVncClient.java @ 79:c76e43a12796

modify MyVncClient

author	e085711
date	Wed, 31 Aug 2011 13:34:32 +0900
parents	42b08ecc4cb5
children	3bfe8845684c

comparison

equal deleted inserted replaced

-:fe94e353d595
+:c76e43a12796
 	String parent, treenum;
 	private String leaderflag;
 	boolean runflag = false;
 	boolean first = true;
-	EchoClient echo;
+	EchoClient echoValue;
+	int echoPort;
+	String pHost;
 	//
 	// main() is called when run as a java program from the command line.
 	// It simply runs the applet inside a newly-created frame.
 	//
 	public static void main(String[] argv) {
 		MyVncClient v = new MyVncClient();
-		v.echo = null;
+		v.echoValue = null;
 		v.runClient(argv);
 	}
 	private void runClient(String[] argv) {
 		mainArgs = argv;
 		inAnApplet = false;
 		inSeparateFrame = true;
 		if (mainArgs.length > 0)
-			host = mainArgs[0];
+			pHost = mainArgs[0];
 		else
-			host = "cls080.ie.u-ryukyu.ac.jp";
+			pHost = "cls080.ie.u-ryukyu.ac.jp";
 		if (mainArgs.length > 1)
 			port = Integer.parseInt(mainArgs[1]);
 		else
 			port = 5999;
 			while (true) {
 				/**
 				 * if my last node case reconnectoion stop
 				 */
-				echo = new EchoClient(echo, this);
+				echoValue = new EchoClient(echoValue, this);
 				try {
 					Thread.sleep(ran);
 				} catch (InterruptedException e1) {
 					e1.printStackTrace();
 				}
 				if (counter >= 3) {
-					echo.openport();
+					echoValue.openport();
-					echo.notfoundParent();
+					echoValue.notfoundParent();
 				}
-				echo.openport();
+				echoValue.openport();
 				// runflag = echo.losthost();
-				if (echo.losthost()) {
+				if (echoValue.losthost()) {
 					break;
 				}
 				counter++;
 			}
 			vncFrame.dispose();
 			// num4
 			// リーダーの子ノードがproxyに対して親が落ちたことを報告をする
 			if (leaderflag != null) {
 				while (true) {
-					echo = new EchoClient(echo, this);
+					echoValue = new EchoClient(echoValue, this);
-					echo.openport();
+					echoValue.openport();
 					// runflag = echo.losthost();
-					if (echo.losthost()) {
+					if (echoValue.losthost()) {
 						break;
 					}
 				}
 			} else {
 			validate();
 		}
 		showConnectionStatus("Connecting to " + host + ", port " + port + "...");
-		rfb = new MyRfbProto(host, port, this);
+		rfb = new MyRfbProto(pHost, port, this);
 		showConnectionStatus("Connected to server");
 		rfb.readVersionMsg();
 		showConnectionStatus("RFB server supports protocol version "
 				+ rfb.serverMajor + "." + rfb.serverMinor);
 		rfb.writeVersionMsg();
 		showConnectionStatus("Using RFB protocol version " + rfb.clientMajor
 				+ "." + rfb.clientMinor);
 		if(rfb.serverMinor == 998) {
 			byte[] b = new byte[4];
 			b = rfb.readEchoPort();
-			int echoPort = castByteInt(b);
+			echoPort = castByteInt(b);
-			InetAddress addr = InetAddress.getByName(host);
+			InetAddress addr = InetAddress.getByName(pHost);
 			String h = new String(addr.getHostAddress());
-			getParentname(echo, echoPort);
+			getParentName();
 			if(!(h.equals(host))) {
 				rfb.changeParent(host, port);
 				rfb.readVersionMsg();
 				rfb.writeVersionMsg();
 			}
 		}
 		int secType = rfb.negotiateSecurity();
 		int authType;
 		if (secType == RfbProto.SecTypeTight) {
 			showConnectionStatus("Enabling TightVNC protocol extensions");
 			int echoPort = castByteInt(b);
 			InetAddress addr = InetAddress.getByName(host);
 			String h = new String(addr.getHostAddress());
-			getParentname(echo, echoPort);
+			getParentName();
 			if(!(h.equals(host))) {
 				rfb.changeParent(host, port);
 				rfb.readVersionMsg();
 				rfb.writeVersionMsg();
 			}
 	}
 	public void windowDeiconified(WindowEvent evt) {
 	}
-	void getParentname(EchoClient value, int echoPort) {
+	public void getParentName() {
-	if (value == null) {
+	if (echoValue == null) {
 		if (clientSocket == null) {
-			String pHost;
-			if (mainArgs.length > 0)
-				pHost = mainArgs[0];
-			else
-				pHost = "cls080.ie.u-ryukyu.ac.jp";
 //			echo = new EchoClient(pHost, this);
-			echo = new EchoClient(pHost, this, echoPort);
+			echoValue = new EchoClient(pHost, this, echoPort);
-			echo.openport();
+			echoValue.openport();
-			value = echo.hostn("1");
+			echoValue = echoValue.hostn("1");
 		} else {
-			echo = new EchoClient();
+			echoValue = new EchoClient();
-			value = echo.Interruption(clientSocket);
+			echoValue = echoValue.Interruption(clientSocket);
 		}
 	}
 	// proxyからの返信で接続先を決定する
-	host = value.responseLine;
+	host = echoValue.responseLine;
-	parent = value.parent;
+	parent = echoValue.parent;
-	if (value.treenum != null) {
+	if (echoValue.treenum != null) {
-		treenum = value.treenum;
+		treenum = echoValue.treenum;
 	} else {
-		treenum = echo.treenum;
+		treenum = echoValue.treenum;
 	}
-	if (value.leaderflag != null) {
+	if (echoValue.leaderflag != null) {
-		leaderflag = value.leaderflag;
+		leaderflag = echoValue.leaderflag;
 	} else {
-		leaderflag = echo.leaderflag;
+		leaderflag = echoValue.leaderflag;
 	}
 	System.out.println("Parent =" + parent);
 	System.out.println("mynumber =" + treenum);
 	System.out.println("connect host =" + host);
 	System.out.println("leaderflag(boolean) = " + leaderflag);
-	echo = value;
+	}
-	if (host == null) {
+	public void setEchoValue(EchoClient value) {
-		host = getCodeBase().getHost();
+		this.echoValue = value;
-		if (host.equals("")) {
+	}
-			fatalError("HOST parameter not specified");
-		}
-	}
-//	port = 5999;
-	}
 	int castByteInt(byte[] b) {
 		ByteBuffer bb = ByteBuffer.wrap(b);
 		int value = bb.getInt();
 		return value;
 	}
-	public static void main(Socket _clientSocket) {
-		MyVncClient v = new MyVncClient();
-		// v.clientSocket = _clientSocket;
-		// v.mainArgs = argv;
-		v.inAnApplet = false;
-		v.inSeparateFrame = true;
-		v.echo = null;
-		v.init();
-		v.start_threads();
-		v.start();
-	}
-	public static void main(EchoClient value) {
-		MyVncClient v = new MyVncClient();
-		v.inAnApplet = false;
-		v.inSeparateFrame = true;
-		v.echo = value;
-		v.init();
-		v.start_threads();
-		v.start();
-	}
 	public void setClientSocket(Socket sock) {
 		clientSocket = sock;
 	}
 	public void close() {
 		rfb.close();
 		vncFrame.setVisible(false);
 		vncFrame.dispose();
 	}

Mercurial > hg > Members > nobuyasu > tightVNCClient

comparison src/myVncClient/MyVncClient.java @ 79:c76e43a12796