aweisberg commented on code in PR #3551:
URL: https://github.com/apache/cassandra/pull/3551#discussion_r1761882445
##########
src/java/org/apache/cassandra/service/accord/AccordMessageSink.java:
##########
@@ -227,12 +225,33 @@ public void send(Node.Id to, Request request)
messaging.send(message, endpoint);
}
+ private static boolean isRangeBarrier(Request request)
+ {
+ if (!(request instanceof TxnRequest))
+ return false;
+
+ TxnRequest<?> txnRequest = (TxnRequest<?>) request;
+ if (!txnRequest.txnId.kind().isSyncPoint())
+ return false;
+
+ return txnRequest.txnId.domain().isRange();
+ }
+
@Override
public void send(Node.Id to, Request request, AgentExecutor executor,
Callback callback)
{
Verb verb = getVerb(request);
Preconditions.checkNotNull(verb, "Verb is null for type %s",
request.type());
- Message<Request> message = Message.out(verb, request);
+ Message<Request> message;
+ if (isRangeBarrier(request))
Review Comment:
Arguably is this problem specific to sync points or do all range
transactions probably have this issue and should have the longer timeout?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
