possible fix for issue robaho#21, protect against NPE

robaho · robaho · commit affadb705556 · 2025-04-04T10:34:35.000-05:00
diff --git a/src/main/java/robaho/net/httpserver/NoSyncBufferedInputStream.java b/src/main/java/robaho/net/httpserver/NoSyncBufferedInputStream.java
@@ -83,7 +83,7 @@ public NoSyncBufferedInputStream(InputStream in) {
     private void fill() throws IOException {
         pos = 0;
         count = 0;
-        int n = getInIfOpen().read(buf);
+        int n = getInIfOpen().read(getBufIfOpen());
         if (n > 0)
             count = n;
     }
diff --git a/src/main/java/robaho/net/httpserver/ServerImpl.java b/src/main/java/robaho/net/httpserver/ServerImpl.java
@@ -621,7 +621,7 @@ public void run() {
 
             logger.log(Level.TRACE, () -> "exchange started "+connection.toString());
 
-            while (true) {
+            while (!connection.closed) {
                 try {
                     runPerRequest();
                     if (connection.closed) {

Original file line number	Diff line number	Diff line change
`@@ -83,7 +83,7 @@ public NoSyncBufferedInputStream(InputStream in) {`
`83`	`83`	`private void fill() throws IOException {`
`84`	`84`	`pos = 0;`
`85`	`85`	`count = 0;`
`86`		`- int n = getInIfOpen().read(buf);`
	`86`	`+ int n = getInIfOpen().read(getBufIfOpen());`
`87`	`87`	`if (n > 0)`
`88`	`88`	`count = n;`
`89`	`89`	`}`