in geode-core/src/main/java/org/apache/geode/distributed/internal/locks/DLockStats.java [113:397]
static {
String statName = "DLockStats";
String statDescription = "Statistics on the gemfire distribution lock service.";
final String grantorsDesc = "The current number of lock grantors hosted by this system member.";
final String servicesDesc = "The current number of lock services used by this system member.";
final String tokensDesc = "The current number of lock tokens used by this system member.";
final String grantTokensDesc = "The current number of grant tokens used by local grantors.";
final String requestQueuesDesc =
"The current number of lock request queues used by this system member.";
final String serialQueueSizeDesc =
"The number of serial distribution messages currently waiting to be processed.";
final String serialThreadsDesc =
"The number of threads currently processing serial/ordered messages.";
final String waitingQueueSizeDesc =
"The number of distribution messages currently waiting for some other resource before they can be processed.";
final String waitingThreadsDesc =
"The number of threads currently processing messages that had to wait for a resource.";
final String lockWaitsInProgressDesc =
"Current number of threads waiting for a distributed lock.";
final String lockWaitsCompletedDesc =
"Total number of times distributed lock wait has completed by successfully obtained the lock.";
final String lockWaitTimeDesc =
"Total time spent waiting for a distributed lock that was obtained.";
final String lockWaitsFailedDesc =
"Total number of times distributed lock wait has completed by failing to obtain the lock.";
final String lockWaitFailedTimeDesc =
"Total time spent waiting for a distributed lock that we failed to obtain.";
final String grantWaitsInProgressDesc =
"Current number of distributed lock requests being granted.";
final String grantWaitsCompletedDesc =
"Total number of times granting of a lock request has completed by successfully granting the lock.";
final String grantWaitTimeDesc = "Total time spent attempting to grant a distributed lock.";
final String grantWaitsNotGrantorDesc =
"Total number of times granting of lock request failed because not grantor.";
final String grantWaitNotGrantorTimeDesc =
"Total time spent granting of lock requests that failed because not grantor.";
final String grantWaitsTimeoutDesc =
"Total number of times granting of lock request failed because timeout.";
final String grantWaitTimeoutTimeDesc =
"Total time spent granting of lock requests that failed because timeout.";
final String grantWaitsNotHolderDesc =
"Total number of times granting of lock request failed because reentrant was not holder.";
final String grantWaitNotHolderTimeDesc =
"Total time spent granting of lock requests that failed because reentrant was not holder.";
final String grantWaitsFailedDesc =
"Total number of times granting of lock request failed because try locks failed.";
final String grantWaitFailedTimeDesc =
"Total time spent granting of lock requests that failed because try locks failed.";
final String grantWaitsSuspendedDesc =
"Total number of times granting of lock request failed because lock service was suspended.";
final String grantWaitSuspendedTimeDesc =
"Total time spent granting of lock requests that failed because lock service was suspended.";
final String grantWaitsDestroyedDesc =
"Total number of times granting of lock request failed because lock service was destroyed.";
final String grantWaitDestroyedTimeDesc =
"Total time spent granting of lock requests that failed because lock service was destroyed.";
final String createGrantorsInProgressDesc =
"Current number of initial grantors being created in this process.";
final String createGrantorsCompletedDesc =
"Total number of initial grantors created in this process.";
final String createGrantorTimeDesc =
"Total time spent waiting create the intial grantor for lock services.";
final String serviceCreatesInProgressDesc =
"Current number of lock services being created in this process.";
final String serviceCreatesCompletedDesc =
"Total number of lock services created in this process.";
final String serviceCreateLatchTimeDesc =
"Total time spent creating lock services before releasing create latches.";
final String serviceInitLatchTimeDesc =
"Total time spent creating lock services before releasing init latches.";
final String grantorWaitsInProgressDesc =
"Current number of threads waiting for grantor latch to open.";
final String grantorWaitsCompletedDesc =
"Total number of times waiting threads completed waiting for the grantor latch to open.";
final String grantorWaitTimeDesc =
"Total time spent waiting for the grantor latch which resulted in success.";
final String grantorWaitsFailedDesc =
"Total number of times waiting threads failed to finish waiting for the grantor latch to open.";
final String grantorWaitFailedTimeDesc =
"Total time spent waiting for the grantor latch which resulted in failure.";
final String grantorThreadsInProgressDesc =
"Current iterations of work performed by grantor thread(s).";
final String grantorThreadsCompletedDesc =
"Total number of iterations of work performed by grantor thread(s).";
final String grantorThreadExpireAndGrantLocksTimeDesc =
"Total time spent by grantor thread(s) performing expireAndGrantLocks tasks.";
final String grantorThreadHandleRequestTimeoutsTimeDesc =
"Total time spent by grantor thread(s) performing handleRequestTimeouts tasks.";
final String grantorThreadRemoveUnusedTokensTimeDesc =
"Total time spent by grantor thread(s) performing removeUnusedTokens tasks.";
final String grantorThreadTimeDesc =
"Total time spent by grantor thread(s) performing all grantor tasks.";
final String pendingRequestsDesc =
"The current number of pending lock requests queued by grantors in this process.";
final String destroyReadWaitsInProgressDesc =
"Current number of threads waiting for a DLockService destroy read lock.";
final String destroyReadWaitsCompletedDesc =
"Total number of times a DLockService destroy read lock wait has completed successfully.";
final String destroyReadWaitTimeDesc =
"Total time spent waiting for a DLockService destroy read lock that was obtained.";
final String destroyReadWaitsFailedDesc =
"Total number of times a DLockService destroy read lock wait has completed unsuccessfully.";
final String destroyReadWaitFailedTimeDesc =
"Total time spent waiting for a DLockService destroy read lock that was not obtained.";
final String destroyWriteWaitsInProgressDesc =
"Current number of thwrites waiting for a DLockService destroy write lock.";
final String destroyWriteWaitsCompletedDesc =
"Total number of times a DLockService destroy write lock wait has completed successfully.";
final String destroyWriteWaitTimeDesc =
"Total time spent waiting for a DLockService destroy write lock that was obtained.";
final String destroyWriteWaitsFailedDesc =
"Total number of times a DLockService destroy write lock wait has completed unsuccessfully.";
final String destroyWriteWaitFailedTimeDesc =
"Total time spent waiting for a DLockService destroy write lock that was not obtained.";
final String destroyReadsDesc =
"The current number of DLockService destroy read locks held by this process.";
final String destroyWritesDesc =
"The current number of DLockService destroy write locks held by this process.";
final String lockReleasesInProgressDesc =
"Current number of threads releasing a distributed lock.";
final String lockReleasesCompletedDesc =
"Total number of times distributed lock release has completed.";
final String lockReleaseTimeDesc = "Total time spent releasing a distributed lock.";
final String becomeGrantorRequestsDesc =
"Total number of times this member has explicitly requested to become lock grantor.";
final String freeResourcesCompletedDesc =
"Total number of times this member has freed resources for a distributed lock.";
final String freeResourcesFailedDesc =
"Total number of times this member has attempted to free resources for a distributed lock which remained in use.";
StatisticsTypeFactory f = StatisticsTypeFactoryImpl.singleton();
type = f.createType(statName, statDescription, new StatisticDescriptor[] {
f.createIntGauge("grantors", grantorsDesc, "grantors"),
f.createIntGauge("services", servicesDesc, "services"),
f.createIntGauge("tokens", tokensDesc, "tokens"),
f.createIntGauge("grantTokens", grantTokensDesc, "grantTokens"),
f.createIntGauge("requestQueues", requestQueuesDesc, "requestQueues"),
f.createIntGauge("serialQueueSize", serialQueueSizeDesc, "messages"),
f.createIntGauge("serialThreads", serialThreadsDesc, "threads"),
f.createIntGauge("waitingQueueSize", waitingQueueSizeDesc, "messages"),
f.createIntGauge("waitingThreads", waitingThreadsDesc, "threads"),
f.createIntGauge("lockWaitsInProgress", lockWaitsInProgressDesc, "operations"),
f.createIntCounter("lockWaitsCompleted", lockWaitsCompletedDesc, "operations"),
f.createLongCounter("lockWaitTime", lockWaitTimeDesc, "nanoseconds", false),
f.createIntCounter("lockWaitsFailed", lockWaitsFailedDesc, "operations"),
f.createLongCounter("lockWaitFailedTime", lockWaitFailedTimeDesc, "nanoseconds", false),
f.createIntGauge("grantWaitsInProgress", grantWaitsInProgressDesc, "operations"),
f.createIntCounter("grantWaitsCompleted", grantWaitsCompletedDesc, "operations"),
f.createLongCounter("grantWaitTime", grantWaitTimeDesc, "nanoseconds", false),
f.createIntCounter("grantWaitsNotGrantor", grantWaitsNotGrantorDesc, "operations"),
f.createLongCounter("grantWaitNotGrantorTime", grantWaitNotGrantorTimeDesc, "nanoseconds",
false),
f.createIntCounter("grantWaitsTimeout", grantWaitsTimeoutDesc, "operations"),
f.createLongCounter("grantWaitTimeoutTime", grantWaitTimeoutTimeDesc, "nanoseconds", false),
f.createIntCounter("grantWaitsNotHolder", grantWaitsNotHolderDesc, "operations"),
f.createLongCounter("grantWaitNotHolderTime", grantWaitNotHolderTimeDesc, "nanoseconds",
false),
f.createIntCounter("grantWaitsFailed", grantWaitsFailedDesc, "operations"),
f.createLongCounter("grantWaitFailedTime", grantWaitFailedTimeDesc, "nanoseconds", false),
f.createIntCounter("grantWaitsSuspended", grantWaitsSuspendedDesc, "operations"),
f.createLongCounter("grantWaitSuspendedTime", grantWaitSuspendedTimeDesc, "nanoseconds",
false),
f.createIntCounter("grantWaitsDestroyed", grantWaitsDestroyedDesc, "operations"),
f.createLongCounter("grantWaitDestroyedTime", grantWaitDestroyedTimeDesc, "nanoseconds",
false),
f.createIntGauge("createGrantorsInProgress", createGrantorsInProgressDesc, "operations"),
f.createIntCounter("createGrantorsCompleted", createGrantorsCompletedDesc, "operations"),
f.createLongCounter("createGrantorTime", createGrantorTimeDesc, "nanoseconds", false),
f.createIntGauge("serviceCreatesInProgress", serviceCreatesInProgressDesc, "operations"),
f.createIntCounter("serviceCreatesCompleted", serviceCreatesCompletedDesc, "operations"),
f.createLongCounter("serviceCreateLatchTime", serviceCreateLatchTimeDesc, "nanoseconds",
false),
f.createLongCounter("serviceInitLatchTime", serviceInitLatchTimeDesc, "nanoseconds", false),
f.createIntGauge("grantorWaitsInProgress", grantorWaitsInProgressDesc, "operations"),
f.createIntCounter("grantorWaitsCompleted", grantorWaitsCompletedDesc, "operations"),
f.createLongCounter("grantorWaitTime", grantorWaitTimeDesc, "nanoseconds", false),
f.createIntCounter("grantorWaitsFailed", grantorWaitsFailedDesc, "operations"),
f.createLongCounter("grantorWaitFailedTime", grantorWaitFailedTimeDesc, "nanoseconds",
false),
f.createIntGauge("grantorThreadsInProgress", grantorThreadsInProgressDesc, "operations"),
f.createIntCounter("grantorThreadsCompleted", grantorThreadsCompletedDesc, "operations"),
f.createLongCounter("grantorThreadExpireAndGrantLocksTime",
grantorThreadExpireAndGrantLocksTimeDesc, "nanoseconds", false),
f.createLongCounter("grantorThreadHandleRequestTimeoutsTime",
grantorThreadHandleRequestTimeoutsTimeDesc, "nanoseconds", false),
f.createLongCounter("grantorThreadRemoveUnusedTokensTime",
grantorThreadRemoveUnusedTokensTimeDesc, "nanoseconds", false),
f.createLongCounter("grantorThreadTime", grantorThreadTimeDesc, "nanoseconds", false),
f.createIntGauge("pendingRequests", pendingRequestsDesc, "pendingRequests"),
f.createIntGauge("destroyReadWaitsInProgress", destroyReadWaitsInProgressDesc,
"operations"),
f.createIntCounter("destroyReadWaitsCompleted", destroyReadWaitsCompletedDesc,
"operations"),
f.createLongCounter("destroyReadWaitTime", destroyReadWaitTimeDesc, "nanoseconds", false),
f.createIntCounter("destroyReadWaitsFailed", destroyReadWaitsFailedDesc, "operations"),
f.createLongCounter("destroyReadWaitFailedTime", destroyReadWaitFailedTimeDesc,
"nanoseconds", false),
f.createIntGauge("destroyWriteWaitsInProgress", destroyWriteWaitsInProgressDesc,
"operations"),
f.createIntCounter("destroyWriteWaitsCompleted", destroyWriteWaitsCompletedDesc,
"operations"),
f.createLongCounter("destroyWriteWaitTime", destroyWriteWaitTimeDesc, "nanoseconds", false),
f.createIntCounter("destroyWriteWaitsFailed", destroyWriteWaitsFailedDesc, "operations"),
f.createLongCounter("destroyWriteWaitFailedTime", destroyWriteWaitFailedTimeDesc,
"nanoseconds", false),
f.createIntGauge("destroyReads", destroyReadsDesc, "destroyReads"),
f.createIntGauge("destroyWrites", destroyWritesDesc, "destroyWrites"),
f.createIntGauge("lockReleasesInProgress", lockReleasesInProgressDesc, "operations"),
f.createIntCounter("lockReleasesCompleted", lockReleasesCompletedDesc, "operations"),
f.createLongCounter("lockReleaseTime", lockReleaseTimeDesc, "nanoseconds", false),
f.createIntCounter("becomeGrantorRequests", becomeGrantorRequestsDesc, "operations"),
f.createIntCounter("freeResourcesCompleted", freeResourcesCompletedDesc, "operations"),
f.createIntCounter("freeResourcesFailed", freeResourcesFailedDesc, "operations"),});
// Initialize id fields
grantorsId = type.nameToId("grantors");
servicesId = type.nameToId("services");
tokensId = type.nameToId("tokens");
grantTokensId = type.nameToId("grantTokens");
requestQueuesId = type.nameToId("requestQueues");
serialQueueSizeId = type.nameToId("serialQueueSize");
serialThreadsId = type.nameToId("serialThreads");
waitingQueueSizeId = type.nameToId("waitingQueueSize");
waitingThreadsId = type.nameToId("waitingThreads");
lockWaitsInProgressId = type.nameToId("lockWaitsInProgress");
lockWaitsCompletedId = type.nameToId("lockWaitsCompleted");
lockWaitTimeId = type.nameToId("lockWaitTime");
lockWaitsFailedId = type.nameToId("lockWaitsFailed");
lockWaitFailedTimeId = type.nameToId("lockWaitFailedTime");
grantWaitsInProgressId = type.nameToId("grantWaitsInProgress");
grantWaitsCompletedId = type.nameToId("grantWaitsCompleted");
grantWaitTimeId = type.nameToId("grantWaitTime");
grantWaitsNotGrantorId = type.nameToId("grantWaitsNotGrantor");
grantWaitNotGrantorTimeId = type.nameToId("grantWaitNotGrantorTime");
grantWaitsTimeoutId = type.nameToId("grantWaitsTimeout");
grantWaitTimeoutTimeId = type.nameToId("grantWaitTimeoutTime");
grantWaitsNotHolderId = type.nameToId("grantWaitsNotHolder");
grantWaitNotHolderTimeId = type.nameToId("grantWaitNotHolderTime");
grantWaitsFailedId = type.nameToId("grantWaitsFailed");
grantWaitFailedTimeId = type.nameToId("grantWaitFailedTime");
grantWaitsSuspendedId = type.nameToId("grantWaitsSuspended");
grantWaitSuspendedTimeId = type.nameToId("grantWaitSuspendedTime");
grantWaitsDestroyedId = type.nameToId("grantWaitsDestroyed");
grantWaitDestroyedTimeId = type.nameToId("grantWaitDestroyedTime");
createGrantorsInProgressId = type.nameToId("createGrantorsInProgress");
createGrantorsCompletedId = type.nameToId("createGrantorsCompleted");
createGrantorTimeId = type.nameToId("createGrantorTime");
serviceCreatesInProgressId = type.nameToId("serviceCreatesInProgress");
serviceCreatesCompletedId = type.nameToId("serviceCreatesCompleted");
serviceCreateLatchTimeId = type.nameToId("serviceCreateLatchTime");
serviceInitLatchTimeId = type.nameToId("serviceInitLatchTime");
grantorWaitsInProgressId = type.nameToId("grantorWaitsInProgress");
grantorWaitsCompletedId = type.nameToId("grantorWaitsCompleted");
grantorWaitTimeId = type.nameToId("grantorWaitTime");
grantorWaitsFailedId = type.nameToId("grantorWaitsFailed");
grantorWaitFailedTimeId = type.nameToId("grantorWaitFailedTime");
grantorThreadsInProgressId = type.nameToId("grantorThreadsInProgress");
grantorThreadsCompletedId = type.nameToId("grantorThreadsCompleted");
grantorThreadExpireAndGrantLocksTimeId = type.nameToId("grantorThreadExpireAndGrantLocksTime");
grantorThreadHandleRequestTimeoutsTimeId =
type.nameToId("grantorThreadHandleRequestTimeoutsTime");
grantorThreadRemoveUnusedTokensTimeId = type.nameToId("grantorThreadRemoveUnusedTokensTime");
grantorThreadTimeId = type.nameToId("grantorThreadTime");
pendingRequestsId = type.nameToId("pendingRequests");
destroyReadWaitsInProgressId = type.nameToId("destroyReadWaitsInProgress");
destroyReadWaitsCompletedId = type.nameToId("destroyReadWaitsCompleted");
destroyReadWaitTimeId = type.nameToId("destroyReadWaitTime");
destroyReadWaitsFailedId = type.nameToId("destroyReadWaitsFailed");
destroyReadWaitFailedTimeId = type.nameToId("destroyReadWaitFailedTime");
destroyWriteWaitsInProgressId = type.nameToId("destroyWriteWaitsInProgress");
destroyWriteWaitsCompletedId = type.nameToId("destroyWriteWaitsCompleted");
destroyWriteWaitTimeId = type.nameToId("destroyWriteWaitTime");
destroyWriteWaitsFailedId = type.nameToId("destroyWriteWaitsFailed");
destroyWriteWaitFailedTimeId = type.nameToId("destroyWriteWaitFailedTime");
destroyReadsId = type.nameToId("destroyReads");
destroyWritesId = type.nameToId("destroyWrites");
lockReleasesInProgressId = type.nameToId("lockReleasesInProgress");
lockReleasesCompletedId = type.nameToId("lockReleasesCompleted");
lockReleaseTimeId = type.nameToId("lockReleaseTime");
becomeGrantorRequestsId = type.nameToId("becomeGrantorRequests");
freeResourcesCompletedId = type.nameToId("freeResourcesCompleted");
freeResourcesFailedId = type.nameToId("freeResourcesFailed");
} // static block