directory-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From elecha...@apache.org
Subject svn commit: r1415013 - /directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/handlers/response/SearchResultReferenceHandler.java
Date Thu, 29 Nov 2012 00:46:39 GMT
Author: elecharny
Date: Thu Nov 29 00:46:38 2012
New Revision: 1415013

URL: http://svn.apache.org/viewvc?rev=1415013&view=rev
Log:
Added some minimal code to manage messageSent events in the SearchhResultReference handler

Modified:
    directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/handlers/response/SearchResultReferenceHandler.java

Modified: directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/handlers/response/SearchResultReferenceHandler.java
URL: http://svn.apache.org/viewvc/directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/handlers/response/SearchResultReferenceHandler.java?rev=1415013&r1=1415012&r2=1415013&view=diff
==============================================================================
--- directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/handlers/response/SearchResultReferenceHandler.java
(original)
+++ directory/apacheds/trunk/protocol-ldap/src/main/java/org/apache/directory/server/ldap/handlers/response/SearchResultReferenceHandler.java
Thu Nov 29 00:46:38 2012
@@ -20,6 +20,7 @@
 package org.apache.directory.server.ldap.handlers.response;
 
 
+import org.apache.directory.server.core.api.SearchRequestContainer;
 import org.apache.directory.server.ldap.LdapSession;
 import org.apache.directory.server.ldap.handlers.LdapResponseHandler;
 import org.apache.directory.shared.ldap.model.message.SearchResultReference;
@@ -38,5 +39,13 @@ public class SearchResultReferenceHandle
     public void handle( LdapSession session, SearchResultReference searchResultReference
) throws Exception
     {
         LOG.debug( "Message Sent : {}", searchResultReference );
+        SearchRequestContainer searchRequestContainer = session.getSearchRequest( searchResultReference.getMessageId()
);
+        
+        if ( searchRequestContainer != null )
+        {
+            searchRequestContainer.increment();
+        }
+        
+        //System.out.println( "SearchResultReference : " + searchRequestContainer );
     }
 }



Mime
View raw message