svn commit: r1619783 - /lucene/dev/trunk/solr/core/src/java/org/apache/solr/response/SortingResponseWriter.java

[jb...@apache.org]

Author: jbernste
Date: Fri Aug 22 12:40:39 2014
New Revision: 1619783

URL: http://svn.apache.org/r1619783
Log:
 SOLR-5244: Exporting Full Sorted Result Sets

Modified:
    lucene/dev/trunk/solr/core/src/java/org/apache/solr/response/SortingResponseWriter.java

Modified: lucene/dev/trunk/solr/core/src/java/org/apache/solr/response/SortingResponseWriter.java
URL: http://svn.apache.org/viewvc/lucene/dev/trunk/solr/core/src/java/org/apache/solr/response/SortingResponseWriter.java?rev=1619783&r1=1619782&r2=1619783&view=diff
==============================================================================
--- lucene/dev/trunk/solr/core/src/java/org/apache/solr/response/SortingResponseWriter.java (original)
+++ lucene/dev/trunk/solr/core/src/java/org/apache/solr/response/SortingResponseWriter.java Fri Aug 22 12:40:39 2014
@@ -72,7 +72,9 @@ public class SortingResponseWriter imple
   public void write(Writer writer, SolrQueryRequest req, SolrQueryResponse res) throws IOException {
     Exception e1 = res.getException();
     if(e1 != null) {
-      e1.printStackTrace(new PrintWriter(writer));
+      if(!(e1 instanceof IgnoreException)) {
+        e1.printStackTrace(new PrintWriter(writer));
+      }
       return;
     }
     SolrRequestInfo info = SolrRequestInfo.getRequestInfo();
@@ -175,8 +177,7 @@ public class SortingResponseWriter imple
         while(ex != null) {
           String m = ex.getMessage();
           if(m != null && m.contains("Broken pipe")) {
-            logger.info("Early client disconnect during export");
-            return;
+            throw new IgnoreException();
           }
           ex = ex.getCause();
         }
@@ -194,7 +195,16 @@ public class SortingResponseWriter imple
     writer.flush();
   }
 
+  public static class IgnoreException extends IOException {
+    public void printStackTrace(PrintWriter pw) {
+      pw.print("Early Client Disconnect");
+
+    }
 
+    public String getMessage() {
+      return "Early Client Disconnect";
+    }
+  }
 
 
   protected void writeDoc(SortDoc sortDoc,