This is an automated email from the ASF dual-hosted git repository.
dimuthuupe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airavata.git
The following commit(s) were added to refs/heads/master by this push:
new 4ec7a7c Minor logging improvements
4ec7a7c is described below
commit 4ec7a7c6defe1f627e48b130f9ce2b562989eefc
Author: Dimuthu Wannipurage <[email protected]>
AuthorDate: Mon Jun 3 14:42:27 2019 -0400
Minor logging improvements
---
.../org/apache/airavata/helix/core/participant/HelixParticipant.java | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/modules/airavata-helix/task-core/src/main/java/org/apache/airavata/helix/core/participant/HelixParticipant.java
b/modules/airavata-helix/task-core/src/main/java/org/apache/airavata/helix/core/participant/HelixParticipant.java
index d825cb8..fbf08f3 100644
---
a/modules/airavata-helix/task-core/src/main/java/org/apache/airavata/helix/core/participant/HelixParticipant.java
+++
b/modules/airavata-helix/task-core/src/main/java/org/apache/airavata/helix/core/participant/HelixParticipant.java
@@ -100,10 +100,12 @@ public class HelixParticipant<T extends AbstractTask>
implements Runnable {
}
public void registerRunningTask(AbstractTask task) {
+ logger.info("Registering Task " + task.getTaskId() + ". Currently
available " + runningTasks.size());
runningTasks.add(task);
}
public void unregisterRunningTask(AbstractTask task) {
+ logger.info("Un registering Task " + task.getTaskId() + ". Currently
available " + runningTasks.size());
runningTasks.remove(task);
}
@@ -205,6 +207,7 @@ public class HelixParticipant<T extends AbstractTask>
implements Runnable {
}
private void disconnect() {
+ logger.info("Shutting down participant. Currently available tasks " +
runningTasks.size());
if (zkHelixManager != null) {
if (runningTasks.size() > 0) {
for (int i = 0; i <= shutdownGraceRetries; i++) {
