[asterisk-commits] russell: branch russell/timing_module_priority r176028 - in /team/russell/tim...

SVN commits to the Asterisk project asterisk-commits at lists.digium.com
Mon Feb 16 09:30:52 CST 2009


Author: russell
Date: Mon Feb 16 09:30:52 2009
New Revision: 176028

URL: http://svn.digium.com/svn-view/asterisk?view=rev&rev=176028
Log:
Add a bunch of updates to the timing API.

1) Add module use count handling so that timing modules can be unloaded.

2) Allow multiple timing modules to be loaded, and use the one with the highest
   priority value.

3) Report which timing module is being use in the "timing test" CLI command,
   at the request of Tzafrir on the -dev list.

Modified:
    team/russell/timing_module_priority/include/asterisk/timing.h
    team/russell/timing_module_priority/main/Makefile
    team/russell/timing_module_priority/main/channel.c
    team/russell/timing_module_priority/main/timing.c
    team/russell/timing_module_priority/res/res_timing_dahdi.c
    team/russell/timing_module_priority/res/res_timing_pthread.c
    team/russell/timing_module_priority/res/res_timing_timerfd.c

Modified: team/russell/timing_module_priority/include/asterisk/timing.h
URL: http://svn.digium.com/svn-view/asterisk/team/russell/timing_module_priority/include/asterisk/timing.h?view=diff&rev=176028&r1=176027&r2=176028
==============================================================================
--- team/russell/timing_module_priority/include/asterisk/timing.h (original)
+++ team/russell/timing_module_priority/include/asterisk/timing.h Mon Feb 16 09:30:52 2009
@@ -1,9 +1,10 @@
 /*
  * Asterisk -- An open source telephony toolkit.
  *
- * Copyright (C) 2008, Digium, Inc.
+ * Copyright (C) 2008 - 2009, Digium, Inc.
  *
  * Kevin P. Fleming <kpfleming at digium.com>
+ * Russell Bryant <russell at digium.com>
  *
  * See http://www.asterisk.org for more information about
  * the Asterisk project. Please do not directly contact
@@ -20,6 +21,7 @@
   \file timing.h
   \brief Timing source management
   \author Kevin P. Fleming <kpfleming at digium.com>
+  \author Russell Bryant <russell at digium.com>
 
   Portions of Asterisk require a timing source, a periodic trigger
   for media handling activities. The functions in this file allow
@@ -55,7 +57,7 @@
 extern "C" {
 #endif
 
-enum ast_timing_event {
+enum ast_timer_event {
 	AST_TIMING_EVENT_EXPIRED = 1,
 	AST_TIMING_EVENT_CONTINUOUS = 2,
 };
@@ -67,27 +69,33 @@
  * So, the behavior of these calls should match the documentation of the
  * public API calls.
  */
-struct ast_timing_functions {
+struct ast_timing_interface {
+	const char *name;
+	/*! This handles the case where multiple timing modules are loaded.
+	 *  The highest priority timing interface available will be used. */
+	unsigned int priority;
 	int (*timer_open)(void);
 	void (*timer_close)(int handle);
 	int (*timer_set_rate)(int handle, unsigned int rate);
 	void (*timer_ack)(int handle, unsigned int quantity);
 	int (*timer_enable_continuous)(int handle);
 	int (*timer_disable_continuous)(int handle);
-	enum ast_timing_event (*timer_get_event)(int handle);
+	enum ast_timer_event (*timer_get_event)(int handle);
 	unsigned int (*timer_get_max_rate)(int handle);
 };
 
 /*!
  * \brief Install a set of timing functions.
  *
- * \param funcs An instance of the \c ast_timing_functions structure with pointers
+ * \param funcs An instance of the \c ast_timer_functions structure with pointers
  *        to the functions provided by the timing implementation.
  *
  * \retval NULL failure 
  * \retval non-Null handle to be passed to ast_uninstall_timing_functions() on success
  */
-void *ast_install_timing_functions(struct ast_timing_functions *funcs);
+#define ast_register_timing_interface(i) _ast_register_timing_interface(i, ast_module_info->self)
+void *_ast_register_timing_interface(struct ast_timing_interface *funcs,
+		struct ast_module *mod);
 
 /*!
  * \brief Uninstall a previously-installed set of timing functions.
@@ -95,9 +103,10 @@
  * \param handle The handle returned from a prior successful call to
  *        ast_install_timing_functions().
  *
- * \return nothing
- */
-void ast_uninstall_timing_functions(void *handle);
+ * \retval 0 success
+ * \retval non-zero failure
+ */
+int ast_unregister_timing_interface(void *handle);
 
 /*!
  * \brief Open a timing fd
@@ -177,7 +186,7 @@
  *
  * \return which event triggered the timing fd
  */
-enum ast_timing_event ast_timer_get_event(int handle);
+enum ast_timer_event ast_timer_get_event(int handle);
 
 /*!
  * \brief Get maximum rate supported for a timing handle

Modified: team/russell/timing_module_priority/main/Makefile
URL: http://svn.digium.com/svn-view/asterisk/team/russell/timing_module_priority/main/Makefile?view=diff&rev=176028&r1=176027&r2=176028
==============================================================================
--- team/russell/timing_module_priority/main/Makefile (original)
+++ team/russell/timing_module_priority/main/Makefile Mon Feb 16 09:30:52 2009
@@ -18,7 +18,7 @@
 include $(ASTTOPDIR)/Makefile.moddir_rules
 
 OBJS= tcptls.o io.o sched.o logger.o frame.o loader.o config.o channel.o \
-	translate.o file.o pbx.o cli.o md5.o term.o \
+	translate.o file.o pbx.o cli.o md5.o term.o heap.o \
 	ulaw.o alaw.o callerid.o fskmodem.o image.o app.o \
 	cdr.o tdd.o acl.o rtp.o udptl.o manager.o asterisk.o \
 	dsp.o chanvars.o indications.o autoservice.o db.o privacy.o \

Modified: team/russell/timing_module_priority/main/channel.c
URL: http://svn.digium.com/svn-view/asterisk/team/russell/timing_module_priority/main/channel.c?view=diff&rev=176028&r1=176027&r2=176028
==============================================================================
--- team/russell/timing_module_priority/main/channel.c (original)
+++ team/russell/timing_module_priority/main/channel.c Mon Feb 16 09:30:52 2009
@@ -2495,7 +2495,7 @@
 	}
 
 	if (chan->timingfd > -1 && chan->fdno == AST_TIMING_FD) {
-		enum ast_timing_event res;
+		enum ast_timer_event res;
 
 		ast_clear_flag(chan, AST_FLAG_EXCEPTION);
 

Modified: team/russell/timing_module_priority/main/timing.c
URL: http://svn.digium.com/svn-view/asterisk/team/russell/timing_module_priority/main/timing.c?view=diff&rev=176028&r1=176027&r2=176028
==============================================================================
--- team/russell/timing_module_priority/main/timing.c (original)
+++ team/russell/timing_module_priority/main/timing.c Mon Feb 16 09:30:52 2009
@@ -1,9 +1,10 @@
 /*
  * Asterisk -- An open source telephony toolkit.
  *
- * Copyright (C) 2008, Digium, Inc.
+ * Copyright (C) 2008 - 2009, Digium, Inc.
  *
  * Kevin P. Fleming <kpfleming at digium.com>
+ * Russell Bryant <russell at digium.com>
  *
  * See http://www.asterisk.org for more information about
  * the Asterisk project. Please do not directly contact
@@ -21,6 +22,7 @@
  * \brief Timing source management
  *
  * \author Kevin P. Fleming <kpfleming at digium.com>
+ * \author Russell Bryant <russell at digium.com>
  */
 
 #include "asterisk.h"
@@ -34,13 +36,37 @@
 #include "asterisk/cli.h"
 #include "asterisk/utils.h"
 #include "asterisk/time.h"
-
-AST_RWLOCK_DEFINE_STATIC(lock);
-
-static struct ast_timing_functions timer_funcs;
-
-void *ast_install_timing_functions(struct ast_timing_functions *funcs)
-{
+#include "asterisk/heap.h"
+#include "asterisk/module.h"
+
+struct timing_holder {
+	/*! Do _not_ move this from the beginning of the struct. */
+	ssize_t __heap_index;
+	struct ast_module *mod;
+	struct ast_timing_interface *iface;
+};
+
+static struct ast_heap *timing_interfaces;
+
+static int timing_holder_cmp(void *_h1, void *_h2)
+{
+	struct timing_holder *h1 = _h1;
+	struct timing_holder *h2 = _h2;
+
+	if (h1->iface->priority > h2->iface->priority) {
+		return 1;
+	} else if (h1->iface->priority == h2->iface->priority) {
+		return 0;
+	} else {
+		return -1;
+	}
+}
+
+void *_ast_register_timing_interface(struct ast_timing_interface *funcs, 
+		struct ast_module *mod)
+{
+	struct timing_holder *h;
+
 	if (!funcs->timer_open ||
 	    !funcs->timer_close ||
 		!funcs->timer_set_rate ||
@@ -52,162 +78,158 @@
 		return NULL;
 	}
 
-	ast_rwlock_wrlock(&lock);
-
-	if (timer_funcs.timer_open) {
-		ast_rwlock_unlock(&lock);
-		ast_log(LOG_NOTICE, "Multiple timing modules are loaded.  You should only load one.\n");
+	if (!(h = ast_calloc(1, sizeof(*h)))) {
 		return NULL;
 	}
-	
-	timer_funcs = *funcs;
-
-	ast_rwlock_unlock(&lock);
-
-	return &timer_funcs;
-}
-
-void ast_uninstall_timing_functions(void *handle)
-{
-	ast_rwlock_wrlock(&lock);
-
-	if (handle != &timer_funcs) {
-		ast_rwlock_unlock(&lock);
-		return;
-	}
-
-	memset(&timer_funcs, 0, sizeof(timer_funcs));
-
-	ast_rwlock_unlock(&lock);
+
+	h->iface = funcs;
+	h->mod = mod;
+
+	ast_heap_wrlock(timing_interfaces);
+	ast_heap_push(timing_interfaces, h);
+	ast_heap_unlock(timing_interfaces);
+
+	return h;
+}
+
+int ast_unregister_timing_interface(void *handle)
+{
+	struct timing_holder *h = handle;
+	int res = -1;
+
+	ast_heap_wrlock(timing_interfaces);
+	h = ast_heap_remove(timing_interfaces, h);
+	ast_heap_unlock(timing_interfaces);
+
+	if (h) {
+		ast_free(h);
+		h = NULL;
+		res = 0;
+	}
+
+	return res;
 }
 
 int ast_timer_open(void)
 {
-	int timer;
-
-	ast_rwlock_rdlock(&lock);
-
-	if (!timer_funcs.timer_open) {
-		ast_rwlock_unlock(&lock);
-		return -1;
-	}
-
-	timer = timer_funcs.timer_open();
-
-	ast_rwlock_unlock(&lock);
-
-	return timer;
+	int fd = -1;
+	struct timing_holder *h;
+
+	ast_heap_rdlock(timing_interfaces);
+
+	if ((h = ast_heap_peek(timing_interfaces, 1))) {
+		fd = h->iface->timer_open();
+		ast_module_ref(h->mod);
+	}
+
+	ast_heap_unlock(timing_interfaces);
+
+	return fd;
 }
 
 void ast_timer_close(int timer)
 {
-	ast_rwlock_rdlock(&lock);
-
-	if (!timer_funcs.timer_close) {
-		ast_rwlock_unlock(&lock);
-		return;
-	}
-
-	timer_funcs.timer_close(timer);
-
-	ast_rwlock_unlock(&lock);
+	struct timing_holder *h;
+
+	ast_heap_rdlock(timing_interfaces);
+
+	if ((h = ast_heap_peek(timing_interfaces, 1))) {
+		h->iface->timer_close(timer);
+		ast_module_unref(h->mod);
+	}
+
+	ast_heap_unlock(timing_interfaces);
 }
 
 int ast_timer_set_rate(int handle, unsigned int rate)
 {
-	int res;
-
-	ast_rwlock_rdlock(&lock);
-
-	if (!timer_funcs.timer_set_rate) {
-		ast_rwlock_unlock(&lock);
-		return -1;
-	}
-
-	res = timer_funcs.timer_set_rate(handle, rate);
-
-	ast_rwlock_unlock(&lock);
+	struct timing_holder *h;
+	int res = -1;
+
+	ast_heap_rdlock(timing_interfaces);
+
+	if ((h = ast_heap_peek(timing_interfaces, 1))) {
+		res = h->iface->timer_set_rate(handle, rate);
+	}
+
+	ast_heap_unlock(timing_interfaces);
 
 	return res;
 }
 
 void ast_timer_ack(int handle, unsigned int quantity)
 {
-	ast_rwlock_rdlock(&lock);
-
-	if (!timer_funcs.timer_ack) {
-		ast_rwlock_unlock(&lock);
-		return;
-	}
-
-	timer_funcs.timer_ack(handle, quantity);
-
-	ast_rwlock_unlock(&lock);
+	struct timing_holder *h;
+
+	ast_heap_rdlock(timing_interfaces);
+
+	if ((h = ast_heap_peek(timing_interfaces, 1))) {
+		h->iface->timer_ack(handle, quantity);
+	}
+
+	ast_heap_unlock(timing_interfaces);
 }
 
 int ast_timer_enable_continuous(int handle)
 {
-	int result;
-
-	ast_rwlock_rdlock(&lock);
-
-	if (!timer_funcs.timer_enable_continuous) {
-		ast_rwlock_unlock(&lock);
-		return -1;
-	}
-
-	result = timer_funcs.timer_enable_continuous(handle);
-
-	ast_rwlock_unlock(&lock);
-
-	return result;
+	struct timing_holder *h;
+	int res = -1;
+
+	ast_heap_rdlock(timing_interfaces);
+
+	if ((h = ast_heap_peek(timing_interfaces, 1))) {
+		res = h->iface->timer_enable_continuous(handle);
+	}
+
+	ast_heap_unlock(timing_interfaces);
+
+	return res;
 }
 
 int ast_timer_disable_continuous(int handle)
 {
-	int result;
-
-	ast_rwlock_rdlock(&lock);
-
-	if (!timer_funcs.timer_disable_continuous) {
-		ast_rwlock_unlock(&lock);
-		return -1;
-	}
-
-	result = timer_funcs.timer_disable_continuous(handle);
-
-	ast_rwlock_unlock(&lock);
-
-	return result;
-}
-
-enum ast_timing_event ast_timer_get_event(int handle)
-{
-	enum ast_timing_event result;
-
-	ast_rwlock_rdlock(&lock);
-
-	if (!timer_funcs.timer_get_event) {
-		ast_rwlock_unlock(&lock);
-		return -1;
-	}
-
-	result = timer_funcs.timer_get_event(handle);
-
-	ast_rwlock_unlock(&lock);
-
-	return result;
+	struct timing_holder *h;
+	int res = -1;
+
+	ast_heap_rdlock(timing_interfaces);
+
+	if ((h = ast_heap_peek(timing_interfaces, 1))) {
+		res = h->iface->timer_disable_continuous(handle);
+	}
+
+	ast_heap_unlock(timing_interfaces);
+
+	return res;
+}
+
+enum ast_timer_event ast_timer_get_event(int handle)
+{
+	struct timing_holder *h;
+	enum ast_timer_event res = -1;
+
+	ast_heap_rdlock(timing_interfaces);
+
+	if ((h = ast_heap_peek(timing_interfaces, 1))) {
+		res = h->iface->timer_get_event(handle);
+	}
+
+	ast_heap_unlock(timing_interfaces);
+
+	return res;
 }
 
 unsigned int ast_timer_get_max_rate(int handle)
 {
-	unsigned int res;
-
-	ast_rwlock_rdlock(&lock);
-
-	res = timer_funcs.timer_get_max_rate(handle);
-
-	ast_rwlock_unlock(&lock);
+	struct timing_holder *h;
+	unsigned int res = 0;
+
+	ast_heap_rdlock(timing_interfaces);
+
+	if ((h = ast_heap_peek(timing_interfaces, 1))) {
+		res = h->iface->timer_get_max_rate(handle);
+	}
+
+	ast_heap_unlock(timing_interfaces);
 
 	return res;
 }
@@ -217,6 +239,7 @@
 	int fd, count = 0;
 	struct timeval start, end;
 	unsigned int test_rate = 50;
+	struct timing_holder *h;
 
 	switch (cmd) {
 	case CLI_INIT:
@@ -242,12 +265,19 @@
 		}
 	}
 
-	ast_cli(a->fd, "Attempting to test a timer with %u ticks per second ...\n", test_rate);
+	ast_cli(a->fd, "Attempting to test a timer with %u ticks per second.\n", test_rate);
 
 	if ((fd = ast_timer_open()) == -1) {
 		ast_cli(a->fd, "Failed to open timing fd\n");
 		return CLI_FAILURE;
 	}
+
+	ast_heap_rdlock(timing_interfaces);
+	if ((h = ast_heap_peek(timing_interfaces, 1))) {
+		ast_cli(a->fd, "Using the '%s' timing module for this test.\n", h->iface->name);
+		h = NULL;
+	}
+	ast_heap_unlock(timing_interfaces);
 
 	start = ast_tvnow();
 
@@ -286,5 +316,9 @@
 
 int ast_timing_init(void)
 {
+	if (!(timing_interfaces = ast_heap_create(2, timing_holder_cmp, 0))) {
+		return -1;
+	}
+
 	return ast_cli_register_multiple(cli_timing, ARRAY_LEN(cli_timing));
 }

Modified: team/russell/timing_module_priority/res/res_timing_dahdi.c
URL: http://svn.digium.com/svn-view/asterisk/team/russell/timing_module_priority/res/res_timing_dahdi.c?view=diff&rev=176028&r1=176027&r2=176028
==============================================================================
--- team/russell/timing_module_priority/res/res_timing_dahdi.c (original)
+++ team/russell/timing_module_priority/res/res_timing_dahdi.c Mon Feb 16 09:30:52 2009
@@ -25,8 +25,6 @@
 
 /*** MODULEINFO
 	<depend>dahdi</depend>
-	<conflict>res_timing_timerfd</conflict>
-	<conflict>res_timing_pthread</conflict>
  ***/
 
 #include "asterisk.h"
@@ -52,10 +50,12 @@
 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 enum ast_timer_event dahdi_timer_get_event(int handle);
 static unsigned int dahdi_timer_get_max_rate(int handle);
 
-static struct ast_timing_functions dahdi_timing_functions = {
+static struct ast_timing_interface dahdi_timing = {
+	.name = "DAHDI",
+	.priority = 100,
 	.timer_open = dahdi_timer_open,
 	.timer_close = dahdi_timer_close,
 	.timer_set_rate = dahdi_timer_set_rate,
@@ -112,7 +112,7 @@
 	return ioctl(handle, DAHDI_TIMERPONG, &flags) ? -1 : 0;
 }
 
-static enum ast_timing_event dahdi_timer_get_event(int handle)
+static enum ast_timer_event dahdi_timer_get_event(int handle)
 {
 	int res;
 	int event;
@@ -184,17 +184,13 @@
 		return AST_MODULE_LOAD_DECLINE;
 	}
 
-	return (timing_funcs_handle = ast_install_timing_functions(&dahdi_timing_functions)) ?
+	return (timing_funcs_handle = ast_register_timing_interface(&dahdi_timing)) ?
 		AST_MODULE_LOAD_SUCCESS : AST_MODULE_LOAD_DECLINE;
 }
 
 static int unload_module(void)
 {
-	/* ast_uninstall_timing_functions(timing_funcs_handle); */
-
-	/* This module can not currently be unloaded.  No use count handling is being done. */
-
-	return -1;
+	return ast_unregister_timing_interface(timing_funcs_handle);
 }
 
 AST_MODULE_INFO_STANDARD(ASTERISK_GPL_KEY, "DAHDI Timing Interface");

Modified: team/russell/timing_module_priority/res/res_timing_pthread.c
URL: http://svn.digium.com/svn-view/asterisk/team/russell/timing_module_priority/res/res_timing_pthread.c?view=diff&rev=176028&r1=176027&r2=176028
==============================================================================
--- team/russell/timing_module_priority/res/res_timing_pthread.c (original)
+++ team/russell/timing_module_priority/res/res_timing_pthread.c Mon Feb 16 09:30:52 2009
@@ -23,11 +23,6 @@
  * \brief pthread timing interface 
  */
 
-/*** MODULEINFO
-	<conflict>res_timing_timerfd</conflict>
-	<conflict>res_timing_dahdi</conflict>
- ***/
-
 #include "asterisk.h"
 
 ASTERISK_FILE_VERSION(__FILE__, "$Revision$");
@@ -50,10 +45,12 @@
 static void pthread_timer_ack(int handle, unsigned int quantity);
 static int pthread_timer_enable_continuous(int handle);
 static int pthread_timer_disable_continuous(int handle);
-static enum ast_timing_event pthread_timer_get_event(int handle);
+static enum ast_timer_event pthread_timer_get_event(int handle);
 static unsigned int pthread_timer_get_max_rate(int handle);
 
-static struct ast_timing_functions pthread_timing_functions = {
+static struct ast_timing_interface pthread_timing = {
+	.name = "pthread",
+	.priority = 0, /* use this as a last resort */
 	.timer_open = pthread_timer_open,
 	.timer_close = pthread_timer_close,
 	.timer_set_rate = pthread_timer_set_rate,
@@ -255,10 +252,10 @@
 	return 0;
 }
 
-static enum ast_timing_event pthread_timer_get_event(int handle)
-{
-	struct pthread_timer *timer;
-	enum ast_timing_event res = AST_TIMING_EVENT_EXPIRED;
+static enum ast_timer_event pthread_timer_get_event(int handle)
+{
+	struct pthread_timer *timer;
+	enum ast_timer_event res = AST_TIMING_EVENT_EXPIRED;
 
 	if (!(timer = find_timer(handle, 0))) {
 		return res;
@@ -491,22 +488,26 @@
 		return AST_MODULE_LOAD_DECLINE;
 	}
 
-	return (timing_funcs_handle = ast_install_timing_functions(&pthread_timing_functions)) ?
+	return (timing_funcs_handle = ast_register_timing_interface(&pthread_timing)) ?
 		AST_MODULE_LOAD_SUCCESS : AST_MODULE_LOAD_DECLINE;
 }
 
 static int unload_module(void)
 {
-#if 0
-	/* XXX code to stop the timing thread ... */
-
-	ast_uninstall_timing_functions(timing_funcs_handle);
-	ao2_ref(pthread_timers, -1);
-#endif
-
-	/* This module can not currently be unloaded.  No use count handling is being done. */
-
-	return -1;
+	int res;
+
+	ast_mutex_lock(&timing_thread.lock);
+	timing_thread.stop = 1;
+	ast_cond_signal(&timing_thread.cond);
+	ast_mutex_unlock(&timing_thread.lock);
+	pthread_join(timing_thread.thread, NULL);
+
+	if (!(res = ast_unregister_timing_interface(timing_funcs_handle))) {
+		ao2_ref(pthread_timers, -1);
+		pthread_timers = NULL;
+	}
+
+	return res;
 }
 
 AST_MODULE_INFO_STANDARD(ASTERISK_GPL_KEY, "pthread Timing Interface");

Modified: team/russell/timing_module_priority/res/res_timing_timerfd.c
URL: http://svn.digium.com/svn-view/asterisk/team/russell/timing_module_priority/res/res_timing_timerfd.c?view=diff&rev=176028&r1=176027&r2=176028
==============================================================================
--- team/russell/timing_module_priority/res/res_timing_timerfd.c (original)
+++ team/russell/timing_module_priority/res/res_timing_timerfd.c Mon Feb 16 09:30:52 2009
@@ -48,10 +48,12 @@
 static void timerfd_timer_ack(int handle, unsigned int quantity);
 static int timerfd_timer_enable_continuous(int handle);
 static int timerfd_timer_disable_continuous(int handle);
-static enum ast_timing_event timerfd_timer_get_event(int handle);
+static enum ast_timer_event timerfd_timer_get_event(int handle);
 static unsigned int timerfd_timer_get_max_rate(int handle);
 
-static struct ast_timing_functions timerfd_timing_functions = {
+static struct ast_timing_interface timerfd_timing = {
+	.name = "timerfd",
+	.priority = 200,
 	.timer_open = timerfd_timer_open,
 	.timer_close = timerfd_timer_close,
 	.timer_set_rate = timerfd_timer_set_rate,
@@ -226,9 +228,9 @@
 	return res;
 }
 
-static enum ast_timing_event timerfd_timer_get_event(int handle)
-{
-	enum ast_timing_event res;
+static enum ast_timer_event timerfd_timer_get_event(int handle)
+{
+	enum ast_timer_event res;
 	struct timerfd_timer *our_timer, find_helper = {
 		.handle = handle,
 	};
@@ -259,7 +261,7 @@
 		return AST_MODULE_LOAD_DECLINE;
 	}
 
-	if (!(timing_funcs_handle = ast_install_timing_functions(&timerfd_timing_functions))) {
+	if (!(timing_funcs_handle = ast_register_timing_interface(&timerfd_timing))) {
 		ao2_ref(timerfd_timers, -1);
 		return AST_MODULE_LOAD_DECLINE;
 	}
@@ -269,11 +271,14 @@
 
 static int unload_module(void)
 {
-	/* ast_uninstall_timing_functions(timing_funcs_handle); */
-
-	/* This module can not currently be unloaded.  No use count handling is being done. */
-
-	return -1;
+	int res;
+
+	if (!(res = ast_unregister_timing_interface(timing_funcs_handle))) {
+		ao2_ref(timerfd_timers, -1);
+		timerfd_timers = NULL;
+	}
+
+	return res;
 }
 
 AST_MODULE_INFO_STANDARD(ASTERISK_GPL_KEY, "Timerfd Timing Interface");




More information about the asterisk-commits mailing list