modules/gemfire-modules/src/main/java/com/gemstone/gemfire/modules/util/ModuleStatistics.java

/*=========================================================================
 * Copyright (c) 2010-2014 Pivotal Software, Inc. All Rights Reserved.
 * This product is protected by U.S. and international copyright
 * and intellectual property laws. Pivotal products are covered by
 * one or more patents listed at http://www.pivotal.io/patents.
 *=========================================================================
 */
package com.gemstone.gemfire.modules.util;

import com.gemstone.gemfire.StatisticDescriptor;
import com.gemstone.gemfire.Statistics;
import com.gemstone.gemfire.StatisticsFactory;
import com.gemstone.gemfire.StatisticsType;
import com.gemstone.gemfire.StatisticsTypeFactory;
import com.gemstone.gemfire.distributed.DistributedSystem;
import com.gemstone.gemfire.internal.StatisticsTypeFactoryImpl;

/**
 * Statistics for modules.
 *
 * @author sbawaska
 */
public class ModuleStatistics {

  private static final StatisticsType type;

  private static final int cacheHitsId;

  private static final int cacheMissesId;

  private static final int hibernateEntityDestroyJobsScheduledId;

  static {
    StatisticsTypeFactory f = StatisticsTypeFactoryImpl.singleton();
    type = f
        .createType(
            "pluginStats",
            "statistics for hibernate plugin and hibernate L2 cache",
            new StatisticDescriptor[]{
                f.createLongCounter("cacheHits",
                    "number of times an entity was found in L2 cache", "count"),
                f.createLongCounter("cacheMisses",
                    "number of times an entity was NOT found in l2 cache",
                    "count"),
                f.createLongCounter(
                    "hibernateEntityDestroyJobsScheduled",
                    "number of entities scheduled for destroy because of version conflict with a remote member",
                    "jobs")});

    cacheHitsId = type.nameToId("cacheHits");
    cacheMissesId = type.nameToId("cacheMisses");
    hibernateEntityDestroyJobsScheduledId = type
        .nameToId("hibernateEntityDestroyJobsScheduled");
  }

  private final Statistics stats;

  private static ModuleStatistics instance;

  private ModuleStatistics(StatisticsFactory factory) {
    this.stats = factory.createAtomicStatistics(type, "PluginStatistics");
  }

  public static ModuleStatistics getInstance(DistributedSystem system) {
    synchronized (ModuleStatistics.class) {
      if (instance == null) {
        instance = new ModuleStatistics(system);
      }
    }
    return instance;
  }

  public void incCacheHit() {
    stats.incLong(cacheHitsId, 1);
  }

  public long getCacheHits() {
    return stats.getLong(cacheHitsId);
  }

  public void incCacheMiss() {
    stats.incLong(cacheMissesId, 1);
  }

  public long getCacheMiss() {
    return stats.getLong(cacheMissesId);
  }

  public void incHibernateDestroyJobsScheduled() {
    stats.incLong(hibernateEntityDestroyJobsScheduledId, 1);
  }
}