510Connectbot: src/org/tn5250j/framework/tn5250/tnvt.java comparison

comparison src/org/tn5250j/framework/tn5250/tnvt.java @ 112:77ac18bc1b2f

cleanup java formatting

author	Carl Byington <carl@five-ten-sg.com>
date	Wed, 18 Jun 2014 13:03:01 -0700
parents	1a34365fab9b
children	6969d6cebcd7

comparison

equal deleted inserted replaced

-:6a0ad4d384ea
+:77ac18bc1b2f
 public final class tnvt implements Runnable {
 private static final String TAG = "tnvt";
 // negotiating commands
-private static final byte IAC = (byte) -1; // 255 FF
+private static final byte IAC = (byte) - 1; // 255 FF
-private static final byte DONT = (byte) -2; //254 FE
+private static final byte DONT = (byte) - 2; //254 FE
-private static final byte DO = (byte) -3; //253 FD
+private static final byte DO = (byte) - 3; //253 FD
-private static final byte WONT = (byte) -4; //252 FC
+private static final byte WONT = (byte) - 4; //252 FC
-private static final byte WILL = (byte) -5; //251 FB
+private static final byte WILL = (byte) - 5; //251 FB
-private static final byte SB = (byte) -6; //250 Sub Begin FA
+private static final byte SB = (byte) - 6; //250 Sub Begin FA
-private static final byte SE = (byte) -16; //240 Sub End F0
+private static final byte SE = (byte) - 16; //240 Sub End F0
-private static final byte EOR = (byte) -17; //239 End of Record EF
+private static final byte EOR = (byte) - 17; //239 End of Record EF
 private static final byte TERMINAL_TYPE = (byte) 24; // 18
 private static final byte OPT_END_OF_RECORD = (byte) 25; // 19
 private static final byte TRANSMIT_BINARY = (byte) 0; // 0
 private static final byte QUAL_IS = (byte) 0; // 0
 private static final byte TIMING_MARK = (byte) 6; // 6
 setCodePage("37");
 dataIncluded = new boolean[24];
 if (System.getProperties().containsKey("SESSION_CONNECT_USER")) {
 user = System.getProperties().getProperty("SESSION_CONNECT_USER");
 if (System.getProperties().containsKey("SESSION_CONNECT_PASSWORD"))
 password = System.getProperties().getProperty(
 "SESSION_CONNECT_PASSWORD");
 if (System.getProperties().containsKey("SESSION_CONNECT_LIBRARY"))
 library = System.getProperties().getProperty(
 "SESSION_CONNECT_LIBRARY");
 if (System.getProperties().containsKey("SESSION_CONNECT_MENU"))
 initialMenu = System.getProperties().getProperty(
 "SESSION_CONNECT_MENU");
 if (System.getProperties().containsKey("SESSION_CONNECT_PROGRAM"))
 program = System.getProperties().getProperty(
 "SESSION_CONNECT_PROGRAM");
 }
 baosp = new ByteArrayOutputStream();
 baosrsp = new ByteArrayOutputStream();
 }
 public void showURL(String url) {
 if (url.indexOf("://") < 0) url = "http://" + url;
 Intent intent = new Intent(Intent.ACTION_VIEW, Uri.parse(url));
 manager.startActivity(intent);
 }
 public String getHostName() {
 return hostname;
 }
 public void setDeviceName(String name) {
 devName = name;
 * @see {@link #isConnected()}
 */
 public boolean isSslSocket() {
 if (this.connected && this.sock != null && this.sock instanceof SSLSocket) {
 return true;
-} else {
+}
+else {
 return false;
 }
 }
 public final void setProxy(String proxyHost, String proxyPort) {
 Properties systemProperties = System.getProperties();
 systemProperties.put("socksProxySet", "true");
 systemProperties.put("socksProxyHost", proxyHost);
 systemProperties.put("socksProxyPort", proxyPort);
 System.setProperties(systemProperties);
-Log.i(TAG," socks set ");
+Log.i(TAG, " socks set ");
 }
 public final boolean connect(String hostname, int port, String encryption, String homeDirectory, vt320 buffer) {
 try {
 this.hostname = hostname;
 this.port     = port;
 this.buffer   = buffer;
 try {
 screen52.getOIA().setInputInhibited(ScreenOIA.INPUTINHIBITED_SYSTEM_WAIT,
-ScreenOIA.OIA_LEVEL_INPUT_INHIBITED,"X - Connecting");
+ScreenOIA.OIA_LEVEL_INPUT_INHIBITED, "X - Connecting");
-} catch (Exception exc) {
+}
-Log.w(TAG,"setStatus(ON) " + exc.getMessage());
+catch (Exception exc) {
+Log.w(TAG, "setStatus(ON) " + exc.getMessage());
 }
 SocketConnector sc = new SocketConnector();
 sock = sc.createSocket(hostname, port, encryption, homeDirectory, bridge, manager);
 if (sock == null) {
-Log.w(TAG,"I did not get a socket");
+Log.w(TAG, "I did not get a socket");
 disconnect();
 return false;
 }
 connected = true;
 sock.setKeepAlive(true);
 sock.setTcpNoDelay(true);
 sock.setSoLinger(false, 0);
 InputStream in = sock.getInputStream();
 OutputStream out = sock.getOutputStream();
 bin = new BufferedInputStream(in, 8192);
 bout = new BufferedOutputStream(out);
 byte abyte0[];
 while (negotiate(abyte0 = readNegotiations()));
 negotiated = true;
 try {
 screen52.setCursorActive(false);
-} catch (Exception excc) {
+}
-Log.w(TAG,"setCursorOff " + excc.getMessage());
+catch (Exception excc) {
+Log.w(TAG, "setCursorOff " + excc.getMessage());
 }
 producer = new DataStreamProducer(this, bin, dsq, abyte0);
 pthread = new Thread(producer);
 //         pthread.setPriority(pthread.MIN_PRIORITY);
 //          pthread.setPriority(Thread.NORM_PRIORITY / 2);
 pthread.start();
 try {
 screen52.getOIA().setInputInhibited(ScreenOIA.INPUTINHIBITED_NOTINHIBITED,
 ScreenOIA.OIA_LEVEL_INPUT_INHIBITED);
-} catch (Exception exc) {
+}
-Log.w(TAG,"setStatus(OFF) " + exc.getMessage());
+catch (Exception exc) {
+Log.w(TAG, "setStatus(OFF) " + exc.getMessage());
 }
 keepTrucking = true;
 me = new Thread(this);
 me.start();
+}
-} catch (Exception exception) {
+catch (Exception exception) {
 if (exception.getMessage() == null)
 exception.printStackTrace();
-Log.w(TAG,"connect() " + exception.getMessage());
+Log.w(TAG, "connect() " + exception.getMessage());
 if (sock == null)
-Log.w(TAG,"I did not get a socket");
+Log.w(TAG, "I did not get a socket");
 disconnect();
 return false;
 }
 return true;
 }
 public final boolean disconnect() {
 if (!connected) {
 screen52.getOIA().setInputInhibited(ScreenOIA.INPUTINHIBITED_SYSTEM_WAIT,
-ScreenOIA.OIA_LEVEL_INPUT_INHIBITED,"X - Disconnected");
+ScreenOIA.OIA_LEVEL_INPUT_INHIBITED, "X - Disconnected");
 return false;
 }
 if (me != null && me.isAlive()) {
 me.interrupt();
 keepTrucking = false;
 pthread.interrupt();
 }
 screen52.getOIA().setInputInhibited(ScreenOIA.INPUTINHIBITED_SYSTEM_WAIT,
-ScreenOIA.OIA_LEVEL_INPUT_INHIBITED,"X - Disconnected");
+ScreenOIA.OIA_LEVEL_INPUT_INHIBITED, "X - Disconnected");
 screen52.getOIA().setKeyBoardLocked(false);
 pendingUnlock = false;
 try {
 if (sock != null) {
-Log.i(TAG,"Closing socket");
+Log.i(TAG, "Closing socket");
 sock.close();
 }
 if (bin != null) bin.close();
 if (bout != null) bout.close();
 connected   = false;
 firstScreen = false;
 // WVL - LDC : TR.000345 : properly disconnect and clear screen
 // Is this the right place to set screen realestate on disconnect?
 //controller.getScreen().clearAll();
 screen52.goto_XY(0);
 screen52.setCursorActive(false);
 screen52.clearAll();
 screen52.restoreScreen();
-} catch (Exception exception) {
+}
-Log.w(TAG,exception.getMessage());
+catch (Exception exception) {
+Log.w(TAG, exception.getMessage());
 connected = false;
 devSeq = -1;
 return false;
+}
-}
 devSeq = -1;
 return true;
 }
 private final ByteArrayOutputStream appendByteStream(byte abyte0[]) {
 ByteArrayOutputStream bytearrayoutputstream = new ByteArrayOutputStream();
 for (int i = 0; i < abyte0.length; i++) {
 bytearrayoutputstream.write(abyte0[i]);
 if (abyte0[i] == -1)
 bytearrayoutputstream.write(-1);
 }
 return bytearrayoutputstream;
 }
 private final byte[] readNegotiations() throws IOException {
 int i = bin.read();
 if (i < 0) {
 throw new IOException("Connection closed.");
-} else {
+}
+else {
 int j = bin.available();
 byte abyte0[] = new byte[j + 1];
 abyte0[0] = (byte) i;
 bin.read(abyte0, 1, j);
 return abyte0;
 }
 }
 private final void writeByte(byte abyte0[]) throws IOException {
 bout.write(abyte0);
 bout.flush();
 }
 //  private final void writeByte(byte byte0) throws IOException {
 //      bout.write(byte0);
 //      bout.flush();
 //  }
 public final void sendHeartBeat() throws IOException {
 byte[] b = { (byte) 0xff, (byte) 0xf1 };
 bout.write(b);
 bout.flush();
 }
 private final void readImmediate(int readType) {
 if (screen52.isStatusErrorCode()) {
 screen52.restoreErrorLine();
 screen52.setStatus(Screen5250.STATUS_ERROR_CODE,
 Screen5250.STATUS_VALUE_OFF, null);
 }
 if (!enhanced) {
 screen52.setCursorActive(false);
 }
 //      screen52.setStatus(Screen5250.STATUS_SYSTEM,
 //              Screen5250.STATUS_VALUE_ON, null);
 screen52.getOIA().setInputInhibited(ScreenOIA.INPUTINHIBITED_SYSTEM_WAIT,
 ScreenOIA.OIA_LEVEL_INPUT_INHIBITED);
 screen52.getOIA().setKeyBoardLocked(true);
 pendingUnlock = false;
 invited = false;
 screen52.getScreenFields().readFormatTable(baosp, readType, codePage);
 try {
 writeGDS(0, 3, baosp.toByteArray());
-} catch (IOException ioe) {
+}
+catch (IOException ioe) {
-Log.w(TAG,ioe.getMessage());
+Log.w(TAG, ioe.getMessage());
 baosp.reset();
 }
 baosp.reset();
 }
 public final boolean sendAidKey(int aid) {
 if (screen52.isStatusErrorCode()) {
 screen52.restoreErrorLine();
 screen52.setStatus(Screen5250.STATUS_ERROR_CODE,
 Screen5250.STATUS_VALUE_OFF, null);
 }
 if (!enhanced) {
 screen52.setCursorActive(false);
 }
 //      screen52.setStatus(Screen5250.STATUS_SYSTEM,
 //              Screen5250.STATUS_VALUE_ON, null);
 screen52.getOIA().setInputInhibited(ScreenOIA.INPUTINHIBITED_SYSTEM_WAIT,
 ScreenOIA.OIA_LEVEL_INPUT_INHIBITED);
 screen52.getOIA().setKeyBoardLocked(true);
 pendingUnlock = false;
 invited = false;
 baosp.write(screen52.getCurrentRow());
 baosp.write(screen52.getCurrentCol());
 baosp.write(aid);
 if (dataIncluded(aid))
 screen52.getScreenFields().readFormatTable(baosp, readType,
 codePage);
 try {
 writeGDS(0, 3, baosp.toByteArray());
-} catch (IOException ioe) {
+}
+catch (IOException ioe) {
-Log.w(TAG,ioe.getMessage());
+Log.w(TAG, ioe.getMessage());
 baosp.reset();
 return false;
 }
 baosp.reset();
 return true;
 }
 private boolean dataIncluded(int aid) {
 switch (aid) {
+case PF1:
-case PF1:
+return !dataIncluded[0];
-return !dataIncluded[0];
 case PF2:
 return !dataIncluded[1];
-case PF3:
-return !dataIncluded[2];
+case PF3:
-case PF4:
+return !dataIncluded[2];
-return !dataIncluded[3];
-case PF5:
+case PF4:
-return !dataIncluded[4];
+return !dataIncluded[3];
-case PF6:
-return !dataIncluded[5];
+case PF5:
-case PF7:
+return !dataIncluded[4];
-return !dataIncluded[6];
-case PF8:
+case PF6:
-return !dataIncluded[7];
+return !dataIncluded[5];
-case PF9:
-return !dataIncluded[8];
+case PF7:
-case PF10:
+return !dataIncluded[6];
-return !dataIncluded[9];
-case PF11:
+case PF8:
-return !dataIncluded[10];
+return !dataIncluded[7];
-case PF12:
-return !dataIncluded[11];
+case PF9:
-case PF13:
+return !dataIncluded[8];
-return !dataIncluded[12];
-case PF14:
+case PF10:
-return !dataIncluded[13];
+return !dataIncluded[9];
-case PF15:
-return !dataIncluded[14];
+case PF11:
-case PF16:
+return !dataIncluded[10];
-return !dataIncluded[15];
-case PF17:
+case PF12:
-return !dataIncluded[16];
+return !dataIncluded[11];
-case PF18:
-return !dataIncluded[17];
+case PF13:
-case PF19:
+return !dataIncluded[12];
-return !dataIncluded[18];
-case PF20:
+case PF14:
-return !dataIncluded[19];
+return !dataIncluded[13];
-case PF21:
-return !dataIncluded[20];
+case PF15:
-case PF22:
+return !dataIncluded[14];
-return !dataIncluded[21];
-case PF23:
+case PF16:
-return !dataIncluded[22];
+return !dataIncluded[15];
-case PF24:
-return !dataIncluded[23];
+case PF17:
+return !dataIncluded[16];
-default:
-return true;
+case PF18:
+return !dataIncluded[17];
-}
+case PF19:
+return !dataIncluded[18];
+case PF20:
+return !dataIncluded[19];
+case PF21:
+return !dataIncluded[20];
+case PF22:
+return !dataIncluded[21];
+case PF23:
+return !dataIncluded[22];
+case PF24:
+return !dataIncluded[23];
+default:
+return true;
+}
 }
 /**
 * Help request -
 *
 *
 * See notes inside method
 */
 public final void sendHelpRequest() {
 // Client sends header 000D12A0000004000003####F3FFEF
 //       operation code 3
 //       row - first ##
 //       column - second ##
 //       F3 - Help Aid Key
 baosp.write(screen52.getCurrentCol());
 baosp.write(AID_HELP);
 try {
 writeGDS(0, 3, baosp.toByteArray());
-} catch (IOException ioe) {
+}
+catch (IOException ioe) {
-Log.w(TAG,ioe.getMessage());
+Log.w(TAG, ioe.getMessage());
 }
 baosp.reset();
 }
 /**
 * Attention Key -
 *
 *
 * See notes inside method
 */
 public final void sendAttentionKey() {
 // Client sends header 000A12A000004400000FFEF
 //    0x40 -> 01000000
 //
 // flags
 // bit 0 - ERR
 // bit 5 - SRQ system request
 // bit 6 - TRQ Test request key
 // bit 7 - HLP
 //      System.out.println("Attention key sent");
 try {
 writeGDS(0x40, 0, null);
-} catch (IOException ioe) {
+}
+catch (IOException ioe) {
-Log.w(TAG,ioe.getMessage());
+Log.w(TAG, ioe.getMessage());
 }
 }
 /**
 * Opens a dialog and asks the user before sending a request
 * @param sr system request option (allowed to be null, but than nothing happens)
 */
 public final void systemRequest(String sr) {
 byte[] bytes = null;
-if ( (sr != null) && (sr.length() > 0)) {
+if ((sr != null) && (sr.length() > 0)) {
 // XXX: Not sure, if this is a sufficient check for 'clear dataq'
 if (sr.charAt(0) == '2') {
 dsq.clear();
 }
 for (int i = 0, l = sr.length(); i < l; i++) {
 baosp.write(codePage.uni2ebcdic(sr.charAt(i)));
 }
 bytes = baosp.toByteArray();
 }
 try {
 writeGDS(4, 0, bytes);
-} catch (IOException ioe) {
+}
-Log.i(TAG,ioe.getMessage());
+catch (IOException ioe) {
-}
+Log.i(TAG, ioe.getMessage());
+}
 baosp.reset();
 }
 /**
 * Cancel Invite - taken from the rfc1205 - 5250 Telnet interface section
 * 4.3
 *
 * See notes inside method
 */
 public final void cancelInvite() {
 //      screen52.setStatus(Screen5250.STATUS_SYSTEM,
 //              Screen5250.STATUS_VALUE_ON, null);
 screen52.getOIA().setInputInhibited(ScreenOIA.INPUTINHIBITED_SYSTEM_WAIT,
 ScreenOIA.OIA_LEVEL_INPUT_INHIBITED);
 // from rfc1205 section 4.3
 // Server: Sends header with the 000A12A0 00000400 000AFFEF
 // Opcode = Cancel Invite.
 // Opcode = Cancel Invite to
 // indicate that the work station is
 // no longer invited.
 try {
 writeGDS(0, 10, null);
-} catch (IOException ioe) {
+}
+catch (IOException ioe) {
-Log.w(TAG,ioe.getMessage());
+Log.w(TAG, ioe.getMessage());
 }
 }
 public final void hostPrint(int aid) {
 if (screen52.isStatusErrorCode()) {
 screen52.restoreErrorLine();
 screen52.setStatus(Screen5250.STATUS_ERROR_CODE,
 Screen5250.STATUS_VALUE_OFF, null);
 }
 screen52.setCursorActive(false);
 //      screen52.setStatus(Screen5250.STATUS_SYSTEM,
 //              Screen5250.STATUS_VALUE_ON, null);
 screen52.getOIA().setInputInhibited(ScreenOIA.INPUTINHIBITED_SYSTEM_WAIT,
 ScreenOIA.OIA_LEVEL_INPUT_INHIBITED);
 // From client access ip capture
 // it seems to use an operation code of 3 and 4
 // also note that the flag field that says reserved is being sent as
 // well
 // with a value of 0x80
 // Client sends header 000D12A0000004000003####F6FFEF
 //       operation code 3
 //       row - first ##
 //       column - second ##
 //       F6 - Print Aid Key
 baosp.write(screen52.getCurrentRow());
 baosp.write(screen52.getCurrentCol());
 baosp.write(AID_PRINT); // aid key
 try {
 writeGDS(0, 3, baosp.toByteArray());
-} catch (IOException ioe) {
+}
+catch (IOException ioe) {
-Log.w(TAG,ioe.getMessage());
+Log.w(TAG, ioe.getMessage());
 }
 baosp.reset();
 }
 public final void toggleDebug() {
 producer.toggleDebug(codePage);
 }
 // write gerneral data stream
 private final void writeGDS(int flags, int opcode, byte abyte0[])
 throws IOException {
 // Added to fix for JDK 1.4 this was null coming from another method.
 //  There was a weird keyRelease event coming from another panel when
 //  using a key instead of the mouse to select button.
 //  The other method was fixed as well but this check should be here
 // anyway.
 if (bout == null)
 return;
 int length;
 if (abyte0 != null)
 length = abyte0.length + 10;
 else
 length = 10;
 // refer to rfc1205 - 5250 Telnet interface
 // Section 3. Data Stream Format
 // Logical Record Length - 16 bits
 baosrsp.write(length >> 8); // Length LL
 baosrsp.write(length & 0xff); //        LL
 // Record Type - 16 bits
 // It should always be set to '12A0'X to indicate the
 // General Data Stream (GDS) record type.
 baosrsp.write(18); // 0x12
 baosrsp.write(160); // 0xA0
 // the next 16 bits are not used
 baosrsp.write(0); // 0x00
 baosrsp.write(0); // 0x00
 //  The second part is meant to be variable in length
 //  currently this portion is 4 octets long (1 byte or 8 bits for us ;-O)
 baosrsp.write(4); // 0x04
 baosrsp.write(flags); // flags
 // bit 0 - ERR
 // bit 1 - ATN Attention
 // bits 2-4 - reserved
 // bit 5 - SRQ system request
 if (abyte0 != null)
 baosrsp.write(abyte0, 0, abyte0.length);
 baosrsp = appendByteStream(baosrsp.toByteArray());
 // make sure we indicate no more to be sent
 baosrsp.write(IAC);
 baosrsp.write(EOR);
 baosrsp.writeTo(bout);
 //        byte[] b = new byte[baosrsp.size()];
 //        b = baosrsp.toByteArray();
 //      dump(b);
 bout.flush();
 //      baos = null;
 baosrsp.reset();
 }
 protected final int getOpCode() {
 return bk.getOpCode();
 }
 //  private final void sendNotify() throws IOException {
 //
 //      writeGDS(0, 0, null);
 //  }
 protected boolean[] getActiveAidKeys() {
 boolean aids[] = new boolean[dataIncluded.length];
-System.arraycopy(dataIncluded,0,aids,0,dataIncluded.length);
+System.arraycopy(dataIncluded, 0, aids, 0, dataIncluded.length);
 return aids;
 }
 private final void setInvited() {
+Log.d(TAG, "invited");
-Log.d(TAG,"invited");
 if (!screen52.isStatusErrorCode())
 screen52.getOIA().setInputInhibited(ScreenOIA.INPUTINHIBITED_NOTINHIBITED,
 ScreenOIA.OIA_LEVEL_INPUT_INHIBITED);
 invited = true;
 }
 // WVL - LDC : 05/08/2005 : TFX.006253 - Support STRPCCMD
-private void strpccmd()
+private void strpccmd() {
-{
+try {
-try
-{
 int str = 11;
 char c;
 ScreenPlanes planes = screen52.getPlanes();
 c = planes.getChar(str);
 boolean waitFor = !(c == 'a');
 StringBuffer command = new StringBuffer();
-for (int i = str+1; i < 132; i++)
-{
+for (int i = str + 1; i < 132; i++) {
 c = planes.getChar(i);
 if (Character.isISOControl(c))
 c = ' ';
 command.append(c);
 }
 String cmd = command.toString().trim();
 run(cmd, waitFor);
 }
-finally
+finally {
-{
 strpccmd = false;
 screen52.sendKeys(TN5250jConstants.MNEMONIC_ENTER);
 }
 }
 // WVL - LDC : 05/08/2005 : TFX.006253 - Support STRPCCMD
-private void run(String cmd, boolean waitFor)
+private void run(String cmd, boolean waitFor) {
-{
+try {
-try
+Log.d(TAG, "RUN cmd = " + cmd);
-{
+Log.d(TAG, "RUN wait = " + waitFor);
-Log.d(TAG,"RUN cmd = " + cmd);
-Log.d(TAG,"RUN wait = " + waitFor);
 Runtime r = Runtime.getRuntime();
 Process p = r.exec(cmd);
-if (waitFor)
-{
+if (waitFor) {
 int result = p.waitFor();
-Log.d(TAG,"RUN result = " + result);
+Log.d(TAG, "RUN result = " + result);
 }
 }
-catch (Throwable t)
+catch (Throwable t) {
-{
+Log.e(TAG, "exception", t);
-Log.e(TAG,"exception",t);
 }
 }
 // WVL - LDC : TR.000300 : Callback scenario from 5250
 * blank character, the {@link parseCommand(ScreenChar[])}is called.
 */
 private void scan() {
 //     System.out.println("Checking command : " +
 // screen52.screen[1].getChar() + screen52.screen[2].getChar());
 //      ScreenChar[] screen = screen52.screen;
 ScreenPlanes planes = screen52.getPlanes();
 if ((planes.getChar(STRSCAN) == '#')
 && (planes.getChar(STRSCAN + 1) == '!')
 && (planes.getChar(STRSCAN + 2) != ' ')) {
 try {
 parseCommand();
-} catch (Throwable t) {
+}
-Log.i(TAG,"Exec cmd: " + t.getMessage());
+catch (Throwable t) {
+Log.i(TAG, "Exec cmd: " + t.getMessage());
 t.printStackTrace();
 }
 }
 }
 private void parseCommand() {
 // Search for the command i.e. the first token in the stream
 // after the #! sequence separated by a space from the rest
 // of the screen.
 char[] screen = screen52.getScreenAsChars();
 for (int s = STRSCAN + 2, i = s; i < screen.length; i++) {
 if (screen[i] == ' ') {
 String command = new String(screen, s, i - s);
 // Skip all white spaces between the command and the rest of
 // the screen.
 //for (; (i < screen.length) && (screen[i] == ' '); i++);
 String remainder = new String(screen, i + 1, screen.length
 - (i + 1));
 //controller.fireScanned(command, remainder);
-Log.i(TAG,"trying to run " + command + " " + remainder);
+Log.i(TAG, "trying to run " + command + " " + remainder);
 break;
 }
 }
 }
 public void run() {
 if (enhanced) sfParser = new WTDSFParser(this);
 bk = new Stream5250();
 while (keepTrucking) {
 try {
 Object e = dsq.poll(0L, TimeUnit.SECONDS);
 if (e == null) {
 buffer.testChanged();
 e = dsq.take();
 };
 bk.initialize((byte[])e);
-} catch (InterruptedException ie) {
+}
-Log.w(TAG,"   vt thread interrupted and stopping ");
+catch (InterruptedException ie) {
+Log.w(TAG, "   vt thread interrupted and stopping ");
 keepTrucking = false;
 continue;
 }
 // lets play nicely with the others on the playground
 //         me.yield();
 Thread.yield();
 invited = false;
 screen52.setCursorActive(false);
 //      System.out.println("operation code: " + bk.getOpCode());
 if (bk == null)
 continue;
 switch (bk.getOpCode()) {
 case 00:
-Log.d(TAG,"No operation");
+Log.d(TAG, "No operation");
 break;
-case 1:
-Log.d(TAG,"Invite Operation");
+case 1:
-parseIncoming();
+Log.d(TAG, "Invite Operation");
-//               screen52.setKeyboardLocked(false);
+parseIncoming();
-pendingUnlock = true;
+//               screen52.setKeyboardLocked(false);
-cursorOn = true;
+pendingUnlock = true;
-setInvited();
+cursorOn = true;
-break;
+setInvited();
-case 2:
+break;
-Log.d(TAG,"Output Only");
-parseIncoming();
+case 2:
-screen52.updateDirty();
+Log.d(TAG, "Output Only");
-break;
+parseIncoming();
-case 3:
+screen52.updateDirty();
-Log.d(TAG,"Put/Get Operation");
+break;
-parseIncoming();
-setInvited();
+case 3:
-if (!firstScreen) {
+Log.d(TAG, "Put/Get Operation");
-firstScreen = true;
+parseIncoming();
-//controller.fireSessionChanged(TN5250jConstants.STATE_CONNECTED);
+setInvited();
-}
-break;
+if (!firstScreen) {
-case 4:
+firstScreen = true;
-Log.d(TAG,"Save Screen Operation");
+//controller.fireSessionChanged(TN5250jConstants.STATE_CONNECTED);
-parseIncoming();
+}
-break;
+break;
-case 5:
-Log.d(TAG,"Restore Screen Operation");
+case 4:
-parseIncoming();
+Log.d(TAG, "Save Screen Operation");
-break;
+parseIncoming();
-case 6:
+break;
-Log.d(TAG,"Read Immediate");
-sendAidKey(0);
+case 5:
-break;
+Log.d(TAG, "Restore Screen Operation");
-case 7:
+parseIncoming();
-Log.d(TAG,"Reserved");
+break;
-break;
-case 8:
+case 6:
-Log.d(TAG,"Read Screen Operation");
+Log.d(TAG, "Read Immediate");
-try {
+sendAidKey(0);
-readScreen();
+break;
-} catch (IOException ex) {
-Log.w(TAG,ex.getMessage());
+case 7:
-}
+Log.d(TAG, "Reserved");
 break;
-case 9:
+case 8:
-Log.d(TAG,"Reserved");
+Log.d(TAG, "Read Screen Operation");
-break;
+try {
-case 10:
+readScreen();
-Log.d(TAG,"Cancel Invite Operation");
+}
-cancelInvite();
+catch (IOException ex) {
-break;
+Log.w(TAG, ex.getMessage());
+}
-case 11:
-Log.d(TAG,"Turn on message light");
+break;
-screen52.getOIA().setMessageLightOn();
-screen52.setCursorActive(true);
+case 9:
+Log.d(TAG, "Reserved");
 break;
-case 12:
-Log.d(TAG,"Turn off Message light");
+case 10:
-screen52.getOIA().setMessageLightOff();
+Log.d(TAG, "Cancel Invite Operation");
-screen52.setCursorActive(true);
+cancelInvite();
+break;
-break;
-default:
+case 11:
-break;
+Log.d(TAG, "Turn on message light");
+screen52.getOIA().setMessageLightOn();
+screen52.setCursorActive(true);
+break;
+case 12:
+Log.d(TAG, "Turn off Message light");
+screen52.getOIA().setMessageLightOff();
+screen52.setCursorActive(true);
+break;
+default:
+break;
 }
 if (screen52.isUsingGuiInterface())
 screen52.drawFields();
 try {
 if (!strpccmd) {
 screen52.updateDirty();
-} else {
+}
+else {
 strpccmd();
 }
-} catch (Exception exd) {
+}
-Log.w(TAG," tnvt.run: " + exd.getMessage());
+catch (Exception exd) {
+Log.w(TAG, " tnvt.run: " + exd.getMessage());
 exd.printStackTrace();
 }
 if (pendingUnlock && !screen52.isStatusErrorCode()) {
 screen52.getOIA().setKeyBoardLocked(false);
 }
 // lets play nicely with the others on the playground
 //me.yield();
 Thread.yield();
 }
 }
 public void dumpStuff() {
-Log.d(TAG," Pending unlock " + pendingUnlock);
+Log.d(TAG, " Pending unlock " + pendingUnlock);
-Log.d(TAG," Status Error " + screen52.isStatusErrorCode());
+Log.d(TAG, " Status Error " + screen52.isStatusErrorCode());
-Log.d(TAG," Keyboard Locked " + screen52.getOIA().isKeyBoardLocked());
+Log.d(TAG, " Keyboard Locked " + screen52.getOIA().isKeyBoardLocked());
-Log.d(TAG," Cursor On " + cursorOn);
+Log.d(TAG, " Cursor On " + cursorOn);
-Log.d(TAG," Cursor Active " + screen52.cursorActive);
+Log.d(TAG, " Cursor Active " + screen52.cursorActive);
 }
 private final void readScreen() throws IOException {
 int rows = screen52.getRows();
 private final void fillScreenArray(byte[] sa, int rows, int cols) {
 int la = 32;
 int sac = 0;
 int len = rows * cols;
 ScreenPlanes planes = screen52.planes;
 for (int y = 0; y < len; y++) { // save the screen data
 if (planes.isAttributePlace(y)) {
 la = planes.getCharAttr(y);
 sa[sac++] = (byte) la;
-} else {
+}
+else {
 if (planes.getCharAttr(y) != la) {
 la = planes.getCharAttr(y);
 sac--;
 sa[sac++] = (byte) la;
 }
 //LDC: Check to see if it is an displayable character. If not,
 //  do not convert the character.
 //  The characters on screen are in unicode
 //sa[sac++] =
 // (byte)codePage.uni2ebcdic(screen52.screen[y].getChar());
 char ch = planes.getChar(y);
 byte byteCh = (byte) ch;
 if (isDataUnicode(ch))
 byteCh = codePage.uni2ebcdic(ch);
 sa[sac++] = byteCh;
 }
 }
 }
 private final void fillRegenerationBuffer(ByteArrayOutputStream sc, int rows, int cols)
 throws IOException {
 int la = 32;
 int sac = 0;
 int len = rows * cols;
 ScreenPlanes planes = screen52.planes;
 byte[] sa = new byte[len];
 try {
 boolean guiExists = sfParser != null && sfParser.isGuisExists();
 for (int y = 0; y < len; y++) { // save the screen data
 if (guiExists) {
 byte[] guiSeg = sfParser.getSegmentAtPos(y);
 if (guiSeg != null) {
 //Log.i(TAG," gui saved at " + y + " - " + screen52.getRow(y) + "," +
 //    screen52.getCol(y));
 byte[] gsa = new byte[sa.length + guiSeg.length + 2];
-System.arraycopy(sa,0,gsa,0,sa.length);
+System.arraycopy(sa, 0, gsa, 0, sa.length);
-System.arraycopy(guiSeg,0,gsa,sac+2,guiSeg.length);
+System.arraycopy(guiSeg, 0, gsa, sac + 2, guiSeg.length);
 sa = new byte[gsa.length];
-System.arraycopy(gsa,0,sa,0,gsa.length);
+System.arraycopy(gsa, 0, sa, 0, gsa.length);
 sa[sac++] = (byte)0x04;
 sa[sac++] = (byte)0x11;
 sac += guiSeg.length;
 //y--;
 //               continue;
 }
 }
 if (planes.isAttributePlace(y)) {
 la = planes.getCharAttr(y);
 sa[sac++] = (byte) la;
-} else {
+}
+else {
 if (planes.getCharAttr(y) != la) {
 la = planes.getCharAttr(y);
 sac--;
 sa[sac++] = (byte) la;
 }
 //LDC: Check to see if it is an displayable character. If not,
 //  do not convert the character.
 //  The characters on screen are in unicode
 //sa[sac++] =
 // (byte)codePage.uni2ebcdic(screen52.screen[y].getChar());
 char ch = planes.getChar(y);
 byte byteCh = (byte) ch;
 if (isDataUnicode(ch))
 byteCh = codePage.uni2ebcdic(ch);
 sa[sac++] = byteCh;
 }
 }
 }
-catch(Exception exc) {
+catch (Exception exc) {
+Log.i(TAG, exc.getMessage());
-Log.i(TAG,exc.getMessage());
 exc.printStackTrace();
 }
 sc.write(sa);
 }
 public final void saveScreen() throws IOException {
 ByteArrayOutputStream sc = new ByteArrayOutputStream();
 sc.write(4);
 sc.write(0x12); // 18
 sc.write(0); // 18
 sc.write(0); // 18
 sc.write((byte) screen52.getRows()); // store the current size
 sc.write((byte) screen52.getColumns()); //    ""
 int cp = screen52.getCurrentPos(); // save off current position
 // fix below submitted by Mitch Blevins
 //int cp = screen52.getScreenFields().getCurrentFieldPos();
 // save off current position
-sc.write((byte) (cp >> 8 & 0xff)); //    ""
+sc.write((byte)(cp >> 8 & 0xff));  //    ""
-sc.write((byte) (cp & 0xff)); //    ""
+sc.write((byte)(cp & 0xff));  //    ""
+sc.write((byte)(screen52.homePos >> 8 & 0xff));  // save home pos
-sc.write((byte) (screen52.homePos >> 8 & 0xff)); // save home pos
+sc.write((byte)(screen52.homePos & 0xff));  //    ""
-sc.write((byte) (screen52.homePos & 0xff)); //    ""
 int rows = screen52.getRows(); // store the current size
 int cols = screen52.getColumns(); //    ""
 //      byte[] sa = new byte[rows * cols];
-fillRegenerationBuffer(sc,rows,cols);
+fillRegenerationBuffer(sc, rows, cols);
 //      fillScreenArray(sa, rows, cols);
 //
 //      sc.write(sa);
 //      sa = null;
 int sizeFields = screen52.getScreenFields().getSize();
-sc.write((byte) (sizeFields >> 8 & 0xff)); //    ""
+sc.write((byte)(sizeFields >> 8 & 0xff));  //    ""
-sc.write((byte) (sizeFields & 0xff)); //    ""
+sc.write((byte)(sizeFields & 0xff));  //    ""
 if (sizeFields > 0) {
 int x = 0;
 int s = screen52.getScreenFields().getSize();
 ScreenField sf = null;
 while (x < s) {
 sf = screen52.getScreenFields().getField(x);
 sc.write((byte) sf.getAttr()); // attribute
 int sp = sf.startPos();
-sc.write((byte) (sp >> 8 & 0xff)); //    ""
+sc.write((byte)(sp >> 8 & 0xff));  //    ""
-sc.write((byte) (sp & 0xff)); //    ""
+sc.write((byte)(sp & 0xff));  //    ""
 if (sf.mdt)
 sc.write((byte) 1);
 else
 sc.write((byte) 0);
-sc.write((byte) (sf.getLength() >> 8 & 0xff)); //    ""
-sc.write((byte) (sf.getLength() & 0xff)); //    ""
+sc.write((byte)(sf.getLength() >> 8 & 0xff));  //    ""
+sc.write((byte)(sf.getLength() & 0xff));  //    ""
 sc.write((byte) sf.getFFW1() & 0xff);
 sc.write((byte) sf.getFFW2() & 0xff);
 sc.write((byte) sf.getFCW1() & 0xff);
 sc.write((byte) sf.getFCW2() & 0xff);
-Log.d(TAG,"Saved ");
+Log.d(TAG, "Saved ");
-Log.d(TAG,sf.toString());
+Log.d(TAG, sf.toString());
 x++;
 }
 sf = null;
 }
 // The following two lines of code looks to have caused all sorts of
 //    problems so for now we have commented them out.
 // for GC ?
 //      screen52.clearTable();
 try {
 writeGDS(0, 3, sc.toByteArray());
-} catch (IOException ioe) {
+}
+catch (IOException ioe) {
-Log.w(TAG,ioe.getMessage());
+Log.w(TAG, ioe.getMessage());
 }
 sc = null;
-Log.d(TAG,"Save Screen end ");
+Log.d(TAG, "Save Screen end ");
 }
 /**
 *
 * @throws IOException
 */
 public final void restoreScreen() throws IOException {
 int which = 0;
 ScreenPlanes planes = screen52.planes;
 try {
-Log.d(TAG,"Restore ");
+Log.d(TAG, "Restore ");
 bk.getNextByte();
 bk.getNextByte();
 int rows = bk.getNextByte() & 0xff;
 int cols = bk.getNextByte() & 0xff;
 int pos = bk.getNextByte() << 8 & 0xff00; // current position
 pos |= bk.getNextByte() & 0xff;
 int hPos = bk.getNextByte() << 8 & 0xff00; // home position
 hPos |= bk.getNextByte() & 0xff;
 if ((rows != screen52.getRows()) || (cols != screen52.getColumns()))
 screen52.setRowsCols(rows, cols);
 screen52.clearAll(); // initialize what we currenty have
 if (sfParser != null && sfParser.isGuisExists())
 sfParser.clearGuiStructs();
 int b = 32;
 int la = 32;
 int len = rows * cols;
 for (int y = 0; y < len; y++) {
 b = bk.getNextByte();
 if (b == 0x04) {
+Log.i(TAG, " gui restored at " + y + " - " + screen52.getRow(y) + "," +
-Log.i(TAG," gui restored at " + y + " - " + screen52.getRow(y) + "," +
+screen52.getCol(y));
-screen52.getCol(y));
 int command = bk.getNextByte();
 byte[] seg = bk.getSegment();
 if (seg.length > 0) {
 screen52.goto_XY(y);
 sfParser.parseWriteToDisplayStructuredField(seg);
 }
 y--;
 //                    screen52.goto_XY(y);
 }
 else {
 //              b = bk.getNextByte();
 if (planes.isUseGui(y))
 continue;
 if (isAttribute(b)) {
 planes.setScreenCharAndAttr(y, planes.getChar(y), b, true);
 la = b;
 }
 else {
 //LDC - 12/02/2003 - Check to see if it is an displayable
 // character. If not,
 //  do not convert the character.
 //  The characters on screen are in unicode
 char ch = (char) b;
 if (isDataEBCDIC(b))
 ch = codePage.ebcdic2uni(b);
 planes.setScreenCharAndAttr(y, ch, la, false);
 }
 }
 }
 int numFields = bk.getNextByte() << 8 & 0xff00;
 numFields |= bk.getNextByte() & 0xff;
-Log.d(TAG,"number of fields " + numFields);
+Log.d(TAG, "number of fields " + numFields);
 if (numFields > 0) {
 int x = 0;
 int attr = 0;
 int fPos = 0;
 int ffw1 = 0;
 int ffw2 = 0;
 int fcw1 = 0;
 int fcw2 = 0;
 boolean mdt = false;
 ScreenField sf = null;
 while (x < numFields) {
 attr = bk.getNextByte();
 fPos = bk.getNextByte() << 8 & 0xff00;
 fPos |= bk.getNextByte() & 0xff;
 if (bk.getNextByte() == 1)
 mdt = true;
 else
 mdt = false;
 fLen = bk.getNextByte() << 8 & 0xff00;
 fLen |= bk.getNextByte() & 0xff;
 ffw1 = bk.getNextByte();
 ffw2 = bk.getNextByte();
 fcw1 = bk.getNextByte();
 fcw2 = bk.getNextByte();
 sf = screen52.getScreenFields().setField(attr,
 screen52.getRow(fPos), screen52.getCol(fPos), fLen,
 ffw1, ffw2, fcw1, fcw2);
 while (fLen-- > 0) {
 // now we set the field plane attributes
-planes.setScreenFieldAttr(fPos++,ffw1);
+planes.setScreenFieldAttr(fPos++, ffw1);
 }
 if (mdt) {
 sf.setMDT();
 screen52.getScreenFields().setMasterMDT();
 }
-Log.d(TAG,"/nRestored ");
-Log.d(TAG,sf.toString());
+Log.d(TAG, "/nRestored ");
+Log.d(TAG, sf.toString());
 x++;
 }
 }
 //  Redraw the gui fields if we are in gui mode
 if (screen52.isUsingGuiInterface())
 screen52.drawFields();
 screen52.restoreScreen(); // display the screen
 //  The position was saved with currentPos which 1,1 offset of the
 //     screen position.
 //  The setPendingInsert is the where the cursor position will be
 //  displayed after the restore.
 screen52.setPendingInsert(true, screen52.getRow(pos + cols), screen52
 .getCol(pos + cols));
 //  We need to offset the pos by -1 since the position is 1,1 based
 //    and the goto_XY is 0,0 based.
 screen52.goto_XY(pos - 1);
 screen52.isInField();
 //          //  Redraw the gui fields if we are in gui mode
 //          if (screen52.isUsingGuiInterface())
 //              screen52.drawFields();
-} catch (Exception e) {
+}
-Log.w(TAG,"error restoring screen " + which + " with "
+catch (Exception e) {
-+ e.getMessage());
+Log.w(TAG, "error restoring screen " + which + " with "
++ e.getMessage());
 }
 }
 public final boolean waitingForInput() {
 return waitingForInput;
 }
 private void parseIncoming() {
 boolean done = false;
 boolean error = false;
 try {
 while (bk.hasNext() && !done) {
 byte b = bk.getNextByte();
 switch (b) {
 case 0:
 case 1:
 break;
-case CMD_SAVE_SCREEN: // 0x02 2 Save Screen
-case 3: // 0x03 3 Save Partial Screen
+case CMD_SAVE_SCREEN: // 0x02 2 Save Screen
-Log.d(TAG,"save screen partial");
+case 3: // 0x03 3 Save Partial Screen
-saveScreen();
+Log.d(TAG, "save screen partial");
-break;
+saveScreen();
+break;
-case ESC: // ESCAPE
-break;
+case ESC: // ESCAPE
-case 7: // audible bell
+break;
-manager.playBeep();
-bk.getNextByte();
+case 7: // audible bell
-bk.getNextByte();
+manager.playBeep();
-break;
+bk.getNextByte();
-case CMD_WRITE_TO_DISPLAY: // 0x11 17 write to display
+bk.getNextByte();
-error = writeToDisplay(true);
+break;
-// WVL - LDC : TR.000300 : Callback scenario from 5250
-// Only scan when WRITE_TO_DISPLAY operation (i.e. refill
+case CMD_WRITE_TO_DISPLAY: // 0x11 17 write to display
-// screen buffer)
+error = writeToDisplay(true);
-// has been issued!
-if (scan)
+// WVL - LDC : TR.000300 : Callback scenario from 5250
-scan();
+// Only scan when WRITE_TO_DISPLAY operation (i.e. refill
+// screen buffer)
-break;
+// has been issued!
-case CMD_RESTORE_SCREEN: // 0x12 18 Restore Screen
+if (scan)
-case 13: // 0x13 19 Restore Partial Screen
+scan();
-Log.d(TAG,"restore screen partial");
-restoreScreen();
+break;
-break;
+case CMD_RESTORE_SCREEN: // 0x12 18 Restore Screen
-case CMD_CLEAR_UNIT_ALTERNATE: // 0x20 32 clear unit alternate
+case 13: // 0x13 19 Restore Partial Screen
-int param = bk.getNextByte();
+Log.d(TAG, "restore screen partial");
-if (param != 0) {
+restoreScreen();
-Log.d(TAG," clear unit alternate error "
+break;
-+ Integer.toHexString(param));
-sendNegResponse(NR_REQUEST_ERROR, 03, 01, 05,
+case CMD_CLEAR_UNIT_ALTERNATE: // 0x20 32 clear unit alternate
-" clear unit alternate not supported");
+int param = bk.getNextByte();
-done = true;
-} else {
+if (param != 0) {
-if (screen52.getRows() != 27)
+Log.d(TAG, " clear unit alternate error "
-screen52.setRowsCols(27, 132);
++ Integer.toHexString(param));
+sendNegResponse(NR_REQUEST_ERROR, 03, 01, 05,
+" clear unit alternate not supported");
+done = true;
+}
+else {
+if (screen52.getRows() != 27)
+screen52.setRowsCols(27, 132);
+screen52.clearAll();
+if (sfParser != null && sfParser.isGuisExists())
+sfParser.clearGuiStructs();
+}
+break;
+case CMD_WRITE_ERROR_CODE: // 0x21 33 Write Error Code
+writeErrorCode();
+error = writeToDisplay(false);
+break;
+case CMD_WRITE_ERROR_CODE_TO_WINDOW: // 0x22 34
+// Write Error Code to window
+writeErrorCodeToWindow();
+error = writeToDisplay(false);
+break;
+case CMD_READ_SCREEN_IMMEDIATE: // 0x62 98
+case CMD_READ_SCREEN_TO_PRINT: // 0x66 102 read screen to print
+readScreen();
+break;
+case CMD_CLEAR_UNIT: // 64 0x40 clear unit
+if (screen52.getRows() != 24)
+screen52.setRowsCols(24, 80);
 screen52.clearAll();
 if (sfParser != null && sfParser.isGuisExists())
 sfParser.clearGuiStructs();
+break;
-}
-break;
+case CMD_CLEAR_FORMAT_TABLE: // 80 0x50 Clear format table
+screen52.clearTable();
-case CMD_WRITE_ERROR_CODE: // 0x21 33 Write Error Code
+break;
-writeErrorCode();
-error = writeToDisplay(false);
+case CMD_READ_INPUT_FIELDS: //0x42 66 read input fields
-break;
+case CMD_READ_MDT_FIELDS: // 0x52 82 read MDT Fields
-case CMD_WRITE_ERROR_CODE_TO_WINDOW: // 0x22 34
+bk.getNextByte();
-// Write Error Code to window
+bk.getNextByte();
-writeErrorCodeToWindow();
+readType = b;
-error = writeToDisplay(false);
+screen52.goHome();
-break;
+// do nothing with the cursor here it is taken care of
+//   in the main loop.
-case CMD_READ_SCREEN_IMMEDIATE: // 0x62 98
+//////////////// screen52.setCursorOn();
-case CMD_READ_SCREEN_TO_PRINT: // 0x66 102 read screen to print
+waitingForInput = true;
-readScreen();
+pendingUnlock = true;
-break;
+//                  screen52.setKeyboardLocked(false);
+break;
-case CMD_CLEAR_UNIT: // 64 0x40 clear unit
-if (screen52.getRows() != 24)
+case CMD_READ_MDT_IMMEDIATE_ALT: // 0x53 83
-screen52.setRowsCols(24, 80);
+readType = b;
-screen52.clearAll();
+//                  screen52.goHome();
-if (sfParser != null && sfParser.isGuisExists())
+//                  waitingForInput = true;
-sfParser.clearGuiStructs();
+//                  screen52.setKeyboardLocked(false);
+readImmediate(readType);
 break;
-case CMD_CLEAR_FORMAT_TABLE: // 80 0x50 Clear format table
+case CMD_WRITE_STRUCTURED_FIELD: // 243 0xF3 -13 Write
-screen52.clearTable();
+// structured field
-break;
+writeStructuredField();
+break;
-case CMD_READ_INPUT_FIELDS: //0x42 66 read input fields
-case CMD_READ_MDT_FIELDS: // 0x52 82 read MDT Fields
+case CMD_ROLL: // 0x23 35 Roll Not sure what it does right now
-bk.getNextByte();
+int updown = bk.getNextByte();
-bk.getNextByte();
+int topline = bk.getNextByte();
-readType = b;
+int bottomline = bk.getNextByte();
-screen52.goHome();
+screen52.rollScreen(updown, topline, bottomline);
-// do nothing with the cursor here it is taken care of
+break;
-//   in the main loop.
-//////////////// screen52.setCursorOn();
+default:
-waitingForInput = true;
+done = true;
-pendingUnlock = true;
+sendNegResponse(NR_REQUEST_ERROR, 03, 01, 01,
-//                  screen52.setKeyboardLocked(false);
+"parseIncoming");
 break;
-case CMD_READ_MDT_IMMEDIATE_ALT: // 0x53 83
-readType = b;
-//                  screen52.goHome();
-//                  waitingForInput = true;
-//                  screen52.setKeyboardLocked(false);
-readImmediate(readType);
-break;
-case CMD_WRITE_STRUCTURED_FIELD: // 243 0xF3 -13 Write
-// structured field
-writeStructuredField();
-break;
-case CMD_ROLL: // 0x23 35 Roll Not sure what it does right now
-int updown = bk.getNextByte();
-int topline = bk.getNextByte();
-int bottomline = bk.getNextByte();
-screen52.rollScreen(updown, topline, bottomline);
-break;
-default:
-done = true;
-sendNegResponse(NR_REQUEST_ERROR, 03, 01, 01,
-"parseIncoming");
-break;
 }
 if (error)
 done = true;
 }
-} catch (Exception exc) {
+}
-Log.w(TAG,"incoming " + exc.getMessage());
+catch (Exception exc) {
+Log.w(TAG, "incoming " + exc.getMessage());
 }
 }
 /**
 * This routine handles sending negative responses back to the host.
 * @param uByte2
 * @param from
 *
 */
 protected void sendNegResponse(int cat, int modifier, int uByte1,
 int uByte2, String from) {
 try {
 int os = bk.getByteOffset(-1) & 0xf0;
 int cp = (bk.getCurrentPos() - 1);
-Log.i(TAG,"invalid " + from + " command " + os
+Log.i(TAG, "invalid " + from + " command " + os
 + " at pos " + cp);
-} catch (Exception e) {
+}
+catch (Exception e) {
-Log.w(TAG,"Send Negative Response error " + e.getMessage());
+Log.w(TAG, "Send Negative Response error " + e.getMessage());
 }
 baosp.write(cat);
 baosp.write(modifier);
 baosp.write(uByte1);
 baosp.write(uByte2);
 try {
 writeGDS(128, 0, baosp.toByteArray());
-} catch (IOException ioe) {
+}
+catch (IOException ioe) {
-Log.w(TAG,ioe.getMessage());
+Log.w(TAG, ioe.getMessage());
 }
 baosp.reset();
 }
 public void sendNegResponse2(int ec) {
 screen52.setPrehelpState(true, true, false);
 baosp.write(0x00);
 baosp.write(ec);
 try {
 writeGDS(1, 0, baosp.toByteArray());
-} catch (IOException ioe) {
+}
+catch (IOException ioe) {
-Log.w(TAG,ioe.getMessage());
+Log.w(TAG, ioe.getMessage());
 }
 baosp.reset();
 }
 private boolean writeToDisplay(boolean controlsExist) {
 boolean error = false;
 boolean done = false;
 int attr;
 byte control0 = 0;
 byte control1 = 0;
 if (controlsExist) {
 control0 = bk.getNextByte();
 control1 = bk.getNextByte();
 processCC0(control0);
 }
 while (bk.hasNext() && !done) {
 //            pos = bk.getCurrentPos();
 //            int rowc = screen52.getCurrentRow();
 //            int colc = screen52.getCurrentCol();
 byte bytebk = bk.getNextByte();
 switch (bytebk) {
+case 1: // SOH - Start of Header Order
-case 1: // SOH - Start of Header Order
+Log.d(TAG, "SOH - Start of Header Order");
-Log.d(TAG,"SOH - Start of Header Order");
+error = processSOH();
-error = processSOH();
+break;
-break;
+case 02: // RA - Repeat to address
-case 02: // RA - Repeat to address
+Log.d(TAG, "RA - Repeat to address");
-Log.d(TAG,"RA - Repeat to address");
+int row = screen52.getCurrentRow();
-int row = screen52.getCurrentRow();
+int col = screen52.getCurrentCol();
-int col = screen52.getCurrentCol();
+int toRow = bk.getNextByte();
+int toCol = bk.getNextByte() & 0xff;
-int toRow = bk.getNextByte();
-int toCol = bk.getNextByte() & 0xff;
+if (toRow >= row) {
-if (toRow >= row) {
+int repeat = bk.getNextByte();
-int repeat = bk.getNextByte();
+// a little intelligence here I hope
+if (row == 1 && col == 2 && toRow == screen52.getRows()
+&& toCol == screen52.getColumns())
+screen52.clearScreen();
+else {
+if (repeat != 0) {
+//LDC - 13/02/2003 - convert it to unicode
+repeat = codePage.ebcdic2uni(repeat);
+//repeat = getASCIIChar(repeat);
+}
+int times = ((toRow * screen52.getColumns()) + toCol)
+- ((row * screen52.getColumns()) + col);
+while (times-- >= 0) {
+screen52.setChar(repeat);
+}
+}
+}
+else {
+sendNegResponse(NR_REQUEST_ERROR, 0x05, 0x01, 0x23,
+" RA invalid");
+error = true;
+}
+break;
+case 03: // EA - Erase to address
+Log.d(TAG, "EA - Erase to address");
+int EArow = screen52.getCurrentRow();
+int EAcol = screen52.getCurrentCol();
+int toEARow = bk.getNextByte();
+int toEACol = bk.getNextByte() & 0xff;
+int EALength = bk.getNextByte() & 0xff;
+while (--EALength > 0) {
+bk.getNextByte();
+}
+char EAAttr = (char) 0;
 // a little intelligence here I hope
-if (row == 1 && col == 2 && toRow == screen52.getRows()
+if (EArow == 1 && EAcol == 2
-&& toCol == screen52.getColumns())
+&& toEARow == screen52.getRows()
+&& toEACol == screen52.getColumns())
 screen52.clearScreen();
 else {
-if (repeat != 0) {
+int times = ((toEARow * screen52.getColumns()) + toEACol)
-//LDC - 13/02/2003 - convert it to unicode
+- ((EArow * screen52.getColumns()) + EAcol);
-repeat = codePage.ebcdic2uni(repeat);
-//repeat = getASCIIChar(repeat);
+while (times-- >= 0) {
+screen52.setChar(EAAttr);
 }
+}
-int times = ((toRow * screen52.getColumns()) + toCol)
-- ((row * screen52.getColumns()) + col);
+break;
-while (times-- >= 0) {
-screen52.setChar(repeat);
+case 04: // Command - Escape
+Log.d(TAG, "Command - Escape");
+done = true;
+break;
+case 16: // TD - Transparent Data
+Log.d(TAG, "TD - Transparent Data");
+int j = (bk.getNextByte() & 0xff) << 8 | bk.getNextByte()
+& 0xff; // length
+break;
+case 17: // SBA - set buffer address order (row column)
+//Log.d(TAG,"SBA - set buffer address order (row column)");
+int saRow = bk.getNextByte();
+int saCol = bk.getNextByte() & 0xff;
+// make sure it is in bounds
+if (saRow >= 0 && saRow <= screen52.getRows() && saCol >= 0
+&& saCol <= screen52.getColumns()) {
+screen52.setCursor(saRow, saCol); // now set screen
+// position for output
+}
+else {
+sendNegResponse(NR_REQUEST_ERROR, 0x05, 0x01, 0x22,
+"invalid row/col order" + " saRow = " + saRow
++ " saRows = " + screen52.getRows()
++ " saCol = " + saCol);
+error = true;
+}
+break;
+case 18: // WEA - Extended Attribute
+Log.d(TAG, "WEA - Extended Attribute");
+bk.getNextByte();
+bk.getNextByte();
+break;
+case 19: // IC - Insert Cursor
+Log.d(TAG, "IC - Insert Cursor");
+int icX = bk.getNextByte();
+int icY = bk.getNextByte() & 0xff;
+if (icX >= 0 && icX <= saRows && icY >= 0 && icY <= saCols) {
+Log.d(TAG, " IC " + icX + " " + icY);
+screen52.setPendingInsert(true, icX, icY);
+}
+else {
+sendNegResponse(NR_REQUEST_ERROR, 0x05, 0x01, 0x22,
+" IC/IM position invalid ");
+error = true;
+}
+break;
+case 20: // MC - Move Cursor
+Log.d(TAG, "MC - Move Cursor");
+int imcX = bk.getNextByte();
+int imcY = bk.getNextByte() & 0xff;
+if (imcX >= 0 && imcX <= saRows && imcY >= 0
+&& imcY <= saCols) {
+Log.d(TAG, " MC " + imcX + " " + imcY);
+screen52.setPendingInsert(false, imcX, imcY);
+}
+else {
+sendNegResponse(NR_REQUEST_ERROR, 0x05, 0x01, 0x22,
+" IC/IM position invalid ");
+error = true;
+}
+break;
+case 21: // WTDSF - Write To Display Structured Field order
+Log.d(TAG, "WTDSF - Write To Display Structured Field order");
+byte[] seg = bk.getSegment();
+error = sfParser.parseWriteToDisplayStructuredField(seg);
+break;
+case 29: // SF - Start of Field
+Log.d(TAG, "SF - Start of Field");
+int fcw1 = 0;
+int fcw2 = 0;
+int ffw1 = 0;
+int ffw0 = bk.getNextByte() & 0xff; // FFW
+if ((ffw0 & 0x40) == 0x40) {
+ffw1 = bk.getNextByte() & 0xff; // FFW 1
+fcw1 = bk.getNextByte() & 0xff; // check for field
+// control word
+// check if the first fcw1 is an 0x81 if it is then get
+// the next pair for checking
+if (fcw1 == 0x81) {
+bk.getNextByte();
+fcw1 = bk.getNextByte() & 0xff; // check for field
+// control word
 }
+if (!isAttribute(fcw1)) {
+fcw2 = bk.getNextByte() & 0xff; // FCW 2
+attr = bk.getNextByte() & 0xff; // attribute field
+while (!isAttribute(attr)) {
+Log.i(TAG, Integer.toHexString(fcw1) + " "
++ Integer.toHexString(fcw2)
++ " ");
+Log.i(TAG, Integer.toHexString(attr)
++ " "
++ Integer.toHexString(bk
+.getNextByte() & 0xff));
+attr = bk.getNextByte() & 0xff; // attribute field
+}
+}
+else {
+attr = fcw1; // attribute of field
+fcw1 = 0;
+}
 }
-} else {
+else {
-sendNegResponse(NR_REQUEST_ERROR, 0x05, 0x01, 0x23,
+attr = ffw0;
-" RA invalid");
-error = true;
-}
-break;
-case 03: // EA - Erase to address
-Log.d(TAG,"EA - Erase to address");
-int EArow = screen52.getCurrentRow();
-int EAcol = screen52.getCurrentCol();
-int toEARow = bk.getNextByte();
-int toEACol = bk.getNextByte() & 0xff;
-int EALength = bk.getNextByte() & 0xff;
-while (--EALength > 0) {
-bk.getNextByte();
-}
-char EAAttr = (char) 0;
-// a little intelligence here I hope
-if (EArow == 1 && EAcol == 2
-&& toEARow == screen52.getRows()
-&& toEACol == screen52.getColumns())
-screen52.clearScreen();
-else {
-int times = ((toEARow * screen52.getColumns()) + toEACol)
-- ((EArow * screen52.getColumns()) + EAcol);
-while (times-- >= 0) {
-screen52.setChar(EAAttr);
 }
-}
-break;
+int fLength = (bk.getNextByte() & 0xff) << 8
-case 04: // Command - Escape
+| bk.getNextByte() & 0xff;
-Log.d(TAG,"Command - Escape");
+screen52.addField(attr, fLength, ffw0, ffw1, fcw1, fcw2);
-done = true;
+break;
-break;
+// WVL - LDC : 05/08/2005 : TFX.006253 - Support STRPCCMD
-case 16: // TD - Transparent Data
+case -128: //STRPCCMD
-Log.d(TAG,"TD - Transparent Data");
+//          if (screen52.getCurrentPos() == 82) {
-int j = (bk.getNextByte() & 0xff) << 8 | bk.getNextByte()
+Log.d(TAG, "STRPCCMD got a -128 command at " + screen52.getCurrentPos());
-& 0xff; // length
+StringBuffer value = new StringBuffer();
-break;
+int b;
+char c;
-case 17: // SBA - set buffer address order (row column)
+int[] pco = new int[9];
-//Log.d(TAG,"SBA - set buffer address order (row column)");
+int[] pcoOk = {0xfc, 0xd7, 0xc3, 0xd6, 0x40, 0x83, 0x80, 0xa1, 0x80};
-int saRow = bk.getNextByte();
-int saCol = bk.getNextByte() & 0xff;
+for (int i = 0; i < 9; i++) {
-// make sure it is in bounds
+b = bk.getNextByte();
-if (saRow >= 0 && saRow <= screen52.getRows() && saCol >= 0
+pco[i] = ((b & 0xff));
-&& saCol <= screen52.getColumns()) {
+c = codePage.ebcdic2uni(b);
-screen52.setCursor(saRow, saCol); // now set screen
+value.append(c);
-// position for output
-} else {
-sendNegResponse(NR_REQUEST_ERROR, 0x05, 0x01, 0x22,
-"invalid row/col order" + " saRow = " + saRow
-+ " saRows = " + screen52.getRows()
-+ " saCol = " + saCol);
-error = true;
-}
-break;
-case 18: // WEA - Extended Attribute
-Log.d(TAG,"WEA - Extended Attribute");
-bk.getNextByte();
-bk.getNextByte();
-break;
-case 19: // IC - Insert Cursor
-Log.d(TAG,"IC - Insert Cursor");
-int icX = bk.getNextByte();
-int icY = bk.getNextByte() & 0xff;
-if (icX >= 0 && icX <= saRows && icY >= 0 && icY <= saCols) {
-Log.d(TAG," IC " + icX + " " + icY);
-screen52.setPendingInsert(true, icX, icY);
-} else {
-sendNegResponse(NR_REQUEST_ERROR, 0x05, 0x01, 0x22,
-" IC/IM position invalid ");
-error = true;
-}
-break;
-case 20: // MC - Move Cursor
-Log.d(TAG,"MC - Move Cursor");
-int imcX = bk.getNextByte();
-int imcY = bk.getNextByte() & 0xff;
-if (imcX >= 0 && imcX <= saRows && imcY >= 0
-&& imcY <= saCols) {
-Log.d(TAG," MC " + imcX + " " + imcY);
-screen52.setPendingInsert(false, imcX, imcY);
-} else {
-sendNegResponse(NR_REQUEST_ERROR, 0x05, 0x01, 0x22,
-" IC/IM position invalid ");
-error = true;
-}
-break;
-case 21: // WTDSF - Write To Display Structured Field order
-Log.d(TAG,"WTDSF - Write To Display Structured Field order");
-byte[] seg = bk.getSegment();
-error = sfParser.parseWriteToDisplayStructuredField(seg);
-break;
-case 29: // SF - Start of Field
-Log.d(TAG,"SF - Start of Field");
-int fcw1 = 0;
-int fcw2 = 0;
-int ffw1 = 0;
-int ffw0 = bk.getNextByte() & 0xff; // FFW
-if ((ffw0 & 0x40) == 0x40) {
-ffw1 = bk.getNextByte() & 0xff; // FFW 1
-fcw1 = bk.getNextByte() & 0xff; // check for field
-// control word
-// check if the first fcw1 is an 0x81 if it is then get
-// the next pair for checking
-if (fcw1 == 0x81) {
-bk.getNextByte();
-fcw1 = bk.getNextByte() & 0xff; // check for field
-// control word
 }
-if (!isAttribute(fcw1)) {
+// Check "PCO-String"
+if (Arrays.equals(pco, pcoOk)) {
-fcw2 = bk.getNextByte() & 0xff; // FCW 2
+strpccmd = true;
-attr = bk.getNextByte() & 0xff; // attribute field
-while (!isAttribute(attr)) {
-Log.i(TAG,Integer.toHexString(fcw1) + " "
-+ Integer.toHexString(fcw2)
-+ " ");
-Log.i(TAG,Integer.toHexString(attr)
-+ " "
-+ Integer.toHexString(bk
-.getNextByte() & 0xff));
-attr = bk.getNextByte() & 0xff; // attribute field
-}
-} else {
-attr = fcw1; // attribute of field
-fcw1 = 0;
 }
-} else {
-attr = ffw0;
+// we return in the stream to have all chars
-}
+// arrive at the screen for later processing
+for (int i = 0; i < 9; i++)
-int fLength = (bk.getNextByte() & 0xff) << 8
+bk.setPrevByte();
-| bk.getNextByte() & 0xff;
-screen52.addField(attr, fLength, ffw0, ffw1, fcw1, fcw2);
-break;
-// WVL - LDC : 05/08/2005 : TFX.006253 - Support STRPCCMD
-case -128: //STRPCCMD
-//          if (screen52.getCurrentPos() == 82) {
-Log.d(TAG,"STRPCCMD got a -128 command at " + screen52.getCurrentPos());
-StringBuffer value = new StringBuffer();
-int b;
-char c;
-int[] pco = new int[9];
-int[] pcoOk = {0xfc, 0xd7, 0xc3, 0xd6, 0x40, 0x83, 0x80, 0xa1, 0x80};
-for (int i = 0; i < 9; i++)
-{
-b = bk.getNextByte();
-pco[i] = ((b & 0xff));
-c = codePage.ebcdic2uni(b);
-value.append(c);
-}
-// Check "PCO-String"
-if (Arrays.equals(pco, pcoOk)) {
-strpccmd = true;
-}
-// we return in the stream to have all chars
-// arrive at the screen for later processing
-for (int i = 0; i < 9; i++)
-bk.setPrevByte();
 //}
 // no break: so every chars arrives
 // on the screen for later parsing
 //break;
 default: // all others must be output to screen
 //Log.d(TAG,"all others must be output to screen");
 byte byte0 = bk.getByteOffset(-1);
-if (isAttribute(byte0)) {
-screen52.setAttr(byte0);
+if (isAttribute(byte0)) {
-} else {
+screen52.setAttr(byte0);
-if (!screen52.isStatusErrorCode()) {
-if (!isDataEBCDIC(byte0)) {
-//                           if (byte0 == 255) {
-//                              sendNegResponse(NR_REQUEST_ERROR,0x05,0x01,0x42,
-//                              " Attempt to send FF to screen");
-//                           }
-//                           else
-screen52.setChar(byte0);
-} else
-//LDC - 13/02/2003 - Convert it to unicode
-//screen52.setChar(getASCIIChar(byte0));
-screen52.setChar(codePage.ebcdic2uni(byte0));
-} else {
-if (byte0 == 0)
-screen52.setChar(byte0);
-else
-//LDC - 13/02/2003 - Convert it to unicode
-//screen52.setChar(getASCIIChar(byte0));
-screen52.setChar(codePage.ebcdic2uni(byte0));
 }
-}
+else {
+if (!screen52.isStatusErrorCode()) {
-break;
+if (!isDataEBCDIC(byte0)) {
+//                           if (byte0 == 255) {
+//                              sendNegResponse(NR_REQUEST_ERROR,0x05,0x01,0x42,
+//                              " Attempt to send FF to screen");
+//                           }
+//                           else
+screen52.setChar(byte0);
+}
+else
+//LDC - 13/02/2003 - Convert it to unicode
+//screen52.setChar(getASCIIChar(byte0));
+screen52.setChar(codePage.ebcdic2uni(byte0));
+}
+else {
+if (byte0 == 0)
+screen52.setChar(byte0);
+else
+//LDC - 13/02/2003 - Convert it to unicode
+//screen52.setChar(getASCIIChar(byte0));
+screen52.setChar(codePage.ebcdic2uni(byte0));
+}
+}
+break;
 }
 if (error)
 done = true;
 }
 }
 catch (Exception e) {
-Log.w(TAG,"write to display " + e.getMessage());
+Log.w(TAG, "write to display " + e.getMessage());
 e.printStackTrace();
 }
 ;
 processCC1(control1);
 return error;
 }
 private boolean processSOH() throws Exception {
 int l = bk.getNextByte(); // length
-Log.d(TAG," byte 0 " + l);
+Log.d(TAG, " byte 0 " + l);
 if (l > 0 && l <= 7) {
 bk.getNextByte(); // flag byte 2
 bk.getNextByte(); // reserved
 bk.getNextByte(); // resequence fields
 screen52.clearTable();
 // well that is the first time I have seen this. This fixes a
 // problem with S/36 command line. Finally got it.
 if (l <= 3) return false;
 screen52.setErrorLine(bk.getNextByte()); // error row
 int byte1 = 0;
 if (l >= 5) {
 byte1 = bk.getNextByte();
 dataIncluded[23] = (byte1 & 0x80) == 0x80;
 dataIncluded[22] = (byte1 & 0x40) == 0x40;
 dataIncluded[21] = (byte1 & 0x20) == 0x20;
 dataIncluded[3] = (byte1 & 0x8) == 0x8;
 dataIncluded[2] = (byte1 & 0x4) == 0x4;
 dataIncluded[1] = (byte1 & 0x2) == 0x2;
 dataIncluded[0] = (byte1 & 0x1) == 0x1;
 }
 return false;
-} else {
+}
+else {
 sendNegResponse(NR_REQUEST_ERROR, 0x05, 0x01, 0x2B,
 "invalid SOH length");
 return true;
 }
 }
 private void processCC0(byte byte0) {
-Log.d(TAG," Control byte0 " + Integer.toBinaryString(byte0 & 0xff));
+Log.d(TAG, " Control byte0 " + Integer.toBinaryString(byte0 & 0xff));
 boolean lockKeyboard = true;
 boolean resetMDT = false;
 boolean resetMDTAll = false;
 boolean nullMDT = false;
 boolean nullAll = false;
 // '10100000' = 0xA0 /160
 // '11000000' = 0xC0 /192
 // '11100000' = 0xE0 /224
 switch (byte0 & 0xE0) {
+case 0x40:
-case 0x40:
+resetMDT = true;
-resetMDT = true;
+break;
-break;
 case 0x60:
 resetMDTAll = true;
 break;
-case 0x80:
-nullMDT = true;
+case 0x80:
-break;
+nullMDT = true;
-case 0xA0:
+break;
-resetMDT = true;
-nullAll = true;
+case 0xA0:
-break;
+resetMDT = true;
-case 0xC0:
+nullAll = true;
-resetMDT = true;
+break;
-nullMDT = true;
-break;
+case 0xC0:
+resetMDT = true;
-case 0xE0:
+nullMDT = true;
-resetMDTAll = true;
+break;
-nullAll = true;
-break;
+case 0xE0:
+resetMDTAll = true;
+nullAll = true;
+break;
 }
 if (lockKeyboard) {
 screen52.getOIA().setKeyBoardLocked(true);
 pendingUnlock = false;
-} else
+}
+else
 pendingUnlock = false;
 if (resetMDT || resetMDTAll || nullMDT || nullAll) {
 ScreenField sf;
 int f = screen52.getScreenFields().getSize();
 for (int x = 0; x < f; x++) {
 sf = screen52.getScreenFields().getField(x);
 if (!sf.isBypassField()) {
 if ((nullMDT && sf.mdt) || nullAll) {
 sf.setFieldChar((char) 0x0);
 screen52.drawField(sf);
 }
 }
 if (resetMDTAll || (resetMDT && !sf.isBypassField()))
 sf.resetMDT();
+}
-}
 sf = null;
 }
 }
 private void processCC1(byte byte1) {
-Log.d(TAG," Control byte1 " + Integer.toBinaryString(byte1 & 0xff));
+Log.d(TAG, " Control byte1 " + Integer.toBinaryString(byte1 & 0xff));
 if ((byte1 & 0x04) == 0x04) {
 manager.playBeep();
 }
 if ((byte1 & 0x02) == 0x02) {
 screen52.getOIA().setMessageLightOff();
 }
 if ((byte1 & 0x01) == 0x01) {
 screen52.getOIA().setMessageLightOn();
 }
 if ((byte1 & 0x01) == 0x01 && (byte1 & 0x02) == 0x02) {
 // if it is on '1' then reset the cursor positioning information
 // *** Note *** unless we receive bit 4 on at the same time
 // this seems to work so far
 if ((byte1 & 0x20) == 0x20 && (byte1 & 0x08) == 0x00) {
 screen52.setPendingInsert(false);
-Log.d(TAG," WTD position no move");
+Log.d(TAG, " WTD position no move");
-} else {
+}
+else {
 screen52.setPendingInsert(true);
-Log.d(TAG," WTD position move to home" + screen52.homePos + " row "
+Log.d(TAG, " WTD position move to home" + screen52.homePos + " row "
 + screen52.getRow(screen52.homePos) + " col "
 + screen52.getCol(screen52.homePos));
+}
-}
 // in enhanced mode we sometimes only receive bit 6 turned on which
 // is reset blinking cursor
 if ((byte1 & 0x20) == 0x20 && enhanced) {
 cursorOn = true;
 }
 if (!screen52.isStatusErrorCode() && (byte1 & 0x08) == 0x08) {
 //         screen52.setStatus(screen52.STATUS_SYSTEM,screen52.STATUS_VALUE_OFF,null);
 cursorOn = true;
 }
 if ((byte1 & 0x20) == 0x20 && (byte1 & 0x08) == 0x00) {
 screen52.setPendingInsert(false, 1, 1);
 }
 }
 private boolean isAttribute(int byte0) {
 int byte1 = byte0 & 0xff;
 return (byte1 & 0xe0) == 0x20;
 }
 //LDC - 12/02/2003 - Function name changed from isData to isDataEBCDIC
 private boolean isDataEBCDIC(int byte0) {
 int byte1 = byte0 & 0xff;
 // here it should always be less than 255
 if (byte1 >= 64 && byte1 < 255)
 return true;
 else
 return false;
 }
 //LDC - 12/02/2003 - Test if the unicode character is a displayable
 // character.
 //  The first 32 characters are non displayable characters
 private boolean isDataUnicode(int byte0) {
 return (((byte0 < 0) || (byte0 >= 32)) && (byte0 != 0xFFFF));
 }
 private void writeStructuredField() {
 boolean done = false;
 try {
 int length = ((bk.getNextByte() & 0xff) << 8 | (bk.getNextByte() & 0xff));
 while (bk.hasNext() && !done) {
 switch (bk.getNextByte()) {
+case -39: // SOH - Start of Header Order
-case -39: // SOH - Start of Header Order
+switch (bk.getNextByte()) {
+case 112: // 5250 Query
-switch (bk.getNextByte()) {
+bk.getNextByte(); // get null required field
-case 112: // 5250 Query
+sendQueryResponse();
-bk.getNextByte(); // get null required field
+break;
-sendQueryResponse();
-break;
+default:
+Log.d(TAG, "invalid structured field sub command "
++ bk.getByteOffset(-1));
+break;
+}
+break;
 default:
-Log.d(TAG,"invalid structured field sub command "
+Log.d(TAG, "invalid structured field command "
 + bk.getByteOffset(-1));
 break;
-}
-break;
-default:
-Log.d(TAG,"invalid structured field command "
-+ bk.getByteOffset(-1));
-break;
 }
 }
-} catch (Exception e) {
+}
-}
+catch (Exception e) {
+}
 ;
 }
 private final void writeErrorCode() throws Exception {
 screen52.setCursor(screen52.getErrorLine(), 1); // Skip the control byte
 screen52.setStatus(Screen5250.STATUS_ERROR_CODE,
 Screen5250.STATUS_VALUE_ON, null);
 screen52.saveErrorLine();
 cursorOn = true;
 }
 private final void writeErrorCodeToWindow() throws Exception {
 int fromCol = bk.getNextByte() & 0xff; // from column
 int toCol = bk.getNextByte() & 0xff; // to column
 screen52.setCursor(screen52.getErrorLine(), fromCol); // Skip the control
 // byte
 screen52.setStatus(Screen5250.STATUS_ERROR_CODE,
 Screen5250.STATUS_VALUE_ON, null);
 screen52.saveErrorLine();
 cursorOn = true;
 }
 /**
 * Method sendQueryResponse
 *
 * 5.3
 *
 * @throws IOException
 */
 private final void sendQueryResponse() throws IOException {
+Log.i(TAG, "sending query response");
-Log.i(TAG,"sending query response");
 byte abyte0[] = new byte[64];
 abyte0[0] = 0; // Cursor Row/column (set to zero)
 abyte0[1] = 0; //           ""
 abyte0[2] = -120; // X'88' inbound write structure Field aid
 if (enhanced == true) {
 abyte0[3] = 0; // 0x003D (61) length of query response
 abyte0[4] = 64; //       "" see note below ?????????
-} else {
+}
+else {
 abyte0[3] = 0; // 0x003A (58) length of query response
 abyte0[4] = 58; //       ""
 //  the length between 58 and 64 seems to cause
 //  different formatting codes to be sent from
 //  the host ???????????????? why ???????
 //    Well the why can be found in the manual if
 //       read a little more ;-)
 }
 abyte0[5] = -39; // command class 0xD9
 abyte0[6] = 112; // Command type query 0x70
 abyte0[7] = -128; // 0x80 Flag byte
 abyte0[8] = 6; // Controller Hardware Class
 abyte0[9] = 0; // 0x0600 - Other WSF or another 5250 Emulator
 abyte0[10] = 1; // Controller Code Level
 abyte0[11] = 1; //    Version 1 Rel 1.0
 abyte0[12] = 0; //       ""
 abyte0[13] = 0; // 13 - 28 are reserved so set to 0x00
 abyte0[14] = 0; //       ""
 abyte0[15] = 0; //       ""
 abyte0[16] = 0; //       ""
 abyte0[17] = 0; //       ""
 abyte0[32] = codePage.uni2ebcdic('5'); //          ""
 abyte0[33] = codePage.uni2ebcdic('1'); //          ""
 abyte0[34] = codePage.uni2ebcdic('0'); //          ""
 abyte0[35] = codePage.uni2ebcdic('1'); //          ""
 abyte0[36] = codePage.uni2ebcdic('1'); //          ""
 abyte0[37] = 2; // Keyboard Id - 0x02 Standard Keyboard
 abyte0[38] = 0; // extended keyboard id
 abyte0[39] = 0; // reserved
 abyte0[40] = 0; // 40 - 43 Display Serial Number
 abyte0[41] = 36; //
 abyte0[42] = 36; //
 abyte0[43] = 0; //
 abyte0[44] = 1; // Maximum number of display fields - 256
 abyte0[45] = 0; // 0x0100
 abyte0[46] = 0; // 46 -48 Reserved set to 0x00
 abyte0[47] = 0;
 abyte0[48] = 0;
 if (enhanced == true) {
 //         abyte0[53] = 0x5E; // 0x5E turns on ehnhanced mode
 //         abyte0[53] = 0x27; // 0x5E turns on ehnhanced mode
 abyte0[53] = 0x7; //  0x5E turns on ehnhanced mode
-Log.i(TAG,"enhanced options");
+Log.i(TAG, "enhanced options");
-} else
+}
+else
 abyte0[53] = 0x0; //  0x0 is normal emulation
 abyte0[54] = 24; // 54 - 60 Reserved set to 0x00
 //  54 - I found out is used for enhanced user
 //       interface level 3. Bit 4 allows headers
 abyte0[61] = 0; // gridlines are not supported
 abyte0[62] = 0; // gridlines are not supported
 abyte0[63] = 0;
 writeGDS(0, 0, abyte0); // now tell them about us
 abyte0 = null;
 }
 protected final boolean negotiate(byte abyte0[]) throws IOException {
 int i = 0;
 // from server negotiations
-if(abyte0[i] == IAC) { // -1
+if (abyte0[i] == IAC) { // -1
+while (i < abyte0.length && abyte0[i++] == -1)
-while(i < abyte0.length && abyte0[i++] == -1)
 //         while(i < abyte0.length && (abyte0[i] == -1 || abyte0[i++] == 0x20))
-switch(abyte0[i++]) {
+switch (abyte0[i++]) {
+// we will not worry about what it WONT do
-// we will not worry about what it WONT do
+case WONT:            // -4
-case WONT:            // -4
+default:
-default:
+break;
-break;
+case DO: //-3
-case DO: //-3
+// not sure why but since moving to V5R2 we are receiving a
-// not sure why but since moving to V5R2 we are receiving a
+//   DO with no option when connecting a second session with
-//   DO with no option when connecting a second session with
+//   device name.  Can not find the cause at all.  If anybody
-//   device name.  Can not find the cause at all.  If anybody
+//   is interested please debug this until then this works.
-//   is interested please debug this until then this works.
+if (i < abyte0.length) {
-if (i < abyte0.length) {
+switch (abyte0[i]) {
-switch(abyte0[i]) {
+case TERMINAL_TYPE: // 24
-case TERMINAL_TYPE: // 24
+baosp.write(IAC);
+baosp.write(WILL);
+baosp.write(TERMINAL_TYPE);
+writeByte(baosp.toByteArray());
+baosp.reset();
+break;
+case OPT_END_OF_RECORD: // 25
+baosp.write(IAC);
+baosp.write(WILL);
+baosp.write(OPT_END_OF_RECORD);
+writeByte(baosp.toByteArray());
+baosp.reset();
+break;
+case TRANSMIT_BINARY: // 0
+baosp.write(IAC);
+baosp.write(WILL);
+baosp.write(TRANSMIT_BINARY);
+writeByte(baosp.toByteArray());
+baosp.reset();
+break;
+case TIMING_MARK: // 6   rfc860
+//                        System.out.println("Timing Mark Received and notifying " +
+//                        "the server that we will not do it");
+baosp.write(IAC);
+baosp.write(WONT);
+baosp.write(TIMING_MARK);
+writeByte(baosp.toByteArray());
+baosp.reset();
+break;
+case NEW_ENVIRONMENT: // 39 rfc1572, rfc4777
+// allways send new environment vars ...
+baosp.write(IAC);
+baosp.write(WILL);
+baosp.write(NEW_ENVIRONMENT);
+writeByte(baosp.toByteArray());
+baosp.reset();
+break;
+default:  // every thing else we will not do at this time
+baosp.write(IAC);
+baosp.write(WONT);
+baosp.write(abyte0[i]); // either
+writeByte(baosp.toByteArray());
+baosp.reset();
+break;
+}
+}
+i++;
+break;
+case WILL:
+switch (abyte0[i]) {
+case OPT_END_OF_RECORD: // 25
+baosp.write(IAC);
+baosp.write(DO);
+baosp.write(OPT_END_OF_RECORD);
+writeByte(baosp.toByteArray());
+baosp.reset();
+break;
+case TRANSMIT_BINARY: // '\0'
+baosp.write(IAC);
+baosp.write(DO);
+baosp.write(TRANSMIT_BINARY);
+writeByte(baosp.toByteArray());
+baosp.reset();
+break;
+}
+i++;
+break;
+case SB: // -6
+if (abyte0[i] == NEW_ENVIRONMENT && abyte0[i + 1] == 1) {
+negNewEnvironment();
+while (++i < abyte0.length && abyte0[i + 1] != IAC);
+}
+if (abyte0[i] == TERMINAL_TYPE && abyte0[i + 1] == 1) {
 baosp.write(IAC);
-baosp.write(WILL);
+baosp.write(SB);
 baosp.write(TERMINAL_TYPE);
+baosp.write(QUAL_IS);
+if (!support132)
+baosp.write("IBM-3179-2".getBytes());
+else
+baosp.write("IBM-3477-FC".getBytes());
+baosp.write(IAC);
+baosp.write(SE);
 writeByte(baosp.toByteArray());
 baosp.reset();
+i++;
-break;
-case OPT_END_OF_RECORD: // 25
-baosp.write(IAC);
-baosp.write(WILL);
-baosp.write(OPT_END_OF_RECORD);
-writeByte(baosp.toByteArray());
-baosp.reset();
-break;
-case TRANSMIT_BINARY: // 0
-baosp.write(IAC);
-baosp.write(WILL);
-baosp.write(TRANSMIT_BINARY);
-writeByte(baosp.toByteArray());
-baosp.reset();
-break;
-case TIMING_MARK: // 6   rfc860
-//                        System.out.println("Timing Mark Received and notifying " +
-//                        "the server that we will not do it");
-baosp.write(IAC);
-baosp.write(WONT);
-baosp.write(TIMING_MARK);
-writeByte(baosp.toByteArray());
-baosp.reset();
-break;
-case NEW_ENVIRONMENT: // 39 rfc1572, rfc4777
-// allways send new environment vars ...
-baosp.write(IAC);
-baosp.write(WILL);
-baosp.write(NEW_ENVIRONMENT);
-writeByte(baosp.toByteArray());
-baosp.reset();
-break;
-default:  // every thing else we will not do at this time
-baosp.write(IAC);
-baosp.write(WONT);
-baosp.write(abyte0[i]); // either
-writeByte(baosp.toByteArray());
-baosp.reset();
-break;
 }
-}
-i++;
-break;
-case WILL:
-switch(abyte0[i]) {
-case OPT_END_OF_RECORD: // 25
-baosp.write(IAC);
-baosp.write(DO);
-baosp.write(OPT_END_OF_RECORD);
-writeByte(baosp.toByteArray());
-baosp.reset();
-break;
-case TRANSMIT_BINARY: // '\0'
-baosp.write(IAC);
-baosp.write(DO);
-baosp.write(TRANSMIT_BINARY);
-writeByte(baosp.toByteArray());
-baosp.reset();
-break;
-}
-i++;
-break;
-case SB: // -6
-if(abyte0[i] == NEW_ENVIRONMENT && abyte0[i + 1] == 1) {
-negNewEnvironment();
-while (++i < abyte0.length && abyte0[i + 1] != IAC);
-}
-if(abyte0[i] == TERMINAL_TYPE && abyte0[i + 1] == 1) {
-baosp.write(IAC);
-baosp.write(SB);
-baosp.write(TERMINAL_TYPE);
-baosp.write(QUAL_IS);
-if(!support132)
-baosp.write("IBM-3179-2".getBytes());
-else
-baosp.write("IBM-3477-FC".getBytes());
-baosp.write(IAC);
-baosp.write(SE);
-writeByte(baosp.toByteArray());
-baosp.reset();
 i++;
-}
+break;
-i++;
-break;
 }
 return true;
 }
 else {
 return false;
 }
 * Negotiate new environment string for device name
 *
 * @throws IOException
 */
 private void negNewEnvironment() throws IOException {
 baosp.write(IAC);
 baosp.write(SB);
 baosp.write(NEW_ENVIRONMENT);
 baosp.write(IS);
 if (kbdTypesCodePage != null) {
 baosp.write(USERVAR);
 baosp.write("KBDTYPE".getBytes());
 baosp.write(VALUE);
 baosp.write(kbdTypesCodePage.kbdType.getBytes());
 baosp.write(USERVAR);
 baosp.write("CODEPAGE".getBytes());
 baosp.write(VALUE);
 baosp.write(kbdTypesCodePage.codepage.getBytes());
 baosp.write(USERVAR);
 baosp.write("CHARSET".getBytes());
 baosp.write(VALUE);
 baosp.write(kbdTypesCodePage.charset.getBytes());
 }
 if (devName != null) {
 baosp.write(USERVAR);
 baosp.write("DEVNAME".getBytes());
 baosp.write(VALUE);
 baosp.write(negDeviceName().getBytes());
 }
 if (user != null) {
 baosp.write(VAR);
 baosp.write("USER".getBytes());
 baosp.write(VALUE);
 baosp.write(user.getBytes());
 baosp.write("IBMPROGRAM".getBytes());
 baosp.write(VALUE);
 baosp.write(program.getBytes());
 }
 }
 baosp.write(IAC);
 baosp.write(SE);
 writeByte(baosp.toByteArray());
 baosp.reset();
 }
 /**
 * This will negotiate a device name with controller. if the sequence is
 * less than zero then it will send the device name as specified. On each
 * the controller says no way.
 *
 * @return String
 */
 private String negDeviceName() {
 if (devSeq++ == -1) {
 devNameUsed = devName;
 return devName;
-} else {
+}
+else {
 StringBuffer sb = new StringBuffer(devName + devSeq);
 int ei = 1;
 while (sb.length() > 10) {
 sb.setLength(0);
 sb.append(devName.substring(0, devName.length() - ei++));
 sb.append(devSeq);
+}
-}
 devNameUsed = sb.toString();
 return devNameUsed;
 }
 }
 public final void setCodePage(String cp) {
 codePage = CharMappings.getCodePage(cp);
 cp = cp.toLowerCase();
 for (KbdTypesCodePages kbdtyp : KbdTypesCodePages.values()) {
-if (("cp"+kbdtyp.codepage).equals(cp) || kbdtyp.ccsid.equals(cp)) {
+if (("cp" + kbdtyp.codepage).equals(cp) || kbdtyp.ccsid.equals(cp)) {
 kbdTypesCodePage = kbdtyp;
 break;
 }
 }
-Log.i(TAG,"Chose keyboard mapping " + kbdTypesCodePage.toString() + " for code page " + cp);
+Log.i(TAG, "Chose keyboard mapping " + kbdTypesCodePage.toString() + " for code page " + cp);
 }
 public final ICodePage getCodePage() {
 return codePage;
 }

Mercurial > 510Connectbot

comparison src/org/tn5250j/framework/tn5250/tnvt.java @ 112:77ac18bc1b2f