mirror of
https://gitlab.freedesktop.org/pulseaudio/pulseaudio.git
synced 2025-11-22 06:59:54 -05:00
52e3628c3e
* Drop "state" directory, fold that into "runtime directory" * No longer automatically rewind when a new stream connects * Rework sound file stream, to cause a rewind on initialisation, shorten _pop() code a bit * Fix reference counting of pa_socket_server in the protocol implementations * Rework daemon initialization code to be compatible with non-SUID-root setups where RLIMIT_RTPRIO is non-zero * Print warning if RT/HP is enabled in the config, but due to missing caps, rlimits, policy we cannot enable it. * Fix potential memory leak in pa_open_config_file() * Add pa_find_config_file() which works much like pa_open_config_file() but doesn't actually open the config file in question. Just searches for it. * Add portable pa_is_path_absolute() * Add pa_close_all() and use it on daemon startup to close leaking file descriptors (inspired from what I did for libdaemon) * Add pa_unblock_sigs() and use it on daemon startup to unblock all signals (inspired from libdaemon, too) * Add pa_reset_sigs() and use it on daemon startup to reset all signal handlers (inspired from libdaemon as well) * Implement pa_set_env() * Define RLIMIT_RTTIME and friends if not defined by glibc * Add pa_strempty() * rename state testing macros to include _IS_, to make clearer that they are no states, but testing macros * Implement pa_source_output_set_requested_latency_within_thread() to be able to forward latency info to sources from within the IO thread * Similar for sink inputs * generelize since_underrun counter in sink inputs to "playing_for" and "underrun_for". Use only this for ignore potential rewind requests over underruns * Add new native protocol message PLAYBACK_STREAM_MESSAGE_STARTED for notification about the end of an underrun * Port native protocol to use underrun_for/playing_for which is maintained by the sink input anyway * Pass underrun_for/playing_for in timing info to client * Drop pa_sink_skip() since it breaks underrun detection code * Move PID file and unix sockets to the runtime dir (i.e. ~/.pulse). This fixes a potention DoS attack from other users stealing dirs in /tmp from us so that we cannot take them anymore) * Allow setting of more resource limits from the config file. Set RTTIME by default * Streamline daemon startup code * Rework algorithm to find default configuration files * If run in system mode use "system.pa" instead of "default.pa" as default script file * Change ladspa sink to use pa_clamp_samples() for clamping samples * Teach module-null-sink how to deal with rewinding * Try to support ALSA devices with no implicit channel map. Synthesize one by padding with PA_CHANNEL_POSITION_AUX channels. This is not tested since I lack hardware with these problems. * Make use of time smoother in the client libraries. * Add new pa_stream_is_corked() and pa_stream_set_started_callback() functions to public API * Since our native socket moved, add some code for finding sockets created by old versions of PA. This should ease upgrades git-svn-id: file:///home/lennart/svn/public/pulseaudio/branches/glitch-free@2329 fefdeb5f-60dc-0310-8127-8f9354f1896f
105 lines
2.6 KiB
C
105 lines
2.6 KiB
C
/* $Id$ */
|
|
|
|
/***
|
|
This file is part of PulseAudio.
|
|
|
|
Copyright 2004-2006 Lennart Poettering
|
|
|
|
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 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 <config.h>
|
|
#endif
|
|
|
|
#include <stdlib.h>
|
|
|
|
#include <pulse/xmalloc.h>
|
|
|
|
#include <pulsecore/cli.h>
|
|
#include <pulsecore/log.h>
|
|
#include <pulsecore/macro.h>
|
|
|
|
#include "protocol-cli.h"
|
|
|
|
/* Don't allow more than this many concurrent connections */
|
|
#define MAX_CONNECTIONS 25
|
|
|
|
struct pa_protocol_cli {
|
|
pa_module *module;
|
|
pa_core *core;
|
|
pa_socket_server*server;
|
|
pa_idxset *connections;
|
|
};
|
|
|
|
static void cli_eof_cb(pa_cli*c, void*userdata) {
|
|
pa_protocol_cli *p = userdata;
|
|
pa_assert(p);
|
|
|
|
pa_idxset_remove_by_data(p->connections, c, NULL);
|
|
pa_cli_free(c);
|
|
}
|
|
|
|
static void on_connection(pa_socket_server*s, pa_iochannel *io, void *userdata) {
|
|
pa_protocol_cli *p = userdata;
|
|
pa_cli *c;
|
|
|
|
pa_assert(s);
|
|
pa_assert(io);
|
|
pa_assert(p);
|
|
|
|
if (pa_idxset_size(p->connections)+1 > MAX_CONNECTIONS) {
|
|
pa_log("Warning! Too many connections (%u), dropping incoming connection.", MAX_CONNECTIONS);
|
|
pa_iochannel_free(io);
|
|
return;
|
|
}
|
|
|
|
c = pa_cli_new(p->core, io, p->module);
|
|
pa_cli_set_eof_callback(c, cli_eof_cb, p);
|
|
|
|
pa_idxset_put(p->connections, c, NULL);
|
|
}
|
|
|
|
pa_protocol_cli* pa_protocol_cli_new(pa_core *core, pa_socket_server *server, pa_module *m, PA_GCC_UNUSED pa_modargs *ma) {
|
|
pa_protocol_cli* p;
|
|
|
|
pa_core_assert_ref(core);
|
|
pa_assert(server);
|
|
|
|
p = pa_xnew(pa_protocol_cli, 1);
|
|
p->module = m;
|
|
p->core = core;
|
|
p->server = pa_socket_server_ref(server);
|
|
p->connections = pa_idxset_new(NULL, NULL);
|
|
|
|
pa_socket_server_set_callback(p->server, on_connection, p);
|
|
|
|
return p;
|
|
}
|
|
|
|
static void free_connection(void *p, PA_GCC_UNUSED void *userdata) {
|
|
pa_assert(p);
|
|
|
|
pa_cli_free(p);
|
|
}
|
|
|
|
void pa_protocol_cli_free(pa_protocol_cli *p) {
|
|
pa_assert(p);
|
|
|
|
pa_idxset_free(p->connections, free_connection, NULL);
|
|
pa_socket_server_unref(p->server);
|
|
pa_xfree(p);
|
|
}
|