/*
|
* CDDL HEADER START
|
*
|
* The contents of this file are subject to the terms of the
|
* Common Development and Distribution License, Version 1.0 only
|
* (the "License"). You may not use this file except in compliance
|
* with the License.
|
*
|
* You can obtain a copy of the license at legal-notices/CDDLv1_0.txt
|
* or http://forgerock.org/license/CDDLv1.0.html.
|
* See the License for the specific language governing permissions
|
* and limitations under the License.
|
*
|
* When distributing Covered Code, include this CDDL HEADER in each
|
* file and include the License file at legal-notices/CDDLv1_0.txt.
|
* If applicable, add the following below this CDDL HEADER, with the
|
* fields enclosed by brackets "[]" replaced with your own identifying
|
* information:
|
* Portions Copyright [yyyy] [name of copyright owner]
|
*
|
* CDDL HEADER END
|
*
|
*
|
* Copyright 2006-2010 Sun Microsystems, Inc.
|
* Portions Copyright 2012-2014 ForgeRock AS
|
*
|
*/
|
package org.opends.server.protocols.ldap;
|
|
|
|
import static org.opends.messages.ProtocolMessages.*;
|
import static org.opends.server.protocols.ldap.LDAPConstants.*;
|
import static org.opends.server.util.ServerConstants.*;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.concurrent.atomic.AtomicLong;
|
|
import org.forgerock.i18n.LocalizableMessage;
|
import org.opends.server.admin.std.server.MonitorProviderCfg;
|
import org.opends.server.api.MonitorProvider;
|
import org.forgerock.opendj.config.server.ConfigException;
|
import org.opends.server.core.DirectoryServer;
|
import org.opends.server.types.*;
|
|
|
/**
|
* This class defines a data structure that will be used to keep track
|
* of various metrics related to LDAP communication that the server has
|
* conducted. The statistics that will be tracked include:
|
* <UL>
|
* <LI>The total number of LDAP client connections accepted by the
|
* server.</LI>
|
* <LI>The total number of LDAP client connections that have been
|
* closed.</LI>
|
* <LI>The total number of LDAP messages read, both overall and broken
|
* down by message type.</LI>
|
* <LI>The total number of LDAP messages written, both overall and
|
* broken down by message type.</LI>
|
* <LI>The total number of bytes read from LDAP clients.</LI>
|
* <LI>The total number of bytes written to LDAP clients.</LI>
|
* </UL>
|
* <BR>
|
* <BR>
|
* This class may also be used in a hierarchical form if it is desirable
|
* to get specific and general statistics at the same time (e.g.,
|
* information about the interaction with a specific client or
|
* aggregated for all clients).
|
*/
|
public class LDAPStatistics extends MonitorProvider<MonitorProviderCfg>
|
{
|
|
// The statistics maintained by this class.
|
private AtomicLong abandonRequests = new AtomicLong(0);
|
private AtomicLong addRequests = new AtomicLong(0);
|
private AtomicLong bindRequests = new AtomicLong(0);
|
private AtomicLong addResponses = new AtomicLong(0);
|
private AtomicLong bindResponses = new AtomicLong(0);
|
private AtomicLong bytesRead = new AtomicLong(0);
|
private AtomicLong bytesWritten = new AtomicLong(0);
|
private AtomicLong compareRequests = new AtomicLong(0);
|
private AtomicLong compareResponses = new AtomicLong(0);
|
private AtomicLong connectionsClosed = new AtomicLong(0);
|
private AtomicLong connectionsEstablished = new AtomicLong(0);
|
private AtomicLong deleteRequests = new AtomicLong(0);
|
private AtomicLong deleteResponses = new AtomicLong(0);
|
private AtomicLong extendedRequests = new AtomicLong(0);
|
private AtomicLong extendedResponses = new AtomicLong(0);
|
private AtomicLong messagesRead = new AtomicLong(0);
|
private AtomicLong messagesWritten = new AtomicLong(0);
|
private AtomicLong modifyRequests = new AtomicLong(0);
|
private AtomicLong modifyResponses = new AtomicLong(0);
|
private AtomicLong modifyDNRequests = new AtomicLong(0);
|
private AtomicLong modifyDNResponses = new AtomicLong(0);
|
private AtomicLong operationsAbandoned = new AtomicLong(0);
|
private AtomicLong operationsCompleted = new AtomicLong(0);
|
private AtomicLong operationsInitiated = new AtomicLong(0);
|
private AtomicLong searchRequests = new AtomicLong(0);
|
private AtomicLong searchOneRequests = new AtomicLong(0);
|
private AtomicLong searchSubRequests = new AtomicLong(0);
|
private AtomicLong searchResultEntries = new AtomicLong(0);
|
private AtomicLong searchResultReferences = new AtomicLong(0);
|
private AtomicLong searchResultsDone = new AtomicLong(0);
|
private AtomicLong unbindRequests = new AtomicLong(0);
|
|
|
// The instance name for this monitor provider instance.
|
private final String instanceName;
|
|
// Monitor Objects : for Operations (count and time)
|
private AtomicLong addOperationCount = new AtomicLong(0);
|
private AtomicLong addOperationTime = new AtomicLong(0);
|
private AtomicLong searchOperationCount = new AtomicLong(0);
|
private AtomicLong searchOperationTime = new AtomicLong(0);
|
private AtomicLong delOperationCount = new AtomicLong(0);
|
private AtomicLong delOperationTime = new AtomicLong(0);
|
private AtomicLong bindOperationCount = new AtomicLong(0);
|
private AtomicLong bindOperationTime = new AtomicLong(0);
|
private AtomicLong unbindOperationCount = new AtomicLong(0);
|
private AtomicLong unbindOperationTime = new AtomicLong(0);
|
private AtomicLong compOperationCount = new AtomicLong(0);
|
private AtomicLong compOperationTime = new AtomicLong(0);
|
private AtomicLong modOperationCount = new AtomicLong(0);
|
private AtomicLong modOperationTime = new AtomicLong(0);
|
private AtomicLong moddnOperationCount = new AtomicLong(0);
|
private AtomicLong moddnOperationTime = new AtomicLong(0);
|
private AtomicLong abandonOperationCount = new AtomicLong(0);
|
private AtomicLong abandonOperationTime = new AtomicLong(0);
|
private AtomicLong extOperationCount = new AtomicLong(0);
|
private AtomicLong extOperationTime = new AtomicLong(0);
|
|
|
/**
|
* Creates a new instance of this class with the specified parent.
|
*
|
* @param instanceName
|
* The name for this monitor provider instance.
|
*/
|
public LDAPStatistics(String instanceName)
|
{
|
this.instanceName = instanceName;
|
}
|
|
|
|
/**
|
* {@inheritDoc}
|
*/
|
@Override
|
public void initializeMonitorProvider(MonitorProviderCfg configuration)
|
throws ConfigException
|
{
|
// Throw an exception, because this monitor is not intended to be
|
// dynamically loaded from the configuration. Rather, it should be
|
// explicitly created and registered by the LDAP connection handler
|
// or an LDAP client connection.
|
LocalizableMessage message =
|
ERR_LDAP_STATS_INVALID_MONITOR_INITIALIZATION.get(configuration.dn());
|
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
|
* monitor provider.
|
*
|
* @return The name of this monitor provider.
|
*/
|
@Override
|
public String getMonitorInstanceName()
|
{
|
return instanceName;
|
}
|
|
|
/**
|
*
|
* {@inheritDoc}
|
*/
|
@Override
|
public ObjectClass getMonitorObjectClass()
|
{
|
return DirectoryConfig.getObjectClass(OC_MONITOR_CONNHANDLERSTATS, true);
|
}
|
|
|
/**
|
* Retrieves a set of attributes containing monitor data that should
|
* be returned to the client if the corresponding monitor entry is
|
* requested.
|
*
|
* @return A set of attributes containing monitor data that should be
|
* returned to the client if the corresponding monitor entry
|
* is requested.
|
*/
|
@Override
|
public List<Attribute> getMonitorData()
|
{
|
List<Attribute> attrs = new ArrayList<Attribute>();
|
|
long tmpAbandonRequests = abandonRequests.get();
|
long tmpAddRequests = addRequests.get();
|
long tmpAddResponses = addResponses.get();
|
long tmpBindRequests = bindRequests.get();
|
long tmpBindResponses = bindResponses.get();
|
long tmpBytesRead = bytesRead.get();
|
long tmpBytesWritten = bytesWritten.get();
|
long tmpCompareRequests = compareRequests.get();
|
long tmpCompareResponses = compareResponses.get();
|
long tmpConnectionsClosed = connectionsClosed.get();
|
long tmpConnectionsEstablished = connectionsEstablished.get();
|
long tmpDeleteRequests = deleteRequests.get();
|
long tmpDeleteResponses = deleteResponses.get();
|
long tmpExtendedRequests = extendedRequests.get();
|
long tmpExtendedResponses = extendedResponses.get();
|
long tmpMessagesRead = messagesRead.get();
|
long tmpMessagesWritten = messagesWritten.get();
|
long tmpModifyRequests = modifyRequests.get();
|
long tmpModifyResponses = modifyResponses.get();
|
long tmpModifyDNRequests = modifyDNRequests.get();
|
long tmpModifyDNResponses = modifyDNResponses.get();
|
long tmpOperationsAbandoned = operationsAbandoned.get();
|
long tmpOperationsCompleted = operationsCompleted.get();
|
long tmpOperationsInitiated = operationsInitiated.get();
|
long tmpSearchRequests = searchRequests.get();
|
long tmpSearchOneRequests = searchOneRequests.get();
|
long tmpSearchSubRequests = searchSubRequests.get();
|
long tmpSearchEntries = searchResultEntries.get();
|
long tmpSearchReferences = searchResultReferences.get();
|
long tmpSearchResultsDone = searchResultsDone.get();
|
long tmpUnbindRequests = unbindRequests.get();
|
long tmpAddOperationCount = addOperationCount.get();
|
long tmpAddOperationTime = addOperationTime.get();
|
long tmpSearchOperationCount = searchOperationCount.get();
|
long tmpSearchOperationTime = searchOperationTime.get();
|
long tmpDelOperationCount = delOperationCount.get();
|
long tmpDelOperationTime = delOperationTime.get();
|
long tmpBindOperationCount = bindOperationCount.get();
|
long tmpBindOperationTime = bindOperationTime.get();
|
long tmpUnbindOperationCount = unbindOperationCount.get();
|
long tmpUnbindOperationTime = unbindOperationTime.get();
|
long tmpCompOperationCount = compOperationCount.get();
|
long tmpCompOperationTime = compOperationTime.get();
|
long tmpModOperationCount = modOperationCount.get();
|
long tmpModOperationTime = modOperationTime.get();
|
long tmpModdnOperationCount = moddnOperationCount.get();
|
long tmpModdnOperationTime = moddnOperationTime.get();
|
long tmpAbandonOperationCount = abandonOperationCount.get();
|
long tmpAbandonOperationTime = abandonOperationTime.get();
|
long tmpExtOperationCount = extOperationCount.get();
|
long tmpExtOperationTime = extOperationTime.get();
|
|
|
// Construct the list of attributes to return.
|
/* TODO : the attribute names should be constant (in ServerConstants.java
|
* and associated with their objectclass
|
* OC_MONITOR_CONNHANDLERSTATS
|
*/
|
attrs.add(createAttribute("connectionsEstablished", String
|
.valueOf(tmpConnectionsEstablished)));
|
attrs.add(createAttribute("connectionsClosed", String
|
.valueOf(tmpConnectionsClosed)));
|
attrs.add(createAttribute("bytesRead", String
|
.valueOf(tmpBytesRead)));
|
attrs.add(createAttribute("bytesWritten", String
|
.valueOf(tmpBytesWritten)));
|
attrs.add(createAttribute("ldapMessagesRead", String
|
.valueOf(tmpMessagesRead)));
|
attrs.add(createAttribute("ldapMessagesWritten", String
|
.valueOf(tmpMessagesWritten)));
|
attrs.add(createAttribute("operationsAbandoned", String
|
.valueOf(tmpOperationsAbandoned)));
|
attrs.add(createAttribute("operationsInitiated", String
|
.valueOf(tmpOperationsInitiated)));
|
attrs.add(createAttribute("operationsCompleted", String
|
.valueOf(tmpOperationsCompleted)));
|
attrs.add(createAttribute("abandonRequests", String
|
.valueOf(tmpAbandonRequests)));
|
attrs.add(createAttribute("addRequests", String
|
.valueOf(tmpAddRequests)));
|
attrs.add(createAttribute("addResponses", String
|
.valueOf(tmpAddResponses)));
|
attrs.add(createAttribute("bindRequests", String
|
.valueOf(tmpBindRequests)));
|
attrs.add(createAttribute("bindResponses", String
|
.valueOf(tmpBindResponses)));
|
attrs.add(createAttribute("compareRequests", String
|
.valueOf(tmpCompareRequests)));
|
attrs.add(createAttribute("compareResponses", String
|
.valueOf(tmpCompareResponses)));
|
attrs.add(createAttribute("deleteRequests", String
|
.valueOf(tmpDeleteRequests)));
|
attrs.add(createAttribute("deleteResponses", String
|
.valueOf(tmpDeleteResponses)));
|
attrs.add(createAttribute("extendedRequests", String
|
.valueOf(tmpExtendedRequests)));
|
attrs.add(createAttribute("extendedResponses", String
|
.valueOf(tmpExtendedResponses)));
|
attrs.add(createAttribute("modifyRequests", String
|
.valueOf(tmpModifyRequests)));
|
attrs.add(createAttribute("modifyResponses", String
|
.valueOf(tmpModifyResponses)));
|
attrs.add(createAttribute("modifyDNRequests", String
|
.valueOf(tmpModifyDNRequests)));
|
attrs.add(createAttribute("modifyDNResponses", String
|
.valueOf(tmpModifyDNResponses)));
|
attrs.add(createAttribute("searchRequests", String
|
.valueOf(tmpSearchRequests)));
|
attrs.add(createAttribute("searchOneRequests", String
|
.valueOf(tmpSearchOneRequests)));
|
attrs.add(createAttribute("searchSubRequests", String
|
.valueOf(tmpSearchSubRequests)));
|
attrs.add(createAttribute("searchResultEntries", String
|
.valueOf(tmpSearchEntries)));
|
attrs.add(createAttribute("searchResultReferences", String
|
.valueOf(tmpSearchReferences)));
|
attrs.add(createAttribute("searchResultsDone", String
|
.valueOf(tmpSearchResultsDone)));
|
attrs.add(createAttribute("unbindRequests", String
|
.valueOf(tmpUnbindRequests)));
|
|
// adds
|
attrs.add(createAttribute("ds-mon-add-operations-total-count",
|
String.valueOf(tmpAddOperationCount)));
|
|
attrs.add(createAttribute(
|
"ds-mon-resident-time-add-operations-total-time", String
|
.valueOf(tmpAddOperationTime)));
|
|
// search
|
attrs.add(createAttribute("ds-mon-search-operations-total-count",
|
String.valueOf(tmpSearchOperationCount)));
|
attrs.add(createAttribute(
|
"ds-mon-resident-time-search-operations-total-time", String
|
.valueOf(tmpSearchOperationTime)));
|
|
// bind
|
attrs.add(createAttribute("ds-mon-bind-operations-total-count",
|
String.valueOf(tmpBindOperationCount)));
|
attrs.add(createAttribute(
|
"ds-mon-resident-time-bind-operations-total-time", String
|
.valueOf(tmpBindOperationTime)));
|
|
// unbind
|
attrs.add(createAttribute("ds-mon-unbind-operations-total-count",
|
String.valueOf(tmpUnbindOperationCount)));
|
attrs.add(createAttribute(
|
"ds-mon-resident-time-unbind-operations-total-time", String
|
.valueOf(tmpUnbindOperationTime)));
|
|
// compare
|
attrs
|
.add(createAttribute("ds-mon-compare-operations-total-count",
|
String.valueOf(tmpCompOperationCount)));
|
attrs.add(createAttribute(
|
"ds-mon-resident-time-compare-operations-total-time", String
|
.valueOf(tmpCompOperationTime)));
|
// del
|
attrs.add(createAttribute("ds-mon-delete-operations-total-count",
|
String.valueOf(tmpDelOperationCount)));
|
attrs.add(createAttribute(
|
"ds-mon-resident-time-delete-operations-total-time", String
|
.valueOf(tmpDelOperationTime)));
|
|
// mod
|
attrs.add(createAttribute("ds-mon-mod-operations-total-count",
|
String.valueOf(tmpModOperationCount)));
|
attrs.add(createAttribute(
|
"ds-mon-resident-time-mod-operations-total-time", String
|
.valueOf(tmpModOperationTime)));
|
|
// moddn
|
attrs.add(createAttribute("ds-mon-moddn-operations-total-count",
|
String.valueOf(tmpModdnOperationCount)));
|
attrs.add(createAttribute(
|
"ds-mon-resident-time-moddn-operations-total-time", String
|
.valueOf(tmpModdnOperationTime)));
|
|
// abandon
|
attrs
|
.add(createAttribute("ds-mon-abandon-operations-total-count",
|
String.valueOf(tmpAbandonOperationCount)));
|
attrs.add(createAttribute(
|
"ds-mon-resident-time-abandon-operations-total-time", String
|
.valueOf(tmpAbandonOperationTime)));
|
|
// extended
|
attrs
|
.add(createAttribute("ds-mon-extended-operations-total-count",
|
String.valueOf(tmpExtOperationCount)));
|
attrs.add(createAttribute(
|
"ds-mon-resident-time-extended-operations-total-time", String
|
.valueOf(tmpExtOperationTime)));
|
|
return attrs;
|
}
|
|
|
/**
|
* Clears any statistical information collected to this point.
|
*/
|
public void clearStatistics()
|
{
|
abandonRequests.set(0);
|
addRequests.set(0);
|
addResponses.set(0);
|
bindRequests.set(0);
|
bindResponses.set(0);
|
bytesRead.set(0);
|
bytesWritten.set(0);
|
compareRequests.set(0);
|
compareResponses.set(0);
|
connectionsClosed.set(0);
|
connectionsEstablished.set(0);
|
deleteRequests.set(0);
|
deleteResponses.set(0);
|
extendedRequests.set(0);
|
extendedResponses.set(0);
|
messagesRead.set(0);
|
messagesWritten.set(0);
|
modifyRequests.set(0);
|
modifyResponses.set(0);
|
modifyDNRequests.set(0);
|
modifyDNResponses.set(0);
|
operationsAbandoned.set(0);
|
operationsCompleted.set(0);
|
operationsInitiated.set(0);
|
searchRequests.set(0);
|
searchOneRequests.set(0);
|
searchSubRequests.set(0);
|
searchResultEntries.set(0);
|
searchResultReferences.set(0);
|
searchResultsDone.set(0);
|
unbindRequests.set(0);
|
|
addOperationCount.set(0);
|
addOperationTime.set(0);
|
searchOperationCount.set(0);
|
searchOperationTime.set(0);
|
delOperationCount.set(0);
|
delOperationTime.set(0);
|
bindOperationCount.set(0);
|
bindOperationTime.set(0);
|
unbindOperationCount.set(0);
|
unbindOperationTime.set(0);
|
compOperationCount.set(0);
|
compOperationTime.set(0);
|
modOperationCount.set(0);
|
modOperationTime.set(0);
|
moddnOperationCount.set(0);
|
moddnOperationTime.set(0);
|
abandonOperationCount.set(0);
|
abandonOperationTime.set(0);
|
extOperationCount.set(0);
|
extOperationTime.set(0);
|
}
|
|
|
|
|
/**
|
* Updates the appropriate set of counters to indicate that a new
|
* connection has been established.
|
*/
|
public void updateConnect()
|
{
|
connectionsEstablished.getAndIncrement();
|
}
|
|
|
|
/**
|
* 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.
|
*
|
* @param bytesRead
|
* The number of bytes read by the client.
|
*/
|
public void updateBytesRead(int bytesRead)
|
{
|
this.bytesRead.getAndAdd(bytesRead);
|
}
|
|
|
|
/**
|
* Updates the appropriate set of counters to indicate that the
|
* specified number of bytes have been written to the client.
|
*
|
* @param bytesWritten
|
* The number of bytes written to the client.
|
*/
|
public void updateBytesWritten(int bytesWritten)
|
{
|
this.bytesWritten.getAndAdd(bytesWritten);
|
}
|
|
|
|
/**
|
* Updates the appropriate set of counters based on the provided
|
* message that has been read from the client.
|
*
|
* @param message
|
* The message that was read from the client.
|
*/
|
public void updateMessageRead(LDAPMessage message)
|
{
|
messagesRead.getAndIncrement();
|
operationsInitiated.getAndIncrement();
|
|
switch (message.getProtocolOp().getType())
|
{
|
case OP_TYPE_ABANDON_REQUEST:
|
abandonRequests.getAndIncrement();
|
break;
|
case OP_TYPE_ADD_REQUEST:
|
addRequests.getAndIncrement();
|
break;
|
case OP_TYPE_BIND_REQUEST:
|
bindRequests.getAndIncrement();
|
break;
|
case OP_TYPE_COMPARE_REQUEST:
|
compareRequests.getAndIncrement();
|
break;
|
case OP_TYPE_DELETE_REQUEST:
|
deleteRequests.getAndIncrement();
|
break;
|
case OP_TYPE_EXTENDED_REQUEST:
|
extendedRequests.getAndIncrement();
|
break;
|
case OP_TYPE_MODIFY_REQUEST:
|
modifyRequests.getAndIncrement();
|
break;
|
case OP_TYPE_MODIFY_DN_REQUEST:
|
modifyDNRequests.getAndIncrement();
|
break;
|
case OP_TYPE_SEARCH_REQUEST:
|
searchRequests.getAndIncrement();
|
SearchRequestProtocolOp s = (SearchRequestProtocolOp)message
|
.getProtocolOp();
|
switch (s.getScope().asEnum())
|
{
|
case BASE_OBJECT:
|
// we don't count base object searches as
|
// this value can be derived from the others
|
break;
|
case SINGLE_LEVEL:
|
searchOneRequests.getAndIncrement();
|
break;
|
case WHOLE_SUBTREE:
|
searchSubRequests.getAndIncrement();
|
break;
|
default:
|
break;
|
}
|
break;
|
case OP_TYPE_UNBIND_REQUEST:
|
unbindRequests.getAndIncrement();
|
break;
|
}
|
}
|
|
|
|
/**
|
* Updates the appropriate set of counters based on the provided
|
* message that has been written to the client.
|
*
|
* @param message
|
* The message that was written to the client.
|
*/
|
public void updateMessageWritten(LDAPMessage message)
|
{
|
messagesWritten.getAndIncrement();
|
|
switch (message.getProtocolOp().getType())
|
{
|
case OP_TYPE_ADD_RESPONSE:
|
addResponses.getAndIncrement();
|
operationsCompleted.getAndIncrement();
|
break;
|
case OP_TYPE_BIND_RESPONSE:
|
bindResponses.getAndIncrement();
|
operationsCompleted.getAndIncrement();
|
break;
|
case OP_TYPE_COMPARE_RESPONSE:
|
compareResponses.getAndIncrement();
|
operationsCompleted.getAndIncrement();
|
break;
|
case OP_TYPE_DELETE_RESPONSE:
|
deleteResponses.getAndIncrement();
|
operationsCompleted.getAndIncrement();
|
break;
|
case OP_TYPE_EXTENDED_RESPONSE:
|
extendedResponses.getAndIncrement();
|
|
// We don't want to include unsolicited notifications as
|
// "completed" operations.
|
if (message.getMessageID() > 0)
|
{
|
operationsCompleted.getAndIncrement();
|
}
|
break;
|
case OP_TYPE_MODIFY_RESPONSE:
|
modifyResponses.getAndIncrement();
|
operationsCompleted.getAndIncrement();
|
break;
|
case OP_TYPE_MODIFY_DN_RESPONSE:
|
modifyDNResponses.getAndIncrement();
|
operationsCompleted.getAndIncrement();
|
break;
|
case OP_TYPE_SEARCH_RESULT_ENTRY:
|
searchResultEntries.getAndIncrement();
|
break;
|
case OP_TYPE_SEARCH_RESULT_REFERENCE:
|
searchResultReferences.getAndIncrement();
|
break;
|
case OP_TYPE_SEARCH_RESULT_DONE:
|
searchResultsDone.getAndIncrement();
|
operationsCompleted.getAndIncrement();
|
break;
|
}
|
}
|
|
|
|
/**
|
* Updates the appropriate set of counters to indicate that an
|
* operation was abandoned without sending a response to the client.
|
*/
|
public void updateAbandonedOperation()
|
{
|
operationsAbandoned.getAndIncrement();
|
}
|
|
|
|
/**
|
* Constructs an attribute using the provided information. It will
|
* use the server's schema definitions.
|
*
|
* @param name
|
* The name to use for the attribute.
|
* @param value
|
* The value to use for the attribute.
|
* @return the constructed attribute.
|
*/
|
protected Attribute createAttribute(String name, String value)
|
{
|
AttributeType attrType =
|
DirectoryServer.getAttributeType(name.toLowerCase());
|
return Attributes.create(attrType, value);
|
}
|
|
|
|
/**
|
* Retrieves the number of client connections that have been
|
* established.
|
*
|
* @return The number of client connections that have been
|
* established.
|
*/
|
public long getConnectionsEstablished()
|
{
|
return connectionsEstablished.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of client connections that have been closed.
|
*
|
* @return The number of client connections that have been closed.
|
*/
|
public long getConnectionsClosed()
|
{
|
return connectionsClosed.get();
|
|
}
|
|
|
|
/**
|
* Retrieves the number of bytes that have been received from clients.
|
*
|
* @return The number of bytes that have been received from clients.
|
*/
|
public long getBytesRead()
|
{
|
return bytesRead.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of bytes that have been written to clients.
|
*
|
* @return The number of bytes that have been written to clients.
|
*/
|
public long getBytesWritten()
|
{
|
return bytesWritten.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of LDAP messages that have been received from
|
* clients.
|
*
|
* @return The number of LDAP messages that have been received from
|
* clients.
|
*/
|
public long getMessagesRead()
|
{
|
return messagesRead.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of LDAP messages that have been written to
|
* clients.
|
*
|
* @return The number of LDAP messages that have been written to
|
* clients.
|
*/
|
public long getMessagesWritten()
|
{
|
return messagesWritten.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of operations that have been initiated by
|
* clients.
|
*
|
* @return The number of operations that have been initiated by
|
* clients.
|
*/
|
public long getOperationsInitiated()
|
{
|
return operationsInitiated.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of operations for which the server has
|
* completed processing.
|
*
|
* @return The number of operations for which the server has completed
|
* processing.
|
*/
|
public long getOperationsCompleted()
|
{
|
return operationsCompleted.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of operations that have been abandoned by
|
* clients.
|
*
|
* @return The number of operations that have been abandoned by
|
* clients.
|
*/
|
public long getOperationsAbandoned()
|
{
|
return operationsAbandoned.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of abandon requests that have been received.
|
*
|
* @return The number of abandon requests that have been received.
|
*/
|
public long getAbandonRequests()
|
{
|
return abandonRequests.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of add requests that have been received.
|
*
|
* @return The number of add requests that have been received.
|
*/
|
public long getAddRequests()
|
{
|
return addRequests.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of add responses that have been sent.
|
*
|
* @return The number of add responses that have been sent.
|
*/
|
public long getAddResponses()
|
{
|
return addResponses.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of bind requests that have been received.
|
*
|
* @return The number of bind requests that have been received.
|
*/
|
public long getBindRequests()
|
{
|
return bindRequests.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of bind responses that have been sent.
|
*
|
* @return The number of bind responses that have been sent.
|
*/
|
public long getBindResponses()
|
{
|
return bindResponses.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of compare requests that have been received.
|
*
|
* @return The number of compare requests that have been received.
|
*/
|
public long getCompareRequests()
|
{
|
return compareRequests.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of compare responses that have been sent.
|
*
|
* @return The number of compare responses that have been sent.
|
*/
|
public long getCompareResponses()
|
{
|
return compareResponses.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of delete requests that have been received.
|
*
|
* @return The number of delete requests that have been received.
|
*/
|
public long getDeleteRequests()
|
{
|
return deleteRequests.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of delete responses that have been sent.
|
*
|
* @return The number of delete responses that have been sent.
|
*/
|
public long getDeleteResponses()
|
{
|
return deleteResponses.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of extended requests that have been received.
|
*
|
* @return The number of extended requests that have been received.
|
*/
|
public long getExtendedRequests()
|
{
|
return extendedRequests.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of extended responses that have been sent.
|
*
|
* @return The number of extended responses that have been sent.
|
*/
|
public long getExtendedResponses()
|
{
|
return extendedResponses.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of modify requests that have been received.
|
*
|
* @return The number of modify requests that have been received.
|
*/
|
public long getModifyRequests()
|
{
|
return modifyRequests.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of modify responses that have been sent.
|
*
|
* @return The number of modify responses that have been sent.
|
*/
|
public long getModifyResponses()
|
{
|
return modifyResponses.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of modify DN requests that have been received.
|
*
|
* @return The number of modify DN requests that have been received.
|
*/
|
public long getModifyDNRequests()
|
{
|
return modifyDNRequests.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of modify DN responses that have been sent.
|
*
|
* @return The number of modify DN responses that have been sent.
|
*/
|
public long getModifyDNResponses()
|
{
|
return modifyDNResponses.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of search requests that have been received.
|
*
|
* @return The number of search requests that have been received.
|
*/
|
public long getSearchRequests()
|
{
|
return searchRequests.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of one-level search requests that have been received.
|
*
|
* @return The number of one-level search requests that have been received.
|
*/
|
public long getSearchOneRequests()
|
{
|
return searchOneRequests.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of subtree search requests that have been received.
|
*
|
* @return The number of subtree search requests that have been received.
|
*/
|
public long getSearchSubRequests()
|
{
|
return searchSubRequests.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of search result entries that have been sent.
|
*
|
* @return The number of search result entries that have been sent.
|
*/
|
public long getSearchResultEntries()
|
{
|
return searchResultEntries.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of search result references that have been
|
* sent.
|
*
|
* @return The number of search result references that have been sent.
|
*/
|
public long getSearchResultReferences()
|
{
|
return searchResultReferences.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of search result done messages that have been
|
* sent.
|
*
|
* @return The number of search result done messages that have been
|
* sent.
|
*/
|
public long getSearchResultsDone()
|
{
|
return searchResultsDone.get();
|
}
|
|
|
|
/**
|
* Retrieves the number of unbind requests that have been received.
|
*
|
* @return The number of unbind requests that have been received.
|
*/
|
public long getUnbindRequests()
|
{
|
return unbindRequests.get();
|
}
|
|
/**
|
* Update the operation counters and times depending on the OperationType.
|
* @param type of the operation.
|
* @param time of the operation execution.
|
*/
|
|
public void updateOperationMonitoringData(OperationType type, long time) {
|
if (type.equals(OperationType.ADD)) {
|
addOperationCount.getAndIncrement();
|
addOperationTime.getAndAdd(time);
|
}
|
else if (type.equals(OperationType.SEARCH)) {
|
searchOperationCount.getAndIncrement();
|
searchOperationTime.getAndAdd(time);
|
}
|
else if (type.equals(OperationType.ABANDON)) {
|
abandonOperationCount.getAndIncrement();
|
abandonOperationTime.getAndAdd(time);
|
}
|
else if (type.equals(OperationType.BIND)) {
|
bindOperationCount.getAndIncrement();
|
bindOperationTime.getAndAdd(time);
|
}
|
else if (type.equals(OperationType.UNBIND)) {
|
unbindOperationCount.getAndIncrement();
|
unbindOperationTime.getAndAdd(time);
|
}
|
else if (type.equals(OperationType.COMPARE)) {
|
compOperationCount.getAndIncrement();
|
compOperationTime.getAndAdd(time);
|
}
|
else if (type.equals(OperationType.DELETE)) {
|
delOperationCount.getAndIncrement();
|
delOperationTime.getAndAdd(time);
|
}
|
else if (type.equals(OperationType.EXTENDED)) {
|
extOperationCount.getAndIncrement();
|
extOperationTime.getAndAdd(time);
|
}
|
else if (type.equals(OperationType.MODIFY)) {
|
modOperationCount.getAndIncrement();
|
modOperationTime.getAndAdd(time);
|
}
|
else if (type.equals(OperationType.MODIFY_DN)) {
|
moddnOperationCount.getAndIncrement();
|
moddnOperationTime.getAndAdd(time);
|
}
|
}
|
|
}
|
