airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dimuthu...@apache.org
Subject [airavata] branch staging updated: Logging improvements
Date Tue, 10 Jul 2018 17:06:11 GMT
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 6df7cbc  Logging improvements
6df7cbc is described below

commit 6df7cbc00017236466ae367618b6377296928b6e
Author: dimuthu <dimuthu.upeksha2@gmail.com>
AuthorDate: Tue Jul 10 13:06:04 2018 -0400

    Logging improvements
---
 .../main/java/org/apache/airavata/helix/adaptor/PoolingSSHJClient.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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 768b4e0..13a1c67 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
@@ -129,7 +129,8 @@ public class PoolingSSHJClient extends SSHClient {
                     logger.debug("Session count for selected connection {}. Threshold {}",
minEntry.getValue().getSessionCount(), maxSessionsForConnection);
                     if (minEntry.getValue().getSessionCount() >= maxSessionsForConnection)
{
                         // if it exceeds the maximum session count, create a new connection
-                        logger.debug("Connection with least amount of sessions exceeds the
threshold. So creating a new connection");
+                        logger.debug("Connection with least amount of sessions exceeds the
threshold. So creating a new connection. " +
+                                "Current connection count " + clientInfoMap.size());
                         SSHClient newClient = createNewSSHClient();
                         SSHClientInfo info = new SSHClientInfo(1, System.currentTimeMillis());
                         clientInfoMap.put(newClient, info);


Mime
View raw message