src/java/org/apache/cassandra/db/transaction/BatchMutateTransactionCoordinator.java
/** Delivers the yesVotes to a coordinator if it exists, and otherwise queues it up for later delivery
     *
     * @param transactionId
     * @param yesVoteCount
     */
Delivers the yesVotes to a coordinator if it exists, and otherwise queues it up for later delivery
@param transactionId
@param yesVoteCount
Delivers the yesVotes to a coordinator if it exists and otherwise queues it up for later delivery @param transactionId @param yesVoteCount
public static void deliverYesVotes(Long transactionId, int yesVoteCount)
    {
        if (static_logger.isTraceEnabled()) {
            static_logger.trace("deliverYesVotes({}, {})", new Object[]{transactionId, yesVoteCount});
        }
        BatchMutateTransactionCoordinator coordinator = null;
        synchronized(queuedYesVotes) {
            coordinator = findCoordinator(transactionId);
            if (coordinator == null) {
                Integer previousCount = queuedYesVotes.get(transactionId);
                if (previousCount != null) {
                    queuedYesVotes.put(transactionId, previousCount + yesVoteCount);
                } else {
                    queuedYesVotes.put(transactionId, yesVoteCount);
                }
            }
        }
        if (coordinator != null) {
            coordinator.receiveYesVotes(yesVoteCount);
        }
    }
public static void deliverYesVotes ( Long transactionId , int yesVoteCount ) { if ( static_logger . isTraceEnabled ( ) ) { static_logger . trace ( "deliverYesVotes({}, {})" , new Object [ ] { transactionId , yesVoteCount } ) ; } BatchMutateTransactionCoordinator coordinator = null ; synchronized ( queuedYesVotes ) { coordinator = findCoordinator ( transactionId ) ; if ( coordinator == null ) { Integer previousCount = queuedYesVotes . get ( transactionId ) ; if ( previousCount != null ) { queuedYesVotes . put ( transactionId , previousCount + yesVoteCount ) ; } else { queuedYesVotes . put ( transactionId , yesVoteCount ) ; } } } if ( coordinator != null ) { coordinator . receiveYesVotes ( yesVoteCount ) ; } }
Delivers the yesVotes to a coordinator if it exists, and otherwise queues it up for later delivery
 @param transactionId
 @param yesVoteCount
Delivers the yesVotes to a coordinator if it exists and otherwise queues it up for later delivery @param transactionId @param yesVoteCount
// Yesvote delivery & coordinator finding are synchronized together to avoid a race //  See deliverNotify for reasoning as why this is correct