mirror of
https://gitlab.freedesktop.org/pulseaudio/pulseaudio.git
synced 2025-10-29 05:40:23 -04:00
1f0961368f
* add typedefs for public structs and enums and drop the struct/enum prefixs from all uses where it makes sense git-svn-id: file:///home/lennart/svn/public/pulseaudio/trunk@447 fefdeb5f-60dc-0310-8127-8f9354f1896f
295 lines
8.7 KiB
C
295 lines
8.7 KiB
C
/* $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.1 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
|
|
Lesser 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 <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <assert.h>
|
|
|
|
#include "pdispatch.h"
|
|
#include "native-common.h"
|
|
#include "xmalloc.h"
|
|
#include "llist.h"
|
|
#include "log.h"
|
|
#include "util.h"
|
|
|
|
/*#define DEBUG_OPCODES */
|
|
|
|
#ifdef DEBUG_OPCODES
|
|
|
|
static const char *command_names[PA_COMMAND_MAX] = {
|
|
[PA_COMMAND_ERROR] = "ERROR",
|
|
[PA_COMMAND_TIMEOUT] = "TIMEOUT",
|
|
[PA_COMMAND_REPLY] = "REPLY",
|
|
[PA_COMMAND_CREATE_PLAYBACK_STREAM] = "CREATE_PLAYBACK_STREAM",
|
|
[PA_COMMAND_DELETE_PLAYBACK_STREAM] = "DELETE_PLAYBACK_STREAM",
|
|
[PA_COMMAND_CREATE_RECORD_STREAM] = "CREATE_RECORD_STREAM",
|
|
[PA_COMMAND_DELETE_RECORD_STREAM] = "DELETE_RECORD_STREAM",
|
|
[PA_COMMAND_AUTH] = "AUTH",
|
|
[PA_COMMAND_REQUEST] = "REQUEST",
|
|
[PA_COMMAND_EXIT] = "EXIT",
|
|
[PA_COMMAND_SET_CLIENT_NAME] = "SET_CLIENT_NAME",
|
|
[PA_COMMAND_LOOKUP_SINK] = "LOOKUP_SINK",
|
|
[PA_COMMAND_LOOKUP_SOURCE] = "LOOKUP_SOURCE",
|
|
[PA_COMMAND_DRAIN_PLAYBACK_STREAM] = "DRAIN_PLAYBACK_STREAM",
|
|
[PA_COMMAND_PLAYBACK_STREAM_KILLED] = "PLAYBACK_STREAM_KILLED",
|
|
[PA_COMMAND_RECORD_STREAM_KILLED] = "RECORD_STREAM_KILLED",
|
|
[PA_COMMAND_STAT] = "STAT",
|
|
[PA_COMMAND_GET_PLAYBACK_LATENCY] = "PLAYBACK_LATENCY",
|
|
[PA_COMMAND_CREATE_UPLOAD_STREAM] = "CREATE_UPLOAD_STREAM",
|
|
[PA_COMMAND_DELETE_UPLOAD_STREAM] = "DELETE_UPLOAD_STREAM",
|
|
[PA_COMMAND_FINISH_UPLOAD_STREAM] = "FINISH_UPLOAD_STREAM",
|
|
[PA_COMMAND_PLAY_SAMPLE] = "PLAY_SAMPLE",
|
|
[PA_COMMAND_REMOVE_SAMPLE] = "REMOVE_SAMPLE",
|
|
[PA_COMMAND_GET_SERVER_INFO] = "GET_SERVER_INFO",
|
|
[PA_COMMAND_GET_SINK_INFO] = "GET_SINK_INFO",
|
|
[PA_COMMAND_GET_SINK_INFO_LIST] = "GET_SINK_INFO_LIST",
|
|
[PA_COMMAND_GET_SOURCE_INFO] = "GET_SOURCE_INFO",
|
|
[PA_COMMAND_GET_SOURCE_INFO_LIST] = "GET_SOURCE_INFO_LIST",
|
|
[PA_COMMAND_GET_MODULE_INFO] = "GET_MODULE_INFO",
|
|
[PA_COMMAND_GET_MODULE_INFO_LIST] = "GET_MODULE_INFO_LIST",
|
|
[PA_COMMAND_GET_CLIENT_INFO] = "GET_CLIENT_INFO",
|
|
[PA_COMMAND_GET_CLIENT_INFO_LIST] = "GET_CLIENT_INFO_LIST",
|
|
[PA_COMMAND_GET_SAMPLE_INFO] = "GET_SAMPLE_INFO",
|
|
[PA_COMMAND_GET_SAMPLE_INFO_LIST] = "GET_SAMPLE_INFO_LIST",
|
|
[PA_COMMAND_GET_SINK_INPUT_INFO] = "GET_SINK_INPUT_INFO",
|
|
[PA_COMMAND_GET_SINK_INPUT_INFO_LIST] = "GET_SINK_INPUT_INFO_LIST",
|
|
[PA_COMMAND_GET_SOURCE_OUTPUT_INFO] = "GET_SOURCE_OUTPUT_INFO",
|
|
[PA_COMMAND_GET_SOURCE_OUTPUT_INFO_LIST] = "GET_SOURCE_OUTPUT_INFO_LIST",
|
|
[PA_COMMAND_SUBSCRIBE] = "SUBSCRIBE",
|
|
[PA_COMMAND_SUBSCRIBE_EVENT] = "SUBSCRIBE_EVENT",
|
|
[PA_COMMAND_SET_SINK_VOLUME] = "SET_SINK_VOLUME",
|
|
[PA_COMMAND_SET_SINK_INPUT_VOLUME] = "SET_SINK_INPUT_VOLUME",
|
|
[PA_COMMAND_TRIGGER_PLAYBACK_STREAM] = "TRIGGER_PLAYBACK_STREAM",
|
|
[PA_COMMAND_FLUSH_PLAYBACK_STREAM] = "FLUSH_PLAYBACK_STREAM",
|
|
[PA_COMMAND_CORK_PLAYBACK_STREAM] = "CORK_PLAYBACK_STREAM",
|
|
[PA_COMMAND_GET_AUTOLOAD_INFO] = "GET_AUTOLOAD_INFO",
|
|
[PA_COMMAND_GET_AUTOLOAD_INFO_LIST] = "GET_AUTOLOAD_INFO_LIST",
|
|
};
|
|
|
|
#endif
|
|
|
|
struct reply_info {
|
|
pa_pdispatch *pdispatch;
|
|
PA_LLIST_FIELDS(struct reply_info);
|
|
pa_pdispatch_callback callback;
|
|
void *userdata;
|
|
uint32_t tag;
|
|
pa_time_event *time_event;
|
|
};
|
|
|
|
struct pa_pdispatch {
|
|
int ref;
|
|
pa_mainloop_api *mainloop;
|
|
const pa_pdispatch_callback *callback_table;
|
|
unsigned n_commands;
|
|
PA_LLIST_HEAD(struct reply_info, replies);
|
|
pa_pdispatch_drain_callback drain_callback;
|
|
void *drain_userdata;
|
|
};
|
|
|
|
static void reply_info_free(struct reply_info *r) {
|
|
assert(r && r->pdispatch && r->pdispatch->mainloop);
|
|
|
|
if (r->time_event)
|
|
r->pdispatch->mainloop->time_free(r->time_event);
|
|
|
|
PA_LLIST_REMOVE(struct reply_info, r->pdispatch->replies, r);
|
|
|
|
pa_xfree(r);
|
|
}
|
|
|
|
pa_pdispatch* pa_pdispatch_new(pa_mainloop_api *mainloop, const pa_pdispatch_callback*table, unsigned entries) {
|
|
pa_pdispatch *pd;
|
|
assert(mainloop);
|
|
|
|
assert((entries && table) || (!entries && !table));
|
|
|
|
pd = pa_xmalloc(sizeof(pa_pdispatch));
|
|
pd->ref = 1;
|
|
pd->mainloop = mainloop;
|
|
pd->callback_table = table;
|
|
pd->n_commands = entries;
|
|
PA_LLIST_HEAD_INIT(pa_reply_info, pd->replies);
|
|
pd->drain_callback = NULL;
|
|
pd->drain_userdata = NULL;
|
|
|
|
return pd;
|
|
}
|
|
|
|
static void pdispatch_free(pa_pdispatch *pd) {
|
|
assert(pd);
|
|
|
|
while (pd->replies)
|
|
reply_info_free(pd->replies);
|
|
|
|
pa_xfree(pd);
|
|
}
|
|
|
|
static void run_action(pa_pdispatch *pd, struct reply_info *r, uint32_t command, pa_tagstruct *ts) {
|
|
pa_pdispatch_callback callback;
|
|
void *userdata;
|
|
uint32_t tag;
|
|
assert(r);
|
|
|
|
pa_pdispatch_ref(pd);
|
|
|
|
callback = r->callback;
|
|
userdata = r->userdata;
|
|
tag = r->tag;
|
|
|
|
reply_info_free(r);
|
|
|
|
callback(pd, command, tag, ts, userdata);
|
|
|
|
if (pd->drain_callback && !pa_pdispatch_is_pending(pd))
|
|
pd->drain_callback(pd, pd->drain_userdata);
|
|
|
|
pa_pdispatch_unref(pd);
|
|
}
|
|
|
|
int pa_pdispatch_run(pa_pdispatch *pd, pa_packet*packet, void *userdata) {
|
|
uint32_t tag, command;
|
|
pa_tagstruct *ts = NULL;
|
|
int ret = -1;
|
|
assert(pd && packet && packet->data);
|
|
|
|
pa_pdispatch_ref(pd);
|
|
|
|
if (packet->length <= 8)
|
|
goto finish;
|
|
|
|
ts = pa_tagstruct_new(packet->data, packet->length);
|
|
assert(ts);
|
|
|
|
if (pa_tagstruct_getu32(ts, &command) < 0 ||
|
|
pa_tagstruct_getu32(ts, &tag) < 0)
|
|
goto finish;
|
|
|
|
#ifdef DEBUG_OPCODES
|
|
{
|
|
char t[256];
|
|
char const *p;
|
|
if (!(p = command_names[command]))
|
|
snprintf((char*) (p = t), sizeof(t), "%u", command);
|
|
|
|
pa_log(__FILE__": Recieved opcode <%s>\n", p);
|
|
}
|
|
#endif
|
|
|
|
if (command == PA_COMMAND_ERROR || command == PA_COMMAND_REPLY) {
|
|
struct reply_info *r;
|
|
|
|
for (r = pd->replies; r; r = r->next)
|
|
if (r->tag == tag)
|
|
break;
|
|
|
|
if (r)
|
|
run_action(pd, r, command, ts);
|
|
|
|
} else if (pd->callback_table && (command < pd->n_commands) && pd->callback_table[command]) {
|
|
const pa_pdispatch_callback *c = pd->callback_table+command;
|
|
|
|
(*c)(pd, command, tag, ts, userdata);
|
|
} else {
|
|
pa_log(__FILE__": Recieved unsupported command %u\n", command);
|
|
goto finish;
|
|
}
|
|
|
|
ret = 0;
|
|
|
|
finish:
|
|
if (ts)
|
|
pa_tagstruct_free(ts);
|
|
|
|
pa_pdispatch_unref(pd);
|
|
|
|
return ret;
|
|
}
|
|
|
|
static void timeout_callback(pa_mainloop_api*m, pa_time_event*e, PA_GCC_UNUSED const struct timeval *tv, void *userdata) {
|
|
struct reply_info*r = userdata;
|
|
assert(r && r->time_event == e && r->pdispatch && r->pdispatch->mainloop == m && r->callback);
|
|
|
|
run_action(r->pdispatch, r, PA_COMMAND_TIMEOUT, NULL);
|
|
}
|
|
|
|
void pa_pdispatch_register_reply(pa_pdispatch *pd, uint32_t tag, int timeout, pa_pdispatch_callback cb, void *userdata) {
|
|
struct reply_info *r;
|
|
struct timeval tv;
|
|
assert(pd && pd->ref >= 1 && cb);
|
|
|
|
r = pa_xmalloc(sizeof(struct reply_info));
|
|
r->pdispatch = pd;
|
|
r->callback = cb;
|
|
r->userdata = userdata;
|
|
r->tag = tag;
|
|
|
|
pa_gettimeofday(&tv);
|
|
tv.tv_sec += timeout;
|
|
|
|
r->time_event = pd->mainloop->time_new(pd->mainloop, &tv, timeout_callback, r);
|
|
assert(r->time_event);
|
|
|
|
PA_LLIST_PREPEND(struct reply_info, pd->replies, r);
|
|
}
|
|
|
|
int pa_pdispatch_is_pending(pa_pdispatch *pd) {
|
|
assert(pd);
|
|
|
|
return !!pd->replies;
|
|
}
|
|
|
|
void pa_pdispatch_set_drain_callback(pa_pdispatch *pd, void (*cb)(pa_pdispatch *pd, void *userdata), void *userdata) {
|
|
assert(pd);
|
|
assert(!cb || pa_pdispatch_is_pending(pd));
|
|
|
|
pd->drain_callback = cb;
|
|
pd->drain_userdata = userdata;
|
|
}
|
|
|
|
void pa_pdispatch_unregister_reply(pa_pdispatch *pd, void *userdata) {
|
|
struct reply_info *r, *n;
|
|
assert(pd);
|
|
|
|
for (r = pd->replies; r; r = n) {
|
|
n = r->next;
|
|
|
|
if (r->userdata == userdata)
|
|
reply_info_free(r);
|
|
}
|
|
}
|
|
|
|
void pa_pdispatch_unref(pa_pdispatch *pd) {
|
|
assert(pd && pd->ref >= 1);
|
|
|
|
if (!(--(pd->ref)))
|
|
pdispatch_free(pd);
|
|
}
|
|
|
|
pa_pdispatch* pa_pdispatch_ref(pa_pdispatch *pd) {
|
|
assert(pd && pd->ref >= 1);
|
|
pd->ref++;
|
|
return pd;
|
|
}
|