blob: f38875b5727350265cd012feedf513eab63dddfb (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
|
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#include "file_acquirer.h"
#include <vespa/fnet/frt/supervisor.h>
#include <vespa/fnet/frt/target.h>
#include <vespa/fnet/frt/rpcrequest.h>
#include <vespa/fnet/transport.h>
#include <vespa/log/log.h>
LOG_SETUP(".config.file_acquirer");
namespace config {
RpcFileAcquirer::RpcFileAcquirer(FNET_Transport & transport, const vespalib::string &spec)
: _orb(std::make_unique<FRT_Supervisor>(&transport)),
_spec(spec)
{ }
vespalib::string
RpcFileAcquirer::wait_for(const vespalib::string &file_ref, double timeout_s)
{
vespalib::string path;
FRT_Target *target = _orb->GetTarget(_spec.c_str());
FRT_RPCRequest *req = _orb->AllocRPCRequest();
req->SetMethodName("waitFor");
req->GetParams()->AddString(file_ref.data(), file_ref.size());
target->InvokeSync(req, timeout_s);
if(req->CheckReturnTypes("s")) {
path = req->GetReturn()->GetValue(0)._string._str;
} else {
LOG(warning, "could not acquire file '%s' (%d: %s)",
file_ref.c_str(), req->GetErrorCode(), req->GetErrorMessage());
}
req->internal_subref();
target->internal_subref();
return path;
}
RpcFileAcquirer::~RpcFileAcquirer() = default;
} // namespace config
|
