You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by "Yuqi Yan (Jira)" <ji...@apache.org> on 2025/05/21 21:29:00 UTC

[jira] [Created] (CASSANDRA-20670) IntrusiveStack.accumulate is not accumulating correctly

Yuqi Yan created CASSANDRA-20670:
------------------------------------

             Summary: IntrusiveStack.accumulate is not accumulating correctly
                 Key: CASSANDRA-20670
                 URL: https://issues.apache.org/jira/browse/CASSANDRA-20670
             Project: Apache Cassandra
          Issue Type: Bug
            Reporter: Yuqi Yan
            Assignee: Yuqi Yan


{code:java}
protected static <T extends IntrusiveStack<T>> long accumulate(T list, LongAccumulator<T> accumulator, long initialValue)
{
    long value = initialValue;
    while (list != null)
    {
        value = accumulator.apply(list, initialValue);
                                          ^^^
        list = list.next;
    }
    return value;
} {code}
Seems we're restarting from the beginning every time when accumulating. This is used in Paxos V2 when aggregating the responses from peers.

Added a simple unit test around FailureRecordingCallback to reproduce this



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org