Lines Matching refs:stream
29 #include <pulse/stream.h>
47 PA_MODULE_DESCRIPTION("Create a network sink which connects via a stream to a remote PulseAudio server");
68 static void stream_state_cb(pa_stream *stream, void *userdata);
69 static void stream_changed_buffer_attr_cb(pa_stream *stream, void *userdata);
70 static void stream_set_buffer_attr_cb(pa_stream *stream, int success, void *userdata);
99 pa_stream *stream;
144 pa_assert(u->stream);
148 * cork the stream), we don't want to keep any old data around, because
151 if ((operation = pa_stream_flush(u->stream, NULL, NULL)))
155 if ((operation = pa_stream_cork(u->stream, cork, NULL, NULL)))
227 pa_stream_get_state(u->stream) == PA_STREAM_READY &&
231 writable = pa_stream_writable_size(u->stream);
243 ret = pa_stream_write(u->stream,
253 pa_log_error("Could not write data into the stream ... ret = %i", ret);
268 if (u->stream) {
269 pa_stream_disconnect(u->stream);
270 pa_stream_unref(u->stream);
271 u->stream = NULL;
283 static void stream_state_cb(pa_stream *stream, void *userdata) {
288 switch (pa_stream_get_state(stream)) {
308 stream_changed_buffer_attr_cb(stream, userdata);
315 /* called when remote server changes the stream buffer_attr */
316 static void stream_changed_buffer_attr_cb(pa_stream *stream, void *userdata) {
321 bufferattr = pa_stream_get_buffer_attr(u->stream);
328 /* called after we requested a change of the stream buffer_attr */
329 static void stream_set_buffer_attr_cb(pa_stream *stream, int success, void *userdata) {
330 stream_changed_buffer_attr_cb(stream, userdata);
334 static void stream_underflow_callback(pa_stream *stream, void *userdata) {
339 static void stream_overflow_callback(pa_stream *stream, void *userdata) {
369 /* TODO: old tunnel put here the remote sink_name into stream name e.g. 'Null Output for lynxis@lazus' */
385 u->stream = pa_stream_new_with_proplist(u->context,
393 if (!u->stream) {
394 pa_log_error("Could not create a stream.");
408 pa_stream_set_state_callback(u->stream, stream_state_cb, u);
409 pa_stream_set_buffer_attr_callback(u->stream, stream_changed_buffer_attr_cb, u);
410 pa_stream_set_underflow_callback(u->stream, stream_underflow_callback, u);
411 pa_stream_set_overflow_callback(u->stream, stream_overflow_callback, u);
412 if (pa_stream_connect_playback(u->stream,
418 pa_log_error("Could not connect stream.");
439 pa_log_debug("Connection successful. Creating stream.");
440 pa_assert(!u->stream);
476 if (u->stream) {
477 switch (pa_stream_get_state(u->stream)) {
479 if (pa_stream_get_buffer_attr(u->stream)->tlength == nbytes)
487 if ((operation = pa_stream_set_buffer_attr(u->stream, &bufferattr, stream_set_buffer_attr_cb, u)))
491 /* we have to delay our request until stream is ready */
513 if (!u->stream) {
518 if (pa_stream_get_state(u->stream) != PA_STREAM_READY) {
523 if (pa_stream_get_latency(u->stream, &remote_latency, &negative) < 0) {
550 if (!u->stream || pa_stream_get_state(u->stream) != PA_STREAM_READY)