Mercurial > 510Connectbot
comparison src/org/tn5250j/framework/tn5250/tnvt.java @ 392:7ac1a0b02f44
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; |