Check if connection is available

downarowiczd · Mar 15, 2022 · c2af272 · c2af272
1 parent 51d8c4d
commit c2af272
Showing 1 changed file with 35 additions and 35 deletions.
diff --git a/src/main/java/at/downardo/j3270Server/Telnet.java b/src/main/java/at/downardo/j3270Server/Telnet.java
@@ -139,44 +139,44 @@ public static int[] TelnetRead(BufferedInputStream in, int[] buf) throws IOExcep
 		int state = NORMAL;
 		int n = 0;		
 		while(n <= (buf.length-1)) {
-			int bufRead = in.read();
-
-
-
-			if(bufRead == 0) {
-				continue;
-			}
-
-
-			switch(state) {
-			case NORMAL:
-				if(bufRead == IAC) {
-					state = COMMAND;
-				}else {
-					buf[n] = bufRead;
-					n++;
+			if(in.available() > 0) {
+				int bufRead = in.read();
+
+				if(bufRead == 0) {
+					continue;
 				}
-				break;
-			case COMMAND:
-				if(bufRead == 0xff) {
-					buf[n] = 0xff;
+
+
+				switch(state) {
+				case NORMAL:
+					if(bufRead == IAC) {
+						state = COMMAND;
+					}else {
+						buf[n] = bufRead;
+						n++;
+					}
+					break;
+				case COMMAND:
+					if(bufRead == 0xff) {
+						buf[n] = 0xff;
+
+						n++;
+						state = NORMAL;
+					}else if(bufRead == SB) {
+						state = SUBNEG;
+					}else {
+						state = NORMAL;
+					}
+					break;
+				case SUBNEG:
+					if(bufRead == SE) {
+						state = NORMAL;
+					}else {
+						//remain in subnegotiation consumin bytes until we get SE
+					}
+					break;
 
-					n++;
-					state = NORMAL;
-				}else if(bufRead == SB) {
-					state = SUBNEG;
-				}else {
-					state = NORMAL;
 				}
-				break;
-			case SUBNEG:
-				if(bufRead == SE) {
-					state = NORMAL;
-				}else {
-					//remain in subnegotiation consumin bytes until we get SE
-				}
-				break;
-
 			}
 
 		}