Diff for /servers/slapd/overlays/syncprov.c between versions 1.62 and 1.65

version 1.62, 2005/01/12 00:49:00 version 1.65, 2005/01/13 20:14:52
Line 1 Line 1
 /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.61 2005/01/11 04:00:59 hyc Exp $ */  /* $OpenLDAP: pkg/ldap/servers/slapd/overlays/syncprov.c,v 1.64 2005/01/13 18:51:01 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 56  typedef struct syncops { Line 56  typedef struct syncops {
         struct berval   s_base;         /* ndn of search base */          struct berval   s_base;         /* ndn of search base */
         ID              s_eid;          /* entryID of search base */          ID              s_eid;          /* entryID of search base */
         Operation       *s_op;          /* search op */          Operation       *s_op;          /* search op */
         int             s_sid;  
         int             s_rid;          int             s_rid;
         struct berval s_filterstr;          struct berval s_filterstr;
         int             s_flags;        /* search status */          int             s_flags;        /* search status */
Line 101  typedef struct slog_entry { Line 100  typedef struct slog_entry {
 } slog_entry;  } slog_entry;
   
 typedef struct sessionlog {  typedef struct sessionlog {
         struct sessionlog *sl_next;  
         int             sl_sid;  
         struct berval   sl_mincsn;          struct berval   sl_mincsn;
         int             sl_num;          int             sl_num;
         int             sl_size;          int             sl_size;
Line 771  syncprov_sendresp( Operation *op, opcook Line 768  syncprov_sendresp( Operation *op, opcook
         }          }
   
         ctrls[1] = NULL;          ctrls[1] = NULL;
         slap_compose_sync_cookie( op, &cookie, &opc->sctxcsn,          slap_compose_sync_cookie( op, &cookie, &opc->sctxcsn, so->s_rid );
                 so->s_sid, so->s_rid );  
   
         e_uuid.e_attrs = &a_uuid;          e_uuid.e_attrs = &a_uuid;
         a_uuid.a_desc = slap_schema.si_ad_entryUUID;          a_uuid.a_desc = slap_schema.si_ad_entryUUID;
Line 886  syncprov_op_abandon( Operation *op, Slap Line 882  syncprov_op_abandon( Operation *op, Slap
                         rs->sr_err = LDAP_CANCELLED;                          rs->sr_err = LDAP_CANCELLED;
                         send_ldap_result( so->s_op, rs );                          send_ldap_result( so->s_op, rs );
                 }                  }
                 /* Our cloned searches have no ctrls set.                  syncprov_drop_psearch( so, 0 );
                  * we don't want to muck with real search ops  
                  * from the frontend.  
                  */  
                 if ( ! so->s_op->o_sync )  
                         syncprov_drop_psearch( so, 0 );  
         }          }
         return SLAP_CB_CONTINUE;          return SLAP_CB_CONTINUE;
 }  }
Line 1102  syncprov_add_slog( Operation *op, struct Line 1093  syncprov_add_slog( Operation *op, struct
         sessionlog *sl;          sessionlog *sl;
         slog_entry *se;          slog_entry *se;
   
         for ( sl = si->si_logs; sl; sl=sl->sl_next ) {          sl = si->si_logs;
           {
                 /* Allocate a record. UUIDs are not NUL-terminated. */                  /* Allocate a record. UUIDs are not NUL-terminated. */
                 se = ch_malloc( sizeof( slog_entry ) + opc->suuid.bv_len +                   se = ch_malloc( sizeof( slog_entry ) + opc->suuid.bv_len + 
                         csn->bv_len + 1 );                          csn->bv_len + 1 );
Line 1631  syncprov_search_response( Operation *op, Line 1623  syncprov_search_response( Operation *op,
   
                 slap_compose_sync_cookie( op, &cookie,                  slap_compose_sync_cookie( op, &cookie,
                         &op->ors_filter->f_and->f_ava->aa_value,                          &op->ors_filter->f_and->f_ava->aa_value,
                         srs->sr_state.sid, srs->sr_state.rid );                          srs->sr_state.rid );
   
                 /* Is this a regular refresh? */                  /* Is this a regular refresh? */
                 if ( !ss->ss_so ) {                  if ( !ss->ss_so ) {
Line 1751  syncprov_op_search( Operation *op, SlapR Line 1743  syncprov_op_search( Operation *op, SlapR
                 sop = ch_malloc( sizeof( syncops ));                  sop = ch_malloc( sizeof( syncops ));
                 *sop = so;                  *sop = so;
                 ldap_pvt_thread_mutex_init( &sop->s_mutex );                  ldap_pvt_thread_mutex_init( &sop->s_mutex );
                 sop->s_sid = srs->sr_state.sid;  
                 sop->s_rid = srs->sr_state.rid;                  sop->s_rid = srs->sr_state.rid;
                 sop->s_inuse = 1;                  sop->s_inuse = 1;
   
Line 1793  syncprov_op_search( Operation *op, SlapR Line 1784  syncprov_op_search( Operation *op, SlapR
                         goto shortcut;                          goto shortcut;
                 }                  }
                 /* Do we have a sessionlog for this search? */                  /* Do we have a sessionlog for this search? */
                 for ( sl=si->si_logs; sl; sl=sl->sl_next )                  sl=si->si_logs;
                         if ( sl->sl_sid == srs->sr_state.sid ) break;  
                 if ( sl ) {                  if ( sl ) {
                         ldap_pvt_thread_mutex_lock( &sl->sl_mutex );                          ldap_pvt_thread_mutex_lock( &sl->sl_mutex );
                         if ( ber_bvcmp( srs->sr_state.ctxcsn, &sl->sl_mincsn ) >= 0 ) {                          if ( ber_bvcmp( srs->sr_state.ctxcsn, &sl->sl_mincsn ) >= 0 ) {
Line 1952  syncprov_db_config( Line 1942  syncprov_db_config(
   
         } else if ( strcasecmp( argv[0], "syncprov-sessionlog" ) == 0 ) {          } else if ( strcasecmp( argv[0], "syncprov-sessionlog" ) == 0 ) {
                 sessionlog *sl;                  sessionlog *sl;
                 int sid, size;                  int size;
                 if ( argc != 3 ) {                  if ( argc != 2 ) {
                         fprintf( stderr, "%s: line %d: wrong number of arguments in "                          fprintf( stderr, "%s: line %d: wrong number of arguments in "
                                 "\"syncprov-sessionlog <sid> <size>\"\n", fname, lineno );                                  "\"syncprov-sessionlog <size>\"\n", fname, lineno );
                         return -1;                          return -1;
                 }                  }
                 sid = atoi( argv[1] );                  size = atoi( argv[1] );
                 if ( sid < 0 || sid > 999 ) {  
                         fprintf( stderr,  
                                 "%s: line %d: session log id %d is out of range [0..999]\n",  
                                 fname, lineno, sid );  
                         return -1;  
                 }  
                 size = atoi( argv[2] );  
                 if ( size < 0 ) {                  if ( size < 0 ) {
                         fprintf( stderr,                          fprintf( stderr,
                                 "%s: line %d: session log size %d is negative\n",                                  "%s: line %d: session log size %d is negative\n",
                                 fname, lineno, size );                                  fname, lineno, size );
                         return -1;                          return -1;
                 }                  }
                 for ( sl = si->si_logs; sl; sl=sl->sl_next ) {                  sl = si->si_logs;
                         if ( sl->sl_sid == sid ) {  
                                 sl->sl_size = size;  
                                 break;  
                         }  
                 }  
                 if ( !sl ) {                  if ( !sl ) {
                         sl = ch_malloc( sizeof( sessionlog ) + LDAP_LUTIL_CSNSTR_BUFSIZE );                          sl = ch_malloc( sizeof( sessionlog ) + LDAP_LUTIL_CSNSTR_BUFSIZE );
                         sl->sl_mincsn.bv_val = (char *)(sl+1);                          sl->sl_mincsn.bv_val = (char *)(sl+1);
                         sl->sl_mincsn.bv_len = 0;                          sl->sl_mincsn.bv_len = 0;
                         sl->sl_sid = sid;  
                         sl->sl_size = size;  
                         sl->sl_num = 0;                          sl->sl_num = 0;
                         sl->sl_head = sl->sl_tail = NULL;                          sl->sl_head = sl->sl_tail = NULL;
                         sl->sl_next = si->si_logs;  
                         ldap_pvt_thread_mutex_init( &sl->sl_mutex );                          ldap_pvt_thread_mutex_init( &sl->sl_mutex );
                         si->si_logs = sl;                          si->si_logs = sl;
                 }                  }
                   sl->sl_size = size;
                 return 0;                  return 0;
         }          }
   

Removed from v.1.62  
changed lines
  Added in v.1.65


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