Go to the documentation of this file.
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 mamaDispatcher_create(mamaDispatcher *result, mamaQueue queue)
Create a mamaDispatcher.
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_getNativeHandle(mamaQueue queue, void **nativeHandle)
Get the native middleware implementation queue handle (if applicable for the implementation).
mama_status
Definition: status.h:37
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.
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_destroy(mamaQueue queue)
Destroy a queue.
MAMAExpDLL mama_status mamaQueue_canDestroy(mamaQueue queue)
Check to see if a queue can be destroyed.
struct mamaBridgeImpl_ * mamaBridge
Definition: types.h:69
void(MAMACALLTYPE * mamaQueueEventCB)(mamaQueue queue, void *closure)
Function invoked when a user added event fires.
Definition: queue.h:85
MAMAExpDLL mama_status mamaQueue_removeEnqueueCallback(mamaQueue queue)
If the specified queue has a registered enqueue callback it is unregistered and the previously suppli...
struct mamaQueueMonitorCallbacks_ mamaQueueMonitorCallbacks
callbacks which may be invoked in response to certain conditions on the specified queue being met.
struct mamaDispatcherImpl_ * mamaDispatcher
Definition: types.h:108
MAMAExpDLL mama_status mamaDispatcher_getQueue(mamaDispatcher dispatcher, mamaQueue *result)
Return the queue associated with the dispatcher.
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
callbacks which may be invoked in response to certain conditions on the specified queue being met.
Definition: queue.h:61
MAMAExpDLL mama_status mamaDispatcher_destroy(mamaDispatcher dispatcher)
Destroy the dispatcher and stop dispatching events.
MAMAExpDLL mama_status mamaQueue_destroyWait(mamaQueue queue)
Destroy a queue.
MAMAExpDLL mama_status mamaQueue_getClosure(mamaQueue queue, void **closure)
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 mamaQueue_getQueueBridgeName(mamaQueue queue, const char **name)
Get the string name identifier of the bridge for the specified event queue.
MAMAExpDLL mama_status mamaQueue_setHighWatermark(mamaQueue queue, size_t highWatermark)
Specify a high watermark for events on 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
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_create_usingNative(mamaQueue *queue, mamaBridge bridgeImpl, void *nativeQueue)
mamaQueueHighWatermarkExceededCb onQueueHighWatermarkExceeded
Definition: queue.h:63
MAMAExpDLL mama_status mamaQueue_getQueueName(mamaQueue queue, const char **name)
Get the string name identifier for the specified event 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_enqueueEvent(mamaQueue queue, mamaQueueEventCB callback, void *closure)
Add an user event to a queue.
mamaQueueLowWatermarkCb onQueueLowWatermark
Definition: queue.h:64
MAMAExpDLL mama_status mamaQueue_dispatch(mamaQueue queue)
Dispatch messages from the queue.
MAMAExpDLL mama_status mamaQueue_enableStats(mamaQueue queue)
Enable stats logging on queue.
MAMAExpDLL mama_status mamaQueue_create(mamaQueue *queue, mamaBridge bridgeImpl)
Create a queue.
MAMAExpDLL mama_status mamaQueue_setClosure(mamaQueue queue, void *closure)
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.
MAMAExpDLL mama_status mamaQueue_stopDispatch(mamaQueue queue)
Unblock the queue as soon as possible.
MAMAExpDLL mama_status mamaQueue_destroyTimedWait(mamaQueue queue, long timeout)
Destroy a queue.
MAMAExpDLL mama_status mamaQueue_setQueueName(mamaQueue queue, const char *name)
Associate a name identifier with the event queue.
MAMAExpDLL mama_status mamaQueue_dispatchEvent(mamaQueue queue)
Dispatch a single event from the specified queue.