diff options
| author | Kinsey Moore <kmoore@digium.com> | 2014-08-06 12:55:28 +0000 |
|---|---|---|
| committer | Kinsey Moore <kmoore@digium.com> | 2014-08-06 12:55:28 +0000 |
| commit | f1036f40dc22c4d4b30cc2ab36199cd749ead9c5 (patch) | |
| tree | 4fd17b406cb14b5eee97cf0be44382b792ccbff9 /main/core_local.c | |
| parent | ac5c75b45d9d7fe047ccd9d1d094cb9d30df8b51 (diff) | |
Stasis: Allow message types to be blocked
This introduces stasis.conf and a mechanism to prevent certain message
types from being published. Internally, this works by preventing the
chosen message types from being created which ensures that those
message types can never be published. This patch also adjusts message
publishers such that message payloads are not created if the related
message type is not available.
ASTERISK-23943 #close
Review: https://reviewboard.asterisk.org/r/3823/
git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@420124 65c4cc65-6c06-0410-ace0-fbb531ad65f3
Diffstat (limited to 'main/core_local.c')
| -rw-r--r-- | main/core_local.c | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/main/core_local.c b/main/core_local.c index e1b66d0a7..54915ecfe 100644 --- a/main/core_local.c +++ b/main/core_local.c @@ -357,6 +357,10 @@ static void local_optimization_started_cb(struct ast_unreal_pvt *base, struct as RAII_VAR(struct stasis_message *, msg, NULL, ao2_cleanup); struct local_pvt *p = (struct local_pvt *)base; + if (!ast_local_optimization_begin_type()) { + return; + } + json_object = ast_json_pack("{s: i, s: i}", "dest", dest, "id", id); @@ -395,6 +399,10 @@ static void local_optimization_finished_cb(struct ast_unreal_pvt *base, int succ RAII_VAR(struct stasis_message *, msg, NULL, ao2_cleanup); struct local_pvt *p = (struct local_pvt *)base; + if (!ast_local_optimization_end_type()) { + return; + } + json_object = ast_json_pack("{s: i, s: i}", "success", success, "id", id); if (!json_object) { @@ -501,6 +509,10 @@ static void publish_local_bridge_message(struct local_pvt *p) struct ast_channel *owner; struct ast_channel *chan; + if (!ast_local_bridge_type()) { + return; + } + ast_unreal_lock_all(&p->base, &chan, &owner); blob = ast_json_pack("{s: s, s: s, s: b}", |