#include "asterisk.h"
#include <sys/socket.h>
#include <sys/time.h>
#include <arpa/inet.h>
#include <fcntl.h>
#include <sys/ioctl.h>
#include <nbs.h>
#include "asterisk/lock.h"
#include "asterisk/channel.h"
#include "asterisk/config.h"
#include "asterisk/module.h"
#include "asterisk/pbx.h"
#include "asterisk/utils.h"
Go to the source code of this file.
Data Structures | |
struct | nbs_pvt |
Functions | |
static void | __reg_module (void) |
static void | __unreg_module (void) |
static int | load_module (void) |
static struct nbs_pvt * | nbs_alloc (void *data) |
static int | nbs_call (struct ast_channel *ast, char *dest, int timeout) |
static void | nbs_destroy (struct nbs_pvt *p) |
static int | nbs_hangup (struct ast_channel *ast) |
static struct ast_channel * | nbs_new (struct nbs_pvt *i, int state) |
static struct ast_channel * | nbs_request (const char *type, int format, void *data, int *cause) |
static struct ast_frame * | nbs_xread (struct ast_channel *ast) |
static int | nbs_xwrite (struct ast_channel *ast, struct ast_frame *frame) |
static int | unload_module (void) |
Variables | |
static struct ast_module_info | __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "Network Broadcast Sound Support" , .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 = "a9c98e5d177805051735cb5b0b16b0a0" , .load = load_module, .unload = unload_module, } |
static struct ast_module_info * | ast_module_info = &__mod_info |
static char | context [AST_MAX_EXTENSION] = "default" |
static struct ast_channel_tech | nbs_tech |
static int | prefformat = AST_FORMAT_SLINEAR |
static const char | tdesc [] = "Network Broadcast Sound Driver" |
static char | type [] = "NBS" |
Definition in file chan_nbs.c.
static void __reg_module | ( | void | ) | [static] |
Definition at line 292 of file chan_nbs.c.
static void __unreg_module | ( | void | ) | [static] |
Definition at line 292 of file chan_nbs.c.
static int load_module | ( | void | ) | [static] |
Definition at line 282 of file chan_nbs.c.
References ast_channel_register(), ast_log(), LOG_ERROR, and nbs_tech.
00283 { 00284 /* Make sure we can register our channel type */ 00285 if (ast_channel_register(&nbs_tech)) { 00286 ast_log(LOG_ERROR, "Unable to register channel class %s\n", type); 00287 return -1; 00288 } 00289 return 0; 00290 }
static struct nbs_pvt* nbs_alloc | ( | void * | data | ) | [static] |
Definition at line 120 of file chan_nbs.c.
References ast_calloc, ast_copy_string(), ast_free, ast_log(), ast_strlen_zero(), LOG_WARNING, and nbs_pvt::stream.
Referenced by nbs_request().
00121 { 00122 struct nbs_pvt *p; 00123 int flags = 0; 00124 char stream[256]; 00125 char *opts; 00126 00127 ast_copy_string(stream, data, sizeof(stream)); 00128 if ((opts = strchr(stream, ':'))) { 00129 *opts = '\0'; 00130 opts++; 00131 } else 00132 opts = ""; 00133 p = ast_calloc(1, sizeof(*p)); 00134 if (p) { 00135 if (!ast_strlen_zero(opts)) { 00136 if (strchr(opts, 'm')) 00137 flags |= NBS_FLAG_MUTE; 00138 if (strchr(opts, 'o')) 00139 flags |= NBS_FLAG_OVERSPEAK; 00140 if (strchr(opts, 'e')) 00141 flags |= NBS_FLAG_EMERGENCY; 00142 if (strchr(opts, 'O')) 00143 flags |= NBS_FLAG_OVERRIDE; 00144 } else 00145 flags = NBS_FLAG_OVERSPEAK; 00146 00147 ast_copy_string(p->stream, stream, sizeof(p->stream)); 00148 p->nbs = nbs_newstream("asterisk", stream, flags); 00149 if (!p->nbs) { 00150 ast_log(LOG_WARNING, "Unable to allocate new NBS stream '%s' with flags %d\n", stream, flags); 00151 ast_free(p); 00152 p = NULL; 00153 } else { 00154 /* Set for 8000 hz mono, 640 samples */ 00155 nbs_setbitrate(p->nbs, 8000); 00156 nbs_setchannels(p->nbs, 1); 00157 nbs_setblocksize(p->nbs, 640); 00158 nbs_setblocking(p->nbs, 0); 00159 } 00160 } 00161 return p; 00162 }
static int nbs_call | ( | struct ast_channel * | ast, | |
char * | dest, | |||
int | timeout | |||
) | [static] |
Definition at line 86 of file chan_nbs.c.
References ast_channel::_state, AST_CONTROL_ANSWER, AST_CONTROL_CONGESTION, ast_debug, ast_log(), ast_queue_control(), ast_setstate(), AST_STATE_DOWN, AST_STATE_RESERVED, AST_STATE_RINGING, LOG_WARNING, ast_channel::name, nbs_pvt::nbs, and ast_channel::tech_pvt.
00087 { 00088 struct nbs_pvt *p; 00089 00090 p = ast->tech_pvt; 00091 00092 if ((ast->_state != AST_STATE_DOWN) && (ast->_state != AST_STATE_RESERVED)) { 00093 ast_log(LOG_WARNING, "nbs_call called on %s, neither down nor reserved\n", ast->name); 00094 return -1; 00095 } 00096 /* When we call, it just works, really, there's no destination... Just 00097 ring the phone and wait for someone to answer */ 00098 ast_debug(1, "Calling %s on %s\n", dest, ast->name); 00099 00100 /* If we can't connect, return congestion */ 00101 if (nbs_connect(p->nbs)) { 00102 ast_log(LOG_WARNING, "NBS Connection failed on %s\n", ast->name); 00103 ast_queue_control(ast, AST_CONTROL_CONGESTION); 00104 } else { 00105 ast_setstate(ast, AST_STATE_RINGING); 00106 ast_queue_control(ast, AST_CONTROL_ANSWER); 00107 } 00108 00109 return 0; 00110 }
static void nbs_destroy | ( | struct nbs_pvt * | p | ) | [static] |
Definition at line 112 of file chan_nbs.c.
References ast_free, ast_module_user_remove, nbs_pvt::nbs, and nbs_pvt::u.
Referenced by nbs_hangup(), and nbs_request().
00113 { 00114 if (p->nbs) 00115 nbs_delstream(p->nbs); 00116 ast_module_user_remove(p->u); 00117 ast_free(p); 00118 }
static int nbs_hangup | ( | struct ast_channel * | ast | ) | [static] |
Definition at line 164 of file chan_nbs.c.
References ast_debug, ast_log(), ast_setstate(), AST_STATE_DOWN, LOG_WARNING, ast_channel::name, nbs_destroy(), and ast_channel::tech_pvt.
00165 { 00166 struct nbs_pvt *p; 00167 p = ast->tech_pvt; 00168 ast_debug(1, "nbs_hangup(%s)\n", ast->name); 00169 if (!ast->tech_pvt) { 00170 ast_log(LOG_WARNING, "Asked to hangup channel not connected\n"); 00171 return 0; 00172 } 00173 nbs_destroy(p); 00174 ast->tech_pvt = NULL; 00175 ast_setstate(ast, AST_STATE_DOWN); 00176 return 0; 00177 }
static struct ast_channel* nbs_new | ( | struct nbs_pvt * | i, | |
int | state | |||
) | [static] |
Definition at line 222 of file chan_nbs.c.
References ast_channel_alloc(), ast_channel_set_fd(), ast_copy_string(), ast_hangup(), ast_log(), ast_module_user_add, ast_pbx_start(), AST_STATE_DOWN, AST_STATE_RING, ast_string_field_set, ast_channel::context, ast_channel::exten, language, LOG_WARNING, ast_channel::nativeformats, nbs_pvt::nbs, nbs_tech, nbs_pvt::owner, ast_channel::rawreadformat, ast_channel::rawwriteformat, ast_channel::readformat, ast_channel::rings, nbs_pvt::stream, ast_channel::tech, ast_channel::tech_pvt, nbs_pvt::u, and ast_channel::writeformat.
Referenced by nbs_request().
00223 { 00224 struct ast_channel *tmp; 00225 tmp = ast_channel_alloc(1, state, 0, 0, "", "s", context, 0, "NBS/%s", i->stream); 00226 if (tmp) { 00227 tmp->tech = &nbs_tech; 00228 ast_channel_set_fd(tmp, 0, nbs_fd(i->nbs)); 00229 tmp->nativeformats = prefformat; 00230 tmp->rawreadformat = prefformat; 00231 tmp->rawwriteformat = prefformat; 00232 tmp->writeformat = prefformat; 00233 tmp->readformat = prefformat; 00234 if (state == AST_STATE_RING) 00235 tmp->rings = 1; 00236 tmp->tech_pvt = i; 00237 ast_copy_string(tmp->context, context, sizeof(tmp->context)); 00238 ast_copy_string(tmp->exten, "s", sizeof(tmp->exten)); 00239 ast_string_field_set(tmp, language, ""); 00240 i->owner = tmp; 00241 i->u = ast_module_user_add(tmp); 00242 if (state != AST_STATE_DOWN) { 00243 if (ast_pbx_start(tmp)) { 00244 ast_log(LOG_WARNING, "Unable to start PBX on %s\n", tmp->name); 00245 ast_hangup(tmp); 00246 } 00247 } 00248 } else 00249 ast_log(LOG_WARNING, "Unable to allocate channel structure\n"); 00250 return tmp; 00251 }
static struct ast_channel * nbs_request | ( | const char * | type, | |
int | format, | |||
void * | data, | |||
int * | cause | |||
) | [static] |
Definition at line 254 of file chan_nbs.c.
References AST_FORMAT_SLINEAR, ast_log(), AST_STATE_DOWN, LOG_NOTICE, nbs_alloc(), nbs_destroy(), and nbs_new().
00255 { 00256 int oldformat; 00257 struct nbs_pvt *p; 00258 struct ast_channel *tmp = NULL; 00259 00260 oldformat = format; 00261 format &= (AST_FORMAT_SLINEAR); 00262 if (!format) { 00263 ast_log(LOG_NOTICE, "Asked to get a channel of unsupported format '%d'\n", oldformat); 00264 return NULL; 00265 } 00266 p = nbs_alloc(data); 00267 if (p) { 00268 tmp = nbs_new(p, AST_STATE_DOWN); 00269 if (!tmp) 00270 nbs_destroy(p); 00271 } 00272 return tmp; 00273 }
static struct ast_frame * nbs_xread | ( | struct ast_channel * | ast | ) | [static] |
Definition at line 179 of file chan_nbs.c.
References ast_debug, ast_frame::data, ast_frame::datalen, ast_frame::delivery, nbs_pvt::fr, ast_frame::mallocd, ast_channel::name, ast_frame::offset, ast_frame::ptr, ast_frame::samples, ast_frame::src, and ast_channel::tech_pvt.
00180 { 00181 struct nbs_pvt *p = ast->tech_pvt; 00182 00183 00184 /* Some nice norms */ 00185 p->fr.datalen = 0; 00186 p->fr.samples = 0; 00187 p->fr.data.ptr = NULL; 00188 p->fr.src = type; 00189 p->fr.offset = 0; 00190 p->fr.mallocd=0; 00191 p->fr.delivery.tv_sec = 0; 00192 p->fr.delivery.tv_usec = 0; 00193 00194 ast_debug(1, "Returning null frame on %s\n", ast->name); 00195 00196 return &p->fr; 00197 }
static int nbs_xwrite | ( | struct ast_channel * | ast, | |
struct ast_frame * | frame | |||
) | [static] |
Definition at line 199 of file chan_nbs.c.
References ast_channel::_state, AST_FORMAT_SLINEAR, AST_FRAME_IMAGE, AST_FRAME_VOICE, ast_log(), AST_STATE_UP, ast_frame::data, ast_frame::datalen, ast_frame::frametype, LOG_WARNING, nbs_pvt::nbs, ast_frame::ptr, ast_frame::subclass, and ast_channel::tech_pvt.
00200 { 00201 struct nbs_pvt *p = ast->tech_pvt; 00202 /* Write a frame of (presumably voice) data */ 00203 if (frame->frametype != AST_FRAME_VOICE) { 00204 if (frame->frametype != AST_FRAME_IMAGE) 00205 ast_log(LOG_WARNING, "Don't know what to do with frame type '%d'\n", frame->frametype); 00206 return 0; 00207 } 00208 if (!(frame->subclass & 00209 (AST_FORMAT_SLINEAR))) { 00210 ast_log(LOG_WARNING, "Cannot handle frames in %d format\n", frame->subclass); 00211 return 0; 00212 } 00213 if (ast->_state != AST_STATE_UP) { 00214 /* Don't try tos end audio on-hook */ 00215 return 0; 00216 } 00217 if (nbs_write(p->nbs, frame->data.ptr, frame->datalen / 2) < 0) 00218 return -1; 00219 return 0; 00220 }
static int unload_module | ( | void | ) | [static] |
Definition at line 275 of file chan_nbs.c.
References ast_channel_unregister(), and nbs_tech.
00276 { 00277 /* First, take us out of the channel loop */ 00278 ast_channel_unregister(&nbs_tech); 00279 return 0; 00280 }
struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "Network Broadcast Sound Support" , .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 = "a9c98e5d177805051735cb5b0b16b0a0" , .load = load_module, .unload = unload_module, } [static] |
Definition at line 292 of file chan_nbs.c.
struct ast_module_info* ast_module_info = &__mod_info [static] |
Definition at line 292 of file chan_nbs.c.
char context[AST_MAX_EXTENSION] = "default" [static] |
Definition at line 55 of file chan_nbs.c.
struct ast_channel_tech nbs_tech [static] |
Definition at line 75 of file chan_nbs.c.
Referenced by load_module(), nbs_new(), and unload_module().
int prefformat = AST_FORMAT_SLINEAR [static] |
Definition at line 53 of file chan_nbs.c.
const char tdesc[] = "Network Broadcast Sound Driver" [static] |
Definition at line 50 of file chan_nbs.c.
char type[] = "NBS" [static] |
Definition at line 56 of file chan_nbs.c.