Lines Matching refs:rstream
125 RstreamPtr rstream = in TEST_F() local
128 dev_io_append_stream(&odev_list_, &idev_list_, rstream.get(), &iodev, 1); in TEST_F()
130 EXPECT_EQ(0, rstream->next_cb_ts.tv_sec); in TEST_F()
131 EXPECT_EQ(0, rstream->next_cb_ts.tv_nsec); in TEST_F()
210 stream1->rstream->next_cb_ts = start; in TEST_F()
213 stream2->rstream->next_cb_ts = start; in TEST_F()
214 stream2->rstream->next_cb_ts.tv_sec += 5; in TEST_F()
215 rstream_stub_dev_offset(stream2->rstream.get(), 1, 200); in TEST_F()
240 stream1->rstream->next_cb_ts = start; in TEST_F()
241 stream1->rstream->next_cb_ts.tv_sec += 2; in TEST_F()
244 stream2->rstream->next_cb_ts = start; in TEST_F()
245 stream2->rstream->next_cb_ts.tv_sec += 5; in TEST_F()
273 stream->rstream->next_cb_ts = stream_wake; in TEST_F()
301 stream->rstream->next_cb_ts.tv_sec = 0; in TEST_F()
302 stream->rstream->next_cb_ts.tv_nsec = 0; in TEST_F()
327 stream->rstream->next_cb_ts = start; in TEST_F()
328 stream->rstream->next_cb_ts.tv_sec += 10; in TEST_F()
329 stream->rstream->flags = USE_DEV_TIMING; in TEST_F()
330 rstream_stub_pending_reply(stream->rstream.get(), 1); in TEST_F()
357 stream->rstream->next_cb_ts.tv_sec = 0; in TEST_F()
358 stream->rstream->next_cb_ts.tv_nsec = 0; in TEST_F()
368 EXPECT_EQ(0, streams[0]->rstream->next_cb_ts.tv_sec); in TEST_F()
369 EXPECT_EQ(0, streams[0]->rstream->next_cb_ts.tv_nsec); in TEST_F()
387 stream->rstream->next_cb_ts.tv_sec = 0; in TEST_F()
388 stream->rstream->next_cb_ts.tv_nsec = 0; in TEST_F()
395 EXPECT_EQ(0, streams[0]->rstream->next_cb_ts.tv_sec); in TEST_F()
396 EXPECT_EQ(0, streams[0]->rstream->next_cb_ts.tv_nsec); in TEST_F()
414 stream->rstream->next_cb_ts = start; in TEST_F()
415 stream->rstream->next_cb_ts.tv_sec += 10; in TEST_F()
416 stream->rstream->flags = USE_DEV_TIMING; in TEST_F()
462 stream->rstream->next_cb_ts = start; in TEST_F()
463 stream->rstream->next_cb_ts.tv_sec += 10; in TEST_F()
489 stream->rstream->next_cb_ts = start; in TEST_F()
501 EXPECT_EQ(start.tv_sec, streams[0]->rstream->next_cb_ts.tv_sec); in TEST_F()
502 EXPECT_EQ(start.tv_nsec, streams[0]->rstream->next_cb_ts.tv_nsec); in TEST_F()
503 EXPECT_EQ(dev_time.tv_sec, streams[0]->rstream->next_cb_ts.tv_sec); in TEST_F()
504 EXPECT_EQ(dev_time.tv_nsec, streams[0]->rstream->next_cb_ts.tv_nsec); in TEST_F()
522 stream->rstream->next_cb_ts = start; in TEST_F()
553 stream->rstream->next_cb_ts = start; in TEST_F()
581 stream->rstream->next_cb_ts = start; in TEST_F()
610 stream1->rstream->next_cb_ts = start; in TEST_F()
616 stream2->rstream->next_cb_ts = start; in TEST_F()
645 stream1->rstream->next_cb_ts = start; in TEST_F()
649 stream2->rstream->next_cb_ts = start; in TEST_F()
679 stream1->rstream->next_cb_ts = start; in TEST_F()
681 add_timespecs(&stream1->rstream->next_cb_ts, &three_millis); in TEST_F()
685 stream2->rstream->next_cb_ts = start; in TEST_F()
687 add_timespecs(&stream2->rstream->next_cb_ts, &five_millis); in TEST_F()
714 stream->rstream->flags = HOTWORD_STREAM; in TEST_F()
715 stream->rstream->next_cb_ts = start; in TEST_F()
718 add_timespecs(&stream->rstream->next_cb_ts, &delay); in TEST_F()
746 stream->rstream->flags = HOTWORD_STREAM; in TEST_F()
747 stream->rstream->next_cb_ts = start; in TEST_F()
753 rstream_stub_pending_reply(streams[0]->rstream.get(), 1); in TEST_F()
785 stream->rstream->flags = HOTWORD_STREAM; in TEST_F()
786 stream->rstream->next_cb_ts = start; in TEST_F()
792 rstream_stub_pending_reply(streams[0]->rstream.get(), 0); in TEST_F()
838 in_stream->rstream->next_cb_ts.tv_sec = 54321; in TEST_F()
839 in_stream->rstream->next_cb_ts.tv_nsec = 12345; in TEST_F()
840 in_stream->rstream->sleep_interval_ts.tv_sec = 321; in TEST_F()
841 in_stream->rstream->sleep_interval_ts.tv_nsec = 123; in TEST_F()
844 RstreamPtr rstream = in TEST_F() local
847 dev_io_append_stream(&odev_list_, &idev_list_, rstream.get(), &out_iodev, 1); in TEST_F()
849 EXPECT_EQ(in_stream->rstream->next_cb_ts.tv_sec, rstream->next_cb_ts.tv_sec); in TEST_F()
850 EXPECT_EQ(in_stream->rstream->next_cb_ts.tv_nsec, in TEST_F()
851 rstream->next_cb_ts.tv_nsec); in TEST_F()
852 EXPECT_EQ(in_stream->rstream->sleep_interval_ts.tv_sec, in TEST_F()
853 rstream->sleep_interval_ts.tv_sec); in TEST_F()
854 EXPECT_EQ(in_stream->rstream->sleep_interval_ts.tv_nsec, in TEST_F()
855 rstream->sleep_interval_ts.tv_nsec); in TEST_F()
876 stream->rstream->next_cb_ts.tv_sec = 54321; in TEST_F()
877 stream->rstream->next_cb_ts.tv_nsec = 12345; in TEST_F()
880 RstreamPtr rstream = in TEST_F() local
883 dev_io_append_stream(&odev_list_, &idev_list_, rstream.get(), &iodev, 1); in TEST_F()
885 EXPECT_EQ(stream->rstream->next_cb_ts.tv_sec, rstream->next_cb_ts.tv_sec); in TEST_F()
886 EXPECT_EQ(stream->rstream->next_cb_ts.tv_nsec, rstream->next_cb_ts.tv_nsec); in TEST_F()
909 RstreamPtr rstream = in TEST_F() local
912 dev_io_append_stream(&odev_list_, &idev_list_, rstream.get(), &iodev, 1); in TEST_F()
914 EXPECT_EQ(start.tv_sec, rstream->next_cb_ts.tv_sec); in TEST_F()
915 EXPECT_EQ(start.tv_nsec, rstream->next_cb_ts.tv_nsec); in TEST_F()
941 RstreamPtr rstream = in TEST_F() local
944 dev_io_append_stream(&odev_list_, &idev_list_, rstream.get(), &iodev, 1); in TEST_F()
950 EXPECT_EQ(start.tv_sec, rstream->next_cb_ts.tv_sec); in TEST_F()
951 EXPECT_EQ(start.tv_nsec, rstream->next_cb_ts.tv_nsec); in TEST_F()
991 stream->rstream->next_cb_ts = start; in TEST_F()
992 stream->rstream->next_cb_ts.tv_sec += 1; in TEST_F()
1016 stream->rstream->next_cb_ts = start; in TEST_F()
1017 stream->rstream->next_cb_ts.tv_sec += 2; in TEST_F()
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()
1048 stream2->rstream->next_cb_ts = start; in TEST_F()
1049 stream2->rstream->next_cb_ts.tv_sec += 5; in TEST_F()
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()
1080 stream2->rstream->next_cb_ts = start; in TEST_F()
1081 stream2->rstream->next_cb_ts.tv_sec += 5; in TEST_F()
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()
1112 stream2->rstream->next_cb_ts = start; in TEST_F()
1113 stream2->rstream->next_cb_ts.tv_sec += 5; in TEST_F()
1138 stream1->rstream->next_cb_ts = start; in TEST_F()
1139 stream1->rstream->next_cb_ts.tv_sec += 2; in TEST_F()
1142 stream2->rstream->next_cb_ts = start; in TEST_F()
1143 stream2->rstream->next_cb_ts.tv_sec += 5; in TEST_F()
1170 stream->rstream->next_cb_ts = start; in TEST_F()
1185 EXPECT_EQ(start.tv_sec, stream->rstream->next_cb_ts.tv_sec); in TEST_F()
1186 EXPECT_EQ(start.tv_nsec, stream->rstream->next_cb_ts.tv_nsec); in TEST_F()