Diff for /servers/slapd/overlays/syncprov.c between versions 1.28 and 1.29

version 1.28, 2004/11/27 13:54:49 version 1.29, 2004/11/27 14:08:25
Line 65  typedef struct syncops { Line 65  typedef struct syncops {
         ldap_pvt_thread_mutex_t s_mutex;          ldap_pvt_thread_mutex_t s_mutex;
 } syncops;  } syncops;
   
 static int      sync_cid;  
   
 /* A received sync control */  /* A received sync control */
 typedef struct sync_control {  typedef struct sync_control {
         struct sync_cookie sr_state;          struct sync_cookie sr_state;
         int sr_rhint;          int sr_rhint;
 } sync_control;  } sync_control;
   
   #if 0 /* moved back to slap.h */
   #define o_sync  o_ctrlflag[slap_cids.sc_LDAPsync]
   #endif
 /* o_sync_mode uses data bits of o_sync */  /* o_sync_mode uses data bits of o_sync */
 #define o_sync  o_ctrlflag[sync_cid]  #define o_sync_mode     o_ctrlflag[slap_cids.sc_LDAPsync]
 #define o_sync_mode     o_ctrlflag[sync_cid]  
   
 #define SLAP_SYNC_NONE                                  (LDAP_SYNC_NONE<<SLAP_CONTROL_SHIFT)  #define SLAP_SYNC_NONE                                  (LDAP_SYNC_NONE<<SLAP_CONTROL_SHIFT)
 #define SLAP_SYNC_REFRESH                               (LDAP_SYNC_REFRESH_ONLY<<SLAP_CONTROL_SHIFT)  #define SLAP_SYNC_REFRESH                               (LDAP_SYNC_REFRESH_ONLY<<SLAP_CONTROL_SHIFT)
Line 558  syncprov_findcsn( Operation *op, int mod Line 558  syncprov_findcsn( Operation *op, int mod
         int rc;          int rc;
         fpres_cookie pcookie;          fpres_cookie pcookie;
         int locked = 0;          int locked = 0;
         sync_control *srs = op->o_controls[sync_cid];          sync_control *srs = op->o_controls[slap_cids.sc_LDAPsync];
   
         if ( srs->sr_state.ctxcsn->bv_len >= LDAP_LUTIL_CSNSTR_BUFSIZE ) {          if ( srs->sr_state.ctxcsn->bv_len >= LDAP_LUTIL_CSNSTR_BUFSIZE ) {
                 return LDAP_OTHER;                  return LDAP_OTHER;
Line 700  syncprov_sendresp( Operation *op, opcook Line 700  syncprov_sendresp( Operation *op, opcook
                 e_uuid.e_nname = opc->sndn;                  e_uuid.e_nname = opc->sndn;
                 rs.sr_entry = &e_uuid;                  rs.sr_entry = &e_uuid;
                 if ( opc->sreference ) {                  if ( opc->sreference ) {
                         struct berval bv;                          struct berval bv = BER_BVNULL;
                         bv.bv_val = NULL;  
                         bv.bv_len = 0;  
                         rs.sr_ref = &bv;                          rs.sr_ref = &bv;
                         send_search_reference( &sop, &rs );                          send_search_reference( &sop, &rs );
                 } else {                  } else {
Line 977  syncprov_op_response( Operation *op, Sla Line 975  syncprov_op_response( Operation *op, Sla
                 cbuf[0] = '\0';                  cbuf[0] = '\0';
                 ldap_pvt_thread_mutex_lock( &si->si_csn_mutex );                  ldap_pvt_thread_mutex_lock( &si->si_csn_mutex );
                 slap_get_commit_csn( op, &maxcsn );                  slap_get_commit_csn( op, &maxcsn );
                 if ( maxcsn.bv_val ) {                  if ( !BER_BVISNULL( &maxcsn ) ) {
                         strcpy( cbuf, maxcsn.bv_val );                          strcpy( cbuf, maxcsn.bv_val );
                         if ( ber_bvcmp( &maxcsn, &si->si_ctxcsn ) > 0 ) {                          if ( ber_bvcmp( &maxcsn, &si->si_ctxcsn ) > 0 ) {
                                 strcpy( si->si_ctxcsnbuf, cbuf );                                  strcpy( si->si_ctxcsnbuf, cbuf );
Line 1056  syncprov_op_compare( Operation *op, Slap Line 1054  syncprov_op_compare( Operation *op, Slap
                 e.e_name = op->o_bd->be_suffix[0];                  e.e_name = op->o_bd->be_suffix[0];
                 e.e_nname = op->o_bd->be_nsuffix[0];                  e.e_nname = op->o_bd->be_nsuffix[0];
   
                 bv[1].bv_val = NULL;                  BER_BVZERO( &bv[1] );
                 bv[0] = si->si_ctxcsn;                  bv[0] = si->si_ctxcsn;
   
                 a.a_desc = slap_schema.si_ad_contextCSN;                  a.a_desc = slap_schema.si_ad_contextCSN;
Line 1202  syncprov_detach_op( Operation *op, synco Line 1200  syncprov_detach_op( Operation *op, synco
         char *ptr;          char *ptr;
   
         /* count the search attrs */          /* count the search attrs */
         for (i=0; op->ors_attrs && op->ors_attrs[i].an_name.bv_val; i++) {          for (i=0; op->ors_attrs && !BER_BVISNULL( &op->ors_attrs[i].an_name ); i++) {
                 alen += op->ors_attrs[i].an_name.bv_len + 1;                  alen += op->ors_attrs[i].an_name.bv_len + 1;
         }          }
         /* Make a new copy of the operation */          /* Make a new copy of the operation */
Line 1219  syncprov_detach_op( Operation *op, synco Line 1217  syncprov_detach_op( Operation *op, synco
         if ( i ) {          if ( i ) {
                 op2->ors_attrs = (AttributeName *)(op2->o_hdr + 1);                  op2->ors_attrs = (AttributeName *)(op2->o_hdr + 1);
                 ptr = (char *)(op2->ors_attrs+i+1);                  ptr = (char *)(op2->ors_attrs+i+1);
                 for (i=0; op->ors_attrs[i].an_name.bv_val; i++) {                  for (i=0; !BER_BVISNULL( &op->ors_attrs[i].an_name ); i++) {
                         op2->ors_attrs[i] = op->ors_attrs[i];                          op2->ors_attrs[i] = op->ors_attrs[i];
                         op2->ors_attrs[i].an_name.bv_val = ptr;                          op2->ors_attrs[i].an_name.bv_val = ptr;
                         ptr = lutil_strcopy( ptr, op->ors_attrs[i].an_name.bv_val ) + 1;                          ptr = lutil_strcopy( ptr, op->ors_attrs[i].an_name.bv_val ) + 1;
                 }                  }
                 op2->ors_attrs[i].an_name.bv_val = NULL;                  BER_BVZERO( &op2->ors_attrs[i].an_name );
                 op2->ors_attrs[i].an_name.bv_len = 0;  
         } else {          } else {
                 ptr = (char *)(op2->o_hdr + 1);                  ptr = (char *)(op2->o_hdr + 1);
         }          }
Line 1257  syncprov_search_response( Operation *op, Line 1254  syncprov_search_response( Operation *op,
         searchstate *ss = op->o_callback->sc_private;          searchstate *ss = op->o_callback->sc_private;
         slap_overinst *on = ss->ss_on;          slap_overinst *on = ss->ss_on;
         syncprov_info_t         *si = on->on_bi.bi_private;          syncprov_info_t         *si = on->on_bi.bi_private;
         sync_control *srs = op->o_controls[sync_cid];          sync_control *srs = op->o_controls[slap_cids.sc_LDAPsync];
   
         if ( rs->sr_type == REP_SEARCH || rs->sr_type == REP_SEARCHREF ) {          if ( rs->sr_type == REP_SEARCH || rs->sr_type == REP_SEARCHREF ) {
                 int i;                  int i;
Line 1366  syncprov_op_search( Operation *op, SlapR Line 1363  syncprov_op_search( Operation *op, SlapR
                 return rs->sr_err;                  return rs->sr_err;
         }          }
   
         srs = op->o_controls[sync_cid];          srs = op->o_controls[slap_cids.sc_LDAPsync];
   
         /* If this is a persistent search, set it up right away */          /* If this is a persistent search, set it up right away */
         if ( op->o_sync_mode & SLAP_SYNC_PERSIST ) {          if ( op->o_sync_mode & SLAP_SYNC_PERSIST ) {
Line 1738  static int syncprov_parseCtrl ( Line 1735  static int syncprov_parseCtrl (
                 return LDAP_PROTOCOL_ERROR;                  return LDAP_PROTOCOL_ERROR;
         }          }
   
         if ( ctrl->ldctl_value.bv_len == 0 ) {          if ( BER_BVISEMPTY( &ctrl->ldctl_value ) ) {
                 rs->sr_text = "Sync control value is empty (or absent)";                  rs->sr_text = "Sync control value is empty (or absent)";
                 return LDAP_PROTOCOL_ERROR;                  return LDAP_PROTOCOL_ERROR;
         }          }
Line 1803  static int syncprov_parseCtrl ( Line 1800  static int syncprov_parseCtrl (
                 slap_parse_sync_cookie( &sr->sr_state );                  slap_parse_sync_cookie( &sr->sr_state );
         }          }
   
         op->o_controls[sync_cid] = sr;          op->o_controls[slap_cids.sc_LDAPsync] = sr;
   
         (void) ber_free( ber, 1 );          (void) ber_free( ber, 1 );
   
Line 1830  syncprov_init() Line 1827  syncprov_init()
   
         rc = register_supported_control( LDAP_CONTROL_SYNC,          rc = register_supported_control( LDAP_CONTROL_SYNC,
                 SLAP_CTRL_HIDE|SLAP_CTRL_SEARCH, NULL,                  SLAP_CTRL_HIDE|SLAP_CTRL_SEARCH, NULL,
                 syncprov_parseCtrl, &sync_cid );                  syncprov_parseCtrl, &slap_cids.sc_LDAPsync );
         if ( rc != LDAP_SUCCESS ) {          if ( rc != LDAP_SUCCESS ) {
                 fprintf( stderr, "Failed to register control %d\n", rc );                  fprintf( stderr, "Failed to register control %d\n", rc );
                 return rc;                  return rc;

Removed from v.1.28  
changed lines
  Added in v.1.29


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