Searched refs:pa_asyncq (Results 1 – 4 of 4) sorted by relevance
| /third_party/pulseaudio/src/pulsecore/ |
| D | asyncq.h | 41 typedef struct pa_asyncq pa_asyncq; typedef
43 pa_asyncq* pa_asyncq_new(unsigned size);
44 void pa_asyncq_free(pa_asyncq* q, pa_free_cb_t free_cb);
46 void* pa_asyncq_pop(pa_asyncq *q, bool wait);
47 int pa_asyncq_push(pa_asyncq *q, void *p, bool wait);
52 void pa_asyncq_post(pa_asyncq*l, void *p);
55 int pa_asyncq_read_fd(pa_asyncq *q);
56 int pa_asyncq_read_before_poll(pa_asyncq *a);
57 void pa_asyncq_read_after_poll(pa_asyncq *a);
60 int pa_asyncq_write_fd(pa_asyncq *q);
[all …]
|
| D | asyncq.c | 58 struct pa_asyncq { struct
71 #define PA_ASYNCQ_CELLS(x) ((pa_atomic_ptr_t*) ((uint8_t*) (x) + PA_ALIGN(sizeof(struct pa_asyncq))… argument
73 static unsigned reduce(pa_asyncq *l, unsigned value) { in reduce()
77 pa_asyncq *pa_asyncq_new(unsigned size) { in pa_asyncq_new()
78 pa_asyncq *l; in pa_asyncq_new()
85 l = pa_xmalloc0(PA_ALIGN(sizeof(pa_asyncq)) + (sizeof(pa_atomic_ptr_t) * size)); in pa_asyncq_new()
107 void pa_asyncq_free(pa_asyncq *l, pa_free_cb_t free_cb) { in pa_asyncq_free()
133 static int push(pa_asyncq*l, void *p, bool wait_op) { in push()
165 static bool flush_postq(pa_asyncq *l, bool wait_op) { in flush_postq()
186 int pa_asyncq_push(pa_asyncq*l, void *p, bool wait_op) { in pa_asyncq_push()
[all …]
|
| D | asyncmsgq.c | 54 pa_asyncq *asyncq;
61 pa_asyncq *asyncq; in pa_asyncmsgq_new()
|
| /third_party/pulseaudio/src/tests/ |
| D | asyncq-test.c | 35 pa_asyncq *q = _q; in producer()
48 pa_asyncq *q = _q; in consumer()
69 pa_asyncq *q; in START_TEST()
|