Mercurial > 510Connectbot

comparison src/org/tn5250j/framework/tn5250/tnvt.java @ 392:7ac1a0b02f44

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
add test buffer changed when input stream runs dry, similar to async test
author Carl Byington <carl@five-ten-sg.com>
date Tue, 16 Sep 2014 16:22:41 -0700
parents d26faad31533
children d3c5480e8441
comparison
equal deleted inserted replaced
391:bcbd579253a1 392:7ac1a0b02f44
830 return aids; 830 return aids;
831 } 831 }
832 832
833 private final void setInvited() { 833 private final void setInvited() {
834 Log.d(TAG, "invited"); 834 Log.d(TAG, "invited");
835
836 if (!screen52.isStatusErrorCode()) 835 if (!screen52.isStatusErrorCode())
837 screen52.getOIA().setInputInhibited(ScreenOIA.INPUTINHIBITED_NOTINHIBITED, 836 screen52.getOIA().setInputInhibited(ScreenOIA.INPUTINHIBITED_NOTINHIBITED,
838 ScreenOIA.OIA_LEVEL_INPUT_INHIBITED); 837 ScreenOIA.OIA_LEVEL_INPUT_INHIBITED);
839
840 invited = true; 838 invited = true;
839 buffer.testChanged();
841 } 840 }
842 841
843 // WVL - LDC : 05/08/2005 : TFX.006253 - Support STRPCCMD 842 // WVL - LDC : 05/08/2005 : TFX.006253 - Support STRPCCMD
844 private void strpccmd() { 843 private void strpccmd() {
845 try { 844 try {
984 bk = new Stream5250(); 983 bk = new Stream5250();
985 984
986 while (keepTrucking) { 985 while (keepTrucking) {
987 try { 986 try {
988 Object e = dsq.take(); 987 Object e = dsq.take();
988
989 if ((e instanceof Integer) && ((Integer)e == 0)) {
990 buffer.testChanged();
991 continue;
992 };
993
989 bk.initialize((byte[])e); 994 bk.initialize((byte[])e);
990 } 995 }
991 catch (InterruptedException ie) { 996 catch (InterruptedException ie) {
992 Log.w(TAG, " vt thread interrupted and stopping "); 997 Log.w(TAG, " vt thread interrupted and stopping ");
993 keepTrucking = false; 998 keepTrucking = false;
994 continue; 999 continue;
995 } 1000 }
996 1001
997 invited = false; 1002 invited = false;
998 screen52.setCursorActive(false); 1003 screen52.setCursorActive(false);
999
1000 if (bk == null) continue; 1004 if (bk == null) continue;
1001 1005
1002 switch (bk.getOpCode()) { 1006 switch (bk.getOpCode()) {
1003 case 00: 1007 case 00:
1004 Log.d(TAG, "No operation"); 1008 Log.d(TAG, "No operation");
1103 } 1107 }
1104 1108
1105 if (pendingUnlock && !screen52.isStatusErrorCode()) { 1109 if (pendingUnlock && !screen52.isStatusErrorCode()) {
1106 screen52.getOIA().setKeyBoardLocked(false); 1110 screen52.getOIA().setKeyBoardLocked(false);
1107 pendingUnlock = false; 1111 pendingUnlock = false;
1108 buffer.testChanged();
1109 } 1112 }
1110 1113
1111 if (cursorOn && !screen52.getOIA().isKeyBoardLocked()) { 1114 if (cursorOn && !screen52.getOIA().isKeyBoardLocked()) {
1112 screen52.setCursorActive(true); 1115 screen52.setCursorActive(true);
1113 cursorOn = false; 1116 cursorOn = false;