Diff for /servers/slapd/overlays/syncprov.c between versions 1.267 and 1.271

version 1.267, 2009/03/12 23:14:19 version 1.271, 2009/03/13 00:07:45
Line 1 Line 1
 /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.266 2009/03/05 16:53:01 hyc Exp $ */  /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.270 2009/03/12 23:28:09 hyc 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/>.
  *   *
Line 783  syncprov_sendresp( Operation *op, opcook Line 783  syncprov_sendresp( Operation *op, opcook
         ctrls[1] = NULL;          ctrls[1] = NULL;
         csns[0] = opc->sctxcsn;          csns[0] = opc->sctxcsn;
         BER_BVZERO( &csns[1] );          BER_BVZERO( &csns[1] );
         slap_compose_sync_cookie( op, &cookie, csns, so->s_rid, slap_serverID );          slap_compose_sync_cookie( op, &cookie, csns, so->s_rid, slap_serverID ? slap_serverID : -1 );
   
         Debug( LDAP_DEBUG_SYNC, "syncprov_sendresp: cookie=%s\n", cookie.bv_val, 0, 0 );          Debug( LDAP_DEBUG_SYNC, "syncprov_sendresp: cookie=%s\n", cookie.bv_val, 0, 0 );
   
Line 982  syncprov_qresp( opcookie *opc, syncops * Line 982  syncprov_qresp( opcookie *opc, syncops *
                 syncprov_info_t *si = opc->son->on_bi.bi_private;                  syncprov_info_t *si = opc->son->on_bi.bi_private;
   
                 slap_compose_sync_cookie( NULL, &cookie, si->si_ctxcsn,                  slap_compose_sync_cookie( NULL, &cookie, si->si_ctxcsn,
                         so->s_rid, slap_serverID);                          so->s_rid, slap_serverID ? slap_serverID : -1);
         }          }
   
         srsize = sizeof(syncres) + opc->suuid.bv_len + 1 +          srsize = sizeof(syncres) + opc->suuid.bv_len + 1 +
Line 1161  syncprov_matchops( Operation *op, opcook Line 1161  syncprov_matchops( Operation *op, opcook
                 ber_dupbv_x( &opc->sndn, &e->e_nname, op->o_tmpmemctx );                  ber_dupbv_x( &opc->sndn, &e->e_nname, op->o_tmpmemctx );
         }          }
   
         scook = op->o_controls[slap_cids.sc_LDAPsync];          scook = op->o_controls ? op->o_controls[slap_cids.sc_LDAPsync] : NULL;
         ldap_pvt_thread_mutex_lock( &si->si_ops_mutex );          ldap_pvt_thread_mutex_lock( &si->si_ops_mutex );
         for (ss = si->si_ops, sprev = (syncops *)&si->si_ops; ss;          for (ss = si->si_ops, sprev = (syncops *)&si->si_ops; ss;
                 sprev = ss, ss=snext)                  sprev = ss, ss=snext)
Line 1176  syncprov_matchops( Operation *op, opcook Line 1176  syncprov_matchops( Operation *op, opcook
                         continue;                          continue;
   
                 /* Don't send ops back to the originator */                  /* Don't send ops back to the originator */
                 if ( opc->ssid && opc->ssid == ss->s_sid ) {                  if ( opc->ssid > 0 && opc->ssid == ss->s_sid ) {
                         Debug( LDAP_DEBUG_SYNC, "syncprov_matchops: skipping original sid %03x\n",                          Debug( LDAP_DEBUG_SYNC, "syncprov_matchops: skipping original sid %03x\n",
                                 opc->ssid, 0, 0 );                                  opc->ssid, 0, 0 );
                         continue;                          continue;
                 }                  }
   
                 /* Don't send ops back to the messenger */                  /* Don't send ops back to the messenger */
                 if ( scook && scook->sid == ss->s_sid ) {                  if ( scook && scook->sid > 0 && scook->sid == ss->s_sid ) {
                         Debug( LDAP_DEBUG_SYNC, "syncprov_matchops: skipping relayed sid %03x\n",                          Debug( LDAP_DEBUG_SYNC, "syncprov_matchops: skipping relayed sid %03x\n",
                                 scook->sid, 0, 0 );                                  scook->sid, 0, 0 );
                         continue;                          continue;
Line 1596  syncprov_playlog( Operation *op, SlapRep Line 1596  syncprov_playlog( Operation *op, SlapRep
   
                 if ( delcsn[0].bv_len ) {                  if ( delcsn[0].bv_len ) {
                         slap_compose_sync_cookie( op, &cookie, delcsn, srs->sr_state.rid,                          slap_compose_sync_cookie( op, &cookie, delcsn, srs->sr_state.rid,
                                 slap_serverID );                                  slap_serverID ? slap_serverID : -1 );
   
                         Debug( LDAP_DEBUG_SYNC, "syncprov_playlog: cookie=%s\n", cookie.bv_val, 0, 0 );                          Debug( LDAP_DEBUG_SYNC, "syncprov_playlog: cookie=%s\n", cookie.bv_val, 0, 0 );
                 }                  }
Line 1631  syncprov_op_response( Operation *op, Sla Line 1631  syncprov_op_response( Operation *op, Sla
                 maxcsn.bv_len = sizeof(cbuf);                  maxcsn.bv_len = sizeof(cbuf);
                 ldap_pvt_thread_rdwr_wlock( &si->si_csn_rwlock );                  ldap_pvt_thread_rdwr_wlock( &si->si_csn_rwlock );
   
   #if 0
                 if ( op->o_dont_replicate &&                  if ( op->o_dont_replicate &&
                                 op->orm_modlist->sml_op == LDAP_MOD_REPLACE &&                                  op->orm_modlist->sml_op == LDAP_MOD_REPLACE &&
                                 op->orm_modlist->sml_desc == slap_schema.si_ad_contextCSN ) {                                  op->orm_modlist->sml_desc == slap_schema.si_ad_contextCSN ) {
Line 1680  syncprov_op_response( Operation *op, Sla Line 1681  syncprov_op_response( Operation *op, Sla
                         }                          }
                         return SLAP_CB_CONTINUE;                          return SLAP_CB_CONTINUE;
                 }                  }
   #endif
   
                 slap_get_commit_csn( op, &maxcsn, &foundit );                  slap_get_commit_csn( op, &maxcsn, &foundit );
                 if ( BER_BVISEMPTY( &maxcsn ) && SLAP_GLUE_SUBORDINATE( op->o_bd )) {                  if ( BER_BVISEMPTY( &maxcsn ) && SLAP_GLUE_SUBORDINATE( op->o_bd )) {
Line 2164  syncprov_search_response( Operation *op, Line 2166  syncprov_search_response( Operation *op,
                 /* If we're in delta-sync mode, always send a cookie */                  /* If we're in delta-sync mode, always send a cookie */
                 if ( si->si_nopres && si->si_usehint && a ) {                  if ( si->si_nopres && si->si_usehint && a ) {
                         struct berval cookie;                          struct berval cookie;
                         slap_compose_sync_cookie( op, &cookie, a->a_nvals, srs->sr_state.rid, slap_serverID );                          slap_compose_sync_cookie( op, &cookie, a->a_nvals, srs->sr_state.rid, slap_serverID ? slap_serverID : -1 );
                         rs->sr_err = syncprov_state_ctrl( op, rs, rs->sr_entry,                          rs->sr_err = syncprov_state_ctrl( op, rs, rs->sr_entry,
                                 LDAP_SYNC_ADD, rs->sr_ctrls, 0, 1, &cookie );                                  LDAP_SYNC_ADD, rs->sr_ctrls, 0, 1, &cookie );
                 } else {                  } else {
Line 2176  syncprov_search_response( Operation *op, Line 2178  syncprov_search_response( Operation *op,
   
                 if ( ss->ss_flags & SS_CHANGED ) {                  if ( ss->ss_flags & SS_CHANGED ) {
                         slap_compose_sync_cookie( op, &cookie, ss->ss_ctxcsn,                          slap_compose_sync_cookie( op, &cookie, ss->ss_ctxcsn,
                                 srs->sr_state.rid, slap_serverID );                                  srs->sr_state.rid, slap_serverID ? slap_serverID : -1 );
   
                         Debug( LDAP_DEBUG_SYNC, "syncprov_search_response: cookie=%s\n", cookie.bv_val, 0, 0 );                          Debug( LDAP_DEBUG_SYNC, "syncprov_search_response: cookie=%s\n", cookie.bv_val, 0, 0 );
                 }                  }

Removed from v.1.267  
changed lines
  Added in v.1.271


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