Lines Matching refs:srs
147 sync_control *srs;
688 sync_control *srs = NULL;
694 srs = op->o_controls[slap_cids.sc_LDAPsync];
1861 sync_control *srs = uuid_progress->srs;
1924 * newer than cookieCSN (srs->sr_state.ctxcsn)
1927 for ( i=0; i<srs->sr_state.numcsns; i++ ) {
1928 if ( sid == srs->sr_state.sids[i] ) {
1929 cmp = ber_bvcmp( &csn[0], &srs->sr_state.ctxcsn[i] );
1994 slap_compose_sync_cookie( op, &cookie, srs->sr_state.ctxcsn,
1995 srs->sr_state.rid, slap_serverID ? slap_serverID : -1, csn );
2015 syncprov_play_sessionlog( Operation *op, SlapReply *rs, sync_control *srs,
2103 for ( k=0; k<srs->sr_state.numcsns; k++ ) {
2104 if ( se->se_sid == srs->sr_state.sids[k] ) {
2105 ndel = ber_bvcmp( &se->se_csn, &srs->sr_state.ctxcsn[k] );
2224 slap_compose_sync_cookie( op, &cookie, srs->sr_state.ctxcsn,
2225 srs->sr_state.rid, slap_serverID ? slap_serverID : -1, csn );
2246 syncprov_play_accesslog( Operation *op, SlapReply *rs, sync_control *srs,
2259 .srs = srs,
2309 * - the consumer's cookie (srs->sr_state.ctxcsn) has the same sids in the
2322 assert( srs->sr_state.numcsns == numcsns );
2327 assert( srs->sr_state.sids[i] == sids[i] );
2328 if ( ber_bvcmp( &srs->sr_state.ctxcsn[i], &ctxcsn[i] ) >= 0 ) {
2335 ber_bvcmp( &srs->sr_state.ctxcsn[i], &a->a_nvals[j] ) < 0 ) {
2340 op->o_log_prefix, srs->sr_state.ctxcsn[i].bv_val );
2346 ber_bvcmp( &oldestcsn, &srs->sr_state.ctxcsn[i] ) > 0 ) {
2347 oldestcsn = srs->sr_state.ctxcsn[i];
2954 sync_control *srs = op->o_controls[slap_cids.sc_LDAPsync];
2998 if ( srs->sr_state.ctxcsn ) {
2999 for ( i=0; i<srs->sr_state.numcsns; i++ ) {
3000 if ( sid == srs->sr_state.sids[i] &&
3002 &srs->sr_state.ctxcsn[i] )<= 0 ) {
3008 srs->sr_state.ctxcsn[i].bv_val );
3021 slap_compose_sync_cookie( op, &cookie, a->a_nvals, srs->sr_state.rid,
3036 srs->sr_state.rid,
3133 sync_control *srs;
3155 srs = op->o_controls[slap_cids.sc_LDAPsync];
3160 srs->sr_state.octet_str.bv_val );
3185 if ( srs->sr_state.numcsns == 0 && rs->sr_err == LDAP_NO_SUCH_OBJECT ) {
3198 sop->s_rid = srs->sr_state.rid;
3199 sop->s_sid = srs->sr_state.sid;
3255 if ( srs->sr_state.ctxcsn ) {
3271 for (i=0; i<srs->sr_state.numcsns; ) {
3273 if ( srs->sr_state.sids[i] <= sids[j] ) {
3278 if ( j == numcsns || srs->sr_state.sids[i] != sids[j] ) {
3279 char *tmp = srs->sr_state.ctxcsn[i].bv_val;
3280 srs->sr_state.numcsns--;
3281 for ( j=i; j<srs->sr_state.numcsns; j++ ) {
3282 srs->sr_state.ctxcsn[j] = srs->sr_state.ctxcsn[j+1];
3283 srs->sr_state.sids[j] = srs->sr_state.sids[j+1];
3285 srs->sr_state.ctxcsn[j].bv_val = tmp;
3286 srs->sr_state.ctxcsn[j].bv_len = 0;
3292 if (srs->sr_state.numcsns != numcsns) {
3299 if ( srs->sr_state.ctxcsn ) {
3300 ber_bvarray_free_x( srs->sr_state.ctxcsn, op->o_tmpmemctx );
3301 srs->sr_state.ctxcsn = NULL;
3303 if ( srs->sr_state.sids ) {
3304 slap_sl_free( srs->sr_state.sids, op->o_tmpmemctx );
3305 srs->sr_state.sids = NULL;
3307 srs->sr_state.numcsns = 0;
3314 for ( i=0,j=0; i<srs->sr_state.numcsns; i++ ) {
3316 while ( srs->sr_state.sids[i] != sids[j] ) j++;
3318 &srs->sr_state.ctxcsn[i] ) < 0 ) {
3319 maxcsn = srs->sr_state.ctxcsn[i];
3322 newer = ber_bvcmp( &srs->sr_state.ctxcsn[i], &ctxcsn[j] );
3327 &srs->sr_state.ctxcsn[i] ) > 0 ) {
3328 mincsn = srs->sr_state.ctxcsn[i];
3337 op->o_log_prefix, sids[i], srs->sr_state.ctxcsn[i].bv_val,
3394 if ( syncprov_play_accesslog( op, rs, srs, ctxcsn,
3400 if ( syncprov_play_sessionlog( op, rs, srs, ctxcsn,
3429 ber_bvcmp( &a->a_vals[i], &srs->sr_state.ctxcsn[j] ) <= 0 ) {
3470 if ( si->si_usehint && srs->sr_rhint == 0 ) {
3478 if ( srs->sr_state.ctxcsn ) {
3479 ber_bvarray_free_x( srs->sr_state.ctxcsn, op->o_tmpmemctx );
3480 srs->sr_state.ctxcsn = NULL;
3482 if ( srs->sr_state.sids ) {
3483 slap_sl_free( srs->sr_state.sids, op->o_tmpmemctx );
3484 srs->sr_state.sids = NULL;
3486 srs->sr_state.numcsns = 0;
Indexes created Thu Sep 24 00:25:51 UTC 2026