Author: remm
Date: Thu Feb 21 19:31:22 2019
New Revision: 1854084
URL: http://svn.apache.org/viewvc?rev=1854084&view=rev
Log:
Revert after CI failure, try something else.
Modified:
tomcat/trunk/java/org/apache/coyote/AbstractProcessor.java
tomcat/trunk/java/org/apache/coyote/AbstractProtocol.java
tomcat/trunk/java/org/apache/coyote/ajp/AjpProcessor.java
tomcat/trunk/java/org/apache/coyote/http11/Http11Processor.java
tomcat/trunk/java/org/apache/coyote/http11/upgrade/UpgradeServletInputStream.java
tomcat/trunk/java/org/apache/coyote/http2/StreamProcessor.java
tomcat/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java
tomcat/trunk/java/org/apache/tomcat/util/net/Nio2Endpoint.java
tomcat/trunk/java/org/apache/tomcat/util/net/NioEndpoint.java
tomcat/trunk/java/org/apache/tomcat/util/net/SocketWrapperBase.java
Modified: tomcat/trunk/java/org/apache/coyote/AbstractProcessor.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/AbstractProcessor.java?rev=1854084&r1=1854083&r2=1854084&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/coyote/AbstractProcessor.java (original)
+++ tomcat/trunk/java/org/apache/coyote/AbstractProcessor.java Thu Feb 21
19:31:22 2019
@@ -790,7 +790,7 @@ public abstract class AbstractProcessor
}
if (!isRequestBodyFullyRead()) {
- registerReadInterest(true);
+ registerReadInterest();
}
return false;
@@ -800,7 +800,7 @@ public abstract class AbstractProcessor
protected abstract boolean isRequestBodyFullyRead();
- protected abstract void registerReadInterest(boolean body);
+ protected abstract void registerReadInterest();
protected abstract boolean isReadyForWrite();
Modified: tomcat/trunk/java/org/apache/coyote/AbstractProtocol.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/AbstractProtocol.java?rev=1854084&r1=1854083&r2=1854084&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/coyote/AbstractProtocol.java (original)
+++ tomcat/trunk/java/org/apache/coyote/AbstractProtocol.java Thu Feb 21
19:31:22 2019
@@ -903,7 +903,7 @@ public abstract class AbstractProtocol<S
// processor. Continue to poll for the next request.
connections.remove(socket);
release(processor);
- wrapper.registerReadInterest(true);
+ wrapper.registerReadInterest();
} else if (state == SocketState.SENDFILE) {
// Sendfile in progress. If it fails, the socket will be
// closed. If it works, the socket either be added to the
@@ -993,7 +993,7 @@ public abstract class AbstractProtocol<S
// - this is an upgraded connection
// - the request line/headers have not been completely
// read
- socket.registerReadInterest(true);
+ socket.registerReadInterest();
}
}
Modified: tomcat/trunk/java/org/apache/coyote/ajp/AjpProcessor.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/ajp/AjpProcessor.java?rev=1854084&r1=1854083&r2=1854084&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/coyote/ajp/AjpProcessor.java (original)
+++ tomcat/trunk/java/org/apache/coyote/ajp/AjpProcessor.java Thu Feb 21
19:31:22 2019
@@ -1134,8 +1134,8 @@ public class AjpProcessor extends Abstra
@Override
- protected final void registerReadInterest(boolean body) {
- socketWrapper.registerReadInterest(!body);
+ protected final void registerReadInterest() {
+ socketWrapper.registerReadInterest();
}
Modified: tomcat/trunk/java/org/apache/coyote/http11/Http11Processor.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/http11/Http11Processor.java?rev=1854084&r1=1854083&r2=1854084&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/coyote/http11/Http11Processor.java (original)
+++ tomcat/trunk/java/org/apache/coyote/http11/Http11Processor.java Thu Feb 21
19:31:22 2019
@@ -1215,8 +1215,8 @@ public class Http11Processor extends Abs
@Override
- protected final void registerReadInterest(boolean body) {
- socketWrapper.registerReadInterest(!body);
+ protected final void registerReadInterest() {
+ socketWrapper.registerReadInterest();
}
Modified:
tomcat/trunk/java/org/apache/coyote/http11/upgrade/UpgradeServletInputStream.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/http11/upgrade/UpgradeServletInputStream.java?rev=1854084&r1=1854083&r2=1854084&view=diff
==============================================================================
---
tomcat/trunk/java/org/apache/coyote/http11/upgrade/UpgradeServletInputStream.java
(original)
+++
tomcat/trunk/java/org/apache/coyote/http11/upgrade/UpgradeServletInputStream.java
Thu Feb 21 19:31:22 2019
@@ -107,7 +107,7 @@ public class UpgradeServletInputStream e
if (ContainerThreadMarker.isContainerThread()) {
processor.addDispatch(DispatchType.NON_BLOCKING_READ);
} else {
- socketWrapper.registerReadInterest(true);
+ socketWrapper.registerReadInterest();
}
// Switching to non-blocking. Don't know if data is available.
Modified: tomcat/trunk/java/org/apache/coyote/http2/StreamProcessor.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/coyote/http2/StreamProcessor.java?rev=1854084&r1=1854083&r2=1854084&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/coyote/http2/StreamProcessor.java (original)
+++ tomcat/trunk/java/org/apache/coyote/http2/StreamProcessor.java Thu Feb 21
19:31:22 2019
@@ -263,7 +263,7 @@ class StreamProcessor extends AbstractPr
@Override
- protected final void registerReadInterest(boolean body) {
+ protected final void registerReadInterest() {
// Should never be called for StreamProcessor as isReadyForRead() is
// overridden
throw new UnsupportedOperationException();
Modified: tomcat/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java?rev=1854084&r1=1854083&r2=1854084&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java (original)
+++ tomcat/trunk/java/org/apache/tomcat/util/net/AprEndpoint.java Thu Feb 21
19:31:22 2019
@@ -2724,7 +2724,7 @@ public class AprEndpoint extends Abstrac
@Override
- public void registerReadInterest(boolean polling) {
+ public void registerReadInterest() {
// Make sure an already closed socket is not added to the poller
synchronized (closedLock) {
if (closed) {
Modified: tomcat/trunk/java/org/apache/tomcat/util/net/Nio2Endpoint.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/tomcat/util/net/Nio2Endpoint.java?rev=1854084&r1=1854083&r2=1854084&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/tomcat/util/net/Nio2Endpoint.java (original)
+++ tomcat/trunk/java/org/apache/tomcat/util/net/Nio2Endpoint.java Thu Feb 21
19:31:22 2019
@@ -1475,11 +1475,14 @@ public class Nio2Endpoint extends Abstra
@Override
- public void registerReadInterest(boolean polling) {
+ public void registerReadInterest() {
+ if (!ContainerThreadMarker.isContainerThread()) {
+ return;
+ }
synchronized (readCompletionHandler) {
if (readPending.availablePermits() == 0) {
readInterest = true;
- } else if (polling) {
+ } else {
// If no read is pending, start waiting for data
awaitBytes();
}
Modified: tomcat/trunk/java/org/apache/tomcat/util/net/NioEndpoint.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/tomcat/util/net/NioEndpoint.java?rev=1854084&r1=1854083&r2=1854084&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/tomcat/util/net/NioEndpoint.java (original)
+++ tomcat/trunk/java/org/apache/tomcat/util/net/NioEndpoint.java Thu Feb 21
19:31:22 2019
@@ -1243,7 +1243,7 @@ public class NioEndpoint extends Abstrac
@Override
- public void registerReadInterest(boolean polling) {
+ public void registerReadInterest() {
getPoller().add(getSocket(), SelectionKey.OP_READ);
}
@@ -1420,7 +1420,7 @@ public class NioEndpoint extends Abstrac
} else if (handshake == -1 ) {
close(socket, key);
} else if (handshake == SelectionKey.OP_READ){
- socketWrapper.registerReadInterest(true);
+ socketWrapper.registerReadInterest();
} else if (handshake == SelectionKey.OP_WRITE){
socketWrapper.registerWriteInterest();
}
Modified: tomcat/trunk/java/org/apache/tomcat/util/net/SocketWrapperBase.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/tomcat/util/net/SocketWrapperBase.java?rev=1854084&r1=1854083&r2=1854084&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/tomcat/util/net/SocketWrapperBase.java
(original)
+++ tomcat/trunk/java/org/apache/tomcat/util/net/SocketWrapperBase.java Thu Feb
21 19:31:22 2019
@@ -763,7 +763,7 @@ public abstract class SocketWrapperBase<
}
- public abstract void registerReadInterest(boolean polling);
+ public abstract void registerReadInterest();
public abstract void registerWriteInterest();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
