Lines Matching defs:source
96 "source_name=<name for the local source> "
97 "source_properties=<properties for the local source> "
98 "auto=<determine server/source/cookie automatically> "
100 "source=<remote source name> "
130 "source",
236 pa_source *source;
385 pa_asyncmsgq_send(u->source->asyncmsgq, PA_MSGOBJECT(u->source), SOURCE_MESSAGE_REMOTE_SUSPEND, PA_UINT32_TO_PTR(suspended), 0, NULL);
418 pa_asyncmsgq_send(u->source->asyncmsgq, PA_MSGOBJECT(u->source), SOURCE_MESSAGE_REMOTE_SUSPEND, PA_UINT32_TO_PTR(suspended), 0, NULL);
735 stream_cork_within_thread(u, u->source->thread_info.state == PA_SOURCE_SUSPENDED);
770 if (PA_SOURCE_IS_OPENED(u->source->thread_info.state))
771 pa_source_post(u->source, &c);
791 bytes = - pa_usec_to_bytes(- offset, &u->source->sample_spec);
793 bytes = pa_usec_to_bytes(offset, &u->source->sample_spec);
802 y = pa_bytes_to_usec((uint64_t) u->counter, &u->source->sample_spec);
995 ss = &u->source->sample_spec;
1013 * is not necessary for the source, because if data is received between request
1014 * and reply, it was already posted before we requested the source latency. */
1026 pa_asyncmsgq_send(u->source->asyncmsgq, PA_MSGOBJECT(u->source), SOURCE_MESSAGE_UPDATE_LATENCY, 0, delay, NULL);
1093 pa_source_set_description(u->source, d);
1094 pa_proplist_sets(u->source->proplist, "tunnel.remote.user", u->user_name);
1095 pa_proplist_sets(u->source->proplist, "tunnel.remote.fqdn", u->server_fqdn);
1096 pa_proplist_sets(u->source->proplist, "tunnel.remote.description", u->device_description);
1692 /* pa_source_set_latency_range(u->source, usec + MIN_NETWORK_LATENCY_USEC, 0); */
1781 pa_proplist_setf(u->source->proplist, "tunnel.remote_version", "%u", u->version);
1782 pa_source_update_proplist(u->source, 0, NULL);
1819 u->fragsize = (uint32_t) pa_usec_to_bytes(PA_USEC_PER_MSEC * u->latency, &u->source->sample_spec);
1848 pa_tagstruct_put_sample_spec(reply, &u->source->sample_spec);
1849 pa_tagstruct_put_channel_map(reply, &u->source->channel_map);
1853 pa_tagstruct_put_boolean(reply, !PA_SOURCE_IS_OPENED(u->source->state));
1916 pa_cvolume_reset(&volume, u->source->sample_spec.channels);
1978 pa_asyncmsgq_send(u->source->asyncmsgq, PA_MSGOBJECT(u->source), SOURCE_MESSAGE_POST, PA_UINT_TO_PTR(seek), offset, chunk);
2014 if (!u->source) {
2164 data_name = pa_sprintf_malloc("tunnel-source.%s", u->server_name);
2176 pa_proplist_sets(data.proplist, "tunnel.remote.source", u->source_name);
2180 u->source = pa_source_new(u->module->core, &data, PA_SOURCE_NETWORK|PA_SOURCE_LATENCY);
2182 if (!u->source) {
2183 pa_log("Failed to create source.");
2187 u->source->parent.process_msg = source_process_msg;
2188 u->source->set_state_in_main_thread = source_set_state_in_main_thread_cb;
2189 u->source->userdata = u;
2191 /* pa_source_set_latency_range(u->source, MIN_NETWORK_LATENCY_USEC, 0); */
2193 pa_source_set_asyncmsgq(u->source, u->thread_mq.inq);
2194 pa_source_set_rtpoll(u->source, u->rtpoll);
2195 pa_source_set_fixed_latency(u->source, u->latency * PA_USEC_PER_MSEC);
2197 u->mcalign = pa_mcalign_new(pa_frame_size(&u->source->sample_spec));
2199 pa_source_put(u->source);
2326 u->source_name = pa_xstrdup(pa_modargs_get_value(ma, "source", NULL));;
2328 u->source = NULL;
2426 /* Also determine the default sink/source on the other server */
2565 if (u->source)
2566 pa_source_unlink(u->source);
2580 if (u->source)
2581 pa_source_unref(u->source);