This is an automated email from the ASF dual-hosted git repository. markt pushed a commit to branch 10.0.x in repository https://gitbox.apache.org/repos/asf/tomcat.git
commit 26204b79db50613eba830e3d03c8a614a3bea35b 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 7e5143b620..c0d904e0c4 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 d1074c4cff..caff2138a4 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