ITS#6717 refine mincsn check for MMR

diff --git a/servers/slapd/overlays/syncprov.c b/servers/slapd/overlays/syncprov.c
index ff517e275b2a24538dd19d917ce01ec362c6d432..14aed8cbd7a6e0a209f53756b15262706eae1413 100644 (file)
--- a/servers/slapd/overlays/syncprov.c
+++ b/servers/slapd/overlays/syncprov.c
@@ -2414,7 +2414,7 @@ syncprov_op_search( Operation *op, SlapReply *rs )
        sync_control *srs;
        BerVarray ctxcsn;
        int i, *sids, numcsns;
-       struct berval mincsn;
+       struct berval mincsn, maxcsn;
        int dirty = 0;
 
        if ( !(op->o_sync_mode & SLAP_SYNC_REFRESH) ) return SLAP_CB_CONTINUE;
@@ -2529,12 +2529,27 @@ syncprov_op_search( Operation *op, SlapReply *rs )
                        i++;
                }
 
-               /* Find the smallest CSN */
-               mincsn = srs->sr_state.ctxcsn[0];
-               for ( i=1; i<srs->sr_state.numcsns; i++ ) {
-                       if ( ber_bvcmp( &mincsn, &srs->sr_state.ctxcsn[i] ) > 0 )
-                               mincsn = srs->sr_state.ctxcsn[i];
-               }
+               /* Find the smallest CSN which differs from contextCSN */
+               mincsn.bv_len = 0;
+               maxcsn.bv_len = 0;
+               for ( i=0; i<srs->sr_state.numcsns; i++ ) {
+                       for ( j=0; j<numcsns; j++ ) {
+                               if ( srs->sr_state.sids[i] != sids[j] )
+                                       continue;
+                               if ( BER_BVISEMPTY( &maxcsn ) || ber_bvcmp( &maxcsn,
+                                       &srs->sr_state.ctxcsn[i] ) < 0 ) {
+                                       maxcsn = srs->sr_state.ctxcsn[i];
+                               }
+                               if ( ber_bvcmp( &srs->sr_state.ctxcsn[i], &ctxcsn[j] ) < 0) {
+                                       if ( BER_BVISEMPTY( &mincsn ) || ber_bvcmp( &mincsn,
+                                               &srs->sr_state.ctxcsn[i] ) > 0 ) {
+                                               mincsn = srs->sr_state.ctxcsn[i];
+                                       }
+                               }
+                       }
+               }
+               if ( BER_BVISEMPTY( &mincsn ))
+                       mincsn = maxcsn;
 
                /* If nothing has changed, shortcut it */
                if ( srs->sr_state.numcsns == numcsns ) {