Lines Matching full:streams
49 const std::vector<StreamPtr>& streams, in SingleInputDevNextWake() argument
58 for (auto const& stream : streams) { in SingleInputDevNextWake()
78 const std::vector<StreamPtr>& streams, in SingleOutputDevNextWake() argument
87 for (auto const& stream : streams) { in SingleOutputDevNextWake()
133 dev_stream_destroy(iodev->streams); in TEST_F()
187 std::vector<StreamPtr> streams; in TEST_F() local
189 SingleInputDevNextWake(4800000, 0, &start, &format, streams); in TEST_F()
217 std::vector<StreamPtr> streams; in TEST_F() local
218 streams.emplace_back(std::move(stream1)); in TEST_F()
219 streams.emplace_back(std::move(stream2)); in TEST_F()
221 SingleInputDevNextWake(480000, 0, &start, &format, streams); in TEST_F()
247 std::vector<StreamPtr> streams; in TEST_F() local
248 streams.emplace_back(std::move(stream1)); in TEST_F()
249 streams.emplace_back(std::move(stream2)); in TEST_F()
251 SingleInputDevNextWake(480000, 0, &start, &format, streams); in TEST_F()
278 std::vector<StreamPtr> streams; in TEST_F() local
279 streams.emplace_back(std::move(stream)); in TEST_F()
280 timespec wake_time = SingleInputDevNextWake(240, 0, &start, &format, streams); in TEST_F()
304 std::vector<StreamPtr> streams; in TEST_F() local
305 streams.emplace_back(std::move(stream)); in TEST_F()
306 timespec dev_time = SingleInputDevNextWake(240, 0, &start, &format, streams); in TEST_F()
332 std::vector<StreamPtr> streams; in TEST_F() local
333 streams.emplace_back(std::move(stream)); in TEST_F()
334 timespec dev_time = SingleInputDevNextWake(4800, 0, &start, &format, streams); in TEST_F()
360 std::vector<StreamPtr> streams; in TEST_F() local
361 streams.emplace_back(std::move(stream)); in TEST_F()
362 timespec dev_time = SingleInputDevNextWake(600, 0, &start, &format, streams); 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()
391 std::vector<StreamPtr> streams; in TEST_F() local
392 streams.emplace_back(std::move(stream)); in TEST_F()
394 SingleInputDevNextWake(480, 480, &start, &format, streams); 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()
418 std::vector<StreamPtr> streams; in TEST_F() local
419 streams.emplace_back(std::move(stream)); in TEST_F()
420 timespec dev_time = SingleInputDevNextWake(600, 0, &start, &format, streams); in TEST_F()
440 std::vector<StreamPtr> streams; in TEST_F() local
441 timespec dev_time = SingleInputDevNextWake(480, 0, &start, &format, streams); in TEST_F()
465 std::vector<StreamPtr> streams; in TEST_F() local
466 streams.emplace_back(std::move(stream)); in TEST_F()
468 SingleInputDevNextWake(480, 480, &start, &format, streams); in TEST_F()
492 std::vector<StreamPtr> streams; in TEST_F() local
493 streams.emplace_back(std::move(stream)); in TEST_F()
495 SingleInputDevNextWake(cb_threshold, 0, &start, &format, streams); 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()
524 std::vector<StreamPtr> streams; in TEST_F() local
525 streams.emplace_back(std::move(stream)); in TEST_F()
527 &start, &format, streams); in TEST_F()
555 std::vector<StreamPtr> streams; in TEST_F() local
556 streams.emplace_back(std::move(stream)); in TEST_F()
558 &start, &format, streams); in TEST_F()
584 std::vector<StreamPtr> streams; in TEST_F() local
585 streams.emplace_back(std::move(stream)); in TEST_F()
587 SingleInputDevNextWake(480, 0, &start, &dev_format, streams); in TEST_F()
596 // One device, two streams. One stream is ready the other still needs data.
619 std::vector<StreamPtr> streams; in TEST_F() local
620 streams.emplace_back(std::move(stream1)); in TEST_F()
621 streams.emplace_back(std::move(stream2)); in TEST_F()
623 SingleInputDevNextWake(cb_threshold, 0, &start, &format, streams); in TEST_F()
632 // One device(44.1), two streams(44.1, 48). One stream is ready the other still
652 std::vector<StreamPtr> streams; in TEST_F() local
653 streams.emplace_back(std::move(stream1)); in TEST_F()
654 streams.emplace_back(std::move(stream2)); in TEST_F()
656 SingleInputDevNextWake(441, 0, &start, &s1_format, streams); in TEST_F()
666 // One device, two streams. Both streams get a full callback of data and the
668 // shorter of the two streams times is used for the next sleep interval.
690 std::vector<StreamPtr> streams; in TEST_F() local
691 streams.emplace_back(std::move(stream1)); in TEST_F()
692 streams.emplace_back(std::move(stream2)); in TEST_F()
694 SingleInputDevNextWake(441, 441, &start, &s1_format, streams); in TEST_F()
724 std::vector<StreamPtr> streams; in TEST_F() local
725 streams.emplace_back(std::move(stream)); in TEST_F()
726 timespec dev_time = SingleInputDevNextWake(4096, 0, &start, &fmt, streams); in TEST_F()
750 std::vector<StreamPtr> streams; in TEST_F() local
751 streams.emplace_back(std::move(stream)); in TEST_F()
753 rstream_stub_pending_reply(streams[0]->rstream.get(), 1); in TEST_F()
756 timespec dev_time = SingleInputDevNextWake(4096, 7000, &start, &fmt, streams, in TEST_F()
760 poll_fd = dev_stream_poll_stream_fd(streams[0]->dstream.get()); in TEST_F()
789 std::vector<StreamPtr> streams; in TEST_F() local
790 streams.emplace_back(std::move(stream)); in TEST_F()
792 rstream_stub_pending_reply(streams[0]->rstream.get(), 0); in TEST_F()
795 timespec dev_time = SingleInputDevNextWake(4096, 7000, &start, &fmt, streams); in TEST_F()
798 poll_fd = dev_stream_poll_stream_fd(streams[0]->dstream.get()); in TEST_F()
812 // 2. If the device already has streams, the next_cb_ts will be the earliest
813 // next callback time from these streams.
814 // 3. If there are no other streams, the next_cb_ts will be set to the time
857 dev_stream_destroy(out_iodev->streams); in TEST_F()
861 // The device already has streams, the next_cb_ts will be the earliest
862 // next_cb_ts from these streams.
888 dev_stream_destroy(iodev->streams->next); in TEST_F()
892 // The there are no streams and no frames in device buffer. The next_cb_ts
917 dev_stream_destroy(iodev->streams); in TEST_F()
921 // The there are no streams and some valid frames in device buffer. The
953 dev_stream_destroy(iodev->streams); in TEST_F()
959 // wake_ts = get_next_stream_wake_from_list(dev.streams)
963 // function get_next_stream_wake_from_list(streams):
964 // for stream in streams:
983 // The wake up time should be the earlier time amoung streams and devices.
994 std::vector<StreamPtr> streams; in TEST_F() local
995 streams.emplace_back(std::move(stream)); in TEST_F()
1001 SingleOutputDevNextWake(48000, 0, &start, &format, streams, &dev_wake_ts); in TEST_F()
1008 // The wake up time should be the earlier time amoung streams and devices.
1019 std::vector<StreamPtr> streams; in TEST_F() local
1020 streams.emplace_back(std::move(stream)); in TEST_F()
1026 SingleOutputDevNextWake(48000, 0, &start, &format, streams, &dev_wake_ts); in TEST_F()
1051 std::vector<StreamPtr> streams; in TEST_F() local
1052 streams.emplace_back(std::move(stream1)); in TEST_F()
1053 streams.emplace_back(std::move(stream2)); in TEST_F()
1059 SingleOutputDevNextWake(48000, 0, &start, &format, streams, &dev_wake_ts); in TEST_F()
1083 std::vector<StreamPtr> streams; in TEST_F() local
1084 streams.emplace_back(std::move(stream1)); in TEST_F()
1085 streams.emplace_back(std::move(stream2)); in TEST_F()
1091 SingleOutputDevNextWake(48000, 0, &start, &format, streams, &dev_wake_ts); in TEST_F()
1115 std::vector<StreamPtr> streams; in TEST_F() local
1116 streams.emplace_back(std::move(stream1)); in TEST_F()
1117 streams.emplace_back(std::move(stream2)); in TEST_F()
1123 SingleOutputDevNextWake(48000, 0, &start, &format, streams, &dev_wake_ts); in TEST_F()
1130 // The wake up time should be the next_cb_ts of streams.
1145 std::vector<StreamPtr> streams; in TEST_F() local
1146 streams.emplace_back(std::move(stream1)); in TEST_F()
1147 streams.emplace_back(std::move(stream2)); in TEST_F()
1153 SingleOutputDevNextWake(48000, 0, &start, &format, streams, &dev_wake_ts); in TEST_F()