Diff for /servers/slapd/overlays/syncprov.c between versions 1.268 and 1.269

version 1.268, 2009/03/12 23:15:28 version 1.269, 2009/03/12 23:26:24
Line 1 Line 1
 /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.267 2009/03/12 23:14:19 hyc Exp $ */  /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.268 2009/03/12 23:15:28 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 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 && 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 2164  syncprov_search_response( Operation *op, Line 2164  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 2176  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.268  
changed lines
  Added in v.1.269


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