You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by ma...@apache.org on 2022/05/20 06:02:06 UTC
[tomcat] 02/03: Add @Override
This is an automated email from the ASF dual-hosted git repository.
markt pushed a commit to branch 8.5.x
in repository https://gitbox.apache.org/repos/asf/tomcat.git
commit 9f15371802a40a4ca9da168d7b5130247d93994e
Author: Mark Thomas <ma...@apache.org>
AuthorDate: Fri May 20 06:47:45 2022 +0100
Add @Override
---
java/org/apache/catalina/filters/CsrfPreventionFilter.java | 2 ++
java/org/apache/coyote/http2/Stream.java | 8 ++++++++
2 files changed, 10 insertions(+)
diff --git a/java/org/apache/catalina/filters/CsrfPreventionFilter.java b/java/org/apache/catalina/filters/CsrfPreventionFilter.java
index 77c0aa3ae1..4ffb7e2277 100644
--- a/java/org/apache/catalina/filters/CsrfPreventionFilter.java
+++ b/java/org/apache/catalina/filters/CsrfPreventionFilter.java
@@ -384,12 +384,14 @@ public class CsrfPreventionFilter extends CsrfPreventionFilterBase {
};
}
+ @Override
public void add(T key) {
synchronized (cache) {
cache.put(key, null);
}
}
+ @Override
public boolean contains(T key) {
synchronized (cache) {
return cache.containsKey(key);
diff --git a/java/org/apache/coyote/http2/Stream.java b/java/org/apache/coyote/http2/Stream.java
index 28bbb4b702..3445e9fc34 100644
--- a/java/org/apache/coyote/http2/Stream.java
+++ b/java/org/apache/coyote/http2/Stream.java
@@ -1224,6 +1224,7 @@ class Stream extends AbstractNonZeroStream implements HeaderEmitter {
}
+ @Override
final boolean isReadyForRead() {
ensureBuffersExist();
@@ -1240,6 +1241,7 @@ class Stream extends AbstractNonZeroStream implements HeaderEmitter {
}
}
+ @Override
final synchronized boolean isRequestBodyFullyRead() {
return (inBuffer == null || inBuffer.position() == 0) && isInputFinished();
}
@@ -1257,6 +1259,7 @@ class Stream extends AbstractNonZeroStream implements HeaderEmitter {
/*
* Called after placing some data in the inBuffer.
*/
+ @Override
final synchronized void onDataAvailable() throws IOException {
if (closed) {
swallowUnread();
@@ -1281,12 +1284,14 @@ class Stream extends AbstractNonZeroStream implements HeaderEmitter {
}
+ @Override
final ByteBuffer getInBuffer() {
ensureBuffersExist();
return inBuffer;
}
+ @Override
final synchronized void insertReplayedBody(ByteChunk body) {
inBuffer = ByteBuffer.wrap(body.getBytes(), body.getOffset(), body.getLength());
}
@@ -1308,6 +1313,7 @@ class Stream extends AbstractNonZeroStream implements HeaderEmitter {
}
+ @Override
final void receiveReset() {
if (inBuffer != null) {
synchronized (inBuffer) {
@@ -1317,6 +1323,7 @@ class Stream extends AbstractNonZeroStream implements HeaderEmitter {
}
}
+ @Override
final void notifyEof() {
if (inBuffer != null) {
synchronized (inBuffer) {
@@ -1325,6 +1332,7 @@ class Stream extends AbstractNonZeroStream implements HeaderEmitter {
}
}
+ @Override
final void swallowUnread() throws IOException {
synchronized (this) {
closed = true;
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org