[asterisk-commits] mmichelson: branch 1.6.0 r157500 - in /branches/1.6.0: ./ channels/chan_sip.c
SVN commits to the Asterisk project
asterisk-commits at lists.digium.com
Tue Nov 18 16:11:12 CST 2008
Author: mmichelson
Date: Tue Nov 18 16:11:11 2008
New Revision: 157500
URL: http://svn.digium.com/view/asterisk?view=rev&rev=157500
Log:
Merged revisions 157496 via svnmerge from
https://origsvn.digium.com/svn/asterisk/trunk
........
r157496 | mmichelson | 2008-11-18 15:59:24 -0600 (Tue, 18 Nov 2008) | 6 lines
Based on Russell's advice on the asterisk-dev list, I have
changed from using a global lock in update_call_counter to
using the locks within the sip_pvt and sip_peer structures
instead.
........
Modified:
branches/1.6.0/ (props changed)
branches/1.6.0/channels/chan_sip.c
Propchange: branches/1.6.0/
------------------------------------------------------------------------------
Binary property 'trunk-merged' - no diff available.
Modified: branches/1.6.0/channels/chan_sip.c
URL: http://svn.digium.com/view/asterisk/branches/1.6.0/channels/chan_sip.c?view=diff&rev=157500&r1=157499&r2=157500
==============================================================================
--- branches/1.6.0/channels/chan_sip.c (original)
+++ branches/1.6.0/channels/chan_sip.c Tue Nov 18 16:11:11 2008
@@ -1416,6 +1416,7 @@
int maxcallbitrate; /*!< Maximum Bitrate for a video call */
int autoframing;
struct sip_st_cfg stimer; /*!< SIP Session-Timers */
+ ast_mutex_t lock;
};
/*!
@@ -1509,6 +1510,7 @@
int timer_t1; /*!< The maximum T1 value for the peer */
int timer_b; /*!< The maximum timer B (transaction timeouts) */
int deprecated_username; /*!< If it's a realtime peer, are they using the deprecated "username" instead of "defaultuser" */
+ ast_mutex_t lock;
};
@@ -1691,9 +1693,6 @@
SDP_T38_ACCEPT, /*!< Remote side accepted our T38 request */
};
-/*! \brief Protect the callcounters inuse,inringing and the corresponding flags */
-AST_MUTEX_DEFINE_STATIC(callctrlock);
-
/*---------------------------- Forward declarations of functions in chan_sip.c */
/* Note: This is added to help splitting up chan_sip.c into several files
in coming releases. */
@@ -4490,6 +4489,7 @@
int outgoing = fup->outgoing_call;
struct sip_user *u = NULL;
struct sip_peer *p = NULL;
+ ast_mutex_t *pu_lock;
ast_debug(3, "Updating call counter for %s call\n", outgoing ? "outgoing" : "incoming");
@@ -4506,11 +4506,13 @@
inuse = &u->inUse;
call_limit = &u->call_limit;
inringing = NULL;
+ pu_lock = &u->lock;
} else if ( (p = find_peer(ast_strlen_zero(fup->peername) ? name : fup->peername, NULL, 1, 0) ) ) { /* Try to find peer */
inuse = &p->inUse;
call_limit = &p->call_limit;
inringing = &p->inRinging;
ast_copy_string(name, fup->peername, sizeof(name));
+ pu_lock = &p->lock;
}
if (!p && !u) {
ast_debug(2, "%s is not a local device, no call limit\n", name);
@@ -4522,36 +4524,43 @@
case DEC_CALL_LIMIT:
/* Decrement inuse count if applicable */
if (inuse) {
- ast_mutex_lock(&callctrlock);
+ sip_pvt_lock(fup);
+ ast_mutex_lock(pu_lock);
if ((*inuse > 0) && ast_test_flag(&fup->flags[0], SIP_INC_COUNT)) {
(*inuse)--;
ast_clear_flag(&fup->flags[0], SIP_INC_COUNT);
} else {
*inuse = 0;
}
- ast_mutex_unlock(&callctrlock);
+ ast_mutex_unlock(pu_lock);
+ sip_pvt_unlock(fup);
}
/* Decrement ringing count if applicable */
if (inringing) {
- ast_mutex_lock(&callctrlock);
+ sip_pvt_lock(fup);
+ ast_mutex_lock(pu_lock);
if ((*inringing > 0)&& ast_test_flag(&fup->flags[0], SIP_INC_RINGING)) {
(*inringing)--;
ast_clear_flag(&fup->flags[0], SIP_INC_RINGING);
} else {
*inringing = 0;
}
- ast_mutex_unlock(&callctrlock);
+ ast_mutex_unlock(pu_lock);
+ sip_pvt_unlock(fup);
}
/* Decrement onhold count if applicable */
- ast_mutex_lock(&callctrlock);
+ sip_pvt_lock(fup);
+ ast_mutex_lock(pu_lock);
if (ast_test_flag(&fup->flags[1], SIP_PAGE2_CALL_ONHOLD) && global_notifyhold) {
ast_clear_flag(&fup->flags[1], SIP_PAGE2_CALL_ONHOLD);
- ast_mutex_unlock(&callctrlock);
+ ast_mutex_unlock(pu_lock);
+ sip_pvt_unlock(fup);
sip_peer_hold(fup, FALSE);
} else {
- ast_mutex_unlock(&callctrlock);
+ ast_mutex_unlock(pu_lock);
+ sip_pvt_unlock(fup);
}
if (sipdebug)
ast_debug(2, "Call %s %s '%s' removed from call limit %d\n", outgoing ? "to" : "from", u ? "user":"peer", name, *call_limit);
@@ -4571,20 +4580,24 @@
}
}
if (inringing && (event == INC_CALL_RINGING)) {
- ast_mutex_lock(&callctrlock);
+ sip_pvt_lock(fup);
+ ast_mutex_lock(pu_lock);
if (!ast_test_flag(&fup->flags[0], SIP_INC_RINGING)) {
(*inringing)++;
ast_set_flag(&fup->flags[0], SIP_INC_RINGING);
}
- ast_mutex_unlock(&callctrlock);
+ ast_mutex_unlock(pu_lock);
+ sip_pvt_unlock(fup);
}
if (inuse) {
- ast_mutex_lock(&callctrlock);
+ sip_pvt_lock(fup);
+ ast_mutex_lock(pu_lock);
if (!ast_test_flag(&fup->flags[0], SIP_INC_COUNT)) {
(*inuse)++;
ast_set_flag(&fup->flags[0], SIP_INC_COUNT);
}
- ast_mutex_unlock(&callctrlock);
+ ast_mutex_unlock(pu_lock);
+ sip_pvt_unlock(fup);
}
if (sipdebug) {
ast_debug(2, "Call %s %s '%s' is %d out of %d\n", outgoing ? "to" : "from", u ? "user":"peer", name, *inuse, *call_limit);
@@ -4593,12 +4606,14 @@
case DEC_CALL_RINGING:
if (inringing) {
- ast_mutex_lock(&callctrlock);
+ sip_pvt_lock(fup);
+ ast_mutex_lock(pu_lock);
if (ast_test_flag(&fup->flags[0], SIP_INC_RINGING)) {
(*inringing)--;
ast_clear_flag(&fup->flags[0], SIP_INC_RINGING);
}
- ast_mutex_unlock(&callctrlock);
+ ast_mutex_unlock(pu_lock);
+ sip_pvt_unlock(fup);
}
break;
More information about the asterisk-commits
mailing list