blob: 0ccfa0ac4e1a7d0d2ed794101bb83519aa15d655 (
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
|
// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#include "bm_storage_message_addresses.h"
#include <vespa/storageapi/messageapi/storagemessage.h>
using storage::api::StorageMessageAddress;
using storage::lib::NodeType;
namespace search::bmcluster {
namespace {
vespalib::string _Storage("storage");
}
BmStorageMessageAddresses::BmStorageMessageAddresses(uint32_t num_nodes, bool distributor)
: _addresses(num_nodes)
{
for (uint32_t node_idx = 0; node_idx < num_nodes; ++node_idx) {
_addresses[node_idx] = std::make_unique<StorageMessageAddress>(&_Storage, distributor ? NodeType::DISTRIBUTOR : NodeType::STORAGE, node_idx);
}
}
BmStorageMessageAddresses::~BmStorageMessageAddresses() = default;
}
|