gh-47 fix ssl

Unknow0 · Aug 13, 2024 · c80f0c8 · c80f0c8
1 parent 7cb599f
commit c80f0c8
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/unknow-server-servlet/src/main/java/unknow/server/servlet/http11/Http11Processor.java b/unknow-server-servlet/src/main/java/unknow/server/servlet/http11/Http11Processor.java
@@ -5,6 +5,7 @@
 
 import unknow.server.servlet.HttpConnection;
 import unknow.server.servlet.HttpProcessor;
+import unknow.server.util.io.Buffers;
 import unknow.server.util.io.BuffersUtils;
 
 /**
@@ -28,8 +29,8 @@ public Http11Processor(HttpConnection co) {
 	}
 
 	@Override
-	public final void process() {
-		if (exec.isDone())
+	public final void process() throws InterruptedException {
+		if (exec.isDone() && isStart(co.pendingRead()))
 			exec = co.submit(new Http11Worker(co));
 	}
 
@@ -48,9 +49,13 @@ public final void close() {
 		exec.cancel(true);
 	}
 
+	public static final boolean isStart(Buffers b) throws InterruptedException {
+		return BuffersUtils.indexOf(b, END, 0, MAX_START_SIZE) > 0;
+	}
+
 	/** the processor factory */
 	public static final HttpProcessorFactory Factory = co -> {
-		if (BuffersUtils.indexOf(co.pendingRead(), END, 0, MAX_START_SIZE) > 0)
+		if (isStart(co.pendingRead()))
 			return new Http11Processor(co);
 		return null;
 	};