Unpack value before reading

apache · Jan 5, 2024 · 185978d · 185978d
1 parent 32da136
commit 185978d
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/server/src/main/java/org/apache/druid/server/initialization/jetty/JettyServerModule.java b/server/src/main/java/org/apache/druid/server/initialization/jetty/JettyServerModule.java
@@ -499,12 +499,15 @@ private static int getTCPAcceptQueueSize()
   {
     try {
       BufferedReader in = Files.newBufferedReader(Paths.get("/proc/sys/net/core/somaxconn"));
-      return Integer.parseInt(in.readLine().trim());
+      String acceptQueueSize = in.readLine();
+      if (acceptQueueSize != null) {
+        return Integer.parseInt(acceptQueueSize);
+      }
     }
     catch (Exception e) {
       log.warn("Unable to read /proc/sys/net/core/somaxconn, falling back to default value for TCP accept queue size");
-      return 128; // Default value of net.core.somaxconn on Linux
     }
+    return 128; // Default value of net.core.somaxconn on Linux
   }
 
   @Provides