Skip to content
Snippets Groups Projects
app_zapras.c 5.71 KiB
Newer Older
  • Learn to ignore specific revisions
  • Mark Spencer's avatar
    Mark Spencer committed
    /*
     * Asterisk -- A telephony toolkit for Linux.
     *
     * Execute an ISDN RAS
     * 
     * Copyright (C) 1999, Mark Spencer
     *
     * Mark Spencer <markster@linux-support.net>
     *
     * This program is free software, distributed under the terms of
     * the GNU General Public License
     */
    
    
    Mark Spencer's avatar
    Mark Spencer committed
    #include <asterisk/lock.h>
    
    Mark Spencer's avatar
    Mark Spencer committed
    #include <asterisk/file.h>
    #include <asterisk/logger.h>
    #include <asterisk/channel.h>
    #include <asterisk/pbx.h>
    #include <asterisk/module.h>
    #include <asterisk/options.h>
    #include <sys/ioctl.h>
    #include <sys/wait.h>
    
    #ifdef __linux__
    
    Mark Spencer's avatar
    Mark Spencer committed
    #include <sys/signal.h>
    
    #else
    #include <signal.h>
    #endif /* __linux__ */
    
    Mark Spencer's avatar
    Mark Spencer committed
    
    #include <stdlib.h>
    #include <unistd.h>
    #include <string.h>
    #include <stdlib.h>
    
    Mark Spencer's avatar
    Mark Spencer committed
    #include <errno.h>
    #include <stdio.h>
    #include <fcntl.h>
    
    Mark Spencer's avatar
    Mark Spencer committed
    
    /* Need some zaptel help here */
    
    #ifdef __linux__
    
    Mark Spencer's avatar
    Mark Spencer committed
    #include <linux/zaptel.h>
    
    #else
    #include <zaptel.h>
    #endif /* __linux__ */
    
    Mark Spencer's avatar
    Mark Spencer committed
    
    static char *tdesc = "Zap RAS Application";
    
    static char *app = "ZapRAS";
    
    static char *synopsis = "Executes Zaptel ISDN RAS application";
    
    static char *descrip =
    "  ZapRAS(args): Executes a RAS server using pppd on the given channel.\n"
    "The channel must be a clear channel (i.e. PRI source) and a Zaptel\n"
    
    James Golovich's avatar
    James Golovich committed
    "channel to be able to use this function (No modem emulation is included).\n"
    
    Mark Spencer's avatar
    Mark Spencer committed
    "Your pppd must be patched to be zaptel aware. Arguments should be\n"
    "separated by | characters.  Always returns -1.\n";
    
    STANDARD_LOCAL_USER;
    
    LOCAL_USER_DECL;
    
    #define PPP_MAX_ARGS	32
    #define PPP_EXEC	"/usr/sbin/pppd"
    
    static pid_t spawn_ras(struct ast_channel *chan, char *args)
    {
    	pid_t pid;
    	int x;	
    	char *c;
    
    	char *argv[PPP_MAX_ARGS];
    	int argc = 0;
    
    Mark Spencer's avatar
    Mark Spencer committed
    	char *stringp=NULL;
    
    Mark Spencer's avatar
    Mark Spencer committed
    
    	/* Start by forking */
    	pid = fork();
    	if (pid)
    		return pid;
    
    	/* Execute RAS on File handles */
    	dup2(chan->fds[0], STDIN_FILENO);
    
    	/* Close other file descriptors */
    	for (x=STDERR_FILENO + 1;x<1024;x++) 
    		close(x);
    
    	/* Restore original signal handlers */
    	for (x=0;x<NSIG;x++)
    		signal(x, SIG_DFL);
    
    	/* Reset all arguments */
    	memset(argv, 0, sizeof(argv));
    
    	/* First argument is executable, followed by standard
    	   arguments for zaptel PPP */
    	argv[argc++] = PPP_EXEC;
    	argv[argc++] = "nodetach";
    
    	/* And all the other arguments */
    
    Mark Spencer's avatar
    Mark Spencer committed
    	stringp=args;
    	c = strsep(&stringp, "|");
    
    Mark Spencer's avatar
    Mark Spencer committed
    	while(c && strlen(c) && (argc < (PPP_MAX_ARGS - 4))) {
    		argv[argc++] = c;
    
    Mark Spencer's avatar
    Mark Spencer committed
    		c = strsep(&stringp, "|");
    
    Mark Spencer's avatar
    Mark Spencer committed
    	}
    
    	argv[argc++] = "plugin";
    	argv[argc++] = "zaptel.so";
    	argv[argc++] = "stdin";
    
    #if 0
    	for (x=0;x<argc;x++) {
    		fprintf(stderr, "Arg %d: %s\n", x, argv[x]);
    	}
    #endif
    
    	/* Finally launch PPP */
    	execv(PPP_EXEC, argv);
    	fprintf(stderr, "Failed to exec PPPD!\n");
    	exit(1);
    }
    
    static void run_ras(struct ast_channel *chan, char *args)
    {
    	pid_t pid;
    	int status;
    	int res;
    	int signalled = 0;
    	struct zt_bufferinfo bi;
    	int x;
    
    	pid = spawn_ras(chan, args);
    	if (pid < 0) {
    		ast_log(LOG_WARNING, "Failed to spawn RAS\n");
    	} else {
    		for (;;) {
    			res = wait4(pid, &status, WNOHANG, NULL);
    			if (!res) {
    				/* Check for hangup */
    
    Mark Spencer's avatar
    Mark Spencer committed
    				if (chan->_softhangup && !signalled) {
    
    Mark Spencer's avatar
    Mark Spencer committed
    					ast_log(LOG_DEBUG, "Channel '%s' hungup.  Signalling RAS at %d to die...\n", chan->name, pid);
    
    Mark Spencer's avatar
    Mark Spencer committed
    					kill(pid, SIGTERM);
    					signalled=1;
    				}
    				/* Try again */
    				sleep(1);
    				continue;
    			}
    			if (res < 0) {
    				ast_log(LOG_WARNING, "wait4 returned %d: %s\n", res, strerror(errno));
    			}
    			if (option_verbose > 2) {
    				if (WIFEXITED(status)) {
    					ast_verbose(VERBOSE_PREFIX_3 "RAS on %s terminated with status %d\n", chan->name, WEXITSTATUS(status));
    				} else if (WIFSIGNALED(status)) {
    					ast_verbose(VERBOSE_PREFIX_3 "RAS on %s terminated with signal %d\n", 
    						 chan->name, WTERMSIG(status));
    				} else {
    					ast_verbose(VERBOSE_PREFIX_3 "RAS on %s terminated weirdly.\n", chan->name);
    				}
    			}
    			/* Throw back into audio mode */
    
    Mark Spencer's avatar
    Mark Spencer committed
    			x = 1;
    
    Mark Spencer's avatar
    Mark Spencer committed
    			ioctl(chan->fds[0], ZT_AUDIOMODE, &x);
    
    			/* Double check buffering too */
    			res = ioctl(chan->fds[0], ZT_GET_BUFINFO, &bi);
    			if (!res) {
    				/* XXX This is ZAP_BLOCKSIZE XXX */
    				bi.bufsize = 204;
    				bi.txbufpolicy = ZT_POLICY_IMMEDIATE;
    				bi.rxbufpolicy = ZT_POLICY_IMMEDIATE;
    				bi.numbufs = 4;
    				res = ioctl(chan->fds[0], ZT_SET_BUFINFO, &bi);
    				if (res < 0) {
    					ast_log(LOG_WARNING, "Unable to set buffer policy on channel %s\n", chan->name);
    				}
    			} else
    				ast_log(LOG_WARNING, "Unable to check buffer policy on channel %s\n", chan->name);
    			break;
    		}
    	}
    }
    
    static int zapras_exec(struct ast_channel *chan, void *data)
    {
    	int res=-1;
    	char args[256];
    	struct localuser *u;
    	ZT_PARAMS ztp;
    
    	if (!data) 
    		data = "";
    	LOCAL_USER_ADD(u);
    	strncpy(args, data, sizeof(args) - 1);
    	/* Answer the channel if it's not up */
    
    Mark Spencer's avatar
    Mark Spencer committed
    	if (chan->_state != AST_STATE_UP)
    
    Mark Spencer's avatar
    Mark Spencer committed
    		ast_answer(chan);
    	if (strcasecmp(chan->type, "Zap")) {
    		/* If it's not a zap channel, we're done.  Wait a couple of
    		   seconds and then hangup... */
    		if (option_verbose > 1)
    			ast_verbose(VERBOSE_PREFIX_2 "Channel %s is not a Zap channel\n", chan->name);
    		sleep(2);
    	} else {
    		memset(&ztp, 0, sizeof(ztp));
    		if (ioctl(chan->fds[0], ZT_GET_PARAMS, &ztp)) {
    			ast_log(LOG_WARNING, "Unable to get zaptel parameters\n");
    		} else if (ztp.sigtype != ZT_SIG_CLEAR) {
    			if (option_verbose > 1)
    				ast_verbose(VERBOSE_PREFIX_2 "Channel %s is not a clear channel\n", chan->name);
    		} else {
    			/* Everything should be okay.  Run PPP. */
    			if (option_verbose > 2)
    				ast_verbose(VERBOSE_PREFIX_3 "Starting RAS on %s\n", chan->name);
    			/* Execute RAS */
    			run_ras(chan, args);
    		}
    	}
    	LOCAL_USER_REMOVE(u);
    	return res;
    }
    
    int unload_module(void)
    {
    	STANDARD_HANGUP_LOCALUSERS;
    	return ast_unregister_application(app);
    }
    
    int load_module(void)
    {
    	return ast_register_application(app, zapras_exec, synopsis, descrip);
    }
    
    char *description(void)
    {
    	return tdesc;
    }
    
    int usecount(void)
    {
    	int res;
    	STANDARD_USECOUNT(res);
    	return res;
    }
    
    char *key()
    {
    	return ASTERISK_GPL_KEY;
    }