You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@directory.apache.org by el...@apache.org on 2016/02/03 14:38:25 UTC

svn commit: r1728306 - /directory/shared/trunk/ldap/client/api/src/main/java/org/apache/directory/ldap/client/api/LdapNetworkConnection.java

Author: elecharny
Date: Wed Feb  3 13:38:25 2016
New Revision: 1728306

URL: http://svn.apache.org/viewvc?rev=1728306&view=rev
Log:
o Added an exception if we can't close a cursor
o Added the support of the inputClose() event

Modified:
    directory/shared/trunk/ldap/client/api/src/main/java/org/apache/directory/ldap/client/api/LdapNetworkConnection.java

Modified: directory/shared/trunk/ldap/client/api/src/main/java/org/apache/directory/ldap/client/api/LdapNetworkConnection.java
URL: http://svn.apache.org/viewvc/directory/shared/trunk/ldap/client/api/src/main/java/org/apache/directory/ldap/client/api/LdapNetworkConnection.java?rev=1728306&r1=1728305&r2=1728306&view=diff
==============================================================================
--- directory/shared/trunk/ldap/client/api/src/main/java/org/apache/directory/ldap/client/api/LdapNetworkConnection.java (original)
+++ directory/shared/trunk/ldap/client/api/src/main/java/org/apache/directory/ldap/client/api/LdapNetworkConnection.java Wed Feb  3 13:38:25 2016
@@ -3430,7 +3430,15 @@ public class LdapNetworkConnection exten
             cursor.next();
 
             // And close the cursor
-            cursor.close();
+            try
+            { 
+                cursor.close();
+            }
+            catch ( IOException ioe )
+            {
+                throw new LdapException( ioe.getMessage(), ioe );
+            }
+
         }
         catch ( CursorException e )
         {
@@ -3765,6 +3773,15 @@ public class LdapNetworkConnection exten
 
         conCloseListeners.add( ccListener );
     }
+    
+    
+    /**
+     * {@inheritDoc}
+     */
+    public void inputClosed( IoSession session ) throws Exception 
+    {
+        session.close( true );
+    }
 
 
     /**