You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@marmotta.apache.org by ss...@apache.org on 2013/09/30 18:45:09 UTC
[32/50] [abbrv] git commit: reasoner force shutdown: make sure there
are no more tasks in the queue
reasoner force shutdown: make sure there are no more tasks in the queue
Project: http://git-wip-us.apache.org/repos/asf/incubator-marmotta/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-marmotta/commit/4ad75ef7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-marmotta/tree/4ad75ef7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-marmotta/diff/4ad75ef7
Branch: refs/heads/master
Commit: 4ad75ef7e7b30d3416afb2b8f5e9fafc5cea5204
Parents: 5088304
Author: Sebastian Schaffert <ss...@apache.org>
Authored: Fri Sep 13 13:27:38 2013 +0200
Committer: Sebastian Schaffert <ss...@apache.org>
Committed: Fri Sep 13 13:27:38 2013 +0200
----------------------------------------------------------------------
.../org/apache/marmotta/kiwi/reasoner/engine/ReasoningEngine.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-marmotta/blob/4ad75ef7/libraries/kiwi/kiwi-reasoner/src/main/java/org/apache/marmotta/kiwi/reasoner/engine/ReasoningEngine.java
----------------------------------------------------------------------
diff --git a/libraries/kiwi/kiwi-reasoner/src/main/java/org/apache/marmotta/kiwi/reasoner/engine/ReasoningEngine.java b/libraries/kiwi/kiwi-reasoner/src/main/java/org/apache/marmotta/kiwi/reasoner/engine/ReasoningEngine.java
index 1b189d8..0e86f8d 100644
--- a/libraries/kiwi/kiwi-reasoner/src/main/java/org/apache/marmotta/kiwi/reasoner/engine/ReasoningEngine.java
+++ b/libraries/kiwi/kiwi-reasoner/src/main/java/org/apache/marmotta/kiwi/reasoner/engine/ReasoningEngine.java
@@ -905,6 +905,7 @@ public class ReasoningEngine implements TransactionListener {
if(force) {
log.warn("forced shutdown of reasoning service initiated, state will be inconsistent ...");
+ reasoningQueue.clear();
reasonerThread.shutdown(true);
for(int i = 0; i<3 && isRunning(); i++) {