Remove back actor_id variables.
GitOrigin-RevId: 918384376cbae7c489cc88749b3db8d950e26c49
This commit is contained in:
parent
7d6f9c493b
commit
15b9a1368d
@ -399,7 +399,7 @@ TEST(Actors, send_to_dead) {
|
|||||||
int threads_n = 5;
|
int threads_n = 5;
|
||||||
sched.init(threads_n);
|
sched.init(threads_n);
|
||||||
|
|
||||||
auto actor_id = sched.create_actor_unsafe<SendToDead>(0, "SendToDead").release();
|
sched.create_actor_unsafe<SendToDead>(0, "SendToDead").release();
|
||||||
sched.start();
|
sched.start();
|
||||||
while (sched.run_main(10)) {
|
while (sched.run_main(10)) {
|
||||||
// empty
|
// empty
|
||||||
@ -414,7 +414,7 @@ TEST(Actors, main_simple) {
|
|||||||
int threads_n = 3;
|
int threads_n = 3;
|
||||||
sched.init(threads_n);
|
sched.init(threads_n);
|
||||||
|
|
||||||
auto actor_id = sched.create_actor_unsafe<SimpleActor>(threads_n > 1 ? 1 : 0, "simple", threads_n).release();
|
sched.create_actor_unsafe<SimpleActor>(threads_n > 1 ? 1 : 0, "simple", threads_n).release();
|
||||||
sched.start();
|
sched.start();
|
||||||
while (sched.run_main(10)) {
|
while (sched.run_main(10)) {
|
||||||
// empty
|
// empty
|
||||||
@ -429,7 +429,7 @@ TEST(Actors, main) {
|
|||||||
int threads_n = 9;
|
int threads_n = 9;
|
||||||
sched.init(threads_n);
|
sched.init(threads_n);
|
||||||
|
|
||||||
auto actor_id = sched.create_actor_unsafe<MainQueryActor>(threads_n > 1 ? 1 : 0, "MainQuery", threads_n).release();
|
sched.create_actor_unsafe<MainQueryActor>(threads_n > 1 ? 1 : 0, "MainQuery", threads_n).release();
|
||||||
sched.start();
|
sched.start();
|
||||||
while (sched.run_main(10)) {
|
while (sched.run_main(10)) {
|
||||||
// empty
|
// empty
|
||||||
@ -457,7 +457,7 @@ TEST(Actors, do_after_stop) {
|
|||||||
int threads_n = 0;
|
int threads_n = 0;
|
||||||
sched.init(threads_n);
|
sched.init(threads_n);
|
||||||
|
|
||||||
auto actor_id = sched.create_actor_unsafe<DoAfterStop>(0, "DoAfterStop").release();
|
sched.create_actor_unsafe<DoAfterStop>(0, "DoAfterStop").release();
|
||||||
sched.start();
|
sched.start();
|
||||||
while (sched.run_main(10)) {
|
while (sched.run_main(10)) {
|
||||||
// empty
|
// empty
|
||||||
|
@ -342,7 +342,7 @@ TEST(Mtproto, socks5) {
|
|||||||
int threads_n = 0;
|
int threads_n = 0;
|
||||||
sched.init(threads_n);
|
sched.init(threads_n);
|
||||||
|
|
||||||
auto actor_id = sched.create_actor_unsafe<Socks5TestActor>(0, "Socks5TestActor").release();
|
sched.create_actor_unsafe<Socks5TestActor>(0, "Socks5TestActor").release();
|
||||||
sched.start();
|
sched.start();
|
||||||
while (sched.run_main(10)) {
|
while (sched.run_main(10)) {
|
||||||
// empty;
|
// empty;
|
||||||
|
@ -701,10 +701,9 @@ class LoginTestActor : public Actor {
|
|||||||
double timeout_;
|
double timeout_;
|
||||||
Promise<> promise_;
|
Promise<> promise_;
|
||||||
};
|
};
|
||||||
auto actor_id =
|
create_actor<WaitActor>("WaitActor", 2,
|
||||||
create_actor<WaitActor>("WaitActor", 2,
|
PromiseCreator::event(self_closure(this, &LoginTestActor::start_up_fence_dec)))
|
||||||
PromiseCreator::event(self_closure(this, &LoginTestActor::start_up_fence_dec)))
|
.release();
|
||||||
.release();
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user