From: Pierangelo Masarati <ando@openldap.org>
Date: Fri, 11 Jan 2002 11:48:46 +0000 (+0000)
Subject: of course this is required by listener monitor
X-Git-Tag: LDBM_PRE_GIANT_RWLOCK~189
X-Git-Url: https://git.sur5r.net/?a=commitdiff_plain;h=6c76b2c55d6223945efc69754fdb0a71a193c126;p=openldap

of course this is required by listener monitor
---

diff --git a/servers/slapd/back-monitor/listener.c b/servers/slapd/back-monitor/listener.c
new file mode 100644
index 0000000000..d9c4cfa5d2
--- /dev/null
+++ b/servers/slapd/back-monitor/listener.c
@@ -0,0 +1,161 @@
+/* listener.c - deals with listener subsystem */
+/*
+ * Copyright 1998-2002 The OpenLDAP Foundation, All Rights Reserved.
+ * COPYING RESTRICTIONS APPLY, see COPYRIGHT file
+ */
+/*
+ * Copyright 2001, Pierangelo Masarati, All rights reserved. <ando@sys-net.it>
+ * 
+ * This work has beed deveolped for the OpenLDAP Foundation 
+ * in the hope that it may be useful to the Open Source community, 
+ * but WITHOUT ANY WARRANTY.
+ * 
+ * Permission is granted to anyone to use this software for any purpose
+ * on any computer system, and to alter it and redistribute it, subject
+ * to the following restrictions:
+ * 
+ * 1. The author and SysNet s.n.c. are not responsible for the consequences
+ *    of use of this software, no matter how awful, even if they arise from
+ *    flaws in it.
+ * 
+ * 2. The origin of this software must not be misrepresented, either by
+ *    explicit claim or by omission.  Since few users ever read sources,
+ *    credits should appear in the documentation.
+ * 
+ * 3. Altered versions must be plainly marked as such, and must not be
+ *    misrepresented as being the original software.  Since few users
+ *    ever read sources, credits should appear in the documentation.
+ *    SysNet s.n.c. cannot be responsible for the consequences of the
+ *    alterations.
+ * 
+ * 4. This notice may not be removed or altered.
+ */
+
+#include "portable.h"
+
+#include <stdio.h>
+
+#include "slap.h"
+#include "back-monitor.h"
+
+int
+monitor_subsys_listener_init(
+	BackendDB	*be
+)
+{
+	struct monitorinfo	*mi;
+	Entry			*e, *e_listener, *e_tmp;
+	int			i;
+	struct monitorentrypriv	*mp;
+	struct berval 		bv[2];
+	Listener		**l;
+
+	assert( be != NULL );
+	assert( monitor_ad_desc != NULL );
+
+	mi = ( struct monitorinfo * )be->be_private;
+
+	if ( monitor_cache_get( mi, 
+				&monitor_subsys[SLAPD_MONITOR_LISTENER].mss_ndn, 
+				&e_listener ) ) {
+#ifdef NEW_LOGGING
+		LDAP_LOG(( "operation", LDAP_LEVEL_CRIT,
+			"monitor_subsys_listener_init: "
+			"unable to get entry '%s'\n",
+			monitor_subsys[SLAPD_MONITOR_LISTENER].mss_ndn.bv_val ));
+#else
+		Debug( LDAP_DEBUG_ANY,
+			"monitor_subsys_listener_init: "
+			"unable to get entry '%s'\n%s%s",
+			monitor_subsys[SLAPD_MONITOR_LISTENER].mss_ndn.bv_val, 
+			"", "" );
+#endif
+		return( -1 );
+	}
+
+	if ( ( l = slapd_get_listeners() ) == NULL ) {
+#ifdef NEW_LOGGING
+		LDAP_LOG(( "operation", LDAP_LEVEL_CRIT,
+			"monitor_subsys_listener_init: "
+			"unable to get listeners\n" ));
+#else
+		Debug( LDAP_DEBUG_ANY,
+			"monitor_subsys_listener_init: "
+			"unable to get listeners\n", 0, 0, 0 );
+#endif
+		return( -1 );
+	}
+
+	e_tmp = NULL;
+	for ( i = 0; l[i]; i++ ) {
+		char 		buf[1024];
+
+		snprintf( buf, sizeof( buf ),
+				"dn: cn=%s,%s\n"
+				SLAPD_MONITOR_OBJECTCLASSES
+				"cn: %s\n",
+				l[i]->sl_name,
+				monitor_subsys[SLAPD_MONITOR_LISTENER].mss_dn.bv_val,
+				l[i]->sl_name );
+		
+		e = str2entry( buf );
+		if ( e == NULL ) {
+#ifdef NEW_LOGGING
+			LDAP_LOG(( "operation", LDAP_LEVEL_CRIT,
+				"monitor_subsys_listener_init: "
+				"unable to create entry 'cn=%s,%s'\n",
+				l[i]->sl_name,
+				monitor_subsys[SLAPD_MONITOR_LISTENER].mss_ndn.bv_val ));
+#else
+			Debug( LDAP_DEBUG_ANY,
+				"monitor_subsys_listener_init: "
+				"unable to create entry 'cn=%s,%s'\n%s",
+				l[i]->sl_name, 
+				monitor_subsys[SLAPD_MONITOR_LISTENER].mss_ndn.bv_val,
+				"" );
+#endif
+			return( -1 );
+		}
+		
+		bv[1].bv_val = NULL;
+		bv[0].bv_val = l[i]->sl_url;
+		bv[0].bv_len = strlen( bv[0].bv_val );
+		attr_merge( e, monitor_ad_desc, bv );
+		
+		mp = ( struct monitorentrypriv * )ch_calloc( sizeof( struct monitorentrypriv ), 1 );
+		e->e_private = ( void * )mp;
+		mp->mp_next = e_tmp;
+		mp->mp_children = NULL;
+		mp->mp_info = &monitor_subsys[SLAPD_MONITOR_LISTENER];
+		mp->mp_flags = monitor_subsys[SLAPD_MONITOR_LISTENER].mss_flags
+			| MONITOR_F_SUB;
+
+		if ( monitor_cache_add( mi, e ) ) {
+#ifdef NEW_LOGGING
+			LDAP_LOG(( "operation", LDAP_LEVEL_CRIT,
+				"monitor_subsys_listener_init: "
+				"unable to add entry 'cn=%s,%s'\n",
+				l[i]->sl_name, 
+				monitor_subsys[SLAPD_MONITOR_LISTENER].mss_ndn.bv_val ));
+#else
+			Debug( LDAP_DEBUG_ANY,
+				"monitor_subsys_listener_init: "
+				"unable to add entry 'cn=%s,%s'\n",
+				l[i]->sl_name, 
+				monitor_subsys[SLAPD_MONITOR_LISTENER].mss_ndn.bv_val,
+				0 );
+#endif
+			return( -1 );
+		}
+
+		e_tmp = e;
+	}
+	
+	mp = ( struct monitorentrypriv * )e_listener->e_private;
+	mp->mp_children = e_tmp;
+
+	monitor_cache_release( mi, e_listener );
+
+	return( 0 );
+}
+