aboutsummaryrefslogtreecommitdiffstats
path: root/channels
diff options
context:
space:
mode:
authortilghman <tilghman@f38db490-d61c-443f-a65b-d21fe96a405b>2008-03-12 07:43:03 +0000
committertilghman <tilghman@f38db490-d61c-443f-a65b-d21fe96a405b>2008-03-12 07:43:03 +0000
commit4467c83755ee1ee9140d869afc62c9e5dca52fa8 (patch)
tree0acf51ce189b0ba90775c88044fa891099d72110 /channels
parent4367e584de0983c7700b576a42ef77648b665cf6 (diff)
Deadlock fixes
(closes issue #12143) Reported by: kactus Patches: 20080312__bug12143__2.diff.txt uploaded by Corydon76 (license 14) Tested by: kactus git-svn-id: http://svn.digium.com/svn/asterisk/trunk@107998 f38db490-d61c-443f-a65b-d21fe96a405b
Diffstat (limited to 'channels')
-rw-r--r--channels/chan_sip.c17
1 files changed, 15 insertions, 2 deletions
diff --git a/channels/chan_sip.c b/channels/chan_sip.c
index 9f3b83043..e5ac3b224 100644
--- a/channels/chan_sip.c
+++ b/channels/chan_sip.c
@@ -2250,6 +2250,7 @@ cleanup2:
}
#define sip_pvt_lock(x) ast_mutex_lock(&x->pvt_lock)
+#define sip_pvt_trylock(x) ast_mutex_trylock(&x->pvt_lock)
#define sip_pvt_unlock(x) ast_mutex_unlock(&x->pvt_lock)
/*!
@@ -5843,6 +5844,7 @@ static struct sip_pvt *find_call(struct sip_request *req, struct sockaddr_in *si
}
dialoglist_lock();
+restartsearch:
for (p = dialoglist; p; p = p->next) {
/* In pedantic, we do not want packets with bad syntax to be connected to a PVT */
int found = FALSE;
@@ -5873,7 +5875,12 @@ static struct sip_pvt *find_call(struct sip_request *req, struct sockaddr_in *si
if (found) {
/* Found the call */
- sip_pvt_lock(p);
+ if (sip_pvt_trylock(p)) {
+ dialoglist_unlock();
+ usleep(1);
+ dialoglist_lock();
+ goto restartsearch;
+ }
dialoglist_unlock();
return p;
}
@@ -18332,7 +18339,13 @@ restartsearch:
get back to this point every millisecond or less)
*/
for (dialog = dialoglist; dialog; dialog = dialog->next) {
- sip_pvt_lock(dialog);
+ if (sip_pvt_trylock(dialog)) {
+ dialoglist_unlock();
+ usleep(1);
+ dialoglist_lock();
+ goto restartsearch;
+ }
+
/* Check RTP timeouts and kill calls if we have a timeout set and do not get RTP */
check_rtp_timeout(dialog, t);
/* If we have sessions that needs to be destroyed, do it now */