[asterisk-commits] mjordan: branch mjordan/12-stasis-performance r414969 - in /team/mjordan/12-s...

[SVN commits to the Asterisk project]

Author: mjordan
Date: Fri May 30 22:51:53 2014
New Revision: 414969

URL: http://svnview.digium.com/svn/asterisk?view=rev&rev=414969
Log:
Turn a few more snapshot generations into cache retrievals

Modified:
    team/mjordan/12-stasis-performance/apps/app_agent_pool.c
    team/mjordan/12-stasis-performance/apps/app_queue.c
    team/mjordan/12-stasis-performance/main/aoc.c
    team/mjordan/12-stasis-performance/main/bridge_channel.c

Modified: team/mjordan/12-stasis-performance/apps/app_agent_pool.c
URL: http://svnview.digium.com/svn/asterisk/team/mjordan/12-stasis-performance/apps/app_agent_pool.c?view=diff&rev=414969&r1=414968&r2=414969
==============================================================================
--- team/mjordan/12-stasis-performance/apps/app_agent_pool.c (original)
+++ team/mjordan/12-stasis-performance/apps/app_agent_pool.c Fri May 30 22:51:53 2014
@@ -1442,7 +1442,7 @@
 		return;
 	}
 
-	ast_channel_publish_blob(chan, ast_channel_agent_login_type(), blob);
+	ast_channel_publish_cached_blob(chan, ast_channel_agent_login_type(), blob);
 }
 
 static void send_agent_logoff(struct ast_channel *chan, const char *agent, long logintime)
@@ -1458,7 +1458,7 @@
 		return;
 	}
 
-	ast_channel_publish_blob(chan, ast_channel_agent_logoff_type(), blob);
+	ast_channel_publish_cached_blob(chan, ast_channel_agent_logoff_type(), blob);
 }
 
 /*!

Modified: team/mjordan/12-stasis-performance/apps/app_queue.c
URL: http://svnview.digium.com/svn/asterisk/team/mjordan/12-stasis-performance/apps/app_queue.c?view=diff&rev=414969&r1=414968&r2=414969
==============================================================================
--- team/mjordan/12-stasis-performance/apps/app_queue.c (original)
+++ team/mjordan/12-stasis-performance/apps/app_queue.c Fri May 30 22:51:53 2014
@@ -3507,7 +3507,7 @@
 				     "Position", qe->pos,
 				     "Count", q->count);
 		ast_channel_lock(qe->chan);
-		ast_channel_publish_blob(qe->chan, queue_caller_join_type(), blob);
+		ast_channel_publish_cached_blob(qe->chan, queue_caller_join_type(), blob);
 		ast_channel_unlock(qe->chan);
 		ast_debug(1, "Queue '%s' Join, Channel '%s', Position '%d'\n", q->name, ast_channel_name(qe->chan), qe->pos );
 	}
@@ -3788,7 +3788,7 @@
 					     "Position", qe->pos,
 					     "Count", q->count);
 			ast_channel_lock(qe->chan);
-			ast_channel_publish_blob(qe->chan, queue_caller_leave_type(), blob);
+			ast_channel_publish_cached_blob(qe->chan, queue_caller_leave_type(), blob);
 			ast_channel_unlock(qe->chan);
 			ast_debug(1, "Queue '%s' Leave, Channel '%s'\n", q->name, ast_channel_name(qe->chan));
 			/* Take us out of the queue */
@@ -4392,7 +4392,7 @@
 	ao2_unlock(qe->parent);
 
 	ast_channel_lock(qe->chan);
-	ast_channel_publish_blob(qe->chan, queue_caller_abandon_type(), blob);
+	ast_channel_publish_cached_blob(qe->chan, queue_caller_abandon_type(), blob);
 	ast_channel_unlock(qe->chan);
 }
 

Modified: team/mjordan/12-stasis-performance/main/aoc.c
URL: http://svnview.digium.com/svn/asterisk/team/mjordan/12-stasis-performance/main/aoc.c?view=diff&rev=414969&r1=414968&r2=414969
==============================================================================
--- team/mjordan/12-stasis-performance/main/aoc.c (original)
+++ team/mjordan/12-stasis-performance/main/aoc.c Fri May 30 22:51:53 2014
@@ -1871,7 +1871,7 @@
 		return 0;
 	}
 
-	ast_channel_publish_blob(chan, msg_type, blob);
+	ast_channel_publish_cached_blob(chan, msg_type, blob);
 	return 0;
 }
 

Modified: team/mjordan/12-stasis-performance/main/bridge_channel.c
URL: http://svnview.digium.com/svn/asterisk/team/mjordan/12-stasis-performance/main/bridge_channel.c?view=diff&rev=414969&r1=414968&r2=414969
==============================================================================
--- team/mjordan/12-stasis-performance/main/bridge_channel.c (original)
+++ team/mjordan/12-stasis-performance/main/bridge_channel.c Fri May 30 22:51:53 2014
@@ -839,7 +839,7 @@
 	}
 
 	ast_channel_lock(bridge_channel->chan);
-	ast_channel_publish_blob(bridge_channel->chan, ast_channel_hold_type(), blob);
+	ast_channel_publish_cached_blob(bridge_channel->chan, ast_channel_hold_type(), blob);
 	ast_channel_unlock(bridge_channel->chan);
 	return ast_bridge_channel_write_control_data(bridge_channel, AST_CONTROL_HOLD,
 		moh_class, datalen);
@@ -848,7 +848,7 @@
 int ast_bridge_channel_write_unhold(struct ast_bridge_channel *bridge_channel)
 {
 	ast_channel_lock(bridge_channel->chan);
-	ast_channel_publish_blob(bridge_channel->chan, ast_channel_unhold_type(), NULL);
+	ast_channel_publish_cached_blob(bridge_channel->chan, ast_channel_unhold_type(), NULL);
 	ast_channel_unlock(bridge_channel->chan);
 	return ast_bridge_channel_write_control_data(bridge_channel, AST_CONTROL_UNHOLD, NULL, 0);
 }