Mercurial > 510Connectbot
changeset 25:5949eb469a79 tn5250
adding tn5250 files, native android logging
| author | Carl Byington <carl@five-ten-sg.com> |
|---|---|
| date | Tue, 03 Jun 2014 12:10:21 -0700 |
| parents | d1c549560aff |
| children | 9ae1c889a64c |
| files | libs/android-logging-log4j-1.0.3.jar libs/log4j-1.2.17.jar src/org/tn5250j/GlobalConfigure.java src/org/tn5250j/encoding/BuiltInCodePageFactory.java src/org/tn5250j/encoding/ToolboxCodePageFactory.java src/org/tn5250j/framework/tn5250/DataStreamProducer.java src/org/tn5250j/framework/tn5250/KeyStrokenizer.java src/org/tn5250j/framework/tn5250/Screen5250.java src/org/tn5250j/framework/tn5250/WTDSFParser.java src/org/tn5250j/framework/tn5250/tnvt.java src/org/tn5250j/framework/transport/SSL/SSLImplementation.java src/org/tn5250j/framework/transport/SocketConnector.java src/org/tn5250j/tools/logging/Log4jLogger.java src/org/tn5250j/tools/logging/TN5250jLogFactory.java |
| diffstat | 14 files changed, 2662 insertions(+), 2861 deletions(-) [+] |
line wrap: on
line diff
--- a/src/org/tn5250j/GlobalConfigure.java Tue Jun 03 11:44:37 2014 -0700 +++ b/src/org/tn5250j/GlobalConfigure.java Tue Jun 03 12:10:21 2014 -0700 @@ -39,8 +39,8 @@ import com.five_ten_sg.connectbot.TerminalView; import org.tn5250j.interfaces.ConfigureFactory; -import org.tn5250j.tools.logging.TN5250jLogFactory; -import org.tn5250j.tools.logging.TN5250jLogger; +import android.util.Log; + /** * Utility class for referencing global settings and functions of which at most @@ -64,7 +64,7 @@ static private Hashtable registry = new Hashtable(); static private Hashtable headers = new Hashtable(); //LUC GORRENS - private final TN5250jLogger log = TN5250jLogFactory.getLogger (this.getClass()); + /** * The constructor is made protected to allow overriding. @@ -112,14 +112,10 @@ final File f = new File (settingsfolder); if (!f.exists()) { try { - if (log.isInfoEnabled()) { - log.info("Settings folder '"+settingsfolder+"' doesn't exist. Will created now."); - } + Log.i(TAG,"Settings folder '"+settingsfolder+"' doesn't exist. Will created now."); f.mkdir(); } catch (Exception e) { - if (log.isWarnEnabled()) { - log.warn("Couldn't create settings folder '"+settingsfolder+"'", e); - } + Log.w(TAG,"Couldn't create settings folder '"+settingsfolder+"'", e); } } } @@ -154,16 +150,12 @@ */ @Override public void reloadSettings() { - if (log.isInfoEnabled()) { - log.info("reloading settings"); - } + Log.i(TAG,"reloading settings"); loadSettings(); loadSessions(); loadMacros(); loadKeyStrokes(); - if (log.isInfoEnabled()) { - log.info("Done (reloading settings)."); - } + Log.i(TAG,"Done (reloading settings)."); } /** @@ -179,18 +171,18 @@ settings.load(in); } catch (FileNotFoundException fnfea) { - log.info(" Information Message: " + Log.i(TAG," Information Message: " + fnfea.getMessage() + ". The file " + settingsFile() + " will be created for first time use."); saveSettings(); } catch (IOException ioea) { - log.warn("IO Exception accessing File " + Log.w(TAG,"IO Exception accessing File " + settingsFile() + " for the following reason : " + ioea.getMessage()); } catch (SecurityException sea) { - log.warn("Security Exception for file " + Log.w(TAG,"Security Exception for file " + settingsFile() + " This file can not be " + "accessed because : " + sea.getMessage()); } @@ -255,17 +247,17 @@ out.close(); } catch (FileNotFoundException fnfe) { - log.warn("File not found : writing file " + Log.w(TAG,"File not found : writing file " + fileName + ". Description of error is " + fnfe.getMessage()); } catch (IOException ioe) { - log.warn("IO Exception : writing file " + Log.w(TAG,"IO Exception : writing file " + fileName + ". Description of error is " + ioe.getMessage()); } catch (SecurityException se) { - log.warn("Security Exception : writing file " + Log.w(TAG,"Security Exception : writing file " + fileName + ". Description of error is " + se.getMessage()); } @@ -323,7 +315,7 @@ catch (FileNotFoundException fnfe) { if (createFile) { - log.info(" Information Message: " + fnfe.getMessage() + Log.i(TAG," Information Message: " + fnfe.getMessage() + ". The file " + fileName + " will" + " be created for first time use."); @@ -332,18 +324,18 @@ } else { - log.info(" Information Message: " + fnfe.getMessage() + Log.i(TAG," Information Message: " + fnfe.getMessage() + "."); } } catch (IOException ioe) { - log.warn("IO Exception accessing File "+ fileName + + Log.w(TAG,"IO Exception accessing File "+ fileName + " for the following reason : " + ioe.getMessage()); } catch (SecurityException se) { - log.warn("Security Exception for file "+ fileName + Log.w(TAG,"Security Exception for file "+ fileName + ". This file can not be accessed because : " + se.getMessage()); } @@ -404,7 +396,7 @@ catch (FileNotFoundException fnfe) { if (createFile) { - log.info(" Information Message: " + fnfe.getMessage() + Log.i(TAG," Information Message: " + fnfe.getMessage() + ". The file " + fileName + " will" + " be created for first time use."); @@ -417,18 +409,18 @@ } else { - log.info(" Information Message: " + fnfe.getMessage() + Log.i(TAG," Information Message: " + fnfe.getMessage() + "."); } } catch (IOException ioe) { - log.warn("IO Exception accessing File "+ fileName + + Log.w(TAG,"IO Exception accessing File "+ fileName + " for the following reason : " + ioe.getMessage()); } catch (SecurityException se) { - log.warn("Security Exception for file "+ fileName + Log.w(TAG,"Security Exception for file "+ fileName + ". This file can not be accessed because : " + se.getMessage()); }
--- a/src/org/tn5250j/encoding/BuiltInCodePageFactory.java Tue Jun 03 11:44:37 2014 -0700 +++ b/src/org/tn5250j/encoding/BuiltInCodePageFactory.java Tue Jun 03 12:10:21 2014 -0700 @@ -52,8 +52,8 @@ import org.tn5250j.encoding.builtin.CCSID871; import org.tn5250j.encoding.builtin.CCSID875; import org.tn5250j.encoding.builtin.ICodepageConverter; -import org.tn5250j.tools.logging.TN5250jLogFactory; -import org.tn5250j.tools.logging.TN5250jLogger; +import android.util.Log; + /** * Methods for built-in code page support. @@ -63,7 +63,7 @@ private static BuiltInCodePageFactory singleton; private final List<Class<?>> clazzes = new ArrayList<Class<?>>(); - private final TN5250jLogger log = TN5250jLogFactory.getLogger(this.getClass()); + private BuiltInCodePageFactory() { register(); @@ -141,7 +141,7 @@ converter.init(); return converter; } catch (Exception e) { - log.error("Couldn't load code page converter class:" + clazz.getCanonicalName(), e); + Log.e(TAG,"Couldn't load code page converter class:" + clazz.getCanonicalName(), e); return null; } }
--- a/src/org/tn5250j/encoding/ToolboxCodePageFactory.java Tue Jun 03 11:44:37 2014 -0700 +++ b/src/org/tn5250j/encoding/ToolboxCodePageFactory.java Tue Jun 03 12:10:21 2014 -0700 @@ -29,8 +29,8 @@ import java.lang.reflect.Constructor; import java.lang.reflect.Method; -import org.tn5250j.tools.logging.TN5250jLogFactory; -import org.tn5250j.tools.logging.TN5250jLogger; +import android.util.Log; + /* package */ class ToolboxCodePageFactory { @@ -55,7 +55,7 @@ private static ToolboxCodePageFactory singleton; - private final TN5250jLogger log = TN5250jLogFactory.getLogger(this.getClass()); + private ToolboxCodePageFactory() { /* private for singleton */ @@ -77,7 +77,7 @@ Class.forName(CONVERTER_NAME, false, loader); return CODEPAGES; } catch (Exception e) { - log.info("Couldn't locate JT400 Toolbox in classpath. Charset converters can't be used."); + Log.i(TAG,"Couldn't locate JT400 Toolbox in classpath. Charset converters can't be used."); return new String[0]; } } @@ -96,7 +96,7 @@ Object convobj = conv_constructor.newInstance(new Object[] { encoding }); return new ToolboxConverterProxy(convobj, toBytes_method, toString_method); } catch (Exception e) { - log.warn("Can't load charset converter from JT400 Toolbox for code page " + encoding, e); + Log.w(TAG,"Can't load charset converter from JT400 Toolbox for code page " + encoding, e); return null; } }
--- a/src/org/tn5250j/framework/tn5250/DataStreamProducer.java Tue Jun 03 11:44:37 2014 -0700 +++ b/src/org/tn5250j/framework/tn5250/DataStreamProducer.java Tue Jun 03 12:10:21 2014 -0700 @@ -11,11 +11,11 @@ import java.util.concurrent.BlockingQueue; import org.tn5250j.encoding.ICodePage; -import org.tn5250j.tools.logging.TN5250jLogFactory; -import org.tn5250j.tools.logging.TN5250jLogger; +import android.util.Log; + public class DataStreamProducer implements Runnable { - + private static final String TAG = "DataStreamProducer"; private BufferedInputStream bin; private ByteArrayOutputStream baosin; private Thread me; @@ -28,7 +28,7 @@ private boolean dumpBytes = false; private ICodePage codePage; - private TN5250jLogger log = TN5250jLogFactory.getLogger (this.getClass()); + public DataStreamProducer(tnvt vt, BufferedInputStream in, BlockingQueue<Object> queue, byte[] init) { bin = in; @@ -52,7 +52,7 @@ // load the first response screen loadStream(abyte2, 0); - + while (!done) { try { @@ -84,20 +84,20 @@ } catch (SocketException se) { - log.warn(" DataStreamProducer thread interrupted and stopping " + se.getMessage()); + Log.w(TAG," DataStreamProducer thread interrupted and stopping " + se.getMessage()); done = true; } catch (IOException ioe) { - log.warn(ioe.getMessage()); + Log.w(TAG,ioe.getMessage()); if (me.isInterrupted()) done = true; } catch (Exception ex) { - log.warn(ex.getMessage()); + Log.w(TAG,ex.getMessage()); if (me.isInterrupted()) done = true; @@ -123,13 +123,13 @@ saveStream = null; inter = null; j = (abyte0[i] & 0xff) << 8 | abyte0[i + 1] & 0xff; - log.debug("partial stream found"); + Log.d(TAG,"partial stream found"); } if (j > size) { saveStream = new byte[abyte0.length]; System.arraycopy(abyte0, 0, saveStream, 0, abyte0.length); - log.debug("partial stream saved"); + Log.d(TAG,"partial stream saved"); } else { byte abyte1[]; @@ -143,7 +143,7 @@ } catch (Exception ex) { - log.warn("load stream error " + ex.getMessage()); + Log.w(TAG,"load stream error " + ex.getMessage()); // ex.printStackTrace(); // dump(abyte0); @@ -160,9 +160,9 @@ baosin.reset(); int j = -1; int i = 0; - + while(!done) { - + i = bin.read(); // WVL - LDC : 16/07/2003 : TR.000345 @@ -257,7 +257,7 @@ } } catch (FileNotFoundException fnfe) { - log.warn(fnfe.getMessage()); + Log.w(TAG,fnfe.getMessage()); } } @@ -275,17 +275,17 @@ } catch(IOException ioe) { - log.warn(ioe.getMessage()); + Log.w(TAG,ioe.getMessage()); } } - log.info("Data Stream output is now " + dumpBytes); + Log.i(TAG,"Data Stream output is now " + dumpBytes); } public void dump (byte[] abyte0) { try { - log.info("\n Buffer Dump of data from AS400: "); + Log.i(TAG,"\n Buffer Dump of data from AS400: "); dw.write("\r\n Buffer Dump of data from AS400: ".getBytes()); StringBuffer h = new StringBuffer(); @@ -333,7 +333,7 @@ } catch(EOFException _ex) { } catch(Exception _ex) { - log.warn("Cannot dump from host\n\r"); + Log.w(TAG,"Cannot dump from host\n\r"); } }
--- a/src/org/tn5250j/framework/tn5250/KeyStrokenizer.java Tue Jun 03 11:44:37 2014 -0700 +++ b/src/org/tn5250j/framework/tn5250/KeyStrokenizer.java Tue Jun 03 12:10:21 2014 -0700 @@ -21,8 +21,8 @@ package org.tn5250j.framework.tn5250; -import org.tn5250j.tools.logging.TN5250jLogFactory; -import org.tn5250j.tools.logging.TN5250jLogger; +import android.util.Log; + public class KeyStrokenizer { @@ -32,7 +32,7 @@ private int index; private int length; - private final TN5250jLogger log = TN5250jLogFactory.getLogger(this.getClass()); + public KeyStrokenizer() { @@ -44,7 +44,7 @@ if (strokes != null) { keyStrokes.setLength(0); - log.debug("set "+ keyStrokes); + Log.d(TAG,"set "+ keyStrokes); length = strokes.length(); } else { @@ -77,7 +77,7 @@ // we need to throw an error here if(index >= length) { - log.warn(" mnemonic key was incomplete :1 " + + Log.w(TAG," mnemonic key was incomplete :1 " + "at position " + index + " len " + length ); } else { @@ -99,7 +99,7 @@ // we need to throw an error here because we did not // find an ending for the potential mnemonic if(index >= length) { - log.warn( + Log.w(TAG, " mnemonic key was incomplete ending not found :2 " + "at position " + index); } @@ -113,7 +113,7 @@ case ']': index++; if(index >= length) { - log.warn( + Log.w(TAG, " mnemonic key was incomplete ending not found :3 " + "at position " + index); sb.append(c); @@ -127,7 +127,7 @@ index++; } else { - log.warn( + Log.w(TAG, " mnemonic key was incomplete beginning not found :4 " + "at position " + index); } @@ -143,7 +143,7 @@ } } - log.debug("next "+ keyStrokes); + Log.d(TAG,"next "+ keyStrokes); return s; }
--- a/src/org/tn5250j/framework/tn5250/Screen5250.java Tue Jun 03 11:44:37 2014 -0700 +++ b/src/org/tn5250j/framework/tn5250/Screen5250.java Tue Jun 03 12:10:21 2014 -0700 @@ -35,8 +35,8 @@ import org.tn5250j.TN5250jConstants; import org.tn5250j.event.ScreenListener; -import org.tn5250j.tools.logging.TN5250jLogFactory; -import org.tn5250j.tools.logging.TN5250jLogger; +import android.util.Log; + public class Screen5250 { @@ -98,7 +98,7 @@ //Added by Barry private StringBuffer keybuf; - private TN5250jLogger log = TN5250jLogFactory.getLogger(this.getClass()); + public Screen5250() { @@ -108,7 +108,7 @@ try { jbInit(); } catch (Exception ex) { - log.warn("In constructor: ", ex); + Log.w(TAG,"In constructor: ", ex); } } @@ -197,7 +197,7 @@ StringBuilder sb = new StringBuilder(); Rect workR = new Rect(); workR.setBounds(area); - log.debug("Copying " + workR); + Log.d(TAG,"Copying " + workR); // loop through all the screen characters to send them to the clip board int m = workR.x; @@ -231,9 +231,7 @@ * @see {@link #copyText(Rectangle)} */ public final void pasteText(String content, boolean special) { - if (log.isDebugEnabled()) { - log.debug("Pasting, special:"+special); - } + Log.d(TAG,"Pasting, special:"+special); setCursorActive(false); StringBuilder sb = new StringBuilder(content); @@ -262,7 +260,7 @@ if ((c == '\n') || (c == '\r')) { - log.info("pasted cr-lf>" + pd + "<"); + Log.i(TAG,"pasted cr-lf>" + pd + "<"); pd.setLength(0); // if we read in a cr lf in the data stream we need to go // to the starting column of the next row and start from there @@ -300,7 +298,7 @@ // if we have anything else not logged then log it out. if (pd.length() > 0) - log.info("pasted >" + pd + "<"); + Log.i(TAG,"pasted >" + pd + "<"); // restore out position within the FFT. screenFields.restoreCurrentField(); @@ -350,7 +348,7 @@ // gui.rubberband.reset(); // gui.repaint(); - log.debug("Summing"); + Log.d(TAG,"Summing"); // obtain the decimal format for parsing DecimalFormat df = (DecimalFormat) NumberFormat.getInstance(); @@ -406,14 +404,14 @@ sumVector.add(new Double(n.doubleValue())); sum += n.doubleValue(); } catch (ParseException pe) { - log.warn(pe.getMessage() + " at " + Log.w(TAG,pe.getMessage() + " at " + pe.getErrorOffset()); } } sb.setLength(0); m++; } - log.debug("" + sum); + Log.d(TAG,"" + sum); return sumVector; } @@ -456,12 +454,12 @@ if (planes.getChar(pos + 1) != '=' && planes.getChar(pos + 1) != '.' && planes.getChar(pos + 1) != '/') { - log.debug(" Hotspot clicked!!! we will send characters " + Log.d(TAG," Hotspot clicked!!! we will send characters " + planes.getChar(pos) + " " + planes.getChar(pos+1)); aid.append(planes.getChar(pos)); aid.append(planes.getChar(pos + 1)); } else { - log.debug(" Hotspot clicked!!! we will send character " + Log.d(TAG," Hotspot clicked!!! we will send character " + planes.getChar(pos)); aid.append(planes.getChar(pos)); } @@ -501,7 +499,7 @@ sessionVT.showURL(eb.toString()); // take out the log statement when we are sure it is // working - log.info("Send to external Browser: " + eb.toString()); + Log.i(TAG,"Send to external Browser: " + eb.toString()); break; default: @@ -1695,7 +1693,7 @@ simulated = true; break; default: - log.info(" Mnemonic not supported " + mnem); + Log.i(TAG," Mnemonic not supported " + mnem); break; } @@ -3186,7 +3184,7 @@ } break; default: - log.warn(" Invalid roll parameter - please report this"); + Log.w(TAG," Invalid roll parameter - please report this"); } // System.out.println(" end roll"); // dumpScreen(); @@ -3207,7 +3205,7 @@ col = 0; } } - log.info(sb.toString()); + Log.i(TAG,sb.toString()); } @@ -3874,7 +3872,7 @@ */ private synchronized void fireScreenChanged(int update) { if (dirtyScreen.x > dirtyScreen.y) { - // log.info(" x < y " + dirtyScreen); + // Log.i(TAG," x < y " + dirtyScreen); return; }
--- a/src/org/tn5250j/framework/tn5250/WTDSFParser.java Tue Jun 03 11:44:37 2014 -0700 +++ b/src/org/tn5250j/framework/tn5250/WTDSFParser.java Tue Jun 03 12:10:21 2014 -0700 @@ -40,8 +40,8 @@ import java.util.List; import org.tn5250j.encoding.ICodePage; -import org.tn5250j.tools.logging.TN5250jLogFactory; -import org.tn5250j.tools.logging.TN5250jLogger; +import android.util.Log; + /** * @@ -62,7 +62,7 @@ boolean error; boolean guiStructsExist; - private TN5250jLogger log = TN5250jLogFactory.getLogger(this.getClass()); + private final List<Window> guiStructs = new ArrayList<Window>(3); private final List<ChoiceField> choices = new ArrayList<ChoiceField>(3); @@ -103,7 +103,7 @@ Window(byte[] seg, int pos) { - //log.info("window created at " + pos); + //Log.i(TAG,"window created at " + pos); window = seg; this.pos = pos; guiStructsExist = true; @@ -361,7 +361,7 @@ } - log.debug( + Log.d(TAG, " orientation " + Integer.toBinaryString(orientation) + " mAttr " + mAttr + " cAttr " + cAttr + @@ -375,7 +375,7 @@ hfBuffer); break; default: - log.warn("Invalid Window minor structure"); + Log.w(TAG,"Invalid Window minor structure"); length = 0; done = true; } @@ -431,7 +431,7 @@ break; case 0x5F: // Remove All GUI Constructs - log.info("remove all gui contructs"); + Log.i(TAG,"remove all gui contructs"); clearGuiStructs(); guiStructsExist = false; int len = 4; @@ -453,7 +453,7 @@ done = true; break; case 0x59: // remove gui window - log.info(" remove window at " + screen52.getCurrentPos()); + Log.i(TAG," remove window at " + screen52.getCurrentPos()); done = true; break; @@ -758,7 +758,7 @@ int cnt = 0; int minLen = 0; majLen -= 21; - log.debug(" row: " + screen52.getCurrentRow() + Log.d(TAG," row: " + screen52.getCurrentRow() + " col: " + screen52.getCurrentCol() + " type " + typeSelection + " gui " + guiDevice @@ -839,14 +839,14 @@ // is in selected state if ((flagCT1 & 0x40) == 0x40) { - log.debug(" selected "); + Log.d(TAG," selected "); selected = true; } //System.out.println(Integer.toBinaryString((flagCT1 & 0xf0))); // is mnemonic offset specified if ((flagCT1 & 0x08) == 8) { - log.debug(" mnemOffset " + mnemOffset); + Log.d(TAG," mnemOffset " + mnemOffset); mnemOffset = segment[pos++]; cnt++; } @@ -855,20 +855,20 @@ if ((flagCT1 & 0x04) == 4) { aid = true; - log.debug(" aidKey " + aid); + Log.d(TAG," aidKey " + aid); // cnt++; } // is single digit number specified if ((flagCT1 & 0x01) == 0x01) { - log.debug(" single digit " ); + Log.d(TAG," single digit " ); pos++; cnt++; } // is double digint number specified if ((flagCT1 & 0x02) == 0x02) { - log.debug(" double digit " ); + Log.d(TAG," double digit " ); pos++; cnt++; @@ -902,7 +902,7 @@ // screen52.getScreenFields().getCurrentField().setMDT(); - log.debug(s + " selected " + selected); + Log.d(TAG,s + " selected " + selected); // chcRowStart; //maxColChoice colCtr++; @@ -938,7 +938,7 @@ } while (majLen > 0); } catch (Exception exc) { - log.warn(" defineSelectionField :", exc); + Log.w(TAG," defineSelectionField :", exc); exc.printStackTrace(); } }
--- a/src/org/tn5250j/framework/tn5250/tnvt.java Tue Jun 03 11:44:37 2014 -0700 +++ b/src/org/tn5250j/framework/tn5250/tnvt.java Tue Jun 03 12:10:21 2014 -0700 @@ -90,118 +90,118 @@ import org.tn5250j.encoding.CharMappings; import org.tn5250j.encoding.ICodePage; import org.tn5250j.framework.transport.SocketConnector; -import org.tn5250j.tools.logging.TN5250jLogFactory; -import org.tn5250j.tools.logging.TN5250jLogger; +import android.util.Log; + public final class tnvt implements Runnable { - // negotiating commands - private static final byte IAC = (byte) -1; // 255 FF - private static final byte DONT = (byte) -2; //254 FE - private static final byte DO = (byte) -3; //253 FD - private static final byte WONT = (byte) -4; //252 FC - private static final byte WILL = (byte) -5; //251 FB - 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 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 - private static final byte NEW_ENVIRONMENT = (byte) 39; // 27 - private static final byte IS = (byte) 0; // 0 - private static final byte SEND = (byte) 1; // 1 - private static final byte INFO = (byte) 2; // 2 - private static final byte VAR = (byte) 0; // 0 - private static final byte VALUE = (byte) 1; // 1 - private static final byte NEGOTIATE_ESC = (byte) 2; // 2 - private static final byte USERVAR = (byte) 3; // 3 - - // miscellaneous - private static final byte ESC = 0x04; // 04 - - private Socket sock; - public BufferedInputStream bin; - public BufferedOutputStream bout; - private final BlockingQueue<Object> dsq = new ArrayBlockingQueue<Object>(25); - private Stream5250 bk; - private DataStreamProducer producer; - protected Screen5250 screen52; - private boolean waitingForInput; - private boolean invited; - private boolean negotiated = false; - private Thread me; - private Thread pthread; - private int readType; - private boolean enhanced = true; - private boolean cursorOn = false; - private String hostname = ""; - private int port = 23; - private boolean connected = false; - private boolean support132 = true; - private ByteArrayOutputStream baosp = null; - private ByteArrayOutputStream baosrsp = null; - private int devSeq = -1; - private String devName; - private String devNameUsed; - private KbdTypesCodePages kbdTypesCodePage; - // WVL - LDC : TR.000300 : Callback scenario from 5250 - private boolean scan; // = false; - private static int STRSCAN = 1; - // WVL - LDC : 05/08/2005 : TFX.006253 - support STRPCCMD - private boolean strpccmd; // = false; - private String user; - private String password; - private String library; - private String initialMenu; - private String program; - private boolean keepTrucking = true; - private boolean pendingUnlock = false; - private boolean[] dataIncluded; - protected ICodePage codePage; - private boolean firstScreen; - private String sslType; - private WTDSFParser sfParser; + // negotiating commands + private static final byte IAC = (byte) -1; // 255 FF + private static final byte DONT = (byte) -2; //254 FE + private static final byte DO = (byte) -3; //253 FD + private static final byte WONT = (byte) -4; //252 FC + private static final byte WILL = (byte) -5; //251 FB + 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 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 + private static final byte NEW_ENVIRONMENT = (byte) 39; // 27 + private static final byte IS = (byte) 0; // 0 + private static final byte SEND = (byte) 1; // 1 + private static final byte INFO = (byte) 2; // 2 + private static final byte VAR = (byte) 0; // 0 + private static final byte VALUE = (byte) 1; // 1 + private static final byte NEGOTIATE_ESC = (byte) 2; // 2 + private static final byte USERVAR = (byte) 3; // 3 + + // miscellaneous + private static final byte ESC = 0x04; // 04 + + private Socket sock; + public BufferedInputStream bin; + public BufferedOutputStream bout; + private final BlockingQueue<Object> dsq = new ArrayBlockingQueue<Object>(25); + private Stream5250 bk; + private DataStreamProducer producer; + protected Screen5250 screen52; + private boolean waitingForInput; + private boolean invited; + private boolean negotiated = false; + private Thread me; + private Thread pthread; + private int readType; + private boolean enhanced = true; + private boolean cursorOn = false; + private String hostname = ""; + private int port = 23; + private boolean connected = false; + private boolean support132 = true; + private ByteArrayOutputStream baosp = null; + private ByteArrayOutputStream baosrsp = null; + private int devSeq = -1; + private String devName; + private String devNameUsed; + private KbdTypesCodePages kbdTypesCodePage; + // WVL - LDC : TR.000300 : Callback scenario from 5250 + private boolean scan; // = false; + private static int STRSCAN = 1; + // WVL - LDC : 05/08/2005 : TFX.006253 - support STRPCCMD + private boolean strpccmd; // = false; + private String user; + private String password; + private String library; + private String initialMenu; + private String program; + private boolean keepTrucking = true; + private boolean pendingUnlock = false; + private boolean[] dataIncluded; + protected ICodePage codePage; + private boolean firstScreen; + private String sslType; + private WTDSFParser sfParser; private TerminalBridge bridge; private TerminalManager manager; - private final TN5250jLogger log = TN5250jLogFactory.getLogger(this.getClass()); - - /** - * @param screen52 - * @param enhanced - * @param support132 + + + /** + * @param screen52 + * @param enhanced + * @param support132 * @param bridge * @param manager - */ - public tnvt(Screen5250 screen52, boolean enhanced, boolean support132, TerminalBridge bridge, TerminalManager manager) { - this.screen52 = screen52; - this.support132 = support132; - this.enhanced = enhanced; + */ + public tnvt(Screen5250 screen52, boolean enhanced, boolean support132, TerminalBridge bridge, TerminalManager manager) { + this.screen52 = screen52; + this.support132 = support132; + this.enhanced = enhanced; this.bridge = bridge; this.manager = manager; - 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(); - } + 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; @@ -209,2497 +209,2467 @@ manager.startActivity(intent); } - public String getHostName() { - - return hostname; - } - - public void setSSLType(String type) { - sslType = type; - } - - public void setDeviceName(String name) { - devName = name; - } - - public String getDeviceName() { - return devName; - } - - public String getAllocatedDeviceName() { - return devNameUsed; - } - - public boolean isConnected() { - return connected; - } - - /** - * @return true when SSL is used and socket is connected. - * @see {@link #isConnected()} - */ - public boolean isSslSocket() { - if (this.connected && this.sock != null && this.sock instanceof SSLSocket) { - return true; - } 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.info(" socks set "); - } - - public final boolean connect() { - - return connect(hostname, port); - - } - - - public final boolean connect(String hostname, int port) { - - //// We will now see if there are any bypass signon parameters to be - //// processed. The system properties override these parameters so - //// have precidence if specified. - //Properties props = controller.getConnectionProperties(); - //if (user == null && props.containsKey("SESSION_CONNECT_USER")) { - // user = props.getProperty("SESSION_CONNECT_USER"); - // log.info(" user -> " + user + " " + controller.getSessionName()); - // if (props.containsKey("SESSION_CONNECT_PASSWORD")) - // password = props.getProperty("SESSION_CONNECT_PASSWORD"); - // if (props.containsKey("SESSION_CONNECT_LIBRARY")) - // library = props.getProperty("SESSION_CONNECT_LIBRARY"); - // if (props.containsKey("SESSION_CONNECT_MENU")) - // initialMenu = props.getProperty("SESSION_CONNECT_MENU"); - // if (props.containsKey("SESSION_CONNECT_PROGRAM")) - // program = props.getProperty("SESSION_CONNECT_PROGRAM"); - //} - - try { - this.hostname = hostname; - this.port = port; - - try { - screen52.getOIA().setInputInhibited(ScreenOIA.INPUTINHIBITED_SYSTEM_WAIT, - ScreenOIA.OIA_LEVEL_INPUT_INHIBITED,"X - Connecting"); - } catch (Exception exc) { - log.warn("setStatus(ON) " + exc.getMessage()); - } - - // sock = new Socket(s, port); - //smk - For SSL compability - SocketConnector sc = new SocketConnector(); - if (sslType != null) sc.setSSLType(sslType); - sock = sc.createSocket(hostname, port, bridge, manager); - - if (sock == null) { - log.warn("I did not get a socket"); - disconnect(); - return false; - } - - connected = true; - // used for JDK1.3 - 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.warn("setCursorOff " + excc.getMessage()); - - } - - producer = new DataStreamProducer(this, bin, dsq, abyte0); - pthread = new Thread(producer); - // pthread.setPriority(pthread.MIN_PRIORITY); - pthread.setPriority(Thread.NORM_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.warn("setStatus(OFF) " + exc.getMessage()); - } - - keepTrucking = true; - me = new Thread(this); - me.start(); - - } catch (Exception exception) { - if (exception.getMessage() == null) - exception.printStackTrace(); - log.warn("connect() " + exception.getMessage()); - - if (sock == null) - log.warn("I did not get a socket"); - - disconnect(); - return false; - } - return true; - - } - - public final boolean disconnect() { - - // Added by LUC - LDC to fix a null pointer exception. - if (!connected) { - screen52.getOIA().setInputInhibited(ScreenOIA.INPUTINHIBITED_SYSTEM_WAIT, - 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"); - screen52.getOIA().setKeyBoardLocked(false); - pendingUnlock = false; - - try { - if (sock != null) { - log.info("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.warn(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 { - 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) { - - log.warn(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) { - - log.warn(ioe.getMessage()); - baosp.reset(); - return false; - } - baosp.reset(); - return true; - - } - - private boolean dataIncluded(int aid) { - - switch (aid) { - - case PF1: - return !dataIncluded[0]; - case PF2: - return !dataIncluded[1]; - case PF3: - return !dataIncluded[2]; - case PF4: - return !dataIncluded[3]; - case PF5: - return !dataIncluded[4]; - case PF6: - return !dataIncluded[5]; - case PF7: - return !dataIncluded[6]; - case PF8: - return !dataIncluded[7]; - case PF9: - return !dataIncluded[8]; - case PF10: - return !dataIncluded[9]; - case PF11: - return !dataIncluded[10]; - case PF12: - return !dataIncluded[11]; - case PF13: - return !dataIncluded[12]; - case PF14: - return !dataIncluded[13]; - case PF15: - return !dataIncluded[14]; - case PF16: - return !dataIncluded[15]; - case PF17: - return !dataIncluded[16]; - 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 - // System.out.println("Help request sent"); - baosp.write(screen52.getCurrentRow()); - baosp.write(screen52.getCurrentCol()); - baosp.write(AID_HELP); - - try { - writeGDS(0, 3, baosp.toByteArray()); - } catch (IOException ioe) { - - log.warn(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 1 - ATN Attention - // bits 2-4 - reserved - // 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) { - - log.warn(ioe.getMessage()); - } - } - - /** - * Opens a dialog and asks the user before sending a request - * - * @see {@link #systemRequest(String)} - */ - public final void systemRequest() { + public String getHostName() { + + return hostname; + } + + public void setSSLType(String type) { + sslType = type; + } + + public void setDeviceName(String name) { + devName = name; + } + + public String getDeviceName() { + return devName; + } + + public String getAllocatedDeviceName() { + return devNameUsed; + } + + public boolean isConnected() { + return connected; + } + + /** + * @return true when SSL is used and socket is connected. + * @see {@link #isConnected()} + */ + public boolean isSslSocket() { + if (this.connected && this.sock != null && this.sock instanceof SSLSocket) { + return true; + } 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 "); + } + + public final boolean connect() { + + return connect(hostname, port); + + } + + + public final boolean connect(String hostname, int port) { + + //// We will now see if there are any bypass signon parameters to be + //// processed. The system properties override these parameters so + //// have precidence if specified. + //Properties props = controller.getConnectionProperties(); + //if (user == null && props.containsKey("SESSION_CONNECT_USER")) { + // user = props.getProperty("SESSION_CONNECT_USER"); + // Log.i(TAG," user -> " + user + " " + controller.getSessionName()); + // if (props.containsKey("SESSION_CONNECT_PASSWORD")) + // password = props.getProperty("SESSION_CONNECT_PASSWORD"); + // if (props.containsKey("SESSION_CONNECT_LIBRARY")) + // library = props.getProperty("SESSION_CONNECT_LIBRARY"); + // if (props.containsKey("SESSION_CONNECT_MENU")) + // initialMenu = props.getProperty("SESSION_CONNECT_MENU"); + // if (props.containsKey("SESSION_CONNECT_PROGRAM")) + // program = props.getProperty("SESSION_CONNECT_PROGRAM"); + //} + + try { + this.hostname = hostname; + this.port = port; + + try { + screen52.getOIA().setInputInhibited(ScreenOIA.INPUTINHIBITED_SYSTEM_WAIT, + ScreenOIA.OIA_LEVEL_INPUT_INHIBITED,"X - Connecting"); + } catch (Exception exc) { + Log.w(TAG,"setStatus(ON) " + exc.getMessage()); + } + + // sock = new Socket(s, port); + //smk - For SSL compability + SocketConnector sc = new SocketConnector(); + if (sslType != null) sc.setSSLType(sslType); + sock = sc.createSocket(hostname, port, bridge, manager); + + if (sock == null) { + Log.w(TAG,"I did not get a socket"); + disconnect(); + return false; + } + + connected = true; + // used for JDK1.3 + 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()); + + } + + producer = new DataStreamProducer(this, bin, dsq, abyte0); + pthread = new Thread(producer); + // pthread.setPriority(pthread.MIN_PRIORITY); + pthread.setPriority(Thread.NORM_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()); + } + + keepTrucking = true; + me = new Thread(this); + me.start(); + + } catch (Exception exception) { + if (exception.getMessage() == null) + exception.printStackTrace(); + Log.w(TAG,"connect() " + exception.getMessage()); + + if (sock == null) + Log.w(TAG,"I did not get a socket"); + + disconnect(); + return false; + } + return true; + + } + + public final boolean disconnect() { + + // Added by LUC - LDC to fix a null pointer exception. + if (!connected) { + screen52.getOIA().setInputInhibited(ScreenOIA.INPUTINHIBITED_SYSTEM_WAIT, + 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"); + screen52.getOIA().setKeyBoardLocked(false); + pendingUnlock = false; + + try { + if (sock != null) { + 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()); + 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 { + 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) { + + 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) { + + Log.w(TAG,ioe.getMessage()); + baosp.reset(); + return false; + } + baosp.reset(); + return true; + + } + + private boolean dataIncluded(int aid) { + + switch (aid) { + + case PF1: + return !dataIncluded[0]; + case PF2: + return !dataIncluded[1]; + case PF3: + return !dataIncluded[2]; + case PF4: + return !dataIncluded[3]; + case PF5: + return !dataIncluded[4]; + case PF6: + return !dataIncluded[5]; + case PF7: + return !dataIncluded[6]; + case PF8: + return !dataIncluded[7]; + case PF9: + return !dataIncluded[8]; + case PF10: + return !dataIncluded[9]; + case PF11: + return !dataIncluded[10]; + case PF12: + return !dataIncluded[11]; + case PF13: + return !dataIncluded[12]; + case PF14: + return !dataIncluded[13]; + case PF15: + return !dataIncluded[14]; + case PF16: + return !dataIncluded[15]; + case PF17: + return !dataIncluded[16]; + 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 + // System.out.println("Help request sent"); + baosp.write(screen52.getCurrentRow()); + baosp.write(screen52.getCurrentCol()); + baosp.write(AID_HELP); + + try { + writeGDS(0, 3, baosp.toByteArray()); + } catch (IOException ioe) { + + 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 1 - ATN Attention + // bits 2-4 - reserved + // 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) { + + Log.w(TAG,ioe.getMessage()); + } + } + + /** + * Opens a dialog and asks the user before sending a request + * + * @see {@link #systemRequest(String)} + */ + public final void systemRequest() { String ask = manager.res.getString(R.string.prompt_sys_request); - String sysreq = bridge.promptHelper.requestStringPrompt(null, ask); - systemRequest(sysreq); - } - - /** - * @param sr - system request option - * @see {@link #systemRequest(String)} - */ - public final void systemRequest(char sr) { - systemRequest(Character.toString(sr)); - } - - /** - * System request, taken from the rfc1205, 5250 Telnet interface section 4.3 - * - * @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)) { - // 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.info(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. - - // Client: sends header with the 000A12A0 00000400 000AFFEF - // Opcode = Cancel Invite to - // indicate that the work station is - // no longer invited. - try { - writeGDS(0, 10, null); - } catch (IOException ioe) { - - log.warn(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 - // - // I have tried with not setting these flags and sending with 3 or 1 - // there is no effect and I still get a host print screen. Go figure - //0000: 000D 12A0 0000 0400 8003 1407 F6FFEF - //0000: 000D 12A0 0000 0400 8001 110E F6FFEF - // - // 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) { - - log.warn(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 - // bit 6 - TRQ Test request key - // bit 7 - HLP - baosrsp.write(0); // reserved - set to 0x00 - baosrsp.write(opcode); // opcode - - 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); - return aids; - } - - private final void setInvited() { - - log.debug("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() - { - 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++) - { - c = planes.getChar(i); - if (Character.isISOControl(c)) - c = ' '; - command.append(c); - } - - String cmd = command.toString().trim(); - - run(cmd, waitFor); - } - finally - { - strpccmd = false; - screen52.sendKeys(TN5250jConstants.MNEMONIC_ENTER); - } - } - - // WVL - LDC : 05/08/2005 : TFX.006253 - Support STRPCCMD - private void run(String cmd, boolean waitFor) - { - try - { - log.debug("RUN cmd = " + cmd); - log.debug("RUN wait = " + waitFor); - - Runtime r = Runtime.getRuntime(); - Process p = r.exec(cmd); - if (waitFor) - { - int result = p.waitFor(); - log.debug("RUN result = " + result); - } - } - catch (Throwable t) - { - log.error(t); - } - } - - - // WVL - LDC : TR.000300 : Callback scenario from 5250 - /** - * Activate or deactivate the command scanning behaviour. - * - * @param scan - * if true, scanning is enabled; disabled otherwise. - * - * @see scan4Cmd() - */ - public void setScanningEnabled(boolean scan) { - this.scan = scan; - } - - // WVL - LDC : TR.000300 : Callback scenario from 5250 - /** - * Checks whether command scanning is enabled. - * - * @return true is command scanning is enabled; false otherwise. - */ - public boolean isScanningEnabled() { - return this.scan; - } - - // WVL - LDC : TR.000300 : Callback scenario from 5250 - /** - * When command scanning is activated, the terminal reads the first and - * second character in the datastream (the zero position allows to - * devisualize the scan stream). If the sequence <code>#!</code> is - * encountered and if this sequence is <strong>not </strong> followed by a - * 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.info("Exec cmd: " + t.getMessage()); - t.printStackTrace(); - } - } - } - - // WVL - LDC : TR.000300 : Callback scenario from 5250 - /** - * The screen is parsed starting from second position until a white space is - * encountered. When found the Session#execCommand(String, int) is - * called with the parsed string. The position immediately following the - * encountered white space, separating the command from the rest of the - * screen, is passed as starting index. - * - * Note that the character at the starting position can potentially be a - * white space itself. The starting position in <code>execCommand</code> - * provided to make the scanning sequence more flexible. We'd like for - * example to embed also a <code>+</code> or <code>-</code> sign to - * indicate whether the tnvt should trigger a repaint or not. This would - * allow the flashing of command sequences without them becoming visible. - * - * <ul> - * <li><strong>PRE </strong> The screen character at position - * <code>STRSCAN + 2</code> is not a white space.</li> - * </ul> - */ - 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.getScreenAsAllChars(); - 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.info("trying to run " + command + " " + remainder); - break; - } - } - } - - public void run() { - - if (enhanced) sfParser = new WTDSFParser(this); - - bk = new Stream5250(); - - while (keepTrucking) { - - try { - bk.initialize((byte[]) dsq.take()); - } catch (InterruptedException ie) { - log.warn(" 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.debug("No operation"); - break; - case 1: - log.debug("Invite Operation"); - parseIncoming(); - // screen52.setKeyboardLocked(false); - pendingUnlock = true; - cursorOn = true; - setInvited(); - break; - case 2: - log.debug("Output Only"); - parseIncoming(); - screen52.updateDirty(); - break; - case 3: - log.debug("Put/Get Operation"); - parseIncoming(); - setInvited(); - if (!firstScreen) { - firstScreen = true; - //controller.fireSessionChanged(TN5250jConstants.STATE_CONNECTED); - } - break; - case 4: - log.debug("Save Screen Operation"); - parseIncoming(); - break; - - case 5: - log.debug("Restore Screen Operation"); - parseIncoming(); - break; - case 6: - log.debug("Read Immediate"); - sendAidKey(0); - break; - case 7: - log.debug("Reserved"); - break; - case 8: - log.debug("Read Screen Operation"); - try { - readScreen(); - } catch (IOException ex) { - log.warn(ex.getMessage()); - } - break; - - case 9: - log.debug("Reserved"); - break; - - case 10: - log.debug("Cancel Invite Operation"); - cancelInvite(); - break; - - case 11: - log.debug("Turn on message light"); - screen52.getOIA().setMessageLightOn(); - screen52.setCursorActive(true); - - break; - case 12: - log.debug("Turn off Message light"); - screen52.getOIA().setMessageLightOff(); - screen52.setCursorActive(true); - - break; - default: - break; - } - - if (screen52.isUsingGuiInterface()) - screen52.drawFields(); - - try { - if (!strpccmd) { - screen52.updateDirty(); - } else { - strpccmd(); - } - } catch (Exception exd) { - log.warn(" tnvt.run: " + exd.getMessage()); - exd.printStackTrace(); - } - - if (pendingUnlock && !screen52.isStatusErrorCode()) { - screen52.getOIA().setKeyBoardLocked(false); - pendingUnlock = false; - } - - if (cursorOn && !screen52.getOIA().isKeyBoardLocked()) { - screen52.setCursorActive(true); - cursorOn = false; - } - - // lets play nicely with the others on the playground - //me.yield(); - Thread.yield(); - - } - } - - public void dumpStuff() { - - if (log.isDebugEnabled()) { - log.debug(" Pending unlock " + pendingUnlock); - log.debug(" Status Error " + screen52.isStatusErrorCode()); - log.debug(" Keyboard Locked " + screen52.getOIA().isKeyBoardLocked()); - log.debug(" Cursor On " + cursorOn); - log.debug(" Cursor Active " + screen52.cursorActive); - } - - } - - - private final void readScreen() throws IOException { - int rows = screen52.getRows(); - int cols = screen52.getColumns(); - byte abyte0[] = new byte[rows * cols]; - fillScreenArray(abyte0, rows, cols); - writeGDS(0, 0, abyte0); - abyte0 = null; - } - - 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 { - 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.info(" 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(guiSeg,0,gsa,sac+2,guiSeg.length); - sa = new byte[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 { - 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) { - - log.info(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 & 0xff)); // "" - - sc.write((byte) (screen52.homePos >> 8 & 0xff)); // save home pos - 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); - // fillScreenArray(sa, rows, cols); - // - // sc.write(sa); - // sa = null; - int sizeFields = screen52.getScreenFields().getSize(); - sc.write((byte) (sizeFields >> 8 & 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 & 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.getFFW1() & 0xff); - sc.write((byte) sf.getFFW2() & 0xff); - sc.write((byte) sf.getFCW1() & 0xff); - sc.write((byte) sf.getFCW2() & 0xff); - log.debug("Saved "); - log.debug(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. - // screen52.getScreenFields().setCurrentField(null); // set it to null - // for GC ? - // screen52.clearTable(); - - try { - writeGDS(0, 3, sc.toByteArray()); - } catch (IOException ioe) { - - log.warn(ioe.getMessage()); - } - - sc = null; - log.debug("Save Screen end "); - } - - /** - * - * @throws IOException - */ - public final void restoreScreen() throws IOException { - int which = 0; - - ScreenPlanes planes = screen52.planes; - - try { - log.debug("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()) - 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.info(" gui restored at " + y + " - " + screen52.getRow(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.debug("number of fields " + numFields); - - if (numFields > 0) { - int x = 0; - int attr = 0; - int fPos = 0; - int fLen = 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); - - } - - if (mdt) { - sf.setMDT(); - screen52.getScreenFields().setMasterMDT(); - } - if (log.isDebugEnabled()) { - log.debug("/nRestored "); - log.debug(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.warn("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 - log.debug("save screen partial"); - saveScreen(); - break; - - case ESC: // ESCAPE - break; - case 7: // audible bell - manager.playBeep(); - bk.getNextByte(); - bk.getNextByte(); - break; - case CMD_WRITE_TO_DISPLAY: // 0x11 17 write to display - error = writeToDisplay(true); - // WVL - LDC : TR.000300 : Callback scenario from 5250 - // Only scan when WRITE_TO_DISPLAY operation (i.e. refill - // screen buffer) - // has been issued! - if (scan) - scan(); - - break; - case CMD_RESTORE_SCREEN: // 0x12 18 Restore Screen - case 13: // 0x13 19 Restore Partial Screen - log.debug("restore screen partial"); - restoreScreen(); - break; - - case CMD_CLEAR_UNIT_ALTERNATE: // 0x20 32 clear unit alternate - int param = bk.getNextByte(); - if (param != 0) { - log.debug(" clear unit alternate error " - + 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; - - case CMD_CLEAR_FORMAT_TABLE: // 80 0x50 Clear format table - screen52.clearTable(); - break; - - case CMD_READ_INPUT_FIELDS: //0x42 66 read input fields - case CMD_READ_MDT_FIELDS: // 0x52 82 read MDT Fields - bk.getNextByte(); - bk.getNextByte(); - readType = b; - screen52.goHome(); - // do nothing with the cursor here it is taken care of - // in the main loop. - //////////////// screen52.setCursorOn(); - waitingForInput = true; - pendingUnlock = true; - // screen52.setKeyboardLocked(false); - 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; - } - // BEGIN FRAMEWORK - // I took this out for debugging a problem - // ScreenField[] a = this.screen52.getScreenFields().getFields(); - // if (log.isDebugEnabled()) { - // for (int x = 0; x < a.length; x++) { - // log.debug(a[x].toString()); - // } - // } - // - // String strokes = this.screen52.getKeys(); - // if (!strokes.equals("")) { - // Tn5250jKeyEvents e = new Tn5250jKeyEvents(this.screen52, - // strokes); - // //from the previous screen. - // Tn5250jController.getCurrent().handleEvent(e); - // } - // - // Tn5250jEvent event = new Tn5250jEvent(screen52); - // Tn5250jController.getCurrent().handleEvent(event); - // - // //END FRAMEWORK - } catch (Exception exc) { - log.warn("incoming " + exc.getMessage()); - } - ; - } - - /** - * This routine handles sending negative responses back to the host. - * - * You can find a description of the types of responses to be sent back by - * looking at section 12.4 of the 5250 Functions Reference manual - * - * - * @param cat - * @param modifier - * @param uByte1 - * @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.info("invalid " + from + " command " + os - + " at pos " + cp); - } catch (Exception e) { - - log.warn("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) { - - log.warn(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) { - - log.warn(ioe.getMessage()); - } - - baosp.reset(); - } - - private boolean writeToDisplay(boolean controlsExist) { - - boolean error = false; - boolean done = false; - int attr; - byte control0 = 0; - byte control1 = 0; - int saRows = screen52.getRows(); - int saCols = screen52.getColumns(); - - try { - 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 - log.debug("SOH - Start of Header Order"); - error = processSOH(); - - break; - case 02: // RA - Repeat to address - log.debug("RA - Repeat to address"); - int row = screen52.getCurrentRow(); - int col = screen52.getCurrentCol(); - - int toRow = bk.getNextByte(); - int toCol = bk.getNextByte() & 0xff; - if (toRow >= row) { - 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.debug("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; - case 04: // Command - Escape - log.debug("Command - Escape"); - done = true; - break; - - case 16: // TD - Transparent Data - log.debug("TD - Transparent Data"); - int j = (bk.getNextByte() & 0xff) << 8 | bk.getNextByte() - & 0xff; // length - break; - - case 17: // SBA - set buffer address order (row column) - log.debug("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.debug("WEA - Extended Attribute"); - bk.getNextByte(); - bk.getNextByte(); - break; - - case 19: // IC - Insert Cursor - log.debug("IC - Insert Cursor"); - int icX = bk.getNextByte(); - int icY = bk.getNextByte() & 0xff; - if (icX >= 0 && icX <= saRows && icY >= 0 && icY <= saCols) { - - log.debug(" 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.debug("MC - Move Cursor"); - int imcX = bk.getNextByte(); - int imcY = bk.getNextByte() & 0xff; - if (imcX >= 0 && imcX <= saRows && imcY >= 0 - && imcY <= saCols) { - - log.debug(" 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.debug("WTDSF - Write To Display Structured Field order"); - byte[] seg = bk.getSegment(); - error = sfParser.parseWriteToDisplayStructuredField(seg); - break; - - case 29: // SF - Start of Field - log.debug("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.info(Integer.toHexString(fcw1) + " " - + Integer.toHexString(fcw2) - + " "); - log.info(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; - } - - int fLength = (bk.getNextByte() & 0xff) << 8 - | 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.debug("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.debug("all others must be output to screen"); - byte byte0 = bk.getByteOffset(-1); - if (isAttribute(byte0)) { - screen52.setAttr(byte0); - } else { - 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)); - } - } - - break; - } - - if (error) - done = true; - } - } - - catch (Exception e) { - log.warn("write to display " + e.getMessage()); - e.printStackTrace(); - } - ; - - processCC1(control1); - - return error; - - } - - private boolean processSOH() throws Exception { - - int l = bk.getNextByte(); // length - log.debug(" 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[20] = (byte1 & 0x10) == 0x10; - dataIncluded[19] = (byte1 & 0x8) == 0x8; - dataIncluded[18] = (byte1 & 0x4) == 0x4; - dataIncluded[17] = (byte1 & 0x2) == 0x2; - dataIncluded[16] = (byte1 & 0x1) == 0x1; - } - - if (l >= 6) { - byte1 = bk.getNextByte(); - dataIncluded[15] = (byte1 & 0x80) == 0x80; - dataIncluded[14] = (byte1 & 0x40) == 0x40; - dataIncluded[13] = (byte1 & 0x20) == 0x20; - dataIncluded[12] = (byte1 & 0x10) == 0x10; - dataIncluded[11] = (byte1 & 0x8) == 0x8; - dataIncluded[10] = (byte1 & 0x4) == 0x4; - dataIncluded[9] = (byte1 & 0x2) == 0x2; - dataIncluded[8] = (byte1 & 0x1) == 0x1; - } - - if (l >= 7) { - byte1 = bk.getNextByte(); - dataIncluded[7] = (byte1 & 0x80) == 0x80; - dataIncluded[6] = (byte1 & 0x40) == 0x40; - dataIncluded[5] = (byte1 & 0x20) == 0x20; - dataIncluded[4] = (byte1 & 0x10) == 0x10; - dataIncluded[3] = (byte1 & 0x8) == 0x8; - dataIncluded[2] = (byte1 & 0x4) == 0x4; - dataIncluded[1] = (byte1 & 0x2) == 0x2; - dataIncluded[0] = (byte1 & 0x1) == 0x1; - } - return false; - } else { - sendNegResponse(NR_REQUEST_ERROR, 0x05, 0x01, 0x2B, - "invalid SOH length"); - return true; - } - - } - - private void processCC0(byte byte0) { - log.debug(" Control byte0 " + Integer.toBinaryString(byte0 & 0xff)); - boolean lockKeyboard = true; - boolean resetMDT = false; - boolean resetMDTAll = false; - boolean nullMDT = false; - boolean nullAll = false; - - // Bits 3 to 6 are reserved and should be set to '0000' - // 0xE0 = '11100000' - only the first 3 bits are tested - if ((byte0 & 0xE0) == 0x00) { - lockKeyboard = false; - } - - // '00100000' = 0x20 /32 -- just lock keyboard - // '01000000' = 0x40 /64 - // '01100000' = 0x60 /96 - // '10000000' = 0x80 /128 - // '10100000' = 0xA0 /160 - // '11000000' = 0xC0 /192 - // '11100000' = 0xE0 /224 - - switch (byte0 & 0xE0) { - - case 0x40: - resetMDT = true; - break; - case 0x60: - resetMDTAll = true; - break; - case 0x80: - nullMDT = true; - break; - case 0xA0: - resetMDT = true; - nullAll = true; - break; - case 0xC0: - resetMDT = true; - nullMDT = true; - break; - - case 0xE0: - resetMDTAll = true; - nullAll = true; - break; - - } - - if (lockKeyboard) { - screen52.getOIA().setKeyBoardLocked(true); - pendingUnlock = false; - } 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.debug(" 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) { - screen52.getOIA().setMessageLightOn(); - } - - // reset blinking cursor seems to control whether to set or not set the - // the cursor position. No documentation for this just testing and - // looking at the bit settings of this field. This was a pain in the - // ass! - // - // if it is off '0' then keep existing cursor positioning information - // 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.debug(" WTD position no move"); - } else { - - screen52.setPendingInsert(true); - log.debug(" 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 - // This is normally the inverse of isDataEBCDIC (That's why there is a - // check on 255 -> 0xFFFF - 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 - - switch (bk.getNextByte()) { - case 112: // 5250 Query - bk.getNextByte(); // get null required field - sendQueryResponse(); - break; - default: - log.debug("invalid structured field sub command " - + bk.getByteOffset(-1)); - break; - } - break; - default: - log.debug("invalid structured field command " - + bk.getByteOffset(-1)); - break; - } - } - } 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 - * - * The query command is used to obtain information about the capabilities of - * the 5250 display. - * - * The Query command must follow an Escape (0x04) and Write Structured Field - * command (0xF3). - * - * This section is modeled after the rfc1205 - 5250 Telnet Interface section - * 5.3 - * - * @throws IOException - */ - private final void sendQueryResponse() throws IOException { - - log.info("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 { - 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[18] = 0; // "" - abyte0[19] = 0; // "" - abyte0[20] = 0; // "" - abyte0[21] = 0; // "" - abyte0[22] = 0; // "" - abyte0[23] = 0; // "" - abyte0[24] = 0; // "" - abyte0[25] = 0; // "" - abyte0[26] = 0; // "" - abyte0[27] = 0; // "" - abyte0[28] = 0; // "" - abyte0[29] = 1; // Device type - 0x01 5250 Emulator - abyte0[30] = codePage.uni2ebcdic('5'); // Device type character - abyte0[31] = codePage.uni2ebcdic('2'); // "" - 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; - abyte0[49] = 1; // 49 - 53 Controller Display Capability - abyte0[50] = 17; // see rfc - tired of typing :-) - abyte0[51] = 0; // "" - abyte0[52] = 0; // "" - - // 53 - // Bit 0-2: B'000' - no graphics capability - // B'001' - 5292-2 style graphics - // Bit 3-7: B '00000' = reserved (it seems for Client access) - - 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.info("enhanced options"); - } 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 - // and footers for windows - abyte0[54] = 8; // 54 - 60 Reserved set to 0x00 - // 54 - I found out is used for enhanced user - // interface level 3. Bit 4 allows headers - // and footers for windows - abyte0[55] = 0; - abyte0[56] = 0; - abyte0[57] = 0; - abyte0[58] = 0; - abyte0[59] = 0; - abyte0[60] = 0; - 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 - - while(i < abyte0.length && abyte0[i++] == -1) - // while(i < abyte0.length && (abyte0[i] == -1 || abyte0[i++] == 0x20)) - switch(abyte0[i++]) { - - // we will not worry about what it WONT do - case WONT: // -4 - default: - break; - - case DO: //-3 - - // not sure why but since moving to V5R2 we are receiving a - // DO with no option when connecting a second session with - // device name. Can not find the cause at all. If anybody - // is interested please debug this until then this works. - if (i < abyte0.length) { - switch(abyte0[i]) { - 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(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++; - } - 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); - - // http://tools.ietf.org/html/rfc4777 - - 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()); - - if (password != null) { - baosp.write(USERVAR); - baosp.write("IBMRSEED".getBytes()); - baosp.write(VALUE); - baosp.write(NEGOTIATE_ESC); - baosp.write(0x0); - baosp.write(0x0); - baosp.write(0x0); - baosp.write(0x0); - baosp.write(0x0); - baosp.write(0x0); - baosp.write(0x0); - baosp.write(0x0); - baosp.write(USERVAR); - baosp.write("IBMSUBSPW".getBytes()); - baosp.write(VALUE); - baosp.write(password.getBytes()); - } - - if (library != null) { - baosp.write(USERVAR); - baosp.write("IBMCURLIB".getBytes()); - baosp.write(VALUE); - baosp.write(library.getBytes()); - } - - if (initialMenu != null) { - baosp.write(USERVAR); - baosp.write("IBMIMENU".getBytes()); - baosp.write(VALUE); - baosp.write(initialMenu.getBytes()); - } - - if (program != null) { - baosp.write(USERVAR); - 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 - * unsuccessful attempt a sequential number is appended until we find one or - * the controller says no way. - * - * @return String - */ - private String negDeviceName() { - - if (devSeq++ == -1) { - devNameUsed = devName; - return devName; - } 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)) { - kbdTypesCodePage = kbdtyp; - break; - } - } - if (log.isInfoEnabled()) { - log.info("Choosed keyboard mapping " + kbdTypesCodePage.toString() + " for code page " + cp); - } - } - - public final ICodePage getCodePage() { - return codePage; - } - - public void signalBell() { - manager.playBeep(); - } + String sysreq = bridge.promptHelper.requestStringPrompt(null, ask); + systemRequest(sysreq); + } + + /** + * @param sr - system request option + * @see {@link #systemRequest(String)} + */ + public final void systemRequest(char sr) { + systemRequest(Character.toString(sr)); + } + + /** + * System request, taken from the rfc1205, 5250 Telnet interface section 4.3 + * + * @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)) { + // 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()); + } + 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. + + // Client: sends header with the 000A12A0 00000400 000AFFEF + // Opcode = Cancel Invite to + // indicate that the work station is + // no longer invited. + try { + writeGDS(0, 10, null); + } catch (IOException ioe) { + + 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 + // + // I have tried with not setting these flags and sending with 3 or 1 + // there is no effect and I still get a host print screen. Go figure + //0000: 000D 12A0 0000 0400 8003 1407 F6FFEF + //0000: 000D 12A0 0000 0400 8001 110E F6FFEF + // + // 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) { + + 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 + // bit 6 - TRQ Test request key + // bit 7 - HLP + baosrsp.write(0); // reserved - set to 0x00 + baosrsp.write(opcode); // opcode + + 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); + return aids; + } + + private final void setInvited() { + + 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() + { + 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++) + { + c = planes.getChar(i); + if (Character.isISOControl(c)) + c = ' '; + command.append(c); + } + + String cmd = command.toString().trim(); + + run(cmd, waitFor); + } + finally + { + strpccmd = false; + screen52.sendKeys(TN5250jConstants.MNEMONIC_ENTER); + } + } + + // WVL - LDC : 05/08/2005 : TFX.006253 - Support STRPCCMD + private void run(String cmd, boolean waitFor) + { + try + { + Log.d(TAG,"RUN cmd = " + cmd); + Log.d(TAG,"RUN wait = " + waitFor); + + Runtime r = Runtime.getRuntime(); + Process p = r.exec(cmd); + if (waitFor) + { + int result = p.waitFor(); + Log.d(TAG,"RUN result = " + result); + } + } + catch (Throwable t) + { + Log.e(TAG,t); + } + } + + + // WVL - LDC : TR.000300 : Callback scenario from 5250 + /** + * Activate or deactivate the command scanning behaviour. + * + * @param scan + * if true, scanning is enabled; disabled otherwise. + * + * @see scan4Cmd() + */ + public void setScanningEnabled(boolean scan) { + this.scan = scan; + } + + // WVL - LDC : TR.000300 : Callback scenario from 5250 + /** + * Checks whether command scanning is enabled. + * + * @return true is command scanning is enabled; false otherwise. + */ + public boolean isScanningEnabled() { + return this.scan; + } + + // WVL - LDC : TR.000300 : Callback scenario from 5250 + /** + * When command scanning is activated, the terminal reads the first and + * second character in the datastream (the zero position allows to + * devisualize the scan stream). If the sequence <code>#!</code> is + * encountered and if this sequence is <strong>not </strong> followed by a + * 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()); + t.printStackTrace(); + } + } + } + + // WVL - LDC : TR.000300 : Callback scenario from 5250 + /** + * The screen is parsed starting from second position until a white space is + * encountered. When found the Session#execCommand(String, int) is + * called with the parsed string. The position immediately following the + * encountered white space, separating the command from the rest of the + * screen, is passed as starting index. + * + * Note that the character at the starting position can potentially be a + * white space itself. The starting position in <code>execCommand</code> + * provided to make the scanning sequence more flexible. We'd like for + * example to embed also a <code>+</code> or <code>-</code> sign to + * indicate whether the tnvt should trigger a repaint or not. This would + * allow the flashing of command sequences without them becoming visible. + * + * <ul> + * <li><strong>PRE </strong> The screen character at position + * <code>STRSCAN + 2</code> is not a white space.</li> + * </ul> + */ + 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.getScreenAsAllChars(); + 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); + break; + } + } + } + + public void run() { + + if (enhanced) sfParser = new WTDSFParser(this); + + bk = new Stream5250(); + + while (keepTrucking) { + + try { + bk.initialize((byte[]) dsq.take()); + } 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"); + break; + case 1: + Log.d(TAG,"Invite Operation"); + parseIncoming(); + // screen52.setKeyboardLocked(false); + pendingUnlock = true; + cursorOn = true; + setInvited(); + break; + case 2: + Log.d(TAG,"Output Only"); + parseIncoming(); + screen52.updateDirty(); + break; + case 3: + Log.d(TAG,"Put/Get Operation"); + parseIncoming(); + setInvited(); + if (!firstScreen) { + firstScreen = true; + //controller.fireSessionChanged(TN5250jConstants.STATE_CONNECTED); + } + break; + case 4: + Log.d(TAG,"Save Screen Operation"); + parseIncoming(); + break; + + case 5: + Log.d(TAG,"Restore Screen Operation"); + parseIncoming(); + break; + case 6: + Log.d(TAG,"Read Immediate"); + sendAidKey(0); + break; + case 7: + Log.d(TAG,"Reserved"); + break; + case 8: + Log.d(TAG,"Read Screen Operation"); + try { + readScreen(); + } catch (IOException ex) { + Log.w(TAG,ex.getMessage()); + } + break; + + case 9: + Log.d(TAG,"Reserved"); + break; + + case 10: + Log.d(TAG,"Cancel Invite Operation"); + cancelInvite(); + break; + + case 11: + 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 { + strpccmd(); + } + } catch (Exception exd) { + Log.w(TAG," tnvt.run: " + exd.getMessage()); + exd.printStackTrace(); + } + + if (pendingUnlock && !screen52.isStatusErrorCode()) { + screen52.getOIA().setKeyBoardLocked(false); + pendingUnlock = false; + } + + if (cursorOn && !screen52.getOIA().isKeyBoardLocked()) { + screen52.setCursorActive(true); + cursorOn = 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," Status Error " + screen52.isStatusErrorCode()); + Log.d(TAG," Keyboard Locked " + screen52.getOIA().isKeyBoardLocked()); + Log.d(TAG," Cursor On " + cursorOn); + Log.d(TAG," Cursor Active " + screen52.cursorActive); + } + + + private final void readScreen() throws IOException { + int rows = screen52.getRows(); + int cols = screen52.getColumns(); + byte abyte0[] = new byte[rows * cols]; + fillScreenArray(abyte0, rows, cols); + writeGDS(0, 0, abyte0); + abyte0 = null; + } + + 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 { + 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(guiSeg,0,gsa,sac+2,guiSeg.length); + sa = new byte[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 { + 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) { + + 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 & 0xff)); // "" + + sc.write((byte) (screen52.homePos >> 8 & 0xff)); // save home pos + 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); + // fillScreenArray(sa, rows, cols); + // + // sc.write(sa); + // sa = null; + int sizeFields = screen52.getScreenFields().getSize(); + sc.write((byte) (sizeFields >> 8 & 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 & 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.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,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. + // screen52.getScreenFields().setCurrentField(null); // set it to null + // for GC ? + // screen52.clearTable(); + + try { + writeGDS(0, 3, sc.toByteArray()); + } catch (IOException ioe) { + + Log.w(TAG,ioe.getMessage()); + } + + sc = null; + 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 "); + + 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()) + 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) + "," + + 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); + + if (numFields > 0) { + int x = 0; + int attr = 0; + int fPos = 0; + int fLen = 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); + + } + + if (mdt) { + sf.setMDT(); + screen52.getScreenFields().setMasterMDT(); + } + 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 " + + 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 + Log.d(TAG,"save screen partial"); + saveScreen(); + break; + + case ESC: // ESCAPE + break; + case 7: // audible bell + manager.playBeep(); + bk.getNextByte(); + bk.getNextByte(); + break; + case CMD_WRITE_TO_DISPLAY: // 0x11 17 write to display + error = writeToDisplay(true); + // WVL - LDC : TR.000300 : Callback scenario from 5250 + // Only scan when WRITE_TO_DISPLAY operation (i.e. refill + // screen buffer) + // has been issued! + if (scan) + scan(); + + break; + case CMD_RESTORE_SCREEN: // 0x12 18 Restore Screen + case 13: // 0x13 19 Restore Partial Screen + Log.d(TAG,"restore screen partial"); + restoreScreen(); + break; + + case CMD_CLEAR_UNIT_ALTERNATE: // 0x20 32 clear unit alternate + int param = bk.getNextByte(); + if (param != 0) { + Log.d(TAG," clear unit alternate error " + + 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; + + case CMD_CLEAR_FORMAT_TABLE: // 80 0x50 Clear format table + screen52.clearTable(); + break; + + case CMD_READ_INPUT_FIELDS: //0x42 66 read input fields + case CMD_READ_MDT_FIELDS: // 0x52 82 read MDT Fields + bk.getNextByte(); + bk.getNextByte(); + readType = b; + screen52.goHome(); + // do nothing with the cursor here it is taken care of + // in the main loop. + //////////////// screen52.setCursorOn(); + waitingForInput = true; + pendingUnlock = true; + // screen52.setKeyboardLocked(false); + 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()); + } + } + + /** + * This routine handles sending negative responses back to the host. + * + * You can find a description of the types of responses to be sent back by + * looking at section 12.4 of the 5250 Functions Reference manual + * + * + * @param cat + * @param modifier + * @param uByte1 + * @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 + + " at pos " + cp); + } catch (Exception e) { + + 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) { + + 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) { + + 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; + int saRows = screen52.getRows(); + int saCols = screen52.getColumns(); + + try { + 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 + Log.d(TAG,"SOH - Start of Header Order"); + error = processSOH(); + + break; + case 02: // RA - Repeat to address + Log.d(TAG,"RA - Repeat to address"); + int row = screen52.getCurrentRow(); + int col = screen52.getCurrentCol(); + + int toRow = bk.getNextByte(); + int toCol = bk.getNextByte() & 0xff; + if (toRow >= row) { + 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 (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; + 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 { + attr = ffw0; + } + + int fLength = (bk.getNextByte() & 0xff) << 8 + | 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); + } else { + 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)); + } + } + + break; + } + + if (error) + done = true; + } + } + + catch (Exception e) { + 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); + + 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[20] = (byte1 & 0x10) == 0x10; + dataIncluded[19] = (byte1 & 0x8) == 0x8; + dataIncluded[18] = (byte1 & 0x4) == 0x4; + dataIncluded[17] = (byte1 & 0x2) == 0x2; + dataIncluded[16] = (byte1 & 0x1) == 0x1; + } + + if (l >= 6) { + byte1 = bk.getNextByte(); + dataIncluded[15] = (byte1 & 0x80) == 0x80; + dataIncluded[14] = (byte1 & 0x40) == 0x40; + dataIncluded[13] = (byte1 & 0x20) == 0x20; + dataIncluded[12] = (byte1 & 0x10) == 0x10; + dataIncluded[11] = (byte1 & 0x8) == 0x8; + dataIncluded[10] = (byte1 & 0x4) == 0x4; + dataIncluded[9] = (byte1 & 0x2) == 0x2; + dataIncluded[8] = (byte1 & 0x1) == 0x1; + } + + if (l >= 7) { + byte1 = bk.getNextByte(); + dataIncluded[7] = (byte1 & 0x80) == 0x80; + dataIncluded[6] = (byte1 & 0x40) == 0x40; + dataIncluded[5] = (byte1 & 0x20) == 0x20; + dataIncluded[4] = (byte1 & 0x10) == 0x10; + dataIncluded[3] = (byte1 & 0x8) == 0x8; + dataIncluded[2] = (byte1 & 0x4) == 0x4; + dataIncluded[1] = (byte1 & 0x2) == 0x2; + dataIncluded[0] = (byte1 & 0x1) == 0x1; + } + return false; + } 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)); + boolean lockKeyboard = true; + boolean resetMDT = false; + boolean resetMDTAll = false; + boolean nullMDT = false; + boolean nullAll = false; + + // Bits 3 to 6 are reserved and should be set to '0000' + // 0xE0 = '11100000' - only the first 3 bits are tested + if ((byte0 & 0xE0) == 0x00) { + lockKeyboard = false; + } + + // '00100000' = 0x20 /32 -- just lock keyboard + // '01000000' = 0x40 /64 + // '01100000' = 0x60 /96 + // '10000000' = 0x80 /128 + // '10100000' = 0xA0 /160 + // '11000000' = 0xC0 /192 + // '11100000' = 0xE0 /224 + + switch (byte0 & 0xE0) { + + case 0x40: + resetMDT = true; + break; + case 0x60: + resetMDTAll = true; + break; + case 0x80: + nullMDT = true; + break; + case 0xA0: + resetMDT = true; + nullAll = true; + break; + case 0xC0: + resetMDT = true; + nullMDT = true; + break; + + case 0xE0: + resetMDTAll = true; + nullAll = true; + break; + + } + + if (lockKeyboard) { + screen52.getOIA().setKeyBoardLocked(true); + pendingUnlock = false; + } 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)); + + 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) { + screen52.getOIA().setMessageLightOn(); + } + + // reset blinking cursor seems to control whether to set or not set the + // the cursor position. No documentation for this just testing and + // looking at the bit settings of this field. This was a pain in the + // ass! + // + // if it is off '0' then keep existing cursor positioning information + // 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"); + } else { + + screen52.setPendingInsert(true); + 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 + // This is normally the inverse of isDataEBCDIC (That's why there is a + // check on 255 -> 0xFFFF + 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 + + switch (bk.getNextByte()) { + case 112: // 5250 Query + bk.getNextByte(); // get null required field + sendQueryResponse(); + break; + default: + Log.d(TAG,"invalid structured field sub command " + + bk.getByteOffset(-1)); + break; + } + break; + default: + Log.d(TAG,"invalid structured field command " + + bk.getByteOffset(-1)); + break; + } + } + } 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 + * + * The query command is used to obtain information about the capabilities of + * the 5250 display. + * + * The Query command must follow an Escape (0x04) and Write Structured Field + * command (0xF3). + * + * This section is modeled after the rfc1205 - 5250 Telnet Interface section + * 5.3 + * + * @throws IOException + */ + private final void sendQueryResponse() throws IOException { + + 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 { + 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[18] = 0; // "" + abyte0[19] = 0; // "" + abyte0[20] = 0; // "" + abyte0[21] = 0; // "" + abyte0[22] = 0; // "" + abyte0[23] = 0; // "" + abyte0[24] = 0; // "" + abyte0[25] = 0; // "" + abyte0[26] = 0; // "" + abyte0[27] = 0; // "" + abyte0[28] = 0; // "" + abyte0[29] = 1; // Device type - 0x01 5250 Emulator + abyte0[30] = codePage.uni2ebcdic('5'); // Device type character + abyte0[31] = codePage.uni2ebcdic('2'); // "" + 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; + abyte0[49] = 1; // 49 - 53 Controller Display Capability + abyte0[50] = 17; // see rfc - tired of typing :-) + abyte0[51] = 0; // "" + abyte0[52] = 0; // "" + + // 53 + // Bit 0-2: B'000' - no graphics capability + // B'001' - 5292-2 style graphics + // Bit 3-7: B '00000' = reserved (it seems for Client access) + + 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"); + } 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 + // and footers for windows + abyte0[54] = 8; // 54 - 60 Reserved set to 0x00 + // 54 - I found out is used for enhanced user + // interface level 3. Bit 4 allows headers + // and footers for windows + abyte0[55] = 0; + abyte0[56] = 0; + abyte0[57] = 0; + abyte0[58] = 0; + abyte0[59] = 0; + abyte0[60] = 0; + 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 + + while(i < abyte0.length && abyte0[i++] == -1) + // while(i < abyte0.length && (abyte0[i] == -1 || abyte0[i++] == 0x20)) + switch(abyte0[i++]) { + + // we will not worry about what it WONT do + case WONT: // -4 + default: + break; + + case DO: //-3 + + // not sure why but since moving to V5R2 we are receiving a + // DO with no option when connecting a second session with + // device name. Can not find the cause at all. If anybody + // is interested please debug this until then this works. + if (i < abyte0.length) { + switch(abyte0[i]) { + 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(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++; + } + 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); + + // http://tools.ietf.org/html/rfc4777 + + 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()); + + if (password != null) { + baosp.write(USERVAR); + baosp.write("IBMRSEED".getBytes()); + baosp.write(VALUE); + baosp.write(NEGOTIATE_ESC); + baosp.write(0x0); + baosp.write(0x0); + baosp.write(0x0); + baosp.write(0x0); + baosp.write(0x0); + baosp.write(0x0); + baosp.write(0x0); + baosp.write(0x0); + baosp.write(USERVAR); + baosp.write("IBMSUBSPW".getBytes()); + baosp.write(VALUE); + baosp.write(password.getBytes()); + } + + if (library != null) { + baosp.write(USERVAR); + baosp.write("IBMCURLIB".getBytes()); + baosp.write(VALUE); + baosp.write(library.getBytes()); + } + + if (initialMenu != null) { + baosp.write(USERVAR); + baosp.write("IBMIMENU".getBytes()); + baosp.write(VALUE); + baosp.write(initialMenu.getBytes()); + } + + if (program != null) { + baosp.write(USERVAR); + 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 + * unsuccessful attempt a sequential number is appended until we find one or + * the controller says no way. + * + * @return String + */ + private String negDeviceName() { + + if (devSeq++ == -1) { + devNameUsed = devName; + return devName; + } 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)) { + kbdTypesCodePage = kbdtyp; + break; + } + } + Log.i(TAG,"Chose keyboard mapping " + kbdTypesCodePage.toString() + " for code page " + cp); + } + + public final ICodePage getCodePage() { + return codePage; + } + + public void signalBell() { + manager.playBeep(); + } }
--- a/src/org/tn5250j/framework/transport/SSL/SSLImplementation.java Tue Jun 03 11:44:37 2014 -0700 +++ b/src/org/tn5250j/framework/transport/SSL/SSLImplementation.java Tue Jun 03 12:10:21 2014 -0700 @@ -44,8 +44,8 @@ import org.tn5250j.GlobalConfigure; import org.tn5250j.framework.transport.SSLInterface; -import org.tn5250j.tools.logging.TN5250jLogFactory; -import org.tn5250j.tools.logging.TN5250jLogger; +import android.util.Log; + /** * <p> @@ -81,7 +81,7 @@ public SSLImplementation(TerminalBridge bridge, TerminalManager manager) { this.bridge = bridge; this.manager = manager; - logger = TN5250jLogFactory.getLogger(getClass()); + } public void init(String sslType) {
--- a/src/org/tn5250j/framework/transport/SocketConnector.java Tue Jun 03 11:44:37 2014 -0700 +++ b/src/org/tn5250j/framework/transport/SocketConnector.java Tue Jun 03 12:10:21 2014 -0700 @@ -30,8 +30,8 @@ import org.tn5250j.framework.transport.SSL.SSLImplementation; import org.tn5250j.TN5250jConstants; -import org.tn5250j.tools.logging.TN5250jLogFactory; -import org.tn5250j.tools.logging.TN5250jLogger; +import android.util.Log; + public class SocketConnector { @@ -43,7 +43,7 @@ * Creates a new instance that creates a plain socket by default. */ public SocketConnector() { - logger = TN5250jLogFactory.getLogger(getClass()); + } /**
--- a/src/org/tn5250j/tools/logging/Log4jLogger.java Tue Jun 03 11:44:37 2014 -0700 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,159 +0,0 @@ -/* - * @(#)Log4jLogger.java - * @author Kenneth J. Pouncey - * - * Copyright: Copyright (c) 2001, 2002, 2003 - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2, or (at your option) - * any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this software; see the file COPYING. If not, write to - * the Free Software Foundation, Inc., 59 Temple Place, Suite 330, - * Boston, MA 02111-1307 USA - * - */ -package org.tn5250j.tools.logging; - -import org.apache.log4j.Level; -import org.apache.log4j.Logger; - -/** - * An implementation of the TN5250jLogger to provide log4j logger instances. - */ -public final class Log4jLogger implements TN5250jLogger { - - private Logger log = null; - - /* - * Package level access only - */ - Log4jLogger() { - - } - - public void initialize(final String clazz) { - log = Logger.getLogger(clazz); - } - - public void debug(Object message) { - log.debug(message); - } - - public void debug(Object message, Throwable throwable) { - log.debug(message, throwable); - } - - public void info(Object message) { - log.info(message); - } - - public void info(Object message, Throwable throwable) { - log.info(message, throwable); - } - - public void warn(Object message) { - log.warn(message); - } - - public void warn(Object message, Throwable throwable) { - log.warn(message, throwable); - } - - public void error(Object message) { - log.error(message); - } - - public void error(Object message, Throwable throwable) { - log.error(message, throwable); - } - - public void fatal(Object message) { - log.fatal(message); - } - - public void fatal(Object message, Throwable throwable) { - log.fatal(message, throwable); - } - - public boolean isDebugEnabled() { - return log.isDebugEnabled(); - } - - public boolean isInfoEnabled() { - return log.isInfoEnabled(); - } - - public boolean isWarnEnabled() { - return (Level.WARN.equals(log.getLevel())); - } - - public boolean isFatalEnabled() { - return (Level.FATAL.equals(log.getLevel())); - } - - public boolean isErrorEnabled() { - return (Level.ERROR.equals(log.getLevel())); - } - - public void setLevel(int newLevel) { - - switch (newLevel) { - case OFF: - log.setLevel(Level.OFF); - break; - - case DEBUG: - log.setLevel(Level.DEBUG); - break; - - case INFO: - log.setLevel(Level.INFO); - break; - - case WARN: - log.setLevel(Level.WARN); - break; - - case ERROR: - log.setLevel(Level.ERROR); - break; - - case FATAL: - log.setLevel(Level.FATAL); - break; - } - - } - - public int getLevel() { - - switch (log.getLevel().toInt()) { - - case (org.apache.log4j.Level.DEBUG_INT): - return DEBUG; - - case (org.apache.log4j.Level.INFO_INT): - return INFO; - - case (org.apache.log4j.Level.WARN_INT): - return WARN; - - case (org.apache.log4j.Level.ERROR_INT): - return ERROR; - - case (org.apache.log4j.Level.FATAL_INT): - return FATAL; - default: - return WARN; - } - - } -} \ No newline at end of file
--- a/src/org/tn5250j/tools/logging/TN5250jLogFactory.java Tue Jun 03 11:44:37 2014 -0700 +++ b/src/org/tn5250j/tools/logging/TN5250jLogFactory.java Tue Jun 03 12:10:21 2014 -0700 @@ -24,7 +24,7 @@ import java.util.*; -import org.tn5250j.tools.logging.TN5250jLogger; + import org.tn5250j.interfaces.ConfigureFactory; /**