Lines Matching refs:rstream
121 void SetupRstream(struct cras_rstream *rstream,
123 memset(rstream, 0, sizeof(*rstream));
124 rstream->direction = direction;
125 rstream->cb_threshold = 480;
126 rstream->shm.area = static_cast<cras_audio_shm_area*>(
127 calloc(1, sizeof(*rstream->shm.area)));
130 void TearDownRstream(struct cras_rstream *rstream) {
131 free(rstream->shm.area);
134 void SetupPinnedStream(struct cras_rstream *rstream,
137 SetupRstream(rstream, direction);
138 rstream->is_pinned = 1;
139 rstream->pinned_dev_idx = pin_to_dev->info.idx;
339 struct cras_rstream rstream;
345 SetupRstream(&rstream, CRAS_STREAM_INPUT);
352 thread_add_stream(thread_, &rstream, iodevs, 2);
359 // Fake offset for rstream
365 EXPECT_EQ(&rstream, cras_rstream_dev_offset_rstream_val[0]);
367 EXPECT_EQ(&rstream, cras_rstream_dev_offset_rstream_val[1]);
378 TearDownRstream(&rstream);
428 struct cras_rstream rstream;
435 SetupRstream(&rstream, CRAS_STREAM_OUTPUT);
441 thread_add_stream(thread_, &rstream, &piodev, 1);
443 EXPECT_EQ(dev_stream->stream, &rstream);
453 EXPECT_EQ(dev_stream->stream, &rstream);
459 EXPECT_EQ(dev_stream->stream, &rstream);
474 dev_io_remove_stream(&thread_->open_devs[rstream.direction],
475 &rstream, &iodev);
490 TearDownRstream(&rstream);
632 struct cras_rstream rstream;
637 SetupRstream(&rstream, CRAS_STREAM_OUTPUT);
644 thread_add_stream(thread_, &rstream, &piodev, 1);
663 TearDownRstream(&rstream);
668 struct cras_rstream rstream;
673 SetupRstream(&rstream, CRAS_STREAM_OUTPUT);
680 thread_add_stream(thread_, &rstream, &piodev, 1);
697 TearDownRstream(&rstream);
701 struct cras_rstream rstream;
705 memset(&rstream, 0, sizeof(rstream));
707 rstream.shm.config.frame_bytes = 4;
710 rstream.shm.config.used_size = 4096 * 4;
711 rstream.shm.area = &shm_area;
712 rstream.format.frame_rate = 48000;
713 rstream.direction = CRAS_STREAM_OUTPUT;
716 EXPECT_EQ(1, thread_drain_stream_ms_remaining(&thread, &rstream));
719 EXPECT_EQ(10, thread_drain_stream_ms_remaining(&thread, &rstream));
722 EXPECT_EQ(0, thread_drain_stream_ms_remaining(&thread, &rstream));
724 rstream.direction = CRAS_STREAM_INPUT;
726 EXPECT_EQ(0, thread_drain_stream_ms_remaining(&thread, &rstream));
882 void cras_rstream_dev_attach(struct cras_rstream *rstream,
888 void cras_rstream_dev_detach(struct cras_rstream *rstream, unsigned int dev_id)
896 void cras_rstream_dev_offset_update(struct cras_rstream *rstream,
902 cras_rstream_dev_offset_update_rstream_val[i] = rstream;
909 unsigned int cras_rstream_dev_offset(const struct cras_rstream *rstream,
914 cras_rstream_dev_offset_rstream_val[i] = rstream;
922 void cras_rstream_record_fetch_interval(struct cras_rstream *rstream,
