Lines Matching refs:stream
41 pa_stream *stream;
71 !(p)->stream || !PA_STREAM_IS_GOOD(pa_stream_get_state((p)->stream))) { \
73 ((p)->stream && pa_stream_get_state((p)->stream) == PA_STREAM_FAILED)) { \
195 if (!(p->stream = pa_stream_new(p->context, stream_name, ss, map))) {
200 pa_stream_set_state_callback(p->stream, stream_state_cb, p);
201 pa_stream_set_read_callback(p->stream, stream_request_cb, p);
202 pa_stream_set_write_callback(p->stream, stream_request_cb, p);
203 pa_stream_set_latency_update_callback(p->stream, stream_latency_update_cb, p);
206 r = pa_stream_connect_playback(p->stream, dev, attr,
211 r = pa_stream_connect_record(p->stream, dev, attr,
224 state = pa_stream_get_state(p->stream);
234 /* Wait until the stream is ready */
258 if (s->stream)
259 pa_stream_unref(s->stream);
287 while (!(l = pa_stream_writable_size(p->stream))) {
297 r = pa_stream_write(p->stream, data, l, NULL, 0LL, PA_SEEK_RELATIVE);
329 r = pa_stream_peek(p->stream, &p->read_data, &p->read_length);
336 /* There's a hole in the stream, skip it. We could generate
338 r = pa_stream_drop(p->stream);
356 r = pa_stream_drop(p->stream);
393 o = pa_stream_drain(p->stream, success_cb, p);
427 o = pa_stream_flush(p->stream, success_cb, p);
465 if (pa_stream_get_latency(p->stream, &t, &negative) >= 0) {
479 already_read = pa_bytes_to_usec(p->read_index, pa_stream_get_sample_spec(p->stream));