Lines Matching defs:sink
52 #include <pulsecore/sink.h>
70 #include "raop-sink.h"
80 pa_sink *sink;
95 /* if true, behaves like a null-sink when disconnected */
132 pa_asyncmsgq_post(u->thread_mq.inq, PA_MSGOBJECT(u->sink), PA_SINK_MESSAGE_SET_RAOP_STATE, PA_INT_TO_PTR(state), 0, NULL, NULL);
150 latency = pa_bytes_to_usec(u->write_count, &u->sink->sample_spec) - (int64_t) now;
169 if (u->sink->state == PA_SINK_RUNNING) {
197 if (u->autoreconnect && u->sink->state == PA_SINK_RUNNING) {
232 if (u->sink->thread_info.state == PA_SINK_SUSPENDED) {
238 sink_set_volume_cb(u->sink);
264 if (u->sink->thread_info.state == PA_SINK_SUSPENDED) {
271 if (u->sink->thread_info.state != PA_SINK_IDLE) {
277 if (u->sink->thread_info.state != PA_SINK_IDLE)
341 * it is emulating a null sink */
459 if (PA_SINK_IS_OPENED(u->sink->thread_info.state)) {
460 if (u->sink->thread_info.rewind_requested)
461 pa_sink_process_rewind(u->sink, 0);
488 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink),
513 if (u->sink->thread_info.state != PA_SINK_RUNNING) {
551 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink),
580 pa_sink_render_full(u->sink, u->block_size, &u->memchunk);
593 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink), PA_SINK_MESSAGE_DISCONNECT_REQUEST,
607 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink), PA_SINK_MESSAGE_DISCONNECT_REQUEST,
620 position = u->write_count - pa_usec_to_bytes(u->delay, &u->sink->sample_spec);
626 estimated = pa_bytes_to_usec(position, &u->sink->sample_spec);
632 intvl = u->start + pa_bytes_to_usec(u->write_count, &u->sink->sample_spec);
639 intvl = u->start + pa_bytes_to_usec(u->write_count, &u->sink->sample_spec);
867 pa_proplist_setf(data.proplist, PA_PROP_DEVICE_DESCRIPTION, "RAOP sink '%s'", server);
897 u->sink = pa_sink_new(m->core, &data, PA_SINK_LATENCY | PA_SINK_NETWORK);
900 if (!(u->sink)) {
901 pa_log("Failed to create sink object");
905 u->sink->parent.process_msg = sink_process_msg;
906 u->sink->set_state_in_io_thread = sink_set_state_in_io_thread_cb;
907 pa_sink_set_set_volume_callback(u->sink, sink_set_volume_cb);
908 pa_sink_set_set_mute_callback(u->sink, sink_set_mute_cb);
909 u->sink->userdata = u;
910 u->sink->set_port = sink_set_port_cb;
912 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq);
913 pa_sink_set_rtpoll(u->sink, u->rtpoll);
925 pa_sink_set_max_request(u->sink, u->block_size);
926 u->block_usec = pa_bytes_to_usec(u->block_size, &u->sink->sample_spec);
930 thread_name = pa_sprintf_malloc("raop-sink-%s", server);
932 pa_log("Failed to create sink thread");
938 pa_sink_put(u->sink);
944 return u->sink;
958 if (u->sink)
959 pa_sink_unlink(u->sink);
968 if (u->sink)
969 pa_sink_unref(u->sink);
970 u->sink = NULL;