Fix Regression on ee9 / ee8 MultiPart parsing

jetty-ee9/jetty-ee9-nested/src/main/java/org/eclipse/jetty/ee9/nested/MultiPartFormInputStream.java

@@ -38,6 +38,7 @@
 import jakarta.servlet.MultipartConfigElement;
 import jakarta.servlet.ServletInputStream;
 import jakarta.servlet.http.Part;
+import org.eclipse.jetty.http.BadMessageException;
 import org.eclipse.jetty.http.ComplianceViolation;
 import org.eclipse.jetty.http.HttpField;
 import org.eclipse.jetty.http.MultiPartCompliance;
@@ -617,6 +618,14 @@ protected void parse()
                 }
                 else if (len == -1)
                 {
+                    if (total == 0)
+                    {
+                        throw new BadMessageException(
+                            "No progress made on multipart/form-data",
+                            new IOException("Missing content for multipart request")
+                        );
+                    }
+
                     parser.parse(BufferUtil.EMPTY_BUFFER, true);
                     break;
                 }

jetty-ee9/jetty-ee9-nested/src/main/java/org/eclipse/jetty/ee9/nested/MultiPartInputStreamLegacyParser.java

@@ -41,6 +41,7 @@
 import jakarta.servlet.MultipartConfigElement;
 import jakarta.servlet.ServletInputStream;
 import jakarta.servlet.http.Part;
+import org.eclipse.jetty.http.BadMessageException;
 import org.eclipse.jetty.http.ComplianceViolation;
 import org.eclipse.jetty.http.MultiPartCompliance;
 import org.eclipse.jetty.util.ByteArrayOutputStream2;
@@ -578,7 +579,12 @@ else if ("".equals(_config.getLocation()))
             }
 
             if (line == null)
-                throw new IOException("Missing content for multipart request");
+            {
+                throw new BadMessageException(
+                    "No progress made on multipart/form-data",
+                    new IOException("Missing content for multipart request")
+                );
+            }
 
             boolean badFormatLogged = false;
 

jetty-ee9/jetty-ee9-servlet/src/test/java/org/eclipse/jetty/ee9/servlet/MultiPartServletTest.java

@@ -24,6 +24,7 @@
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
 import java.util.function.Consumer;
+import java.util.stream.Stream;
 import java.util.zip.GZIPInputStream;
 
 import jakarta.servlet.MultipartConfigElement;
@@ -49,15 +50,20 @@
 import org.eclipse.jetty.http.HttpStatus;
 import org.eclipse.jetty.http.MimeTypes;
 import org.eclipse.jetty.http.MultiPart;
+import org.eclipse.jetty.http.MultiPartCompliance;
 import org.eclipse.jetty.io.EofException;
 import org.eclipse.jetty.logging.StacklessLogging;
+import org.eclipse.jetty.server.HttpConfiguration;
+import org.eclipse.jetty.server.HttpConnectionFactory;
 import org.eclipse.jetty.server.Server;
 import org.eclipse.jetty.server.ServerConnector;
 import org.eclipse.jetty.server.handler.gzip.GzipHandler;
 import org.eclipse.jetty.util.IO;
 import org.junit.jupiter.api.AfterEach;
-import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.params.ParameterizedTest;
+import org.junit.jupiter.params.provider.Arguments;
+import org.junit.jupiter.params.provider.MethodSource;
 
 import static org.hamcrest.MatcherAssert.assertThat;
 import static org.hamcrest.Matchers.containsString;
@@ -130,14 +136,15 @@ protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws S
         }
     }
 
-    @BeforeEach
-    public void start() throws Exception
+    private void startServer(MultiPartCompliance multiPartCompliance) throws Exception
     {
         tmpDir = Files.createTempDirectory(MultiPartServletTest.class.getSimpleName());
         assertNotNull(tmpDir);
 
         server = new Server();
-        connector = new ServerConnector(server);
+        HttpConfiguration httpConfiguration = new HttpConfiguration();
+        httpConfiguration.setMultiPartCompliance(multiPartCompliance);
+        connector = new ServerConnector(server, new HttpConnectionFactory(httpConfiguration));
         server.addConnector(connector);
 
         MultipartConfigElement config = new MultipartConfigElement(tmpDir.toAbsolutePath().toString(),
@@ -180,9 +187,46 @@ public void stop() throws Exception
         IO.delete(tmpDir.toFile());
     }
 
+    public static Stream<Arguments> multipartModes()
+    {
+        return Stream.of(
+            Arguments.of(MultiPartCompliance.RFC7578),
+            Arguments.of(MultiPartCompliance.LEGACY)
+        );
+    }
+
+    /**
+     * The request indicates that it is a multipart/form-data, but no body is sent.
+     */
+    @ParameterizedTest
+    @MethodSource("multipartModes")
+    public void testEmptyBodyMultipartForm(MultiPartCompliance multiPartCompliance) throws Exception
+    {
+        startServer(multiPartCompliance);
+
+        String contentType = "multipart/form-data; boundary=---------------boundaryXYZ123";
+        StringRequestContent emptyContent = new StringRequestContent(contentType, "");
+
+        InputStreamResponseListener listener = new InputStreamResponseListener();
+        client.newRequest("localhost", connector.getLocalPort())
+            .path("/defaultConfig")
+            .scheme(HttpScheme.HTTP.asString())
+            .method(HttpMethod.POST)
+            .body(emptyContent)
+            .send(listener);
+
+        Response response = listener.get(60, TimeUnit.SECONDS);
+        assertThat(response.getStatus(), equalTo(HttpStatus.BAD_REQUEST_400));
+
+        String responseBody = IO.toString(listener.getInputStream());
+        assertThat(responseBody, containsString("java.io.IOException: Missing content for multipart request"));
+    }
+
     @Test
     public void testLargePart() throws Exception
     {
+        startServer(MultiPartCompliance.RFC7578);
+
         OutputStreamRequestContent content = new OutputStreamRequestContent();
         MultiPartRequestContent multiPart = new MultiPartRequestContent();
         multiPart.addPart(new MultiPart.ContentSourcePart("param", null, null, content));
@@ -215,6 +259,8 @@ public void testLargePart() throws Exception
     @Test
     public void testManyParts() throws Exception
     {
+        startServer(MultiPartCompliance.RFC7578);
+
         byte[] byteArray = new byte[1024];
         Arrays.fill(byteArray, (byte)1);
 
@@ -244,6 +290,8 @@ public void testManyParts() throws Exception
     @Test
     public void testMaxRequestSize() throws Exception
     {
+        startServer(MultiPartCompliance.RFC7578);
+
         OutputStreamRequestContent content = new OutputStreamRequestContent();
         MultiPartRequestContent multiPart = new MultiPartRequestContent();
         multiPart.addPart(new MultiPart.ContentSourcePart("param", null, null, content));
@@ -304,6 +352,8 @@ private static void assert400orEof(InputStreamResponseListener listener, Consume
     @Test
     public void testTempFilesDeletedOnError() throws Exception
     {
+        startServer(MultiPartCompliance.RFC7578);
+
         byte[] byteArray = new byte[LARGE_MESSAGE_SIZE];
         Arrays.fill(byteArray, (byte)1);
         BytesRequestContent content = new BytesRequestContent(byteArray);
@@ -333,6 +383,8 @@ public void testTempFilesDeletedOnError() throws Exception
     @Test
     public void testMultiPartGzip() throws Exception
     {
+        startServer(MultiPartCompliance.RFC7578);
+
         String contentString = "the quick brown fox jumps over the lazy dog, " +
             "the quick brown fox jumps over the lazy dog";
         StringRequestContent content = new StringRequestContent(contentString);