src/java/org/apache/cassandra/service/AntiEntropyService.java
/**
         * Trigger a validation compaction which will return the tree upon completion.
         */
Trigger a validation compaction which will return the tree upon completion.
Trigger a validation compaction which will return the tree upon completion .
public void doVerb(Message message, String id)
        { 
            byte[] bytes = message.getMessageBody();
            DataInputStream buffer = new DataInputStream(new FastByteArrayInputStream(bytes));
            try
            {
                TreeRequest remotereq = this.deserialize(buffer, message.getVersion());
                TreeRequest request = new TreeRequest(remotereq.sessionid, message.getFrom(), remotereq.range, remotereq.cf);
                ColumnFamilyStore store = Table.open(request.cf.left).getColumnFamilyStore(request.cf.right);
                Validator validator = new Validator(request);
                logger.debug("Queueing validation compaction for " + request);
                CompactionManager.instance.submitValidation(store, validator);
            }
            catch (IOException e)
            {
                throw new IOError(e);            
            }
        }
public void doVerb ( Message message , String id ) { byte [ ] bytes = message . getMessageBody ( ) ; DataInputStream buffer = new DataInputStream ( new FastByteArrayInputStream ( bytes ) ) ; try { TreeRequest remotereq = this . deserialize ( buffer , message . getVersion ( ) ) ; TreeRequest request = new TreeRequest ( remotereq . sessionid , message . getFrom ( ) , remotereq . range , remotereq . cf ) ; ColumnFamilyStore store = Table . open ( request . cf . left ) . getColumnFamilyStore ( request . cf . right ) ; Validator validator = new Validator ( request ) ; logger . debug ( "Queueing validation compaction for " + request ) ; CompactionManager . instance . submitValidation ( store , validator ) ; } catch ( IOException e ) { throw new IOError ( e ) ; } }
Trigger a validation compaction which will return the tree upon completion.
Trigger a validation compaction which will return the tree upon completion .
// trigger readonly-compaction