Examples of com.sleepycat.je.utilint.StatGroup

com.sleepycat.je.utilint.StatGroup
The Stats infrastructure provides context for JE statistics. Each statistic has these attributes: - metadata - specifically, a name and description - each statistic is associated with a parent stat group, which itself has a name and description. - support for the StatsConfig.clear semantics - a way to print statistics in a user friendly way. To create a statistic variable, instantiate one of the concrete subclasses of Stat. Each concrete subclass should hold the methods that are needed to best set and display the value. For example, instead of using LongStat to hold a timestamp or LSN value, use TimestampStat or LSNStat. A Stat instance needs to specify a StatDefinition. There may be multiple Stat variables in different components that share a StatDefinition. They are differentiated when displayed by their parent StatGroup. Each Stat instance is associated with a StatGroup, which holds the collection of stats that belong to a given component. Each member of the StatGroup has a unique StatDefinition. StatGroups can be combined, in order to accumulate values. For example, the LockManager may have multiple lock tables. Each lock table keeps its own latch statistics. When LockStats are generated, the StatsGroup for each latch is collected and rolled up into a single StatGroup, using the addAll(StatGroup) method. The Stats infrastructure is for internal use only. Public API classes like EnvironmentStats, LockStats, etc, contain StatGroups. A call to retrieve stats is implementing by getting a clone of the StatGroups held by the components like the cleaner, the incompressor, the LockManager, etc. The public API classes provide getter methods that reach into the StatGroups to return the specific stat value. To add a statistic, create the Stat variable in the component where it is being used and associate it with a StatGroup. The Stat infrastruture does the rest of the work for plumbing that statistic up to the public API class. Each API class must provide a getter method to access the specific statistic. Currenly, this is done manually.

    /**
     * Return stats for the multiple INLists covered by this evictor.
     */
    @Override
    StatGroup getINListStats(StatsConfig config) {
        StatGroup totalINListStats = new StatGroup("temp", "temp");
        if (config.getFast()) {


            /* 
             * This is a slow stat for shared envs, because of the need to
             * synchronize.
             */
            return totalINListStats;
        }


        List<Subject> copy = null;
        synchronized(this) {
            copy = new ArrayList<Subject>(subjects);
        }


        for (Subject s: copy) {
            totalINListStats.addAll(s.env.getInMemoryINs().loadStats());
        }


        return totalINListStats;
    }

View Full Code Here

            (EnvironmentParams.COMPRESSOR_LOCK_TIMEOUT);
        binRefQueue = new HashMap<Long, BINReference>();
        binRefQueueSync = new Object();
 
        /* Do the stats definitions. */
        stats = new StatGroup(GROUP_NAME, GROUP_DESC);
        splitBins = new LongStat(stats, INCOMP_SPLIT_BINS);
        dbClosedBins = new LongStat(stats, INCOMP_DBCLOSED_BINS);
        cursorsBins = new LongStat(stats, INCOMP_CURSORS_BINS);
        nonEmptyBins = new LongStat(stats, INCOMP_NON_EMPTY_BINS);
        processedBins = new LongStat(stats, INCOMP_PROCESSED_BINS);

View Full Code Here

    /**
     * @hidden
     * Internal use only.
     */
    public EnvironmentStats() {
        incompStats = new StatGroup(INCompStatDefinition.GROUP_NAME,
                                    INCompStatDefinition.GROUP_DESC);
        /* 
         * Memory budget stats are displayed with evictor stats, as a single
         * cache category.
         */
        cacheStats = new StatGroup(EvictorStatDefinition.GROUP_NAME,
                                   EvictorStatDefinition.GROUP_DESC);
        ckptStats = new StatGroup(CheckpointStatDefinition.GROUP_NAME,
                                  CheckpointStatDefinition.GROUP_DESC);
        cleanerStats = new StatGroup(CleanerStatDefinition.GROUP_NAME,
                                     CleanerStatDefinition.GROUP_DESC);
        logStats = new StatGroup(LogStatDefinition.GROUP_NAME, 
                                 LogStatDefinition.GROUP_DESC);
        lockStats = new StatGroup(LockStatDefinition.GROUP_NAME,
                                  LockStatDefinition.GROUP_DESC);
        envImplStats = new StatGroup(DbiStatDefinition.ENV_GROUP_NAME,
                                     DbiStatDefinition.ENV_GROUP_DESC);
    }

View Full Code Here

        logWriteLatch = new Latch(DEBUG_NAME);
        readBufferSize =
            configManager.getInt(EnvironmentParams.LOG_FAULT_READ_SIZE);


        /* Do the stats definitions. */
        stats = new StatGroup(GROUP_NAME, GROUP_DESC);
        nRepeatFaultReads = new LongStat(stats, LOGMGR_REPEAT_FAULT_READS);
        nTempBufferWrites = new LongStat(stats, LOGMGR_TEMP_BUFFER_WRITES);
        endOfLog = new LSNStat(stats, LOGMGR_END_OF_LOG);
    }

View Full Code Here


        if (!config.getFast()) {
            loadEndOfLogStat();
        }


        StatGroup copyStats = stats.cloneGroup(config.getClear());
        /* Add all the LogBufferPool's stats to the LogManager's stat group. */
        copyStats.addAll(logBufferPool.loadStats(config));
        /* Add all the FileManager's stats to the LogManager's stat group. */
        copyStats.addAll(fileManager.loadStats(config));


        return copyStats;
    }

View Full Code Here


    /**
     * All stats from the INList are instantaneous -- never need to be cleared.
     */
    public StatGroup loadStats() {
        StatGroup stats = new StatGroup(EvictorStatDefinition.GROUP_NAME,
                              EvictorStatDefinition.GROUP_DESC);


        long bstat = nCachedBINs.get();
        long istat = nCachedUpperINs.get();
        new LongStat(stats, EvictorStatDefinition.CACHED_UPPER_INS,

View Full Code Here

            configManager.getDuration(RepParams.REPLAY_TXN_LOCK_TIMEOUT);
        defaultConsistencyPolicy = RepUtils.getReplicaConsistencyPolicy
            (configManager.get(RepParams.CONSISTENCY_POLICY));
        addRepConfigObserver(this);


        nodeStats = new StatGroup(RepImplStatDefinition.GROUP_NAME,
                                  RepImplStatDefinition.GROUP_DESC);
        hardRecoveryStat = new BooleanStat(nodeStats,
                                           RepImplStatDefinition.HARD_RECOVERY);
        hardRecoveryInfoStat = 
            new StringStat(nodeStats, RepImplStatDefinition.HARD_RECOVERY_INFO,

View Full Code Here

     * @param map the actual map instance.
     */
    public SizeAwaitMap(Map<K, V> map) {
        thresholdLatches = new HashMap<Integer,ThresholdLatch>();
        this.map = map;
        stats = new StatGroup(SizeAwaitMapStatDefinition.GROUP_NAME,
                              SizeAwaitMapStatDefinition.GROUP_DESC);
        nNoWaits = new LongStat(stats, N_NO_WAITS);
        nRealWaits = new LongStat(stats, N_REAL_WAITS);
        nWaitTime = new LongStat(stats, N_WAIT_TIME);
    }

View Full Code Here


    /**
     * Loads file selection stats.
     */
    synchronized StatGroup loadStats() {
        StatGroup stats = new StatGroup(CleanerStatDefinition.FS_GROUP_NAME,
                                        CleanerStatDefinition.FS_GROUP_DESC);
        new IntStat(stats, CLEANER_BACKLOG, getBacklog());
        new IntStat(stats, CLEANER_FILE_DELETION_BACKLOG, 
                    getNumberOfFiles(FileStatus.SAFE_TO_DELETE));

View Full Code Here

    public static final String FEEDER_SERVICE = "Feeder";


    FeederManager(RepNode repNode) {
        this.repNode = repNode;
        logger = LoggerUtils.getLogger(getClass());
        stats = new StatGroup(FeederManagerStatDefinition.GROUP_NAME,
                              FeederManagerStatDefinition.GROUP_DESC);
        nFeedersCreated = new IntStat(stats, N_FEEDERS_CREATED);
        nFeedersShutdown = new IntStat(stats, N_FEEDERS_SHUTDOWN);
    }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of com.sleepycat.je.utilint.StatGroup

com.sleepycat.je.BtreeStats

com.sleepycat.je.cleaner.Cleaner

com.sleepycat.je.cleaner.FileSelector

com.sleepycat.je.dbi.DatabaseImpl$StatsAccumulator

com.sleepycat.je.dbi.EnvironmentImpl

com.sleepycat.je.dbi.INList

com.sleepycat.je.dbi.MemoryBudget

com.sleepycat.je.EnvironmentStats

com.sleepycat.je.evictor.Arbiter

com.sleepycat.je.evictor.Evictor

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.