mirror of
https://github.com/ton-blockchain/ton
synced 2025-03-09 15:40:10 +00:00
0434eadc1f
* Private overlay for external messages * Improve ext msg overlays * Manage from validator console * Bypass out queue size limit for high-priority messages * Shuffle messages in get_external_messages * Cleanup mempool when creating validator group * Improve private overlays for externals 1. Allow using validator adnl ids in addition to fullnode ids 2. Set priority per sender, not per overlay 3. Require the same overlay name for all nodes 4. Enable lz4 in private block overlay * Fix typo, add debug logs * Enable lz4 in private block overlay by config Change proto_version for lz4 in catchain overlays to 4 * Add logs for broadcasts in fullnode --------- Co-authored-by: SpyCheese <mikle98@yandex.ru>
106 lines
4.3 KiB
C++
106 lines
4.3 KiB
C++
/*
|
|
This file is part of TON Blockchain Library.
|
|
|
|
TON Blockchain Library 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 2 of the License, or
|
|
(at your option) any later version.
|
|
|
|
TON Blockchain Library 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 TON Blockchain Library. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
Copyright 2017-2020 Telegram Systems LLP
|
|
*/
|
|
#pragma once
|
|
|
|
#include <vector>
|
|
#include <utility>
|
|
|
|
#include "ton/ton-types.h"
|
|
|
|
#include "td/actor/actor.h"
|
|
|
|
#include "adnl/adnl.h"
|
|
#include "rldp/rldp.h"
|
|
#include "rldp2/rldp.h"
|
|
#include "dht/dht.h"
|
|
#include "overlay/overlays.h"
|
|
#include "validator/validator.h"
|
|
#include "adnl/adnl-ext-client.h"
|
|
|
|
namespace ton {
|
|
|
|
namespace validator {
|
|
|
|
namespace fullnode {
|
|
|
|
constexpr int VERBOSITY_NAME(FULL_NODE_WARNING) = verbosity_WARNING;
|
|
constexpr int VERBOSITY_NAME(FULL_NODE_NOTICE) = verbosity_INFO;
|
|
constexpr int VERBOSITY_NAME(FULL_NODE_INFO) = verbosity_DEBUG;
|
|
constexpr int VERBOSITY_NAME(FULL_NODE_DEBUG) = verbosity_DEBUG;
|
|
constexpr int VERBOSITY_NAME(FULL_NODE_EXTRA_DEBUG) = verbosity_DEBUG + 1;
|
|
|
|
struct FullNodeConfig {
|
|
FullNodeConfig() = default;
|
|
FullNodeConfig(const tl_object_ptr<ton_api::engine_validator_fullNodeConfig>& obj);
|
|
tl_object_ptr<ton_api::engine_validator_fullNodeConfig> tl() const;
|
|
bool operator==(const FullNodeConfig& rhs) const;
|
|
bool operator!=(const FullNodeConfig& rhs) const;
|
|
|
|
bool ext_messages_broadcast_disabled_ = false;
|
|
};
|
|
|
|
class FullNode : public td::actor::Actor {
|
|
public:
|
|
virtual ~FullNode() = default;
|
|
|
|
virtual void update_dht_node(td::actor::ActorId<dht::Dht> dht) = 0;
|
|
|
|
virtual void add_permanent_key(PublicKeyHash key, td::Promise<td::Unit> promise) = 0;
|
|
virtual void del_permanent_key(PublicKeyHash key, td::Promise<td::Unit> promise) = 0;
|
|
|
|
virtual void sign_shard_overlay_certificate(ShardIdFull shard_id, PublicKeyHash signed_key,
|
|
td::uint32 expiry_at, td::uint32 max_size,
|
|
td::Promise<td::BufferSlice> promise) = 0;
|
|
virtual void import_shard_overlay_certificate(ShardIdFull shard_id, PublicKeyHash signed_key,
|
|
std::shared_ptr<ton::overlay::Certificate> cert,
|
|
td::Promise<td::Unit> promise) = 0;
|
|
|
|
virtual void update_adnl_id(adnl::AdnlNodeIdShort adnl_id, td::Promise<td::Unit> promise) = 0;
|
|
virtual void set_config(FullNodeConfig config) = 0;
|
|
|
|
virtual void add_ext_msg_overlay(std::vector<adnl::AdnlNodeIdShort> nodes,
|
|
std::map<adnl::AdnlNodeIdShort, int> senders, std::string name,
|
|
td::Promise<td::Unit> promise) = 0;
|
|
virtual void del_ext_msg_overlay(std::string name, td::Promise<td::Unit> promise) = 0;
|
|
|
|
static constexpr td::uint32 max_block_size() {
|
|
return 4 << 20;
|
|
}
|
|
static constexpr td::uint32 max_proof_size() {
|
|
return 4 << 20;
|
|
}
|
|
static constexpr td::uint64 max_state_size() {
|
|
return 4ull << 30;
|
|
}
|
|
|
|
static td::actor::ActorOwn<FullNode> create(ton::PublicKeyHash local_id, adnl::AdnlNodeIdShort adnl_id,
|
|
FileHash zero_state_file_hash, FullNodeConfig config,
|
|
td::actor::ActorId<keyring::Keyring> keyring,
|
|
td::actor::ActorId<adnl::Adnl> adnl, td::actor::ActorId<rldp::Rldp> rldp,
|
|
td::actor::ActorId<rldp2::Rldp> rldp2, td::actor::ActorId<dht::Dht> dht,
|
|
td::actor::ActorId<overlay::Overlays> overlays,
|
|
td::actor::ActorId<ValidatorManagerInterface> validator_manager,
|
|
td::actor::ActorId<adnl::AdnlExtClient> client, std::string db_root);
|
|
};
|
|
|
|
} // namespace fullnode
|
|
|
|
} // namespace validator
|
|
|
|
} // namespace ton
|