Lines Matching defs:ctxcsn
148 BerVarray ctxcsn;
1924 * newer than cookieCSN (srs->sr_state.ctxcsn)
1929 cmp = ber_bvcmp( &csn[0], &srs->sr_state.ctxcsn[i] );
1941 * not newer than snapshot ctxcsn (uuid_progress->ctxcsn)
1946 cmp = ber_bvcmp( &csn[0], &uuid_progress->ctxcsn[i] );
1994 slap_compose_sync_cookie( op, &cookie, srs->sr_state.ctxcsn,
2016 BerVarray ctxcsn, int numcsns, int *sids,
2105 ndel = ber_bvcmp( &se->se_csn, &srs->sr_state.ctxcsn[k] );
2116 ndel = ber_bvcmp( &se->se_csn, &ctxcsn[k] );
2224 slap_compose_sync_cookie( op, &cookie, srs->sr_state.ctxcsn,
2247 BerVarray ctxcsn, int numcsns, int *sids,
2260 .ctxcsn = ctxcsn,
2309 * - the consumer's cookie (srs->sr_state.ctxcsn) has the same sids in the
2310 * same order as ctxcsn
2311 * - at least one of the cookie's csns is older than its ctxcsn counterpart
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];
2350 ber_bvcmp( &newestcsn, &ctxcsn[i] ) < 0 ) {
2351 newestcsn = ctxcsn[i];
2998 if ( srs->sr_state.ctxcsn ) {
3002 &srs->sr_state.ctxcsn[i] )<= 0 ) {
3008 srs->sr_state.ctxcsn[i].bv_val );
3134 BerVarray ctxcsn;
3237 /* snapshot the ctxcsn
3243 ber_bvarray_dup_x( &ctxcsn, si->si_ctxcsn, op->o_tmpmemctx );
3248 ctxcsn = NULL;
3255 if ( srs->sr_state.ctxcsn ) {
3279 char *tmp = srs->sr_state.ctxcsn[i].bv_val;
3282 srs->sr_state.ctxcsn[j] = srs->sr_state.ctxcsn[j+1];
3285 srs->sr_state.ctxcsn[j].bv_val = tmp;
3286 srs->sr_state.ctxcsn[j].bv_len = 0;
3299 if ( srs->sr_state.ctxcsn ) {
3300 ber_bvarray_free_x( srs->sr_state.ctxcsn, op->o_tmpmemctx );
3301 srs->sr_state.ctxcsn = NULL;
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,
3339 ctxcsn[j].bv_val);
3355 ber_bvarray_free_x( ctxcsn, op->o_tmpmemctx );
3381 ber_bvarray_free_x( ctxcsn, op->o_tmpmemctx );
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 ) {
3478 if ( srs->sr_state.ctxcsn ) {
3479 ber_bvarray_free_x( srs->sr_state.ctxcsn, op->o_tmpmemctx );
3480 srs->sr_state.ctxcsn = NULL;
3545 ss->ss_ctxcsn = ctxcsn;
4089 "generated a new ctxcsn=%s for suffix %s\n",
4340 if ( sr->sr_state.ctxcsn ) {
4341 ber_bvarray_free_x( sr->sr_state.ctxcsn, op->o_tmpmemctx );
4342 sr->sr_state.ctxcsn = NULL;
Indexes created Tue May 26 00:24:38 UTC 2026