Diff for /servers/slapd/overlays/syncprov.c between versions 1.128 and 1.139

version 1.128, 2005/11/20 21:14:57 version 1.139, 2006/01/03 22:12:25
Line 1 Line 1
 /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.127 2005/11/20 09:39:05 hyc Exp $ */  /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.138 2005/12/26 16:00:12 ando Exp $ */
 /* syncprov.c - syncrepl provider */  /* syncprov.c - syncrepl provider */
 /* This work is part of OpenLDAP Software <http://www.openldap.org/>.  /* This work is part of OpenLDAP Software <http://www.openldap.org/>.
  *   *
  * Copyright 2004-2005 The OpenLDAP Foundation.   * Copyright 2004-2006 The OpenLDAP Foundation.
  * All rights reserved.   * All rights reserved.
  *   *
  * Redistribution and use in source and binary forms, with or without   * Redistribution and use in source and binary forms, with or without
Line 450  syncprov_findbase( Operation *op, fbase_ Line 450  syncprov_findbase( Operation *op, fbase_
                 case LDAP_SCOPE_SUBTREE:                  case LDAP_SCOPE_SUBTREE:
                         fc->fscope = dnIsSuffix( fc->fdn, &fc->fss->s_base );                          fc->fscope = dnIsSuffix( fc->fdn, &fc->fss->s_base );
                         break;                          break;
 #ifdef LDAP_SCOPE_SUBORDINATE  
                 case LDAP_SCOPE_SUBORDINATE:                  case LDAP_SCOPE_SUBORDINATE:
                         fc->fscope = dnIsSuffix( fc->fdn, &fc->fss->s_base ) &&                          fc->fscope = dnIsSuffix( fc->fdn, &fc->fss->s_base ) &&
                                 !dn_match( fc->fdn, &fc->fss->s_base );                                  !dn_match( fc->fdn, &fc->fss->s_base );
                         break;                          break;
 #endif  
                 }                  }
         }          }
   
Line 1802  syncprov_search_response( Operation *op, Line 1800  syncprov_search_response( Operation *op,
                         return SLAP_CB_CONTINUE;                          return SLAP_CB_CONTINUE;
                 }                  }
                 a = attr_find( rs->sr_entry->e_attrs, slap_schema.si_ad_entryCSN );                  a = attr_find( rs->sr_entry->e_attrs, slap_schema.si_ad_entryCSN );
                   if ( a == NULL && rs->sr_operational_attrs != NULL ) {
                           a = attr_find( rs->sr_operational_attrs, slap_schema.si_ad_entryCSN );
                   }
                 if ( a ) {                  if ( a ) {
                         /* Make sure entry is less than the snaphot'd contextCSN */                          /* Make sure entry is less than the snapshot'd contextCSN */
                         if ( ber_bvcmp( &a->a_nvals[0], &ss->ss_ctxcsn ) > 0 )                          if ( ber_bvcmp( &a->a_nvals[0], &ss->ss_ctxcsn ) > 0 )
                                 return LDAP_SUCCESS;                                  return LDAP_SUCCESS;
   
Line 2195  sp_cf_gen(ConfigArgs *c) Line 2196  sp_cf_gen(ConfigArgs *c)
         }          }
         switch ( c->type ) {          switch ( c->type ) {
         case SP_CHKPT:          case SP_CHKPT:
                 si->si_chkops = atoi( c->argv[1] );                  if ( lutil_atoi( &si->si_chkops, c->argv[1] ) != 0 ) {
                 si->si_chktime = atoi( c->argv[2] ) * 60;                          sprintf( c->msg, "%s unable to parse checkpoint ops # \"%s\"",
                                   c->argv[0], c->argv[1] );
                           Debug( LDAP_DEBUG_CONFIG, "%s: %s\n", c->log, c->msg, 0 );
                           return ARG_BAD_CONF;
                   }
                   if ( si->si_chkops <= 0 ) {
                           sprintf( c->msg, "%s invalid checkpoint ops # \"%d\"",
                                   c->argv[0], si->si_chkops );
                           Debug( LDAP_DEBUG_CONFIG, "%s: %s\n", c->log, c->msg, 0 );
                           return ARG_BAD_CONF;
                   }
                   if ( lutil_atoi( &si->si_chktime, c->argv[2] ) != 0 ) {
                           sprintf( c->msg, "%s unable to parse checkpoint time \"%s\"",
                                   c->argv[0], c->argv[1] );
                           Debug( LDAP_DEBUG_CONFIG, "%s: %s\n", c->log, c->msg, 0 );
                           return ARG_BAD_CONF;
                   }
                   if ( si->si_chktime <= 0 ) {
                           sprintf( c->msg, "%s invalid checkpoint time \"%d\"",
                                   c->argv[0], si->si_chkops );
                           Debug( LDAP_DEBUG_CONFIG, "%s: %s\n", c->log, c->msg, 0 );
                           return ARG_BAD_CONF;
                   }
                   si->si_chktime *= 60;
                 break;                  break;
         case SP_SESSL: {          case SP_SESSL: {
                 sessionlog *sl;                  sessionlog *sl;
Line 2255  syncprov_db_open( Line 2279  syncprov_db_open(
         slap_overinst   *on = (slap_overinst *) be->bd_info;          slap_overinst   *on = (slap_overinst *) be->bd_info;
         syncprov_info_t *si = (syncprov_info_t *)on->on_bi.bi_private;          syncprov_info_t *si = (syncprov_info_t *)on->on_bi.bi_private;
   
         Connection conn;          Connection conn = { 0 };
         OperationBuffer opbuf;          OperationBuffer opbuf = { 0 };
         char ctxcsnbuf[LDAP_LUTIL_CSNSTR_BUFSIZE];          char ctxcsnbuf[LDAP_LUTIL_CSNSTR_BUFSIZE];
         Operation *op = (Operation *) &opbuf;          Operation *op = (Operation *) &opbuf;
         Entry *e;          Entry *e;
Line 2299  syncprov_db_open( Line 2323  syncprov_db_open(
                         strcpy( ctxcsnbuf, si->si_ctxcsnbuf );                          strcpy( ctxcsnbuf, si->si_ctxcsnbuf );
                 }                  }
                 be_entry_release_rw( op, e, 0 );                  be_entry_release_rw( op, e, 0 );
                 op->o_bd->bd_info = (BackendInfo *)on;                  if ( !BER_BVISEMPTY( &si->si_ctxcsn ) ) {
                 op->o_req_dn = be->be_suffix[0];                          op->o_bd->bd_info = (BackendInfo *)on;
                 op->o_req_ndn = be->be_nsuffix[0];                          op->o_req_dn = be->be_suffix[0];
                 op->ors_scope = LDAP_SCOPE_SUBTREE;                          op->o_req_ndn = be->be_nsuffix[0];
                 ldap_pvt_thread_create( &tid, 0, syncprov_db_otask, op );                          op->ors_scope = LDAP_SCOPE_SUBTREE;
                 ldap_pvt_thread_join( tid, NULL );                          ldap_pvt_thread_create( &tid, 0, syncprov_db_otask, op );
                           ldap_pvt_thread_join( tid, NULL );
                   }
         } else if ( SLAP_SYNC_SHADOW( op->o_bd )) {          } else if ( SLAP_SYNC_SHADOW( op->o_bd )) {
                 /* If we're also a consumer, and we didn't find the context entry,                  /* If we're also a consumer, and we didn't find the context entry,
                  * then don't generate anything, wait for our provider to send it                   * then don't generate anything, wait for our provider to send it
Line 2398  syncprov_db_destroy( Line 2424  syncprov_db_destroy(
         syncprov_info_t *si = (syncprov_info_t *)on->on_bi.bi_private;          syncprov_info_t *si = (syncprov_info_t *)on->on_bi.bi_private;
   
         if ( si ) {          if ( si ) {
                   if ( si->si_logs ) {
                           ch_free( si->si_logs );
                   }
                 ldap_pvt_thread_mutex_destroy( &si->si_mods_mutex );                  ldap_pvt_thread_mutex_destroy( &si->si_mods_mutex );
                 ldap_pvt_thread_mutex_destroy( &si->si_ops_mutex );                  ldap_pvt_thread_mutex_destroy( &si->si_ops_mutex );
                 ldap_pvt_thread_mutex_destroy( &si->si_csn_mutex );                  ldap_pvt_thread_mutex_destroy( &si->si_csn_mutex );
Line 2516  static int syncprov_parseCtrl ( Line 2545  static int syncprov_parseCtrl (
 static slap_overinst            syncprov;  static slap_overinst            syncprov;
   
 int  int
 syncprov_init()  syncprov_initialize()
 {  {
         int rc;          int rc;
   
         rc = register_supported_control( LDAP_CONTROL_SYNC,          rc = register_supported_control( LDAP_CONTROL_SYNC,
                 SLAP_CTRL_HIDE|SLAP_CTRL_SEARCH, NULL,                  SLAP_CTRL_SEARCH, NULL,
                 syncprov_parseCtrl, &slap_cids.sc_LDAPsync );                  syncprov_parseCtrl, &slap_cids.sc_LDAPsync );
         if ( rc != LDAP_SUCCESS ) {          if ( rc != LDAP_SUCCESS ) {
                 Debug( LDAP_DEBUG_ANY,                  Debug( LDAP_DEBUG_ANY,
Line 2561  syncprov_init() Line 2590  syncprov_init()
 int  int
 init_module( int argc, char *argv[] )  init_module( int argc, char *argv[] )
 {  {
         return syncprov_init();          return syncprov_initialize();
 }  }
 #endif /* SLAPD_OVER_SYNCPROV == SLAPD_MOD_DYNAMIC */  #endif /* SLAPD_OVER_SYNCPROV == SLAPD_MOD_DYNAMIC */
   

Removed from v.1.128  
changed lines
  Added in v.1.139


______________
© Copyright 1998-2020, OpenLDAP Foundation, info@OpenLDAP.org