32     pa_stream *stream;  member
38     pa_stream *stream;  member
85 #define CHECK_DEAD_GOTO(c, stream, label, msg)                          \  argument
88             !(stream) || !PA_STREAM_IS_GOOD (pa_stream_get_state ((stream)))) { \
90                 ((stream) && pa_stream_get_state ((stream)) == PA_STREAM_FAILED)) { \
107     CHECK_DEAD_GOTO(c, p->stream, unlock_and_fail,  in qpa_get_buffer_in()
111         r = pa_stream_peek(p->stream, &p->read_data, &p->read_length);  in qpa_get_buffer_in()
135     CHECK_DEAD_GOTO(c, p->stream, unlock,  in qpa_put_buffer_in()
144         r = pa_stream_drop(p->stream);  in qpa_put_buffer_in()
160     CHECK_DEAD_GOTO(c, p->stream, unlock_and_fail,  in qpa_read()
162     if (pa_stream_get_state(p->stream) != PA_STREAM_READY) {  in qpa_read()
163         /* wait for stream to become ready */  in qpa_read()
172             r = pa_stream_peek(p->stream, &p->read_data, &p->read_length);  in qpa_read()
189             r = pa_stream_drop(p->stream);  in qpa_read()
212     CHECK_DEAD_GOTO(c, p->stream, unlock_and_fail,  in qpa_buffer_get_free()
214     if (pa_stream_get_state(p->stream) != PA_STREAM_READY) {  in qpa_buffer_get_free()
215         /* wait for stream to become ready */  in qpa_buffer_get_free()
220     l = pa_stream_writable_size(p->stream);  in qpa_buffer_get_free()
242     CHECK_DEAD_GOTO(c, p->stream, unlock_and_fail,  in qpa_get_buffer_out()
246     r = pa_stream_begin_write(p->stream, &ret, size);  in qpa_get_buffer_out()
267     CHECK_DEAD_GOTO(c, p->stream, unlock_and_fail,  in qpa_put_buffer_out()
270     r = pa_stream_write(p->stream, data, length, NULL, 0LL, PA_SEEK_RELATIVE);  in qpa_put_buffer_out()
290     CHECK_DEAD_GOTO(c, p->stream, unlock_and_fail,  in qpa_write()
292     if (pa_stream_get_state(p->stream) != PA_STREAM_READY) {  in qpa_write()
293         /* wait for stream to become ready */  in qpa_write()
298     l = pa_stream_writable_size(p->stream);  in qpa_write()
307     r = pa_stream_write(p->stream, data, l, NULL, 0LL, PA_SEEK_RELATIVE);  in qpa_write()
423     pa_stream *stream = NULL;  in qpa_simple_new()  local
472     stream = pa_stream_new(c->context, name, ss, &map);  in qpa_simple_new()
473     if (!stream) {  in qpa_simple_new()
477     pa_stream_set_state_callback(stream, stream_state_cb, c);  in qpa_simple_new()
482         /* don't move the stream if the user specified a sink/source */  in qpa_simple_new()
487         r = pa_stream_connect_playback(stream, dev, attr, flags, NULL, NULL);  in qpa_simple_new()
489         r = pa_stream_connect_record(stream, dev, attr, flags);  in qpa_simple_new()
498     return stream;  in qpa_simple_new()
503     if (stream) {  in qpa_simple_new()
504         pa_stream_unref (stream);  in qpa_simple_new()
537     pa->stream = qpa_simple_new (  in qpa_init_out()
546     if (!pa->stream) {  in qpa_init_out()
586     pa->stream = qpa_simple_new (  in qpa_init_in()
595     if (!pa->stream) {  in qpa_init_in()
611 static void qpa_simple_disconnect(PAConnection *c, pa_stream *stream)  in qpa_simple_disconnect()  argument
619     while (pa_stream_get_state(stream) == PA_STREAM_CREATING) {  in qpa_simple_disconnect()
623     err = pa_stream_disconnect(stream);  in qpa_simple_disconnect()
627     pa_stream_unref(stream);  in qpa_simple_disconnect()
634     if (pa->stream) {  in qpa_fini_out()
638         qpa_simple_disconnect(c, pa->stream);  in qpa_fini_out()
639         pa->stream = NULL;  in qpa_fini_out()
648     if (pa->stream) {  in qpa_fini_in()
653             int r = pa_stream_drop(pa->stream);  in qpa_fini_in()
660         qpa_simple_disconnect(c, pa->stream);  in qpa_fini_in()
661         pa->stream = NULL;  in qpa_fini_in()
686                                           pa_stream_get_index(pa->stream),  in qpa_volume_out()
696                                         pa_stream_get_index(pa->stream),  in qpa_volume_out()
728         pa_stream_get_index(pa->stream),  in qpa_volume_in()
738         pa_stream_get_index(pa->stream),  in qpa_volume_in()