Lines Matching refs:stream

29 #include <pulse/stream.h>
47 PA_MODULE_DESCRIPTION("Create a network source which connects via a stream to a remote PulseAudio server");
67 static void stream_state_cb(pa_stream *stream, void *userdata);
97 pa_stream *stream;
142 pa_assert(u->stream);
144 if ((operation = pa_stream_cork(u->stream, cork, NULL, NULL)))
173 /* called from io context to read samples from the stream into our source */
184 if (PA_UNLIKELY(!u->connected || pa_stream_get_state(u->stream) != PA_STREAM_READY))
187 readable = pa_stream_readable_size(u->stream);
190 if (PA_UNLIKELY(pa_stream_peek(u->stream, &p, &nbytes) != 0)) {
222 pa_stream_drop(u->stream);
282 if (u->stream) {
283 pa_stream_disconnect(u->stream);
284 pa_stream_unref(u->stream);
285 u->stream = NULL;
297 static void stream_state_cb(pa_stream *stream, void *userdata) {
302 switch (pa_stream_get_state(stream)) {
353 /* TODO: old tunnel put here the remote source_name into stream name e.g. 'Null Output for lynxis@lazus' */
369 u->stream = pa_stream_new_with_proplist(u->context,
377 if (!u->stream) {
378 pa_log_error("Could not create a stream: %s", pa_strerror(pa_context_errno(u->context)));
390 pa_stream_set_state_callback(u->stream, stream_state_cb, u);
391 pa_stream_set_read_callback(u->stream, stream_read_cb, u);
392 if (pa_stream_connect_record(u->stream,
396 pa_log_debug("Could not create stream: %s", pa_strerror(pa_context_errno(u->context)));
413 pa_log_debug("Connection successful. Creating stream.");
414 pa_assert(!u->stream);
449 if (u->stream) {
450 switch (pa_stream_get_state(u->stream)) {
452 if (pa_stream_get_buffer_attr(u->stream)->fragsize == nbytes)
457 if ((operation = pa_stream_set_buffer_attr(u->stream, &bufferattr, NULL, NULL)))
461 /* we have to delay our request until stream is ready */
483 if (!u->stream) {
488 if (pa_stream_get_state(u->stream) != PA_STREAM_READY) {
493 if (pa_stream_get_latency(u->stream, &remote_latency, &negative) < 0) {
524 if (!u->stream || pa_stream_get_state(u->stream) != PA_STREAM_READY)