Lines Matching refs:stream
50 pa_stream *stream;
132 if (!(op = pa_context_get_sink_input_info(ctx, pa_stream_get_index(s->stream),
169 static void pulse_stream_writable(pa_stream *stream, size_t nbytes, void *userdata)
175 if (stream != s->stream)
182 static void pulse_overflow(pa_stream *stream, void *userdata)
188 static void pulse_underflow(pa_stream *stream, void *userdata)
194 static void pulse_stream_state(pa_stream *stream, void *userdata)
198 if (stream != s->stream)
201 switch (pa_stream_get_state(s->stream)) {
215 while ((state = pa_stream_get_state(s->stream)) != PA_STREAM_READY) {
252 static void pulse_stream_result(pa_stream *stream, int success, void *userdata)
256 if (stream != s->stream)
284 op = pa_stream_cork(s->stream, pause, pulse_stream_result, s);
292 op = pa_stream_flush(s->stream, pulse_stream_result, s);
328 op = pa_context_set_sink_input_mute(s->ctx, pa_stream_get_index(s->stream),
338 const pa_sample_spec *ss = pa_stream_get_sample_spec(s->stream);
344 op = pa_context_set_sink_input_volume(s->ctx, pa_stream_get_index(s->stream),
419 if (s->stream) {
420 pa_stream_disconnect(s->stream);
421 pa_stream_set_state_callback(s->stream, NULL, NULL);
422 pa_stream_set_write_callback(s->stream, NULL, NULL);
423 pa_stream_set_overflow_callback(s->stream, NULL, NULL);
424 pa_stream_set_underflow_callback(s->stream, NULL, NULL);
425 pa_stream_unref(s->stream);
426 s->stream = NULL;
459 av_log(s, AV_LOG_ERROR, "Only a single audio stream is supported.\n");
561 s->stream = pa_stream_new(s->ctx, stream_name, &sample_spec,
569 if (!s->stream) {
570 av_log(s, AV_LOG_ERROR, "Cannot create stream.\n");
574 pa_stream_set_state_callback(s->stream, pulse_stream_state, s);
575 pa_stream_set_write_callback(s->stream, pulse_stream_writable, h);
576 pa_stream_set_overflow_callback(s->stream, pulse_overflow, h);
577 pa_stream_set_underflow_callback(s->stream, pulse_underflow, h);
579 if ((ret = pa_stream_connect_playback(s->stream, s->device, &buffer_attributes,
592 buffer_attributes = *pa_stream_get_buffer_attr(s->stream);
649 if (!PA_STREAM_IS_GOOD(pa_stream_get_state(s->stream))) {
650 av_log(s, AV_LOG_ERROR, "PulseAudio stream is in invalid state.\n");
653 while (pa_stream_writable_size(s->stream) < s->minreq) {
661 if ((ret = pa_stream_write(s->stream, pkt->data, pkt->size, NULL, 0, PA_SEEK_RELATIVE)) < 0) {
665 if ((writable_size = pa_stream_writable_size(s->stream)) >= s->minreq)
694 static void pulse_get_output_timestamp(AVFormatContext *h, int stream, int64_t *dts, int64_t *wall)
700 pa_stream_get_latency(s->stream, &latency, &neg);
726 return pulse_set_pause(s, !pa_stream_is_corked(s->stream));
767 { "stream_name", "set stream description", OFFSET(stream_name), AV_OPT_TYPE_STRING, {.str = NULL}, 0, 0, E },