You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@directory.apache.org by ka...@apache.org on 2010/05/22 12:20:38 UTC

svn commit: r947277 - /directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/replication/SyncReplConsumer.java

Author: kayyagari
Date: Sat May 22 10:20:38 2010
New Revision: 947277

URL: http://svn.apache.org/viewvc?rev=947277&view=rev
Log:
o fixed an issue with updating entry sent to a consumer in refreshNPersist mode
  (when such a consumer can't be reachable for some reason and a MODIFY event happens on provider's DIT during that time
   then that will be sent to the client as a ADD event when the consumer comes back and resumes the session again)

Modified:
    directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/replication/SyncReplConsumer.java

Modified: directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/replication/SyncReplConsumer.java
URL: http://svn.apache.org/viewvc/directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/replication/SyncReplConsumer.java?rev=947277&r1=947276&r2=947277&view=diff
==============================================================================
--- directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/replication/SyncReplConsumer.java (original)
+++ directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/replication/SyncReplConsumer.java Sat May 22 10:20:38 2010
@@ -367,8 +367,7 @@ public class SyncReplConsumer implements
                         LOG.debug( remoteEntry.toString() );
                         session.add( new DefaultEntry( schemaManager, remoteEntry ) );
                     }
-                    // in refreshOnly mode the modified entry will be sent with state ADD
-                    else if ( !config.isRefreshNPersist() )
+                    else
                     {
                         LOG.debug( "updating entry in refreshOnly mode {}", remoteEntry.getDn().getName() );
                         modify( remoteEntry );