summaryrefslogtreecommitdiffstats
path: root/polyp/protocol-cli.c
diff options
context:
space:
mode:
Diffstat (limited to 'polyp/protocol-cli.c')
-rw-r--r--polyp/protocol-cli.c95
1 files changed, 0 insertions, 95 deletions
diff --git a/polyp/protocol-cli.c b/polyp/protocol-cli.c
deleted file mode 100644
index d2d73550..00000000
--- a/polyp/protocol-cli.c
+++ /dev/null
@@ -1,95 +0,0 @@
-/* $Id$ */
-
-/***
- This file is part of polypaudio.
-
- polypaudio 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.
-
- polypaudio 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 polypaudio; 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 <assert.h>
-#include <stdlib.h>
-
-#include "protocol-cli.h"
-#include "cli.h"
-#include "xmalloc.h"
-#include "log.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;
- 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;
- assert(s && io && p);
-
- if (pa_idxset_size(p->connections)+1 > MAX_CONNECTIONS) {
- pa_log(__FILE__": Warning! Too many connections (%u), dropping incoming connection.\n", MAX_CONNECTIONS);
- pa_iochannel_free(io);
- return;
- }
-
- c = pa_cli_new(p->core, io, p->module);
- assert(c);
- 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;
- assert(core && server);
-
- p = pa_xmalloc(sizeof(pa_protocol_cli));
- p->module = m;
- p->core = core;
- p->server = 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) {
- assert(p);
- pa_cli_free(p);
-}
-
-void pa_protocol_cli_free(pa_protocol_cli *p) {
- assert(p);
-
- pa_idxset_free(p->connections, free_connection, NULL);
- pa_socket_server_unref(p->server);
- pa_xfree(p);
-}