version 1.214, 2008/02/10 01:10:28
|
version 1.215, 2008/02/10 23:19:43
|
Line 1566 syncprov_op_response( Operation *op, Sla
|
Line 1566 syncprov_op_response( Operation *op, Sla
|
char cbuf[LDAP_LUTIL_CSNSTR_BUFSIZE]; |
char cbuf[LDAP_LUTIL_CSNSTR_BUFSIZE]; |
int do_check = 0, have_psearches; |
int do_check = 0, have_psearches; |
|
|
/* Don't do any processing for consumer contextCSN updates */ |
|
if ( SLAP_SYNC_SHADOW( op->o_bd ) && |
|
op->o_msgid == SLAP_SYNC_UPDATE_MSGID ) { |
|
return SLAP_CB_CONTINUE; |
|
} |
|
|
|
/* Update our context CSN */ |
/* Update our context CSN */ |
cbuf[0] = '\0'; |
cbuf[0] = '\0'; |
ldap_pvt_thread_rdwr_wlock( &si->si_csn_rwlock ); |
ldap_pvt_thread_rdwr_wlock( &si->si_csn_rwlock ); |
Line 1598 syncprov_op_response( Operation *op, Sla
|
Line 1592 syncprov_op_response( Operation *op, Sla
|
} |
} |
} |
} |
|
|
|
/* Don't do any processing for consumer contextCSN updates */ |
|
if ( SLAP_SYNC_SHADOW( op->o_bd ) && |
|
op->o_msgid == SLAP_SYNC_UPDATE_MSGID ) { |
|
ldap_pvt_thread_rdwr_wunlock( &si->si_csn_rwlock ); |
|
return SLAP_CB_CONTINUE; |
|
} |
|
|
si->si_numops++; |
si->si_numops++; |
if ( si->si_chkops || si->si_chktime ) { |
if ( si->si_chkops || si->si_chktime ) { |
if ( si->si_chkops && si->si_numops >= si->si_chkops ) { |
if ( si->si_chkops && si->si_numops >= si->si_chkops ) { |