Merge changes from timing branch

 - Convert chan_iax2 to use the timing API
 - Convert usage of timing in the core to use the timing API instead of
   using DAHDI directly
 - Make a change to the timing API to add the set_rate() function
 - change the timing core to use a rwlock
 - merge a timing implementation, res_timing_dahdi

Basic testing was successful using res_timing_dahdi


git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@122523 65c4cc65-6c06-0410-ace0-fbb531ad65f3

1 files changed, 188 insertions, 0 deletions

diff --git a/res/res_timing_dahdi.c b/res/res_timing_dahdi.c
new file mode 100644
index 000000000..16b64b21a
--- /dev/null
+++ b/res/res_timing_dahdi.c
@@ -0,0 +1,188 @@
+/*
+ * Asterisk -- An open source telephony toolkit.
+ *
+ * Copyright (C) 2008, Digium, Inc.
+ *
+ * Russell Bryant <russell@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
+ * \author Russell Bryant <russell@digium.com>
+ *
+ * \brief DAHDI timing interface 
+ */
+
+/*** MODULEINFO
+	<depend>dahdi</depend>
+ ***/
+
+#include "asterisk.h"
+
+ASTERISK_FILE_VERSION(__FILE__, "$Revision$");
+
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <fcntl.h>
+#include <math.h>
+
+#include "asterisk/module.h"
+#include "asterisk/timing.h"
+#include "asterisk/dahdi.h"
+#include "asterisk/utils.h"
+
+static void *timing_funcs_handle;
+
+static int dahdi_timer_open(void);
+static void dahdi_timer_close(int handle);
+static int dahdi_timer_set_rate(int handle, unsigned int rate);
+static void dahdi_timer_ack(int handle, unsigned int quantity);
+static int dahdi_timer_enable_continuous(int handle);
+static int dahdi_timer_disable_continuous(int handle);
+static enum ast_timing_event dahdi_timer_get_event(int handle);
+
+static struct ast_timing_functions dahdi_timing_functions = {
+	.timer_open = dahdi_timer_open,
+	.timer_close = dahdi_timer_close,
+	.timer_set_rate = dahdi_timer_set_rate,
+	.timer_ack = dahdi_timer_ack,
+	.timer_enable_continuous = dahdi_timer_enable_continuous,
+	.timer_disable_continuous = dahdi_timer_disable_continuous,
+	.timer_get_event = dahdi_timer_get_event,
+};
+
+static int dahdi_timer_open(void)
+{
+	return open("/dev/dahdi/timer", O_RDWR);
+}
+
+static void dahdi_timer_close(int handle)
+{
+	close(handle);
+}
+
+static int dahdi_timer_set_rate(int handle, unsigned int rate)
+{
+	int samples;
+
+	/* DAHDI timers are configured using a number of samples,
+	 * based on an 8 kHz sample rate. */
+	samples = (unsigned int) roundf((8000.0 / ((float) rate)));
+
+	if (ioctl(handle, DAHDI_TIMERCONFIG, &samples)) {
+		ast_log(LOG_ERROR, "Failed to configure DAHDI timing fd for %u sample timer ticks\n",
+			samples);
+		return -1;
+	}
+
+	return 0;
+}
+
+static void dahdi_timer_ack(int handle, unsigned int quantity)
+{
+	ioctl(handle, DAHDI_TIMERACK, &quantity);
+}
+
+static int dahdi_timer_enable_continuous(int handle)
+{
+	int flags = 1;
+
+	return ioctl(handle, DAHDI_TIMERPING, &flags) ? -1 : 0;
+}
+
+static int dahdi_timer_disable_continuous(int handle)
+{
+	int flags = -1;
+
+	return ioctl(handle, DAHDI_TIMERPONG, &flags) ? -1 : 0;
+}
+
+static enum ast_timing_event dahdi_timer_get_event(int handle)
+{
+	int res;
+	int event;
+
+	res = ioctl(handle, DAHDI_GETEVENT, &event);
+
+	if (res) {
+		event = DAHDI_EVENT_TIMER_EXPIRED;
+	}
+
+	switch (event) {
+	case DAHDI_EVENT_TIMER_PING:
+		return AST_TIMING_EVENT_CONTINUOUS;
+	case DAHDI_EVENT_TIMER_EXPIRED:
+	default:
+		return AST_TIMING_EVENT_EXPIRED;	
+	}
+}
+
+static int dahdi_test_timer(void)
+{
+	int fd;
+	int x = 160;
+	
+	fd = open("/dev/dahdi/timer", O_RDWR);
+
+	if (fd < 0) {
+		return -1;
+	}
+
+	if (ioctl(fd, DAHDI_TIMERCONFIG, &x)) {
+		ast_log(LOG_ERROR, "You have DAHDI built and drivers loaded, but the DAHDI timer test failed to set DAHDI_TIMERCONFIG to %d.\n", x);
+		close(fd);
+		return -1;
+	}
+
+	if ((x = ast_wait_for_input(fd, 300)) < 0) {
+		ast_log(LOG_ERROR, "You have DAHDI built and drivers loaded, but the DAHDI timer could not be polled during the DAHDI timer test.\n");
+		close(fd);
+		return -1;
+	}
+
+	if (!x) {
+		const char dahdi_timer_error[] = {
+			"Asterisk has detected a problem with your DAHDI configuration and will shutdown for your protection.  You have options:"
+			"\n\t1. You only have to compile DAHDI support into Asterisk if you need it.  One option is to recompile without DAHDI support."
+			"\n\t2. You only have to load DAHDI drivers if you want to take advantage of DAHDI services.  One option is to unload DAHDI modules if you don't need them."
+			"\n\t3. If you need DAHDI services, you must correctly configure DAHDI."
+		};
+		ast_log(LOG_ERROR, "%s\n", dahdi_timer_error);
+		usleep(100);
+		close(fd);
+		return -1;
+	}
+
+	close(fd);
+
+	return 0;
+}
+
+static int load_module(void)
+{
+	if (dahdi_test_timer()) {
+		return AST_MODULE_LOAD_DECLINE;
+	}
+
+	return (timing_funcs_handle = ast_install_timing_functions(&dahdi_timing_functions)) ?
+		AST_MODULE_LOAD_SUCCESS : AST_MODULE_LOAD_DECLINE;
+}
+
+static int unload_module(void)
+{
+	ast_uninstall_timing_functions(timing_funcs_handle);
+
+	return 0;
+}
+
+AST_MODULE_INFO_STANDARD(ASTERISK_GPL_KEY, "DAHDI Timing Interface");