Moving NSCP Directory Server from DirectoryBranch to TRUNK, initial drop. (foxworth)ldapserver7x

1 files changed, 151 insertions, 0 deletions

diff --git a/ldap/servers/slapd/counters.c b/ldap/servers/slapd/counters.c
new file mode 100644
index 00000000..f9875790
--- /dev/null
+++ b/ldap/servers/slapd/counters.c
@@ -0,0 +1,151 @@
+/** BEGIN COPYRIGHT BLOCK
+ * Copyright 2001 Sun Microsystems, Inc.
+ * Portions copyright 1999, 2001-2003 Netscape Communications Corporation.
+ * All rights reserved.
+ * END COPYRIGHT BLOCK **/
+
+#include <prcountr.h>
+#include "slap.h"
+
+#if defined(DEBUG)
+struct counter
+{
+	const char *qname;
+	const char *rname;
+	const char *description;
+	PRUint32 before_counter;
+	PRUint32 after_counter;
+};
+
+static int num_counters= 0;
+static struct counter *counters= NULL;
+
+static int
+count_counters()
+{
+	int i= 0;
+	PR_DEFINE_COUNTER(qh);
+	PR_INIT_COUNTER_HANDLE(qh,NULL);
+	PR_FIND_NEXT_COUNTER_QNAME(qh,qh);
+	while(qh!=NULL)
+	{
+		PR_DEFINE_COUNTER(rh);
+		PR_INIT_COUNTER_HANDLE(rh,NULL);
+		PR_FIND_NEXT_COUNTER_RNAME(rh,rh,qh);
+		while(rh!=NULL)
+		{
+			i++;
+			PR_FIND_NEXT_COUNTER_RNAME(rh,rh,qh);
+		}
+		PR_FIND_NEXT_COUNTER_QNAME(qh,qh);
+	}
+	return i;
+}
+
+static int
+do_fetch_counters()
+{
+	int i= 0;
+	PR_DEFINE_COUNTER(qh);
+	PR_INIT_COUNTER_HANDLE(qh,NULL);
+	PR_FIND_NEXT_COUNTER_QNAME(qh,qh);
+	while(qh!=NULL)
+	{
+		PR_DEFINE_COUNTER(rh);
+		PR_INIT_COUNTER_HANDLE(rh,NULL);
+		PR_FIND_NEXT_COUNTER_RNAME(rh,rh,qh);
+		while(rh!=NULL)
+		{
+			if(i<num_counters)
+			{
+				counters[i].before_counter= counters[i].after_counter;
+				PR_GET_COUNTER_NAME_FROM_HANDLE(rh,&counters[i].qname,&counters[i].rname,&counters[i].description);
+				PR_GET_COUNTER(counters[i].after_counter,rh);
+			}
+			i++;
+			PR_FIND_NEXT_COUNTER_RNAME(rh,rh,qh);
+		}
+		PR_FIND_NEXT_COUNTER_QNAME(qh,qh);
+	}
+	return i;
+}
+
+static void
+fetch_counters()
+{
+	int i;
+	if(counters==NULL)
+	{
+		num_counters= count_counters();
+		counters= (struct counter*)calloc(num_counters,sizeof(struct counter));
+	}
+	i= do_fetch_counters();
+	if(i>num_counters)
+	{
+		free(counters);
+		counters= NULL;
+		num_counters= i;
+		counters= (struct counter*)calloc(num_counters,sizeof(struct counter));
+		do_fetch_counters();
+	}
+}
+
+static size_t
+counter_size(struct counter *counter)
+{
+	size_t r= 0;
+	r+= (counter->qname?strlen(counter->qname):0);
+	r+= (counter->rname?strlen(counter->rname):0);
+	r+= (counter->description?strlen(counter->description):0);
+	return r;
+}
+
+static void
+counter_dump(char *name, char *value, int i)
+{
+	PRUint32 diff_counter;
+	sprintf(name,"%s_%s_%s",counters[i].qname,counters[i].rname,counters[i].description);
+	diff_counter= counters[i].after_counter-counters[i].before_counter;
+	sprintf(value,"%d -> %d (%s%d)",
+		counters[i].before_counter,
+		counters[i].after_counter,
+		(diff_counter>0?"+":""),
+		diff_counter);
+}
+#endif
+
+void
+counters_as_entry(Slapi_Entry* e)
+{
+#if defined(DEBUG)
+	int i;
+	fetch_counters();
+	for(i=0;i<num_counters;i++)
+	{
+		char value[40];
+		char *type= (char*)malloc(counter_size(&counters[i])+4);
+		counter_dump(type,value,i);
+		slapi_entry_attr_set_charptr( e, type, value);
+		free(type);
+	}
+#endif
+}
+
+
+void
+counters_to_errors_log(const char *text)
+{
+#if defined(DEBUG)
+	int i;
+	fetch_counters();
+	LDAPDebug( LDAP_DEBUG_ANY, "Counter Dump - %s\n",text, 0, 0);
+	for(i=0;i<num_counters;i++)
+	{
+		char value[40];
+		char *type= (char*)malloc(counter_size(&counters[i])+4);
+		counter_dump(type,value,i);
+		LDAPDebug( LDAP_DEBUG_ANY, "%s %s\n",type, value, 0);
+		free(type);
+	}
+#endif
+}