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 2009/07/22 15:23:56 UTC
svn commit: r796709 -
/directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/handlers/SearchHandler.java
Author: elecharny
Date: Wed Jul 22 13:23:56 2009
New Revision: 796709
URL: http://svn.apache.org/viewvc?rev=796709&view=rev
Log:
Added some specific code to handle an abandonrequest
Added some logs
Modified:
directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/handlers/SearchHandler.java
Modified: directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/handlers/SearchHandler.java
URL: http://svn.apache.org/viewvc/directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/handlers/SearchHandler.java?rev=796709&r1=796708&r2=796709&view=diff
==============================================================================
--- directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/handlers/SearchHandler.java (original)
+++ directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/handlers/SearchHandler.java Wed Jul 22 13:23:56 2009
@@ -317,8 +317,20 @@
while ( (count < sizeLimit ) && cursor.next() )
{
+ // Handle closed session
if ( session.getIoSession().isClosing() )
{
+ // The client has closed the connection
+ LOG.debug( "Request terminated for message {}, the client has closed the session",
+ req.getMessageId() );
+ break;
+ }
+
+ if ( cursor.isClosed() )
+ {
+ // The cursor has been closed by an abandon request.
+ LOG.debug( "Request terminated by an AbandonRequest for message {}",
+ req.getMessageId() );
break;
}