in geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionStats.java [247:938]
static {
String statName = "DistributionStats";
String statDescription = "Statistics on the gemfire distribution layer.";
final String sentMessagesDesc =
"The number of distribution messages that this GemFire system has sent. This includes broadcastMessages.";
final String sentCommitMessagesDesc =
"The number of transaction commit messages that this GemFire system has created to be sent. Note that it is possible for a commit to only create one message even though it will end up being sent to multiple recipients.";
final String commitWaitsDesc =
"The number of transaction commits that had to wait for a response before they could complete.";
final String sentMessagesTimeDesc =
"The total amount of time this distribution manager has spent sending messages. This includes broadcastMessagesTime.";
final String sentMessagesMaxTimeDesc =
"The highest amount of time this distribution manager has spent distributing a single message to the network.";
final String broadcastMessagesDesc =
"The number of distribution messages that this GemFire system has broadcast. A broadcast message is one sent to every other manager in the group.";
final String broadcastMessagesTimeDesc =
"The total amount of time this distribution manager has spent broadcasting messages. A broadcast message is one sent to every other manager in the group.";
final String receivedMessagesDesc =
"The number of distribution messages that this GemFire system has received.";
final String receivedBytesDesc =
"The number of distribution message bytes that this GemFire system has received.";
final String sentBytesDesc =
"The number of distribution message bytes that this GemFire system has sent.";
final String processedMessagesDesc =
"The number of distribution messages that this GemFire system has processed.";
final String processedMessagesTimeDesc =
"The amount of time this distribution manager has spent in message.process().";
final String messageProcessingScheduleTimeDesc =
"The amount of time this distribution manager has spent dispatching message to processor threads.";
final String overflowQueueSizeDesc =
"The number of normal distribution messages currently waiting to be processed.";
final String waitingQueueSizeDesc =
"The number of distribution messages currently waiting for some other resource before they can be processed.";
final String overflowQueueThrottleTimeDesc =
"The total amount of time, in nanoseconds, spent delayed by the overflow queue throttle.";
final String overflowQueueThrottleCountDesc =
"The total number of times a thread was delayed in adding a normal message to the overflow queue.";
final String highPriorityQueueSizeDesc =
"The number of high priority distribution messages currently waiting to be processed.";
final String highPriorityQueueThrottleTimeDesc =
"The total amount of time, in nanoseconds, spent delayed by the high priority queue throttle.";
final String highPriorityQueueThrottleCountDesc =
"The total number of times a thread was delayed in adding a normal message to the high priority queue.";
final String serialQueueSizeDesc =
"The number of serial distribution messages currently waiting to be processed.";
final String serialQueueBytesDesc =
"The approximate number of bytes consumed by serial distribution messages currently waiting to be processed.";
final String serialPooledThreadDesc =
"The number of threads created in the SerialQueuedExecutorPool.";
final String serialQueueThrottleTimeDesc =
"The total amount of time, in nanoseconds, spent delayed by the serial queue throttle.";
final String serialQueueThrottleCountDesc =
"The total number of times a thread was delayed in adding a ordered message to the serial queue.";
final String serialThreadsDesc =
"The number of threads currently processing serial/ordered messages.";
final String processingThreadsDesc =
"The number of threads currently processing normal messages.";
final String highPriorityThreadsDesc =
"The number of threads currently processing high priority messages.";
final String partitionedRegionThreadsDesc =
"The number of threads currently processing partitioned region messages.";
final String functionExecutionThreadsDesc =
"The number of threads currently processing function execution messages.";
final String waitingThreadsDesc =
"The number of threads currently processing messages that had to wait for a resource.";
final String messageChannelTimeDesc =
"The total amount of time received messages spent in the distribution channel";
final String udpDispatchRequestTimeDesc =
"The total amount of time spent deserializing and dispatching UDP messages in the message-reader thread.";
final String replyMessageTimeDesc =
"The amount of time spent processing reply messages. This includes both processedMessagesTime and messageProcessingScheduleTime.";
final String distributeMessageTimeDesc =
"The amount of time it takes to prepare a message and send it on the network. This includes sentMessagesTime.";
final String nodesDesc = "The current number of nodes in this distributed system.";
final String replyWaitsInProgressDesc = "Current number of threads waiting for a reply.";
final String replyWaitsCompletedDesc =
"Total number of times waits for a reply have completed.";
final String replyWaitTimeDesc = "Total time spent waiting for a reply to a message.";
final String replyWaitMaxTimeDesc =
"Maximum time spent transmitting and then waiting for a reply to a message. See sentMessagesMaxTime for related information";
final String replyTimeoutsDesc = "Total number of message replies that have timed out.";
final String receiverConnectionsDesc =
"Current number of sockets dedicated to receiving messages.";
final String failedAcceptsDesc =
"Total number of times an accept (receiver creation) of a connect from some other member has failed";
final String failedConnectsDesc =
"Total number of times a connect (sender creation) to some other member has failed.";
final String reconnectAttemptsDesc =
"Total number of times an established connection was lost and a reconnect was attempted.";
final String lostConnectionLeaseDesc =
"Total number of times an unshared sender socket has remained idle long enough that its lease expired.";
final String sharedOrderedSenderConnectionsDesc =
"Current number of shared sockets dedicated to sending ordered messages.";
final String sharedUnorderedSenderConnectionsDesc =
"Current number of shared sockets dedicated to sending unordered messages.";
final String threadOrderedSenderConnectionsDesc =
"Current number of thread sockets dedicated to sending ordered messages.";
final String threadUnorderedSenderConnectionsDesc =
"Current number of thread sockets dedicated to sending unordered messages.";
final String asyncQueuesDesc = "The current number of queues for asynchronous messaging.";
final String asyncQueueFlushesInProgressDesc =
"Current number of asynchronous queues being flushed.";
final String asyncQueueFlushesCompletedDesc =
"Total number of asynchronous queue flushes completed.";
final String asyncQueueFlushTimeDesc = "Total time spent flushing asynchronous queues.";
final String asyncQueueTimeoutExceededDesc =
"Total number of asynchronous queues that have timed out by being blocked for more than async-queue-timeout milliseconds.";
final String asyncQueueSizeExceededDesc =
"Total number of asynchronous queues that have exceeded max size.";
final String asyncDistributionTimeoutExceededDesc =
"Total number of times the async-distribution-timeout has been exceeded during a socket write.";
final String asyncQueueSizeDesc = "The current size in bytes used for asynchronous queues.";
final String asyncQueuedMsgsDesc =
"The total number of queued messages used for asynchronous queues.";
final String asyncDequeuedMsgsDesc =
"The total number of queued messages that have been removed from the queue and successfully sent.";
final String asyncConflatedMsgsDesc =
"The total number of queued conflated messages used for asynchronous queues.";
final String asyncThreadsDesc = "Total number of asynchronous message queue threads.";
final String asyncThreadInProgressDesc =
"Current iterations of work performed by asynchronous message queue threads.";
final String asyncThreadCompletedDesc =
"Total number of iterations of work performed by asynchronous message queue threads.";
final String asyncThreadTimeDesc =
"Total time spent by asynchronous message queue threads performing iterations.";
final String receiverDirectBufferSizeDesc =
"Current number of bytes allocated from direct memory as buffers for incoming messages.";
final String receiverHeapBufferSizeDesc =
"Current number of bytes allocated from Java heap memory as buffers for incoming messages.";
final String senderDirectBufferSizeDesc =
"Current number of bytes allocated from direct memory as buffers for outgoing messages.";
final String senderHeapBufferSizeDesc =
"Current number of bytes allocated from Java heap memory as buffers for outoing messages.";
final String replyHandoffTimeDesc =
"Total number of seconds to switch thread contexts from processing thread to application thread.";
final String partitionedRegionThreadJobsDesc =
"The number of messages currently being processed by partitioned region threads";
final String functionExecutionThreadJobsDesc =
"The number of messages currently being processed by function execution threads";
final String serialThreadJobsDesc =
"The number of messages currently being processed by serial threads.";
final String serialPooledThreadJobsDesc =
"The number of messages currently being processed by pooled serial processor threads.";
final String processingThreadJobsDesc =
"The number of messages currently being processed by pooled message processor threads.";
final String highPriorityThreadJobsDesc =
"The number of messages currently being processed by high priority processor threads.";
final String waitingThreadJobsDesc =
"The number of messages currently being processed by waiting pooly processor threads.";
final String eldersDesc = "Current number of system elders hosted in this member.";
final String initialImageMessagesInFlightDesc =
"The number of messages with initial image data sent from this member that have not yet been acknowledged.";
final String initialImageRequestsInProgressDesc =
"The number of initial images this member is currently receiving.";
// For GMSHealthMonitor
final String heartbeatRequestsSentDesc =
"Heartbeat request messages that this member has sent.";
final String heartbeatRequestsReceivedDesc =
"Heartbeat request messages that this member has received.";
final String heartbeatsSentDesc = "Heartbeat messages that this member has sent.";
final String heartbeatsReceivedDesc = "Heartbeat messages that this member has received.";
final String suspectsSentDesc = "Suspect member messages that this member has sent.";
final String suspectsReceivedDesc = "Suspect member messages that this member has received.";
final String finalCheckRequestsSentDesc = "Final check requests that this member has sent.";
final String finalCheckRequestsReceivedDesc =
"Final check requests that this member has received.";
final String finalCheckResponsesSentDesc = "Final check responses that this member has sent.";
final String finalCheckResponsesReceivedDesc =
"Final check responses that this member has received.";
final String tcpFinalCheckRequestsSentDesc =
"TCP final check requests that this member has sent.";
final String tcpFinalCheckRequestsReceivedDesc =
"TCP final check requests that this member has received.";
final String tcpFinalCheckResponsesSentDesc =
"TCP final check responses that this member has sent.";
final String tcpFinalCheckResponsesReceivedDesc =
"TCP final check responses that this member has received.";
final String udpFinalCheckRequestsSentDesc =
"UDP final check requests that this member has sent.";
final String udpFinalCheckRequestsReceivedDesc =
"UDP final check requests that this member has received.";
final String udpFinalCheckResponsesSentDesc =
"UDP final check responses that this member has sent.";
final String udpFinalCheckResponsesReceivedDesc =
"UDP final check responses that this member has received.";
final String senderCreatesDesc =
"Total amount of time, in nanoseconds, spent creating a sender.";
final String senderCreatesInProgressDesc =
"Current number of sender creations in progress.";
StatisticsTypeFactory f = StatisticsTypeFactoryImpl.singleton();
type = f.createType(statName, statDescription, new StatisticDescriptor[] {
f.createLongCounter("sentMessages", sentMessagesDesc, "messages"),
f.createLongCounter("commitMessages", sentCommitMessagesDesc, "messages"),
f.createLongCounter("commitWaits", commitWaitsDesc, "messages"),
f.createLongCounter("sentMessagesTime", sentMessagesTimeDesc, "nanoseconds", false),
f.createLongGauge("sentMessagesMaxTime", sentMessagesMaxTimeDesc, "milliseconds", false),
f.createLongCounter("broadcastMessages", broadcastMessagesDesc, "messages"),
f.createLongCounter("broadcastMessagesTime", broadcastMessagesTimeDesc, "nanoseconds",
false),
f.createLongCounter("receivedMessages", receivedMessagesDesc, "messages"),
f.createLongCounter("receivedBytes", receivedBytesDesc, "bytes"),
f.createLongCounter("sentBytes", sentBytesDesc, "bytes"),
f.createLongCounter("processedMessages", processedMessagesDesc, "messages"),
f.createLongCounter("processedMessagesTime", processedMessagesTimeDesc, "nanoseconds",
false),
f.createLongCounter("messageProcessingScheduleTime", messageProcessingScheduleTimeDesc,
"nanoseconds", false),
f.createLongGauge("overflowQueueSize", overflowQueueSizeDesc, "messages"),
f.createLongGauge("waitingQueueSize", waitingQueueSizeDesc, "messages"),
f.createLongGauge("overflowQueueThrottleCount", overflowQueueThrottleCountDesc, "delays"),
f.createLongCounter("overflowQueueThrottleTime", overflowQueueThrottleTimeDesc,
"nanoseconds", false),
f.createLongGauge("highPriorityQueueSize", highPriorityQueueSizeDesc, "messages"),
f.createLongGauge("highPriorityQueueThrottleCount", highPriorityQueueThrottleCountDesc,
"delays"),
f.createLongCounter("highPriorityQueueThrottleTime", highPriorityQueueThrottleTimeDesc,
"nanoseconds", false),
f.createLongGauge("partitionedRegionQueueSize", highPriorityQueueSizeDesc, "messages"),
f.createLongGauge("partitionedRegionQueueThrottleCount", highPriorityQueueThrottleCountDesc,
"delays"),
f.createLongCounter("partitionedRegionQueueThrottleTime", highPriorityQueueThrottleTimeDesc,
"nanoseconds", false),
f.createLongGauge("functionExecutionQueueSize", highPriorityQueueSizeDesc, "messages"),
f.createLongGauge("functionExecutionQueueThrottleCount", highPriorityQueueThrottleCountDesc,
"delays"),
f.createLongCounter("functionExecutionQueueThrottleTime", highPriorityQueueThrottleTimeDesc,
"nanoseconds", false),
f.createLongGauge("serialQueueSize", serialQueueSizeDesc, "messages"),
f.createLongGauge("serialQueueBytes", serialQueueBytesDesc, "bytes"),
f.createLongCounter("serialPooledThread", serialPooledThreadDesc, "threads"),
f.createLongGauge("serialQueueThrottleCount", serialQueueThrottleCountDesc, "delays"),
f.createLongCounter("serialQueueThrottleTime", serialQueueThrottleTimeDesc, "nanoseconds",
false),
f.createLongGauge("serialThreads", serialThreadsDesc, "threads"),
f.createLongGauge("processingThreads", processingThreadsDesc, "threads"),
f.createLongGauge("highPriorityThreads", highPriorityThreadsDesc, "threads"),
f.createLongGauge("partitionedRegionThreads", partitionedRegionThreadsDesc, "threads"),
f.createLongGauge("functionExecutionThreads", functionExecutionThreadsDesc, "threads"),
f.createLongGauge("waitingThreads", waitingThreadsDesc, "threads"),
f.createLongCounter("messageChannelTime", messageChannelTimeDesc, "nanoseconds", false),
f.createLongCounter("udpDispatchRequestTime", udpDispatchRequestTimeDesc, "nanoseconds",
false),
f.createLongCounter("replyMessageTime", replyMessageTimeDesc, "nanoseconds", false),
f.createLongCounter("distributeMessageTime", distributeMessageTimeDesc, "nanoseconds",
false),
f.createLongGauge("nodes", nodesDesc, "nodes"),
f.createLongGauge("replyWaitsInProgress", replyWaitsInProgressDesc, "operations"),
f.createLongCounter("replyWaitsCompleted", replyWaitsCompletedDesc, "operations"),
f.createLongCounter("replyWaitTime", replyWaitTimeDesc, "nanoseconds", false),
f.createLongGauge("replyWaitMaxTime", replyWaitMaxTimeDesc, "milliseconds", false),
f.createLongCounter("replyTimeouts", replyTimeoutsDesc, "timeouts", false),
f.createLongGauge("receivers", receiverConnectionsDesc, "sockets"),
f.createLongGauge("sendersSO", sharedOrderedSenderConnectionsDesc, "sockets"),
f.createLongGauge("sendersSU", sharedUnorderedSenderConnectionsDesc, "sockets"),
f.createLongGauge("sendersTO", threadOrderedSenderConnectionsDesc, "sockets"),
f.createLongGauge("sendersTU", threadUnorderedSenderConnectionsDesc, "sockets"),
f.createLongCounter("failedAccepts", failedAcceptsDesc, "accepts"),
f.createLongCounter("failedConnects", failedConnectsDesc, "connects"),
f.createLongCounter("reconnectAttempts", reconnectAttemptsDesc, "connects"),
f.createLongCounter("senderTimeouts", lostConnectionLeaseDesc, "expirations"),
f.createLongCounter("senderCreateTime", senderCreatesDesc, "nanoseconds"),
f.createLongGauge("senderCreatesInProgress", senderCreatesInProgressDesc, "operations"),
f.createLongGauge("syncSocketWritesInProgress",
"Current number of synchronous/blocking socket write calls in progress.", "writes"),
f.createLongCounter("syncSocketWriteTime",
"Total amount of time, in nanoseconds, spent in synchronous/blocking socket write calls.",
"nanoseconds"),
f.createLongCounter("syncSocketWrites",
"Total number of completed synchronous/blocking socket write calls.", "writes"),
f.createLongCounter("syncSocketWriteBytes",
"Total number of bytes sent out in synchronous/blocking mode on sockets.", "bytes"),
f.createLongCounter("ucastReads", "Total number of unicast datagrams received",
"datagrams"),
f.createLongCounter("ucastReadBytes", "Total number of bytes received in unicast datagrams",
"bytes"),
f.createLongCounter("ucastWrites", "Total number of unicast datagram socket write calls.",
"writes"),
f.createLongCounter("ucastWriteBytes",
"Total number of bytes sent out on unicast datagram sockets.", "bytes"),
f.createLongCounter("ucastRetransmits",
"Total number of unicast datagram socket retransmissions", "writes"),
f.createLongCounter("mcastReads", "Total number of multicast datagrams received",
"datagrams"),
f.createLongCounter("mcastReadBytes",
"Total number of bytes received in multicast datagrams", "bytes"),
f.createLongCounter("mcastWrites", "Total number of multicast datagram socket write calls.",
"writes"),
f.createLongCounter("mcastWriteBytes",
"Total number of bytes sent out on multicast datagram sockets.", "bytes"),
f.createLongCounter("mcastRetransmits",
"Total number of multicast datagram socket retransmissions", "writes"),
f.createLongCounter("mcastRetransmitRequests",
"Total number of multicast datagram socket retransmission requests sent to other processes",
"requests"),
f.createLongCounter("serializationTime",
"Total amount of time, in nanoseconds, spent serializing objects. This includes pdx serializations.",
"nanoseconds"),
f.createLongCounter("serializations",
"Total number of object serialization calls. This includes pdx serializations.", "ops"),
f.createLongCounter("serializedBytes",
"Total number of bytes produced by object serialization. This includes pdx serializations.",
"bytes"),
f.createLongCounter("pdxSerializations", "Total number of pdx serializations.", "ops"),
f.createLongCounter("pdxSerializedBytes",
"Total number of bytes produced by pdx serialization.", "bytes"),
f.createLongCounter("deserializationTime",
"Total amount of time, in nanoseconds, spent deserializing objects. This includes deserialization that results in a PdxInstance.",
"nanoseconds"),
f.createLongCounter("deserializations",
"Total number of object deserialization calls. This includes deserialization that results in a PdxInstance.",
"ops"),
f.createLongCounter("deserializedBytes",
"Total number of bytes read by object deserialization. This includes deserialization that results in a PdxInstance.",
"bytes"),
f.createLongCounter("pdxDeserializations", "Total number of pdx deserializations.", "ops"),
f.createLongCounter("pdxDeserializedBytes",
"Total number of bytes read by pdx deserialization.", "bytes"),
f.createLongCounter("msgSerializationTime",
"Total amount of time, in nanoseconds, spent serializing messages.", "nanoseconds"),
f.createLongCounter("msgDeserializationTime",
"Total amount of time, in nanoseconds, spent deserializing messages.", "nanoseconds"),
f.createLongCounter("udpMsgEncryptionTime",
"Total amount of time, in nanoseconds, spent encrypting udp messages.", "nanoseconds"),
f.createLongCounter("udpMsgDecryptionTime",
"Total amount of time, in nanoseconds, spent decrypting udp messages.", "nanoseconds"),
f.createLongCounter("pdxInstanceDeserializations",
"Total number of times getObject has been called on a PdxInstance.", "ops"),
f.createLongCounter("pdxInstanceDeserializationTime",
"Total amount of time, in nanoseconds, spent deserializing PdxInstances by calling getObject.",
"nanoseconds"),
f.createLongCounter("pdxInstanceCreations",
"Total number of times a deserialization created a PdxInstance.", "ops"),
f.createLongCounter("batchSendTime",
"Total amount of time, in nanoseconds, spent queueing and flushing message batches",
"nanoseconds"),
f.createLongCounter("batchWaitTime", "Reserved for future use", "nanoseconds"),
f.createLongCounter("batchCopyTime",
"Total amount of time, in nanoseconds, spent copying messages for batched transmission",
"nanoseconds"),
f.createLongCounter("batchFlushTime",
"Total amount of time, in nanoseconds, spent flushing batched messages to the network",
"nanoseconds"),
f.createLongGauge("asyncSocketWritesInProgress",
"Current number of non-blocking socket write calls in progress.", "writes"),
f.createLongCounter("asyncSocketWrites",
"Total number of non-blocking socket write calls completed.", "writes"),
f.createLongCounter("asyncSocketWriteRetries",
"Total number of retries needed to write a single block of data using non-blocking socket write calls.",
"writes"),
f.createLongCounter("asyncSocketWriteTime",
"Total amount of time, in nanoseconds, spent in non-blocking socket write calls.",
"nanoseconds"),
f.createLongCounter("asyncSocketWriteBytes",
"Total number of bytes sent out on non-blocking sockets.", "bytes"),
f.createLongCounter("asyncQueueAddTime",
"Total amount of time, in nanoseconds, spent in adding messages to async queue.",
"nanoseconds"),
f.createLongCounter("asyncQueueRemoveTime",
"Total amount of time, in nanoseconds, spent in removing messages from async queue.",
"nanoseconds"),
f.createLongGauge("asyncQueues", asyncQueuesDesc, "queues"),
f.createLongGauge("asyncQueueFlushesInProgress", asyncQueueFlushesInProgressDesc,
"operations"),
f.createLongCounter("asyncQueueFlushesCompleted", asyncQueueFlushesCompletedDesc,
"operations"),
f.createLongCounter("asyncQueueFlushTime", asyncQueueFlushTimeDesc, "nanoseconds", false),
f.createLongCounter("asyncQueueTimeoutExceeded", asyncQueueTimeoutExceededDesc, "timeouts"),
f.createLongCounter("asyncQueueSizeExceeded", asyncQueueSizeExceededDesc, "operations"),
f.createLongCounter("asyncDistributionTimeoutExceeded",
asyncDistributionTimeoutExceededDesc,
"operations"),
f.createLongGauge("asyncQueueSize", asyncQueueSizeDesc, "bytes"),
f.createLongCounter("asyncQueuedMsgs", asyncQueuedMsgsDesc, "msgs"),
f.createLongCounter("asyncDequeuedMsgs", asyncDequeuedMsgsDesc, "msgs"),
f.createLongCounter("asyncConflatedMsgs", asyncConflatedMsgsDesc, "msgs"),
f.createLongGauge("asyncThreads", asyncThreadsDesc, "threads"),
f.createLongGauge("asyncThreadInProgress", asyncThreadInProgressDesc, "operations"),
f.createLongCounter("asyncThreadCompleted", asyncThreadCompletedDesc, "operations"),
f.createLongCounter("asyncThreadTime", asyncThreadTimeDesc, "nanoseconds", false),
f.createLongGauge("receiversTO",
"Number of receiver threads owned by non-receiver threads in other members.",
"threads"),
f.createLongGauge("receiversTO2",
"Number of receiver threads owned in turn by receiver threads in other members",
"threads"),
f.createLongGauge("receiverDirectBufferSize", receiverDirectBufferSizeDesc, "bytes"),
f.createLongGauge("receiverHeapBufferSize", receiverHeapBufferSizeDesc, "bytes"),
f.createLongGauge("senderDirectBufferSize", senderDirectBufferSizeDesc, "bytes"),
f.createLongGauge("senderHeapBufferSize", senderHeapBufferSizeDesc, "bytes"),
f.createLongGauge("socketLocksInProgress",
"Current number of threads waiting to lock a socket", "threads", false),
f.createLongCounter("socketLocks", "Total number of times a socket has been locked.",
"locks"),
f.createLongCounter("socketLockTime",
"Total amount of time, in nanoseconds, spent locking a socket", "nanoseconds", false),
f.createLongGauge("bufferAcquiresInProgress",
"Current number of threads waiting to acquire a buffer", "threads", false),
f.createLongCounter("bufferAcquires", "Total number of times a buffer has been acquired.",
"operations"),
f.createLongCounter("bufferAcquireTime",
"Total amount of time, in nanoseconds, spent acquiring a socket", "nanoseconds", false),
f.createLongGauge("messagesBeingReceived",
"Current number of message being received off the network or being processed after reception.",
"messages"),
f.createLongGauge("messageBytesBeingReceived",
"Current number of bytes consumed by messages being received or processed.", "bytes"),
f.createLongCounter("serialThreadStarts",
"Total number of times a thread has been created for the serial message executor.",
"starts", false),
f.createLongCounter("processingThreadStarts",
"Total number of times a thread has been created for the pool processing normal messages.",
"starts", false),
f.createLongCounter("highPriorityThreadStarts",
"Total number of times a thread has been created for the pool handling high priority messages.",
"starts", false),
f.createLongCounter("waitingThreadStarts",
"Total number of times a thread has been created for the waiting pool.", "starts",
false),
f.createLongCounter("partitionedRegionThreadStarts",
"Total number of times a thread has been created for the pool handling partitioned region messages.",
"starts", false),
f.createLongCounter("functionExecutionThreadStarts",
"Total number of times a thread has been created for the pool handling function execution messages.",
"starts", false),
f.createLongCounter("serialPooledThreadStarts",
"Total number of times a thread has been created for the serial pool(s).", "starts",
false),
f.createLongCounter("TOSentMsgs", "Total number of messages sent on thread owned senders",
"messages", false),
f.createLongCounter("replyHandoffTime", replyHandoffTimeDesc, "nanoseconds"),
f.createLongGauge("partitionedRegionThreadJobs", partitionedRegionThreadJobsDesc,
"messages"),
f.createLongGauge("functionExecutionThreadJobs", functionExecutionThreadJobsDesc,
"messages"),
f.createLongGauge("serialThreadJobs", serialThreadJobsDesc, "messages"),
f.createLongGauge("serialPooledThreadJobs", serialPooledThreadJobsDesc, "messages"),
f.createLongGauge("processingThreadJobs", processingThreadJobsDesc, "messages"),
f.createLongGauge("highPriorityThreadJobs", highPriorityThreadJobsDesc, "messages"),
f.createLongGauge("waitingThreadJobs", waitingThreadJobsDesc, "messages"),
f.createLongGauge("elders", eldersDesc, "elders"),
f.createLongGauge("initialImageMessagesInFlight", initialImageMessagesInFlightDesc,
"messages"),
f.createLongGauge("initialImageRequestsInProgress", initialImageRequestsInProgressDesc,
"requests"),
// For GMSHealthMonitor
f.createLongCounter("heartbeatRequestsSent", heartbeatRequestsSentDesc, "messages"),
f.createLongCounter("heartbeatRequestsReceived", heartbeatRequestsReceivedDesc, "messages"),
f.createLongCounter("heartbeatsSent", heartbeatsSentDesc, "messages"),
f.createLongCounter("heartbeatsReceived", heartbeatsReceivedDesc, "messages"),
f.createLongCounter("suspectsSent", suspectsSentDesc, "messages"),
f.createLongCounter("suspectsReceived", suspectsReceivedDesc, "messages"),
f.createLongCounter("finalCheckRequestsSent", finalCheckRequestsSentDesc, "messages"),
f.createLongCounter("finalCheckRequestsReceived", finalCheckRequestsReceivedDesc,
"messages"),
f.createLongCounter("finalCheckResponsesSent", finalCheckResponsesSentDesc, "messages"),
f.createLongCounter("finalCheckResponsesReceived", finalCheckResponsesReceivedDesc,
"messages"),
f.createLongCounter("tcpFinalCheckRequestsSent", tcpFinalCheckRequestsSentDesc, "messages"),
f.createLongCounter("tcpFinalCheckRequestsReceived", tcpFinalCheckRequestsReceivedDesc,
"messages"),
f.createLongCounter("tcpFinalCheckResponsesSent", tcpFinalCheckResponsesSentDesc,
"messages"),
f.createLongCounter("tcpFinalCheckResponsesReceived", tcpFinalCheckResponsesReceivedDesc,
"messages"),
f.createLongCounter("udpFinalCheckRequestsSent", udpFinalCheckRequestsSentDesc, "messages"),
f.createLongCounter("udpFinalCheckRequestsReceived", udpFinalCheckRequestsReceivedDesc,
"messages"),
f.createLongCounter("udpFinalCheckResponsesSent", udpFinalCheckResponsesSentDesc,
"messages"),
f.createLongCounter("udpFinalCheckResponsesReceived", udpFinalCheckResponsesReceivedDesc,
"messages"),});
// Initialize id fields
sentMessagesId = type.nameToId("sentMessages");
sentCommitMessagesId = type.nameToId("commitMessages");
commitWaitsId = type.nameToId("commitWaits");
sentMessagesTimeId = type.nameToId("sentMessagesTime");
sentMessagesMaxTimeId = type.nameToId("sentMessagesMaxTime");
broadcastMessagesId = type.nameToId("broadcastMessages");
broadcastMessagesTimeId = type.nameToId("broadcastMessagesTime");
receivedMessagesId = type.nameToId("receivedMessages");
receivedBytesId = type.nameToId("receivedBytes");
sentBytesId = type.nameToId("sentBytes");
processedMessagesId = type.nameToId("processedMessages");
processedMessagesTimeId = type.nameToId("processedMessagesTime");
messageProcessingScheduleTimeId = type.nameToId("messageProcessingScheduleTime");
messageChannelTimeId = type.nameToId("messageChannelTime");
udpDispatchRequestTimeId = type.nameToId("udpDispatchRequestTime");
replyMessageTimeId = type.nameToId("replyMessageTime");
distributeMessageTimeId = type.nameToId("distributeMessageTime");
nodesId = type.nameToId("nodes");
overflowQueueSizeId = type.nameToId("overflowQueueSize");
waitingQueueSizeId = type.nameToId("waitingQueueSize");
overflowQueueThrottleTimeId = type.nameToId("overflowQueueThrottleTime");
overflowQueueThrottleCountId = type.nameToId("overflowQueueThrottleCount");
highPriorityQueueSizeId = type.nameToId("highPriorityQueueSize");
highPriorityQueueThrottleTimeId = type.nameToId("highPriorityQueueThrottleTime");
highPriorityQueueThrottleCountId = type.nameToId("highPriorityQueueThrottleCount");
partitionedRegionQueueSizeId = type.nameToId("partitionedRegionQueueSize");
partitionedRegionQueueThrottleTimeId = type.nameToId("partitionedRegionQueueThrottleTime");
partitionedRegionQueueThrottleCountId = type.nameToId("partitionedRegionQueueThrottleCount");
functionExecutionQueueSizeId = type.nameToId("functionExecutionQueueSize");
functionExecutionQueueThrottleTimeId = type.nameToId("functionExecutionQueueThrottleTime");
functionExecutionQueueThrottleCountId = type.nameToId("functionExecutionQueueThrottleCount");
serialQueueSizeId = type.nameToId("serialQueueSize");
serialQueueBytesId = type.nameToId("serialQueueBytes");
serialPooledThreadId = type.nameToId("serialPooledThread");
serialQueueThrottleTimeId = type.nameToId("serialQueueThrottleTime");
serialQueueThrottleCountId = type.nameToId("serialQueueThrottleCount");
serialThreadsId = type.nameToId("serialThreads");
processingThreadsId = type.nameToId("processingThreads");
highPriorityThreadsId = type.nameToId("highPriorityThreads");
partitionedRegionThreadsId = type.nameToId("partitionedRegionThreads");
functionExecutionThreadsId = type.nameToId("functionExecutionThreads");
waitingThreadsId = type.nameToId("waitingThreads");
replyWaitsInProgressId = type.nameToId("replyWaitsInProgress");
replyWaitsCompletedId = type.nameToId("replyWaitsCompleted");
replyWaitTimeId = type.nameToId("replyWaitTime");
replyTimeoutsId = type.nameToId("replyTimeouts");
replyWaitMaxTimeId = type.nameToId("replyWaitMaxTime");
receiverConnectionsId = type.nameToId("receivers");
failedAcceptsId = type.nameToId("failedAccepts");
failedConnectsId = type.nameToId("failedConnects");
reconnectAttemptsId = type.nameToId("reconnectAttempts");
lostConnectionLeaseId = type.nameToId("senderTimeouts");
sharedOrderedSenderConnectionsId = type.nameToId("sendersSO");
sharedUnorderedSenderConnectionsId = type.nameToId("sendersSU");
threadOrderedSenderConnectionsId = type.nameToId("sendersTO");
threadUnorderedSenderConnectionsId = type.nameToId("sendersTU");
senderCreateTimeId = type.nameToId("senderCreateTime");
senderCreatesInProgressId = type.nameToId("senderCreatesInProgress");
syncSocketWritesInProgressId = type.nameToId("syncSocketWritesInProgress");
syncSocketWriteTimeId = type.nameToId("syncSocketWriteTime");
syncSocketWritesId = type.nameToId("syncSocketWrites");
syncSocketWriteBytesId = type.nameToId("syncSocketWriteBytes");
ucastReadsId = type.nameToId("ucastReads");
ucastReadBytesId = type.nameToId("ucastReadBytes");
ucastWritesId = type.nameToId("ucastWrites");
ucastWriteBytesId = type.nameToId("ucastWriteBytes");
ucastRetransmitsId = type.nameToId("ucastRetransmits");
mcastReadsId = type.nameToId("mcastReads");
mcastReadBytesId = type.nameToId("mcastReadBytes");
mcastWritesId = type.nameToId("mcastWrites");
mcastWriteBytesId = type.nameToId("mcastWriteBytes");
mcastRetransmitsId = type.nameToId("mcastRetransmits");
mcastRetransmitRequestsId = type.nameToId("mcastRetransmitRequests");
serializationTimeId = type.nameToId("serializationTime");
serializationsId = type.nameToId("serializations");
serializedBytesId = type.nameToId("serializedBytes");
deserializationTimeId = type.nameToId("deserializationTime");
deserializationsId = type.nameToId("deserializations");
deserializedBytesId = type.nameToId("deserializedBytes");
pdxSerializationsId = type.nameToId("pdxSerializations");
pdxSerializedBytesId = type.nameToId("pdxSerializedBytes");
pdxDeserializationsId = type.nameToId("pdxDeserializations");
pdxDeserializedBytesId = type.nameToId("pdxDeserializedBytes");
pdxInstanceDeserializationsId = type.nameToId("pdxInstanceDeserializations");
pdxInstanceDeserializationTimeId = type.nameToId("pdxInstanceDeserializationTime");
pdxInstanceCreationsId = type.nameToId("pdxInstanceCreations");
msgSerializationTimeId = type.nameToId("msgSerializationTime");
msgDeserializationTimeId = type.nameToId("msgDeserializationTime");
udpMsgEncryptionTimeId = type.nameToId("udpMsgEncryptionTime");
udpMsgDecryptionTimeId = type.nameToId("udpMsgDecryptionTime");
batchSendTimeId = type.nameToId("batchSendTime");
batchCopyTimeId = type.nameToId("batchCopyTime");
batchWaitTimeId = type.nameToId("batchWaitTime");
batchFlushTimeId = type.nameToId("batchFlushTime");
asyncSocketWritesInProgressId = type.nameToId("asyncSocketWritesInProgress");
asyncSocketWritesId = type.nameToId("asyncSocketWrites");
asyncSocketWriteRetriesId = type.nameToId("asyncSocketWriteRetries");
asyncSocketWriteTimeId = type.nameToId("asyncSocketWriteTime");
asyncSocketWriteBytesId = type.nameToId("asyncSocketWriteBytes");
asyncQueueAddTimeId = type.nameToId("asyncQueueAddTime");
asyncQueueRemoveTimeId = type.nameToId("asyncQueueRemoveTime");
asyncQueuesId = type.nameToId("asyncQueues");
asyncQueueFlushesInProgressId = type.nameToId("asyncQueueFlushesInProgress");
asyncQueueFlushesCompletedId = type.nameToId("asyncQueueFlushesCompleted");
asyncQueueFlushTimeId = type.nameToId("asyncQueueFlushTime");
asyncQueueTimeoutExceededId = type.nameToId("asyncQueueTimeoutExceeded");
asyncQueueSizeExceededId = type.nameToId("asyncQueueSizeExceeded");
asyncDistributionTimeoutExceededId = type.nameToId("asyncDistributionTimeoutExceeded");
asyncQueueSizeId = type.nameToId("asyncQueueSize");
asyncQueuedMsgsId = type.nameToId("asyncQueuedMsgs");
asyncDequeuedMsgsId = type.nameToId("asyncDequeuedMsgs");
asyncConflatedMsgsId = type.nameToId("asyncConflatedMsgs");
asyncThreadsId = type.nameToId("asyncThreads");
asyncThreadInProgressId = type.nameToId("asyncThreadInProgress");
asyncThreadCompletedId = type.nameToId("asyncThreadCompleted");
asyncThreadTimeId = type.nameToId("asyncThreadTime");
threadOwnedReceiversId = type.nameToId("receiversTO");
threadOwnedReceiversId2 = type.nameToId("receiversTO2");
receiverDirectBufferSizeId = type.nameToId("receiverDirectBufferSize");
receiverHeapBufferSizeId = type.nameToId("receiverHeapBufferSize");
senderDirectBufferSizeId = type.nameToId("senderDirectBufferSize");
senderHeapBufferSizeId = type.nameToId("senderHeapBufferSize");
socketLocksInProgressId = type.nameToId("socketLocksInProgress");
socketLocksId = type.nameToId("socketLocks");
socketLockTimeId = type.nameToId("socketLockTime");
bufferAcquiresInProgressId = type.nameToId("bufferAcquiresInProgress");
bufferAcquiresId = type.nameToId("bufferAcquires");
bufferAcquireTimeId = type.nameToId("bufferAcquireTime");
messagesBeingReceivedId = type.nameToId("messagesBeingReceived");
messageBytesBeingReceivedId = type.nameToId("messageBytesBeingReceived");
serialThreadStartsId = type.nameToId("serialThreadStarts");
processingThreadStartsId = type.nameToId("processingThreadStarts");
highPriorityThreadStartsId = type.nameToId("highPriorityThreadStarts");
waitingThreadStartsId = type.nameToId("waitingThreadStarts");
partitionedRegionThreadStartsId = type.nameToId("partitionedRegionThreadStarts");
functionExecutionThreadStartsId = type.nameToId("functionExecutionThreadStarts");
serialPooledThreadStartsId = type.nameToId("serialPooledThreadStarts");
TOSentMsgId = type.nameToId("TOSentMsgs");
replyHandoffTimeId = type.nameToId("replyHandoffTime");
partitionedRegionThreadJobsId = type.nameToId("partitionedRegionThreadJobs");
functionExecutionThreadJobsId = type.nameToId("functionExecutionThreadJobs");
serialThreadJobsId = type.nameToId("serialThreadJobs");
serialPooledThreadJobsId = type.nameToId("serialPooledThreadJobs");
pooledMessageThreadJobsId = type.nameToId("processingThreadJobs");
highPriorityThreadJobsId = type.nameToId("highPriorityThreadJobs");
waitingPoolThreadJobsId = type.nameToId("waitingThreadJobs");
eldersId = type.nameToId("elders");
initialImageMessagesInFlightId = type.nameToId("initialImageMessagesInFlight");
initialImageRequestsInProgressId = type.nameToId("initialImageRequestsInProgress");
// For GMSHealthMonitor
heartbeatRequestsSentId = type.nameToId("heartbeatRequestsSent");
heartbeatRequestsReceivedId = type.nameToId("heartbeatRequestsReceived");
heartbeatsSentId = type.nameToId("heartbeatsSent");
heartbeatsReceivedId = type.nameToId("heartbeatsReceived");
suspectsSentId = type.nameToId("suspectsSent");
suspectsReceivedId = type.nameToId("suspectsReceived");
finalCheckRequestsSentId = type.nameToId("finalCheckRequestsSent");
finalCheckRequestsReceivedId = type.nameToId("finalCheckRequestsReceived");
finalCheckResponsesSentId = type.nameToId("finalCheckResponsesSent");
finalCheckResponsesReceivedId = type.nameToId("finalCheckResponsesReceived");
tcpFinalCheckRequestsSentId = type.nameToId("tcpFinalCheckRequestsSent");
tcpFinalCheckRequestsReceivedId = type.nameToId("tcpFinalCheckRequestsReceived");
tcpFinalCheckResponsesSentId = type.nameToId("tcpFinalCheckResponsesSent");
tcpFinalCheckResponsesReceivedId = type.nameToId("tcpFinalCheckResponsesReceived");
udpFinalCheckRequestsSentId = type.nameToId("udpFinalCheckRequestsSent");
udpFinalCheckResponsesReceivedId = type.nameToId("udpFinalCheckResponsesReceived");
}