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

   1 /*
   2  * Copyright (c) 1995 Regents of the University of Michigan.
   3  * All rights reserved.
   4  *
   5  * Redistribution and use in source and binary forms are permitted
   6  * provided that this notice is preserved and that due credit is given
   7  * to the University of Michigan at Ann Arbor. The name of the University
   8  * may not be used to endorse or promote products derived from this
   9  * software without specific prior written permission. This software
  10  * is provided ``as is'' without express or implied warranty.
  11  */
  12
  13 #include "portable.h"
  14
  15 #include <stdio.h>
  16
  17 #include <ac/socket.h>
  18 #include <ac/string.h>
  19 #include <ac/time.h>
  20
  21 #include "ldap_defaults.h"
  22 #include "slap.h"
  23
  24 char *supportedControls[] = {
  25         NULL
  26 };
  27
  28 char *supportedExtensions[] = {
  29         NULL
  30 };
  31
  32 #if defined( SLAPD_MONITOR_DN )
  33
  34 void
  35 monitor_info( Connection *conn, Operation *op )
  36 {
  37         Entry           *e;
  38         char            buf[BUFSIZ];
  39         struct berval   val;
  40         struct berval   *vals[2];
  41         int    nconns, nwritewaiters, nreadwaiters;
  42         struct tm       *ltm;
  43         char            *p;
  44     char       buf2[22];
  45     char       buf3[22];
  46         Connection *c;
  47         int                     connindex;
  48     time_t              currenttime;
  49
  50         vals[0] = &val;
  51         vals[1] = NULL;
  52
  53         e = (Entry *) ch_calloc( 1, sizeof(Entry) );
  54         /* initialize reader/writer lock */
  55         e->e_attrs = NULL;
  56         e->e_dn = ch_strdup( SLAPD_MONITOR_DN );
  57         e->e_ndn = dn_normalize_case( ch_strdup(SLAPD_MONITOR_DN) );
  58         e->e_private = NULL;
  59
  60         val.bv_val = (char *) Versionstr;
  61         if (( p = strchr( Versionstr, '\n' )) == NULL ) {
  62                 val.bv_len = strlen( Versionstr );
  63         } else {
  64                 val.bv_len = p - Versionstr;
  65         }
  66         attr_merge( e, "version", vals );
  67
  68         ldap_pvt_thread_mutex_lock( &active_threads_mutex );
  69         sprintf( buf, "%d", active_threads );
  70         ldap_pvt_thread_mutex_unlock( &active_threads_mutex );
  71         val.bv_val = buf;
  72         val.bv_len = strlen( buf );
  73         attr_merge( e, "threads", vals );
  74
  75         nconns = 0;
  76         nwritewaiters = 0;
  77         nreadwaiters = 0;
  78
  79         /* loop through the connections */
  80         for ( c = connection_first( &connindex );
  81                 c != NULL;
  82                 c = connection_next( c, &connindex ))
  83         {
  84                 nconns++;
  85                 if ( c->c_writewaiter ) {
  86                         nwritewaiters++;
  87                 }
  88                 if ( c->c_currentber != NULL ) {
  89                         nreadwaiters++;
  90                 }
  91
  92                 ldap_pvt_thread_mutex_lock( &gmtime_mutex );
  93 #ifndef LDAP_LOCALTIME
  94                 ltm = gmtime( &c->c_starttime );
  95                 strftime( buf2, sizeof(buf2), "%Y%m%d%H%M%SZ", ltm );
  96
  97                 ltm = gmtime( &c->c_activitytime );
  98                 strftime( buf3, sizeof(buf2), "%Y%m%d%H%M%SZ", ltm );
  99 #else
 100                 ltm = localtime( &c->.c_starttime );
 101                 strftime( buf2, sizeof(buf2), "%y%m%d%H%M%SZ", ltm );
 102
 103                 ltm = localtime( &c->c_activitytime );
 104                 strftime( buf3, sizeof(buf2), "%y%m%d%H%M%SZ", ltm );
 105 #endif
 106
 107                 ldap_pvt_thread_mutex_unlock( &gmtime_mutex );
 108
 109                 sprintf( buf,
 110                         "%ld : %ld "
 111                         ": %ld/%ld/%ld/%ld "
 112                         ": %ld/%ld/%ld "
 113                         ": %s%s%s%s "
 114                         ": %s : %s : %s "
 115                         ": %s : %s",
 116
 117                         c->c_connid,
 118                         (long) c->c_protocol,
 119
 120                         c->c_n_ops_received, c->c_n_ops_executing,
 121                         c->c_n_ops_pending, c->c_n_ops_completed,
 122
 123                         /* add low-level counters here */
 124                         c->c_n_get, c->c_n_read, c->c_n_write,
 125
 126                     c->c_currentber ? "r" : "",
 127                     c->c_writewaiter ? "w" : "",
 128                     c->c_ops != NULL ? "x" : "",
 129                     c->c_pending_ops != NULL ? "p" : "",
 130
 131                     c->c_cdn ? c->c_cdn : "<anonymous>",
 132                     c->c_client_addr ? c->c_client_addr : "unknown",
 133                     c->c_client_name ? c->c_client_name : "unknown",
 134
 135                     buf2,
 136                         buf3
 137                 );
 138
 139                 val.bv_val = buf;
 140                 val.bv_len = strlen( buf );
 141                 attr_merge( e, "connection", vals );
 142         }
 143         connection_done(c);
 144
 145         sprintf( buf, "%d", nconns );
 146         val.bv_val = buf;
 147         val.bv_len = strlen( buf );
 148         attr_merge( e, "currentconnections", vals );
 149
 150         sprintf( buf, "%ld", connections_nextid() );
 151         val.bv_val = buf;
 152         val.bv_len = strlen( buf );
 153         attr_merge( e, "totalconnections", vals );
 154
 155         sprintf( buf, "%ld", (long) dtblsize );
 156         val.bv_val = buf;
 157         val.bv_len = strlen( buf );
 158         attr_merge( e, "dtablesize", vals );
 159
 160         sprintf( buf, "%d", nwritewaiters );
 161         val.bv_val = buf;
 162         val.bv_len = strlen( buf );
 163         attr_merge( e, "writewaiters", vals );
 164
 165         sprintf( buf, "%d", nreadwaiters );
 166         val.bv_val = buf;
 167         val.bv_len = strlen( buf );
 168         attr_merge( e, "readwaiters", vals );
 169
 170         ldap_pvt_thread_mutex_lock(&num_ops_mutex);
 171         sprintf( buf, "%ld", num_ops_initiated );
 172         ldap_pvt_thread_mutex_unlock(&num_ops_mutex);
 173         val.bv_val = buf;
 174         val.bv_len = strlen( buf );
 175         attr_merge( e, "opsinitiated", vals );
 176
 177         ldap_pvt_thread_mutex_lock(&num_ops_mutex);
 178         sprintf( buf, "%ld", num_ops_completed );
 179         ldap_pvt_thread_mutex_unlock(&num_ops_mutex);
 180         val.bv_val = buf;
 181         val.bv_len = strlen( buf );
 182         attr_merge( e, "opscompleted", vals );
 183
 184         ldap_pvt_thread_mutex_lock(&num_sent_mutex);
 185         sprintf( buf, "%ld", num_entries_sent );
 186         ldap_pvt_thread_mutex_unlock(&num_sent_mutex);
 187         val.bv_val = buf;
 188         val.bv_len = strlen( buf );
 189         attr_merge( e, "entriessent", vals );
 190
 191         ldap_pvt_thread_mutex_lock(&num_sent_mutex);
 192         sprintf( buf, "%ld", num_bytes_sent );
 193         ldap_pvt_thread_mutex_unlock(&num_sent_mutex);
 194         val.bv_val = buf;
 195         val.bv_len = strlen( buf );
 196         attr_merge( e, "bytessent", vals );
 197
 198         currenttime = slap_get_time();
 199
 200         ldap_pvt_thread_mutex_lock( &gmtime_mutex );
 201 #ifndef LDAP_LOCALTIME
 202         ltm = gmtime( &currenttime );
 203         strftime( buf, sizeof(buf), "%Y%m%d%H%M%SZ", ltm );
 204 #else
 205         ltm = localtime( &currenttime );
 206         strftime( buf, sizeof(buf), "%y%m%d%H%M%SZ", ltm );
 207 #endif
 208         val.bv_val = buf;
 209         val.bv_len = strlen( buf );
 210         attr_merge( e, "currenttime", vals );
 211
 212 #ifndef LDAP_LOCALTIME
 213         ltm = gmtime( &starttime );
 214         strftime( buf, sizeof(buf), "%Y%m%d%H%M%SZ", ltm );
 215 #else
 216         ltm = localtime( &starttime );
 217         strftime( buf, sizeof(buf), "%y%m%d%H%M%SZ", ltm );
 218 #endif
 219         ldap_pvt_thread_mutex_unlock( &gmtime_mutex );
 220
 221         val.bv_val = buf;
 222         val.bv_len = strlen( buf );
 223         attr_merge( e, "starttime", vals );
 224
 225         sprintf( buf, "%d", nbackends );
 226         val.bv_val = buf;
 227         val.bv_len = strlen( buf );
 228         attr_merge( e, "nbackends", vals );
 229
 230 #ifdef HAVE_THREAD_CONCURRENCY
 231         sprintf( buf, "%d", ldap_pvt_thread_get_concurrency() );
 232         val.bv_val = buf;
 233         val.bv_len = strlen( buf );
 234         attr_merge( e, "concurrency", vals );
 235 #endif
 236
 237         send_search_entry( &backends[0], conn, op, e, NULL, 0 );
 238         send_ldap_search_result( conn, op, LDAP_SUCCESS, NULL, NULL, 1 );
 239
 240         entry_free( e );
 241 }
 242
 243 #endif /* slapd_monitor_dn */