app_nbscat.c File Reference

Silly application to play an NBScat file -- uses nbscat8k. More...

#include "asterisk.h"
#include <fcntl.h>
#include <sys/time.h>
#include <sys/socket.h>
#include <signal.h>
#include "asterisk/lock.h"
#include "asterisk/file.h"
#include "asterisk/channel.h"
#include "asterisk/frame.h"
#include "asterisk/pbx.h"
#include "asterisk/module.h"
#include "asterisk/translate.h"
#include "asterisk/app.h"

Include dependency graph for app_nbscat.c:

Go to the source code of this file.

Defines

#define AF_LOCAL   AF_UNIX

#define LOCAL_NBSCAT   "/usr/local/bin/nbscat8k"

#define NBSCAT   "/usr/bin/nbscat8k"

Functions

static void __reg_module (void)

static void __unreg_module (void)

static int load_module (void)

static int NBScat_exec (struct ast_channel *chan, const char *data)

static int NBScatplay (int fd)

static int timed_read (int fd, void *data, int datalen)

static int unload_module (void)

Variables

static struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Silly NBS Stream Application" , .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_DEFAULT, }

static char * app = "NBScat"

static struct ast_module_info * ast_module_info = &__mod_info

Detailed Description

Silly application to play an NBScat file -- uses nbscat8k.

Author:: Mark Spencer <markster@digium.com>

Definition in file app_nbscat.c.

Define Documentation

#define AF_LOCAL AF_UNIX

Definition at line 67 of file app_nbscat.c.

Referenced by ast_makesocket(), ast_tryconnect(), listener(), and NBScat_exec().

#define LOCAL_NBSCAT "/usr/local/bin/nbscat8k"

Definition at line 63 of file app_nbscat.c.

Referenced by NBScatplay().

#define NBSCAT "/usr/bin/nbscat8k"

Definition at line 64 of file app_nbscat.c.

Referenced by NBScatplay().

Function Documentation

static void __reg_module ( void ) [static]

Definition at line 221 of file app_nbscat.c.

static void __unreg_module ( void ) [static]

Definition at line 221 of file app_nbscat.c.

static int load_module ( void ) [static]

Definition at line 216 of file app_nbscat.c.

References ast_register_application_xml, and NBScat_exec().

00217 {
00218    return ast_register_application_xml(app, NBScat_exec);
00219 }

static int NBScat_exec	(	struct ast_channel *	chan,
		const char *	data
	)			`[static]`

Definition at line 112 of file app_nbscat.c.

References AF_LOCAL, ast_debug, ast_format_clear(), ast_format_copy(), ast_format_set(), AST_FORMAT_SLINEAR, AST_FRAME_DTMF, AST_FRAME_VOICE, ast_frfree, AST_FRIENDLY_OFFSET, ast_log(), ast_read(), ast_samp2tv(), ast_set_write_format(), ast_set_write_format_by_id(), ast_stopstream(), ast_tvadd(), ast_tvdiff_ms(), ast_tvnow(), ast_waitfor(), ast_write(), f, ast_frame::frametype, ast_format::id, LOG_WARNING, NBScatplay(), ast_frame::offset, timed_read(), and ast_channel::writeformat.

Referenced by load_module().

00113 {
00114    int res=0;
00115    int fds[2];
00116    int ms = -1;
00117    int pid = -1;
00118    struct ast_format owriteformat;
00119    struct timeval next;
00120    struct ast_frame *f;
00121    struct myframe {
00122       struct ast_frame f;
00123       char offset[AST_FRIENDLY_OFFSET];
00124       short frdata[160];
00125    } myf;
00126 
00127    ast_format_clear(&owriteformat);
00128    if (socketpair(AF_LOCAL, SOCK_STREAM, 0, fds)) {
00129       ast_log(LOG_WARNING, "Unable to create socketpair\n");
00130       return -1;
00131    }
00132    
00133    ast_stopstream(chan);
00134 
00135    ast_format_copy(&owriteformat, &chan->writeformat);
00136    res = ast_set_write_format_by_id(chan, AST_FORMAT_SLINEAR);
00137    if (res < 0) {
00138       ast_log(LOG_WARNING, "Unable to set write format to signed linear\n");
00139       return -1;
00140    }
00141    
00142    res = NBScatplay(fds[1]);
00143    /* Wait 1000 ms first */
00144    next = ast_tvnow();
00145    next.tv_sec += 1;
00146    if (res >= 0) {
00147       pid = res;
00148       /* Order is important -- there's almost always going to be mp3...  we want to prioritize the
00149          user */
00150       for (;;) {
00151          ms = ast_tvdiff_ms(next, ast_tvnow());
00152          if (ms <= 0) {
00153             res = timed_read(fds[0], myf.frdata, sizeof(myf.frdata));
00154             if (res > 0) {
00155                myf.f.frametype = AST_FRAME_VOICE;
00156                ast_format_set(&myf.f.subclass.format, AST_FORMAT_SLINEAR, 0);
00157                myf.f.datalen = res;
00158                myf.f.samples = res / 2;
00159                myf.f.mallocd = 0;
00160                myf.f.offset = AST_FRIENDLY_OFFSET;
00161                myf.f.src = __PRETTY_FUNCTION__;
00162                myf.f.delivery.tv_sec = 0;
00163                myf.f.delivery.tv_usec = 0;
00164                myf.f.data.ptr = myf.frdata;
00165                if (ast_write(chan, &myf.f) < 0) {
00166                   res = -1;
00167                   break;
00168                }
00169             } else {
00170                ast_debug(1, "No more mp3\n");
00171                res = 0;
00172                break;
00173             }
00174             next = ast_tvadd(next, ast_samp2tv(myf.f.samples, 8000));
00175          } else {
00176             ms = ast_waitfor(chan, ms);
00177             if (ms < 0) {
00178                ast_debug(1, "Hangup detected\n");
00179                res = -1;
00180                break;
00181             }
00182             if (ms) {
00183                f = ast_read(chan);
00184                if (!f) {
00185                   ast_debug(1, "Null frame == hangup() detected\n");
00186                   res = -1;
00187                   break;
00188                }
00189                if (f->frametype == AST_FRAME_DTMF) {
00190                   ast_debug(1, "User pressed a key\n");
00191                   ast_frfree(f);
00192                   res = 0;
00193                   break;
00194                }
00195                ast_frfree(f);
00196             } 
00197          }
00198       }
00199    }
00200    close(fds[0]);
00201    close(fds[1]);
00202    
00203    if (pid > -1)
00204       kill(pid, SIGKILL);
00205    if (!res && owriteformat.id)
00206       ast_set_write_format(chan, &owriteformat);
00207 
00208    return res;
00209 }

static int NBScatplay ( int fd ) [static]

Definition at line 72 of file app_nbscat.c.

References ast_close_fds_above_n(), ast_log(), ast_opt_high_priority, ast_safe_fork(), ast_set_priority(), LOCAL_NBSCAT, LOG_WARNING, and NBSCAT.

Referenced by NBScat_exec().

00073 {
00074    int res;
00075 
00076    res = ast_safe_fork(0);
00077    if (res < 0) {
00078       ast_log(LOG_WARNING, "Fork failed\n");
00079    }
00080 
00081    if (res) {
00082       return res;
00083    }
00084 
00085    if (ast_opt_high_priority)
00086       ast_set_priority(0);
00087 
00088    dup2(fd, STDOUT_FILENO);
00089    ast_close_fds_above_n(STDERR_FILENO);
00090    /* Most commonly installed in /usr/local/bin */
00091    execl(NBSCAT, "nbscat8k", "-d", (char *)NULL);
00092    execl(LOCAL_NBSCAT, "nbscat8k", "-d", (char *)NULL);
00093    fprintf(stderr, "Execute of nbscat8k failed\n");
00094    _exit(0);
00095 }

static int timed_read	(	int	fd,
		void *	data,
		int	datalen
	)			`[static]`

Definition at line 97 of file app_nbscat.c.

References ast_log(), ast_poll, and LOG_NOTICE.

00098 {
00099    int res;
00100    struct pollfd fds[1];
00101    fds[0].fd = fd;
00102    fds[0].events = POLLIN;
00103    res = ast_poll(fds, 1, 2000);
00104    if (res < 1) {
00105       ast_log(LOG_NOTICE, "Selected timed out/errored out with %d\n", res);
00106       return -1;
00107    }
00108    return read(fd, data, datalen);
00109    
00110 }

static int unload_module ( void ) [static]

Definition at line 211 of file app_nbscat.c.

References ast_unregister_application().

00212 {
00213    return ast_unregister_application(app);
00214 }

Variable Documentation

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Silly NBS Stream Application" , .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_DEFAULT, } [static]

Definition at line 221 of file app_nbscat.c.

char* app = "NBScat" [static]

Definition at line 70 of file app_nbscat.c.

struct ast_module_info* ast_module_info = &__mod_info [static]

Definition at line 221 of file app_nbscat.c.


Defines
#define	AF_LOCAL AF_UNIX
#define	LOCAL_NBSCAT "/usr/local/bin/nbscat8k"
#define	NBSCAT "/usr/bin/nbscat8k"
Functions
static void	__reg_module (void)
static void	__unreg_module (void)
static int	load_module (void)
static int	NBScat_exec (struct ast_channel chan, const char data)
static int	NBScatplay (int fd)
static int	timed_read (int fd, void *data, int datalen)
static int	unload_module (void)
Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Silly NBS Stream Application" , .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_DEFAULT, }
static char *	app = "NBScat"
static struct ast_module_info *	ast_module_info = &__mod_info

Asterisk developer's documentation

app_nbscat.c File Reference

Defines

Functions

Variables

Detailed Description

Define Documentation

Function Documentation

Variable Documentation