You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by di...@apache.org on 2018/07/11 13:51:56 UTC
[airavata] branch staging updated: Minor log level changes
This is an automated email from the ASF dual-hosted git repository.
dimuthuupe pushed a commit to branch staging
in repository https://gitbox.apache.org/repos/asf/airavata.git
The following commit(s) were added to refs/heads/staging by this push:
new 93bfe76 Minor log level changes
93bfe76 is described below
commit 93bfe76c9278119995df7a4449e2d978349859b6
Author: dimuthu <di...@gmail.com>
AuthorDate: Wed Jul 11 09:51:49 2018 -0400
Minor log level changes
---
.../java/org/apache/airavata/helix/adaptor/PoolingSSHJClient.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/modules/airavata-helix/agent-impl/sshj-agent/src/main/java/org/apache/airavata/helix/adaptor/PoolingSSHJClient.java b/modules/airavata-helix/agent-impl/sshj-agent/src/main/java/org/apache/airavata/helix/adaptor/PoolingSSHJClient.java
index 3e4411d..75ab626 100644
--- a/modules/airavata-helix/agent-impl/sshj-agent/src/main/java/org/apache/airavata/helix/adaptor/PoolingSSHJClient.java
+++ b/modules/airavata-helix/agent-impl/sshj-agent/src/main/java/org/apache/airavata/helix/adaptor/PoolingSSHJClient.java
@@ -202,13 +202,13 @@ public class PoolingSSHJClient extends SSHClient {
private void removeStaleConnections() {
List<Map.Entry<SSHClient, SSHClientInfo>> entriesTobeRemoved;
lock.writeLock().lock();
- logger.debug("Removing stale connections for host {}", host);
+ logger.info("Removing stale connections for host {}", host);
try {
entriesTobeRemoved = clientInfoMap.entrySet().stream().filter(entry ->
((entry.getValue().getSessionCount() == 0) &&
(entry.getValue().getLastAccessedTime() + maxConnectionIdleTimeMS < System.currentTimeMillis()))).collect(Collectors.toList());
entriesTobeRemoved.forEach(entry -> {
- logger.debug("Removing connection {} due to inactivity for host {}", entry.getValue().getClientId(), host);
+ logger.info("Removing connection {} due to inactivity for host {}", entry.getValue().getClientId(), host);
clientInfoMap.remove(entry.getKey());
});
} finally {