Diff for /servers/slapd/overlays/syncprov.c between versions 1.296 and 1.300

version 1.296, 2009/11/14 20:53:06 version 1.300, 2009/11/21 02:38:13
Line 1 Line 1
 /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.295 2009/11/14 08:35:23 hyc Exp $ */  /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.298 2009/11/19 10:17:53 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 792  syncprov_sendresp( Operation *op, opcook Line 792  syncprov_sendresp( Operation *op, opcook
         }          }
   
 #ifdef LDAP_DEBUG  #ifdef LDAP_DEBUG
         if ( !BER_BVISNULL( &cookie )) {          if ( so->s_sid > 0 ) {
                 if ( so->s_sid > 0 ) {                  Debug( LDAP_DEBUG_SYNC, "syncprov_sendresp: to=%03x, cookie=%s\n",
                         Debug( LDAP_DEBUG_SYNC, "syncprov_sendresp: to=%03x, cookie=%s\n",                          so->s_sid, cookie.bv_val ? cookie.bv_val : "", 0 );
                                 so->s_sid, cookie.bv_val , 0 );          } else {
                 } else {                  Debug( LDAP_DEBUG_SYNC, "syncprov_sendresp: cookie=%s\n",
                         Debug( LDAP_DEBUG_SYNC, "syncprov_sendresp: cookie=%s\n",                          cookie.bv_val ? cookie.bv_val : "", 0, 0 );
                                 cookie.bv_val, 0, 0 );          }
                 }  
         }                 
 #endif  #endif
   
         e_uuid.e_attrs = &a_uuid;          e_uuid.e_attrs = &a_uuid;
Line 1198  syncprov_matchops( Operation *op, opcook Line 1196  syncprov_matchops( Operation *op, opcook
                 if ( ss->s_op->o_abandon )                  if ( ss->s_op->o_abandon )
                         continue;                          continue;
   
                 /* First time thru, check for possible skips */                  /* Don't send ops back to the originator */
                 if ( saveit || op->o_tag == LDAP_REQ_ADD ) {                  if ( opc->osid > 0 && opc->osid == ss->s_sid ) {
                           Debug( LDAP_DEBUG_SYNC, "syncprov_matchops: skipping original sid %03x\n",
                         /* Don't send ops back to the originator */                                  opc->osid, 0, 0 );
                         if ( opc->osid > 0 && opc->osid == ss->s_sid ) {                          continue;
                                 Debug( LDAP_DEBUG_SYNC, "syncprov_matchops: skipping original sid %03x\n",                  }
                                         opc->osid, 0, 0 );  
                                 continue;  
                         }  
   
                         /* Don't send ops back to the messenger */                  /* Don't send ops back to the messenger */
                         if ( opc->rsid > 0 && opc->rsid == ss->s_sid ) {                  if ( opc->rsid > 0 && opc->rsid == 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",
                                         opc->rsid, 0, 0 );                                  opc->rsid, 0, 0 );
                                 continue;                          continue;
                         }  
                 }                  }
   
                 /* validate base */                  /* validate base */
Line 2893  syncprov_db_open( Line 2887  syncprov_db_open(
         }          }
   
         thrctx = ldap_pvt_thread_pool_context();          thrctx = ldap_pvt_thread_pool_context();
         connection_fake_init( &conn, &opbuf, thrctx );          connection_fake_init2( &conn, &opbuf, thrctx, 0 );
         op = &opbuf.ob_op;          op = &opbuf.ob_op;
         op->o_bd = be;          op->o_bd = be;
         op->o_dn = be->be_rootdn;          op->o_dn = be->be_rootdn;
Line 2978  syncprov_db_close( Line 2972  syncprov_db_close(
                 void *thrctx;                  void *thrctx;
   
                 thrctx = ldap_pvt_thread_pool_context();                  thrctx = ldap_pvt_thread_pool_context();
                 connection_fake_init( &conn, &opbuf, thrctx );                  connection_fake_init2( &conn, &opbuf, thrctx, 0 );
                 op = &opbuf.ob_op;                  op = &opbuf.ob_op;
                 op->o_bd = be;                  op->o_bd = be;
                 op->o_dn = be->be_rootdn;                  op->o_dn = be->be_rootdn;

Removed from v.1.296  
changed lines
  Added in v.1.300


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