[asterisk-commits] irroot: branch irroot/distrotech-customers-10 r345020 - in /team/irroot/distr...

SVN commits to the Asterisk project asterisk-commits at lists.digium.com
Sun Nov 13 02:52:28 CST 2011


Author: irroot
Date: Sun Nov 13 02:52:24 2011
New Revision: 345020

URL: http://svnview.digium.com/svn/asterisk?view=rev&rev=345020
Log:
Change pickup macro to use datastore adding a bridge callback to datastore

Modified:
    team/irroot/distrotech-customers-10/include/asterisk/datastore.h
    team/irroot/distrotech-customers-10/main/channel.c
    team/irroot/distrotech-customers-10/main/features.c
    team/irroot/distrotech-customers-10/main/global_datastores.c

Modified: team/irroot/distrotech-customers-10/include/asterisk/datastore.h
URL: http://svnview.digium.com/svn/asterisk/team/irroot/distrotech-customers-10/include/asterisk/datastore.h?view=diff&rev=345020&r1=345019&r2=345020
==============================================================================
--- team/irroot/distrotech-customers-10/include/asterisk/datastore.h (original)
+++ team/irroot/distrotech-customers-10/include/asterisk/datastore.h Sun Nov 13 02:52:24 2011
@@ -48,6 +48,17 @@
 	 * \return nothing.
 	 */
 	void (*chan_fixup)(void *data, struct ast_channel *old_chan, struct ast_channel *new_chan);
+
+	/*!
+	 * \brief Callback to operate on bridge channel before entring bridge loop
+	 *
+	 * \arg data The datastore data
+	 * \arg chan channel owning the datastore (locked and running autoservice)
+	 * \arg bridge channel
+	 *
+	 * \return nothing.
+	 */
+	void (*bridge_fixup)(void *data, struct ast_channel *chan, struct ast_channel *bridge);
 };
 
 /*! \brief Structure for a data store object */

Modified: team/irroot/distrotech-customers-10/main/channel.c
URL: http://svnview.digium.com/svn/asterisk/team/irroot/distrotech-customers-10/main/channel.c?view=diff&rev=345020&r1=345019&r2=345020
==============================================================================
--- team/irroot/distrotech-customers-10/main/channel.c (original)
+++ team/irroot/distrotech-customers-10/main/channel.c Sun Nov 13 02:52:24 2011
@@ -7444,9 +7444,6 @@
 	long time_left_ms=0;
 	char caller_warning = 0;
 	char callee_warning = 0;
-	const char *bridge_macro;
-	const char *bridge_macro_args;
-	struct ast_datastore *ds_bridge_macro;
 
 	*fo = NULL;
 
@@ -7526,31 +7523,6 @@
 	/* Before we enter in and bridge these two together tell them both the source of audio has changed */
 	ast_indicate(c0, AST_CONTROL_SRCUPDATE);
 	ast_indicate(c1, AST_CONTROL_SRCUPDATE);
-
-	if ((ds_bridge_macro = ast_channel_datastore_find(c0, &pickup_target_info, NULL))) {
-		bridge_macro = pbx_builtin_getvar_helper(c0, "PICKUP_BRIDGE_MACRO");
-		if (!ast_strlen_zero(bridge_macro)) {
-			bridge_macro_args = pbx_builtin_getvar_helper(c0, "PICKUP_BRIDGE_MACRO_ARGS");
-			ast_app_run_macro(c0, c1, bridge_macro, bridge_macro_args);
-		}
-		ast_channel_lock(c0);
-		if (!ast_channel_datastore_remove(c0, ds_bridge_macro)) {
-			ast_datastore_free(ds_bridge_macro);
-		}
-		ast_channel_unlock(c0);
-	}
-	if ((ds_bridge_macro = ast_channel_datastore_find(c1, &pickup_target_info, NULL))) {
-		bridge_macro = pbx_builtin_getvar_helper(c1, "PICKUP_BRIDGE_MACRO");
-		if (!ast_strlen_zero(bridge_macro)) {
-			bridge_macro_args = pbx_builtin_getvar_helper(c1, "PICKUP_BRIDGE_MACRO_ARGS");
-			ast_app_run_macro(c1, c0, bridge_macro, bridge_macro_args);
-		}
-		ast_channel_lock(c1);
-		if (!ast_channel_datastore_remove(c1, ds_bridge_macro)) {
-			ast_datastore_free(ds_bridge_macro);
-		}
-		ast_channel_unlock(c1);
-	}
 
 	for (/* ever */;;) {
 		struct timeval now = { 0, };

Modified: team/irroot/distrotech-customers-10/main/features.c
URL: http://svnview.digium.com/svn/asterisk/team/irroot/distrotech-customers-10/main/features.c?view=diff&rev=345020&r1=345019&r2=345020
==============================================================================
--- team/irroot/distrotech-customers-10/main/features.c (original)
+++ team/irroot/distrotech-customers-10/main/features.c Sun Nov 13 02:52:24 2011
@@ -3856,6 +3856,7 @@
 	struct ast_cdr *new_peer_cdr = NULL; /* the proper chan cdr, if there are forked cdrs */
 	struct ast_silence_generator *silgen = NULL;
 	const char *h_context;
+	struct ast_datastore *ds;
 
 	if (chan && peer) {
 		pbx_builtin_setvar_helper(chan, "BRIDGEPEER", peer->name);
@@ -4012,6 +4013,29 @@
 	 * don't, well, what can we do about that? */
 	clear_dialed_interfaces(chan);
 	clear_dialed_interfaces(peer);
+
+	/*put channel in autoservice and lock while we run any bridging callbacks*/
+	ast_autoservice_start(chan);
+	ast_channel_lock(chan);
+	AST_LIST_TRAVERSE_SAFE_BEGIN(&chan->datastores, ds, entry) {
+		if (ds->info->bridge_fixup) {
+			ds->info->bridge_fixup(ds->data, chan, peer);
+		}
+	}
+	AST_LIST_TRAVERSE_SAFE_END;
+	ast_channel_unlock(chan);
+	ast_autoservice_stop(chan);
+
+	ast_autoservice_start(peer);
+	ast_channel_lock(peer);
+	AST_LIST_TRAVERSE_SAFE_BEGIN(&peer->datastores, ds, entry) {
+		if (ds->info->bridge_fixup) {
+			ds->info->bridge_fixup(ds->data, peer, chan);
+		}
+	}
+	AST_LIST_TRAVERSE_SAFE_END;
+	ast_channel_unlock(peer);
+	ast_autoservice_stop(peer);
 
 	for (;;) {
 		struct ast_channel *other;	/* used later */
@@ -7193,6 +7217,23 @@
 	return res;
 }
 
+static void ast_pickup_bridge_fixup(void *data, struct ast_channel *chan, struct ast_channel *bridge)
+{
+	const char *bridge_macro;
+	const char *bridge_macro_args;
+
+	if ((bridge_macro = pbx_builtin_getvar_helper(chan, "PICKUP_BRIDGE_MACRO")) &&
+	    !ast_strlen_zero(bridge_macro)) {
+		bridge_macro_args = pbx_builtin_getvar_helper(chan, "PICKUP_BRIDGE_MACRO_ARGS");
+		ast_app_run_macro(NULL, bridge, bridge_macro, bridge_macro_args);
+	}
+}
+
+const struct ast_datastore_info pickup_target_info = {
+	.type = "pickup-call",
+	.bridge_fixup = ast_pickup_bridge_fixup,
+};
+
 int ast_do_pickup(struct ast_channel *chan, struct ast_channel *target)
 {
 	struct ast_party_connected_line connected_caller;
@@ -7215,10 +7256,11 @@
 	}
 	ast_channel_datastore_add(target, ds_pickup);
 
-	/* Mark the target so a macro can be run on it if needed. */
-	ds_bridge_macro = ast_datastore_alloc(&pickup_target_info, NULL);
-	if (ds_bridge_macro) {
-		ast_channel_datastore_add(target, ds_bridge_macro);
+	/* Mark the channel so a macro can be run when about to be bridged
+	 * the datastore is left so a pickup can be detected.
+	 */
+	if ((ds_bridge_macro = ast_datastore_alloc(&pickup_target_info, NULL))) {
+		ast_channel_datastore_add(chan, ds_bridge_macro);
 	} else {
 		ast_log(LOG_WARNING,
 			"Unable to create channel datastore on '%s' for running macro\n", target_name);
@@ -7277,7 +7319,7 @@
 	if (!ast_channel_datastore_remove(target, ds_pickup)) {
 		ast_datastore_free(ds_pickup);
 	}
-	if (res && ds_bridge_macro && !ast_channel_datastore_remove(target, ds_bridge_macro)) {
+	if (res && ds_bridge_macro && !ast_channel_datastore_remove(chan, ds_bridge_macro)) {
 		ast_datastore_free(ds_bridge_macro);
 	}
 

Modified: team/irroot/distrotech-customers-10/main/global_datastores.c
URL: http://svnview.digium.com/svn/asterisk/team/irroot/distrotech-customers-10/main/global_datastores.c?view=diff&rev=345020&r1=345019&r2=345020
==============================================================================
--- team/irroot/distrotech-customers-10/main/global_datastores.c (original)
+++ team/irroot/distrotech-customers-10/main/global_datastores.c Sun Nov 13 02:52:24 2011
@@ -110,7 +110,3 @@
 	.destroy = secure_call_store_destroy,
 	.duplicate = secure_call_store_duplicate,
 };
-
-const struct ast_datastore_info pickup_target_info = {
-	.type = "pickup-call",
-};




More information about the asterisk-commits mailing list