This is an automated email from the ASF dual-hosted git repository.
markt pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/tomcat.git
commit 0535f4c73161761273457b5359b175a21533de03
Author: Mark Thomas <ma...@apache.org>
AuthorDate: Thu Feb 25 10:01:51 2021 +0000
Avoid possible NPE during shutdown for some error conditions
---
java/org/apache/catalina/connector/CoyoteAdapter.java | 15 +++++++++------
1 file changed, 9 insertions(+), 6 deletions(-)
diff --git a/java/org/apache/catalina/connector/CoyoteAdapter.java
b/java/org/apache/catalina/connector/CoyoteAdapter.java
index 84190ac..df01fd9 100644
--- a/java/org/apache/catalina/connector/CoyoteAdapter.java
+++ b/java/org/apache/catalina/connector/CoyoteAdapter.java
@@ -149,9 +149,10 @@ public class CoyoteAdapter implements Adapter {
success = false;
Throwable t =
(Throwable)req.getAttribute(RequestDispatcher.ERROR_EXCEPTION);
req.getAttributes().remove(RequestDispatcher.ERROR_EXCEPTION);
+ Context context = request.getContext();
ClassLoader oldCL = null;
try {
- oldCL = request.getContext().bind(false, null);
+ oldCL = context.bind(false, null);
if (req.getReadListener() != null) {
req.getReadListener().onError(t);
}
@@ -159,7 +160,7 @@ public class CoyoteAdapter implements Adapter {
res.getWriteListener().onError(t);
}
} finally {
- request.getContext().unbind(false, oldCL);
+ context.unbind(false, oldCL);
}
if (t != null) {
asyncConImpl.setErrorState(t, true);
@@ -171,9 +172,10 @@ public class CoyoteAdapter implements Adapter {
WriteListener writeListener = res.getWriteListener();
ReadListener readListener = req.getReadListener();
if (writeListener != null && status == SocketEvent.OPEN_WRITE)
{
+ Context context = request.getContext();
ClassLoader oldCL = null;
try {
- oldCL = request.getContext().bind(false, null);
+ oldCL = context.bind(false, null);
res.onWritePossible();
if (request.isFinished() && req.sendAllDataReadEvent()
&&
readListener != null) {
@@ -194,12 +196,13 @@ public class CoyoteAdapter implements Adapter {
writeListener.onError(t);
asyncConImpl.setErrorState(t, true);
} finally {
- request.getContext().unbind(false, oldCL);
+ context.unbind(false, oldCL);
}
} else if (readListener != null && status ==
SocketEvent.OPEN_READ) {
+ Context context = request.getContext();
ClassLoader oldCL = null;
try {
- oldCL = request.getContext().bind(false, null);
+ oldCL = context.bind(false, null);
// If data is being read on a non-container thread a
// dispatch with status OPEN_READ will be used to get
// execution back on a container thread for the
@@ -226,7 +229,7 @@ public class CoyoteAdapter implements Adapter {
readListener.onError(t);
asyncConImpl.setErrorState(t, true);
} finally {
- request.getContext().unbind(false, oldCL);
+ context.unbind(false, oldCL);
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org
For additional commands, e-mail: dev-h...@tomcat.apache.org
