]> code.delx.au - pulseaudio/blob - polyp/client.c
add CPU load limiter
[pulseaudio] / polyp / client.c
1 /* $Id$ */
2
3 /***
4 This file is part of polypaudio.
5
6 polypaudio is free software; you can redistribute it and/or modify
7 it under the terms of the GNU General Public License as published
8 by the Free Software Foundation; either version 2 of the License,
9 or (at your option) any later version.
10
11 polypaudio is distributed in the hope that it will be useful, but
12 WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 General Public License for more details.
15
16 You should have received a copy of the GNU General Public License
17 along with polypaudio; if not, write to the Free Software
18 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
19 USA.
20 ***/
21
22 #ifdef HAVE_CONFIG_H
23 #include <config.h>
24 #endif
25
26 #include <stdio.h>
27 #include <assert.h>
28 #include <stdlib.h>
29 #include <string.h>
30
31 #include "client.h"
32 #include "xmalloc.h"
33 #include "subscribe.h"
34
35 struct pa_client *pa_client_new(struct pa_core *core, const char *protocol_name, char *name) {
36 struct pa_client *c;
37 int r;
38 assert(core);
39
40 c = pa_xmalloc(sizeof(struct pa_client));
41 c->name = pa_xstrdup(name);
42 c->owner = NULL;
43 c->core = core;
44 c->protocol_name = protocol_name;
45
46 c->kill = NULL;
47 c->userdata = NULL;
48
49 r = pa_idxset_put(core->clients, c, &c->index);
50 assert(c->index != PA_IDXSET_INVALID && r >= 0);
51
52 fprintf(stderr, "client: created %u \"%s\"\n", c->index, c->name);
53 pa_subscription_post(core, PA_SUBSCRIPTION_EVENT_CLIENT|PA_SUBSCRIPTION_EVENT_NEW, c->index);
54
55 return c;
56 }
57
58 void pa_client_free(struct pa_client *c) {
59 assert(c && c->core);
60
61 pa_idxset_remove_by_data(c->core->clients, c, NULL);
62 fprintf(stderr, "client: freed %u \"%s\"\n", c->index, c->name);
63 pa_subscription_post(c->core, PA_SUBSCRIPTION_EVENT_CLIENT|PA_SUBSCRIPTION_EVENT_REMOVE, c->index);
64 pa_xfree(c->name);
65 pa_xfree(c);
66 }
67
68 void pa_client_kill(struct pa_client *c) {
69 assert(c);
70 if (!c->kill) {
71 fprintf(stderr, "kill() operation not implemented for client %u\n", c->index);
72 return;
73 }
74
75 c->kill(c);
76 }
77
78 void pa_client_rename(struct pa_client *c, const char *name) {
79 assert(c);
80 pa_xfree(c->name);
81 c->name = pa_xstrdup(name);
82
83 pa_subscription_post(c->core, PA_SUBSCRIPTION_EVENT_CLIENT|PA_SUBSCRIPTION_EVENT_CHANGE, c->index);
84 }