-
Notifications
You must be signed in to change notification settings - Fork 33
/
ServerHooksUtils.cpp
43 lines (38 loc) · 1.68 KB
/
ServerHooksUtils.cpp
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
/**
*** Copyright (c) 2016-2019, Jaguar0625, gimre, BloodyRookie, Tech Bureau, Corp.
*** Copyright (c) 2020-present, Jaguar0625, gimre, BloodyRookie.
*** All rights reserved.
***
*** This file is part of Catapult.
***
*** Catapult is free software: you can redistribute it and/or modify
*** it under the terms of the GNU Lesser General Public License as published by
*** the Free Software Foundation, either version 3 of the License, or
*** (at your option) any later version.
***
*** Catapult is distributed in the hope that it will be useful,
*** but WITHOUT ANY WARRANTY; without even the implied warranty of
*** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
*** GNU Lesser General Public License for more details.
***
*** You should have received a copy of the GNU Lesser General Public License
*** along with Catapult. If not, see <http://www.gnu.org/licenses/>.
**/
#include "ServerHooksUtils.h"
namespace catapult { namespace extensions {
namespace {
template<typename TConsumerFactory>
auto CreatePushEntityCallback(const TConsumerFactory& consumerFactory, const extensions::ChainSyncedPredicate& isChainSynced) {
return [isChainSynced, consumer = consumerFactory(disruptor::InputSource::Remote_Push)](auto&& range) {
if (isChainSynced())
consumer(std::move(range));
};
}
}
BlockRangeConsumerFunc CreateBlockPushEntityCallback(const ServerHooks& hooks) {
return CreatePushEntityCallback(hooks.blockRangeConsumerFactory(), hooks.chainSyncedPredicate());
}
TransactionRangeConsumerFunc CreateTransactionPushEntityCallback(const ServerHooks& hooks) {
return CreatePushEntityCallback(hooks.transactionRangeConsumerFactory(), hooks.chainSyncedPredicate());
}
}}