提交 93489d10 authored 作者: Anthony Minessale's avatar Anthony Minessale

finish up last commit

git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@13118 d0543943-73ff-0310-b7d9-9358b9ac24b2
上级 4781ffa3
...@@ -3670,8 +3670,17 @@ static switch_status_t conf_api_sub_transfer(conference_obj_t *conference, switc ...@@ -3670,8 +3670,17 @@ static switch_status_t conf_api_sub_transfer(conference_obj_t *conference, switc
channel = switch_core_session_get_channel(member->session); channel = switch_core_session_get_channel(member->session);
if (!new_conference) { if (!new_conference) {
switch_mutex_lock(globals.setup_mutex); if (!locked) {
locked = 1; switch_mutex_lock(globals.setup_mutex);
locked = 1;
}
if ((new_conference = conference_find(conf_name))) {
if (locked) {
switch_mutex_unlock(globals.setup_mutex);
locked = 0;
}
}
if (!(new_conference = conference_find(conf_name))) { if (!(new_conference = conference_find(conf_name))) {
/* build a new conference if it doesn't exist */ /* build a new conference if it doesn't exist */
...@@ -3700,13 +3709,6 @@ static switch_status_t conf_api_sub_transfer(conference_obj_t *conference, switc ...@@ -3700,13 +3709,6 @@ static switch_status_t conf_api_sub_transfer(conference_obj_t *conference, switc
xml_cfg.profile = switch_xml_find_child(profiles, "profile", "name", profile_name); xml_cfg.profile = switch_xml_find_child(profiles, "profile", "name", profile_name);
} }
if (!xml_cfg.profile) {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Cannot find profile: %s\n", profile_name);
switch_xml_free(cxml);
cxml = NULL;
goto done;
}
xml_cfg.controls = switch_xml_child(cfg, "caller-controls"); xml_cfg.controls = switch_xml_child(cfg, "caller-controls");
/* Release the config registry handle */ /* Release the config registry handle */
...@@ -3726,8 +3728,10 @@ static switch_status_t conf_api_sub_transfer(conference_obj_t *conference, switc ...@@ -3726,8 +3728,10 @@ static switch_status_t conf_api_sub_transfer(conference_obj_t *conference, switc
goto done; goto done;
} }
switch_mutex_unlock(globals.setup_mutex); if (locked) {
locked = 0; switch_mutex_unlock(globals.setup_mutex);
locked = 0;
}
/* Set the minimum number of members (once you go above it you cannot go below it) */ /* Set the minimum number of members (once you go above it you cannot go below it) */
new_conference->min = 1; new_conference->min = 1;
...@@ -4715,8 +4719,10 @@ SWITCH_STANDARD_APP(conference_function) ...@@ -4715,8 +4719,10 @@ SWITCH_STANDARD_APP(conference_function)
/* if this is a bridging call, and it's not a duplicate, build a */ /* if this is a bridging call, and it's not a duplicate, build a */
/* conference object, and skip pin handling, and locked checking */ /* conference object, and skip pin handling, and locked checking */
switch_mutex_lock(globals.setup_mutex); if (!locked) {
locked = 1; switch_mutex_lock(globals.setup_mutex);
locked = 1;
}
if (isbr) { if (isbr) {
char *uuid = switch_core_session_get_uuid(session); char *uuid = switch_core_session_get_uuid(session);
...@@ -4737,8 +4743,10 @@ SWITCH_STANDARD_APP(conference_function) ...@@ -4737,8 +4743,10 @@ SWITCH_STANDARD_APP(conference_function)
goto done; goto done;
} }
switch_mutex_unlock(globals.setup_mutex); if (locked) {
locked = 0; switch_mutex_unlock(globals.setup_mutex);
locked = 0;
}
switch_channel_set_variable(channel, "conference_name", conference->name); switch_channel_set_variable(channel, "conference_name", conference->name);
...@@ -4759,8 +4767,15 @@ SWITCH_STANDARD_APP(conference_function) ...@@ -4759,8 +4767,15 @@ SWITCH_STANDARD_APP(conference_function)
enforce_security = switch_true(pvar); enforce_security = switch_true(pvar);
} }
if ((conference = conference_find(conf_name))) {
if (locked) {
switch_mutex_unlock(globals.setup_mutex);
locked = 0;
}
}
/* if the conference exists, get the pointer to it */ /* if the conference exists, get the pointer to it */
if (!(conference = conference_find(conf_name))) { if (!conference) {
/* couldn't find the conference, create one */ /* couldn't find the conference, create one */
conference = conference_new(conf_name, xml_cfg, NULL); conference = conference_new(conf_name, xml_cfg, NULL);
...@@ -4768,8 +4783,10 @@ SWITCH_STANDARD_APP(conference_function) ...@@ -4768,8 +4783,10 @@ SWITCH_STANDARD_APP(conference_function)
goto done; goto done;
} }
switch_mutex_unlock(globals.setup_mutex); if (locked) {
locked = 0; switch_mutex_unlock(globals.setup_mutex);
locked = 0;
}
switch_channel_set_variable(channel, "conference_name", conference->name); switch_channel_set_variable(channel, "conference_name", conference->name);
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论