29 #if defined(__cplusplus) 45 typedef void (MAMACALLTYPE *mamaQueueHighWatermarkExceededCb) (
mamaQueue queue,
53 typedef void (MAMACALLTYPE *mamaQueueLowWatermarkCb) (
mamaQueue queue,
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...
const char mamaFtState void * closure
Definition: ft.h:54
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.
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.
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.
size_t size
Definition: queue.h:46
MAMAExpDLL mama_status mamaQueue_setQueueName(mamaQueue queue, const char *name)
Associate a name identifier with the event queue.
typedef void(MAMACALLTYPE *mamaQueueHighWatermarkExceededCb)(mamaQueue queue
Callback invoked if an upper size limit has been specified for a queue and that limit has been exceed...
size_t void * closure
Definition: queue.h:46
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.