summaryrefslogtreecommitdiffstats
path: root/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/FileAcquirerImpl.java
diff options
context:
space:
mode:
Diffstat (limited to 'fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/FileAcquirerImpl.java')
-rw-r--r--fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/FileAcquirerImpl.java12
1 files changed, 8 insertions, 4 deletions
diff --git a/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/FileAcquirerImpl.java b/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/FileAcquirerImpl.java
index ab0f7521e7e..bd4401d3cab 100644
--- a/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/FileAcquirerImpl.java
+++ b/fileacquirer/src/main/java/com/yahoo/filedistribution/fileacquirer/FileAcquirerImpl.java
@@ -52,14 +52,18 @@ class FileAcquirerImpl implements FileAcquirer {
private void connect(Timer timer) throws InterruptedException {
while (timer.isTimeLeft()) {
pause();
- target = supervisor.connectSync(spec);
- if (target.isValid()) {
+ target = supervisor.connect(spec);
+ // ping to check if connection is working
+ Request request = new Request("frt.rpc.ping");
+ target.invokeSync(request, 5.0);
+ if (request.isError()) {
+ logWarning();
+ target.close();
+ } else {
log.log(LogLevel.DEBUG, "Successfully connected to '" + spec + "', this = " + System.identityHashCode(this));
pauseTime = 0;
logCount = 0;
return;
- } else {
- logWarning();
}
}
}