Lines Matching defs:sink
81 "sink_name=<name for the local sink> "
82 "sink_properties=<properties for the local sink> "
83 "auto=<determine server/sink/cookie automatically> "
85 "sink=<remote sink name> "
126 "sink",
231 pa_sink *sink;
383 pa_asyncmsgq_send(u->sink->asyncmsgq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_REMOTE_SUSPEND, PA_UINT32_TO_PTR(suspended), 0, NULL);
416 pa_asyncmsgq_send(u->sink->asyncmsgq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_REMOTE_SUSPEND, PA_UINT32_TO_PTR(suspended), 0, NULL);
568 pa_sink_render(u->sink, u->requested_bytes, &memchunk);
569 pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_POST, NULL, 0, &memchunk, NULL);
590 stream_cork_within_thread(u, u->sink->thread_info.state == PA_SINK_SUSPENDED);
592 if (PA_SINK_IS_OPENED(u->sink->thread_info.state))
607 yl = pa_bytes_to_usec((uint64_t) u->counter, &u->sink->sample_spec);
627 if (PA_SINK_IS_OPENED(u->sink->thread_info.state))
642 bytes = - pa_usec_to_bytes(- offset, &u->sink->sample_spec);
644 bytes = pa_usec_to_bytes(offset, &u->sink->sample_spec);
656 y = pa_bytes_to_usec((uint64_t) u->counter, &u->sink->sample_spec);
867 if (u->sink && PA_UNLIKELY(u->sink->thread_info.rewind_requested))
868 pa_sink_process_rewind(u->sink, 0);
911 pa_asyncmsgq_post(u->sink->asyncmsgq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_REQUEST, NULL, bytes, NULL, NULL);
992 ss = &u->sink->sample_spec;
1016 pa_asyncmsgq_send(u->sink->asyncmsgq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_GET_LATENCY_SNAPSHOT, &send_counter, 0, NULL);
1024 pa_asyncmsgq_send(u->sink->asyncmsgq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_UPDATE_LATENCY, 0, delay, NULL);
1088 pa_sink_set_description(u->sink, d);
1089 pa_proplist_sets(u->sink->proplist, "tunnel.remote.user", u->user_name);
1090 pa_proplist_sets(u->sink->proplist, "tunnel.remote.fqdn", u->server_fqdn);
1091 pa_proplist_sets(u->sink->proplist, "tunnel.remote.description", u->device_description);
1329 uint32_t idx, owner_module, client, sink;
1353 pa_tagstruct_getu32(t, &sink) < 0 ||
1418 pa_assert(u->sink);
1420 if ((u->version < 11 || mute == u->sink->muted) &&
1421 pa_cvolume_equal(&volume, &u->sink->real_volume))
1424 pa_sink_volume_changed(u->sink, &volume);
1427 pa_sink_mute_changed(u->sink, mute);
1690 /* pa_sink_set_latency_range(u->sink, usec + MIN_NETWORK_LATENCY_USEC, 0); */
1721 pa_asyncmsgq_post(u->sink->asyncmsgq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_REQUEST, NULL, bytes, NULL, NULL);
1773 pa_proplist_setf(u->sink->proplist, "tunnel.remote_version", "%u", u->version);
1774 pa_sink_update_proplist(u->sink, 0, NULL);
1815 u->tlength = (uint32_t) pa_usec_to_bytes(PA_USEC_PER_MSEC * u->latency, &u->sink->sample_spec);
1816 u->minreq = (uint32_t) pa_usec_to_bytes(PA_USEC_PER_MSEC * u->latency / 4, &u->sink->sample_spec);
1829 pa_tagstruct_put_sample_spec(reply, &u->sink->sample_spec);
1830 pa_tagstruct_put_channel_map(reply, &u->sink->channel_map);
1834 pa_tagstruct_put_boolean(reply, !PA_SINK_IS_OPENED(u->sink->state));
1839 pa_cvolume_reset(&volume, u->sink->sample_spec.channels);
2007 if (!u->sink) {
2071 static void sink_set_volume(pa_sink *sink) {
2075 pa_assert(sink);
2076 u = sink->userdata;
2083 pa_tagstruct_put_cvolume(t, &sink->real_volume);
2088 static void sink_set_mute(pa_sink *sink) {
2092 pa_assert(sink);
2093 u = sink->userdata;
2103 pa_tagstruct_put_boolean(t, sink->muted);
2115 data_name = pa_sprintf_malloc("tunnel-sink.%s", u->server_name);
2127 pa_proplist_sets(data.proplist, "tunnel.remote.sink", u->sink_name);
2131 u->sink = pa_sink_new(u->module->core, &data, PA_SINK_NETWORK|PA_SINK_LATENCY);
2133 if (!u->sink) {
2134 pa_log("Failed to create sink.");
2138 u->sink->parent.process_msg = sink_process_msg;
2139 u->sink->userdata = u;
2140 u->sink->set_state_in_main_thread = sink_set_state_in_main_thread_cb;
2141 pa_sink_set_set_volume_callback(u->sink, sink_set_volume);
2142 pa_sink_set_set_mute_callback(u->sink, sink_set_mute);
2144 u->sink->refresh_volume = u->sink->refresh_muted = false;
2146 /* pa_sink_set_latency_range(u->sink, MIN_NETWORK_LATENCY_USEC, 0); */
2148 pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq);
2149 pa_sink_set_rtpoll(u->sink, u->rtpoll);
2150 pa_sink_set_fixed_latency(u->sink, u->latency * PA_USEC_PER_MSEC);
2152 pa_sink_put(u->sink);
2321 u->sink_name = pa_xstrdup(pa_modargs_get_value(ma, "sink", NULL));;
2323 u->sink = NULL;
2426 /* Also determine the default sink/source on the other server */
2562 if (u->sink)
2563 pa_sink_unlink(u->sink);
2577 if (u->sink)
2578 pa_sink_unref(u->sink);