mirror of
				https://github.com/asterisk/asterisk.git
				synced 2025-10-31 10:47:18 +00:00 
			
		
		
		
	I've noticed when doing a graceful shutdown that the res_stasis_http.so module gets unloaded before the modules that use it, which causes some asserts during their unload. While r386928 was a quick hack to get it to not assert and die, this patch increases the use counts on res_stasis.so and res_stasis_http.so properly. It's a bigger change than I expected, hence the review instead of just committing it. Review: https://reviewboard.asterisk.org/r/2489/ git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@388350 65c4cc65-6c06-0410-ace0-fbb531ad65f3
		
			
				
	
	
		
			169 lines
		
	
	
		
			4.8 KiB
		
	
	
	
		
			C
		
	
	
	
	
	
			
		
		
	
	
			169 lines
		
	
	
		
			4.8 KiB
		
	
	
	
		
			C
		
	
	
	
	
	
| /*
 | |
|  * Asterisk -- An open source telephony toolkit.
 | |
|  *
 | |
|  * Copyright (C) 2012 - 2013, Digium, Inc.
 | |
|  *
 | |
|  * David M. Lee, II <dlee@digium.com>
 | |
|  *
 | |
|  * See http://www.asterisk.org for more information about
 | |
|  * the Asterisk project. Please do not directly contact
 | |
|  * any of the maintainers of this project for assistance;
 | |
|  * the project provides a web site, mailing lists and IRC
 | |
|  * channels for your use.
 | |
|  *
 | |
|  * This program is free software, distributed under the terms of
 | |
|  * the GNU General Public License Version 2. See the LICENSE file
 | |
|  * at the top of the source tree.
 | |
|  */
 | |
| 
 | |
| /*
 | |
|  * !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
 | |
|  * !!!!!                               DO NOT EDIT                        !!!!!
 | |
|  * !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
 | |
|  * This file is generated by a mustache template. Please see the original
 | |
|  * template in rest-api-templates/res_stasis_http_resource.c.mustache
 | |
|  */
 | |
| 
 | |
| /*! \file
 | |
|  *
 | |
|  * \brief Playback control resources
 | |
|  *
 | |
|  * \author David M. Lee, II <dlee@digium.com>
 | |
|  */
 | |
| 
 | |
| /*** MODULEINFO
 | |
| 	<depend type="module">res_stasis_http</depend>
 | |
| 	<depend type="module">res_stasis</depend>
 | |
| 	<support_level>core</support_level>
 | |
|  ***/
 | |
| 
 | |
| #include "asterisk.h"
 | |
| 
 | |
| ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
 | |
| 
 | |
| #include "asterisk/module.h"
 | |
| #include "asterisk/stasis_app.h"
 | |
| #include "stasis_http/resource_playback.h"
 | |
| 
 | |
| /*!
 | |
|  * \brief Parameter parsing callback for /playback/{playbackId}.
 | |
|  * \param get_params GET parameters in the HTTP request.
 | |
|  * \param path_vars Path variables extracted from the request.
 | |
|  * \param headers HTTP headers.
 | |
|  * \param[out] response Response to the HTTP request.
 | |
|  */
 | |
| static void stasis_http_get_playback_cb(
 | |
|     struct ast_variable *get_params, struct ast_variable *path_vars,
 | |
|     struct ast_variable *headers, struct stasis_http_response *response)
 | |
| {
 | |
| 	struct ast_get_playback_args args = {};
 | |
| 	struct ast_variable *i;
 | |
| 
 | |
| 	for (i = path_vars; i; i = i->next) {
 | |
| 		if (strcmp(i->name, "playbackId") == 0) {
 | |
| 			args.playback_id = (i->value);
 | |
| 		} else
 | |
| 		{}
 | |
| 	}
 | |
| 	stasis_http_get_playback(headers, &args, response);
 | |
| }
 | |
| /*!
 | |
|  * \brief Parameter parsing callback for /playback/{playbackId}.
 | |
|  * \param get_params GET parameters in the HTTP request.
 | |
|  * \param path_vars Path variables extracted from the request.
 | |
|  * \param headers HTTP headers.
 | |
|  * \param[out] response Response to the HTTP request.
 | |
|  */
 | |
| static void stasis_http_stop_playback_cb(
 | |
|     struct ast_variable *get_params, struct ast_variable *path_vars,
 | |
|     struct ast_variable *headers, struct stasis_http_response *response)
 | |
| {
 | |
| 	struct ast_stop_playback_args args = {};
 | |
| 	struct ast_variable *i;
 | |
| 
 | |
| 	for (i = path_vars; i; i = i->next) {
 | |
| 		if (strcmp(i->name, "playbackId") == 0) {
 | |
| 			args.playback_id = (i->value);
 | |
| 		} else
 | |
| 		{}
 | |
| 	}
 | |
| 	stasis_http_stop_playback(headers, &args, response);
 | |
| }
 | |
| /*!
 | |
|  * \brief Parameter parsing callback for /playback/{playbackId}/control.
 | |
|  * \param get_params GET parameters in the HTTP request.
 | |
|  * \param path_vars Path variables extracted from the request.
 | |
|  * \param headers HTTP headers.
 | |
|  * \param[out] response Response to the HTTP request.
 | |
|  */
 | |
| static void stasis_http_control_playback_cb(
 | |
|     struct ast_variable *get_params, struct ast_variable *path_vars,
 | |
|     struct ast_variable *headers, struct stasis_http_response *response)
 | |
| {
 | |
| 	struct ast_control_playback_args args = {};
 | |
| 	struct ast_variable *i;
 | |
| 
 | |
| 	for (i = get_params; i; i = i->next) {
 | |
| 		if (strcmp(i->name, "operation") == 0) {
 | |
| 			args.operation = (i->value);
 | |
| 		} else
 | |
| 		{}
 | |
| 	}
 | |
| 	for (i = path_vars; i; i = i->next) {
 | |
| 		if (strcmp(i->name, "playbackId") == 0) {
 | |
| 			args.playback_id = (i->value);
 | |
| 		} else
 | |
| 		{}
 | |
| 	}
 | |
| 	stasis_http_control_playback(headers, &args, response);
 | |
| }
 | |
| 
 | |
| /*! \brief REST handler for /api-docs/playback.{format} */
 | |
| static struct stasis_rest_handlers playback_playbackId_control = {
 | |
| 	.path_segment = "control",
 | |
| 	.callbacks = {
 | |
| 		[AST_HTTP_POST] = stasis_http_control_playback_cb,
 | |
| 	},
 | |
| 	.num_children = 0,
 | |
| 	.children = {  }
 | |
| };
 | |
| /*! \brief REST handler for /api-docs/playback.{format} */
 | |
| static struct stasis_rest_handlers playback_playbackId = {
 | |
| 	.path_segment = "playbackId",
 | |
| 	.is_wildcard = 1,
 | |
| 	.callbacks = {
 | |
| 		[AST_HTTP_GET] = stasis_http_get_playback_cb,
 | |
| 		[AST_HTTP_DELETE] = stasis_http_stop_playback_cb,
 | |
| 	},
 | |
| 	.num_children = 1,
 | |
| 	.children = { &playback_playbackId_control, }
 | |
| };
 | |
| /*! \brief REST handler for /api-docs/playback.{format} */
 | |
| static struct stasis_rest_handlers playback = {
 | |
| 	.path_segment = "playback",
 | |
| 	.callbacks = {
 | |
| 	},
 | |
| 	.num_children = 1,
 | |
| 	.children = { &playback_playbackId, }
 | |
| };
 | |
| 
 | |
| static int load_module(void)
 | |
| {
 | |
| 	stasis_app_ref();
 | |
| 	return stasis_http_add_handler(&playback);
 | |
| }
 | |
| 
 | |
| static int unload_module(void)
 | |
| {
 | |
| 	stasis_http_remove_handler(&playback);
 | |
| 	stasis_app_unref();
 | |
| 	return 0;
 | |
| }
 | |
| 
 | |
| AST_MODULE_INFO(ASTERISK_GPL_KEY, AST_MODFLAG_DEFAULT,
 | |
| 	"RESTful API module - Playback control resources",
 | |
| 	.load = load_module,
 | |
| 	.unload = unload_module,
 | |
| 	.nonoptreq = "res_stasis_http,res_stasis",
 | |
| 	);
 |