Members/nobuyasu/tightVNCProxy: src/myVncProxy/MyRfbProto.java comparison

comparison src/myVncProxy/MyRfbProto.java @ 65:5fca2bb52dc7

create checkMillis

author	e085711
date	Fri, 22 Jul 2011 03:21:56 +0900
parents	7795e2b5d3ef
children	7632606406cb

comparison

equal deleted inserted replaced

-:4864a7d1df00
+:5fca2bb52dc7
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.io.OutputStream;
 class MyRfbProto extends RfbProto {
 	final static String versionMsg_3_998 = "RFB 003.998\n";
+	/**
+	 * CheckMillis is one of new msgType for RFB 3.998.
+	 */
+	final static int CheckMillis = 4;
+	boolean printStatusFlag = false;
+	long startCheckTime;
 	private int messageType;
 	private int rectangles;
 	private int rectX;
 	private int rectY;
 			dataLen = 1000000;
 			mark(dataLen);
 		}
 		return dataLen;
 	}
 	void readSendData(int dataLen) throws IOException {
 		byte buffer[] = new byte[dataLen];
 		readFully(buffer);
 		multicastqueue.put(buffer);
 		reset();
 /*
 		for (Socket cli : cliList) {
 			try {
 				OutputStream out = cli.getOutputStream();
 				executor.execute(new SendThread(out, buffer));
 	BufferedImage createBimg() throws IOException {
 		BufferedImage bimg = ImageIO.read(new ByteArrayInputStream(pngBytes));
 		return bimg;
 	}
+/*
 	void readPngData() throws IOException {
 		pngBytes = new byte[is.available()];
 		readFully(pngBytes);
 	}
+*/
 	void printFramebufferUpdate() {
 		System.out.println("messageType=" + messageType);
 		System.out.println("rectangles=" + rectangles);
 		System.out.println("encoding=" + encoding);
 					+ 16);
 			break;
 		default:
 		}
 	}
+	void readCheckMillis() throws IOException {
+		byte[] b = new byte[4];
+		readFully(b);
+	}
+	void startCheckMills() {
+		byte[] b = new byte[4];
+		b = castIntByte(4);
+		startCheckTime = System.currentTimeMillis();
+		multicastqueue.put(b);
+	}
+	void endCheckMills() {
+		long accTime = System.currentTimeMillis();
+		long time = accTime - startCheckTime;
+		System.out.println("checkMillis: " + time);
+	}
+	void printStatus() {
+		System.out.println();
+	}
+	synchronized void changeStatusFlag() {
+		printStatusFlag = true;
+	}
+	void printMills() {
+		if(printStatusFlag) {
+			changeStatusFlag();
+		} else {
+			changeStatusFlag();
+		}
+	}
 	void newClient(acceptThread acceptThread, final Socket newCli,
 			final OutputStream os, final InputStream is) throws IOException {
 		// createBimgFlag = true;
 		// rfb.addSockTmp(newCli);
 		//		addSock(newCli);
 		final Client<byte[]> c = multicastqueue.newClient();
 		Runnable sender = new Runnable() {
 			public void run() {
 				try {
-					// 初期接続確立の部分
+					/**
+					 *  initial connection of RFB protocol
+					 */
 					sendRfbVersion(os);
 					readVersionMsg(is);
 					sendSecurityType(os);
 					readSecType(is);
 					sendSecResult(os);
 					for (;;) {
 						byte[] b = c.poll();
 						os.write(b, 0, b.length);
 					}
 				} catch (IOException e) {
-					//接続が切れた処理
+					/**
-					//lockしないと駄目
+					 * if socket closed
+					 */
 					//					cliList.remove(newCli);
 				}
 			}

Mercurial > hg > Members > nobuyasu > tightVNCProxy

comparison src/myVncProxy/MyRfbProto.java @ 65:5fca2bb52dc7