From 944c33cbff5f2cfb1c80f48193aa2161574864fd Mon Sep 17 00:00:00 2001 From: inmarket Date: Tue, 11 Mar 2014 17:11:02 +1000 Subject: [PATCH] Add support for gfxQueueGSyncGetI() --- src/gqueue/gqueue.c | 11 +++++++++++ src/gqueue/sys_defs.h | 13 +++++++------ 2 files changed, 18 insertions(+), 6 deletions(-) diff --git a/src/gqueue/gqueue.c b/src/gqueue/gqueue.c index f3da1cdf..b7ecb032 100644 --- a/src/gqueue/gqueue.c +++ b/src/gqueue/gqueue.c @@ -138,6 +138,17 @@ return pi; } + gfxQueueGSyncItem *gfxQueueGSyncGetI(gfxQueueGSync *pqueue) { + gfxQueueGSyncItem *pi; + + if (!gfxSemWaitI(&pqueue->sem)) + return 0; + + pi = pqueue->head; + pqueue->head = pi->next; + pi->next = 0; + return pi; + } void gfxQueueGSyncPut(gfxQueueGSync *pqueue, gfxQueueGSyncItem *pitem) { gfxSystemLock(); diff --git a/src/gqueue/sys_defs.h b/src/gqueue/sys_defs.h index 4446fcba..4351d4ad 100644 --- a/src/gqueue/sys_defs.h +++ b/src/gqueue/sys_defs.h @@ -113,6 +113,7 @@ void gfxQueueFSyncInit(gfxQueueFSync *pqueue); gfxQueueASyncItem *gfxQueueASyncGet(gfxQueueASync *pqueue); gfxQueueASyncItem *gfxQueueASyncGetI(gfxQueueASync *pqueue); gfxQueueGSyncItem *gfxQueueGSyncGet(gfxQueueGSync *pqueue, delaytime_t ms); +gfxQueueGSyncItem *gfxQueueGSyncGetI(gfxQueueGSync *pqueue); gfxQueueFSyncItem *gfxQueueFSyncGet(gfxQueueFSync *pqueue, delaytime_t ms); /* @} */ @@ -208,12 +209,12 @@ void gfxQueueFSyncRemove(gfxQueueFSync *pqueue, gfxQueueFSyncItem *pitem); * @api * @{ */ -#define gfxQueueASyncIsEmpty(pqueue) (pqueue->head == 0) -#define gfxQueueASyncIsEmptyI(pqueue) (pqueue->head == 0) -#define gfxQueueGSyncIsEmpty(pqueue) (pqueue->head == 0) -#define gfxQueueGSyncIsEmptyI(pqueue) (pqueue->head == 0) -#define gfxQueueFSyncIsEmpty(pqueue) (pqueue->head == 0) -#define gfxQueueFSyncIsEmptyI(pqueue) (pqueue->head == 0) +#define gfxQueueASyncIsEmpty(pqueue) ((pqueue)->head == 0) +#define gfxQueueASyncIsEmptyI(pqueue) ((pqueue)->head == 0) +#define gfxQueueGSyncIsEmpty(pqueue) ((pqueue)->head == 0) +#define gfxQueueGSyncIsEmptyI(pqueue) ((pqueue)->head == 0) +#define gfxQueueFSyncIsEmpty(pqueue) ((pqueue)->head == 0) +#define gfxQueueFSyncIsEmptyI(pqueue) ((pqueue)->head == 0) /* @} */ /**