Lines Matching refs:producer_id
112 uid_t GetProducerUid(ProducerID producer_id) {
113 return svc->GetProducer(producer_id)->uid_;
130 const std::set<BufferID>& GetAllowedTargetBuffers(ProducerID producer_id) {
131 return svc->GetProducer(producer_id)->allowed_target_buffers_;
134 const std::map<WriterID, BufferID>& GetWriters(ProducerID producer_id) {
135 return svc->GetProducer(producer_id)->writers_;
139 ProducerID producer_id) {
140 return std::move(svc->GetProducer(producer_id)->inproc_shmem_arbiter_);
158 void WaitForTraceWritersChanged(ProducerID producer_id) {
160 auto checkpoint_name = "writers_changed_" + std::to_string(producer_id) +
163 auto writers = GetWriters(producer_id);
165 task = [&task, writers, writers_changed, producer_id, this]() {
166 if (writers != GetWriters(producer_id)) {
2223 ProducerID producer_id = *last_producer_id();
2226 EXPECT_EQ(std::set<BufferID>(), GetAllowedTargetBuffers(producer_id));
2238 EXPECT_EQ(expected_buffers, GetAllowedTargetBuffers(producer_id));
2285 EXPECT_EQ(std::set<BufferID>(), GetAllowedTargetBuffers(producer_id));
2295 ProducerID producer_id = *last_producer_id();
2298 EXPECT_TRUE(GetWriters(producer_id).empty());
2319 WaitForTraceWritersChanged(producer_id);
2323 EXPECT_EQ(expected_writers, GetWriters(producer_id));
2337 WaitForTraceWritersChanged(producer_id);
2338 EXPECT_TRUE(GetWriters(producer_id).empty());
2358 ProducerID producer_id = *last_producer_id();
2378 WaitForTraceWritersChanged(producer_id);
2448 ProducerID producer_id = *last_producer_id();
2465 WaitForTraceWritersChanged(producer_id);
2502 ProducerID producer_id = *last_producer_id();
2522 WaitForTraceWritersChanged(producer_id);
2532 auto shmem_arbiter = TakeShmemArbiterForProducer(producer_id);
2566 ProducerID producer_id = *last_producer_id();
2586 WaitForTraceWritersChanged(producer_id);
