Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package com.sleepycat.je.sync.impl;
 
 
 /*
  * Used to track the JE on log data for a SyncDataSet. 
  *
 * The cleaner throttle is determined as the 
 * min(LogChangeSet.nextPosition) for all the SyncDataSets. The 
 * EnvironmentImpl should keep a list of the SyncDataSets.
 */
public class LogChangeSet {
    /* Describe the NULL position for a JE log. */
    public static final long NULL_POSITION = 0;
    /* 
     * Following properties are the lsn numbers for a standalone Environment,
     * VLSN numbers for a replicated Environment.
     */
    /* 
     * The start position of the next sync action. 
     *
     * It's the first entry of the first comitted but not yet acked JE
     * transaction on the log.
     */ 
    private long nextSyncStart;
    /* 
     * The end position of last sync action. 
     *
     * It's the commit entry of the last committed and acked JE transaction on
     * the log.
     */
    private long lastSyncEnd;
    public LogChangeSet() {
        this. = ;
        this. = ;
    }
    public LogChangeSet(long nextSyncStart,
                        long lastSyncEnd) {
        this. = nextSyncStart;
        this. = lastSyncEnd;
    }
    public long getNextSyncStart() {
        return ;
    }
    public long getLastSyncEnd() {
        return ;
    }
    public void setNextSyncStart(long nextSyncStart) {        
        this. = nextSyncStart;
    }
    public void setLastSyncEnd(long lastSyncEnd) {
        this. = lastSyncEnd;
    }
    /* The binding used to write the LogChangeSet information to the SyncDB. */
    public static class LogChangeSetBinding 
            extends TupleBinding<LogChangeSet> {
        @Override
        public LogChangeSet entryToObject(TupleInput input) {
            LogChangeSet changeSet =
                new LogChangeSet(input.readLong(), input.readLong());
            return changeSet;
        }
        @Override
        public void objectToEntry(LogChangeSet changeSet
                                  TupleOutput output) {
            output.writeLong(changeSet.getNextSyncStart());
            output.writeLong(changeSet.getLastSyncEnd());
        }
    }
New to GrepCode? Check out our FAQ X