36   bool Remove(const std::string& id) { return queue_.Remove(id); }  in Remove()
39     return queue_.Cleanup(task_runner_.GetClock()->Now() + interval);  in Cleanup()
43     return queue_.remove_queue_.top().second;  in GetFirstCommandToBeRemoved()
47   CommandQueue queue_{&task_runner_, task_runner_.GetClock()};  member in weave::CommandQueueTest
87   EXPECT_TRUE(queue_.IsEmpty());  in TEST_F()
88   EXPECT_EQ(0u, queue_.GetCount());  in TEST_F()
92   queue_.Add(CreateDummyCommandInstance("base.reboot", "id1"));  in TEST_F()
93   queue_.Add(CreateDummyCommandInstance("base.reboot", "id2"));  in TEST_F()
94   queue_.Add(CreateDummyCommandInstance("base.reboot", "id3"));  in TEST_F()
95   EXPECT_EQ(3u, queue_.GetCount());  in TEST_F()
96   EXPECT_FALSE(queue_.IsEmpty());  in TEST_F()
102   queue_.Add(CreateDummyCommandInstance("base.reboot", id1));  in TEST_F()
103   queue_.Add(CreateDummyCommandInstance("base.reboot", id2));  in TEST_F()
104   EXPECT_FALSE(queue_.IsEmpty());  in TEST_F()
106   EXPECT_EQ(2u, queue_.GetCount());  in TEST_F()
108   EXPECT_EQ(1u, queue_.GetCount());  in TEST_F()
110   EXPECT_EQ(1u, queue_.GetCount());  in TEST_F()
112   EXPECT_EQ(0u, queue_.GetCount());  in TEST_F()
114   EXPECT_EQ(0u, queue_.GetCount());  in TEST_F()
115   EXPECT_TRUE(queue_.IsEmpty());  in TEST_F()
120   queue_.Add(CreateDummyCommandInstance("base.reboot", id1));  in TEST_F()
121   EXPECT_EQ(1u, queue_.GetCount());  in TEST_F()
123   queue_.RemoveLater(id1);  in TEST_F()
124   EXPECT_EQ(1u, queue_.GetCount());  in TEST_F()
127   EXPECT_EQ(1u, queue_.GetCount());  in TEST_F()
130   EXPECT_EQ(0u, queue_.GetCount());  in TEST_F()
135   queue_.Add(CreateDummyCommandInstance("base.reboot", id1));  in TEST_F()
136   EXPECT_EQ(1u, queue_.GetCount());  in TEST_F()
138   queue_.RemoveLater(id1);  in TEST_F()
139   EXPECT_EQ(1u, queue_.GetCount());  in TEST_F()
144   EXPECT_EQ(0u, queue_.GetCount());  in TEST_F()
152   queue_.Add(CreateDummyCommandInstance("base.reboot", id1));  in TEST_F()
153   queue_.Add(CreateDummyCommandInstance("base.reboot", id2));  in TEST_F()
154   auto remove_task = [this](const std::string& id) { queue_.RemoveLater(id); };  in TEST_F()
158   EXPECT_EQ(2u, queue_.GetCount());  in TEST_F()
161   ASSERT_EQ(2u, queue_.GetCount());  in TEST_F()
165   ASSERT_EQ(1u, queue_.GetCount());  in TEST_F()
169   EXPECT_EQ(0u, queue_.GetCount());  in TEST_F()
174   FakeDispatcher dispatch(&queue_);  in TEST_F()
177   queue_.Add(CreateDummyCommandInstance("base.reboot", id1));  in TEST_F()
178   queue_.Add(CreateDummyCommandInstance("base.reboot", id2));  in TEST_F()
192   queue_.Add(CreateDummyCommandInstance("base.reboot", id1));  in TEST_F()
193   queue_.Add(CreateDummyCommandInstance("base.shutdown", id2));  in TEST_F()
194   EXPECT_EQ(nullptr, queue_.Find("dummy"));  in TEST_F()
195   auto cmd1 = queue_.Find(id1);  in TEST_F()
199   auto cmd2 = queue_.Find(id2);  in TEST_F()