[Freeswitch-trunk] [commit] r3856 - in freeswitch/trunk/src: . mod/endpoints/mod_sofia
Freeswitch SVN
anthm at freeswitch.org
Wed Dec 27 20:08:06 EST 2006
Author: anthm
Date: Wed Dec 27 20:08:06 2006
New Revision: 3856
Modified:
freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c
freeswitch/trunk/src/switch_core.c
freeswitch/trunk/src/switch_ivr.c
Log:
fix sofia (part 1)
Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c
==============================================================================
--- freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c (original)
+++ freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c Wed Dec 27 20:08:06 2006
@@ -193,7 +193,7 @@
} reg_state_t;
struct outbound_reg {
- sofia_private_t sofia_private;
+ sofia_private_t *sofia_private;
nua_handle_t *nh;
sofia_profile_t *profile;
char *name;
@@ -255,7 +255,8 @@
struct private_object {
- sofia_private_t sofia_private;
+ sofia_private_t *sofia_private;
+ sofia_private_t *sofia_private2;
uint32_t flags;
switch_payload_t agreed_pt;
switch_core_session_t *session;
@@ -606,13 +607,12 @@
return 0;
}
-static void check_expire(sofia_profile_t *profile, time_t now)
+static void check_expire(switch_core_db_t *db, sofia_profile_t *profile, time_t now)
{
char sql[1024];
char *errmsg;
- switch_core_db_t *db;
- if (!(db = switch_core_db_open_file(profile->dbname))) {
+ if (!db) {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Error Opening DB %s\n", profile->dbname);
return;
}
@@ -636,7 +636,6 @@
switch_mutex_unlock(profile->ireg_mutex);
- switch_core_db_close(db);
}
static char *find_reg_url(sofia_profile_t *profile, char *user, char *host, char *val, switch_size_t len)
@@ -670,7 +669,12 @@
switch_mutex_unlock(profile->ireg_mutex);
switch_core_db_close(db);
- return cbt.matches ? val : NULL;
+ if (cbt.matches) {
+ return val;
+ } else {
+ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "Cannot locate registered user %s@%s\n", user, host);
+ return NULL;
+ }
}
@@ -975,8 +979,12 @@
SIPTAG_CONTACT_STR(tech_pvt->profile->url),
TAG_END());
- tech_pvt->sofia_private.session = session;
- nua_handle_bind(tech_pvt->nh, &tech_pvt->sofia_private);
+ if (!(tech_pvt->sofia_private = malloc(sizeof(*tech_pvt->sofia_private)))) {
+ abort();
+ }
+ memset(tech_pvt->sofia_private, 0, sizeof(*tech_pvt->sofia_private));
+ tech_pvt->sofia_private->session = session;
+ nua_handle_bind(tech_pvt->nh, tech_pvt->sofia_private);
}
@@ -1048,8 +1056,13 @@
SIPTAG_CONTACT_STR(tech_pvt->profile->url),
TAG_END());
-
- nua_handle_bind(tech_pvt->nh2, &tech_pvt->sofia_private);
+
+ if (!(tech_pvt->sofia_private2 = malloc(sizeof(*tech_pvt->sofia_private2)))) {
+ abort();
+ }
+ memset(tech_pvt->sofia_private2, 0, sizeof(*tech_pvt->sofia_private2));
+ tech_pvt->sofia_private2->session = tech_pvt->sofia_private->session;
+ nua_handle_bind(tech_pvt->nh2, tech_pvt->sofia_private2);
@@ -1257,14 +1270,14 @@
if (tech_pvt->nh) {
if (!switch_test_flag(tech_pvt, TFLAG_BYE)) {
if (switch_test_flag(tech_pvt, TFLAG_ANS)) {
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Sending BYE\n");
+ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Sending BYE to %s\n", switch_channel_get_name(channel));
nua_bye(tech_pvt->nh, TAG_END());
} else {
if (!switch_test_flag(tech_pvt, TFLAG_OUTBOUND)) {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Responding to INVITE with: %d\n", sip_cause);
nua_respond(tech_pvt->nh, sip_cause, NULL, TAG_END());
} else {
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Sending CANCEL\n");
+ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Sending CANCEL to %s\n", switch_channel_get_name(channel));
nua_cancel(tech_pvt->nh, TAG_END());
}
}
@@ -1283,6 +1296,10 @@
tech_pvt->home = NULL;
}
+ if (tech_pvt->sofia_private) {
+ tech_pvt->sofia_private->session = NULL;
+ }
+
return SWITCH_STATUS_SUCCESS;
}
@@ -1577,7 +1594,7 @@
tech_pvt->read_frame.datalen = 0;
- while (!switch_test_flag(tech_pvt, TFLAG_BYE) && switch_test_flag(tech_pvt, TFLAG_IO) && tech_pvt->read_frame.datalen == 0) {
+ while (switch_test_flag(tech_pvt, TFLAG_IO) && tech_pvt->read_frame.datalen == 0) {
tech_pvt->read_frame.flags = SFF_NONE;
status = switch_rtp_zerocopy_read_frame(tech_pvt->rtp_session, &tech_pvt->read_frame);
@@ -2779,7 +2796,7 @@
if (session) {
if (switch_test_flag(tech_pvt, TFLAG_RWLOCK)) {
switch_core_session_rwunlock(session);
- switch_clear_flag(tech_pvt, TFLAG_RWLOCK);
+ switch_clear_flag_locked(tech_pvt, TFLAG_RWLOCK);
}
if (!switch_test_flag(tech_pvt, TFLAG_BYE)) {
@@ -2792,6 +2809,12 @@
terminate_session(&session, sip_cause_to_freeswitch(status), __LINE__);
}
}
+
+ if (tech_pvt->sofia_private) {
+ free(tech_pvt->sofia_private);
+ nua_handle_bind(tech_pvt->nh, NULL);
+ tech_pvt->sofia_private = NULL;
+ }
tech_pvt->nh = NULL;
}
if (nh) {
@@ -3069,12 +3092,12 @@
from_host,
contact_str,
rpid,
- (long) time(NULL) + (long)exptime);
+ (long) time(NULL) + (long)exptime * 2);
} else {
sql = switch_mprintf("update sip_registrations set contact='%q', expires=%ld, rpid='%q' where user='%q' and host='%q'",
contact_str,
- (long) time(NULL) + (long)exptime,
+ (long) time(NULL) + (long)exptime * 2,
rpid,
from_user,
from_host);
@@ -3574,30 +3597,39 @@
goto done;
}
if ((replaces = sip_replaces_make(tech_pvt->home, rep)) && (bnh = nua_handle_by_replaces(nua, replaces))) {
- sofia_private_t *b_private;
-
+ sofia_private_t *b_private = NULL;
+ private_object_t *tech_pvt_b = NULL;
switch_channel_set_variable(channel_a, SOFIA_REPLACES_HEADER, rep);
if ((b_private = nua_handle_magic(bnh))) {
- channel_b = switch_core_session_get_channel(b_private->session);
+ tech_pvt_b = (private_object_t *) switch_core_session_get_private(b_private->session);
+ channel_b = switch_core_session_get_channel(b_private->session);
br_a = switch_channel_get_variable(channel_a, SWITCH_BRIDGE_VARIABLE);
br_b = switch_channel_get_variable(channel_b, SWITCH_BRIDGE_VARIABLE);
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Attended Transfer [%s][%s]\n", br_a, br_b);
-
+
+ if (switch_test_flag(tech_pvt, TFLAG_RWLOCK)) {
+ switch_core_session_rwunlock(tech_pvt->session);
+ switch_clear_flag_locked(tech_pvt, TFLAG_RWLOCK);
+ }
+ if (switch_test_flag(tech_pvt_b, TFLAG_RWLOCK)) {
+ switch_core_session_rwunlock(tech_pvt_b->session);
+ switch_clear_flag_locked(tech_pvt_b, TFLAG_RWLOCK);
+ }
+
+
if (br_a && br_b) {
switch_ivr_uuid_bridge(br_a, br_b);
switch_channel_set_variable(channel_b, "endpoint_disposition", "ATTENDED_TRANSFER");
-
+ switch_set_flag_locked(tech_pvt, TFLAG_BYE);
nua_notify(tech_pvt->nh, SIPTAG_CONTENT_TYPE_STR("message/sipfrag"),
SIPTAG_PAYLOAD_STR("SIP/2.0 200 OK"),
SIPTAG_EVENT_STR(etmp),
TAG_END());
-
+
} else {
- private_object_t *tech_pvt_b = (private_object_t *) switch_core_session_get_private(b_private->session);
-
- if (!br_a && !br_b) {
+ if (!br_a && !br_b) {
switch_set_flag_locked(tech_pvt, TFLAG_NOHUP);
switch_set_flag_locked(tech_pvt_b, TFLAG_XFER);
tech_pvt_b->xferto = switch_core_session_strdup(b_private->session, switch_core_session_get_uuid(session));
@@ -3632,7 +3664,7 @@
switch_channel_hangup(channel_b, SWITCH_CAUSE_ATTENDED_TRANSFER);
}
-
+ switch_set_flag_locked(tech_pvt, TFLAG_BYE);
nua_notify(tech_pvt->nh, SIPTAG_CONTENT_TYPE_STR("message/sipfrag"),
SIPTAG_PAYLOAD_STR("SIP/2.0 200 OK"),
SIPTAG_EVENT_STR(etmp),
@@ -3684,6 +3716,11 @@
tuuid_str = switch_core_session_get_uuid(tsession);
switch_ivr_uuid_bridge(br_a, tuuid_str);
switch_channel_set_variable(channel_a, "endpoint_disposition", "ATTENDED_TRANSFER");
+ switch_set_flag_locked(tech_pvt, TFLAG_BYE);
+ if (switch_test_flag(tech_pvt, TFLAG_RWLOCK)) {
+ switch_core_session_rwunlock(tech_pvt->session);
+ switch_clear_flag_locked(tech_pvt, TFLAG_RWLOCK);
+ }
nua_notify(tech_pvt->nh, SIPTAG_CONTENT_TYPE_STR("message/sipfrag"),
SIPTAG_PAYLOAD_STR("SIP/2.0 200 OK"),
SIPTAG_EVENT_STR(etmp),
@@ -3727,10 +3764,16 @@
switch_channel_set_variable(channel, "endpoint_disposition", "BLIND_TRANSFER");
+ /*
nua_notify(tech_pvt->nh, SIPTAG_CONTENT_TYPE_STR("message/sipfrag"),
SIPTAG_PAYLOAD_STR("SIP/2.0 200 OK"),
SIPTAG_EVENT_STR(etmp),
TAG_END());
+ */
+ if (switch_test_flag(tech_pvt, TFLAG_RWLOCK)) {
+ switch_core_session_rwunlock(tech_pvt->session);
+ switch_clear_flag_locked(tech_pvt, TFLAG_RWLOCK);
+ }
} else {
exten = switch_mprintf("sip:%s@%s:%s",
(char *) refer_to->r_url->url_user,
@@ -3741,12 +3784,16 @@
switch_set_flag_locked(tech_pvt, TFLAG_NOHUP);
-
+ /*
nua_notify(tech_pvt->nh, SIPTAG_CONTENT_TYPE_STR("message/sipfrag"),
SIPTAG_PAYLOAD_STR("SIP/2.0 200 OK"),
SIPTAG_EVENT_STR(etmp),
TAG_END());
-
+ */
+ if (switch_test_flag(tech_pvt, TFLAG_RWLOCK)) {
+ switch_core_session_rwunlock(tech_pvt->session);
+ switch_clear_flag_locked(tech_pvt, TFLAG_RWLOCK);
+ }
do_xfer_invite(session);
}
@@ -4022,8 +4069,8 @@
}
attach_private(session, profile, tech_pvt, username);
- //switch_core_session_read_lock(session);
- //switch_set_flag(tech_pvt, TFLAG_RWLOCK);
+ switch_core_session_read_lock(session);
+ switch_set_flag(tech_pvt, TFLAG_RWLOCK);
channel = switch_core_session_get_channel(session);
switch_channel_set_variable(channel, "endpoint_disposition", "INBOUND CALL");
set_chat_hash(tech_pvt, sip);
@@ -4091,7 +4138,7 @@
snprintf(uri, sizeof(uri), "%s@%s:%s", req_user, req_host, req_port);
switch_channel_set_variable(channel, "sip_req_uri", uri);
-
+
if ((tech_pvt->caller_profile = switch_caller_profile_new(switch_core_session_get_pool(session),
(char *) from->a_url->url_user,
@@ -4167,8 +4214,12 @@
switch_safe_free(to_username);
}
- tech_pvt->sofia_private.session = session;
- nua_handle_bind(nh, &tech_pvt->sofia_private);
+ if (!(tech_pvt->sofia_private = malloc(sizeof(*tech_pvt->sofia_private)))) {
+ abort();
+ }
+ memset(tech_pvt->sofia_private, 0, sizeof(*tech_pvt->sofia_private));
+ tech_pvt->sofia_private->session = session;
+ nua_handle_bind(nh, tech_pvt->sofia_private);
}
}
}
@@ -4483,9 +4534,6 @@
break;
case nua_r_message:
case nua_r_notify:
- if (nh) {
- nua_handle_destroy(nh);
- }
break;
case nua_i_notify:
@@ -4529,6 +4577,11 @@
{
outbound_reg_t *oregp;
for (oregp = profile->registrations; oregp; oregp = oregp->next) {
+ if (oregp->sofia_private) {
+ free(oregp->sofia_private);
+ nua_handle_bind(oregp->nh, NULL);
+ oregp->sofia_private = NULL;
+ }
nua_handle_destroy(oregp->nh);
}
}
@@ -4553,8 +4606,14 @@
NUTAG_CALLSTATE_REF(ss_state),
SIPTAG_FROM_STR(oregp->register_from), TAG_END()))) {
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "registering %s\n", oregp->name);
- oregp->sofia_private.oreg = oregp;
- nua_handle_bind(oregp->nh, &oregp->sofia_private);
+
+ if (!(oregp->sofia_private = malloc(sizeof(*oregp->sofia_private)))) {
+ abort();
+ }
+ memset(oregp->sofia_private, 0, sizeof(*oregp->sofia_private));
+
+ oregp->sofia_private->oreg = oregp;
+ nua_handle_bind(oregp->nh, oregp->sofia_private);
nua_register(oregp->nh,
SIPTAG_FROM_STR(oregp->register_from),
@@ -4661,7 +4720,7 @@
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CRIT, "Cannot Open SQL Database!\n");
return NULL;
}
- switch_core_db_close(db);
+
switch_mutex_init(&profile->ireg_mutex, SWITCH_MUTEX_NESTED, profile->pool);
switch_mutex_init(&profile->oreg_mutex, SWITCH_MUTEX_NESTED, profile->pool);
@@ -4696,9 +4755,12 @@
establish_presence(profile);
}
+
+
+
while(globals.running == 1) {
if (++ireg_loops >= IREG_SECONDS) {
- check_expire(profile, time(NULL));
+ check_expire(db, profile, time(NULL));
ireg_loops = 0;
}
@@ -4710,6 +4772,7 @@
su_root_step(profile->s_root, 1000);
}
+ switch_core_db_close(db);
unreg(profile);
su_home_unref(profile->home);
Modified: freeswitch/trunk/src/switch_core.c
==============================================================================
--- freeswitch/trunk/src/switch_core.c (original)
+++ freeswitch/trunk/src/switch_core.c Wed Dec 27 20:08:06 2006
@@ -539,11 +539,12 @@
SWITCH_DECLARE(switch_status_t) switch_core_session_read_lock(switch_core_session_t *session)
{
- switch_status_t status = SWITCH_STATUS_SUCCESS;
+ switch_status_t status = SWITCH_STATUS_FALSE;
+ if (session->rwlock) {
+ status = (switch_status_t) switch_thread_rwlock_tryrdlock(session->rwlock);
+ }
- status = (switch_status_t) switch_thread_rwlock_tryrdlock(session->rwlock);
-
return status;
}
Modified: freeswitch/trunk/src/switch_ivr.c
==============================================================================
--- freeswitch/trunk/src/switch_ivr.c (original)
+++ freeswitch/trunk/src/switch_ivr.c Wed Dec 27 20:08:06 2006
@@ -1939,6 +1939,8 @@
switch_mutex_unlock(data->mutex);
}
}
+
+ switch_core_session_kill_channel(session_b, SWITCH_SIG_BREAK);
msg.message_id = SWITCH_MESSAGE_INDICATE_UNBRIDGE;
msg.from = __FILE__;
@@ -3304,19 +3306,18 @@
switch_event_fire(&event);
}
-
- if (switch_channel_get_state(caller_channel) != CS_EXECUTE && !switch_channel_test_flag(caller_channel, CF_TRANSFER)) {
- switch_channel_hangup(caller_channel, SWITCH_CAUSE_NORMAL_CLEARING);
- }
-
if (switch_channel_test_flag(caller_channel, CF_TRANSFER) && !switch_channel_test_flag(peer_channel, CF_TRANSFER)) {
- switch_channel_hangup(peer_channel, SWITCH_CAUSE_NORMAL_CLEARING);
+ //switch_channel_hangup(peer_channel, SWITCH_CAUSE_NORMAL_CLEARING);
+ switch_yield(2000000);
}
+
if (!switch_channel_test_flag(caller_channel, CF_TRANSFER) && switch_channel_test_flag(peer_channel, CF_TRANSFER)) {
- switch_channel_hangup(caller_channel, SWITCH_CAUSE_NORMAL_CLEARING);
+ //switch_channel_hangup(caller_channel, SWITCH_CAUSE_NORMAL_CLEARING);
+ switch_yield(2000000);
}
- this_audio_thread->objs[0] = NULL;
+
+ this_audio_thread->objs[0] = NULL;
this_audio_thread->objs[1] = NULL;
this_audio_thread->objs[2] = NULL;
this_audio_thread->input_callback = NULL;
More information about the Freeswitch-trunk
mailing list