src/java/org/apache/cassandra/db/Column.java
//WL TODO Trigger this after the read txn timeout has passed
WL TODO Trigger this after the read txn timeout has passed
WL TODO Trigger this after the read txn timeout has passed
private void removeOldPreviousVersions()
    {
        synchronized (this) {
            if (this.previousVersions == null) {
                return;
            }
            long safeTime = System.currentTimeMillis() - DatabaseDescriptor.getGetTransactionTimeoutInMs();
            Iterator<IColumn> prevVersionIt = this.previousVersions.iterator();
            while (prevVersionIt.hasNext()) {
                IColumn prevVersion = prevVersionIt.next();
                if (prevVersion.lastAccessTimeOfAPreviousVersion() < safeTime) {
                    prevVersionIt.remove();
                } else {
                    return;
                }
            }
        }
    }
private void removeOldPreviousVersions ( ) { synchronized ( this ) { if ( this . previousVersions == null ) { return ; } long safeTime = System . currentTimeMillis ( ) - DatabaseDescriptor . getGetTransactionTimeoutInMs ( ) ; Iterator < IColumn > prevVersionIt = this . previousVersions . iterator ( ) ; while ( prevVersionIt . hasNext ( ) ) { IColumn prevVersion = prevVersionIt . next ( ) ; if ( prevVersion . lastAccessTimeOfAPreviousVersion ( ) < safeTime ) { prevVersionIt . remove ( ) ; } else { return ; } } } }
WL TODO Trigger this after the read txn timeout has passed
WL TODO Trigger this after the read txn timeout has passed
// lastAccessTimeOfAPreviousVersions are monotonically increasing so nothing else can be cleaned now