m->defer_enable(p->defer_event, 0);
p->send_queue = pa_queue_new();
- pa_assert(p->send_queue);
p->write.current = NULL;
p->write.index = 0;
p->mainloop->defer_enable(p->defer_event, 1);
}
+/* might be called from thread context */
static void memimport_release_cb(pa_memimport *i, uint32_t block_id, void *userdata) {
struct item_info *item;
pa_pstream *p = userdata;
p->mainloop->defer_enable(p->defer_event, 1);
}
+/* might be called from thread context */
static void memexport_revoke_cb(pa_memexport *e, uint32_t block_id, void *userdata) {
struct item_info *item;
pa_pstream *p = userdata;