diff options
| author | Joshua Colp <jcolp@digium.com> | 2013-06-13 11:02:16 +0000 |
|---|---|---|
| committer | Joshua Colp <jcolp@digium.com> | 2013-06-13 11:02:16 +0000 |
| commit | 65c492e851639897d8db79741bdcebc3557ad29d (patch) | |
| tree | ca67c5c9f3765f2dc4a45f2a4bdbc85c8d8b6fdd /main/stasis_endpoints.c | |
| parent | 1e9faaf78a9caa4f03f456bf027aa139c31783f2 (diff) | |
Add support for requiring that all queued messages on a caching topic have been handled before
retrieving from the cache and also change adding channels to an endpoint to be an immediate
operation.
Review: https://reviewboard.asterisk.org/r/2599/
git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@391596 65c4cc65-6c06-0410-ace0-fbb531ad65f3
Diffstat (limited to 'main/stasis_endpoints.c')
| -rw-r--r-- | main/stasis_endpoints.c | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/main/stasis_endpoints.c b/main/stasis_endpoints.c index a7b7f556b..d5347cbcb 100644 --- a/main/stasis_endpoints.c +++ b/main/stasis_endpoints.c @@ -52,7 +52,7 @@ struct stasis_caching_topic *ast_endpoint_topic_all_cached(void) } struct ast_endpoint_snapshot *ast_endpoint_latest_snapshot(const char *tech, - const char *name) + const char *name, unsigned int guaranteed) { RAII_VAR(char *, id, NULL, ast_free); RAII_VAR(struct stasis_message *, msg, NULL, ao2_cleanup); @@ -63,8 +63,8 @@ struct ast_endpoint_snapshot *ast_endpoint_latest_snapshot(const char *tech, return NULL; } - msg = stasis_cache_get(ast_endpoint_topic_all_cached(), - ast_endpoint_snapshot_type(), id); + msg = stasis_cache_get_extended(ast_endpoint_topic_all_cached(), + ast_endpoint_snapshot_type(), id, guaranteed); if (!msg) { return NULL; } |