natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix SimpleClient ability to release acquired capacity 

patch by Sam Tunnicliffe; reviewed by Dmitry Konstantinov, Mick Semb Wever for CASSANDRA-20202
This commit is contained in:
Sam Tunnicliffe 2025-01-14 17:02:05 +00:00 committed by mck
parent fc232f45f0
commit 291cbcccf6
No known key found for this signature in database
GPG Key ID: E91335D77E3E87CB
3 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGES.txt
View File

@ -1,4 +1,5 @@
4.1.9
* Fix SimpleClient ability to release acquired capacity (CASSANDRA-20202)
* Fix WaitQueue.Signal.awaitUninterruptibly may block forever if invoking thread is interrupted (CASSANDRA-20084)
Merged from 4.0:
* Fix autocompletion for role names/user names (CASSANDRA-20175)

5
src/java/org/apache/cassandra/transport/CQLMessageHandler.java
View File

@ -373,11 +373,6 @@ public class CQLMessageHandler<M extends Message> extends AbstractMessageHandler
return new Envelope(header, body);
}
protected boolean processRequest(Envelope request)
{
return processRequest(request, Overload.NONE);
}
protected boolean processRequest(Envelope request, Overload backpressure)
{
M message = null;

4
src/java/org/apache/cassandra/transport/SimpleClient.java
View File

@ -518,9 +518,9 @@ public class SimpleClient implements Closeable
errorHandler,
ctx.channel().attr(Connection.attributeKey).get().isThrowOnOverload())
{
protected boolean processRequest(Envelope request)
protected boolean processRequest(Envelope request, Overload overload)
{
boolean continueProcessing = super.processRequest(request);
boolean continueProcessing = super.processRequest(request, overload);
releaseCapacity(Ints.checkedCast(request.header.bodySizeInBytes));
return continueProcessing;
}