/* (non-Javadoc)
@see com.ibm.ws.sib.msgstore.CacheStatistics#getTotalRefusalCount()
421076
public final long getTotalRefusalCount()
    {
        long result = 0;
        result = result + _storedItemManager.getStatistics().getTotalRefusalCount();
        result = result + _unstoredItemManager.getStatistics().getTotalRefusalCount();
        return result;
    }
525233
public final long getCurrentCount()
    {
        long result = 0;
        result = result + _storedItemManager.getCurrentCount();
        result = result + _unstoredItemManager.getCurrentCount();
        return result;
    }
460172
@Override
    public List<Integer> getStepThreadInstancePartitionNumbersOfRelatedCompletedPartitions(
                                                                                           final StepThreadInstanceKey topLevelKey) {

        final EntityManager em = getPsu().createEntityManager();

        try {
            List<Integer> exec = new TranRequest<List<Integer>>(em) {
                @Override
                public List<Integer> call() throws Exception {
                    TypedQuery<Integer> query = em.createNamedQuery(TopLevelStepInstanceEntity.GET_RELATED_PARTITION_LEVEL_COMPLETED_PARTITION_NUMBERS,
                                                                    Integer.class);
                    query.setParameter("instanceId", topLevelKey.getJobInstance());
                    query.setParameter("stepName", topLevelKey.getStepName());

                    return query.getResultList();
                }
            }.runInNewOrExistingGlobalTran();
            return exec;
        } finally {
            em.close();
        }

    }
329296
public int getCount() throws InterruptedException, KeeperException {
        return ByteBuffer.wrap(m_zk.getData(m_path, false, null)).getInt();
    }
956410
public double getAverage() {
        readLock.lock();
        try {
            // any values at all, needed to avoid a DivideByZero exception
            if (this.values.size() <= 0) {
                return 0;
            }
            return ((double)this.total / (double)this.values.size());
        } finally {
            readLock.unlock();
        }
    }
136053
public static double getTotalGCPercentage() {
        long totalCollectionTime = getTotalCollectionTime();
        if(totalCollectionTime == -1) {
            return -1.0;
        }
        long uptime = ManagementFactory.getRuntimeMXBean().getUptime();
        return ((double) totalCollectionTime / (double) uptime);
    }
426652
public int getTotalLockCount() {
      int count = 0;
      for (ReentrantReadWriteLock lock : sharedLocks) {
         count += lock.getReadLockCount();
         count += lock.isWriteLocked() ? 1 : 0;
      }
      return count;
   }
934526
public static long getProcessedCount(List<TaskState> taskStates) {
    long value = 0;

    for (TaskState taskState : taskStates) {
      value += taskState.getPropAsLong(ConfigurationKeys.WRITER_RECORDS_WRITTEN, 0);
    }

    return value;
  }
821847
public int getConsumersCount()
    {
    	synchronized (sessions)
		{
    		if (sessions.isEmpty())
    			return 0;
    
    		int total = 0;
    		Iterator<AbstractSession>sessionsIterator = sessions.values().iterator();
			while (sessionsIterator.hasNext())
			{
				AbstractSession session = sessionsIterator.next();
				total += session.getConsumersCount();
			}
			return total;
		}
    }
213035
public long count() throws Exception {
		final String id = new AbstractID().toString();

		output(new Utils.CountHelper<T>(id)).name("count()");

		JobExecutionResult res = getExecutionEnvironment().execute();
		return res.<Long> getAccumulatorResult(id);
	}
91202
public long getTotalSavings() {
		long totalSavings = 0;
		for (OptimizerResult result : results) {
			totalSavings += (result.getOriginalFileSize() - result.getOptimizedFileSize());
		}

		return totalSavings;
	}
1216187
public EtcdStoreStatsResponse getStoreStats() {
    try {
      return new EtcdStoreStatsRequest(this.client, retryHandler).send().get();
    } catch (IOException | EtcdException | EtcdAuthenticationException | TimeoutException e) {
      return null;
    }
  }
611666
public int getBlankCount() {
        int count = mBlankCount;
        if (count < 0) {
            mBlankCount = count = (mPropFilter.isConstant() ? 0 : 1)
                + ((mPrev == null) ? 0 : mPrev.getBlankCount());
        }
        return count;
    }
42511
public Number getTotalCount(Criterion... criterion) throws HibernateException {
        Criteria criteria = getSession().createCriteria(entityClass);
        addCriterionsToCriteria(criteria, criterion);
        criteria.setProjection(Projections.rowCount());
        return (Long) criteria.uniqueResult();
    }
1153721
public long getNumberOfQueuedMessages()
  {
    long count = 0;
    try
    {
      count = itemStream.getStatistics().getTotalItemCount();
    }
    catch (MessageStoreException e)
    {
      FFDCFilter.processException(
          e,
          "com.ibm.ws.sib.processor.runtime.LocalQueuePoint.getNumberOfQueuedMessages",
          "1:494:1.58", 
          this);
      SibTr.exception(tc, e);
    }    
    return count;
  }
814979
@Override
    public Long getRepositoryObjectCount() {
        final Repository repo = getJcrRepository(repository);
        try {
            return getRepositoryCount(repo);
        } catch (final RepositoryException e) {
            throw new RepositoryRuntimeException(e);
        }
    }
844860
public Integer getCountAtOrAbove(final long version) {
        if (versionsStored < versionWindow.length) {
            return null;
        }
        int count = 0;
        for (int versionIdx = 0; versionIdx < versionWindow.length; versionIdx++) {
            if (versionWindow[versionIdx] >= version) {
                count++;
            }
        }

        return count;
    }