kenmirrors/asterisk
1
0
Fork 0
mirror of https://github.com/asterisk/asterisk.git synced 2026-07-28 00:10:25 -07:00
Code Issues Packages Projects Releases Wiki Activity

Merge "stasis: Add setting subscription congestion levels." into 13

Browse Source
This commit is contained in:
Joshua Colp
2016-06-09 20:25:15 -05:00
committed by Gerrit Code Review
parent e842a99e7c 557333ea4c
commit ecc186a4cc
7 changed files with 61 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
include/asterisk/stasis.h
+14
View File
@@ -600,6 +600,20 @@ struct stasis_subscription *stasis_subscribe_pool(struct stasis_topic *topic,
struct stasis_subscription *stasis_unsubscribe(
struct stasis_subscription *subscription);
/*!
* \brief Set the high and low alert water marks of the stasis subscription.
* \since 13.10.0
*
* \param subscription Pointer to a stasis subscription
* \param low_water New queue low water mark. (-1 to set as 90% of high_water)
* \param high_water New queue high water mark.
*
* \retval 0 on success.
* \retval -1 on error (water marks not changed).
*/
int stasis_subscription_set_congestion_limits(struct stasis_subscription *subscription,
long low_water, long high_water);
/*!
* \brief Block until the last message is processed on a subscription.
*
include/asterisk/stasis_message_router.h
+14
View File
@@ -126,6 +126,20 @@ int stasis_message_router_is_done(struct stasis_message_router *router);
void stasis_message_router_publish_sync(struct stasis_message_router *router,
struct stasis_message *message);
/*!
* \brief Set the high and low alert water marks of the stasis message router.
* \since 13.10.0
*
* \param router Pointer to a stasis message router
* \param low_water New queue low water mark. (-1 to set as 90% of high_water)
* \param high_water New queue high water mark.
*
* \retval 0 on success.
* \retval -1 on error (water marks not changed).
*/
int stasis_message_router_set_congestion_limits(struct stasis_message_router *router,
long low_water, long high_water);
/*!
* \brief Add a route to a message router.
*