jdk-sandbox: comparison src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/internal/common/SSLFlowDelegate.java

equal deleted inserted replaced

-:08e8e41841cf
+:a8423a38386e
 }
 if (writeList.isEmpty() && needWrap()) {
 writer.addData(HS_TRIGGER);
 }
 } catch (Throwable ex) {
+errorCommon(ex);
 handleError(ex);
 }
 }
 private boolean needWrap() {
 return l;
 }
 private void executeTasks(List<Runnable> tasks) {
 exec.execute(() -> {
-handshakeState.getAndUpdate((current) -> current | DOING_TASKS);
+try {
-List<Runnable> nextTasks = tasks;
+handshakeState.getAndUpdate((current) -> current | DOING_TASKS);
-do {
+List<Runnable> nextTasks = tasks;
-try {
+do {
-nextTasks.forEach((r) -> {
+nextTasks.forEach(Runnable::run);
-r.run();
-});
 if (engine.getHandshakeStatus() == HandshakeStatus.NEED_TASK) {
 nextTasks = obtainTasks();
-} else break;
+} else {
-} catch (Throwable t) {
+break;
-handleError(t);
+}
-}
+} while (true);
-} while(true);
+handshakeState.getAndUpdate((current) -> current & ~DOING_TASKS);
-handshakeState.getAndUpdate((current) -> current & ~DOING_TASKS);
+writer.addData(HS_TRIGGER);
-writer.addData(HS_TRIGGER);
+resumeActivity();
-resumeActivity();
+} catch (Throwable t) {
+handleError(t);
+}
 });
 }
 EngineResult unwrapBuffer(ByteBuffer src) throws IOException {