[svn-commits] dlee: branch dlee/stasis-cache-split r393996 - /team/dlee/stasis-cache-split/...

[SVN commits to the Digium repositories]

Author: dlee
Date: Wed Jul 10 12:22:03 2013
New Revision: 393996

URL: http://svnview.digium.com/svn/asterisk?view=rev&rev=393996
Log:
gulp fixes

Modified:
    team/dlee/stasis-cache-split/channels/chan_gulp.c

Modified: team/dlee/stasis-cache-split/channels/chan_gulp.c
URL: http://svnview.digium.com/svn/asterisk/team/dlee/stasis-cache-split/channels/chan_gulp.c?view=diff&rev=393996&r1=393995&r2=393996
==============================================================================
--- team/dlee/stasis-cache-split/channels/chan_gulp.c (original)
+++ team/dlee/stasis-cache-split/channels/chan_gulp.c Wed Jul 10 12:22:03 2013
@@ -816,9 +816,12 @@
 	ao2_ref(cache, +1);
 
 	for (num = 0; num < endpoint_snapshot->num_channels; num++) {
-		RAII_VAR(struct stasis_message *, msg, stasis_cache_get_extended(cache, ast_channel_snapshot_type(),
-			endpoint_snapshot->channel_ids[num], 1), ao2_cleanup);
+		RAII_VAR(struct stasis_message *, msg, NULL, ao2_cleanup);
 		struct ast_channel_snapshot *snapshot;
+
+		stasis_topic_wait(ast_channel_topic_all_cached());
+		msg = stasis_cache_get(cache, ast_channel_snapshot_type(),
+			endpoint_snapshot->channel_ids[num]);
 
 		if (!msg) {
 			continue;