diff options
| author | levlam <levlam@telegram.org> | 2024-02-01 20:31:43 +0300 |
|---|---|---|
| committer | levlam <levlam@telegram.org> | 2024-02-01 20:31:43 +0300 |
| commit | b9e339c934fc9aa19867291c9eaf6bc31e41b611 (patch) | |
| tree | 9d0255d96837ecea9d1dd575f1ca7d530965805d /tdactor/td | |
| parent | c287f02e9a284720e413650a1a5031c4240a6a5f (diff) | |
Improve ServiceActor logging.
Diffstat (limited to 'tdactor/td')
| -rw-r--r-- | tdactor/td/actor/impl/Scheduler.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/tdactor/td/actor/impl/Scheduler.cpp b/tdactor/td/actor/impl/Scheduler.cpp index 46c436c22..0ea0eb78a 100644 --- a/tdactor/td/actor/impl/Scheduler.cpp +++ b/tdactor/td/actor/impl/Scheduler.cpp @@ -24,6 +24,7 @@ #include "td/utils/port/thread_local.h" #include "td/utils/Promise.h" #include "td/utils/ScopeGuard.h" +#include "td/utils/SliceBuilder.h" #include "td/utils/Time.h" #include <functional> @@ -80,6 +81,7 @@ void Scheduler::ServiceActor::start_up() { void Scheduler::ServiceActor::loop() { auto &queue = inbound_; int ready_n = queue->reader_wait_nonblock(); + VLOG(actor) << "Have " << ready_n << " pending events"; if (ready_n == 0) { return; } @@ -228,7 +230,7 @@ void Scheduler::init(int32 id, std::vector<std::shared_ptr<MpscPollableQueue<Eve sched_id_ = id; sched_n_ = static_cast<int32>(outbound_queues_.size()); service_actor_.set_queue(inbound_queue_); - register_actor("ServiceActor", &service_actor_).release(); + register_actor(PSLICE() << "ServiceActor" << id, &service_actor_).release(); } void Scheduler::clear() { |