aboutsummaryrefslogtreecommitdiffstats
path: root/res
diff options
context:
space:
mode:
authorrussell <russell@f38db490-d61c-443f-a65b-d21fe96a405b>2009-05-29 22:33:31 +0000
committerrussell <russell@f38db490-d61c-443f-a65b-d21fe96a405b>2009-05-29 22:33:31 +0000
commit61e9680b02eb6a28a46cded3f752cdd4526fbdc7 (patch)
treeb05982f760ccde8c956d0860ff554d997c1a6e01 /res
parentefea35bb6a0c9ea6435d96a41953d187b1b7753a (diff)
Improve handling of trying to ACK too many timer expirations.
git-svn-id: http://svn.digium.com/svn/asterisk/trunk@198183 f38db490-d61c-443f-a65b-d21fe96a405b
Diffstat (limited to 'res')
-rw-r--r--res/res_timing_pthread.c14
1 files changed, 13 insertions, 1 deletions
diff --git a/res/res_timing_pthread.c b/res/res_timing_pthread.c
index 5e3c31364..86ae1bb42 100644
--- a/res/res_timing_pthread.c
+++ b/res/res_timing_pthread.c
@@ -357,9 +357,21 @@ static int check_timer(struct pthread_timer *timer)
static void read_pipe(struct pthread_timer *timer, unsigned int quantity)
{
int rd_fd = timer->pipe[PIPE_READ];
+ int pending_ticks = timer->pending_ticks;
ast_assert(quantity);
- ast_assert(quantity >= timer->pending_ticks);
+
+ if (timer->continuous && pending_ticks) {
+ pending_ticks--;
+ }
+
+ if (quantity > pending_ticks) {
+ quantity = pending_ticks;
+ }
+
+ if (!quantity) {
+ return;
+ }
do {
unsigned char buf[1024];