svn commit: r1903673 - in /manifoldcf/trunk: CHANGES.txt connectors/generic/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/generic/GenericConnector.java

[kwright]

Author: kwright
Date: Thu Aug 25 10:41:43 2022
New Revision: 1903673

URL: http://svn.apache.org/viewvc?rev=1903673&view=rev
Log:
Fix for CONNECTORS-1724

Modified:
    manifoldcf/trunk/CHANGES.txt
    
manifoldcf/trunk/connectors/generic/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/generic/GenericConnector.java

Modified: manifoldcf/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/manifoldcf/trunk/CHANGES.txt?rev=1903673&r1=1903672&r2=1903673&view=diff
==============================================================================
--- manifoldcf/trunk/CHANGES.txt (original)
+++ manifoldcf/trunk/CHANGES.txt Thu Aug 25 10:41:43 2022
@@ -3,6 +3,8 @@ $Id$
 
 ======================= 2.24-dev =====================
 
+CONNECTORS-1724: Free up crossthread buffer when error returned in 
GenericConnector.
+(Nguyen Huu)
 
 ======================= Release 2.23 =====================
 

Modified: 
manifoldcf/trunk/connectors/generic/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/generic/GenericConnector.java
URL: 
http://svn.apache.org/viewvc/manifoldcf/trunk/connectors/generic/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/generic/GenericConnector.java?rev=1903673&r1=1903672&r2=1903673&view=diff
==============================================================================
--- 
manifoldcf/trunk/connectors/generic/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/generic/GenericConnector.java
 (original)
+++ 
manifoldcf/trunk/connectors/generic/connector/src/main/java/org/apache/manifoldcf/crawler/connectors/generic/GenericConnector.java
 Thu Aug 25 10:41:43 2022
@@ -1152,6 +1152,7 @@ public class GenericConnector extends Ba
         } finally {
           EntityUtils.consume(response.getEntity());
           method.releaseConnection();
+          seedBuffer.signalDone();
         }
       } catch (IOException ex) {
         exception = ex;