jena-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [08/13] jena git commit: JENA-1011 : Make finish idempotent based on closedByProducer.
Date Thu, 20 Aug 2015 19:03:02 GMT
JENA-1011 : Make finish idempotent based on closedByProducer.


Project: http://git-wip-us.apache.org/repos/asf/jena/repo
Commit: http://git-wip-us.apache.org/repos/asf/jena/commit/503bdcfd
Tree: http://git-wip-us.apache.org/repos/asf/jena/tree/503bdcfd
Diff: http://git-wip-us.apache.org/repos/asf/jena/diff/503bdcfd

Branch: refs/heads/JENA-491-construct-quads
Commit: 503bdcfdff3c46b3887434ae658e213f6bf1b982
Parents: c08f31d
Author: Andy Seaborne <andy@apache.org>
Authored: Thu Aug 20 19:11:55 2015 +0100
Committer: Andy Seaborne <andy@apache.org>
Committed: Thu Aug 20 19:17:56 2015 +0100

----------------------------------------------------------------------
 .../src/main/java/org/apache/jena/riot/lang/PipedRDFIterator.java  | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/jena/blob/503bdcfd/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFIterator.java
----------------------------------------------------------------------
diff --git a/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFIterator.java b/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFIterator.java
index 68395af..3259b9d 100644
--- a/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFIterator.java
+++ b/jena-arq/src/main/java/org/apache/jena/riot/lang/PipedRDFIterator.java
@@ -374,6 +374,8 @@ public class PipedRDFIterator<T> implements Iterator<T>, Closeable
{
      * and error out.
      */
     protected void finish() {
+        if ( closedByProducer )
+            return ;
         receive(endMarker);
         closedByProducer = true;
     }


Mime
View raw message