mirror of https://github.com/asterisk/asterisk
				
				
				
			
			You can not select more than 25 topics
			Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
		
		
		
		
		
			
		
			
				
					
					
						
							137 lines
						
					
					
						
							2.9 KiB
						
					
					
				
			
		
		
	
	
							137 lines
						
					
					
						
							2.9 KiB
						
					
					
				| /*
 | |
|  * Asterisk -- An open source telephony toolkit.
 | |
|  *
 | |
|  * Copyright (C) 1999 - 2005, Digium, Inc.
 | |
|  *
 | |
|  * Mark Spencer <markster@digium.com>
 | |
|  *
 | |
|  * See http://www.asterisk.org for more information about
 | |
|  * the Asterisk project. Please do not directly contact
 | |
|  * any of the maintainers of this project for assistance;
 | |
|  * the project provides a web site, mailing lists and IRC
 | |
|  * channels for your use.
 | |
|  *
 | |
|  * This program is free software, distributed under the terms of
 | |
|  * the GNU General Public License Version 2. See the LICENSE file
 | |
|  * at the top of the source tree.
 | |
|  */
 | |
| 
 | |
| /*! \file
 | |
|  *
 | |
|  * \brief Wait for Ring Application
 | |
|  *
 | |
|  * \author Mark Spencer <markster@digium.com>
 | |
|  * 
 | |
|  * \ingroup applications
 | |
|  */
 | |
| 
 | |
| #include "asterisk.h"
 | |
| 
 | |
| ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
 | |
| 
 | |
| #include <stdlib.h>
 | |
| #include <stdio.h>
 | |
| #include <string.h>
 | |
| #include <unistd.h>
 | |
| #include <sys/types.h>
 | |
| 
 | |
| #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 "asterisk/lock.h"
 | |
| 
 | |
| static char *synopsis = "Wait for Ring Application";
 | |
| 
 | |
| static char *desc = "  WaitForRing(timeout)\n"
 | |
| "Returns 0 after waiting at least timeout seconds. and\n"
 | |
| "only after the next ring has completed.  Returns 0 on\n"
 | |
| "success or -1 on hangup\n";
 | |
| 
 | |
| static char *app = "WaitForRing";
 | |
| 
 | |
| 
 | |
| static int waitforring_exec(struct ast_channel *chan, void *data)
 | |
| {
 | |
| 	struct ast_module_user *u;
 | |
| 	struct ast_frame *f;
 | |
| 	int res = 0;
 | |
| 	int ms;
 | |
| 
 | |
| 	if (!data || (sscanf(data, "%d", &ms) != 1)) {
 | |
|                 ast_log(LOG_WARNING, "WaitForRing requires an argument (minimum seconds)\n");
 | |
| 		return 0;
 | |
| 	}
 | |
| 
 | |
| 	u = ast_module_user_add(chan);
 | |
| 
 | |
| 	ms *= 1000;
 | |
| 	while(ms > 0) {
 | |
| 		ms = ast_waitfor(chan, ms);
 | |
| 		if (ms < 0) {
 | |
| 			res = ms;
 | |
| 			break;
 | |
| 		}
 | |
| 		if (ms > 0) {
 | |
| 			f = ast_read(chan);
 | |
| 			if (!f) {
 | |
| 				res = -1;
 | |
| 				break;
 | |
| 			}
 | |
| 			if ((f->frametype == AST_FRAME_CONTROL) && (f->subclass == AST_CONTROL_RING)) {
 | |
| 				if (option_verbose > 2)
 | |
| 					ast_verbose(VERBOSE_PREFIX_3 "Got a ring but still waiting for timeout\n");
 | |
| 			}
 | |
| 			ast_frfree(f);
 | |
| 		}
 | |
| 	}
 | |
| 	/* Now we're really ready for the ring */
 | |
| 	if (!res) {
 | |
| 		ms = 99999999;
 | |
| 		while(ms > 0) {
 | |
| 			ms = ast_waitfor(chan, ms);
 | |
| 			if (ms < 0) {
 | |
| 				res = ms;
 | |
| 				break;
 | |
| 			}
 | |
| 			if (ms > 0) {
 | |
| 				f = ast_read(chan);
 | |
| 				if (!f) {
 | |
| 					res = -1;
 | |
| 					break;
 | |
| 				}
 | |
| 				if ((f->frametype == AST_FRAME_CONTROL) && (f->subclass == AST_CONTROL_RING)) {
 | |
| 					if (option_verbose > 2)
 | |
| 						ast_verbose(VERBOSE_PREFIX_3 "Got a ring after the timeout\n");
 | |
| 					ast_frfree(f);
 | |
| 					break;
 | |
| 				}
 | |
| 				ast_frfree(f);
 | |
| 			}
 | |
| 		}
 | |
| 	}
 | |
| 	ast_module_user_remove(u);
 | |
| 
 | |
| 	return res;
 | |
| }
 | |
| 
 | |
| static int unload_module(void)
 | |
| {
 | |
| 	int res;
 | |
| 
 | |
| 	res = ast_unregister_application(app);
 | |
| 
 | |
| 	ast_module_user_hangup_all();
 | |
| 
 | |
| 	return res;	
 | |
| }
 | |
| 
 | |
| static int load_module(void)
 | |
| {
 | |
| 	return ast_register_application(app, waitforring_exec, synopsis, desc);
 | |
| }
 | |
| 
 | |
| AST_MODULE_INFO_STANDARD(ASTERISK_GPL_KEY, "Waits until first ring after time");
 |