5 #include "protocol-native-spec.h"
7 static const char *command_names[PA_COMMAND_MAX] = {
8 [PA_COMMAND_ERROR] = "ERROR",
9 [PA_COMMAND_TIMEOUT] = "TIMEOUT",
10 [PA_COMMAND_REPLY] = "REPLY",
11 [PA_COMMAND_CREATE_PLAYBACK_STREAM] = "CREATE_PLAYBACK_STREAM",
12 [PA_COMMAND_DELETE_PLAYBACK_STREAM] = "DELETE_PLAYBACK_STREAM",
13 [PA_COMMAND_CREATE_RECORD_STREAM] = "CREATE_RECORD_STREAM",
14 [PA_COMMAND_DELETE_RECORD_STREAM] = "DELETE_RECORD_STREAM",
15 [PA_COMMAND_AUTH] = "AUTH",
16 [PA_COMMAND_REQUEST] = "REQUEST",
17 [PA_COMMAND_EXIT] = "EXIT",
18 [PA_COMMAND_SET_NAME] = "SET_NAME",
19 [PA_COMMAND_LOOKUP_SINK] = "LOOKUP_SINK",
20 [PA_COMMAND_LOOKUP_SOURCE] = "LOOKUP_SOURCE",
24 struct pa_pdispatch *pdispatch;
25 struct reply_info *next, *previous;
26 void (*callback)(struct pa_pdispatch *pd, uint32_t command, uint32_t tag, struct pa_tagstruct *t, void *userdata);
29 void *mainloop_timeout;
33 struct pa_mainloop_api *mainloop;
34 const struct pa_pdispatch_command *command_table;
36 struct reply_info *replies;
37 void (*drain_callback)(struct pa_pdispatch *pd, void *userdata);
39 int in_use, shall_free;
42 static void reply_info_free(struct reply_info *r) {
43 assert(r && r->pdispatch && r->pdispatch->mainloop);
46 r->pdispatch->mainloop->cancel_time(r->pdispatch->mainloop, r->mainloop_timeout);
49 r->previous->next = r->next;
51 r->pdispatch->replies = r->next;
54 r->next->previous = r->previous;
59 struct pa_pdispatch* pa_pdispatch_new(struct pa_mainloop_api *mainloop, const struct pa_pdispatch_command*table, unsigned entries) {
60 struct pa_pdispatch *pd;
63 assert((entries && table) || (!entries && !table));
65 pd = malloc(sizeof(struct pa_pdispatch));
67 pd->mainloop = mainloop;
68 pd->command_table = table;
69 pd->n_commands = entries;
71 pd->drain_callback = NULL;
72 pd->drain_userdata = NULL;
74 pd->in_use = pd->shall_free = 0;
78 void pa_pdispatch_free(struct pa_pdispatch *pd) {
87 reply_info_free(pd->replies);
91 int pa_pdispatch_run(struct pa_pdispatch *pd, struct pa_packet*packet, void *userdata) {
92 uint32_t tag, command;
93 struct pa_tagstruct *ts = NULL;
95 assert(pd && packet && packet->data && !pd->in_use);
97 if (packet->length <= 8)
100 ts = pa_tagstruct_new(packet->data, packet->length);
103 if (pa_tagstruct_getu32(ts, &command) < 0 ||
104 pa_tagstruct_getu32(ts, &tag) < 0)
107 /*fprintf(stderr, __FILE__": Recieved opcode <%s>\n", command_names[command]);*/
109 if (command == PA_COMMAND_ERROR || command == PA_COMMAND_REPLY) {
110 struct reply_info *r;
112 for (r = pd->replies; r; r = r->next) {
118 r->callback(r->pdispatch, command, tag, ts, r->userdata);
122 if (pd->shall_free) {
123 pa_pdispatch_free(pd);
127 if (pd->drain_callback && !pa_pdispatch_is_pending(r->pdispatch))
128 pd->drain_callback(r->pdispatch, r->pdispatch->drain_userdata);
133 } else if (pd->command_table && command < pd->n_commands) {
134 const struct pa_pdispatch_command *c = pd->command_table+command;
137 c->proc(pd, command, tag, ts, userdata);
145 pa_tagstruct_free(ts);
150 static void timeout_callback(struct pa_mainloop_api*m, void *id, const struct timeval *tv, void *userdata) {
151 struct reply_info*r = userdata;
152 assert (r && r->mainloop_timeout == id && r->pdispatch && r->pdispatch->mainloop == m && r->callback);
154 r->callback(r->pdispatch, PA_COMMAND_TIMEOUT, r->tag, NULL, r->userdata);
157 if (r->pdispatch->drain_callback && !pa_pdispatch_is_pending(r->pdispatch))
158 r->pdispatch->drain_callback(r->pdispatch, r->pdispatch->drain_userdata);
161 void pa_pdispatch_register_reply(struct pa_pdispatch *pd, uint32_t tag, int timeout, void (*cb)(struct pa_pdispatch *pd, uint32_t command, uint32_t tag, struct pa_tagstruct *t, void *userdata), void *userdata) {
162 struct reply_info *r;
166 r = malloc(sizeof(struct reply_info));
170 r->userdata = userdata;
173 gettimeofday(&tv, NULL);
174 tv.tv_sec += timeout;
176 r->mainloop_timeout = pd->mainloop->source_time(pd->mainloop, &tv, timeout_callback, r);
177 assert(r->mainloop_timeout);
180 r->next = pd->replies;
182 r->next->previous = r;
186 int pa_pdispatch_is_pending(struct pa_pdispatch *pd) {
189 return !!pd->replies;
192 void pa_pdispatch_set_drain_callback(struct pa_pdispatch *pd, void (*cb)(struct pa_pdispatch *pd, void *userdata), void *userdata) {
194 assert(!cb || pa_pdispatch_is_pending(pd));
196 pd->drain_callback = cb;
197 pd->drain_userdata = userdata;