external/ton
1
0
Fork 0
mirror of https://github.com/ton-blockchain/ton synced 2025-03-09 15:40:10 +00:00
Code Issues Releases Wiki Activity

--shutdown-at parameter for validator-engine (#745)

Browse source 
Co-authored-by: SpyCheese <mikle98@yandex.ru>
This commit is contained in:
EmelyanenkoK 2023-07-14 15:39:03 +03:00 • committed by GitHub
parent f923b96a2f
commit afb630bf41
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 19 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

18
validator-engine/validator-engine.cpp
View file

@ -71,6 +71,7 @@
#include "git.h" #include "git.h"
#include "block-auto.h" #include "block-auto.h"
#include "block-parse.h" #include "block-parse.h"
#include "common/delay.h"
Config::Config() { Config::Config() {
out_port = 3278; out_port = 3278;
@ -1174,6 +1175,18 @@ void ValidatorEngine::set_global_config(std::string str) {
void ValidatorEngine::set_db_root(std::string db_root) { void ValidatorEngine::set_db_root(std::string db_root) {
db_root_ = db_root; db_root_ = db_root;
} }
void ValidatorEngine::schedule_shutdown(double at) {
td::Timestamp ts = td::Timestamp::at_unix(at);
if (ts.is_in_past()) {
LOG(DEBUG) << "Scheduled shutdown is in past (" << at << ")";
} else {
LOG(INFO) << "Schedule shutdown for " << at << " (in " << ts.in() << "s)";
ton::delay_action([]() {
LOG(WARNING) << "Shutting down as scheduled";
std::_Exit(0);
}, ts);
}
}
void ValidatorEngine::start_up() { void ValidatorEngine::start_up() {
alarm_timestamp() = td::Timestamp::in(1.0 + td::Random::fast(0, 100) * 0.01); alarm_timestamp() = td::Timestamp::in(1.0 + td::Random::fast(0, 100) * 0.01);
} }
@ -3743,6 +3756,11 @@ int main(int argc, char *argv[]) {
return td::Status::OK(); return td::Status::OK();
}); });
p.add_checked_option('u', "user", "change user", [&](td::Slice user) { return td::change_user(user.str()); }); p.add_checked_option('u', "user", "change user", [&](td::Slice user) { return td::change_user(user.str()); });
p.add_checked_option('\0', "shutdown-at", "stop validator at the given time (unix timestamp)", [&](td::Slice arg) {
TRY_RESULT(at, td::to_integer_safe<td::uint32>(arg));
acts.push_back([&x, at]() { td::actor::send_closure(x, &ValidatorEngine::schedule_shutdown, (double)at); });
return td::Status::OK();
});
auto S = p.run(argc, argv); auto S = p.run(argc, argv);
if (S.is_error()) { if (S.is_error()) {
LOG(ERROR) << "failed to parse options: " << S.move_as_error(); LOG(ERROR) << "failed to parse options: " << S.move_as_error();

1
validator-engine/validator-engine.hpp
View file

@ -256,6 +256,7 @@ class ValidatorEngine : public td::actor::Actor {
void add_key_to_set(ton::PublicKey key) { void add_key_to_set(ton::PublicKey key) {
keys_[key.compute_short_id()] = key; keys_[key.compute_short_id()] = key;
} }
void schedule_shutdown(double at);
void start_up() override; void start_up() override;
ValidatorEngine() { ValidatorEngine() {
} }