This is an automated email from the ASF dual-hosted git repository. markt pushed a commit to branch 9.0.x in repository https://gitbox.apache.org/repos/asf/tomcat.git
commit be6166f4de7781a1ccd411c561ac870da36b60c8 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 72cf285c22..0b25f6a942 100644 --- a/java/org/apache/coyote/http2/Stream.java +++ b/java/org/apache/coyote/http2/Stream.java @@ -1162,6 +1162,7 @@ class Stream extends AbstractNonZeroStream implements HeaderEmitter { } + @Override final boolean isReadyForRead() { ensureBuffersExist(); @@ -1178,6 +1179,7 @@ class Stream extends AbstractNonZeroStream implements HeaderEmitter { } } + @Override final synchronized boolean isRequestBodyFullyRead() { return (inBuffer == null || inBuffer.position() == 0) && isInputFinished(); } @@ -1195,6 +1197,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(); @@ -1219,12 +1222,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()); } @@ -1246,6 +1251,7 @@ class Stream extends AbstractNonZeroStream implements HeaderEmitter { } + @Override final void receiveReset() { if (inBuffer != null) { synchronized (inBuffer) { @@ -1255,6 +1261,7 @@ class Stream extends AbstractNonZeroStream implements HeaderEmitter { } } + @Override final void notifyEof() { if (inBuffer != null) { synchronized (inBuffer) { @@ -1263,6 +1270,7 @@ class Stream extends AbstractNonZeroStream implements HeaderEmitter { } } + @Override final void swallowUnread() throws IOException { synchronized (this) { closed = true; --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org For additional commands, e-mail: dev-h...@tomcat.apache.org