You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by mf...@apache.org on 2014/06/17 21:45:47 UTC
[04/15] git commit: STREAMS-83 | Updated Sysomos information provider
with running method
STREAMS-83 | Updated Sysomos information provider with running method
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/89b191e1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/89b191e1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/89b191e1
Branch: refs/heads/master
Commit: 89b191e104c94338ccdac6c5fb70dffe1faa38db
Parents: 673b38b
Author: mfranklin <mf...@apache.org>
Authored: Thu Jun 12 11:39:55 2014 -0500
Committer: mfranklin <mf...@apache.org>
Committed: Thu Jun 12 11:39:55 2014 -0500
----------------------------------------------------------------------
.../org/apache/streams/sysomos/provider/SysomosProvider.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/89b191e1/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/provider/SysomosProvider.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/provider/SysomosProvider.java b/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/provider/SysomosProvider.java
index 0073ac2..7d8a35e 100644
--- a/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/provider/SysomosProvider.java
+++ b/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/provider/SysomosProvider.java
@@ -154,6 +154,11 @@ public class SysomosProvider implements StreamsProvider {
}
@Override
+ public boolean isRunning() {
+ return completedHeartbeats.size() < this.getConfig().getHeartbeatIds().size();
+ }
+
+ @Override
public void prepare(Object configurationObject) {
this.providerQueue = constructQueue();
if(configurationObject instanceof Map) {
@@ -187,7 +192,7 @@ public class SysomosProvider implements StreamsProvider {
try {
this.lock.writeLock().lock();
this.completedHeartbeats.add(heartbeatId);
- if(completedHeartbeats.size() == this.getConfig().getHeartbeatIds().size()) {
+ if(!this.isRunning()) {
this.cleanUp();
}
} finally {