From 0ece30dc7c0e34b4c5911969b8fa99c33c6d023c Mon Sep 17 00:00:00 2001 From: George Hazan Date: Wed, 30 Nov 2022 17:48:47 +0300 Subject: Telegram: update for TDLIB --- .../Telegram/tdlib/td/tdactor/example/example.cpp | 28 +++++++++++----------- 1 file changed, 14 insertions(+), 14 deletions(-) (limited to 'protocols/Telegram/tdlib/td/tdactor/example') diff --git a/protocols/Telegram/tdlib/td/tdactor/example/example.cpp b/protocols/Telegram/tdlib/td/tdactor/example/example.cpp index 4c2415c5e2..8f182d8350 100644 --- a/protocols/Telegram/tdlib/td/tdactor/example/example.cpp +++ b/protocols/Telegram/tdlib/td/tdactor/example/example.cpp @@ -1,31 +1,33 @@ // -// Copyright Aliaksei Levin (levlam@telegram.org), Arseny Smirnov (arseny30@gmail.com) 2014-2018 +// Copyright Aliaksei Levin (levlam@telegram.org), Arseny Smirnov (arseny30@gmail.com) 2014-2022 // // Distributed under the Boost Software License, Version 1.0. (See accompanying // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) // #include "td/actor/actor.h" +#include "td/actor/ConcurrentScheduler.h" #include "td/utils/logging.h" +#include "td/utils/Time.h" -class Worker : public td::Actor { +class Worker final : public td::Actor { public: void ping(int x) { - LOG(ERROR) << "got ping " << x; + LOG(ERROR) << "Got ping " << x; } }; -class MainActor : public td::Actor { +class MainActor final : public td::Actor { public: - void start_up() override { - LOG(ERROR) << "start up"; + void start_up() final { + LOG(ERROR) << "Start up"; set_timeout_in(10); worker_ = td::create_actor_on_scheduler("Worker", 1); send_closure(worker_, &Worker::ping, 123); } - void timeout_expired() override { - LOG(ERROR) << "timeout expired"; + void timeout_expired() final { + LOG(ERROR) << "Timeout expired"; td::Scheduler::instance()->finish(); } @@ -33,17 +35,15 @@ class MainActor : public td::Actor { td::ActorOwn worker_; }; -int main(void) { - td::ConcurrentScheduler scheduler; - scheduler.init(4 /*threads_count*/); +int main() { + td::ConcurrentScheduler scheduler(4 /*thread_count*/, 0); scheduler.start(); { - auto guard = scheduler.get_current_guard(); + auto guard = scheduler.get_main_guard(); td::create_actor_on_scheduler("Main actor", 0).release(); } while (!scheduler.is_finished()) { - scheduler.run_main(10); + scheduler.run_main(td::Timestamp::in(10)); } scheduler.finish(); - return 0; } -- cgit v1.2.3