summaryrefslogtreecommitdiff
path: root/main/timing.c
diff options
context:
space:
mode:
authorJoshua Colp <jcolp@digium.com>2014-02-07 20:01:45 +0000
committerJoshua Colp <jcolp@digium.com>2014-02-07 20:01:45 +0000
commite8e2f91bbac77ca50dddc4a496512475990a8764 (patch)
treefdbb590820a386771e01916e9dbd7809bd187232 /main/timing.c
parent5fd63e2d0beeae4e118a7567716b586899166090 (diff)
timing: Improve performance for most timing implementations.
This change allows timing implementation data to be stored directly on the timer itself thus removing the requirement for many implementations to do a container lookup for the same information. This means that API calls into timing implementations can directly access the information they need instead of having to find it. Review: https://reviewboard.asterisk.org/r/3175/ git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@407749 65c4cc65-6c06-0410-ace0-fbb531ad65f3
Diffstat (limited to 'main/timing.c')
-rw-r--r--main/timing.c56
1 files changed, 16 insertions, 40 deletions
diff --git a/main/timing.c b/main/timing.c
index 84bff081b..5318ded06 100644
--- a/main/timing.c
+++ b/main/timing.c
@@ -54,7 +54,7 @@ struct timing_holder {
static struct ast_heap *timing_interfaces;
struct ast_timer {
- int fd;
+ void *data;
struct timing_holder *holder;
};
@@ -84,7 +84,8 @@ void *_ast_register_timing_interface(struct ast_timing_interface *funcs,
!funcs->timer_get_event ||
!funcs->timer_get_max_rate ||
!funcs->timer_enable_continuous ||
- !funcs->timer_disable_continuous) {
+ !funcs->timer_disable_continuous ||
+ !funcs->timer_fd) {
return NULL;
}
@@ -122,22 +123,22 @@ int ast_unregister_timing_interface(void *handle)
struct ast_timer *ast_timer_open(void)
{
- int fd = -1;
+ void *data = NULL;
struct timing_holder *h;
struct ast_timer *t = NULL;
ast_heap_rdlock(timing_interfaces);
if ((h = ast_heap_peek(timing_interfaces, 1))) {
- fd = h->iface->timer_open();
+ data = h->iface->timer_open();
ast_module_ref(h->mod);
}
- if (fd != -1) {
+ if (data) {
if (!(t = ast_calloc(1, sizeof(*t)))) {
- h->iface->timer_close(fd);
+ h->iface->timer_close(data);
} else {
- t->fd = fd;
+ t->data = data;
t->holder = h;
}
}
@@ -149,69 +150,44 @@ struct ast_timer *ast_timer_open(void)
void ast_timer_close(struct ast_timer *handle)
{
- handle->holder->iface->timer_close(handle->fd);
- handle->fd = -1;
+ handle->holder->iface->timer_close(handle->data);
ast_module_unref(handle->holder->mod);
ast_free(handle);
}
int ast_timer_fd(const struct ast_timer *handle)
{
- return handle->fd;
+ return handle->holder->iface->timer_fd(handle->data);
}
int ast_timer_set_rate(const struct ast_timer *handle, unsigned int rate)
{
- int res = -1;
-
- res = handle->holder->iface->timer_set_rate(handle->fd, rate);
-
- return res;
+ return handle->holder->iface->timer_set_rate(handle->data, rate);
}
int ast_timer_ack(const struct ast_timer *handle, unsigned int quantity)
{
- int res = -1;
-
- res = handle->holder->iface->timer_ack(handle->fd, quantity);
-
- return res;
+ return handle->holder->iface->timer_ack(handle->data, quantity);
}
int ast_timer_enable_continuous(const struct ast_timer *handle)
{
- int res = -1;
-
- res = handle->holder->iface->timer_enable_continuous(handle->fd);
-
- return res;
+ return handle->holder->iface->timer_enable_continuous(handle->data);
}
int ast_timer_disable_continuous(const struct ast_timer *handle)
{
- int res = -1;
-
- res = handle->holder->iface->timer_disable_continuous(handle->fd);
-
- return res;
+ return handle->holder->iface->timer_disable_continuous(handle->data);
}
enum ast_timer_event ast_timer_get_event(const struct ast_timer *handle)
{
- enum ast_timer_event res = -1;
-
- res = handle->holder->iface->timer_get_event(handle->fd);
-
- return res;
+ return handle->holder->iface->timer_get_event(handle->data);
}
unsigned int ast_timer_get_max_rate(const struct ast_timer *handle)
{
- unsigned int res = 0;
-
- res = handle->holder->iface->timer_get_max_rate(handle->fd);
-
- return res;
+ return handle->holder->iface->timer_get_max_rate(handle->data);
}
const char *ast_timer_get_name(const struct ast_timer *handle)