You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sc...@apache.org on 2016/05/02 19:40:09 UTC
airavata git commit: credential store client initialization retry
attempts
Repository: airavata
Updated Branches:
refs/heads/develop 5f59387a8 -> 3418fda51
credential store client initialization retry attempts
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/3418fda5
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/3418fda5
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/3418fda5
Branch: refs/heads/develop
Commit: 3418fda517036442769ec14385d0dd4e79e273cd
Parents: 5f59387
Author: scnakandala <su...@gmail.com>
Authored: Mon May 2 13:40:04 2016 -0400
Committer: scnakandala <su...@gmail.com>
Committed: Mon May 2 13:40:04 2016 -0400
----------------------------------------------------------------------
.../store/client/CredentialStoreClientFactory.java | 8 ++++++++
1 file changed, 8 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/3418fda5/modules/credential-store/credential-store-stubs/src/main/java/org/apache/airavata/credential/store/client/CredentialStoreClientFactory.java
----------------------------------------------------------------------
diff --git a/modules/credential-store/credential-store-stubs/src/main/java/org/apache/airavata/credential/store/client/CredentialStoreClientFactory.java b/modules/credential-store/credential-store-stubs/src/main/java/org/apache/airavata/credential/store/client/CredentialStoreClientFactory.java
index 1e2fb76..7f49c10 100644
--- a/modules/credential-store/credential-store-stubs/src/main/java/org/apache/airavata/credential/store/client/CredentialStoreClientFactory.java
+++ b/modules/credential-store/credential-store-stubs/src/main/java/org/apache/airavata/credential/store/client/CredentialStoreClientFactory.java
@@ -35,6 +35,14 @@ public class CredentialStoreClientFactory {
try {
TTransport transport = new TSocket(serverHost, serverPort);
transport.open();
+ int maxWaitTime = 4;
+ while(!transport.isOpen() && maxWaitTime > 0){
+ try {
+ Thread.sleep(3000);
+ } catch (InterruptedException e) {}
+ maxWaitTime--;
+ transport.open();
+ }
TProtocol protocol = new TBinaryProtocol(transport);
return new CredentialStoreService.Client(protocol);
} catch (TTransportException e) {