Improve some log messages.
This commit is contained in:
parent
2bdb2dc371
commit
511689877c
@ -14,7 +14,6 @@
|
||||
|
||||
#include "td/utils/algorithm.h"
|
||||
#include "td/utils/ChainScheduler.h"
|
||||
#include "td/utils/format.h"
|
||||
#include "td/utils/logging.h"
|
||||
#include "td/utils/misc.h"
|
||||
#include "td/utils/Promise.h"
|
||||
@ -265,11 +264,11 @@ void MultiSequenceDispatcherOld::send(NetQueryPtr query) {
|
||||
auto it_ok = dispatchers_.emplace(sequence_id, Data{0, ActorOwn<SequenceDispatcher>()});
|
||||
auto &data = it_ok.first->second;
|
||||
if (it_ok.second) {
|
||||
LOG(DEBUG) << "Create SequenceDispatcher" << sequence_id;
|
||||
LOG(DEBUG) << "Create SequenceDispatcher " << sequence_id;
|
||||
data.dispatcher_ = create_actor<SequenceDispatcher>("SequenceDispatcher", actor_shared(this, sequence_id));
|
||||
}
|
||||
data.cnt_++;
|
||||
query->debug(PSTRING() << "send to SequenceDispatcher " << tag("sequence_id", sequence_id));
|
||||
query->debug(PSTRING() << "send to SequenceDispatcher " << sequence_id);
|
||||
send_closure(data.dispatcher_, &SequenceDispatcher::send_with_callback, std::move(query), std::move(callback));
|
||||
}
|
||||
|
||||
|
@ -80,7 +80,7 @@ class NetQuery final : public TsListNode<NetQueryDebug> {
|
||||
}
|
||||
|
||||
void resend(DcId new_dc_id) {
|
||||
VLOG(net_query) << "Resend" << *this;
|
||||
VLOG(net_query) << "Resend " << *this;
|
||||
{
|
||||
auto guard = lock();
|
||||
get_data_unsafe().resend_count_++;
|
||||
|
@ -259,7 +259,7 @@ class MpmcSleepyWaiter {
|
||||
guard.unlock();
|
||||
} else {
|
||||
guard.unlock();
|
||||
VLOG(waiter) << "Not in sleepers" << slot.worker_id;
|
||||
VLOG(waiter) << "Not in sleepers " << slot.worker_id;
|
||||
CHECK(slot.cancel_park());
|
||||
}
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user