diff options
| author | Kinsey Moore <kmoore@digium.com> | 2013-03-16 15:45:58 +0000 |
|---|---|---|
| committer | Kinsey Moore <kmoore@digium.com> | 2013-03-16 15:45:58 +0000 |
| commit | 99aa02d17f7f1815f9a2abf75282f815a975cd67 (patch) | |
| tree | 5ebb9cf3ddecd7153afb9e30f767d170c44b2142 /include/asterisk/stasis.h | |
| parent | 5d45596f6257b86189bef2dfaf5d9cc0b001fa46 (diff) | |
Transition MWI to Stasis-core
Remove MWI's dependency on the event system by moving it to
Stasis-core. This also introduces forwarding topic pools in Stasis-core
which aggregate many dynamically allocated topics into a single primary
topic.
Review: https://reviewboard.asterisk.org/r/2368/
(closes issue ASTERISK-21097)
Patch-by: Kinsey Moore
git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@383284 65c4cc65-6c06-0410-ace0-fbb531ad65f3
Diffstat (limited to 'include/asterisk/stasis.h')
| -rw-r--r-- | include/asterisk/stasis.h | 21 |
1 files changed, 21 insertions, 0 deletions
diff --git a/include/asterisk/stasis.h b/include/asterisk/stasis.h index 9a5f7537c..f0d73fd72 100644 --- a/include/asterisk/stasis.h +++ b/include/asterisk/stasis.h @@ -377,6 +377,27 @@ struct stasis_subscription_change { */ struct stasis_message_type *stasis_subscription_change(void); +/*! + * \brief Pool for topic aggregation + */ +struct stasis_topic_pool; + +/*! + * \brief Create a topic pool that routes messages from dynamically generated topics to the given topic + * \param pooled_topic Topic to which messages will be routed + * \retval the new stasis_topic_pool or NULL on failure + */ +struct stasis_topic_pool *stasis_topic_pool_create(struct stasis_topic *pooled_topic); + +/*! + * \brief Find or create a topic in the pool + * \param pool Pool for which to get the topic + * \param topic_name Name of the topic to get + * \retval The already stored or newly allocated topic + * \retval NULL if the topic was not found and could not be allocated + */ +struct stasis_topic *stasis_topic_pool_get_topic(struct stasis_topic_pool *pool, const char *topic_name); + /*! @} */ /*! @{ */ |