#include "asterisk.h"
#include <fcntl.h>
#include <sys/signal.h>
#include "asterisk/lock.h"
#include "asterisk/channel.h"
#include "asterisk/config.h"
#include "asterisk/module.h"
#include "asterisk/pbx.h"
#include "asterisk/sched.h"
#include "asterisk/io.h"
#include "asterisk/acl.h"
#include "asterisk/callerid.h"
#include "asterisk/file.h"
#include "asterisk/cli.h"
#include "asterisk/app.h"
#include "asterisk/rtp_engine.h"
#include "asterisk/causes.h"

Go to the source code of this file.
Functions | |
| static void | __reg_module (void) |
| static void | __unreg_module (void) |
| static int | load_module (void) |
| Function called when our module is loaded. | |
| static int | multicast_rtp_call (struct ast_channel *ast, const char *dest, int timeout) |
| Function called when we should actually call the destination. | |
| static int | multicast_rtp_hangup (struct ast_channel *ast) |
| Function called when we should hang the channel up. | |
| static struct ast_frame * | multicast_rtp_read (struct ast_channel *ast) |
| Function called when we should read a frame from the channel. | |
| static struct ast_channel * | multicast_rtp_request (const char *type, struct ast_format_cap *cap, const struct ast_channel *requestor, const char *data, int *cause) |
| Function called when we should prepare to call the destination. | |
| static int | multicast_rtp_write (struct ast_channel *ast, struct ast_frame *f) |
| Function called when we should write a frame to the channel. | |
| static int | unload_module (void) |
| Function called when our module is unloaded. | |
Variables | |
| static struct ast_module_info | __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Multicast RTP Paging Channel" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .load = load_module, .unload = unload_module, .load_pri = AST_MODPRI_CHANNEL_DRIVER, } |
| static struct ast_module_info * | ast_module_info = &__mod_info |
| static struct ast_channel_tech | multicast_rtp_tech |
| static const char | tdesc [] = "Multicast RTP Paging Channel Driver" |
Definition in file chan_multicast_rtp.c.
| static void __reg_module | ( | void | ) | [static] |
Definition at line 204 of file chan_multicast_rtp.c.
| static void __unreg_module | ( | void | ) | [static] |
Definition at line 204 of file chan_multicast_rtp.c.
| static int load_module | ( | void | ) | [static] |
Function called when our module is loaded.
Definition at line 177 of file chan_multicast_rtp.c.
References ast_channel_register(), ast_format_cap_add_all(), ast_format_cap_alloc(), ast_log(), AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, ast_channel_tech::capabilities, and LOG_ERROR.
00178 { 00179 if (!(multicast_rtp_tech.capabilities = ast_format_cap_alloc())) { 00180 return AST_MODULE_LOAD_DECLINE; 00181 } 00182 ast_format_cap_add_all(multicast_rtp_tech.capabilities); 00183 if (ast_channel_register(&multicast_rtp_tech)) { 00184 ast_log(LOG_ERROR, "Unable to register channel class 'MulticastRTP'\n"); 00185 return AST_MODULE_LOAD_DECLINE; 00186 } 00187 00188 return AST_MODULE_LOAD_SUCCESS; 00189 }
| static int multicast_rtp_call | ( | struct ast_channel * | ast, | |
| const char * | dest, | |||
| int | timeout | |||
| ) | [static] |
Function called when we should actually call the destination.
Definition at line 91 of file chan_multicast_rtp.c.
References AST_CONTROL_ANSWER, ast_queue_control(), ast_rtp_instance_activate(), and ast_channel::tech_pvt.
00092 { 00093 struct ast_rtp_instance *instance = ast->tech_pvt; 00094 00095 ast_queue_control(ast, AST_CONTROL_ANSWER); 00096 00097 return ast_rtp_instance_activate(instance); 00098 }
| static int multicast_rtp_hangup | ( | struct ast_channel * | ast | ) | [static] |
Function called when we should hang the channel up.
Definition at line 101 of file chan_multicast_rtp.c.
References ast_rtp_instance_destroy(), and ast_channel::tech_pvt.
00102 { 00103 struct ast_rtp_instance *instance = ast->tech_pvt; 00104 00105 ast_rtp_instance_destroy(instance); 00106 00107 ast->tech_pvt = NULL; 00108 00109 return 0; 00110 }
| static struct ast_frame * multicast_rtp_read | ( | struct ast_channel * | ast | ) | [static, read] |
Function called when we should read a frame from the channel.
Definition at line 77 of file chan_multicast_rtp.c.
References ast_null_frame.
00078 { 00079 return &ast_null_frame; 00080 }
| static struct ast_channel * multicast_rtp_request | ( | const char * | type, | |
| struct ast_format_cap * | cap, | |||
| const struct ast_channel * | requestor, | |||
| const char * | data, | |||
| int * | cause | |||
| ) | [static, read] |
Function called when we should prepare to call the destination.
Definition at line 113 of file chan_multicast_rtp.c.
References ast_best_codec(), AST_CAUSE_FAILURE, ast_channel_alloc, ast_channel_linkedid(), ast_format_cap_add(), ast_format_copy(), ast_rtp_instance_destroy(), ast_rtp_instance_new(), ast_rtp_instance_set_remote_address(), ast_sockaddr_parse(), ast_sockaddr_setnull(), AST_STATE_DOWN, ast_strdupa, ast_strlen_zero(), ast_channel::nativeformats, PARSE_PORT_REQUIRE, ast_channel::rawreadformat, ast_channel::rawwriteformat, ast_channel::readformat, ast_channel::tech, ast_channel::tech_pvt, and ast_channel::writeformat.
00114 { 00115 char *tmp = ast_strdupa(data), *multicast_type = tmp, *destination, *control; 00116 struct ast_rtp_instance *instance; 00117 struct ast_sockaddr control_address; 00118 struct ast_sockaddr destination_address; 00119 struct ast_channel *chan; 00120 struct ast_format fmt; 00121 ast_best_codec(cap, &fmt); 00122 00123 ast_sockaddr_setnull(&control_address); 00124 00125 /* If no type was given we can't do anything */ 00126 if (ast_strlen_zero(multicast_type)) { 00127 goto failure; 00128 } 00129 00130 if (!(destination = strchr(tmp, '/'))) { 00131 goto failure; 00132 } 00133 *destination++ = '\0'; 00134 00135 if ((control = strchr(destination, '/'))) { 00136 *control++ = '\0'; 00137 if (!ast_sockaddr_parse(&control_address, control, 00138 PARSE_PORT_REQUIRE)) { 00139 goto failure; 00140 } 00141 } 00142 00143 if (!ast_sockaddr_parse(&destination_address, destination, 00144 PARSE_PORT_REQUIRE)) { 00145 goto failure; 00146 } 00147 00148 if (!(instance = ast_rtp_instance_new("multicast", NULL, &control_address, multicast_type))) { 00149 goto failure; 00150 } 00151 00152 if (!(chan = ast_channel_alloc(1, AST_STATE_DOWN, "", "", "", "", "", requestor ? ast_channel_linkedid(requestor) : "", 0, "MulticastRTP/%p", instance))) { 00153 ast_rtp_instance_destroy(instance); 00154 goto failure; 00155 } 00156 00157 ast_rtp_instance_set_remote_address(instance, &destination_address); 00158 00159 chan->tech = &multicast_rtp_tech; 00160 00161 ast_format_cap_add(chan->nativeformats, &fmt); 00162 ast_format_copy(&chan->writeformat, &fmt); 00163 ast_format_copy(&chan->rawwriteformat, &fmt); 00164 ast_format_copy(&chan->readformat, &fmt); 00165 ast_format_copy(&chan->rawreadformat, &fmt); 00166 00167 chan->tech_pvt = instance; 00168 00169 return chan; 00170 00171 failure: 00172 *cause = AST_CAUSE_FAILURE; 00173 return NULL; 00174 }
| static int multicast_rtp_write | ( | struct ast_channel * | ast, | |
| struct ast_frame * | f | |||
| ) | [static] |
Function called when we should write a frame to the channel.
Definition at line 83 of file chan_multicast_rtp.c.
References ast_rtp_instance_write(), and ast_channel::tech_pvt.
00084 { 00085 struct ast_rtp_instance *instance = ast->tech_pvt; 00086 00087 return ast_rtp_instance_write(instance, f); 00088 }
| static int unload_module | ( | void | ) | [static] |
Function called when our module is unloaded.
Definition at line 192 of file chan_multicast_rtp.c.
References ast_channel_unregister(), ast_format_cap_destroy(), and ast_channel_tech::capabilities.
00193 { 00194 ast_channel_unregister(&multicast_rtp_tech); 00195 multicast_rtp_tech.capabilities = ast_format_cap_destroy(multicast_rtp_tech.capabilities); 00196 00197 return 0; 00198 }
struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Multicast RTP Paging Channel" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .load = load_module, .unload = unload_module, .load_pri = AST_MODPRI_CHANNEL_DRIVER, } [static] |
Definition at line 204 of file chan_multicast_rtp.c.
struct ast_module_info* ast_module_info = &__mod_info [static] |
Definition at line 204 of file chan_multicast_rtp.c.
struct ast_channel_tech multicast_rtp_tech [static] |
Definition at line 66 of file chan_multicast_rtp.c.
const char tdesc[] = "Multicast RTP Paging Channel Driver" [static] |
Definition at line 56 of file chan_multicast_rtp.c.
1.5.6