# HG changeset patch
# User Carl Byington <carl@five-ten-sg.com>
# Date 1404841600 25200
# Node ID c438c2ff005256490cc47b3d582f64e343543133
# Parent  2bdc413623b2ca3a1c5840aa0e4e961cf6d8603b
remove unnecessary socket run dry flagging

diff -r 2bdc413623b2 -r c438c2ff0052 src/org/tn5250j/framework/tn5250/DataStreamProducer.java
--- a/src/org/tn5250j/framework/tn5250/DataStreamProducer.java	Tue Jul 08 10:35:14 2014 -0700
+++ b/src/org/tn5250j/framework/tn5250/DataStreamProducer.java	Tue Jul 08 10:46:40 2014 -0700
@@ -146,12 +146,6 @@
         int i = 0;
 
         while (!done) {
-            try {
-                if (bin.available() == 0) dsq.put(new Integer(0));  // trigger buffer.testChanged()
-            }
-            catch (Exception ex) {
-                Log.w(TAG, "readIncoming error " + ex.getMessage());
-            }
             i = bin.read();
 
             // WVL - LDC : 16/07/2003 : TR.000345
@@ -224,12 +218,6 @@
 
         if (negotiate) {
             // get the negotiation option
-            try {
-                if (bin.available() == 0) dsq.put(new Integer(0));  // trigger buffer.testChanged()
-            }
-            catch (Exception ex) {
-                Log.w(TAG, "readIncoming error " + ex.getMessage());
-            }
             baosin.write(bin.read());
             vt.negotiate(rBytes);
             return null;
diff -r 2bdc413623b2 -r c438c2ff0052 src/org/tn5250j/framework/tn5250/tnvt.java
--- a/src/org/tn5250j/framework/tn5250/tnvt.java	Tue Jul 08 10:35:14 2014 -0700
+++ b/src/org/tn5250j/framework/tn5250/tnvt.java	Tue Jul 08 10:46:40 2014 -0700
@@ -983,12 +983,6 @@
         while (keepTrucking) {
             try {
                 Object e = dsq.take();
-
-                if ((e instanceof Integer) && ((Integer)e == 0)) {
-                    //buffer.testChanged();
-                    continue;
-                };
-
                 bk.initialize((byte[])e);
             }
             catch (InterruptedException ie) {