geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From upthewatersp...@apache.org
Subject [42/51] [abbrv] [partial] incubator-geode git commit: Merge remote-tracking branch 'origin/develop' into feature/GEODE-917
Date Sat, 20 Feb 2016 00:00:00 GMT
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/5beaaedc/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DMStats.java
----------------------------------------------------------------------
diff --cc geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DMStats.java
index 7bf5b80,0000000..6091b83
mode 100644,000000..100644
--- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DMStats.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/DMStats.java
@@@ -1,619 -1,0 +1,622 @@@
 +/*
 + * Licensed to the Apache Software Foundation (ASF) under one or more
 + * contributor license agreements.  See the NOTICE file distributed with
 + * this work for additional information regarding copyright ownership.
 + * The ASF licenses this file to You under the Apache License, Version 2.0
 + * (the "License"); you may not use this file except in compliance with
 + * the License.  You may obtain a copy of the License at
 + *
 + *      http://www.apache.org/licenses/LICENSE-2.0
 + *
 + * Unless required by applicable law or agreed to in writing, software
 + * distributed under the License is distributed on an "AS IS" BASIS,
 + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 + * See the License for the specific language governing permissions and
 + * limitations under the License.
 + */
 +package com.gemstone.gemfire.distributed.internal;
 +
 +/**
 + * Defines the interface used to access and modify DM statistics.
 + *
 + * @author Darrel Schneider
 + *
 + */
 +public interface DMStats {
 +
 +  /**
 +   * Returns the total number of messages sent by the distribution
 +   * manager 
 +   */
 +  public long getSentMessages();
 +
 +  /**
 +   * Increments the total number of messages sent by the distribution
 +   * manager 
 +   */
 +  public void incSentMessages(long messages);
 +
 +  public void incTOSentMsg();
 +  /**
 +   * Returns the total number of transaction commit messages
 +   * sent by the distribution manager 
 +   */
 +  public long getSentCommitMessages();
 +
 +  /**
 +   * Increments the total number of transaction commit messages
 +   * sent by the distribution manager 
 +   */
 +  public void incSentCommitMessages(long messages);
 +
 +  /**
 +   * Returns the total number commits that had to wait for an ack
 +   * before completion.
 +   */
 +  public long getCommitWaits();
 +
 +  /**
 +   * Increments the number of commit waits by one.
 +   */
 +  public void incCommitWaits();
 +
 +  /**
 +   * Returns the total number of nanoseconds spent sending messages.
 +   */
 +  public long getSentMessagesTime();
 +
 +  /**
 +   * Increments the total number of nanoseconds spent sending messages.
 +   */
 +  public void incSentMessagesTime(long nanos);
 +
 +  /**
 +   * Returns the total number of messages broadcast by the distribution
 +   * manager 
 +   */
 +  public long getBroadcastMessages();
 +
 +  /**
 +   * Increments the total number of messages broadcast by the distribution
 +   * manager 
 +   */
 +  public void incBroadcastMessages(long messages);
 +
 +  /**
 +   * Returns the total number of nanoseconds spent sending messages.
 +   */
 +  public long getBroadcastMessagesTime();
 +
 +  /**
 +   * Increments the total number of nanoseconds spend sending messages.
 +   */
 +  public void incBroadcastMessagesTime(long nanos);
 +
 +  /**
 +   * Returns the total number of messages received by the distribution
 +   * manager
 +   */
 +  public long getReceivedMessages();
 +
 +  /**
 +   * Increments the total number of messages received by the distribution
 +   * manager 
 +   */
 +  public void incReceivedMessages(long messages);
 +
 +  /**
 +   * Returns the total number of message bytes received by the distribution
 +   * manager
 +   */
 +  public long getReceivedBytes();
 +
 +  /**
 +   * Increments the total number of message bytes received by the distribution
 +   * manager 
 +   */
 +  public void incReceivedBytes(long bytes);
 +
 +  /**
 +   * Increments the total number of message bytes sent by the distribution
 +   * manager 
 +   */
 +  public void incSentBytes(long bytes);
 +
 +  /**
 +   * Returns the total number of messages processed by the distribution
 +   * manager
 +   */
 +  public long getProcessedMessages();
 +
 +  /**
 +   * Increments the total number of messages processed by the distribution
 +   * manager 
 +   */
 +  public void incProcessedMessages(long messages);
 +
 +  /**
 +   * Returns the total number of nanoseconds spent processing messages.
 +   */
 +  public long getProcessedMessagesTime();
 +
 +  /**
 +   * Increments the total number of nanoseconds spent processing messages.
 +   */
 +  public void incProcessedMessagesTime(long nanos);
 +
 +  /**
 +   * Returns the total number of nanoseconds spent scheduling messages to be processed.
 +   */
 +  public long getMessageProcessingScheduleTime();
 +
 +  public void incBatchSendTime(long start);
 +  public void incBatchCopyTime(long start);
 +  public void incBatchWaitTime(long start);
 +  public void incBatchFlushTime(long start);
 +  /**
 +   * Increments the total number of nanoseconds spent scheduling messages to be processed.
 +   */
 +  public void incMessageProcessingScheduleTime(long nanos);
 +
 +  public int getOverflowQueueSize();
 +  
 +  public void incOverflowQueueSize(int messages);
 +  
 +  public int getNumProcessingThreads();
 +  
 +  public void incNumProcessingThreads(int threads);
 +
 +  public int getNumSerialThreads();
 +  
 +  public void incNumSerialThreads(int threads);
 +
 +  public void incMessageChannelTime(long val);
++
++  public void incUDPDispatchRequestTime(long val);
++  public long getUDPDispatchRequestTime();
 +  
 +  public long getReplyMessageTime();
 +  public void incReplyMessageTime(long val);
 +
 +  public long getDistributeMessageTime();
 +  public void incDistributeMessageTime(long val);
 +  
 +  public long startSocketWrite(boolean sync);
 +  public void endSocketWrite(boolean sync, long start, int bytesWritten, int retries);
 +  /**
 +   * increments
 +   * the number of unicast writes performed and the number of bytes written
 +   * @since 5.0
 +   */
 +  public void incUcastWriteBytes(int bytesWritten);
 +  /**
 +   * increment the number of unicast datagram payload bytes received and
 +   * the number of unicast reads performed
 +   */
 +  public void incUcastReadBytes(int amount);
 +  /**
 +   * increment the number of multicast datagrams sent and
 +   * the number of multicast bytes transmitted
 +   */
 +  public void incMcastWriteBytes(int bytesWritten);
 +  /**
 +   * increment the number of multicast datagram payload bytes received, and
 +   * the number of mcast messages read
 +   */
 +  public void incMcastReadBytes(int amount);
 +  /**
 +   * returns the current value of the mcastWrites statistic
 +   */
 +  public int getMcastWrites();
 +  public int getMcastReads();
 +
 +  public long startSerialization();
 +  public void endSerialization(long start, int bytes);
 +  public long startDeserialization();
 +  public void endDeserialization(long start, int bytes);
 +  public long startMsgSerialization();
 +  public void endMsgSerialization(long start);
 +  public long startMsgDeserialization();
 +  public void endMsgDeserialization(long start);
 +
 +  public int getNodes();
 +  public void setNodes(int val);
 +  public void incNodes(int val);
 +  public int getReplyWaitsInProgress();
 +  public int getReplyWaitsCompleted();
 +  public long getReplyWaitTime();
 +  /**
 +   * @return the timestamp that marks the start of the operation
 +   */
 +  public long startReplyWait();
 +  /**
 +   * @param startNanos the timestamp taken when the operation started
 +   * @param initTime the time the operation begain (before msg transmission) 
 +   */
 +  public void endReplyWait(long startNanos, long initTime);
 +
 +  /**
 +   * Increments the number of message replies that have timed out
 +   *
 +   * @since 3.5
 +   */
 +  public void incReplyTimeouts();
 +
 +  /**
 +   * Returns the number of message replies that have timed out
 +   *
 +   * @since 3.5
 +   */
 +  public long getReplyTimeouts();
 +
 +  /**
 +   * @since 4.1
 +   */
 +  public void incReceivers();
 +  /**
 +   * @since 4.1
 +   */
 +  public void decReceivers();
 +  /**
 +   * @since 4.1
 +   */
 +  public void incFailedAccept();
 +  /**
 +   * @since 4.1
 +   */
 +  public void incFailedConnect();
 +  /**
 +   * @since 4.1.1
 +   */
 +  public void incReconnectAttempts();
 +  /**
 +   * @since 4.1
 +   */
 +  public void incLostLease();
 +  /**
 +   * @since 4.1
 +   */
 +  public void incSenders(boolean shared, boolean preserveOrder);
 +  /**
 +   * @since 4.1
 +   */
 +  public void decSenders(boolean shared, boolean preserveOrder);
 +  /**
 +   * @since 4.1
 +   */
 +  public int getSendersSU();
 +  /**
 +   * increment the number of unicast UDP retransmission requests received from
 +   * other processes
 +   * @since 5.0
 +   */
 +  public void incUcastRetransmits();
 +  /**
 +   * increment the number of multicast UDP retransmissions sent to
 +   * other processes
 +   * @since 5.0
 +   */
 +  public void incMcastRetransmits();
 +  /**
 +   * returns the current number of multicast retransmission requests
 +   * processed
 +   */
 +  public int getMcastRetransmits();
 +  /**
 +   * increment the number of multicast UDP retransmission requests sent to
 +   * other processes
 +   * @since 5.0
 +   */
 +  public void incMcastRetransmitRequests();
 +
 +  /**
 +   * @since 4.2.2
 +   */
 +  public int getAsyncSocketWritesInProgress();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public int getAsyncSocketWrites();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public int getAsyncSocketWriteRetries();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public long getAsyncSocketWriteBytes();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public long getAsyncSocketWriteTime();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public int getAsyncQueues();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public void incAsyncQueues(int inc);
 +  /**
 +   * @since 4.2.2
 +   */
 +  public int getAsyncQueueFlushesInProgress();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public int getAsyncQueueFlushesCompleted();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public long getAsyncQueueFlushTime();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public long startAsyncQueueFlush();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public void endAsyncQueueFlush(long start);
 +  /**
 +   * @since 4.2.2
 +   */
 +  public int getAsyncQueueTimeouts();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public void incAsyncQueueTimeouts(int inc);
 +  /**
 +   * @since 4.2.2
 +   */
 +  public int getAsyncQueueSizeExceeded();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public void incAsyncQueueSizeExceeded(int inc);
 +  /**
 +   * @since 4.2.2
 +   */
 +  public int getAsyncDistributionTimeoutExceeded();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public void incAsyncDistributionTimeoutExceeded();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public long getAsyncQueueSize();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public void incAsyncQueueSize(long inc);
 +  /**
 +   * @since 4.2.2
 +   */
 +  public long getAsyncQueuedMsgs();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public void incAsyncQueuedMsgs();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public long getAsyncDequeuedMsgs();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public void incAsyncDequeuedMsgs();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public long getAsyncConflatedMsgs();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public void incAsyncConflatedMsgs();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public int getAsyncThreads();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public void incAsyncThreads(int inc);
 +  /**
 +   * @since 4.2.2
 +   */
 +  public int getAsyncThreadInProgress();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public int getAsyncThreadCompleted();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public long getAsyncThreadTime();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public long startAsyncThread();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public void endAsyncThread(long start);
 +  /**
 +   * @since 4.2.2
 +   */
 +  public long getAsyncQueueAddTime();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public void incAsyncQueueAddTime(long inc);
 +  /**
 +   * @since 4.2.2
 +   */
 +  public long getAsyncQueueRemoveTime();
 +  /**
 +   * @since 4.2.2
 +   */
 +  public void incAsyncQueueRemoveTime(long inc);
 +
 +  /**
 +   * @since 5.0.2.4 
 +   */
 +  public void incReceiverBufferSize(int inc, boolean direct);
 +  /**
 +   * @since 5.0.2.4 
 +   */
 +  public void incSenderBufferSize(int inc, boolean direct);
 +  /**
 +   * @since 5.0.2.4 
 +   */
 +  public long startSocketLock();
 +  /**
 +   * @since 5.0.2.4 
 +   */
 +  public void endSocketLock(long start);
 +
 +  /**
 +   * @since 5.0.2.4 
 +   */
 +  public long startBufferAcquire();
 +  /**
 +   * @since 5.0.2.4 
 +   */
 +  public void endBufferAcquire(long start);
 +
 +  /**
 +   * increment/decrement the number of thread-owned receivers with the given
 +   * domino count
 +   * @param value
 +   * @param dominoCount thread-owned connection chain count
 +   */
 +  public void incThreadOwnedReceivers(long value, int dominoCount);
 +  
 +  /**
 +   * Called when a new message is received.
 +   * @param newMsg true if a new message being received was detected; false if
 +   *   this is just additional data for a message already detected.
 +   * @param bytes the number of bytes read, so far, for the message being received. 
 +   * @since 5.0.2
 +   */
 +  public void incMessagesBeingReceived(boolean newMsg, int bytes);
 +  /**
 +   * Called when we finish processing a received message.
 +   * @param bytes the number of bytes read off the wire for the message we have finished
with.
 +   * @since 5.0.2
 +   */
 +  public void decMessagesBeingReceived(int bytes);
 +
 +  public void incReplyHandOffTime(long start);
 +  
 +  /**
 +   * Returns 1 if the system elder is this member, else returns 0.
 +   * @return 1 if the system elder is this member, else returns 0
 +   */
 +  public int getElders();
 +  public void incElders(int val);
 +  
 +  /**
 +   * Returns the number of initial image reply messages sent from this member
 +   * which have not yet been acked.  
 +   */
 +  public int getInitialImageMessagesInFlight();
 +
 +  public void incInitialImageMessagesInFlight(int val);
 +  
 +  /**
 +   * Returns the number of initial images this member is currently requesting. 
 +   */
 +  public int getInitialImageRequestsInProgress();
 +  
 +  public void incInitialImageRequestsInProgress(int val);
 +
 +  public void incPdxSerialization(int bytesWritten);
 +
 +  public void incPdxDeserialization(int i);
 +
 +  public long startPdxInstanceDeserialization();
 +
 +  public void endPdxInstanceDeserialization(long start);
 +  public void incPdxInstanceCreations();
 +  
 +  //Stats for GMSHealthMonitor
 +  public long getHeartbeatRequestsSent();
 +  
 +  public void incHeartbeatRequestsSent();
 +  
 +  public long getHeartbeatRequestsReceived();
 +  
 +  public void incHeartbeatRequestsReceived();
 +  
 +  public long getHeartbeatsSent();
 +  
 +  public void incHeartbeatsSent();
 +
 +  public long getHeartbeatsReceived();
 +  
 +  public void incHeartbeatsReceived();
 +  
 +
 +  public long getSuspectsSent();
 +  
 +  public void incSuspectsSent();
 +
 +  public long getSuspectsReceived();
 +  
 +  public void incSuspectsReceived();
 +  
 +  
 +  public long getFinalCheckRequestsSent();
 +  
 +  public void incFinalCheckRequestsSent();
 +  
 +  public long getFinalCheckRequestsReceived();
 +  
 +  public void incFinalCheckRequestsReceived();
 +  
 +  public long getFinalCheckResponsesSent();
 +  
 +  public void incFinalCheckResponsesSent();
 +  
 +  public long getFinalCheckResponsesReceived();
 +  
 +  public void incFinalCheckResponsesReceived();
 +  
 +  
 +  public long getTcpFinalCheckRequestsSent();
 +  
 +  public void incTcpFinalCheckRequestsSent();
 +
 +  public long getTcpFinalCheckRequestsReceived();
 +  
 +  public void incTcpFinalCheckRequestsReceived();
 +  
 +  public long getTcpFinalCheckResponsesSent();
 +  
 +  public void incTcpFinalCheckResponsesSent();
 +
 +  public long getTcpFinalCheckResponsesReceived();
 +  
 +  public void incTcpFinalCheckResponsesReceived();
 +
 +  
 +  public long getUdpFinalCheckRequestsSent();
 +  
 +  public void incUdpFinalCheckRequestsSent();
 +  
 +//  UDP final check is implemented using HeartbeatRequestMessage and HeartbeatMessage
 +//  So the following code is commented out.
 +  
 +//  public long getUdpFinalCheckRequestsReceived();
 +//  
 +//  public void incUdpFinalCheckRequestsReceived();
 +//  
 +//  public long getUdpFinalCheckResponsesSent();
 +//  
 +//  public void incUdpFinalCheckResponsesSent();
 +
 +  public long getUdpFinalCheckResponsesReceived();
 +  
 +  public void incUdpFinalCheckResponsesReceived();
 +}


Mime
View raw message