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 2009/05/09 19:13:05 UTC

svn commit: r773252 - /directory/apacheds/branches/apacheds-replication/syncrepl/src/main/java/org/apache/directory/server/syncrepl/SyncReplConsumer.java

Author: kayyagari
Date: Sat May  9 17:13:05 2009
New Revision: 773252

URL: http://svn.apache.org/viewvc?rev=773252&view=rev
Log:
o removed an un-used method
o set the connection object to null after disconnecting

Modified:
    directory/apacheds/branches/apacheds-replication/syncrepl/src/main/java/org/apache/directory/server/syncrepl/SyncReplConsumer.java

Modified: directory/apacheds/branches/apacheds-replication/syncrepl/src/main/java/org/apache/directory/server/syncrepl/SyncReplConsumer.java
URL: http://svn.apache.org/viewvc/directory/apacheds/branches/apacheds-replication/syncrepl/src/main/java/org/apache/directory/server/syncrepl/SyncReplConsumer.java?rev=773252&r1=773251&r2=773252&view=diff
==============================================================================
--- directory/apacheds/branches/apacheds-replication/syncrepl/src/main/java/org/apache/directory/server/syncrepl/SyncReplConsumer.java (original)
+++ directory/apacheds/branches/apacheds-replication/syncrepl/src/main/java/org/apache/directory/server/syncrepl/SyncReplConsumer.java Sat May  9 17:13:05 2009
@@ -148,19 +148,6 @@
     }
 
 
-    /**
-     * A helper method to check that we didn't get an error.
-     */
-    private static void checkldapResult( LdapConnection connection, LdapResult ldapResult ) throws IOException
-    {
-        if ( ldapResult.getResultCode() != ResultCodeEnum.SUCCESS )
-        {
-            LOG.debug( "failed to bind on the server : " + ldapResult );
-            quit( connection );
-        }
-    }
-
-
     public void init( DirectoryService directoryservice ) throws Exception
     {
         this.directoryService = directoryservice;
@@ -630,6 +617,7 @@
             connection.close();
             LOG.info( "Connection closed for the server {}", config.getProviderHost() );
 
+            connection = null;
             // persist the cookie
             storeCookie();
         }