andreacavalli/tdlib-fork
Archived
1
0
Fork 0
Code Pull Requests Releases Activity

Fix tests

Browse Source 
GitOrigin-RevId: 829b0485d9b1eebc6e53f7d1f035bd702187fdf9
This commit is contained in:
Arseny Smirnov 2018-09-13 13:26:14 +03:00
parent 86ef95e0a8
commit 63ffada352
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tdactor/test/actors_simple.cpp
View File

@ -35,11 +35,17 @@ static char buf2[BUF_SIZE];
static StringBuilder sb(MutableSlice(buf, BUF_SIZE - 1)); static StringBuilder sb(MutableSlice(buf, BUF_SIZE - 1));
static StringBuilder sb2(MutableSlice(buf2, BUF_SIZE - 1)); static StringBuilder sb2(MutableSlice(buf2, BUF_SIZE - 1));
auto create_queue() {
auto res = std::make_shared<MpscPollableQueue<EventFull>>();
res->init();
return res;
}
TEST(Actors, SendLater) { TEST(Actors, SendLater) {
SET_VERBOSITY_LEVEL(VERBOSITY_NAME(ERROR)); SET_VERBOSITY_LEVEL(VERBOSITY_NAME(ERROR));
sb.clear(); sb.clear();
Scheduler scheduler; Scheduler scheduler;
scheduler.init(0, {std::make_shared<MpscPollableQueue<EventFull>>()}, nullptr); scheduler.init(0, {create_queue()}, nullptr);
auto guard = scheduler.get_guard(); auto guard = scheduler.get_guard();
class Worker : public Actor { class Worker : public Actor {
@ -96,7 +102,7 @@ class XReceiver final : public Actor {
TEST(Actors, simple_pass_event_arguments) { TEST(Actors, simple_pass_event_arguments) {
SET_VERBOSITY_LEVEL(VERBOSITY_NAME(ERROR)); SET_VERBOSITY_LEVEL(VERBOSITY_NAME(ERROR));
Scheduler scheduler; Scheduler scheduler;
scheduler.init(0, {std::make_shared<MpscPollableQueue<EventFull>>()}, nullptr); scheduler.init(0, {create_queue()}, nullptr);
auto guard = scheduler.get_guard(); auto guard = scheduler.get_guard();
auto id = create_actor<XReceiver>("XR").release(); auto id = create_actor<XReceiver>("XR").release();
@ -203,7 +209,7 @@ class PrintChar final : public Actor {
TEST(Actors, simple_hand_yield) { TEST(Actors, simple_hand_yield) {
SET_VERBOSITY_LEVEL(VERBOSITY_NAME(ERROR)); SET_VERBOSITY_LEVEL(VERBOSITY_NAME(ERROR));
Scheduler scheduler; Scheduler scheduler;
scheduler.init(0, {std::make_shared<MpscPollableQueue<EventFull>>()}, nullptr); scheduler.init(0, {create_queue()}, nullptr);
sb.clear(); sb.clear();
int cnt = 1000; int cnt = 1000;
{ {
@ -356,7 +362,7 @@ class MasterActor : public MsgActor {
TEST(Actors, call_after_destruct) { TEST(Actors, call_after_destruct) {
SET_VERBOSITY_LEVEL(VERBOSITY_NAME(ERROR)); SET_VERBOSITY_LEVEL(VERBOSITY_NAME(ERROR));
Scheduler scheduler; Scheduler scheduler;
scheduler.init(0, {std::make_shared<MpscPollableQueue<EventFull>>()}, nullptr); scheduler.init(0, {create_queue()}, nullptr);
{ {
auto guard = scheduler.get_guard(); auto guard = scheduler.get_guard();
create_actor<MasterActor>("Master").release(); create_actor<MasterActor>("Master").release();