| | |
| | | private AtomicLong extOperationCount = new AtomicLong(0); |
| | | private AtomicLong extOperationTime = new AtomicLong(0); |
| | | |
| | | |
| | | /** |
| | | * Creates a new instance of this class with the specified parent. |
| | | * |
| | |
| | | this.instanceName = instanceName; |
| | | } |
| | | |
| | | |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public void initializeMonitorProvider(MonitorProviderCfg configuration) |
| | | throws ConfigException |
| | |
| | | throw new ConfigException(message); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the name of this monitor provider. It should be unique |
| | | * among all monitor providers, including all instances of the same |
| | |
| | | return instanceName; |
| | | } |
| | | |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public ObjectClass getMonitorObjectClass() |
| | | { |
| | |
| | | return attrs; |
| | | } |
| | | |
| | | |
| | | /** |
| | | * Clears any statistical information collected to this point. |
| | | */ |
| | | /** Clears any statistical information collected to this point. */ |
| | | public void clearStatistics() |
| | | { |
| | | abandonRequests.set(0); |
| | |
| | | extOperationTime.set(0); |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | /** |
| | | * Updates the appropriate set of counters to indicate that a new |
| | | * connection has been established. |
| | |
| | | connectionsEstablished.getAndIncrement(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Updates the appropriate set of counters to indicate that a |
| | | * connection has been closed. |
| | | */ |
| | | /** Updates the appropriate set of counters to indicate that a connection has been closed. */ |
| | | public void updateDisconnect() |
| | | { |
| | | connectionsClosed.getAndIncrement(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Updates the appropriate set of counters to indicate that the |
| | | * specified number of bytes have been read by the client. |
| | |
| | | this.bytesRead.getAndAdd(bytesRead); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Updates the appropriate set of counters to indicate that the |
| | | * specified number of bytes have been written to the client. |
| | |
| | | this.bytesWritten.getAndAdd(bytesWritten); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Updates the appropriate set of counters based on the provided |
| | | * message that has been read from the client. |
| | |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Updates the appropriate set of counters based on the provided |
| | | * message that has been written to the client. |
| | |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Updates the appropriate set of counters to indicate that an |
| | | * operation was abandoned without sending a response to the client. |
| | |
| | | return connectionsEstablished.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of client connections that have been closed. |
| | | * |
| | |
| | | return connectionsClosed.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of bytes that have been received from clients. |
| | | * |
| | |
| | | return bytesRead.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of bytes that have been written to clients. |
| | | * |
| | |
| | | return bytesWritten.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of LDAP messages that have been received from |
| | | * clients. |
| | |
| | | return messagesRead.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of LDAP messages that have been written to |
| | | * clients. |
| | |
| | | return messagesWritten.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of operations that have been initiated by |
| | | * clients. |
| | |
| | | return operationsInitiated.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of operations for which the server has |
| | | * completed processing. |
| | |
| | | return operationsCompleted.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of operations that have been abandoned by |
| | | * clients. |
| | |
| | | return operationsAbandoned.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of abandon requests that have been received. |
| | | * |
| | |
| | | return abandonRequests.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of add requests that have been received. |
| | | * |
| | |
| | | return addRequests.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of add responses that have been sent. |
| | | * |
| | |
| | | return addResponses.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of bind requests that have been received. |
| | | * |
| | |
| | | return bindRequests.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of bind responses that have been sent. |
| | | * |
| | |
| | | return bindResponses.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of compare requests that have been received. |
| | | * |
| | |
| | | return compareRequests.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of compare responses that have been sent. |
| | | * |
| | |
| | | return compareResponses.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of delete requests that have been received. |
| | | * |
| | |
| | | return deleteRequests.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of delete responses that have been sent. |
| | | * |
| | |
| | | return deleteResponses.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of extended requests that have been received. |
| | | * |
| | |
| | | return extendedRequests.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of extended responses that have been sent. |
| | | * |
| | |
| | | return extendedResponses.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of modify requests that have been received. |
| | | * |
| | |
| | | return modifyRequests.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of modify responses that have been sent. |
| | | * |
| | |
| | | return modifyResponses.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of modify DN requests that have been received. |
| | | * |
| | |
| | | return modifyDNRequests.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of modify DN responses that have been sent. |
| | | * |
| | |
| | | return modifyDNResponses.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of search requests that have been received. |
| | | * |
| | |
| | | return searchRequests.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of one-level search requests that have been received. |
| | | * |
| | |
| | | return searchOneRequests.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of subtree search requests that have been received. |
| | | * |
| | |
| | | return searchSubRequests.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of search result entries that have been sent. |
| | | * |
| | |
| | | return searchResultEntries.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of search result references that have been |
| | | * sent. |
| | |
| | | return searchResultReferences.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of search result done messages that have been |
| | | * sent. |
| | |
| | | return searchResultsDone.get(); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * Retrieves the number of unbind requests that have been received. |
| | | * |
| | |
| | | moddnOperationTime.getAndAdd(time); |
| | | } |
| | | } |
| | | |
| | | } |