blob: c8e96707b0864a280f75dea4e14f2f0ec441dba9 (
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
42
43
44
45
46
47
48
|
// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#pragma once
#include <vespa/fnet/frt/invokable.h>
#include <atomic>
#include <memory>
class FRT_RPCRequest;
namespace storage {
class MessageDispatcher;
namespace api {
class StorageCommand;
class StorageMessage;
class StorageMessageAddress;
class StorageReply;
}
namespace rpc {
class SharedRpcResources;
class ClusterControllerApiRpcService : public FRT_Invokable {
MessageDispatcher& _message_dispatcher;
std::atomic<bool> _closed;
public:
static constexpr uint32_t StateBundleMaxUncompressedSize = 1024 * 1024 * 16;
ClusterControllerApiRpcService(MessageDispatcher& message_dispatcher,
SharedRpcResources& rpc_resources);
~ClusterControllerApiRpcService() override;
void close();
void RPC_getNodeState2(FRT_RPCRequest* req);
void RPC_setSystemState2(FRT_RPCRequest* req);
void RPC_setDistributionStates(FRT_RPCRequest* req);
void RPC_activateClusterStateVersion(FRT_RPCRequest* req);
private:
void register_server_methods(SharedRpcResources&);
// TODO factor out as shared functionality
void detach_and_forward_to_enqueuer(std::shared_ptr<api::StorageMessage> cmd, FRT_RPCRequest* req);
};
} // rpc
} // storage
|
