mirrors/pulseaudio
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pulseaudio/pulseaudio.git synced 2025-11-03 09:01:50 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

Rename the wait parameter to wait_op, to avoid shadowing wait().

Browse source
This commit is contained in:
Diego Elio 'Flameeyes' Pettenò 2009-06-25 11:50:10 +02:00 • committed by Lennart Poettering
parent 2266a39bd3
commit 9a2ac32dcd
2 changed files with 13 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

18
src/pulsecore/asyncq.c
View file

@ -131,7 +131,7 @@ void pa_asyncq_free(pa_asyncq *l, pa_free_cb_t free_cb) {
pa_xfree(l); pa_xfree(l);
} }
static int push(pa_asyncq*l, void *p, pa_bool_t wait) { static int push(pa_asyncq*l, void *p, pa_bool_t wait_op) {
unsigned idx; unsigned idx;
pa_atomic_ptr_t *cells; pa_atomic_ptr_t *cells;
@ -145,7 +145,7 @@ static int push(pa_asyncq*l, void *p, pa_bool_t wait) {
if (!pa_atomic_ptr_cmpxchg(&cells[idx], NULL, p)) { if (!pa_atomic_ptr_cmpxchg(&cells[idx], NULL, p)) {
if (!wait) if (!wait_op)
return -1; return -1;
/* pa_log("sleeping on push"); */ /* pa_log("sleeping on push"); */
@ -163,14 +163,14 @@ static int push(pa_asyncq*l, void *p, pa_bool_t wait) {
return 0; return 0;
} }
static pa_bool_t flush_postq(pa_asyncq *l, pa_bool_t wait) { static pa_bool_t flush_postq(pa_asyncq *l, pa_bool_t wait_op) {
struct localq *q; struct localq *q;
pa_assert(l); pa_assert(l);
while ((q = l->last_localq)) { while ((q = l->last_localq)) {
if (push(l, q->data, wait) < 0) if (push(l, q->data, wait_op) < 0)
return FALSE; return FALSE;
l->last_localq = q->prev; l->last_localq = q->prev;
@ -184,13 +184,13 @@ static pa_bool_t flush_postq(pa_asyncq *l, pa_bool_t wait) {
return TRUE; return TRUE;
} }
int pa_asyncq_push(pa_asyncq*l, void *p, pa_bool_t wait) { int pa_asyncq_push(pa_asyncq*l, void *p, pa_bool_t wait_op) {
pa_assert(l); pa_assert(l);
if (!flush_postq(l, wait)) if (!flush_postq(l, wait_op))
return -1; return -1;
return push(l, p, wait); return push(l, p, wait_op);
} }
void pa_asyncq_post(pa_asyncq*l, void *p) { void pa_asyncq_post(pa_asyncq*l, void *p) {
@ -221,7 +221,7 @@ void pa_asyncq_post(pa_asyncq*l, void *p) {
return; return;
} }
void* pa_asyncq_pop(pa_asyncq*l, pa_bool_t wait) { void* pa_asyncq_pop(pa_asyncq*l, pa_bool_t wait_op) {
unsigned idx; unsigned idx;
void *ret; void *ret;
pa_atomic_ptr_t *cells; pa_atomic_ptr_t *cells;
@ -235,7 +235,7 @@ void* pa_asyncq_pop(pa_asyncq*l, pa_bool_t wait) {
if (!(ret = pa_atomic_ptr_load(&cells[idx]))) { if (!(ret = pa_atomic_ptr_load(&cells[idx]))) {
if (!wait) if (!wait_op)
return NULL; return NULL;
/* pa_log("sleeping on pop"); */ /* pa_log("sleeping on pop"); */

8
src/pulsecore/rtpoll.c
View file

@ -220,7 +220,7 @@ static void reset_all_revents(pa_rtpoll *p) {
} }
} }
int pa_rtpoll_run(pa_rtpoll *p, pa_bool_t wait) { int pa_rtpoll_run(pa_rtpoll *p, pa_bool_t wait_op) {
pa_rtpoll_item *i; pa_rtpoll_item *i;
int r = 0; int r = 0;
struct timeval timeout; struct timeval timeout;
@ -289,7 +289,7 @@ int pa_rtpoll_run(pa_rtpoll *p, pa_bool_t wait) {
memset(&timeout, 0, sizeof(timeout)); memset(&timeout, 0, sizeof(timeout));
/* Calculate timeout */ /* Calculate timeout */
if (wait && !p->quit && p->timer_enabled) { if (wait_op && !p->quit && p->timer_enabled) {
struct timeval now; struct timeval now;
pa_rtclock_get(&now); pa_rtclock_get(&now);
@ -311,10 +311,10 @@ int pa_rtpoll_run(pa_rtpoll *p, pa_bool_t wait) {
struct timespec ts; struct timespec ts;
ts.tv_sec = timeout.tv_sec; ts.tv_sec = timeout.tv_sec;
ts.tv_nsec = timeout.tv_usec * 1000; ts.tv_nsec = timeout.tv_usec * 1000;
r = ppoll(p->pollfd, p->n_pollfd_used, (!wait || p->quit || p->timer_enabled) ? &ts : NULL, NULL); r = ppoll(p->pollfd, p->n_pollfd_used, (!wait_op || p->quit || p->timer_enabled) ? &ts : NULL, NULL);
} }
#else #else
r = poll(p->pollfd, p->n_pollfd_used, (!wait || p->quit || p->timer_enabled) ? (int) ((timeout.tv_sec*1000) + (timeout.tv_usec / 1000)) : -1); r = poll(p->pollfd, p->n_pollfd_used, (!wait_op || p->quit || p->timer_enabled) ? (int) ((timeout.tv_sec*1000) + (timeout.tv_usec / 1000)) : -1);
#endif #endif
#ifdef DEBUG_TIMING #ifdef DEBUG_TIMING