Lines Matching refs:queue
27 UnwindQueue<int, kCapacity> queue; in TEST() local
31 WriteView v = queue.BeginWrite(); in TEST()
33 queue.at(v.write_pos) = i; in TEST()
34 queue.CommitWrite(); in TEST()
38 WriteView v = queue.BeginWrite(); in TEST()
43 ReadView v = queue.BeginRead(); in TEST()
49 read_back.push_back(queue.at(pos)); in TEST()
51 queue.CommitNewReadPosition(v.write_pos); in TEST()
56 ASSERT_TRUE(queue.BeginWrite().valid); in TEST()
58 ASSERT_TRUE(queue.BeginRead().read_pos == queue.BeginRead().write_pos); in TEST()
63 UnwindQueue<int, kCapacity> queue; in TEST() local
67 WriteView v = queue.BeginWrite(); in TEST()
69 queue.at(v.write_pos) = i; in TEST()
70 queue.CommitWrite(); in TEST()
74 ASSERT_FALSE(queue.BeginWrite().valid); in TEST()
78 ReadView v = queue.BeginRead(); in TEST()
81 queue.CommitNewReadPosition(v.read_pos + 2); in TEST()
86 WriteView v = queue.BeginWrite(); in TEST()
88 queue.at(v.write_pos) = 4 + i; in TEST()
89 queue.CommitWrite(); in TEST()
93 ASSERT_FALSE(queue.BeginWrite().valid); in TEST()
96 ReadView v = queue.BeginRead(); in TEST()
102 read_back.push_back(queue.at(pos)); in TEST()
104 queue.CommitNewReadPosition(v.write_pos); in TEST()
109 ASSERT_TRUE(queue.BeginWrite().valid); in TEST()
111 ASSERT_TRUE(queue.BeginRead().read_pos == queue.BeginRead().write_pos); in TEST()