Home
last modified time | relevance | path

Searched refs:pa_asyncq (Results 1 - 4 of 4) sorted by relevance

/third_party/pulseaudio/src/pulsecore/
H A Dasyncq.h41 typedef struct pa_asyncq pa_asyncq; typedef
43 unsigned PaAsyncqGetNumToRead(pa_asyncq *l);
44 pa_asyncq* pa_asyncq_new(unsigned size);
45 void pa_asyncq_free(pa_asyncq* q, pa_free_cb_t free_cb);
47 void* pa_asyncq_pop(pa_asyncq *q, bool wait);
48 int pa_asyncq_push(pa_asyncq *q, void *p, bool wait);
53 void pa_asyncq_post(pa_asyncq*l, void *p);
56 int pa_asyncq_read_fd(pa_asyncq *q);
57 int pa_asyncq_read_before_poll(pa_asyncq *
[all...]
H A Dasyncq.c58 struct pa_asyncq { struct
71 #define PA_ASYNCQ_CELLS(x) ((pa_atomic_ptr_t*) ((uint8_t*) (x) + PA_ALIGN(sizeof(struct pa_asyncq))))
73 static unsigned reduce(pa_asyncq *l, unsigned value) { in reduce()
77 unsigned PaAsyncqGetNumToRead(pa_asyncq *l) in PaAsyncqGetNumToRead()
82 pa_asyncq *pa_asyncq_new(unsigned size) { in pa_asyncq_new()
83 pa_asyncq *l; in pa_asyncq_new()
90 l = pa_xmalloc0(PA_ALIGN(sizeof(pa_asyncq)) + (sizeof(pa_atomic_ptr_t) * size)); in pa_asyncq_new()
112 void pa_asyncq_free(pa_asyncq *l, pa_free_cb_t free_cb) { in pa_asyncq_free()
138 static int push(pa_asyncq*l, void *p, bool wait_op) { in push()
170 static bool flush_postq(pa_asyncq *
[all...]
H A Dasyncmsgq.c55 pa_asyncq *asyncq;
62 pa_asyncq *asyncq; in pa_asyncmsgq_new()
/third_party/pulseaudio/src/tests/
H A Dasyncq-test.c35 pa_asyncq *q = _q; in producer()
48 pa_asyncq *q = _q; in consumer()
69 pa_asyncq *q; in START_TEST()

Completed in 3 milliseconds