src/java/org/apache/cassandra/db/transaction/BatchMutateTransactionCoordinator.java
/* only needs to be called for local transactions, replicated transactions
     * will always have a coordinator created and go through the first round
     * before yesVotes start coming in
     */
only needs to be called for local transactions, replicated transactions
will always have a coordinator created and go through the first round
before yesVotes start coming in
only needs to be called for local transactions replicated transactions will always have a coordinator created and go through the first round before yesVotes start coming in
private void checkQueuedYesVotes()
    {
        if (sanityCheckFireOnces) {
            synchronized(checkedQueuedYesVotes) {
                assert checkedQueuedYesVotes == false : "May only checkQueuedYesVotes for " + transactionId + " once";
                checkedQueuedYesVotes = true;
            }
        }
        if (logger.isTraceEnabled()) {
            logger.trace("checkQueuedYesVotes() on {}", new Object[]{transactionId});
        }
        Integer queuedCount;
        synchronized(queuedYesVotes) {
            queuedCount = queuedYesVotes.get(transactionId);
            if (queuedCount != null) {
                queuedYesVotes.remove(transactionId);
            }
        }
        if (queuedCount == null) {
            queuedCount = 0;
        }
        receiveYesVotes(queuedCount);
    }
private void checkQueuedYesVotes ( ) { if ( sanityCheckFireOnces ) { synchronized ( checkedQueuedYesVotes ) { assert checkedQueuedYesVotes == false : "May only checkQueuedYesVotes for " + transactionId + " once" ; checkedQueuedYesVotes = true ; } } if ( logger . isTraceEnabled ( ) ) { logger . trace ( "checkQueuedYesVotes() on {}" , new Object [ ] { transactionId } ) ; } Integer queuedCount ; synchronized ( queuedYesVotes ) { queuedCount = queuedYesVotes . get ( transactionId ) ; if ( queuedCount != null ) { queuedYesVotes . remove ( transactionId ) ; } } if ( queuedCount == null ) { queuedCount = 0 ; } receiveYesVotes ( queuedCount ) ; }
only needs to be called for local transactions, replicated transactions
 will always have a coordinator created and go through the first round
 before yesVotes start coming in
only needs to be called for local transactions replicated transactions will always have a coordinator created and go through the first round before yesVotes start coming in