app_mp3.c File Reference

Silly application to play an MP3 file -- uses mpg123. More...

#include "asterisk.h"
#include <sys/time.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_mp3.c:

Go to the source code of this file.

Defines
#define	LOCAL_MPG_123 "/usr/local/bin/mpg123"
#define	MPG_123 "/usr/bin/mpg123"
Functions
static void	__reg_module (void)
static void	__unreg_module (void)
static int	load_module (void)
static int	mp3_exec (struct ast_channel chan, void data)
static int	mp3play (char *filename, int fd)
static int	timed_read (int fd, void *data, int datalen, int timeout)
static int	unload_module (void)
Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "Silly MP3 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 = "0901e4e500243c855563a2d78b0c03e4" , .load = load_module, .unload = unload_module, }
static char *	app = "MP3Player"
static struct ast_module_info *	ast_module_info = &__mod_info

Detailed Description

Silly application to play an MP3 file -- uses mpg123.

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

Definition in file app_mp3.c.

Define Documentation

#define LOCAL_MPG_123 "/usr/local/bin/mpg123"

Definition at line 44 of file app_mp3.c.

Referenced by mp3play(), and spawn_mp3().

#define MPG_123 "/usr/bin/mpg123"

Definition at line 45 of file app_mp3.c.

Referenced by mp3play(), and spawn_mp3().

Function Documentation

static void __reg_module ( void ) [static]

Definition at line 239 of file app_mp3.c.

static void __unreg_module ( void ) [static]

Definition at line 239 of file app_mp3.c.

static int load_module ( void ) [static]

Definition at line 234 of file app_mp3.c.

References ast_register_application_xml, and mp3_exec().

00235 {
00236    return ast_register_application_xml(app, mp3_exec);
00237 }

static int mp3_exec	(	struct ast_channel *	chan,
		void *	data
	)			`[static]`

Definition at line 120 of file app_mp3.c.

References ast_debug, 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_stopstream(), ast_strlen_zero(), ast_tvadd(), ast_tvdiff_ms(), ast_tvnow(), ast_waitfor(), ast_write(), f, ast_frame::frametype, LOG_WARNING, mp3play(), ast_frame::offset, timed_read(), and ast_channel::writeformat.

Referenced by load_module().

00122 00123 00124 00125 00126 00127 00128 00129 00130 00131 00132 00133 00134    } myf = { 00135 00136    }; 00137 00138 00139 00140 00141    } 00142 00143 00144 00145 00146    } 00147 00148 00149 00150 00151 00152 00153 00154 00155    } 00156 00157 00158 00159 00160    } 00161 00162 00163 00164 00165 00166 00167 00168 00169 00170 00171 00172 00173 00174 00175 00176 00177 00178 00179 00180 00181 00182 00183 00184 00185 00186 00187 00188 00189 00190 00191 00192 00193 00194 00195 00196 00197 00198 00199 00200 00201 00202 00203 00204 00205 00206 00207 00208 00209 00210 00211 00212 00213 00214 00215          } 00216       } 00217    } 00218 00219 00220 00221 00222 00223 00224 00225 00226 00227 }

class="fragment">00121 { int res=0; int fds[2]; int ms = -1; int pid = -1; int owriteformat; int timeout = 2000; struct timeval next; struct ast_frame *f; struct myframe { struct ast_frame f; char offset[AST_FRIENDLY_OFFSET]; short frdata[160]; .f = { 0, }, if (ast_strlen_zero(data)) { ast_log(LOG_WARNING, "MP3 Playback requires an argument (filename)\n"); return -1; if (pipe(fds)) { ast_log(LOG_WARNING, "Unable to create pipe\n"); return -1; ast_stopstream(chan); owriteformat = chan->writeformat; res = ast_set_write_format(chan, AST_FORMAT_SLINEAR); if (res < 0) { ast_log(LOG_WARNING, "Unable to set write format to signed linear\n"); return -1; res = mp3play((char *)data, fds[1]); if (!strncasecmp((char *)data, "http://", 7)) { timeout = 10000; /* Wait 1000 ms first */ next = ast_tvnow(); next.tv_sec += 1; if (res >= 0) { pid = res; /* Order is important -- there's almost always going to be mp3... we want to prioritize the user */ for (;;) { ms = ast_tvdiff_ms(next, ast_tvnow()); if (ms <= 0) { res = timed_read(fds[0], myf.frdata, sizeof(myf.frdata), timeout); if (res > 0) { myf.f.frametype = AST_FRAME_VOICE; myf.f.subclass = AST_FORMAT_SLINEAR; myf.f.datalen = res; myf.f.samples = res / 2; myf.f.mallocd = 0; myf.f.offset = AST_FRIENDLY_OFFSET; myf.f.src = __PRETTY_FUNCTION__; myf.f.delivery.tv_sec = 0; myf.f.delivery.tv_usec = 0; myf.f.data.ptr = myf.frdata; if (ast_write(chan, &myf.f) < 0) { res = -1; break; } } else { ast_debug(1, "No more mp3\n"); res = 0; break; } next = ast_tvadd(next, ast_samp2tv(myf.f.samples, 8000)); } else { ms = ast_waitfor(chan, ms); if (ms < 0) { ast_debug(1, "Hangup detected\n"); res = -1; break; } if (ms) { f = ast_read(chan); if (!f) { ast_debug(1, "Null frame == hangup() detected\n"); res = -1; break; } if (f->frametype == AST_FRAME_DTMF) { ast_debug(1, "User pressed a key\n"); ast_frfree(f); res = 0; break; } ast_frfree(f); } close(fds[0]); close(fds[1]); if (pid > -1) kill(pid, SIGKILL); if (!res && owriteformat) ast_set_write_format(chan, owriteformat); return res;

static int mp3play	(	char *	filename,
		int	fd
	)			`[static]`

Definition at line 67 of file app_mp3.c.

References ast_close_fds_above_n(), ast_log(), ast_opt_high_priority, ast_safe_fork(), ast_set_priority(), LOCAL_MPG_123, LOG_WARNING, and MPG_123.

Referenced by mp3_exec().

00068 {
00069    int res;
00070 
00071    res = ast_safe_fork(0);
00072    if (res < 0) 
00073       ast_log(LOG_WARNING, "Fork failed\n");
00074    if (res) {
00075       return res;
00076    }
00077    if (ast_opt_high_priority)
00078       ast_set_priority(0);
00079 
00080    dup2(fd, STDOUT_FILENO);
00081    ast_close_fds_above_n(STDERR_FILENO);
00082 
00083    /* Execute mpg123, but buffer if it's a net connection */
00084    if (!strncasecmp(filename, "http://", 7)) {
00085       /* Most commonly installed in /usr/local/bin */
00086        execl(LOCAL_MPG_123, "mpg123", "-q", "-s", "-b", "1024", "-f", "8192", "--mono", "-r", "8000", filename, (char *)NULL);
00087       /* But many places has it in /usr/bin */
00088        execl(MPG_123, "mpg123", "-q", "-s", "-b", "1024","-f", "8192", "--mono", "-r", "8000", filename, (char *)NULL);
00089       /* As a last-ditch effort, try to use PATH */
00090        execlp("mpg123", "mpg123", "-q", "-s", "-b", "1024",  "-f", "8192", "--mono", "-r", "8000", filename, (char *)NULL);
00091    }
00092    else {
00093       /* Most commonly installed in /usr/local/bin */
00094        execl(MPG_123, "mpg123", "-q", "-s", "-f", "8192", "--mono", "-r", "8000", filename, (char *)NULL);
00095       /* But many places has it in /usr/bin */
00096        execl(LOCAL_MPG_123, "mpg123", "-q", "-s", "-f", "8192", "--mono", "-r", "8000", filename, (char *)NULL);
00097       /* As a last-ditch effort, try to use PATH */
00098        execlp("mpg123", "mpg123", "-q", "-s", "-f", "8192", "--mono", "-r", "8000", filename, (char *)NULL);
00099    }
00100    /* Can't use ast_log since FD's are closed */
00101    fprintf(stderr, "Execute of mpg123 failed\n");
00102    _exit(0);
00103 }

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

Definition at line 105 of file app_mp3.c.

References ast_log(), ast_poll, and LOG_NOTICE.

Referenced by mp3_exec().

00106 {
00107    int res;
00108    struct pollfd fds[1];
00109    fds[0].fd = fd;
00110    fds[0].events = POLLIN;
00111    res = ast_poll(fds, 1, timeout);
00112    if (res < 1) {
00113       ast_log(LOG_NOTICE, "Poll timed out/errored out with %d\n", res);
00114       return -1;
00115    }
00116    return read(fd, data, datalen);
00117    
00118 }

static int unload_module ( void ) [static]

Definition at line 229 of file app_mp3.c.

References ast_unregister_application().

00230 {
00231    return ast_unregister_application(app);
00232 }

Variable Documentation

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "Silly MP3 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 = "0901e4e500243c855563a2d78b0c03e4" , .load = load_module, .unload = unload_module, } [static]

Definition at line 239 of file app_mp3.c.

char* app = "MP3Player" [static]

Definition at line 65 of file app_mp3.c.

struct ast_module_info* ast_module_info = &__mod_info [static]

Definition at line 239 of file app_mp3.c.

Asterisk developer's documentation

app_mp3.c File Reference

Defines

Functions

Variables

Detailed Description

Define Documentation

Function Documentation

Variable Documentation