209   StreamPtr stream1 = create_stream(1, 1, CRAS_STREAM_INPUT, 480, &format);  in TEST_F()  local
210   stream1->rstream->next_cb_ts = start;  in TEST_F()
218   streams.emplace_back(std::move(stream1));  in TEST_F()
239   StreamPtr stream1 = create_stream(1, 1, CRAS_STREAM_INPUT, 480, &format);  in TEST_F()  local
240   stream1->rstream->next_cb_ts = start;  in TEST_F()
241   stream1->rstream->next_cb_ts.tv_sec += 2;  in TEST_F()
248   streams.emplace_back(std::move(stream1));  in TEST_F()
606   StreamPtr stream1 =  in TEST_F()  local
610   stream1->rstream->next_cb_ts = start;  in TEST_F()
611   AddFakeDataToStream(stream1.get(), cb_threshold);  in TEST_F()
620   streams.emplace_back(std::move(stream1));  in TEST_F()
642   StreamPtr stream1 = create_stream(1, 1, CRAS_STREAM_INPUT, 441, &s1_format);  in TEST_F()  local
645   stream1->rstream->next_cb_ts = start;  in TEST_F()
646   AddFakeDataToStream(stream1.get(), 441);  in TEST_F()
653   streams.emplace_back(std::move(stream1));  in TEST_F()
678   StreamPtr stream1 = create_stream(1, 1, CRAS_STREAM_INPUT, 441, &s1_format);  in TEST_F()  local
679   stream1->rstream->next_cb_ts = start;  in TEST_F()
681   add_timespecs(&stream1->rstream->next_cb_ts, &three_millis);  in TEST_F()
682   AddFakeDataToStream(stream1.get(), 441);  in TEST_F()
688   AddFakeDataToStream(stream1.get(), 480);  in TEST_F()
691   streams.emplace_back(std::move(stream1));  in TEST_F()
1041   StreamPtr stream1 = create_stream(1, 1, CRAS_STREAM_OUTPUT, 480, &format);  in TEST_F()  local
1042   stream1->rstream->next_cb_ts = start;  in TEST_F()
1043   stream1->rstream->next_cb_ts.tv_sec += 2;  in TEST_F()
1044   stream1->rstream->is_draining = 1;  in TEST_F()
1045   stream1->rstream->queued_frames = 480;  in TEST_F()
1052   streams.emplace_back(std::move(stream1));  in TEST_F()
1074   StreamPtr stream1 = create_stream(1, 1, CRAS_STREAM_OUTPUT, 480, &format);  in TEST_F()  local
1075   stream1->rstream->next_cb_ts = start;  in TEST_F()
1076   stream1->rstream->next_cb_ts.tv_sec += 2;  in TEST_F()
1077   rstream_stub_pending_reply(stream1->rstream.get(), 1);  in TEST_F()
1084   streams.emplace_back(std::move(stream1));  in TEST_F()
1106   StreamPtr stream1 = create_stream(1, 1, CRAS_STREAM_OUTPUT, 480, &format);  in TEST_F()  local
1107   stream1->rstream->next_cb_ts = start;  in TEST_F()
1108   stream1->rstream->next_cb_ts.tv_sec += 2;  in TEST_F()
1109   stream1->rstream->flags = USE_DEV_TIMING;  in TEST_F()
1116   streams.emplace_back(std::move(stream1));  in TEST_F()
1137   StreamPtr stream1 = create_stream(1, 1, CRAS_STREAM_OUTPUT, 480, &format);  in TEST_F()  local
1138   stream1->rstream->next_cb_ts = start;  in TEST_F()
1139   stream1->rstream->next_cb_ts.tv_sec += 2;  in TEST_F()
1146   streams.emplace_back(std::move(stream1));  in TEST_F()