directory-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kayyag...@apache.org
Subject svn commit: r1486738 - /directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/replication/consumer/ReplicationConsumerImpl.java
Date Tue, 28 May 2013 05:07:39 GMT
Author: kayyagari
Date: Tue May 28 05:07:39 2013
New Revision: 1486738

URL: http://svn.apache.org/r1486738
Log:
o replicate createTimestamp and creatorsName attributes
o cleaned up connectionClosed()

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

Modified: directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/replication/consumer/ReplicationConsumerImpl.java
URL: http://svn.apache.org/viewvc/directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/replication/consumer/ReplicationConsumerImpl.java?rev=1486738&r1=1486737&r2=1486738&view=diff
==============================================================================
--- directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/replication/consumer/ReplicationConsumerImpl.java
(original)
+++ directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/replication/consumer/ReplicationConsumerImpl.java
Tue May 28 05:07:39 2013
@@ -126,7 +126,7 @@ public class ReplicationConsumerImpl imp
     private SchemaManager schemaManager;
 
     /** flag to indicate whether the consumer was disconnected */
-    private boolean disconnected;
+    private volatile boolean disconnected;
 
     /** the core session */
     private CoreSession session;
@@ -136,8 +136,6 @@ public class ReplicationConsumerImpl imp
         {
             SchemaConstants.ENTRY_UUID_AT,
             SchemaConstants.ENTRY_DN_AT,
-            SchemaConstants.CREATE_TIMESTAMP_AT,
-            SchemaConstants.CREATORS_NAME_AT,
             SchemaConstants.ENTRY_PARENT_ID_AT,
             SchemaConstants.COLLECTIVE_ATTRIBUTE_SUBENTRIES_AT
     };
@@ -539,17 +537,7 @@ public class ReplicationConsumerImpl imp
                 config.getProducer() );
         }
 
-        // Cleanup
-        disconnected = true;
-        connection = null;
-
-        // persist the cookie
-        storeCookie();
-
-        // reset the cookie
-        syncCookie = null;
-
-        return;
+        disconnect();
     }
 
 



Mime
View raw message