24 const char* str1 =
"msg1";
25 const char* str2 =
"msg2";
26 const char* str3 =
"msg3";
27 const char* str4 =
"msg4";
28 const char* str5 =
"msg5";
29 const char* str6 =
"msg6";
32 std::unique_ptr<Message> msg =
36 queue.Enqueue(std::move(msg),
false);
47 queue.Enqueue(std::move(msg),
false);
58 EXPECT(
queue.FindMessageById(
reinterpret_cast<intptr_t
>(msg1)) == msg1);
59 EXPECT(
queue.FindMessageById(
reinterpret_cast<intptr_t
>(msg2)) == msg2);
65 msg =
queue.Dequeue();
67 EXPECT_STREQ(str1,
reinterpret_cast<char*
>(msg->snapshot()));
75 msg =
queue.Dequeue();
77 EXPECT_STREQ(str2,
reinterpret_cast<char*
>(msg->snapshot()));
82 queue.Enqueue(std::move(msg),
true);
87 queue.Enqueue(std::move(msg),
true);
92 queue.Enqueue(std::move(msg),
false);
97 queue.Enqueue(std::move(msg),
true);
100 msg =
queue.Dequeue();
102 EXPECT_STREQ(str3,
reinterpret_cast<char*
>(msg->snapshot()));
105 msg =
queue.Dequeue();
107 EXPECT_STREQ(str4,
reinterpret_cast<char*
>(msg->snapshot()));
110 msg =
queue.Dequeue();
112 EXPECT_STREQ(str6,
reinterpret_cast<char*
>(msg->snapshot()));
115 msg =
queue.Dequeue();
117 EXPECT_STREQ(str5,
reinterpret_cast<char*
>(msg->snapshot()));