Mercurial > 510Connectbot
annotate src/org/tn5250j/framework/tn5250/DataStreamProducer.java @ 99:eda03b809f48
move blocking test from socket read to queue take
| author | Carl Byington <carl@five-ten-sg.com> |
|---|---|
| date | Tue, 17 Jun 2014 15:13:41 -0700 |
| parents | 16e023784917 |
| children | 77ac18bc1b2f |
| rev | line source |
|---|---|
| 3 | 1 package org.tn5250j.framework.tn5250; |
| 2 | |
| 3 import java.io.BufferedInputStream; | |
| 4 import java.io.BufferedOutputStream; | |
| 5 import java.io.ByteArrayOutputStream; | |
| 6 import java.io.EOFException; | |
| 7 import java.io.FileNotFoundException; | |
| 8 import java.io.FileOutputStream; | |
| 9 import java.io.IOException; | |
| 10 import java.net.SocketException; | |
| 11 import java.util.concurrent.BlockingQueue; | |
| 12 | |
| 13 import org.tn5250j.encoding.ICodePage; | |
|
72
8181cb01c64d
use 5250 encryption config entry
Carl Byington <carl@five-ten-sg.com>
parents:
69
diff
changeset
|
14 |
|
25
5949eb469a79
adding tn5250 files, native android logging
Carl Byington <carl@five-ten-sg.com>
parents:
3
diff
changeset
|
15 import android.util.Log; |
|
5949eb469a79
adding tn5250 files, native android logging
Carl Byington <carl@five-ten-sg.com>
parents:
3
diff
changeset
|
16 |
| 3 | 17 |
| 18 public class DataStreamProducer implements Runnable { | |
|
25
5949eb469a79
adding tn5250 files, native android logging
Carl Byington <carl@five-ten-sg.com>
parents:
3
diff
changeset
|
19 private static final String TAG = "DataStreamProducer"; |
|
69
294435151b0c
use 5250 encryption config entry
Carl Byington <carl@five-ten-sg.com>
parents:
25
diff
changeset
|
20 private tnvt vt; |
| 3 | 21 private BufferedInputStream bin; |
| 22 private ByteArrayOutputStream baosin; | |
| 23 private Thread me; | |
| 24 private byte[] saveStream; | |
| 25 private final BlockingQueue<Object> dsq; | |
| 26 private byte[] abyte2; | |
| 27 private FileOutputStream fw; | |
| 28 private BufferedOutputStream dw; | |
| 29 private boolean dumpBytes = false; | |
| 30 private ICodePage codePage; | |
| 31 | |
|
25
5949eb469a79
adding tn5250 files, native android logging
Carl Byington <carl@five-ten-sg.com>
parents:
3
diff
changeset
|
32 |
| 3 | 33 |
|
99
eda03b809f48
move blocking test from socket read to queue take
Carl Byington <carl@five-ten-sg.com>
parents:
98
diff
changeset
|
34 public DataStreamProducer(tnvt vt, BufferedInputStream bin, BlockingQueue<Object> queue, byte[] init) { |
|
69
294435151b0c
use 5250 encryption config entry
Carl Byington <carl@five-ten-sg.com>
parents:
25
diff
changeset
|
35 this.bin = bin; |
|
294435151b0c
use 5250 encryption config entry
Carl Byington <carl@five-ten-sg.com>
parents:
25
diff
changeset
|
36 this.vt = vt; |
| 3 | 37 baosin = new ByteArrayOutputStream(); |
| 38 dsq = queue; | |
| 39 abyte2 = init; | |
| 40 } | |
| 41 | |
| 42 public void setInputStream(ByteArrayOutputStream is) { | |
| 43 | |
| 44 baosin = is; | |
| 45 | |
| 46 } | |
| 47 | |
| 48 public final void run() { | |
| 49 | |
| 50 boolean done = false; | |
| 51 | |
| 52 me = Thread.currentThread(); | |
| 53 | |
| 54 // load the first response screen | |
| 55 loadStream(abyte2, 0); | |
|
25
5949eb469a79
adding tn5250 files, native android logging
Carl Byington <carl@five-ten-sg.com>
parents:
3
diff
changeset
|
56 |
| 3 | 57 while (!done) { |
| 58 try { | |
| 59 | |
| 60 byte[] abyte0 = readIncoming(); | |
| 61 | |
| 62 // WVL - LDC : 17/05/2004 : Device name negotiations send TIMING MARK | |
| 63 // Restructured to the readIncoming() method to return null | |
| 64 // on TIMING MARK. Don't process in that case (abyte0 == null)! | |
| 65 if (abyte0 != null) | |
| 66 { | |
| 67 // WVL - LDC : 16/07/2003 : TR.000345 | |
| 68 // When the socket has been closed, the reading returns | |
| 69 // no bytes (an empty byte arrray). | |
| 70 // But the loadStream fails on this, so we check it here! | |
| 71 if (abyte0.length > 0) | |
| 72 { | |
| 73 loadStream(abyte0, 0); | |
| 74 } | |
| 75 // WVL - LDC : 16/07/2003 : TR.000345 | |
| 76 // Returning no bytes means the input buffer has | |
| 77 // reached end-of-stream, so we do a disconnect! | |
| 78 else | |
| 79 { | |
| 80 done = true; | |
| 81 vt.disconnect(); | |
| 82 } | |
| 83 } | |
| 84 | |
| 85 } | |
| 86 | |
| 87 catch (SocketException se) { | |
|
25
5949eb469a79
adding tn5250 files, native android logging
Carl Byington <carl@five-ten-sg.com>
parents:
3
diff
changeset
|
88 Log.w(TAG," DataStreamProducer thread interrupted and stopping " + se.getMessage()); |
| 3 | 89 done = true; |
| 90 } | |
| 91 | |
| 92 catch (IOException ioe) { | |
| 93 | |
|
25
5949eb469a79
adding tn5250 files, native android logging
Carl Byington <carl@five-ten-sg.com>
parents:
3
diff
changeset
|
94 Log.w(TAG,ioe.getMessage()); |
| 3 | 95 if (me.isInterrupted()) |
| 96 done = true; | |
| 97 | |
| 98 } | |
| 99 catch (Exception ex) { | |
| 100 | |
|
25
5949eb469a79
adding tn5250 files, native android logging
Carl Byington <carl@five-ten-sg.com>
parents:
3
diff
changeset
|
101 Log.w(TAG,ex.getMessage()); |
| 3 | 102 if (me.isInterrupted()) |
| 103 done = true; | |
| 104 | |
| 105 } | |
| 106 } | |
| 107 } | |
| 108 | |
| 109 private final void loadStream(byte abyte0[], int i) { | |
| 110 | |
| 111 int j = 0; | |
| 112 int size = 0; | |
| 113 if (saveStream == null) { | |
| 114 j = (abyte0[i] & 0xff) << 8 | abyte0[i + 1] & 0xff; | |
| 115 size = abyte0.length; | |
| 116 } | |
| 117 else { | |
| 118 size = saveStream.length + abyte0.length; | |
| 119 byte[] inter = new byte[size]; | |
| 120 System.arraycopy(saveStream, 0, inter, 0, saveStream.length); | |
| 121 System.arraycopy(abyte0, 0, inter, saveStream.length, abyte0.length); | |
| 122 abyte0 = new byte[size]; | |
| 123 System.arraycopy(inter, 0, abyte0, 0, size); | |
| 124 saveStream = null; | |
| 125 inter = null; | |
| 126 j = (abyte0[i] & 0xff) << 8 | abyte0[i + 1] & 0xff; | |
|
25
5949eb469a79
adding tn5250 files, native android logging
Carl Byington <carl@five-ten-sg.com>
parents:
3
diff
changeset
|
127 Log.d(TAG,"partial stream found"); |
| 3 | 128 } |
| 129 | |
| 130 if (j > size) { | |
| 131 saveStream = new byte[abyte0.length]; | |
| 132 System.arraycopy(abyte0, 0, saveStream, 0, abyte0.length); | |
|
25
5949eb469a79
adding tn5250 files, native android logging
Carl Byington <carl@five-ten-sg.com>
parents:
3
diff
changeset
|
133 Log.d(TAG,"partial stream saved"); |
| 3 | 134 } |
| 135 else { | |
| 136 byte abyte1[]; | |
| 137 try { | |
| 138 abyte1 = new byte[j + 2]; | |
| 139 | |
| 140 System.arraycopy(abyte0, i, abyte1, 0, j + 2); | |
| 141 dsq.put(abyte1); | |
| 142 if(abyte0.length > abyte1.length + i) | |
| 143 loadStream(abyte0, i + j + 2); | |
| 144 } | |
| 145 catch (Exception ex) { | |
| 146 | |
|
25
5949eb469a79
adding tn5250 files, native android logging
Carl Byington <carl@five-ten-sg.com>
parents:
3
diff
changeset
|
147 Log.w(TAG,"load stream error " + ex.getMessage()); |
| 3 | 148 // ex.printStackTrace(); |
| 149 // dump(abyte0); | |
| 150 | |
| 151 } | |
| 152 } | |
| 153 } | |
| 154 | |
| 155 public final byte[] readIncoming() | |
| 156 throws IOException { | |
| 157 | |
| 158 boolean done = false; | |
| 159 boolean negotiate = false; | |
| 160 | |
| 161 baosin.reset(); | |
| 162 int j = -1; | |
| 163 int i = 0; | |
|
25
5949eb469a79
adding tn5250 files, native android logging
Carl Byington <carl@five-ten-sg.com>
parents:
3
diff
changeset
|
164 |
| 3 | 165 while(!done) { |
| 166 i = bin.read(); | |
| 167 | |
| 168 // WVL - LDC : 16/07/2003 : TR.000345 | |
| 169 // The inStream return -1 when end-of-stream is reached. This | |
| 170 // happens e.g. when the connection is closed from the AS/400. | |
| 171 // So we stop in this case! | |
| 172 // ==> an empty byte array is returned from this method. | |
| 173 if (i == -1) // nothing read! | |
| 174 { | |
| 175 done = true; | |
| 176 vt.disconnect(); | |
| 177 continue; | |
| 178 } | |
| 179 | |
| 180 // We use the values instead of the static values IAC and EOR | |
| 181 // because they are defined as bytes. | |
| 182 // | |
| 183 // The > if(i != 255 || j != 255) < is a hack for the double FF FF's | |
| 184 // that are being returned. I do not know why this is like this and | |
| 185 // can not find any documentation for it. It is also being returned | |
| 186 // on my Client Access tcp dump as well so they are handling it. | |
| 187 // | |
| 188 // my5250 | |
| 189 // 0000: 00 50 DA 44 C8 45 42 00 00 00 00 24 08 00 45 00 .P.D.EB....$..E. | |
| 190 // 0010: 04 2A BC F9 00 00 40 06 D0 27 C1 A8 33 04 C1 A8 .*....@..'..3... | |
| 191 // 0020: 33 58 00 17 04 18 6F A2 83 CB 00 1E D1 BA 50 18 3X....o.......P. | |
| 192 // 0030: 20 00 8A 9A 00 00 03 FF FF 12 A0 00 00 04 00 00 ............... | |
| 193 // --------------------------- || || ------------------------------------- | |
| 194 // 0040: 03 04 40 04 11 00 20 01 07 00 00 00 18 00 00 10 ..@... ......... | |
| 195 | |
| 196 if(j == 255 && i == 255) { | |
| 197 j = -1; | |
| 198 continue; | |
| 199 } | |
| 200 baosin.write(i); | |
| 201 // check for end of record EOR and IAC - FFEF | |
| 202 if(j == 255 && i == 239) | |
| 203 done = true; | |
| 204 | |
| 205 // This is to check for the TELNET TIMING MARK OPTION | |
| 206 // rfc860 explains this in more detail. When we receive it | |
| 207 // we will negotiate with the server by sending a WONT'T TIMING-MARK | |
| 208 // This will let the server know that we processed the information | |
| 209 // and are just waiting for the user to enter some data so keep the | |
| 210 // socket alive. This is more or less a AYT (ARE YOU THERE) or not. | |
| 211 if(i == 253 && j == 255) { | |
| 212 done = true; | |
| 213 negotiate = true; | |
| 214 } | |
| 215 j = i; | |
| 216 } | |
| 217 | |
| 218 // after the initial negotiation we might get other options such as | |
| 219 // timing marks ?????????????? do we ???????????? look at telnet spec | |
| 220 // yes we do. rfc860 explains about timing marks. | |
| 221 | |
| 222 // WVL - LDC : 17/05/2004 : Device name negotiations send TIMING MARK | |
| 223 // to existing device! | |
| 224 // Handled incorrectly: we cannot continue processing the TIMING MARK DO | |
| 225 // after we have handled it in the vt.negotiate() | |
| 226 // We should not return the bytes; | |
| 227 // ==> restructured to return null after negotiation! | |
| 228 // Impacts the run method! Added the null check. | |
| 229 byte[] rBytes = baosin.toByteArray(); | |
| 230 | |
| 231 if (dumpBytes) { | |
| 232 dump(rBytes); | |
| 233 } | |
| 234 | |
| 235 if (negotiate) { | |
| 236 // get the negotiation option | |
| 237 baosin.write(bin.read()); | |
| 238 vt.negotiate(rBytes); | |
| 239 | |
| 240 return null; | |
| 241 } | |
| 242 return rBytes; | |
| 243 } | |
| 244 | |
| 245 protected final void toggleDebug (ICodePage cp) { | |
| 246 | |
| 247 if (codePage == null) | |
| 248 codePage = cp; | |
| 249 | |
| 250 dumpBytes = !dumpBytes; | |
| 251 if (dumpBytes) { | |
| 252 | |
| 253 try { | |
| 254 if (fw == null) { | |
| 255 fw = new FileOutputStream("log.txt"); | |
| 256 dw = new BufferedOutputStream(fw); | |
| 257 } | |
| 258 } | |
| 259 catch (FileNotFoundException fnfe) { | |
|
25
5949eb469a79
adding tn5250 files, native android logging
Carl Byington <carl@five-ten-sg.com>
parents:
3
diff
changeset
|
260 Log.w(TAG,fnfe.getMessage()); |
| 3 | 261 } |
| 262 | |
| 263 } | |
| 264 else { | |
| 265 | |
| 266 try { | |
| 267 | |
| 268 if (dw != null) | |
| 269 dw.close(); | |
| 270 if (fw != null) | |
| 271 fw.close(); | |
| 272 dw = null; | |
| 273 fw = null; | |
| 274 codePage = null; | |
| 275 } | |
| 276 catch(IOException ioe) { | |
| 277 | |
|
25
5949eb469a79
adding tn5250 files, native android logging
Carl Byington <carl@five-ten-sg.com>
parents:
3
diff
changeset
|
278 Log.w(TAG,ioe.getMessage()); |
| 3 | 279 } |
| 280 } | |
| 281 | |
|
25
5949eb469a79
adding tn5250 files, native android logging
Carl Byington <carl@five-ten-sg.com>
parents:
3
diff
changeset
|
282 Log.i(TAG,"Data Stream output is now " + dumpBytes); |
| 3 | 283 } |
| 284 | |
| 285 public void dump (byte[] abyte0) { | |
| 286 try { | |
| 287 | |
|
25
5949eb469a79
adding tn5250 files, native android logging
Carl Byington <carl@five-ten-sg.com>
parents:
3
diff
changeset
|
288 Log.i(TAG,"\n Buffer Dump of data from AS400: "); |
| 3 | 289 dw.write("\r\n Buffer Dump of data from AS400: ".getBytes()); |
| 290 | |
| 291 StringBuffer h = new StringBuffer(); | |
| 292 for (int x = 0; x < abyte0.length; x++) { | |
| 293 if (x % 16 == 0) { | |
| 294 System.out.println(" " + h.toString()); | |
| 295 dw.write((" " + h.toString() + "\r\n").getBytes()); | |
| 296 | |
| 297 h.setLength(0); | |
| 298 h.append("+0000"); | |
| 299 h.setLength(5 - Integer.toHexString(x).length()); | |
| 300 h.append(Integer.toHexString(x).toUpperCase()); | |
| 301 | |
| 302 System.out.print(h.toString()); | |
| 303 dw.write(h.toString().getBytes()); | |
| 304 | |
| 305 h.setLength(0); | |
| 306 } | |
| 307 char ac = codePage.ebcdic2uni(abyte0[x]); | |
| 308 if (ac < ' ') | |
| 309 h.append('.'); | |
| 310 else | |
| 311 h.append(ac); | |
| 312 if (x % 4 == 0) { | |
| 313 System.out.print(" "); | |
| 314 dw.write((" ").getBytes()); | |
| 315 | |
| 316 } | |
| 317 | |
| 318 if (Integer.toHexString(abyte0[x] & 0xff).length() == 1){ | |
| 319 System.out.print("0" + Integer.toHexString(abyte0[x] & 0xff).toUpperCase()); | |
| 320 dw.write(("0" + Integer.toHexString(abyte0[x] & 0xff).toUpperCase()).getBytes()); | |
| 321 | |
| 322 } | |
| 323 else { | |
| 324 System.out.print(Integer.toHexString(abyte0[x] & 0xff).toUpperCase()); | |
| 325 dw.write((Integer.toHexString(abyte0[x] & 0xff).toUpperCase()).getBytes()); | |
| 326 } | |
| 327 | |
| 328 } | |
| 329 System.out.println(); | |
| 330 dw.write("\r\n".getBytes()); | |
| 331 | |
| 332 dw.flush(); | |
| 333 } | |
| 334 catch(EOFException _ex) { } | |
| 335 catch(Exception _ex) { | |
|
25
5949eb469a79
adding tn5250 files, native android logging
Carl Byington <carl@five-ten-sg.com>
parents:
3
diff
changeset
|
336 Log.w(TAG,"Cannot dump from host\n\r"); |
| 3 | 337 } |
| 338 | |
| 339 } | |
| 340 | |
| 341 // public void dumpBytes() { | |
| 342 // byte shit[] = bk.buffer; | |
| 343 // for (int i = 0;i < shit.length;i++) | |
| 344 // System.out.println(i + ">" + shit[i] + "< - ascii - >" + getASCIIChar(shit[i]) + "<"); | |
| 345 // } | |
| 346 // | |
| 347 // public void dumpHexBytes(byte[] abyte) { | |
| 348 // byte shit[] = abyte; | |
| 349 // for (int i = 0;i < shit.length;i++) | |
| 350 // System.out.println(i + ">" + shit[i] + "< hex >" + Integer.toHexString((shit[i] & 0xff))); | |
| 351 // } | |
| 352 | |
|
98
16e023784917
protect both read calls with test for blocking
Carl Byington <carl@five-ten-sg.com>
parents:
72
diff
changeset
|
353 } |