diff --git a/jetty-fcgi/fcgi-client/src/main/java/org/eclipse/jetty/fcgi/parser/ResponseContentParser.java b/jetty-fcgi/fcgi-client/src/main/java/org/eclipse/jetty/fcgi/parser/ResponseContentParser.java index 8b426327f0e..c10564e6310 100644 --- a/jetty-fcgi/fcgi-client/src/main/java/org/eclipse/jetty/fcgi/parser/ResponseContentParser.java +++ b/jetty-fcgi/fcgi-client/src/main/java/org/eclipse/jetty/fcgi/parser/ResponseContentParser.java @@ -98,7 +98,7 @@ public class ResponseContentParser extends StreamContentParser { case HEADERS: { - if (httpParser.parseHeaders(buffer)) + if (httpParser.parseNext(buffer)) state = State.CONTENT_MODE; remaining = buffer.remaining(); break; @@ -124,7 +124,8 @@ public class ResponseContentParser extends StreamContentParser } case HTTP_CONTENT: { - httpParser.parseContent(buffer); + if (httpParser.parseNext(buffer)) + return true; remaining = buffer.remaining(); break; } @@ -250,8 +251,7 @@ public class ResponseContentParser extends StreamContentParser @Override public boolean content(ByteBuffer buffer) { - notifyContent(buffer); - return false; + return notifyContent(buffer); } private boolean notifyContent(ByteBuffer buffer) @@ -305,18 +305,6 @@ public class ResponseContentParser extends StreamContentParser setState(State.HEADER); } - @Override - protected boolean parseHeaders(ByteBuffer buffer) - { - return super.parseHeaders(buffer); - } - - @Override - protected boolean parseContent(ByteBuffer buffer) - { - return super.parseContent(buffer); - } - @Override protected void setResponseStatus(int status) {