You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@jena.apache.org by an...@apache.org on 2015/08/20 20:18:40 UTC
[4/6] jena git commit: JENA-1011 : Make finish idempotent based on
closedByProducer.
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/master
Commit: 503bdcfdff3c46b3887434ae658e213f6bf1b982
Parents: c08f31d
Author: Andy Seaborne <an...@apache.org>
Authored: Thu Aug 20 19:11:55 2015 +0100
Committer: Andy Seaborne <an...@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;
}