tdlight-team/tdlight
tdlight-team/tdlight
1
1
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Deprecate ActorShared with 0 token.

Browse Source 
GitOrigin-RevId: 15dc5e63afa4c0d08f911101eaa78513df6aebc5
This commit is contained in:
levlam 2020-08-27 01:27:34 +03:00
parent b8419b7832
commit 2009d58f6a
7 changed files with 9 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
td/telegram/ConfigManager.cpp
View File

@ -1055,7 +1055,7 @@ void ConfigManager::request_config_from_dc_impl(DcId dc_id) {
config_sent_cnt_++;
auto query = G()->net_query_creator().create_unauth(telegram_api::help_getConfig(), dc_id);
query->total_timeout_limit_ = 60 * 60 * 24;
G()->net_query_dispatcher().dispatch_with_callback(std::move(query), actor_shared(this, 0));
G()->net_query_dispatcher().dispatch_with_callback(std::move(query), actor_shared(this, 8));
}
void ConfigManager::do_set_ignore_sensitive_content_restrictions(bool ignore_sensitive_content_restrictions) {
@ -1276,7 +1276,7 @@ void ConfigManager::on_result(NetQueryPtr res) {
return;
}
CHECK(token == 0);
CHECK(token == 8);
CHECK(config_sent_cnt_ > 0);
config_sent_cnt_--;
auto r_config = fetch_result<telegram_api::help_getConfig>(std::move(res));

2
tdactor/td/actor/SignalSlot.h
View File

@ -72,7 +72,7 @@ class Slot final : public Actor {
}
ActorShared<> get_signal_new() {
register_if_empty();
return actor_shared();
return actor_shared(this);
}
private:

1
tdactor/td/actor/impl/Actor-decl.h
View File

@ -101,7 +101,6 @@ class Actor : public ObserverBase {
template <class SelfT>
ActorId<SelfT> actor_id(SelfT *self);
ActorShared<> actor_shared();
template <class SelfT>
ActorShared<SelfT> actor_shared(SelfT *self, uint64 id = static_cast<uint64>(-1));

5
tdactor/td/actor/impl/Actor.h
View File

@ -125,12 +125,11 @@ ActorId<SelfT> Actor::actor_id(SelfT *self) {
return ActorId<SelfT>(info_.get_weak());
}
inline ActorShared<> Actor::actor_shared() {
return actor_shared(this);
}
template <class SelfT>
ActorShared<SelfT> Actor::actor_shared(SelfT *self, uint64 id) {
CHECK(static_cast<Actor *>(self) == this);
// TODO replace with CHECK
LOG_IF(ERROR, id == 0) << "ActorShared with token 0 must not be created";
return ActorShared<SelfT>(actor_id(self), id);
}

4
tdactor/test/actors_main.cpp
View File

@ -353,7 +353,7 @@ class SendToDead : public Actor {
set_timeout_in(Random::fast_uint32() % 3 * 0.001);
if (ttl_ != 0) {
child_ = create_actor_on_scheduler<Parent>(
"Child", Random::fast_uint32() % Scheduler::instance()->sched_count(), actor_shared(), ttl_ - 1);
"Child", Random::fast_uint32() % Scheduler::instance()->sched_count(), actor_shared(this), ttl_ - 1);
}
}
void timeout_expired() override {
@ -376,7 +376,7 @@ class SendToDead : public Actor {
ActorShared<> create_reference() {
ref_cnt_++;
return actor_shared();
return actor_shared(this);
}
void hangup_shared() override {
ref_cnt_--;

2
tdactor/test/actors_simple.cpp
View File

@ -482,7 +482,7 @@ class LaterMasterActor : public Actor {
std::vector<ActorOwn<LaterSlave>> children_;
void start_up() override {
for (int i = 0; i < cnt_; i++) {
children_.push_back(create_actor<LaterSlave>("B", actor_shared()));
children_.push_back(create_actor<LaterSlave>("B", actor_shared(this)));
}
yield();
}

2
test/mtproto.cpp
View File

@ -459,7 +459,7 @@ class Socks5TestActor : public Actor {
return promise.set_error(Status::Error(PSTRING() << "Failed to open socket: " << r_socket.error()));
}
create_actor<Socks5>("socks5", r_socket.move_as_ok(), mtproto_ip_address, "", "",
make_unique<Callback>(std::move(promise)), actor_shared())
make_unique<Callback>(std::move(promise)), actor_shared(this))
.release();
}