This is an automated email from the ASF dual-hosted git repository. markt pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/tomcat.git
commit 1c84dc9b4339a033daf1a0fc643a9d0093b20520 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 cde762e76b..e623c9fbab 100644 --- a/java/org/apache/catalina/filters/CsrfPreventionFilter.java +++ b/java/org/apache/catalina/filters/CsrfPreventionFilter.java @@ -372,12 +372,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 f0d5207e43..dacc2392ad 100644 --- a/java/org/apache/coyote/http2/Stream.java +++ b/java/org/apache/coyote/http2/Stream.java @@ -1167,6 +1167,7 @@ class Stream extends AbstractNonZeroStream implements HeaderEmitter { } + @Override final boolean isReadyForRead() { ensureBuffersExist(); @@ -1183,6 +1184,7 @@ class Stream extends AbstractNonZeroStream implements HeaderEmitter { } } + @Override final synchronized boolean isRequestBodyFullyRead() { return (inBuffer == null || inBuffer.position() == 0) && isInputFinished(); } @@ -1200,6 +1202,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(); @@ -1224,12 +1227,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()); } @@ -1251,6 +1256,7 @@ class Stream extends AbstractNonZeroStream implements HeaderEmitter { } + @Override final void receiveReset() { if (inBuffer != null) { synchronized (inBuffer) { @@ -1260,6 +1266,7 @@ class Stream extends AbstractNonZeroStream implements HeaderEmitter { } } + @Override final void notifyEof() { if (inBuffer != null) { synchronized (inBuffer) { @@ -1268,6 +1275,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