mirror of
https://github.com/asterisk/asterisk.git
synced 2025-09-30 02:26:23 +00:00
Use the right pthread lock and condition when waiting.
(closes issue #12664) Reported by: tomo1657 Patches: res_smdi.c.patch uploaded by tomo1657 (license 484) git-svn-id: https://origsvn.digium.com/svn/asterisk/branches/1.4@117135 65c4cc65-6c06-0410-ace0-fbb531ad65f3
This commit is contained in:
@@ -394,6 +394,19 @@ static void *smdi_message_wait(struct ast_smdi_interface *iface, int timeout,
|
|||||||
struct timeval start;
|
struct timeval start;
|
||||||
long diff = 0;
|
long diff = 0;
|
||||||
void *msg;
|
void *msg;
|
||||||
|
ast_cond_t *cond = NULL;
|
||||||
|
ast_mutex_t *lock = NULL;
|
||||||
|
|
||||||
|
switch (type) {
|
||||||
|
case SMDI_MWI:
|
||||||
|
cond = &iface->mwi_q_cond;
|
||||||
|
lock = &iface->mwi_q_lock;
|
||||||
|
break;
|
||||||
|
case SMDI_MD:
|
||||||
|
cond = &iface->md_q_cond;
|
||||||
|
lock = &iface->md_q_lock;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
start = ast_tvnow();
|
start = ast_tvnow();
|
||||||
while (diff < timeout) {
|
while (diff < timeout) {
|
||||||
@@ -414,7 +427,7 @@ static void *smdi_message_wait(struct ast_smdi_interface *iface, int timeout,
|
|||||||
/* If there were no messages in the queue, then go to sleep until one
|
/* If there were no messages in the queue, then go to sleep until one
|
||||||
* arrives. */
|
* arrives. */
|
||||||
|
|
||||||
ast_cond_timedwait(&iface->md_q_cond, &iface->md_q_lock, &ts);
|
ast_cond_timedwait(cond, lock, &ts);
|
||||||
|
|
||||||
if ((msg = smdi_msg_find(iface, type, station))) {
|
if ((msg = smdi_msg_find(iface, type, station))) {
|
||||||
unlock_msg_q(iface, type);
|
unlock_msg_q(iface, type);
|
||||||
|
Reference in New Issue
Block a user