Mercurial > hg > Applications > TreeVNC
annotate src/main/java/com/glavsoft/rfb/encoding/decoder/ZRLEDecoder.java @ 576:d5138119d8c4
remove single buffer
author | Shinji KONO <kono@ie.u-ryukyu.ac.jp> |
---|---|
date | Fri, 07 Feb 2020 14:50:01 +0900 |
parents | a0eeba3ee5d4 |
children | a236602a9191 |
rev | line source |
---|---|
57
17b702648079
version2.7.2 original version.
Taninari YU <you@cr.ie.u-ryukyu.ac.jp>
parents:
0
diff
changeset
|
1 // Copyright (C) 2010, 2011, 2012, 2013 GlavSoft LLC. |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
2 // All rights reserved. |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
3 // |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
4 //------------------------------------------------------------------------- |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
5 // This file is part of the TightVNC software. Please visit our Web site: |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
6 // |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
7 // http://www.tightvnc.com/ |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
8 // |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
9 // This program is free software; you can redistribute it and/or modify |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
10 // it under the terms of the GNU General Public License as published by |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
11 // the Free Software Foundation; either version 2 of the License, or |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
12 // (at your option) any later version. |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
13 // |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
14 // This program is distributed in the hope that it will be useful, |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
15 // but WITHOUT ANY WARRANTY; without even the implied warranty of |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
16 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
17 // GNU General Public License for more details. |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
18 // |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
19 // You should have received a copy of the GNU General Public License along |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
20 // with this program; if not, write to the Free Software Foundation, Inc., |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
21 // 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
22 //------------------------------------------------------------------------- |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
23 // |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
24 |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
25 package com.glavsoft.rfb.encoding.decoder; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
26 |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
27 import com.glavsoft.drawing.Renderer; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
28 import com.glavsoft.exceptions.TransportException; |
526 | 29 import com.glavsoft.rfb.encoding.EncodingType; |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
30 import com.glavsoft.transport.Reader; |
526 | 31 import jp.ac.u_ryukyu.treevnc.CheckDelay; |
498 | 32 import jp.ac.u_ryukyu.treevnc.TreeRFBProto; |
526 | 33 import java.io.UnsupportedEncodingException; |
34 import java.nio.ByteBuffer; | |
528 | 35 import java.util.LinkedList; |
526 | 36 import java.util.zip.Deflater; |
37 | |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
38 public class ZRLEDecoder extends ZlibDecoder { |
57
17b702648079
version2.7.2 original version.
Taninari YU <you@cr.ie.u-ryukyu.ac.jp>
parents:
0
diff
changeset
|
39 private static final int MAX_TILE_SIZE = 64; |
539 | 40 private int[] decodedBitmap; |
41 private int[] palette; | |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
42 |
539 | 43 class TileLoop { |
535 | 44 private final boolean blocking; |
538 | 45 private int deflate_size = 55507; |
528 | 46 private ByteBuffer c1; |
532 | 47 private int width; // phase2 length |
528 | 48 private FramebufferUpdateRectangle c1rect; |
49 private int prevLineOffset; | |
50 private int prevC1Offset; | |
541 | 51 private int prevC1LineOffset; |
528 | 52 private int prevoffset; |
53 private Deflater deflater; | |
572 | 54 private int flushOffset; |
528 | 55 |
56 /** | |
57 * Multicast framebufferUpdate to children. | |
58 * read FrameBuffferUpdate. If it is ZLE, make it ZLEE which is self contained compressed packet. | |
59 * put the packet to the multicastqueue. Then normal rendering engine read the same stream using is.reset(). | |
539 | 60 * <p> |
528 | 61 * Haeder |
539 | 62 * messageID ( FrameBuffer Update |
63 * 1 byte padding | |
64 * 2 byte numberofrectangle | |
65 * 2 - U16 - x-position | |
66 * 2 - U16 - y-position | |
67 * 2 - U16 - width | |
68 * 2 - U16 - height | |
69 * 4 - S32 - encoding-type | |
70 * 4 byte datalengths | |
71 * datalengths databyte | |
528 | 72 * |
73 * @throws TransportException | |
74 * @throws UnsupportedEncodingException | |
75 */ | |
76 | |
566 | 77 public TileLoop(TreeRFBProto rfb, int offset) { |
539 | 78 prevoffset = prevLineOffset = offset; |
79 prevC1Offset = 0; | |
572 | 80 flushOffset = 0; |
566 | 81 if (rfb == null || offset < deflate_size + spanGap) { |
535 | 82 // packet size fit in broadcast send it all at once |
83 blocking = false; | |
84 } else | |
85 blocking = true; | |
533 | 86 } |
528 | 87 |
535 | 88 private void zrleeBlocking(TreeRFBProto rfb, ByteBuffer header, FramebufferUpdateRectangle rect, byte bytes[]) { |
528 | 89 // dump32(inputs); |
90 deflater = rfb.deflater; | |
541 | 91 c1rect = new FramebufferUpdateRectangle(rect.x, rect.y, 0, 0); |
532 | 92 newMulticastPacket(rfb, rect); |
568 | 93 //c1.put(header.get(0)); |
535 | 94 if (!blocking) { |
539 | 95 deflater.setInput(bytes, 0, prevoffset); |
535 | 96 deflater.deflate(c1); |
572 | 97 flushMuticast(rfb, bytes); |
535 | 98 } |
532 | 99 return; |
100 } | |
101 | |
102 private void newMulticastPacket(TreeRFBProto rfb, FramebufferUpdateRectangle rect) { | |
539 | 103 c1 = rfb.multicastqueue.allocate(deflate_size + 20); |
104 c1.limit(c1.limit() - 20); | |
528 | 105 if (rfb.addSerialNum) |
106 c1.putLong(rfb.counter++); | |
107 if (rfb.checkDelay) | |
108 CheckDelay.checkDelay(c1, rect.x, rect.y, rect.width, rect.height, System.currentTimeMillis(), EncodingType.CHECK_DELAY); | |
541 | 109 c1.put((byte) 0); |
532 | 110 c1.put((byte) 0); |
111 c1.putShort((short) 0); | |
550
9c0cbe119155
fix make rectangle packet in client
e165729 <e165729@ie.u-ryukyu.ac.jp>
parents:
545
diff
changeset
|
112 c1.position(c1.position() + 12); |
532 | 113 c1.putInt(0); // should be data length |
539 | 114 prevC1Offset = c1.position(); |
541 | 115 prevC1LineOffset = prevC1Offset; |
532 | 116 width = 0; |
541 | 117 c1rect.width = c1rect.height = 0; |
528 | 118 } |
531
13d3c4341d14
remove .idea modules fix for loop
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
529
diff
changeset
|
119 |
528 | 120 int spanGap = 128; |
121 /** | |
534
a3d0ba67e8cf
try 512 tiles / 256 tiles flush
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
533
diff
changeset
|
122 * Series of tiles compose at most three rectangles. SYNC_FLUSH is necessary on |
a3d0ba67e8cf
try 512 tiles / 256 tiles flush
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
533
diff
changeset
|
123 * rectangle boundaries. |
539 | 124 * <p> |
545
1ba61b57be39
add test routine in -p ( running as root mode )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
543
diff
changeset
|
125 * +----+ |
1ba61b57be39
add test routine in -p ( running as root mode )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
543
diff
changeset
|
126 * | | phase 0 |
1ba61b57be39
add test routine in -p ( running as root mode )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
543
diff
changeset
|
127 * +---------------+ |
1ba61b57be39
add test routine in -p ( running as root mode )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
543
diff
changeset
|
128 * | | phase 1 |
1ba61b57be39
add test routine in -p ( running as root mode )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
543
diff
changeset
|
129 * +----+----------+ |
1ba61b57be39
add test routine in -p ( running as root mode )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
543
diff
changeset
|
130 * | | phase 2 |
1ba61b57be39
add test routine in -p ( running as root mode )
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
543
diff
changeset
|
131 * +----+ |
539 | 132 * <p> |
534
a3d0ba67e8cf
try 512 tiles / 256 tiles flush
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
533
diff
changeset
|
133 * Broadcast packet have to less than 64kbytes |
539 | 134 * A tile 64x64x3 11288byte, a packet can contain 5 raw tiles, when these are |
135 * compressed 10 to 100 tiles can be stored. It is impossible to predict the | |
136 * compression rate. To check the compressed capacity, Deflate.needsInputs() can | |
137 * be used. If needsInputs() is false on SYNC_FLUSH, smaller input is necessary. | |
138 * <p> | |
139 * We'll try 512 tiles before SYNC_FLUSH in a phase, if it fails try flush former 256 tiles. | |
140 * If it will failed again, flush the previous line and do flush 512 tiles in new Packet. | |
141 * If it failed again try former 256 tiles flushed, if this failes again dicard the former half. | |
142 * The last case cannot happen but former 256 tiles have to be flushed, because the next 256 lines | |
143 * may failed again and restart the from this point. | |
144 * The next packet start with later 256 tiles filled and unflushed. | |
534
a3d0ba67e8cf
try 512 tiles / 256 tiles flush
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
533
diff
changeset
|
145 * |
528 | 146 * @param rfb |
147 * @param last | |
148 * @param rect | |
149 * @param bytes | |
150 * @param offset | |
151 * @param tileW | |
152 * @param tileH | |
153 */ | |
539 | 154 |
534
a3d0ba67e8cf
try 512 tiles / 256 tiles flush
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
533
diff
changeset
|
155 int MAX_ZTILE = 512; |
a3d0ba67e8cf
try 512 tiles / 256 tiles flush
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
533
diff
changeset
|
156 |
531
13d3c4341d14
remove .idea modules fix for loop
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
529
diff
changeset
|
157 public void multicastPut(TreeRFBProto rfb, boolean last, FramebufferUpdateRectangle rect, byte[] bytes, int offset, int tileW, int tileH) { |
564 | 158 boolean flush = false; |
535 | 159 if (!blocking) return; |
528 | 160 int span = offset - prevoffset; |
539 | 161 deflater.setInput(bytes, prevoffset, span); |
564 | 162 int output = deflater.deflate(c1, Deflater.NO_FLUSH); |
163 if (output==0 && ! deflater.needsInput() ) { | |
164 // compression failed | |
565 | 165 deflater.setInput(bytes, prevoffset, 0); |
166 output = deflater.deflate(c1, Deflater.FULL_FLUSH); | |
571
1dd4eea9f566
offset manegement in ZREE blocking
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
568
diff
changeset
|
167 prevoffset = offset; |
564 | 168 flushRectangle(rect); |
572 | 169 flushMuticast(rfb, bytes); |
564 | 170 if (!last) { |
171 newMulticastPacket(rfb, rect); | |
172 deflater.deflate(c1, Deflater.NO_FLUSH); | |
173 } else { | |
174 deflater.deflate(c1, Deflater.NO_FLUSH); | |
175 deflater.finish(); | |
572 | 176 flushMuticast(rfb, bytes); |
564 | 177 } |
178 return ; | |
179 } | |
571
1dd4eea9f566
offset manegement in ZREE blocking
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
568
diff
changeset
|
180 // deflater.deflate(c1); |
528 | 181 prevoffset = offset; |
539 | 182 width += tileW; |
532 | 183 if (c1rect.x > rect.x) { // phase 0 |
539 | 184 if (c1rect.x + c1rect.width < rect.x + rect.width) { |
564 | 185 } else { // end of phase 0 |
539 | 186 c1rect.width = rect.x + rect.width - c1rect.x; |
541 | 187 prevC1LineOffset = c1.position(); |
528 | 188 } |
538 | 189 } else { // phase 1 |
564 | 190 if (width >= rect.width) { // next line |
532 | 191 c1rect.width = rect.width; |
192 width = 0; | |
531
13d3c4341d14
remove .idea modules fix for loop
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
529
diff
changeset
|
193 prevLineOffset = offset; |
541 | 194 prevC1LineOffset = c1.position(); |
534
a3d0ba67e8cf
try 512 tiles / 256 tiles flush
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
533
diff
changeset
|
195 } |
a3d0ba67e8cf
try 512 tiles / 256 tiles flush
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
533
diff
changeset
|
196 } |
a3d0ba67e8cf
try 512 tiles / 256 tiles flush
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
533
diff
changeset
|
197 } |
a3d0ba67e8cf
try 512 tiles / 256 tiles flush
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
533
diff
changeset
|
198 |
528 | 199 |
200 /** | |
201 * fix rectangle header | |
202 * create next rectangle header | |
203 * update position paramater | |
204 * send muticast pacate if nessesally | |
205 */ | |
532 | 206 private void flushRectangle(FramebufferUpdateRectangle rect) { |
550
9c0cbe119155
fix make rectangle packet in client
e165729 <e165729@ie.u-ryukyu.ac.jp>
parents:
545
diff
changeset
|
207 c1.putShort(prevC1Offset - 16, (short) c1rect.x); |
9c0cbe119155
fix make rectangle packet in client
e165729 <e165729@ie.u-ryukyu.ac.jp>
parents:
545
diff
changeset
|
208 c1.putShort(prevC1Offset - 14, (short) c1rect.y); |
9c0cbe119155
fix make rectangle packet in client
e165729 <e165729@ie.u-ryukyu.ac.jp>
parents:
545
diff
changeset
|
209 c1.putShort(prevC1Offset - 12, (short) c1rect.width); |
9c0cbe119155
fix make rectangle packet in client
e165729 <e165729@ie.u-ryukyu.ac.jp>
parents:
545
diff
changeset
|
210 c1.putShort(prevC1Offset - 10, (short) c1rect.height); |
9c0cbe119155
fix make rectangle packet in client
e165729 <e165729@ie.u-ryukyu.ac.jp>
parents:
545
diff
changeset
|
211 c1.putInt(prevC1Offset - 8, EncodingType.ZRLEE.getId()); |
9c0cbe119155
fix make rectangle packet in client
e165729 <e165729@ie.u-ryukyu.ac.jp>
parents:
545
diff
changeset
|
212 c1.putInt(prevC1Offset - 4, c1.position() - prevC1Offset - 12); // data length |
539 | 213 c1.putShort(2, (short) (c1.getShort(2) + 1)); // increment rectangle count |
214 prevC1Offset = c1.position(); | |
541 | 215 nextPhase(rect); |
534
a3d0ba67e8cf
try 512 tiles / 256 tiles flush
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
533
diff
changeset
|
216 } |
a3d0ba67e8cf
try 512 tiles / 256 tiles flush
Shinji KONO <kono@ie.u-ryukyu.ac.jp>
parents:
533
diff
changeset
|
217 |
541 | 218 private void nextPhase(FramebufferUpdateRectangle rect) { |
539 | 219 if (c1rect.x + c1rect.width < rect.x + rect.width) { |
532 | 220 c1rect.x = c1rect.width; // next rectangle is phase 1 |
221 } else { | |
222 c1rect.x = rect.x; | |
223 c1rect.y += c1rect.height; | |
224 } | |
225 width = 0; | |
528 | 226 } |
227 | |
572 | 228 private void flushMuticast(TreeRFBProto rfb, byte[] checkBytes) { |
528 | 229 c1.flip(); |
230 //System.out.println("multicastPut: " + c1rect + " length: " + (c1.remaining()-c1headerPos-header.limit())); | |
563 | 231 deflater.reset(); |
529 | 232 |
563 | 233 LinkedList<ByteBuffer> bufs = new LinkedList<ByteBuffer>(); |
234 bufs.add(c1); | |
572 | 235 rfb.getContext().checkFrameBufferRectanble(c1, checkBytes, flushOffset, prevoffset); |
236 flushOffset = prevoffset; | |
563 | 237 if (rfb.isTreeManager() && rfb.connectionPresenter.isUseMulticast()) { |
238 for (ByteBuffer buf : bufs) | |
239 rfb.getViewer().getRfbBroadcastListener().multicastUpdateRectangle(buf); | |
240 } else { | |
241 rfb.multicastqueue.put(bufs); | |
242 } | |
528 | 243 } |
244 } | |
526 | 245 |
246 @Override | |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
247 public void decode(Reader reader, Renderer renderer, |
539 | 248 FramebufferUpdateRectangle rect) throws TransportException { |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
249 int zippedLength = (int) reader.readUInt32(); |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
250 if (0 == zippedLength) return; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
251 int length = rect.width * rect.height * renderer.getBytesPerPixel(); |
576 | 252 byte[] bytes = unzip(reader, zippedLength, length, rect.getEncodingType()).array(); |
526 | 253 decode1(renderer, null, rect, bytes, zippedLength, null); |
539 | 254 } |
533 | 255 |
256 | |
257 public void multicastDecode(Reader reader, Renderer renderer, | |
539 | 258 FramebufferUpdateRectangle rect, TreeRFBProto rfb) throws TransportException { |
259 ByteBuffer header = ByteBuffer.allocate(16); | |
260 reader.read(header.array()); | |
533 | 261 int zippedLength = (int) reader.readUInt32(); |
262 if (0 == zippedLength) return; | |
263 int length = rect.width * rect.height * renderer.getBytesPerPixel(); | |
576 | 264 byte[] bytes = unzip(reader, zippedLength, length, rect.getEncodingType()).array(); |
533 | 265 decode1(renderer, header, rect, bytes, zippedLength, rfb); |
266 } | |
267 | |
526 | 268 public void decode1(Renderer renderer, ByteBuffer header, FramebufferUpdateRectangle rect, byte[] bytes, int zippedLength, TreeRFBProto rfbProto) throws TransportException { |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
269 int offset = zippedLength; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
270 int maxX = rect.x + rect.width; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
271 int maxY = rect.y + rect.height; |
528 | 272 |
566 | 273 TileLoop tileloop = new TileLoop(rfbProto, zippedLength); |
550
9c0cbe119155
fix make rectangle packet in client
e165729 <e165729@ie.u-ryukyu.ac.jp>
parents:
545
diff
changeset
|
274 //System.out.println("decode1: "+rect.toString()); |
539 | 275 if (null == palette) { |
276 palette = new int[128]; | |
277 } | |
278 if (null == decodedBitmap) { | |
279 decodedBitmap = new int[MAX_TILE_SIZE * MAX_TILE_SIZE]; | |
280 } | |
526 | 281 |
566 | 282 if (rfbProto !=null && rfbProto.multicastBlocking) { |
539 | 283 tileloop.zrleeBlocking(rfbProto, header, rect, bytes); |
526 | 284 } |
539 | 285 try { |
286 for (int tileY = rect.y; tileY < maxY; tileY += MAX_TILE_SIZE) { | |
287 int tileHeight = Math.min(maxY - tileY, MAX_TILE_SIZE); | |
566 | 288 if (tileloop.blocking) |
289 tileloop.c1rect.height += tileHeight; | |
539 | 290 for (int tileX = rect.x; tileX < maxX; tileX += MAX_TILE_SIZE) { |
291 int tileWidth = Math.min(maxX - tileX, MAX_TILE_SIZE); | |
566 | 292 if (tileloop.blocking && tileloop.c1rect.x + tileloop.c1rect.width < rect.x + rect.width) |
564 | 293 tileloop.c1rect.width += tileWidth; |
539 | 294 int subencoding = bytes[offset++] & 0x0ff; |
295 if (subencoding != 0) | |
296 System.out.println("----------------" + subencoding); | |
297 // 128 -plain RLE, 130-255 - Palette RLE | |
298 boolean isRle = (subencoding & 128) != 0; | |
299 // 2 to 16 for raw packed palette data, 130 to 255 for Palette RLE (subencoding - 128) | |
300 int paletteSize = subencoding & 127; | |
301 offset += readPalette(bytes, offset, renderer, paletteSize); | |
302 if (1 == subencoding) { // A solid tile consisting of a single colour | |
303 renderer.fillRect(palette[0], tileX, tileY, tileWidth, tileHeight); | |
304 } else if (isRle) { | |
305 if (0 == paletteSize) { // subencoding == 128 (or paletteSize == 0) - Plain RLE | |
306 offset += decodePlainRle(bytes, offset, renderer, tileX, tileY, tileWidth, tileHeight); | |
307 } else { | |
308 offset += decodePaletteRle(bytes, offset, renderer, tileX, tileY, tileWidth, tileHeight); | |
309 } | |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
310 } else { |
539 | 311 if (0 == paletteSize) { // subencoding == 0 (or paletteSize == 0) - raw CPIXEL data |
312 offset += decodeRaw(bytes, offset, renderer, tileX, tileY, tileWidth, tileHeight); | |
63 | 313 // System.out.println("offset:"+offset); |
539 | 314 } else { |
315 offset += decodePacked(bytes, offset, renderer, paletteSize, tileX, tileY, tileWidth, tileHeight); | |
316 } | |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
317 } |
539 | 318 if (rfbProto != null && rfbProto.multicastBlocking) |
319 tileloop.multicastPut(rfbProto, false, rect, bytes, offset, tileWidth, tileHeight); | |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
320 } |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
321 } |
539 | 322 if (rfbProto != null && rfbProto.multicastBlocking) |
323 tileloop.multicastPut(rfbProto, true, rect, bytes, offset, 0, 0); | |
324 } catch (Exception e) { | |
560 | 325 e.printStackTrace(); |
539 | 326 if (rfbProto != null && rfbProto.multicastBlocking) |
327 tileloop.multicastPut(rfbProto, true, rect, bytes, offset, 0, 0); | |
328 throw e; | |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
329 } |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
330 } |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
331 |
539 | 332 |
333 | |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
334 private int decodePlainRle(byte[] bytes, int offset, Renderer renderer, |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
335 int tileX, int tileY, int tileWidth, int tileHeight) { |
57
17b702648079
version2.7.2 original version.
Taninari YU <you@cr.ie.u-ryukyu.ac.jp>
parents:
0
diff
changeset
|
336 int bytesPerCPixel = renderer.getBytesPerCPixel(); |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
337 int decodedOffset = 0; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
338 int decodedEnd = tileWidth * tileHeight; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
339 int index = offset; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
340 while (decodedOffset < decodedEnd) { |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
341 int color = renderer.getCompactPixelColor(bytes, index); |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
342 index += bytesPerCPixel; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
343 int rlength = 1; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
344 do { |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
345 rlength += bytes[index] & 0x0ff; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
346 } while ((bytes[index++] & 0x0ff) == 255); |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
347 assert rlength <= decodedEnd - decodedOffset; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
348 renderer.fillColorBitmapWithColor(decodedBitmap, decodedOffset, rlength, color); |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
349 decodedOffset += rlength; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
350 } |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
351 renderer.drawColoredBitmap(decodedBitmap, tileX, tileY, tileWidth, tileHeight); |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
352 return index - offset; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
353 } |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
354 |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
355 private int decodePaletteRle(byte[] bytes, int offset, Renderer renderer, |
57
17b702648079
version2.7.2 original version.
Taninari YU <you@cr.ie.u-ryukyu.ac.jp>
parents:
0
diff
changeset
|
356 int tileX, int tileY, int tileWidth, int tileHeight) { |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
357 int decodedOffset = 0; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
358 int decodedEnd = tileWidth * tileHeight; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
359 int index = offset; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
360 while (decodedOffset < decodedEnd) { |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
361 int colorIndex = bytes[index++]; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
362 int color = palette[colorIndex & 127]; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
363 int rlength = 1; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
364 if ((colorIndex & 128) != 0) { |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
365 do { |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
366 rlength += bytes[index] & 0x0ff; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
367 } while (bytes[index++] == (byte) 255); |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
368 } |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
369 assert rlength <= decodedEnd - decodedOffset; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
370 renderer.fillColorBitmapWithColor(decodedBitmap, decodedOffset, rlength, color); |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
371 decodedOffset += rlength; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
372 } |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
373 renderer.drawColoredBitmap(decodedBitmap, tileX, tileY, tileWidth, tileHeight); |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
374 return index - offset; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
375 } |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
376 |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
377 private int decodePacked(byte[] bytes, int offset, Renderer renderer, |
57
17b702648079
version2.7.2 original version.
Taninari YU <you@cr.ie.u-ryukyu.ac.jp>
parents:
0
diff
changeset
|
378 int paletteSize, int tileX, int tileY, int tileWidth, int tileHeight) { |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
379 int bitsPerPalletedPixel = paletteSize > 16 ? 8 : paletteSize > 4 ? 4 |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
380 : paletteSize > 2 ? 2 : 1; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
381 int packedOffset = offset; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
382 int decodedOffset = 0; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
383 for (int i = 0; i < tileHeight; ++i) { |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
384 int decodedRowEnd = decodedOffset + tileWidth; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
385 int byteProcessed = 0; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
386 int bitsRemain = 0; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
387 |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
388 while (decodedOffset < decodedRowEnd) { |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
389 if (bitsRemain == 0) { |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
390 byteProcessed = bytes[packedOffset++]; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
391 bitsRemain = 8; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
392 } |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
393 bitsRemain -= bitsPerPalletedPixel; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
394 int index = byteProcessed >> bitsRemain & (1 << bitsPerPalletedPixel) - 1 & 127; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
395 int color = palette[index]; |
57
17b702648079
version2.7.2 original version.
Taninari YU <you@cr.ie.u-ryukyu.ac.jp>
parents:
0
diff
changeset
|
396 renderer.fillColorBitmapWithColor(decodedBitmap, decodedOffset, 1, color); |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
397 ++decodedOffset; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
398 } |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
399 } |
57
17b702648079
version2.7.2 original version.
Taninari YU <you@cr.ie.u-ryukyu.ac.jp>
parents:
0
diff
changeset
|
400 renderer.drawColoredBitmap(decodedBitmap, tileX, tileY, tileWidth, tileHeight); |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
401 return packedOffset - offset; |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
402 } |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
403 |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
404 private int decodeRaw(byte[] bytes, int offset, Renderer renderer, |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
405 int tileX, int tileY, int tileWidth, int tileHeight) throws TransportException { |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
406 return renderer.drawCompactBytes(bytes, offset, tileX, tileY, tileWidth, tileHeight); |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
407 } |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
408 |
57
17b702648079
version2.7.2 original version.
Taninari YU <you@cr.ie.u-ryukyu.ac.jp>
parents:
0
diff
changeset
|
409 private int readPalette(byte[] bytes, int offset, Renderer renderer, int paletteSize) { |
17b702648079
version2.7.2 original version.
Taninari YU <you@cr.ie.u-ryukyu.ac.jp>
parents:
0
diff
changeset
|
410 final int bytesPerCPixel = renderer.getBytesPerCPixel(); |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
411 for (int i=0; i<paletteSize; ++i) { |
57
17b702648079
version2.7.2 original version.
Taninari YU <you@cr.ie.u-ryukyu.ac.jp>
parents:
0
diff
changeset
|
412 palette[i] = renderer.getCompactPixelColor(bytes, offset + i* bytesPerCPixel); |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
413 } |
57
17b702648079
version2.7.2 original version.
Taninari YU <you@cr.ie.u-ryukyu.ac.jp>
parents:
0
diff
changeset
|
414 return paletteSize * bytesPerCPixel; |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
415 } |
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
416 |
526 | 417 |
418 | |
0
4689cc86d6cb
create TreeViewer2 Repository
Yu Taninari <you@cr.ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
419 } |