comparison src/main/java/jp/ac/u_ryukyu/treevnc/server/MyRfbProtoProxy.java @ 20:98519d16a8c3

getInitData from ProtocolContext
author Shinji KONO <kono@ie.u-ryukyu.ac.jp>
date Wed, 29 Aug 2012 23:22:14 +0900
parents ea83f4be0cc9
children bfddb801c3aa
comparison
equal deleted inserted replaced
19:ea83f4be0cc9 20:98519d16a8c3
14 import org.junit.Test; 14 import org.junit.Test;
15 15
16 import com.glavsoft.exceptions.CommonException; 16 import com.glavsoft.exceptions.CommonException;
17 import com.glavsoft.exceptions.TransportException; 17 import com.glavsoft.exceptions.TransportException;
18 import com.glavsoft.rfb.encoding.EncodingType; 18 import com.glavsoft.rfb.encoding.EncodingType;
19 import com.glavsoft.rfb.protocol.Protocol;
20 import com.glavsoft.rfb.protocol.ProtocolContext;
19 import com.glavsoft.transport.Reader; 21 import com.glavsoft.transport.Reader;
20 import com.glavsoft.transport.Writer; 22 import com.glavsoft.transport.Writer;
21 23
22 //import myVncProxy.MulticastQueue.Client; 24 //import myVncProxy.MulticastQueue.Client;
23 25
51 53
52 54
53 private ServerSocket servSock; 55 private ServerSocket servSock;
54 protected int acceptPort; 56 protected int acceptPort;
55 // private byte initData[]; 57 // private byte initData[];
56 byte initData[]; 58 ProtocolContext context;
57 private LinkedList<Socket> cliListTmp; 59 private LinkedList<Socket> cliListTmp;
58 private LinkedList<Socket> cliList; 60 private LinkedList<Socket> cliList;
59 boolean createBimgFlag; 61 boolean createBimgFlag;
60 boolean proxyFlag = true; 62 boolean proxyFlag = true;
61 // private Reader is; 63 // private Reader is;
753 byte[] b = new byte[0]; 755 byte[] b = new byte[0];
754 in.readBytes(b); 756 in.readBytes(b);
755 } 757 }
756 758
757 void sendInitData(Writer os) throws TransportException { 759 void sendInitData(Writer os) throws TransportException {
758 os.write(initData); 760 os.write(context.getInitData());
759 } 761 }
760 762
761 public void writeFramebufferUpdateRequest(int x, int y, int w, int h, 763 public void writeFramebufferUpdateRequest(int x, int y, int w, int h,
762 boolean incremental) throws TransportException { 764 boolean incremental) throws TransportException {
763 byte[] b = new byte[10]; 765 byte[] b = new byte[10];
773 b[8] = (byte) ((h >> 8) & 0xff); 775 b[8] = (byte) ((h >> 8) & 0xff);
774 b[9] = (byte) (h & 0xff); 776 b[9] = (byte) (h & 0xff);
775 777
776 os.write(b); 778 os.write(b);
777 } 779 }
780
781 public void setProtocolContext(Protocol workingProtocol) {
782 context = workingProtocol;
783 }
778 784
779 public void setInitData(byte[] _initData) {
780 initData = _initData;
781 }
782 } 785 }