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

   1 /* $OpenLDAP$ */
   2 #include "portable.h"
   3
   4 #include <stdio.h>
   5
   6 #include <ac/stdlib.h>
   7 #include <ac/string.h>
   8 #include <ac/unistd.h>
   9
  10 #include <ldap.h>
  11 #include <ldbm.h>
  12
  13 #define CACHE_SIZE      1000000
  14 #define MODE            0600
  15 #define DB_FLAGS        (LDBM_WRCREAT|LDBM_NEWDB)
  16 #define SUBLEN          3
  17
  18 extern char     *first_word(char *);
  19 extern char     *next_word(char *);
  20 extern char     *word_dup(char *);
  21 extern char     *phonetic(char *);
  22
  23 extern int ldap_debug;
  24
  25 int slap_debug;
  26 int     ldap_syslog;
  27 int     ldap_syslog_level;
  28
  29 static void     add(LDBM ldbm, char *s, int *count, int *size, int freeit);
  30
  31 int
  32 main( int argc, char **argv )
  33 {
  34         LDAP                    *ld;
  35         LDAPMessage             *res, *e;
  36         int                             i, j, k, count, len, nentries;
  37         int                             vcount, wcount, pcount, scount;
  38         int                             vsize, wsize, psize, ssize;
  39         struct berval   **bvals;
  40         char                    **vals;
  41         char                    *dn, *p, *val;
  42         char                    buf[SUBLEN+1];
  43         LDBM                    wldbm, pldbm, sldbm;
  44         static char             *attrs[] = { "cn", "nentries", NULL };
  45
  46 /*
  47         ldap_debug = 255;
  48 */
  49         if ( (ld = ldap_init( "vertigo:5555", 0 )) == NULL ) {
  50                 perror( "ldap_init" );
  51                 exit( EXIT_FAILURE );
  52         }
  53
  54         if ( ldap_search( ld, "cn=index", LDAP_SCOPE_ONELEVEL, "(objectclass=*)",
  55           attrs, 0 ) == -1 ) {
  56                 ldap_perror( ld, "ldap_search" );
  57                 exit( EXIT_FAILURE );
  58         }
  59
  60         printf( "attr\tdn\tnentries\tvcount\tvsize\twcount\twsize\tpcount\tpsize\tscount\tssize\n" );
  61         fflush( stdout );
  62         count = 0;
  63         while ( ldap_result( ld, LDAP_RES_ANY, 0, NULL, &res )
  64           == LDAP_RES_SEARCH_ENTRY ) {
  65                 count++;
  66                 e = ldap_first_entry( ld, res );
  67                 dn = ldap_get_dn( ld, e );
  68                 if ( (vals = ldap_get_values( ld, e, "nentries" )) != NULL ) {
  69                         nentries = atoi( vals[0] );
  70                         ldap_value_free( vals );
  71                 } else {
  72                         fprintf( stderr, "no nentries attribute for (%s)\n", dn );
  73                         nentries = -1;
  74                 }
  75
  76                 for ( i = 0; attrs[i] != NULL; i++ ) {
  77                         if ( strcasecmp( attrs[i], "nentries" ) == 0 ) {
  78                                 continue;
  79                         }
  80                         if ( (wldbm = ldbm_open( "wcount.ldbm", DB_FLAGS, MODE,
  81                           CACHE_SIZE )) == NULL || (pldbm = ldbm_open( "pcount.ldbm",
  82                           DB_FLAGS, MODE, CACHE_SIZE )) == NULL || (sldbm = ldbm_open(
  83                           "scount.ldbm", DB_FLAGS, MODE, CACHE_SIZE )) == NULL ) {
  84                                 perror( "ldbm_open" );
  85                                 exit( EXIT_FAILURE );
  86                         }
  87                         vcount = 0; vsize = 0;
  88                         wcount = 0; wsize = 0;
  89                         pcount = 0; psize = 0;
  90                         scount = 0; ssize = 0;
  91                         if ( (bvals = ldap_get_values_len( ld, e, attrs[i] )) != NULL ) {
  92                                 for ( j = 0; bvals[j] != NULL; j++ ) {
  93                                         char    *w;
  94
  95                                         /* update value count */
  96                                         vcount++;
  97                                         vsize += bvals[j]->bv_len;
  98
  99                                         /* update word and phoneme counts */
 100                                         for ( w = first_word( bvals[j]->bv_val ); w != NULL;
 101                                           w = next_word( w ) ) {
 102                                                 add( wldbm, word_dup( w ), &wcount, &wsize, 1 );
 103
 104                                                 add( pldbm, phonetic( w ), &pcount, &psize, 1 );
 105                                         }
 106
 107                                         /* update substring count */
 108                                         len = bvals[j]->bv_len;
 109                                         val = bvals[j]->bv_val;
 110                                         if ( len > SUBLEN - 2 ) {
 111                                                 buf[0] = '^';
 112                                                 for ( k = 0; k < SUBLEN - 1; k++ ) {
 113                                                         buf[k + 1] = val[k];
 114                                                 }
 115                                                 buf[SUBLEN] = '\0';
 116                                                 add( sldbm, buf, &scount, &ssize, 0 );
 117
 118                                                 p = val + len - SUBLEN + 1;
 119                                                 for ( k = 0; k < SUBLEN; k++ ) {
 120                                                         buf[k] = p[k];
 121                                                 }
 122                                                 buf[SUBLEN - 1] = '$';
 123                                                 buf[SUBLEN] = '\0';
 124                                                 add( sldbm, buf, &scount, &ssize, 0 );
 125                                         }
 126                                         for ( p = val; p < (val + len - SUBLEN + 1); p++ ) {
 127                                                 for ( k = 0; k < SUBLEN; k++ ) {
 128                                                         buf[k] = p[k];
 129                                                 }
 130                                                 buf[SUBLEN] = '\0';
 131                                                 add( sldbm, buf, &scount, &ssize, 0 );
 132                                         }
 133                                 }
 134                                 ldap_value_free_len( bvals );
 135                         }
 136                         printf( "%s\t%s\t%d", attrs[i], dn, nentries );
 137                         printf( "\t%d\t%d", vcount, vsize );
 138                         printf( "\t%d\t%d", wcount, wsize );
 139                         printf( "\t%d\t%d", pcount, psize );
 140                         printf( "\t%d\t%d\n", scount, ssize );
 141                         fflush( stdout );
 142
 143                         ldbm_close( wldbm );
 144                         ldbm_close( pldbm );
 145                         ldbm_close( sldbm );
 146                 }
 147
 148                 free( dn );
 149                 ldap_msgfree( res );
 150         }
 151         printf( "%d entries\n", count );
 152         fflush( stdout );
 153
 154         if ( ldap_result2error( ld, res, 1 ) != LDAP_SUCCESS ) {
 155                 ldap_perror( ld, "ldap_result" );
 156         }
 157         ldap_unbind( ld );
 158
 159         (void) unlink( "wcount.ldbm" );
 160         (void) unlink( "pcount.ldbm" );
 161         (void) unlink( "scount.ldbm" );
 162
 163         exit( EXIT_SUCCESS );
 164 }
 165
 166 static void
 167 add(
 168     LDBM        ldbm,
 169     char        *s,
 170     int         *count,
 171     int         *size,
 172     int         freeit
 173 )
 174 {
 175         Datum   key, data;
 176
 177         ldbm_datum_init( key );
 178         ldbm_datum_init( data );
 179
 180         key.dptr = s;
 181         key.dsize = strlen( key.dptr ) + 1;
 182         data.dptr = "";
 183         data.dsize = 0;
 184         if ( ldbm_store( ldbm, key, data, LDBM_INSERT ) == 0 ) {
 185                 (*count)++;
 186                 (*size) += strlen( key.dptr );
 187         }
 188         if ( freeit && ( key.dptr != NULL ) )
 189                 ldbm_datum_free( ldbm, key );
 190 }