29 #if defined(__cplusplus) 190 size_t highWatermark);
202 size_t* highWatermark);
218 size_t lowWatermark);
230 size_t* lowWatermark);
413 void** nativeHandle);
474 #if defined(__cplusplus) MAMAExpDLL mama_status mamaQueue_getNativeHandle(mamaQueue queue, void **nativeHandle)
Get the native middleware implementation queue handle (if applicable for the implementation).
MAMAExpDLL mama_status mamaQueue_create(mamaQueue *queue, mamaBridge bridgeImpl)
Create a queue.
MAMAExpDLL mama_status mamaQueue_setClosure(mamaQueue queue, void *closure)
MAMAExpDLL mama_status mamaQueue_setHighWatermark(mamaQueue queue, size_t highWatermark)
Specify a high watermark for events on the queue.
MAMAExpDLL mama_status mamaQueue_setQueueMonitorCallbacks(mamaQueue queue, mamaQueueMonitorCallbacks *queueMonitorCallbacks, void *closure)
Specify a set of callbacks which may be invoked in response to certain conditions arising on the queu...
MAMAExpDLL mama_status mamaQueue_dispatchEvent(mamaQueue queue)
Dispatch a single event from the specified queue.
MAMAExpDLL mama_status mamaQueue_setLowWatermark(mamaQueue queue, size_t lowWatermark)
Set the low water mark for the queue.
MAMAExpDLL mama_status mamaQueue_timedDispatch(mamaQueue queue, uint64_t timeout)
Dispatch messages from the queue.
void(MAMACALLTYPE * mamaQueueEnqueueCB)(mamaQueue queue, void *closure)
Function invoked when an event is enqueued on the queue for which this function was registered...
Definition: queue.h:78
struct mamaQueueMonitorCallbacks_ mamaQueueMonitorCallbacks
callbacks which may be invoked in response to certain conditions on the specified queue being met...
callbacks which may be invoked in response to certain conditions on the specified queue being met...
Definition: queue.h:61
struct mamaBridgeImpl_ * mamaBridge
Definition: types.h:69
MAMAExpDLL mama_status mamaQueue_destroyWait(mamaQueue queue)
Destroy a queue.
MAMAExpDLL mama_status mamaQueue_enableStats(mamaQueue queue)
Enable stats logging on queue.
void(MAMACALLTYPE * mamaQueueLowWatermarkCb)(mamaQueue queue, size_t size, void *closure)
Callback invoked when the queue size returns to the lower limit specified.
Definition: queue.h:53
MAMAExpDLL mama_status mamaQueue_canDestroy(mamaQueue queue)
Check to see if a queue can be destroyed.
MAMAExpDLL mama_status mamaQueue_create_usingNative(mamaQueue *queue, mamaBridge bridgeImpl, void *nativeQueue)
MAMAExpDLL mama_status mamaQueue_enqueueEvent(mamaQueue queue, mamaQueueEventCB callback, void *closure)
Add an user event to a queue.
MAMAExpDLL mama_status mamaQueue_removeEnqueueCallback(mamaQueue queue)
If the specified queue has a registered enqueue callback it is unregistered and the previously suppli...
MAMAExpDLL mama_status mamaQueue_destroyTimedWait(mamaQueue queue, long timeout)
Destroy a queue.
struct mamaQueueImpl_ * mamaQueue
Definition: types.h:107
MAMAExpDLL mama_status mamaQueue_getLowWatermark(mamaQueue queue, size_t *lowWatermark)
Get the value of the low water mark for the specified queue.
mamaQueueHighWatermarkExceededCb onQueueHighWatermarkExceeded
Definition: queue.h:63
struct mamaDispatcherImpl_ * mamaDispatcher
Definition: types.h:108
MAMAExpDLL mama_status mamaDispatcher_create(mamaDispatcher *result, mamaQueue queue)
Create a mamaDispatcher.
void(MAMACALLTYPE * mamaQueueHighWatermarkExceededCb)(mamaQueue queue, size_t size, void *closure)
Callback invoked if an upper size limit has been specified for a queue and that limit has been exceed...
Definition: queue.h:45
MAMAExpDLL mama_status mamaQueue_setEnqueueCallback(mamaQueue queue, mamaQueueEnqueueCB callback, void *closure)
Register the specified callback function to receive a callback each time an event is enqueued on the ...
MAMAExpDLL mama_status mamaQueue_getHighWatermark(mamaQueue queue, size_t *highWatermark)
Get the value of the high water mark for the specified queue.
MAMAExpDLL mama_status mamaQueue_getQueueName(mamaQueue queue, const char **name)
Get the string name identifier for the specified event queue.
MAMAExpDLL mama_status mamaQueue_destroy(mamaQueue queue)
Destroy a queue.
MAMAExpDLL mama_status mamaQueue_setQueueName(mamaQueue queue, const char *name)
Associate a name identifier with the event queue.
mama_status
Definition: status.h:37
MAMAExpDLL mama_status mamaQueue_stopDispatch(mamaQueue queue)
Unblock the queue as soon as possible.
mamaQueueLowWatermarkCb onQueueLowWatermark
Definition: queue.h:64
MAMAExpDLL mama_status mamaQueue_getQueueBridgeName(mamaQueue queue, const char **name)
Get the string name identifier of the bridge for the specified event queue.
void(MAMACALLTYPE * mamaQueueEventCB)(mamaQueue queue, void *closure)
Function invoked when a user added event fires.
Definition: queue.h:85
MAMAExpDLL mama_status mamaDispatcher_destroy(mamaDispatcher dispatcher)
Destroy the dispatcher and stop dispatching events.
MAMAExpDLL mama_status mamaQueue_getClosure(mamaQueue queue, void **closure)
MAMAExpDLL mama_status mamaQueue_dispatch(mamaQueue queue)
Dispatch messages from the queue.
MAMAExpDLL mama_status mamaQueue_getEventCount(mamaQueue queue, size_t *count)
Writes the number of events currently on the specified queue to the address specified by count...
MAMAExpDLL mama_status mamaDispatcher_getQueue(mamaDispatcher dispatcher, mamaQueue *result)
Return the queue associated with the dispatcher.