From 6c76b2c55d6223945efc69754fdb0a71a193c126 Mon Sep 17 00:00:00 2001 From: Pierangelo Masarati Date: Fri, 11 Jan 2002 11:48:46 +0000 Subject: [PATCH] of course this is required by listener monitor --- servers/slapd/back-monitor/listener.c | 161 ++++++++++++++++++++++++++ 1 file changed, 161 insertions(+) create mode 100644 servers/slapd/back-monitor/listener.c 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. + * + * 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 + +#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 ); +} + -- 2.39.5