From c65ebeec1e3eafef453ff9d936af4d314034c5c3 Mon Sep 17 00:00:00 2001 From: Lennart Poettering Date: Wed, 17 Jun 2009 15:09:28 +0200 Subject: raop: move all raop files to subdir --- src/modules/module-raop-sink.c | 697 ----------------------------------------- 1 file changed, 697 deletions(-) delete mode 100644 src/modules/module-raop-sink.c (limited to 'src/modules/module-raop-sink.c') diff --git a/src/modules/module-raop-sink.c b/src/modules/module-raop-sink.c deleted file mode 100644 index 54de42c2..00000000 --- a/src/modules/module-raop-sink.c +++ /dev/null @@ -1,697 +0,0 @@ -/*** - This file is part of PulseAudio. - - Copyright 2004-2006 Lennart Poettering - Copyright 2008 Colin Guthrie - - PulseAudio is free software; you can redistribute it and/or modify - it under the terms of the GNU Lesser General Public License as published - by the Free Software Foundation; either version 2.1 of the License, - or (at your option) any later version. - - PulseAudio is distributed in the hope that it will be useful, but - WITHOUT ANY WARRANTY; without even the implied warranty of - MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - General Public License for more details. - - You should have received a copy of the GNU Lesser General Public License - along with PulseAudio; if not, write to the Free Software - Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 - USA. -***/ - -#ifdef HAVE_CONFIG_H -#include -#endif - -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include - -#ifdef HAVE_LINUX_SOCKIOS_H -#include -#endif - -#include -#include - -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include - -#include "module-raop-sink-symdef.h" -#include "rtp.h" -#include "sdp.h" -#include "sap.h" -#include "raop_client.h" - -PA_MODULE_AUTHOR("Colin Guthrie"); -PA_MODULE_DESCRIPTION("RAOP Sink"); -PA_MODULE_VERSION(PACKAGE_VERSION); -PA_MODULE_LOAD_ONCE(FALSE); -PA_MODULE_USAGE( - "sink_name= " - "sink_properties= " - "server=
" - "format= " - "rate= " - "channels="); - -#define DEFAULT_SINK_NAME "raop" - -struct userdata { - pa_core *core; - pa_module *module; - pa_sink *sink; - - pa_thread_mq thread_mq; - pa_rtpoll *rtpoll; - pa_rtpoll_item *rtpoll_item; - pa_thread *thread; - - pa_memchunk raw_memchunk; - pa_memchunk encoded_memchunk; - - void *write_data; - size_t write_length, write_index; - - void *read_data; - size_t read_length, read_index; - - pa_usec_t latency; - - /*esd_format_t format;*/ - int32_t rate; - - pa_smoother *smoother; - int fd; - - int64_t offset; - int64_t encoding_overhead; - int32_t next_encoding_overhead; - double encoding_ratio; - - pa_raop_client *raop; - - size_t block_size; -}; - -static const char* const valid_modargs[] = { - "sink_name", - "sink_properties", - "server", - "format", - "rate", - "channels", - "description", /* supported for compatibility reasons, made redundant by sink_properties= */ - NULL -}; - -enum { - SINK_MESSAGE_PASS_SOCKET = PA_SINK_MESSAGE_MAX, - SINK_MESSAGE_RIP_SOCKET -}; - -/* Forward declaration */ -static void sink_set_volume_cb(pa_sink *); - -static void on_connection(int fd, void*userdata) { - int so_sndbuf = 0; - socklen_t sl = sizeof(int); - struct userdata *u = userdata; - pa_assert(u); - - pa_assert(u->fd < 0); - u->fd = fd; - - if (getsockopt(u->fd, SOL_SOCKET, SO_SNDBUF, &so_sndbuf, &sl) < 0) - pa_log_warn("getsockopt(SO_SNDBUF) failed: %s", pa_cstrerror(errno)); - else { - pa_log_debug("SO_SNDBUF is %zu.", (size_t) so_sndbuf); - pa_sink_set_max_request(u->sink, PA_MAX((size_t) so_sndbuf, u->block_size)); - } - - /* Set the initial volume */ - sink_set_volume_cb(u->sink); - - pa_log_debug("Connection authenticated, handing fd to IO thread..."); - - pa_asyncmsgq_post(u->thread_mq.inq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_PASS_SOCKET, NULL, 0, NULL, NULL); -} - -static void on_close(void*userdata) { - struct userdata *u = userdata; - pa_assert(u); - - pa_log_debug("Connection closed, informing IO thread..."); - - pa_asyncmsgq_post(u->thread_mq.inq, PA_MSGOBJECT(u->sink), SINK_MESSAGE_RIP_SOCKET, NULL, 0, NULL, NULL); -} - -static int sink_process_msg(pa_msgobject *o, int code, void *data, int64_t offset, pa_memchunk *chunk) { - struct userdata *u = PA_SINK(o)->userdata; - - switch (code) { - - case PA_SINK_MESSAGE_SET_STATE: - - switch ((pa_sink_state_t) PA_PTR_TO_UINT(data)) { - - case PA_SINK_SUSPENDED: - pa_assert(PA_SINK_IS_OPENED(u->sink->thread_info.state)); - - pa_smoother_pause(u->smoother, pa_rtclock_usec()); - - /* Issue a FLUSH if we are connected */ - if (u->fd >= 0) { - pa_raop_flush(u->raop); - } - break; - - case PA_SINK_IDLE: - case PA_SINK_RUNNING: - - if (u->sink->thread_info.state == PA_SINK_SUSPENDED) { - pa_smoother_resume(u->smoother, pa_rtclock_usec(), TRUE); - - /* The connection can be closed when idle, so check to - see if we need to reestablish it */ - if (u->fd < 0) - pa_raop_connect(u->raop); - else - pa_raop_flush(u->raop); - } - - break; - - case PA_SINK_UNLINKED: - case PA_SINK_INIT: - case PA_SINK_INVALID_STATE: - ; - } - - break; - - case PA_SINK_MESSAGE_GET_LATENCY: { - pa_usec_t w, r; - - r = pa_smoother_get(u->smoother, pa_rtclock_usec()); - w = pa_bytes_to_usec((u->offset - u->encoding_overhead + (u->encoded_memchunk.length / u->encoding_ratio)), &u->sink->sample_spec); - - *((pa_usec_t*) data) = w > r ? w - r : 0; - return 0; - } - - case SINK_MESSAGE_PASS_SOCKET: { - struct pollfd *pollfd; - - pa_assert(!u->rtpoll_item); - - u->rtpoll_item = pa_rtpoll_item_new(u->rtpoll, PA_RTPOLL_NEVER, 1); - pollfd = pa_rtpoll_item_get_pollfd(u->rtpoll_item, NULL); - pollfd->fd = u->fd; - pollfd->events = POLLOUT; - /*pollfd->events = */pollfd->revents = 0; - - if (u->sink->thread_info.state == PA_SINK_SUSPENDED) { - /* Our stream has been suspended so we just flush it.... */ - pa_raop_flush(u->raop); - } - return 0; - } - - case SINK_MESSAGE_RIP_SOCKET: { - pa_assert(u->fd >= 0); - - pa_close(u->fd); - u->fd = -1; - - if (u->sink->thread_info.state == PA_SINK_SUSPENDED) { - - pa_log_debug("RTSP control connection closed, but we're suspended so let's not worry about it... we'll open it again later"); - - if (u->rtpoll_item) - pa_rtpoll_item_free(u->rtpoll_item); - u->rtpoll_item = NULL; - } else { - /* Quesiton: is this valid here: or should we do some sort of: - return pa_sink_process_msg(PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL); - ?? */ - pa_module_unload_request(u->module, TRUE); - } - return 0; - } - } - - return pa_sink_process_msg(o, code, data, offset, chunk); -} - -static void sink_set_volume_cb(pa_sink *s) { - struct userdata *u = s->userdata; - pa_cvolume hw; - pa_volume_t v; - char t[PA_CVOLUME_SNPRINT_MAX]; - - pa_assert(u); - - /* If we're muted we don't need to do anything */ - if (s->muted) - return; - - /* Calculate the max volume of all channels. - We'll use this as our (single) volume on the APEX device and emulate - any variation in channel volumes in software */ - v = pa_cvolume_max(&s->virtual_volume); - - /* Create a pa_cvolume version of our single value */ - pa_cvolume_set(&hw, s->sample_spec.channels, v); - - /* Perform any software manipulation of the volume needed */ - pa_sw_cvolume_divide(&s->soft_volume, &s->virtual_volume, &hw); - - pa_log_debug("Requested volume: %s", pa_cvolume_snprint(t, sizeof(t), &s->virtual_volume)); - pa_log_debug("Got hardware volume: %s", pa_cvolume_snprint(t, sizeof(t), &hw)); - pa_log_debug("Calculated software volume: %s", pa_cvolume_snprint(t, sizeof(t), &s->soft_volume)); - - /* Any necessary software volume manipulateion is done so set - our hw volume (or v as a single value) on the device */ - pa_raop_client_set_volume(u->raop, v); -} - -static void sink_set_mute_cb(pa_sink *s) { - struct userdata *u = s->userdata; - - pa_assert(u); - - if (s->muted) { - pa_raop_client_set_volume(u->raop, PA_VOLUME_MUTED); - } else { - sink_set_volume_cb(s); - } -} - -static void thread_func(void *userdata) { - struct userdata *u = userdata; - int write_type = 0; - pa_memchunk silence; - uint32_t silence_overhead = 0; - double silence_ratio = 0; - - pa_assert(u); - - pa_log_debug("Thread starting up"); - - pa_thread_mq_install(&u->thread_mq); - pa_rtpoll_install(u->rtpoll); - - pa_smoother_set_time_offset(u->smoother, pa_rtclock_usec()); - - /* Create a chunk of memory that is our encoded silence sample. */ - pa_memchunk_reset(&silence); - - for (;;) { - int ret; - - if (PA_SINK_IS_OPENED(u->sink->thread_info.state)) - if (u->sink->thread_info.rewind_requested) - pa_sink_process_rewind(u->sink, 0); - - if (u->rtpoll_item) { - struct pollfd *pollfd; - pollfd = pa_rtpoll_item_get_pollfd(u->rtpoll_item, NULL); - - /* Render some data and write it to the fifo */ - if (/*PA_SINK_IS_OPENED(u->sink->thread_info.state) && */pollfd->revents) { - pa_usec_t usec; - int64_t n; - void *p; - - if (!silence.memblock) { - pa_memchunk silence_tmp; - - pa_memchunk_reset(&silence_tmp); - silence_tmp.memblock = pa_memblock_new(u->core->mempool, 4096); - silence_tmp.length = 4096; - p = pa_memblock_acquire(silence_tmp.memblock); - memset(p, 0, 4096); - pa_memblock_release(silence_tmp.memblock); - pa_raop_client_encode_sample(u->raop, &silence_tmp, &silence); - pa_assert(0 == silence_tmp.length); - silence_overhead = silence_tmp.length - 4096; - silence_ratio = silence_tmp.length / 4096; - pa_memblock_unref(silence_tmp.memblock); - } - - for (;;) { - ssize_t l; - - if (u->encoded_memchunk.length <= 0) { - if (u->encoded_memchunk.memblock) - pa_memblock_unref(u->encoded_memchunk.memblock); - if (PA_SINK_IS_OPENED(u->sink->thread_info.state)) { - size_t rl; - - /* We render real data */ - if (u->raw_memchunk.length <= 0) { - if (u->raw_memchunk.memblock) - pa_memblock_unref(u->raw_memchunk.memblock); - pa_memchunk_reset(&u->raw_memchunk); - - /* Grab unencoded data */ - pa_sink_render(u->sink, u->block_size, &u->raw_memchunk); - } - pa_assert(u->raw_memchunk.length > 0); - - /* Encode it */ - rl = u->raw_memchunk.length; - u->encoding_overhead += u->next_encoding_overhead; - pa_raop_client_encode_sample(u->raop, &u->raw_memchunk, &u->encoded_memchunk); - u->next_encoding_overhead = (u->encoded_memchunk.length - (rl - u->raw_memchunk.length)); - u->encoding_ratio = u->encoded_memchunk.length / (rl - u->raw_memchunk.length); - } else { - /* We render some silence into our memchunk */ - memcpy(&u->encoded_memchunk, &silence, sizeof(pa_memchunk)); - pa_memblock_ref(silence.memblock); - - /* Calculate/store some values to be used with the smoother */ - u->next_encoding_overhead = silence_overhead; - u->encoding_ratio = silence_ratio; - } - } - pa_assert(u->encoded_memchunk.length > 0); - - p = pa_memblock_acquire(u->encoded_memchunk.memblock); - l = pa_write(u->fd, (uint8_t*) p + u->encoded_memchunk.index, u->encoded_memchunk.length, &write_type); - pa_memblock_release(u->encoded_memchunk.memblock); - - pa_assert(l != 0); - - if (l < 0) { - - if (errno == EINTR) - continue; - else if (errno == EAGAIN) { - - /* OK, we filled all socket buffers up - * now. */ - goto filled_up; - - } else { - pa_log("Failed to write data to FIFO: %s", pa_cstrerror(errno)); - goto fail; - } - - } else { - u->offset += l; - - u->encoded_memchunk.index += l; - u->encoded_memchunk.length -= l; - - pollfd->revents = 0; - - if (u->encoded_memchunk.length > 0) { - /* we've completely written the encoded data, so update our overhead */ - u->encoding_overhead += u->next_encoding_overhead; - - /* OK, we wrote less that we asked for, - * hence we can assume that the socket - * buffers are full now */ - goto filled_up; - } - } - } - - filled_up: - - /* At this spot we know that the socket buffers are - * fully filled up. This is the best time to estimate - * the playback position of the server */ - - n = u->offset - u->encoding_overhead; - -#ifdef SIOCOUTQ - { - int l; - if (ioctl(u->fd, SIOCOUTQ, &l) >= 0 && l > 0) - n -= (l / u->encoding_ratio); - } -#endif - - usec = pa_bytes_to_usec(n, &u->sink->sample_spec); - - if (usec > u->latency) - usec -= u->latency; - else - usec = 0; - - pa_smoother_put(u->smoother, pa_rtclock_usec(), usec); - } - - /* Hmm, nothing to do. Let's sleep */ - pollfd->events = POLLOUT; /*PA_SINK_IS_OPENED(u->sink->thread_info.state) ? POLLOUT : 0;*/ - } - - if ((ret = pa_rtpoll_run(u->rtpoll, TRUE)) < 0) - goto fail; - - if (ret == 0) - goto finish; - - if (u->rtpoll_item) { - struct pollfd* pollfd; - - pollfd = pa_rtpoll_item_get_pollfd(u->rtpoll_item, NULL); - - if (pollfd->revents & ~POLLOUT) { - if (u->sink->thread_info.state != PA_SINK_SUSPENDED) { - pa_log("FIFO shutdown."); - goto fail; - } - - /* We expect this to happen on occasion if we are not sending data. - It's perfectly natural and normal and natural */ - if (u->rtpoll_item) - pa_rtpoll_item_free(u->rtpoll_item); - u->rtpoll_item = NULL; - } - } - } - -fail: - /* If this was no regular exit from the loop we have to continue - * processing messages until we received PA_MESSAGE_SHUTDOWN */ - pa_asyncmsgq_post(u->thread_mq.outq, PA_MSGOBJECT(u->core), PA_CORE_MESSAGE_UNLOAD_MODULE, u->module, 0, NULL, NULL); - pa_asyncmsgq_wait_for(u->thread_mq.inq, PA_MESSAGE_SHUTDOWN); - -finish: - if (silence.memblock) - pa_memblock_unref(silence.memblock); - pa_log_debug("Thread shutting down"); -} - -int pa__init(pa_module*m) { - struct userdata *u = NULL; - pa_sample_spec ss; - pa_modargs *ma = NULL; - const char *server, *desc; - pa_sink_new_data data; - - pa_assert(m); - - if (!(ma = pa_modargs_new(m->argument, valid_modargs))) { - pa_log("failed to parse module arguments"); - goto fail; - } - - ss = m->core->default_sample_spec; - if (pa_modargs_get_sample_spec(ma, &ss) < 0) { - pa_log("invalid sample format specification"); - goto fail; - } - - if ((/*ss.format != PA_SAMPLE_U8 &&*/ ss.format != PA_SAMPLE_S16NE) || - (ss.channels > 2)) { - pa_log("sample type support is limited to mono/stereo and U8 or S16NE sample data"); - goto fail; - } - - u = pa_xnew0(struct userdata, 1); - u->core = m->core; - u->module = m; - m->userdata = u; - u->fd = -1; - u->smoother = pa_smoother_new( - PA_USEC_PER_SEC, - PA_USEC_PER_SEC*2, - TRUE, - TRUE, - 10, - 0, - FALSE); - pa_memchunk_reset(&u->raw_memchunk); - pa_memchunk_reset(&u->encoded_memchunk); - u->offset = 0; - u->encoding_overhead = 0; - u->next_encoding_overhead = 0; - u->encoding_ratio = 1.0; - - u->rtpoll = pa_rtpoll_new(); - pa_thread_mq_init(&u->thread_mq, m->core->mainloop, u->rtpoll); - u->rtpoll_item = NULL; - - /*u->format = - (ss.format == PA_SAMPLE_U8 ? ESD_BITS8 : ESD_BITS16) | - (ss.channels == 2 ? ESD_STEREO : ESD_MONO);*/ - u->rate = ss.rate; - u->block_size = pa_usec_to_bytes(PA_USEC_PER_SEC/20, &ss); - - u->read_data = u->write_data = NULL; - u->read_index = u->write_index = u->read_length = u->write_length = 0; - - /*u->state = STATE_AUTH;*/ - u->latency = 0; - - if (!(server = pa_modargs_get_value(ma, "server", NULL))) { - pa_log("No server argument given."); - goto fail; - } - - pa_sink_new_data_init(&data); - data.driver = __FILE__; - data.module = m; - pa_sink_new_data_set_name(&data, pa_modargs_get_value(ma, "sink_name", DEFAULT_SINK_NAME)); - pa_sink_new_data_set_sample_spec(&data, &ss); - pa_proplist_sets(data.proplist, PA_PROP_DEVICE_STRING, server); - pa_proplist_sets(data.proplist, PA_PROP_DEVICE_INTENDED_ROLES, "music"); - if ((desc = pa_modargs_get_value(ma, "description", NULL))) - pa_proplist_sets(data.proplist, PA_PROP_DEVICE_DESCRIPTION, desc); - else - pa_proplist_setf(data.proplist, PA_PROP_DEVICE_DESCRIPTION, "RAOP sink '%s'", server); - - if (pa_modargs_get_proplist(ma, "sink_properties", data.proplist, PA_UPDATE_REPLACE) < 0) { - pa_log("Invalid properties"); - pa_sink_new_data_done(&data); - goto fail; - } - - u->sink = pa_sink_new(m->core, &data, PA_SINK_LATENCY|PA_SINK_NETWORK); - pa_sink_new_data_done(&data); - - if (!u->sink) { - pa_log("Failed to create sink."); - goto fail; - } - - u->sink->parent.process_msg = sink_process_msg; - u->sink->userdata = u; - u->sink->set_volume = sink_set_volume_cb; - u->sink->set_mute = sink_set_mute_cb; - u->sink->flags = PA_SINK_LATENCY|PA_SINK_NETWORK|PA_SINK_HW_VOLUME_CTRL; - - pa_sink_set_asyncmsgq(u->sink, u->thread_mq.inq); - pa_sink_set_rtpoll(u->sink, u->rtpoll); - - if (!(u->raop = pa_raop_client_new(u->core, server))) { - pa_log("Failed to connect to server."); - goto fail; - } - - pa_raop_client_set_callback(u->raop, on_connection, u); - pa_raop_client_set_closed_callback(u->raop, on_close, u); - - if (!(u->thread = pa_thread_new(thread_func, u))) { - pa_log("Failed to create thread."); - goto fail; - } - - pa_sink_put(u->sink); - - pa_modargs_free(ma); - - return 0; - -fail: - if (ma) - pa_modargs_free(ma); - - pa__done(m); - - return -1; -} - -int pa__get_n_used(pa_module *m) { - struct userdata *u; - - pa_assert(m); - pa_assert_se(u = m->userdata); - - return pa_sink_linked_by(u->sink); -} - -void pa__done(pa_module*m) { - struct userdata *u; - pa_assert(m); - - if (!(u = m->userdata)) - return; - - if (u->sink) - pa_sink_unlink(u->sink); - - if (u->thread) { - pa_asyncmsgq_send(u->thread_mq.inq, NULL, PA_MESSAGE_SHUTDOWN, NULL, 0, NULL); - pa_thread_free(u->thread); - } - - pa_thread_mq_done(&u->thread_mq); - - if (u->sink) - pa_sink_unref(u->sink); - - if (u->rtpoll_item) - pa_rtpoll_item_free(u->rtpoll_item); - - if (u->rtpoll) - pa_rtpoll_free(u->rtpoll); - - if (u->raw_memchunk.memblock) - pa_memblock_unref(u->raw_memchunk.memblock); - - if (u->encoded_memchunk.memblock) - pa_memblock_unref(u->encoded_memchunk.memblock); - - if (u->raop) - pa_raop_client_free(u->raop); - - pa_xfree(u->read_data); - pa_xfree(u->write_data); - - if (u->smoother) - pa_smoother_free(u->smoother); - - if (u->fd >= 0) - pa_close(u->fd); - - pa_xfree(u); -} -- cgit