[asterisk-commits] russell: branch 1.4 r78242 - /branches/1.4/channels/chan_iax2.c
SVN commits to the Asterisk project
asterisk-commits at lists.digium.com
Mon Aug 6 15:44:09 CDT 2007
Author: russell
Date: Mon Aug 6 15:44:09 2007
New Revision: 78242
URL: http://svn.digium.com/view/asterisk?view=rev&rev=78242
Log:
Fix an issue where dynamic threads can get free'd, but still exist in the
dynamic thread list.
(closes issue #10392, patch from Mihai, with credit to his colleague, Pete)
Modified:
branches/1.4/channels/chan_iax2.c
Modified: branches/1.4/channels/chan_iax2.c
URL: http://svn.digium.com/view/asterisk/branches/1.4/channels/chan_iax2.c?view=diff&rev=78242&r1=78241&r2=78242
==============================================================================
--- branches/1.4/channels/chan_iax2.c (original)
+++ branches/1.4/channels/chan_iax2.c Mon Aug 6 15:44:09 2007
@@ -856,6 +856,9 @@
.fixup = iax2_fixup,
};
+/* WARNING: insert_idle_thread should only ever be called within the
+ * context of an iax2_process_thread() thread.
+ */
static void insert_idle_thread(struct iax2_thread *thread)
{
if (thread->type == IAX_TYPE_DYNAMIC) {
@@ -6384,11 +6387,13 @@
if (errno != ECONNREFUSED && errno != EAGAIN)
ast_log(LOG_WARNING, "Error: %s\n", strerror(errno));
handle_error();
- insert_idle_thread(thread);
+ thread->iostate = IAX_IOSTATE_IDLE;
+ signal_condition(&thread->lock, &thread->cond);
return 1;
}
if (test_losspct && ((100.0 * ast_random() / (RAND_MAX + 1.0)) < test_losspct)) { /* simulate random loss condition */
- insert_idle_thread(thread);
+ thread->iostate = IAX_IOSTATE_IDLE;
+ signal_condition(&thread->lock, &thread->cond);
return 1;
}
@@ -6411,7 +6416,8 @@
so queue it up for processing later. */
defer_full_frame(thread, cur);
AST_LIST_UNLOCK(&active_list);
- insert_idle_thread(thread);
+ thread->iostate = IAX_IOSTATE_IDLE;
+ signal_condition(&thread->lock, &thread->cond);
return 1;
} else {
/* this thread is going to process this frame, so mark it */
@@ -7896,12 +7902,26 @@
/* Someone grabbed our thread *right* after we timed out.
* Wait for them to set us up with something to do and signal
* us to continue. */
- ast_cond_wait(&thread->cond, &thread->lock);
+ tv = ast_tvadd(ast_tvnow(), ast_samp2tv(30000, 1000));
+ ts.tv_sec = tv.tv_sec;
+ ts.tv_nsec = tv.tv_usec * 1000;
+ if (ast_cond_timedwait(&thread->cond, &thread->lock, &ts) == ETIMEDOUT)
+ {
+ ast_mutex_unlock(&thread->lock);
+ break;
+ }
}
} else {
ast_cond_wait(&thread->cond, &thread->lock);
}
+
+ /* Go back into our respective list */
+ put_into_idle = 1;
+
ast_mutex_unlock(&thread->lock);
+
+ if (thread->iostate == IAX_IOSTATE_IDLE)
+ continue;
/* Add ourselves to the active list now */
AST_LIST_LOCK(&active_list);
@@ -7937,9 +7957,6 @@
/* Make sure another frame didn't sneak in there after we thought we were done. */
handle_deferred_full_frames(thread);
-
- /* Go back into our respective list */
- put_into_idle = 1;
}
/* I am exiting here on my own volition, I need to clean up my own data structures
More information about the asterisk-commits
mailing list