git.sur5r.net Git - openldap/blob - servers/slapd/back-monitor/init.c

   1 /* init.c - initialize monitor backend */
   2 /* $OpenLDAP$ */
   3 /* This work is part of OpenLDAP Software <http://www.openldap.org/>.
   4  *
   5  * Copyright 2001-2004 The OpenLDAP Foundation.
   6  * Portions Copyright 2001-2003 Pierangelo Masarati.
   7  * All rights reserved.
   8  *
   9  * Redistribution and use in source and binary forms, with or without
  10  * modification, are permitted only as authorized by the OpenLDAP
  11  * Public License.
  12  *
  13  * A copy of this license is available in file LICENSE in the
  14  * top-level directory of the distribution or, alternatively, at
  15  * <http://www.OpenLDAP.org/license.html>.
  16  */
  17 /* ACKNOWLEDGEMENTS:
  18  * This work was initially developed by Pierangelo Masarati for inclusion
  19  * in OpenLDAP Software.
  20  */
  21
  22 #include "portable.h"
  23
  24 #include <stdio.h>
  25 #include <ac/string.h>
  26
  27 #include <lutil.h>
  28 #include "slap.h"
  29 #include "lber_pvt.h"
  30 #include "back-monitor.h"
  31
  32 #undef INTEGRATE_CORE_SCHEMA
  33
  34 /*
  35  * used by many functions to add description to entries
  36  */
  37 BackendDB *be_monitor = NULL;
  38
  39 /*
  40  * subsystem data
  41  */
  42 struct monitorsubsys monitor_subsys[] = {
  43         {
  44                 SLAPD_MONITOR_LISTENER, SLAPD_MONITOR_LISTENER_NAME,
  45                 BER_BVNULL, BER_BVNULL, BER_BVNULL,
  46                 MONITOR_F_PERSISTENT_CH,
  47                 monitor_subsys_listener_init,
  48                 NULL,   /* update */
  49                 NULL,   /* create */
  50                 NULL    /* modify */
  51         }, {
  52                 SLAPD_MONITOR_DATABASE, SLAPD_MONITOR_DATABASE_NAME,
  53                 BER_BVNULL, BER_BVNULL, BER_BVNULL,
  54                 MONITOR_F_PERSISTENT_CH,
  55                 monitor_subsys_database_init,
  56                 NULL,   /* update */
  57                 NULL,   /* create */
  58                 monitor_subsys_database_modify
  59         }, {
  60                 SLAPD_MONITOR_BACKEND, SLAPD_MONITOR_BACKEND_NAME,
  61                 BER_BVNULL, BER_BVNULL, BER_BVNULL,
  62                 MONITOR_F_PERSISTENT_CH,
  63                 monitor_subsys_backend_init,
  64                 NULL,   /* update */
  65                 NULL,   /* create */
  66                 NULL    /* modify */
  67         }, {
  68                 SLAPD_MONITOR_THREAD, SLAPD_MONITOR_THREAD_NAME,
  69                 BER_BVNULL, BER_BVNULL, BER_BVNULL,
  70                 MONITOR_F_NONE,
  71                 monitor_subsys_thread_init,
  72                 monitor_subsys_thread_update,
  73                 NULL,   /* create */
  74                 NULL    /* modify */
  75         }, {
  76                 SLAPD_MONITOR_SASL, SLAPD_MONITOR_SASL_NAME,
  77                 BER_BVNULL, BER_BVNULL, BER_BVNULL,
  78                 MONITOR_F_NONE,
  79                 NULL,   /* init */
  80                 NULL,   /* update */
  81                 NULL,   /* create */
  82                 NULL    /* modify */
  83         }, {
  84                 SLAPD_MONITOR_TLS, SLAPD_MONITOR_TLS_NAME,
  85                 BER_BVNULL, BER_BVNULL, BER_BVNULL,
  86                 MONITOR_F_NONE,
  87                 NULL,   /* init */
  88                 NULL,   /* update */
  89                 NULL,   /* create */
  90                 NULL    /* modify */
  91         }, {
  92                 SLAPD_MONITOR_CONN, SLAPD_MONITOR_CONN_NAME,
  93                 BER_BVNULL, BER_BVNULL, BER_BVNULL,
  94                 MONITOR_F_VOLATILE_CH,
  95                 monitor_subsys_conn_init,
  96                 monitor_subsys_conn_update,
  97                 monitor_subsys_conn_create,
  98                 NULL    /* modify */
  99         }, {
 100                 SLAPD_MONITOR_RWW, SLAPD_MONITOR_RWW_NAME,
 101                 BER_BVNULL, BER_BVNULL, BER_BVNULL,
 102                 MONITOR_F_PERSISTENT_CH,
 103                 monitor_subsys_rww_init,
 104                 monitor_subsys_rww_update,
 105                 NULL,   /* create */
 106                 NULL    /* modify */
 107         }, {
 108                 SLAPD_MONITOR_LOG, SLAPD_MONITOR_LOG_NAME,
 109                 BER_BVNULL, BER_BVNULL, BER_BVNULL,
 110                 MONITOR_F_NONE,
 111                 monitor_subsys_log_init,
 112                 NULL,   /* update */
 113                 NULL,   /* create */
 114                 monitor_subsys_log_modify
 115         }, {
 116                 SLAPD_MONITOR_OPS, SLAPD_MONITOR_OPS_NAME,
 117                 BER_BVNULL, BER_BVNULL, BER_BVNULL,
 118                 MONITOR_F_PERSISTENT_CH,
 119                 monitor_subsys_ops_init,
 120                 monitor_subsys_ops_update,
 121                 NULL,   /* create */
 122                 NULL,   /* modify */
 123         }, {
 124                 SLAPD_MONITOR_SENT, SLAPD_MONITOR_SENT_NAME,
 125                 BER_BVNULL, BER_BVNULL, BER_BVNULL,
 126                 MONITOR_F_PERSISTENT_CH,
 127                 monitor_subsys_sent_init,
 128                 monitor_subsys_sent_update,
 129                 NULL,   /* create */
 130                 NULL,   /* modify */
 131         }, {
 132                 SLAPD_MONITOR_TIME, SLAPD_MONITOR_TIME_NAME,
 133                 BER_BVNULL, BER_BVNULL, BER_BVNULL,
 134                 MONITOR_F_PERSISTENT_CH,
 135                 monitor_subsys_time_init,
 136                 monitor_subsys_time_update,
 137                 NULL,   /* create */
 138                 NULL,   /* modify */
 139         }, {
 140                 SLAPD_MONITOR_OVERLAY, SLAPD_MONITOR_OVERLAY_NAME,
 141                 BER_BVNULL, BER_BVNULL, BER_BVNULL,
 142                 MONITOR_F_PERSISTENT_CH,
 143                 monitor_subsys_overlay_init,
 144                 NULL,   /* update */
 145                 NULL,   /* create */
 146                 NULL,   /* modify */
 147         }, { -1, NULL }
 148 };
 149
 150 #if SLAPD_MONITOR == SLAPD_MOD_DYNAMIC
 151
 152 int
 153 init_module( int argc, char *argv[] )
 154 {
 155         BackendInfo bi;
 156
 157         memset( &bi, '\0', sizeof(bi) );
 158         bi.bi_type = "monitor";
 159         bi.bi_init = monitor_back_initialize;
 160         backend_add( &bi );
 161         return 0;
 162 }
 163
 164 #endif /* SLAPD_MONITOR */
 165
 166 int
 167 monitor_back_initialize(
 168         BackendInfo     *bi
 169 )
 170 {
 171         static char *controls[] = {
 172                 LDAP_CONTROL_MANAGEDSAIT,
 173                 LDAP_CONTROL_VALUESRETURNFILTER,
 174                 NULL
 175         };
 176
 177         bi->bi_controls = controls;
 178
 179         bi->bi_init = 0;
 180         bi->bi_open = 0;
 181         bi->bi_config = monitor_back_config;
 182         bi->bi_close = 0;
 183         bi->bi_destroy = 0;
 184
 185         bi->bi_db_init = monitor_back_db_init;
 186         bi->bi_db_config = monitor_back_db_config;
 187         bi->bi_db_open = monitor_back_db_open;
 188         bi->bi_db_close = 0;
 189         bi->bi_db_destroy = monitor_back_db_destroy;
 190
 191         bi->bi_op_bind = monitor_back_bind;
 192         bi->bi_op_unbind = 0;
 193         bi->bi_op_search = monitor_back_search;
 194         bi->bi_op_compare = monitor_back_compare;
 195         bi->bi_op_modify = monitor_back_modify;
 196         bi->bi_op_modrdn = 0;
 197         bi->bi_op_add = 0;
 198         bi->bi_op_delete = 0;
 199         bi->bi_op_abandon = 0;
 200
 201         bi->bi_extended = 0;
 202
 203         bi->bi_entry_release_rw = 0;
 204         bi->bi_chk_referrals = 0;
 205         bi->bi_operational = monitor_back_operational;
 206
 207         /*
 208          * hooks for slap tools
 209          */
 210         bi->bi_tool_entry_open = 0;
 211         bi->bi_tool_entry_close = 0;
 212         bi->bi_tool_entry_first = 0;
 213         bi->bi_tool_entry_next = 0;
 214         bi->bi_tool_entry_get = 0;
 215         bi->bi_tool_entry_put = 0;
 216         bi->bi_tool_entry_reindex = 0;
 217         bi->bi_tool_sync = 0;
 218         bi->bi_tool_dn2id_get = 0;
 219         bi->bi_tool_id2entry_get = 0;
 220         bi->bi_tool_entry_modify = 0;
 221
 222         bi->bi_connection_init = 0;
 223         bi->bi_connection_destroy = 0;
 224
 225         return 0;
 226 }
 227
 228 int
 229 monitor_back_db_init(
 230         BackendDB       *be
 231 )
 232 {
 233         struct monitorinfo      *mi;
 234         int                     i, rc;
 235         struct berval           dn, ndn;
 236         struct berval           bv;
 237         const char              *text;
 238
 239         struct m_s {
 240                 char    *name;
 241                 char    *schema;
 242                 slap_mask_t flags;
 243                 int     offset;
 244         } moc[] = {
 245                 { "monitor", "( 1.3.6.1.4.1.4203.666.3.2 "
 246                         "NAME 'monitor' "
 247                         "DESC 'OpenLDAP system monitoring' "
 248                         "SUP top STRUCTURAL "
 249                         "MUST cn "
 250                         "MAY ( "
 251                                 "description "
 252                                 "$ l "
 253 #if 0   /* temporarily disabled */
 254                                 "$ st "
 255                                 "$ street "
 256                                 "$ postalAddress "
 257                                 "$ postalCode "
 258 #endif
 259                                 "$ seeAlso "
 260                                 "$ labeledURI "
 261                                 "$ monitoredInfo "
 262                                 "$ managedInfo "
 263                                 "$ monitorOverlay "
 264                         ") )", SLAP_OC_OPERATIONAL|SLAP_OC_HIDE,
 265                         offsetof(struct monitorinfo, mi_oc_monitor) },
 266                 { "monitorServer", "( 1.3.6.1.4.1.4203.666.3.7 "
 267                         "NAME 'monitorServer' "
 268                         "DESC 'Server monitoring root entry' "
 269                         "SUP monitor STRUCTURAL )", SLAP_OC_OPERATIONAL|SLAP_OC_HIDE,
 270                         offsetof(struct monitorinfo, mi_oc_monitorServer) },
 271                 { "monitorContainer", "( 1.3.6.1.4.1.4203.666.3.8 "
 272                         "NAME 'monitorContainer' "
 273                         "DESC 'monitor container class' "
 274                         "SUP monitor STRUCTURAL )", SLAP_OC_OPERATIONAL|SLAP_OC_HIDE,
 275                         offsetof(struct monitorinfo, mi_oc_monitorContainer) },
 276                 { "monitorCounterObject", "( 1.3.6.1.4.1.4203.666.3.9 "
 277                         "NAME 'monitorCounterObject' "
 278                         "DESC 'monitor counter class' "
 279                         "SUP monitor STRUCTURAL )", SLAP_OC_OPERATIONAL|SLAP_OC_HIDE,
 280                         offsetof(struct monitorinfo, mi_oc_monitorCounterObject) },
 281                 { "monitorOperation", "( 1.3.6.1.4.1.4203.666.3.10 "
 282                         "NAME 'monitorOperation' "
 283                         "DESC 'monitor operation class' "
 284                         "SUP monitor STRUCTURAL )", SLAP_OC_OPERATIONAL|SLAP_OC_HIDE,
 285                         offsetof(struct monitorinfo, mi_oc_monitorOperation) },
 286                 { "monitorConnection", "( 1.3.6.1.4.1.4203.666.3.11 "
 287                         "NAME 'monitorConnection' "
 288                         "DESC 'monitor connection class' "
 289                         "SUP monitor STRUCTURAL )", SLAP_OC_OPERATIONAL|SLAP_OC_HIDE,
 290                         offsetof(struct monitorinfo, mi_oc_monitorConnection) },
 291                 { "managedObject", "( 1.3.6.1.4.1.4203.666.3.12 "
 292                         "NAME 'managedObject' "
 293                         "DESC 'monitor managed entity class' "
 294                         "SUP monitor STRUCTURAL )", SLAP_OC_OPERATIONAL|SLAP_OC_HIDE,
 295                         offsetof(struct monitorinfo, mi_oc_managedObject) },
 296                 { "monitoredObject", "( 1.3.6.1.4.1.4203.666.3.13 "
 297                         "NAME 'monitoredObject' "
 298                         "DESC 'monitor monitored entity class' "
 299                         "SUP monitor STRUCTURAL )", SLAP_OC_OPERATIONAL|SLAP_OC_HIDE,
 300                         offsetof(struct monitorinfo, mi_oc_monitoredObject) },
 301                 { NULL, NULL, 0, -1 }
 302         }, mat[] = {
 303                 { "monitoredInfo", "( 1.3.6.1.4.1.4203.666.1.14 "
 304                         "NAME 'monitoredInfo' "
 305                         "DESC 'monitored info' "
 306                         /* "SUP name " */
 307                         "EQUALITY caseIgnoreMatch "
 308                         "SUBSTR caseIgnoreSubstringsMatch "
 309                         "SYNTAX 1.3.6.1.4.1.1466.115.121.1.15{32768} "
 310                         "NO-USER-MODIFICATION "
 311                         "USAGE directoryOperation )", SLAP_AT_HIDE,
 312                         offsetof(struct monitorinfo, mi_ad_monitoredInfo) },
 313                 { "managedInfo", "( 1.3.6.1.4.1.4203.666.1.15 "
 314                         "NAME 'managedInfo' "
 315                         "DESC 'monitor managed info' "
 316                         "SUP name )", SLAP_AT_HIDE,
 317                         offsetof(struct monitorinfo, mi_ad_managedInfo) },
 318                 { "monitorCounter", "( 1.3.6.1.4.1.4203.666.1.16 "
 319                         "NAME 'monitorCounter' "
 320                         "DESC 'monitor counter' "
 321                         "EQUALITY integerMatch "
 322                         "ORDERING integerOrderingMatch "
 323                         "SYNTAX 1.3.6.1.4.1.1466.115.121.1.27 "
 324                         "NO-USER-MODIFICATION "
 325                         "USAGE directoryOperation )", SLAP_AT_HIDE,
 326                         offsetof(struct monitorinfo, mi_ad_monitorCounter) },
 327                 { "monitorOpCompleted", "( 1.3.6.1.4.1.4203.666.1.17 "
 328                         "NAME 'monitorOpCompleted' "
 329                         "DESC 'monitor completed operations' "
 330                         "SUP monitorCounter "
 331                         "NO-USER-MODIFICATION "
 332                         "USAGE directoryOperation )", SLAP_AT_FINAL|SLAP_AT_HIDE,
 333                         offsetof(struct monitorinfo, mi_ad_monitorOpCompleted) },
 334                 { "monitorOpInitiated", "( 1.3.6.1.4.1.4203.666.1.18 "
 335                         "NAME 'monitorOpInitiated' "
 336                         "DESC 'monitor initiated operations' "
 337                         "SUP monitorCounter "
 338                         "NO-USER-MODIFICATION "
 339                         "USAGE directoryOperation )", SLAP_AT_FINAL|SLAP_AT_HIDE,
 340                         offsetof(struct monitorinfo, mi_ad_monitorOpInitiated) },
 341                 { "monitorConnectionNumber", "( 1.3.6.1.4.1.4203.666.1.19 "
 342                         "NAME 'monitorConnectionNumber' "
 343                         "DESC 'monitor connection number' "
 344                         "SUP monitorCounter "
 345                         "NO-USER-MODIFICATION "
 346                         "USAGE directoryOperation )", SLAP_AT_FINAL|SLAP_AT_HIDE,
 347                         offsetof(struct monitorinfo, mi_ad_monitorConnectionNumber) },
 348                 { "monitorConnectionAuthzDN", "( 1.3.6.1.4.1.4203.666.1.20 "
 349                         "NAME 'monitorConnectionAuthzDN' "
 350                         "DESC 'monitor connection authorization DN' "
 351                         /* "SUP distinguishedName " */
 352                         "EQUALITY distinguishedNameMatch "
 353                         "SYNTAX 1.3.6.1.4.1.1466.115.121.1.12 "
 354                         "NO-USER-MODIFICATION "
 355                         "USAGE directoryOperation )", SLAP_AT_FINAL|SLAP_AT_HIDE,
 356                         offsetof(struct monitorinfo, mi_ad_monitorConnectionAuthzDN) },
 357                 { "monitorConnectionLocalAddress", "( 1.3.6.1.4.1.4203.666.1.21 "
 358                         "NAME 'monitorConnectionLocalAddress' "
 359                         "DESC 'monitor connection local address' "
 360                         "SUP monitoredInfo "
 361                         "NO-USER-MODIFICATION "
 362                         "USAGE directoryOperation )", SLAP_AT_FINAL|SLAP_AT_HIDE,
 363                         offsetof(struct monitorinfo, mi_ad_monitorConnectionLocalAddress) },
 364                 { "monitorConnectionPeerAddress", "( 1.3.6.1.4.1.4203.666.1.22 "
 365                         "NAME 'monitorConnectionPeerAddress' "
 366                         "DESC 'monitor connection peer address' "
 367                         "SUP monitoredInfo "
 368                         "NO-USER-MODIFICATION "
 369                         "USAGE directoryOperation )", SLAP_AT_FINAL|SLAP_AT_HIDE,
 370                         offsetof(struct monitorinfo, mi_ad_monitorConnectionPeerAddress) },
 371                 { "monitorTimestamp", "( 1.3.6.1.4.1.4203.666.1.24 "
 372                         "NAME 'monitorTimestamp' "
 373                         "DESC 'monitor timestamp' "
 374                         "EQUALITY generalizedTimeMatch "
 375                         "ORDERING generalizedTimeOrderingMatch "
 376                         "SYNTAX 1.3.6.1.4.1.1466.115.121.1.24 "
 377                         "SINGLE-VALUE "
 378                         "NO-USER-MODIFICATION "
 379                         "USAGE directoryOperation )", SLAP_AT_FINAL|SLAP_AT_HIDE,
 380                         offsetof(struct monitorinfo, mi_ad_monitorTimestamp) },
 381                 { "monitorOverlay", "( 1.3.6.1.4.1.4203.666.1.27 "
 382                         "NAME 'monitorOverlay' "
 383                         "DESC 'name of overlays defined for a give database' "
 384                         "SUP monitoredInfo "
 385                         "NO-USER-MODIFICATION "
 386                         "USAGE directoryOperation )", SLAP_AT_HIDE,
 387                         offsetof(struct monitorinfo, mi_ad_monitorOverlay) },
 388                 { "readOnly", "( 1.3.6.1.4.1.4203.666.1.31 "
 389                         "NAME 'readOnly' "
 390                         "DESC 'read/write status of a given database' "
 391                         "EQUALITY booleanMatch "
 392                         "SYNTAX 1.3.6.1.4.1.1466.115.121.1.7 "
 393                         "SINGLE-VALUE "
 394                         "USAGE directoryOperation )", SLAP_AT_HIDE,
 395                         offsetof(struct monitorinfo, mi_ad_readOnly) },
 396                 { "restrictedOperation", "( 1.3.6.1.4.1.4203.666.1.32 "
 397                         "NAME 'restrictedOperation' "
 398                         "DESC 'name of restricted operation for a given database' "
 399                         "SUP managedInfo )", SLAP_AT_HIDE,
 400                         offsetof(struct monitorinfo, mi_ad_restrictedOperation ) },
 401 #ifdef INTEGRATE_CORE_SCHEMA
 402                 { NULL, NULL, 0, -1 },  /* description */
 403                 { NULL, NULL, 0, -1 },  /* seeAlso */
 404                 { NULL, NULL, 0, -1 },  /* l */
 405                 { NULL, NULL, 0, -1 },  /* labeledURI */
 406 #endif /* INTEGRATE_CORE_SCHEMA */
 407                 { NULL, NULL, 0, -1 }
 408         }, mat_core[] = {
 409                 { "description", "( 2.5.4.13 "
 410                         "NAME 'description' "
 411                         "DESC 'RFC2256: descriptive information' "
 412                         "EQUALITY caseIgnoreMatch "
 413                         "SUBSTR caseIgnoreSubstringsMatch "
 414                         "SYNTAX 1.3.6.1.4.1.1466.115.121.1.15{1024} )", 0,
 415                         offsetof(struct monitorinfo, mi_ad_description) },
 416                 { "seeAlso", "( 2.5.4.34 "
 417                         "NAME 'seeAlso' "
 418                         "DESC 'RFC2256: DN of related object' "
 419                         "SUP distinguishedName )", 0,
 420                         offsetof(struct monitorinfo, mi_ad_seeAlso) },
 421                 { "l", "( 2.5.4.7 "
 422                         "NAME ( 'l' 'localityName' ) "
 423                         "DESC 'RFC2256: locality which this object resides in' "
 424                         "SUP name )", 0,
 425                         offsetof(struct monitorinfo, mi_ad_l) },
 426                 { "labeledURI", "( 1.3.6.1.4.1.250.1.57 "
 427                         "NAME 'labeledURI' "
 428                         "DESC 'RFC2079: Uniform Resource Identifier with optional label' "
 429                         "EQUALITY caseExactMatch "
 430                         "SYNTAX 1.3.6.1.4.1.1466.115.121.1.15 )", 0,
 431                         offsetof(struct monitorinfo, mi_ad_labeledURI) },
 432                 { NULL, NULL, 0, -1 }
 433         };
 434
 435         /*
 436          * database monitor can be defined once only
 437          */
 438         if ( be_monitor ) {
 439 #ifdef NEW_LOGGING
 440                 LDAP_LOG( OPERATION, CRIT,
 441                         "only one monitor backend is allowed\n", 0, 0, 0);
 442 #else
 443                 Debug( LDAP_DEBUG_ANY,
 444                         "only one monitor backend is allowed\n", 0, 0, 0 );
 445 #endif
 446                 return( -1 );
 447         }
 448         be_monitor = be;
 449
 450         /* indicate system schema supported */
 451         SLAP_BFLAGS(be) |= SLAP_BFLAG_MONITOR;
 452
 453         dn.bv_val = SLAPD_MONITOR_DN;
 454         dn.bv_len = sizeof( SLAPD_MONITOR_DN ) - 1;
 455
 456         rc = dnNormalize( 0, NULL, NULL, &dn, &ndn, NULL );
 457         if( rc != LDAP_SUCCESS ) {
 458 #ifdef NEW_LOGGING
 459                 LDAP_LOG( OPERATION, CRIT,
 460                         "unable to normalize monitor DN \"%s\"\n",
 461                         SLAPD_MONITOR_DN, 0, 0 );
 462 #else
 463                 Debug( LDAP_DEBUG_ANY,
 464                         "unable to normalize monitor DN \"%s\"\n",
 465                         SLAPD_MONITOR_DN, 0, 0 );
 466 #endif
 467                 return -1;
 468         }
 469
 470         ber_dupbv( &bv, &dn );
 471         ber_bvarray_add( &be->be_suffix, &bv );
 472         ber_bvarray_add( &be->be_nsuffix, &ndn );
 473
 474         mi = ( struct monitorinfo * )ch_calloc( sizeof( struct monitorinfo ), 1 );
 475         if ( mi == NULL ) {
 476 #ifdef NEW_LOGGING
 477                 LDAP_LOG( OPERATION, CRIT,
 478                         "unable to initialize monitor backend\n", 0, 0, 0 );
 479 #else
 480                 Debug( LDAP_DEBUG_ANY,
 481                         "unable to initialize monitor backend\n", 0, 0, 0 );
 482 #endif
 483                 return -1;
 484         }
 485
 486         memset( mi, 0, sizeof( struct monitorinfo ) );
 487
 488         ldap_pvt_thread_mutex_init( &mi->mi_cache_mutex );
 489
 490         be->be_private = mi;
 491
 492 #ifdef INTEGRATE_CORE_SCHEMA
 493         /* prepare for schema integration */
 494         for ( k = 0; mat[k].name != NULL; k++ );
 495 #endif /* INTEGRATE_CORE_SCHEMA */
 496
 497         for ( i = 0; mat_core[i].name != NULL; i++ ) {
 498                 AttributeDescription    **ad;
 499                 const char              *text;
 500
 501                 ad = ((AttributeDescription **)&(((char *)mi)[mat_core[i].offset]));
 502                 ad[0] = NULL;
 503
 504                 switch (slap_str2ad( mat_core[i].name, ad, &text ) ) {
 505                 case LDAP_SUCCESS:
 506                         break;
 507
 508 #ifdef INTEGRATE_CORE_SCHEMA
 509                 case LDAP_UNDEFINED_TYPE:
 510                         mat[k] = mat_core[i];
 511                         k++;
 512                         break;
 513 #endif /* INTEGRATE_CORE_SCHEMA */
 514
 515                 default:
 516 #ifdef NEW_LOGGING
 517                         LDAP_LOG( OPERATION, CRIT,
 518                                 "monitor_back_db_init: %s: %s\n",
 519                                 mat_core[i].name, text, 0 );
 520 #else
 521                         Debug( LDAP_DEBUG_ANY,
 522                                 "monitor_back_db_init: %s: %s\n",
 523                                 mat_core[i].name, text, 0 );
 524 #endif
 525                         return( -1 );
 526                 }
 527         }
 528
 529         /* schema integration */
 530         for ( i = 0; mat[i].name; i++ ) {
 531                 LDAPAttributeType       *at;
 532                 int                     code;
 533                 const char              *err;
 534                 AttributeDescription    **ad;
 535
 536                 at = ldap_str2attributetype( mat[i].schema, &code,
 537                         &err, LDAP_SCHEMA_ALLOW_ALL );
 538                 if ( !at ) {
 539 #ifdef NEW_LOGGING
 540                         LDAP_LOG( OPERATION, CRIT, "monitor_back_db_init: "
 541                                 "in AttributeType '%s' %s before %s\n",
 542                                 mat[i].name, ldap_scherr2str(code), err );
 543 #else
 544                         Debug( LDAP_DEBUG_ANY, "monitor_back_db_init: "
 545                                 "in AttributeType '%s' %s before %s\n",
 546                                 mat[i].name, ldap_scherr2str(code), err );
 547 #endif
 548                         return -1;
 549                 }
 550
 551                 if ( at->at_oid == NULL ) {
 552 #ifdef NEW_LOGGING
 553                         LDAP_LOG( OPERATION, CRIT, "monitor_back_db_init: "
 554                                 "null OID for attributeType '%s'\n",
 555                                 mat[i].name, 0, 0 );
 556 #else
 557                         Debug( LDAP_DEBUG_ANY, "monitor_back_db_init: "
 558                                 "null OID for attributeType '%s'\n",
 559                                 mat[i].name, 0, 0 );
 560 #endif
 561                         return -1;
 562                 }
 563
 564                 code = at_add(at, &err);
 565                 if ( code ) {
 566 #ifdef NEW_LOGGING
 567                         LDAP_LOG( OPERATION, CRIT, "monitor_back_db_init: "
 568                                 "%s in attributeType '%s'\n",
 569                                 scherr2str(code), mat[i].name, 0 );
 570 #else
 571                         Debug( LDAP_DEBUG_ANY, "monitor_back_db_init: "
 572                                 "%s in attributeType '%s'\n",
 573                                 scherr2str(code), mat[i].name, 0 );
 574 #endif
 575                         return -1;
 576                 }
 577                 ldap_memfree(at);
 578
 579                 ad = ((AttributeDescription **)&(((char *)mi)[mat[i].offset]));
 580                 ad[0] = NULL;
 581                 if ( slap_str2ad( mat[i].name, ad, &text ) ) {
 582 #ifdef NEW_LOGGING
 583                         LDAP_LOG( OPERATION, CRIT,
 584                                 "monitor_back_db_init: %s\n", text, 0, 0 );
 585 #else
 586                         Debug( LDAP_DEBUG_ANY,
 587                                 "monitor_back_db_init: %s\n", text, 0, 0 );
 588 #endif
 589                         return -1;
 590                 }
 591
 592                 (*ad)->ad_type->sat_flags |= mat[i].flags;
 593         }
 594
 595         for ( i = 0; moc[i].name; i++ ) {
 596                 LDAPObjectClass         *oc;
 597                 int                     code;
 598                 const char              *err;
 599                 ObjectClass             *Oc;
 600
 601                 oc = ldap_str2objectclass(moc[i].schema, &code, &err,
 602                                 LDAP_SCHEMA_ALLOW_ALL );
 603                 if ( !oc ) {
 604 #ifdef NEW_LOGGING
 605                         LDAP_LOG( OPERATION, CRIT,
 606                                 "unable to parse monitor objectclass '%s': "
 607                                 "%s before %s\n" , moc[i].name,
 608                                 ldap_scherr2str(code), err );
 609 #else
 610                         Debug( LDAP_DEBUG_ANY,
 611                                 "unable to parse monitor objectclass '%s': "
 612                                 "%s before %s\n" , moc[i].name,
 613                                 ldap_scherr2str(code), err );
 614 #endif
 615                         return -1;
 616                 }
 617
 618                 if ( oc->oc_oid == NULL ) {
 619 #ifdef NEW_LOGGING
 620                         LDAP_LOG( OPERATION, CRIT,
 621                                 "objectclass '%s' has no OID\n" ,
 622                                 moc[i].name, 0, 0 );
 623 #else
 624                         Debug( LDAP_DEBUG_ANY,
 625                                 "objectclass '%s' has no OID\n" ,
 626                                 moc[i].name, 0, 0 );
 627 #endif
 628                         return -1;
 629                 }
 630
 631                 code = oc_add(oc, 0, &err);
 632                 if ( code ) {
 633 #ifdef NEW_LOGGING
 634                         LDAP_LOG( OPERATION, CRIT,
 635                                 "objectclass '%s': %s \"%s\"\n" ,
 636                                 moc[i].name, scherr2str(code), err );
 637 #else
 638                         Debug( LDAP_DEBUG_ANY,
 639                                 "objectclass '%s': %s \"%s\"\n" ,
 640                                 moc[i].name, scherr2str(code), err );
 641 #endif
 642                         return -1;
 643                 }
 644
 645                 ldap_memfree(oc);
 646
 647                 Oc = oc_find( moc[i].name );
 648                 if ( Oc == NULL ) {
 649 #ifdef NEW_LOGGING
 650                         LDAP_LOG( OPERATION, CRIT, "monitor_back_db_init: "
 651                                         "unable to find objectClass %s "
 652                                         "(just added)\n", moc[i].name, 0, 0 );
 653 #else
 654                         Debug( LDAP_DEBUG_ANY, "monitor_back_db_init: "
 655                                         "unable to find objectClass %s "
 656                                         "(just added)\n", moc[i].name, 0, 0 );
 657 #endif
 658                         return -1;
 659                 }
 660
 661                 Oc->soc_flags |= moc[i].flags;
 662
 663                 ((ObjectClass **)&(((char *)mi)[moc[i].offset]))[0] = Oc;
 664         }
 665
 666         return 0;
 667 }
 668
 669 int
 670 monitor_back_db_open(
 671         BackendDB       *be
 672 )
 673 {
 674         struct monitorinfo      *mi = (struct monitorinfo *)be->be_private;
 675         struct monitorsubsys    *ms;
 676         Entry                   *e, *e_tmp;
 677         struct monitorentrypriv *mp;
 678         int                     i;
 679         char                    buf[ BACKMONITOR_BUFSIZE ], *end_of_line;
 680         struct berval           bv;
 681         struct tm               *tms;
 682 #ifdef HAVE_GMTIME_R
 683         struct tm               tm_buf;
 684 #endif
 685         static char             tmbuf[ LDAP_LUTIL_GENTIME_BUFSIZE ];
 686
 687         /*
 688          * Start
 689          */
 690 #ifndef HAVE_GMTIME_R
 691         ldap_pvt_thread_mutex_lock( &gmtime_mutex );
 692 #endif
 693 #ifdef HACK_LOCAL_TIME
 694 # ifdef HAVE_LOCALTIME_R
 695         tms = localtime_r( &starttime, &tm_buf );
 696 # else
 697         tms = localtime( &starttime );
 698 # endif /* HAVE_LOCALTIME_R */
 699         lutil_localtime( tmbuf, sizeof(tmbuf), tms, -timezone );
 700 #else /* !HACK_LOCAL_TIME */
 701 # ifdef HAVE_GMTIME_R
 702         tms = gmtime_r( &starttime, &tm_buf );
 703 # else
 704         tms = gmtime( &starttime );
 705 # endif /* HAVE_GMTIME_R */
 706         lutil_gentime( tmbuf, sizeof(tmbuf), tms );
 707 #endif /* !HACK_LOCAL_TIME */
 708 #ifndef HAVE_GMTIME_R
 709         ldap_pvt_thread_mutex_unlock( &gmtime_mutex );
 710 #endif
 711
 712         mi->mi_startTime.bv_val = tmbuf;
 713         mi->mi_startTime.bv_len = strlen( tmbuf );
 714
 715         if ( BER_BVISEMPTY( &be->be_rootdn ) ) {
 716                 BER_BVSTR( &mi->mi_creatorsName, SLAPD_ANONYMOUS );
 717         } else {
 718                 mi->mi_creatorsName = be->be_rootdn;
 719         }
 720
 721         /*
 722          * Create all the subsystem specific entries
 723          */
 724         e_tmp = NULL;
 725         for ( i = 0; monitor_subsys[ i ].mss_name != NULL; i++ ) {
 726                 int             len = strlen( monitor_subsys[ i ].mss_name );
 727                 struct berval   dn;
 728                 int             rc;
 729
 730                 dn.bv_len = len + sizeof( "cn=" ) - 1;
 731                 dn.bv_val = ch_calloc( sizeof( char ), dn.bv_len + 1 );
 732                 strcpy( dn.bv_val, "cn=" );
 733                 strcat( dn.bv_val, monitor_subsys[ i ].mss_name );
 734                 rc = dnPretty( NULL, &dn, &monitor_subsys[ i ].mss_rdn, NULL );
 735                 free( dn.bv_val );
 736                 if ( rc != LDAP_SUCCESS ) {
 737 #ifdef NEW_LOGGING
 738                         LDAP_LOG( OPERATION, CRIT,
 739                                 "monitor RDN \"%s\" is invalid\n",
 740                                 dn.bv_val, 0, 0 );
 741 #else
 742                         Debug( LDAP_DEBUG_ANY,
 743                                 "monitor RDN \"%s\" is invalid\n",
 744                                 dn.bv_val, 0, 0 );
 745 #endif
 746                         return( -1 );
 747                 }
 748
 749                 dn.bv_len += sizeof( SLAPD_MONITOR_DN ); /* 1 for the , */
 750                 dn.bv_val = ch_malloc( dn.bv_len + 1 );
 751                 strcpy( dn.bv_val , monitor_subsys[ i ].mss_rdn.bv_val );
 752                 strcat( dn.bv_val, "," SLAPD_MONITOR_DN );
 753                 rc = dnPrettyNormal( NULL, &dn, &monitor_subsys[ i ].mss_dn,
 754                         &monitor_subsys[ i ].mss_ndn, NULL );
 755                 free( dn.bv_val );
 756                 if ( rc != LDAP_SUCCESS ) {
 757 #ifdef NEW_LOGGING
 758                         LDAP_LOG( OPERATION, CRIT,
 759                                 "monitor DN \"%s\" is invalid\n",
 760                                 dn.bv_val, 0, 0 );
 761 #else
 762                         Debug( LDAP_DEBUG_ANY,
 763                                 "monitor DN \"%s\" is invalid\n",
 764                                 dn.bv_val, 0, 0 );
 765 #endif
 766                         return( -1 );
 767                 }
 768
 769                 snprintf( buf, sizeof( buf ),
 770                                 "dn: %s\n"
 771                                 "objectClass: %s\n"
 772                                 "structuralObjectClass: %s\n"
 773                                 "cn: %s\n"
 774                                 "creatorsName: %s\n"
 775                                 "modifiersName: %s\n"
 776                                 "createTimestamp: %s\n"
 777                                 "modifyTimestamp: %s\n",
 778                                 monitor_subsys[ i ].mss_dn.bv_val,
 779                                 mi->mi_oc_monitorContainer->soc_cname.bv_val,
 780                                 mi->mi_oc_monitorContainer->soc_cname.bv_val,
 781                                 monitor_subsys[ i ].mss_name,
 782                                 mi->mi_creatorsName.bv_val,
 783                                 mi->mi_creatorsName.bv_val,
 784                                 mi->mi_startTime.bv_val,
 785                                 mi->mi_startTime.bv_val );
 786
 787                 e = str2entry( buf );
 788
 789                 if ( e == NULL) {
 790 #ifdef NEW_LOGGING
 791                         LDAP_LOG( OPERATION, CRIT,
 792                                 "unable to create '%s' entry\n",
 793                                 monitor_subsys[ i ].mss_dn.bv_val, 0, 0 );
 794 #else
 795                         Debug( LDAP_DEBUG_ANY,
 796                                 "unable to create '%s' entry\n",
 797                                 monitor_subsys[ i ].mss_dn.bv_val, 0, 0 );
 798 #endif
 799                         return( -1 );
 800                 }
 801
 802                 mp = ( struct monitorentrypriv * )ch_calloc( sizeof( struct monitorentrypriv ), 1 );
 803                 e->e_private = ( void * )mp;
 804                 mp->mp_info = &monitor_subsys[ i ];
 805                 mp->mp_children = NULL;
 806                 mp->mp_next = e_tmp;
 807                 mp->mp_flags = monitor_subsys[ i ].mss_flags;
 808
 809                 if ( monitor_cache_add( mi, e ) ) {
 810 #ifdef NEW_LOGGING
 811                         LDAP_LOG( OPERATION, CRIT,
 812                                 "unable to add entry '%s' to cache\n",
 813                                 monitor_subsys[ i ].mss_dn.bv_val, 0, 0 );
 814 #else
 815                         Debug( LDAP_DEBUG_ANY,
 816                                 "unable to add entry '%s' to cache\n",
 817                                 monitor_subsys[ i ].mss_dn.bv_val, 0, 0 );
 818 #endif
 819                         return -1;
 820                 }
 821
 822                 e_tmp = e;
 823         }
 824
 825         /*
 826          * creates the "cn=Monitor" entry
 827          */
 828         snprintf( buf, sizeof( buf ),
 829                 "dn: %s\n"
 830                 "objectClass: %s\n"
 831                 "structuralObjectClass: %s\n"
 832                 "cn: Monitor\n"
 833                 "%s: This subtree contains monitoring/managing objects.\n"
 834                 "%s: This object contains information about this server.\n"
 835 #if 0
 836                 "%s: createTimestamp reflects the time this server instance was created.\n"
 837                 "%s: modifyTimestamp reflects the time this server instance was last accessed.\n"
 838 #endif
 839                 "creatorsName: %s\n"
 840                 "modifiersName: %s\n"
 841                 "createTimestamp: %s\n"
 842                 "modifyTimestamp: %s\n",
 843                 SLAPD_MONITOR_DN,
 844                 mi->mi_oc_monitorServer->soc_cname.bv_val,
 845                 mi->mi_oc_monitorServer->soc_cname.bv_val,
 846                 mi->mi_ad_description->ad_cname.bv_val,
 847                 mi->mi_ad_description->ad_cname.bv_val,
 848 #if 0
 849                 mi->mi_ad_description->ad_cname.bv_val,
 850                 mi->mi_ad_description->ad_cname.bv_val,
 851 #endif
 852                 mi->mi_creatorsName.bv_val,
 853                 mi->mi_creatorsName.bv_val,
 854                 mi->mi_startTime.bv_val,
 855                 mi->mi_startTime.bv_val );
 856
 857         e = str2entry( buf );
 858         if ( e == NULL) {
 859 #ifdef NEW_LOGGING
 860                 LDAP_LOG( OPERATION, CRIT,
 861                         "unable to create '%s' entry\n",
 862                         SLAPD_MONITOR_DN, 0, 0 );
 863 #else
 864                 Debug( LDAP_DEBUG_ANY,
 865                         "unable to create '%s' entry\n",
 866                         SLAPD_MONITOR_DN, 0, 0 );
 867 #endif
 868                 return( -1 );
 869         }
 870
 871         bv.bv_val = (char *) Versionstr;
 872         end_of_line = strchr( Versionstr, '\n' );
 873         if ( end_of_line ) {
 874                 bv.bv_len = end_of_line - Versionstr;
 875         } else {
 876                 bv.bv_len = strlen( Versionstr );
 877         }
 878
 879         if ( attr_merge_normalize_one( e, mi->mi_ad_monitoredInfo,
 880                                 &bv, NULL ) ) {
 881 #ifdef NEW_LOGGING
 882                 LDAP_LOG( OPERATION, CRIT,
 883                         "unable to add monitoredInfo to '%s' entry\n",
 884                         SLAPD_MONITOR_DN, 0, 0 );
 885 #else
 886                 Debug( LDAP_DEBUG_ANY,
 887                         "unable to add monitoredInfo to '%s' entry\n",
 888                         SLAPD_MONITOR_DN, 0, 0 );
 889 #endif
 890                 return( -1 );
 891         }
 892
 893         if ( mi->mi_l.bv_len ) {
 894                 if ( attr_merge_normalize_one( e, mi->mi_ad_l, &mi->mi_l, NULL ) ) {
 895 #ifdef NEW_LOGGING
 896                         LDAP_LOG( OPERATION, CRIT,
 897                                 "unable to add locality to '%s' entry\n",
 898                                 SLAPD_MONITOR_DN, 0, 0 );
 899 #else
 900                         Debug( LDAP_DEBUG_ANY,
 901                                 "unable to add locality to '%s' entry\n",
 902                                 SLAPD_MONITOR_DN, 0, 0 );
 903 #endif
 904                         return( -1 );
 905                 }
 906         }
 907
 908         mp = ( struct monitorentrypriv * )ch_calloc( sizeof( struct monitorentrypriv ), 1 );
 909         e->e_private = ( void * )mp;
 910
 911         mp->mp_info = NULL;
 912         mp->mp_children = e_tmp;
 913         mp->mp_next = NULL;
 914
 915         if ( monitor_cache_add( mi, e ) ) {
 916 #ifdef NEW_LOGGING
 917                 LDAP_LOG( OPERATION, CRIT,
 918                         "unable to add entry '%s' to cache\n",
 919                         SLAPD_MONITOR_DN, 0, 0 );
 920 #else
 921                 Debug( LDAP_DEBUG_ANY,
 922                         "unable to add entry '%s' to cache\n",
 923                         SLAPD_MONITOR_DN, 0, 0 );
 924 #endif
 925                 return -1;
 926         }
 927
 928         be->be_private = mi;
 929
 930         assert( be );
 931
 932         /*
 933          * opens the monitor backend
 934          */
 935         for ( ms = monitor_subsys; ms->mss_name != NULL; ms++ ) {
 936                 if ( ms->mss_init && ( *ms->mss_init )( be ) ) {
 937                         return( -1 );
 938                 }
 939         }
 940
 941         return( 0 );
 942 }
 943
 944 int
 945 monitor_back_config(
 946         BackendInfo     *bi,
 947         const char      *fname,
 948         int             lineno,
 949         int             argc,
 950         char            **argv
 951 )
 952 {
 953         /*
 954          * eventually, will hold backend specific configuration parameters
 955          */
 956         return SLAP_CONF_UNKNOWN;
 957 }
 958
 959 int
 960 monitor_back_db_config(
 961         Backend     *be,
 962         const char  *fname,
 963         int         lineno,
 964         int         argc,
 965         char        **argv
 966 )
 967 {
 968         struct monitorinfo *mi = (struct monitorinfo *)be->be_private;
 969
 970         /*
 971          * eventually, will hold database specific configuration parameters
 972          */
 973         if ( strcasecmp( argv[ 0 ], "l" ) == 0 ) {
 974                 if ( argc != 2 ) {
 975                         return 1;
 976                 }
 977
 978                 ber_str2bv( argv[ 1 ], 0, 1, &mi->mi_l );
 979
 980         } else {
 981                 return SLAP_CONF_UNKNOWN;
 982         }
 983
 984         return( 0 );
 985 }
 986
 987 int
 988 monitor_back_db_destroy(
 989         BackendDB       *be
 990 )
 991 {
 992         /*
 993          * FIXME: destroys all the data
 994          */
 995         return 0;
 996 }
 997