140cb5e5dSvi /*
240cb5e5dSvi * CDDL HEADER START
340cb5e5dSvi *
440cb5e5dSvi * The contents of this file are subject to the terms of the
540cb5e5dSvi * Common Development and Distribution License (the "License").
640cb5e5dSvi * You may not use this file except in compliance with the License.
740cb5e5dSvi *
840cb5e5dSvi * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
940cb5e5dSvi * or http://www.opensolaris.org/os/licensing.
1040cb5e5dSvi * See the License for the specific language governing permissions
1140cb5e5dSvi * and limitations under the License.
1240cb5e5dSvi *
1340cb5e5dSvi * When distributing Covered Code, include this CDDL HEADER in each
1440cb5e5dSvi * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
1540cb5e5dSvi * If applicable, add the following below this CDDL HEADER, with the
1640cb5e5dSvi * fields enclosed by brackets "[]" replaced with your own identifying
1740cb5e5dSvi * information: Portions Copyright [yyyy] [name of copyright owner]
1840cb5e5dSvi *
1940cb5e5dSvi * CDDL HEADER END
2040cb5e5dSvi */
2140cb5e5dSvi
2240cb5e5dSvi /*
23*943efbc3Sgm * Copyright 2008 Sun Microsystems, Inc. All rights reserved.
2440cb5e5dSvi * Use is subject to license terms.
2540cb5e5dSvi */
2640cb5e5dSvi
272c2c4183Svi #include <stdlib.h>
282c2c4183Svi #include <assert.h>
292c2c4183Svi #include <errno.h>
302c2c4183Svi #include <pthread.h>
312c2c4183Svi #include <strings.h>
322c2c4183Svi
3340cb5e5dSvi #include "sip_parse_uri.h"
3440cb5e5dSvi #include "sip_msg.h"
3540cb5e5dSvi #include "sip_miscdefs.h"
3640cb5e5dSvi #include "sip_xaction.h"
3740cb5e5dSvi #include "sip_hash.h"
3840cb5e5dSvi
3940cb5e5dSvi #define RFC_3261_BRANCH "z9hG4bK"
4040cb5e5dSvi
4140cb5e5dSvi /*
4240cb5e5dSvi * The transaction hash table
4340cb5e5dSvi */
4440cb5e5dSvi sip_hash_t sip_xaction_hash[SIP_HASH_SZ];
4540cb5e5dSvi
4640cb5e5dSvi int (*sip_xaction_ulp_trans_err)(sip_transaction_t, int, void *) = NULL;
4740cb5e5dSvi void (*sip_xaction_ulp_state_cb)(sip_transaction_t, sip_msg_t, int, int) = NULL;
4840cb5e5dSvi
4940cb5e5dSvi int sip_xaction_add(sip_xaction_t *, char *, _sip_msg_t *, sip_method_t);
5040cb5e5dSvi static boolean_t sip_is_conn_obj_cache(sip_conn_object_t, void *);
5140cb5e5dSvi
5240cb5e5dSvi /*
5340cb5e5dSvi * Get the md5 hash of the required fields
5440cb5e5dSvi */
5540cb5e5dSvi int
sip_find_md5_digest(char * bid,_sip_msg_t * msg,uint16_t * hindex,sip_method_t method)5640cb5e5dSvi sip_find_md5_digest(char *bid, _sip_msg_t *msg, uint16_t *hindex,
5740cb5e5dSvi sip_method_t method)
5840cb5e5dSvi {
5940cb5e5dSvi boolean_t is_2543;
6040cb5e5dSvi
6140cb5e5dSvi is_2543 = (bid == NULL ||
6240cb5e5dSvi strncmp(bid, RFC_3261_BRANCH, strlen(RFC_3261_BRANCH)) != 0);
6340cb5e5dSvi
6440cb5e5dSvi if (is_2543 && msg == NULL)
6540cb5e5dSvi return (EINVAL);
6640cb5e5dSvi if (is_2543) {
6740cb5e5dSvi _sip_header_t *from = NULL;
6840cb5e5dSvi _sip_header_t *cid = NULL;
6940cb5e5dSvi _sip_header_t *via = NULL;
7040cb5e5dSvi const sip_str_t *to_uri = NULL;
7140cb5e5dSvi int cseq;
7240cb5e5dSvi int error = 0;
7340cb5e5dSvi
7440cb5e5dSvi /*
7540cb5e5dSvi * Since the response might contain parameters not in the
7640cb5e5dSvi * request, just use the to URI.
7740cb5e5dSvi */
7840cb5e5dSvi to_uri = sip_get_to_uri_str((sip_msg_t)msg, &error);
7940cb5e5dSvi if (to_uri == NULL || error != 0)
8040cb5e5dSvi return (EINVAL);
8140cb5e5dSvi cseq = sip_get_callseq_num((sip_msg_t)msg, &error);
8240cb5e5dSvi if (cseq < 0 || error != 0)
8340cb5e5dSvi return (EINVAL);
8440cb5e5dSvi (void) pthread_mutex_lock(&msg->sip_msg_mutex);
8540cb5e5dSvi via = sip_search_for_header(msg, SIP_VIA, NULL);
8640cb5e5dSvi from = sip_search_for_header(msg, SIP_FROM, NULL);
8740cb5e5dSvi cid = sip_search_for_header(msg, SIP_CALL_ID, NULL);
8840cb5e5dSvi (void) pthread_mutex_unlock(&msg->sip_msg_mutex);
8940cb5e5dSvi if (via == NULL || from == NULL || cid == NULL)
9040cb5e5dSvi return (EINVAL);
9140cb5e5dSvi sip_md5_hash(via->sip_hdr_start,
9240cb5e5dSvi via->sip_hdr_end - via->sip_hdr_start,
9340cb5e5dSvi cid->sip_hdr_start,
9440cb5e5dSvi cid->sip_hdr_end - cid->sip_hdr_start,
9540cb5e5dSvi from->sip_hdr_start,
9640cb5e5dSvi from->sip_hdr_end - from->sip_hdr_start,
9740cb5e5dSvi (char *)&cseq, sizeof (int),
9840cb5e5dSvi (char *)&method, sizeof (sip_method_t),
9940cb5e5dSvi to_uri->sip_str_ptr, to_uri->sip_str_len,
10040cb5e5dSvi (uchar_t *)hindex);
10140cb5e5dSvi } else {
10240cb5e5dSvi sip_md5_hash(bid, strlen(bid), (char *)&method,
10340cb5e5dSvi sizeof (sip_method_t), NULL, 0, NULL, 0, NULL, 0, NULL, 0,
10440cb5e5dSvi (uchar_t *)hindex);
10540cb5e5dSvi }
10640cb5e5dSvi return (0);
10740cb5e5dSvi }
10840cb5e5dSvi
10940cb5e5dSvi /*
11040cb5e5dSvi * Add object to the connection cache object. Not checking for duplicates!!
11140cb5e5dSvi */
11240cb5e5dSvi int
sip_add_conn_obj_cache(sip_conn_object_t obj,void * cobj)11340cb5e5dSvi sip_add_conn_obj_cache(sip_conn_object_t obj, void *cobj)
11440cb5e5dSvi {
11540cb5e5dSvi void **obj_val;
11640cb5e5dSvi sip_conn_obj_pvt_t *pvt_data;
11740cb5e5dSvi sip_conn_cache_t *xaction_list;
11840cb5e5dSvi sip_xaction_t *sip_trans = (sip_xaction_t *)cobj;
11940cb5e5dSvi
12040cb5e5dSvi /*
12140cb5e5dSvi * Is already cached
12240cb5e5dSvi */
12340cb5e5dSvi if (sip_trans->sip_xaction_conn_obj != NULL) {
12440cb5e5dSvi if (sip_is_conn_obj_cache(sip_trans->sip_xaction_conn_obj,
12540cb5e5dSvi (void *)sip_trans)) {
12640cb5e5dSvi return (0);
12740cb5e5dSvi }
12840cb5e5dSvi /*
12940cb5e5dSvi * Transaction has cached a different conn_obj, release it
13040cb5e5dSvi */
13140cb5e5dSvi sip_del_conn_obj_cache(sip_trans->sip_xaction_conn_obj,
13240cb5e5dSvi (void *)sip_trans);
13340cb5e5dSvi }
13440cb5e5dSvi
13540cb5e5dSvi xaction_list = malloc(sizeof (sip_conn_cache_t));
13640cb5e5dSvi if (xaction_list == NULL)
13740cb5e5dSvi return (ENOMEM);
13840cb5e5dSvi xaction_list->obj = cobj;
13940cb5e5dSvi xaction_list->next = xaction_list->prev = NULL;
14040cb5e5dSvi
14140cb5e5dSvi obj_val = (void *)obj;
14240cb5e5dSvi pvt_data = (sip_conn_obj_pvt_t *)*obj_val;
14340cb5e5dSvi if (pvt_data == NULL) {
14440cb5e5dSvi free(xaction_list);
14540cb5e5dSvi return (EINVAL);
14640cb5e5dSvi }
14740cb5e5dSvi (void) pthread_mutex_lock(&pvt_data->sip_conn_obj_cache_lock);
14840cb5e5dSvi
14940cb5e5dSvi if (pvt_data->sip_conn_obj_cache == NULL) {
15040cb5e5dSvi pvt_data->sip_conn_obj_cache = xaction_list;
15140cb5e5dSvi } else {
15240cb5e5dSvi xaction_list->next = pvt_data->sip_conn_obj_cache;
15340cb5e5dSvi pvt_data->sip_conn_obj_cache->prev = xaction_list;
15440cb5e5dSvi pvt_data->sip_conn_obj_cache = xaction_list;
15540cb5e5dSvi }
15640cb5e5dSvi sip_refhold_conn(obj);
15740cb5e5dSvi sip_trans->sip_xaction_conn_obj = obj;
15840cb5e5dSvi (void) pthread_mutex_unlock(&pvt_data->sip_conn_obj_cache_lock);
15940cb5e5dSvi return (0);
16040cb5e5dSvi }
16140cb5e5dSvi
16240cb5e5dSvi /*
16340cb5e5dSvi * Walk thru the list of transactions that have cached this obj and
16440cb5e5dSvi * and return true if 'cobj' is one of them.
16540cb5e5dSvi */
16640cb5e5dSvi static boolean_t
sip_is_conn_obj_cache(sip_conn_object_t obj,void * cobj)16740cb5e5dSvi sip_is_conn_obj_cache(sip_conn_object_t obj, void *cobj)
16840cb5e5dSvi {
16940cb5e5dSvi void **obj_val;
17040cb5e5dSvi sip_conn_obj_pvt_t *pvt_data;
17140cb5e5dSvi sip_conn_cache_t *xaction_list;
17240cb5e5dSvi sip_xaction_t *trans;
17340cb5e5dSvi sip_xaction_t *ctrans = (sip_xaction_t *)cobj;
17440cb5e5dSvi
17540cb5e5dSvi obj_val = (void *)obj;
17640cb5e5dSvi pvt_data = (sip_conn_obj_pvt_t *)*obj_val;
17740cb5e5dSvi if (pvt_data == NULL)
17840cb5e5dSvi return (B_FALSE);
17940cb5e5dSvi (void) pthread_mutex_lock(&pvt_data->sip_conn_obj_cache_lock);
18040cb5e5dSvi xaction_list = pvt_data->sip_conn_obj_cache;
18140cb5e5dSvi while (xaction_list != NULL) {
18240cb5e5dSvi trans = (sip_xaction_t *)xaction_list->obj;
18340cb5e5dSvi if (ctrans != trans) {
18440cb5e5dSvi xaction_list = xaction_list->next;
18540cb5e5dSvi continue;
18640cb5e5dSvi }
18740cb5e5dSvi (void) pthread_mutex_unlock(&pvt_data->sip_conn_obj_cache_lock);
18840cb5e5dSvi return (B_TRUE);
18940cb5e5dSvi }
19040cb5e5dSvi (void) pthread_mutex_unlock(&pvt_data->sip_conn_obj_cache_lock);
19140cb5e5dSvi return (B_FALSE);
19240cb5e5dSvi }
19340cb5e5dSvi
19440cb5e5dSvi
19540cb5e5dSvi /*
19640cb5e5dSvi * Walk thru the list of transactions that have cached this obj and
19740cb5e5dSvi * refrele the objs.
19840cb5e5dSvi */
19940cb5e5dSvi void
sip_del_conn_obj_cache(sip_conn_object_t obj,void * cobj)20040cb5e5dSvi sip_del_conn_obj_cache(sip_conn_object_t obj, void *cobj)
20140cb5e5dSvi {
20240cb5e5dSvi void **obj_val;
20340cb5e5dSvi sip_conn_obj_pvt_t *pvt_data;
20440cb5e5dSvi sip_conn_cache_t *xaction_list;
20540cb5e5dSvi sip_conn_cache_t *tmp_list;
20640cb5e5dSvi sip_xaction_t *trans;
20740cb5e5dSvi sip_xaction_t *ctrans = NULL;
20840cb5e5dSvi
20940cb5e5dSvi if (cobj != NULL)
21040cb5e5dSvi ctrans = (sip_xaction_t *)cobj;
21140cb5e5dSvi
21240cb5e5dSvi obj_val = (void *)obj;
21340cb5e5dSvi pvt_data = (sip_conn_obj_pvt_t *)*obj_val;
21440cb5e5dSvi if (pvt_data == NULL) { /* ASSERT FALSE if ctrans != NULL?? */
21540cb5e5dSvi if (ctrans != NULL) {
21640cb5e5dSvi sip_refrele_conn(obj);
21740cb5e5dSvi ctrans->sip_xaction_conn_obj = NULL;
21840cb5e5dSvi }
21940cb5e5dSvi return;
22040cb5e5dSvi }
22140cb5e5dSvi (void) pthread_mutex_lock(&pvt_data->sip_conn_obj_cache_lock);
22240cb5e5dSvi xaction_list = pvt_data->sip_conn_obj_cache;
22340cb5e5dSvi while (xaction_list != NULL) {
22440cb5e5dSvi tmp_list = xaction_list;
22540cb5e5dSvi trans = (sip_xaction_t *)xaction_list->obj;
22640cb5e5dSvi assert(trans != NULL);
22740cb5e5dSvi if (ctrans != NULL && ctrans != trans) {
22840cb5e5dSvi xaction_list = xaction_list->next;
22940cb5e5dSvi continue;
23040cb5e5dSvi }
23140cb5e5dSvi if (ctrans == NULL)
23240cb5e5dSvi (void) pthread_mutex_lock(&trans->sip_xaction_mutex);
23340cb5e5dSvi assert(trans->sip_xaction_conn_obj == obj);
23440cb5e5dSvi sip_refrele_conn(obj);
23540cb5e5dSvi trans->sip_xaction_conn_obj = NULL;
23640cb5e5dSvi if (ctrans == NULL)
23740cb5e5dSvi (void) pthread_mutex_unlock(&trans->sip_xaction_mutex);
23840cb5e5dSvi xaction_list = xaction_list->next;
23940cb5e5dSvi
24040cb5e5dSvi /*
24140cb5e5dSvi * Take the obj out of the list
24240cb5e5dSvi */
24340cb5e5dSvi if (tmp_list == pvt_data->sip_conn_obj_cache) {
24440cb5e5dSvi if (xaction_list == NULL) {
24540cb5e5dSvi pvt_data->sip_conn_obj_cache = NULL;
24640cb5e5dSvi } else {
24740cb5e5dSvi xaction_list->prev = NULL;
24840cb5e5dSvi pvt_data->sip_conn_obj_cache = xaction_list;
24940cb5e5dSvi }
25040cb5e5dSvi } else if (xaction_list == NULL) {
25140cb5e5dSvi assert(tmp_list->prev != NULL);
25240cb5e5dSvi tmp_list->prev->next = NULL;
25340cb5e5dSvi } else {
25440cb5e5dSvi assert(tmp_list->prev != NULL);
25540cb5e5dSvi tmp_list->prev->next = xaction_list;
25640cb5e5dSvi xaction_list->prev = tmp_list->prev;
25740cb5e5dSvi }
25840cb5e5dSvi tmp_list->prev = NULL;
25940cb5e5dSvi tmp_list->next = NULL;
26040cb5e5dSvi tmp_list->obj = NULL;
26140cb5e5dSvi
26240cb5e5dSvi free(tmp_list);
26340cb5e5dSvi }
26440cb5e5dSvi (void) pthread_mutex_unlock(&pvt_data->sip_conn_obj_cache_lock);
26540cb5e5dSvi }
26640cb5e5dSvi
26740cb5e5dSvi /*
26840cb5e5dSvi * Check for a transaction match. Passed to sip_hash_find().
26940cb5e5dSvi */
27040cb5e5dSvi boolean_t
sip_xaction_match(void * obj,void * hindex)27140cb5e5dSvi sip_xaction_match(void *obj, void *hindex)
27240cb5e5dSvi {
27340cb5e5dSvi sip_xaction_t *tmp = (sip_xaction_t *)obj;
27440cb5e5dSvi
27540cb5e5dSvi tmp = (sip_xaction_t *)obj;
27640cb5e5dSvi
27740cb5e5dSvi if (SIP_IS_XACTION_TERMINATED(tmp->sip_xaction_state))
27840cb5e5dSvi return (B_FALSE);
27940cb5e5dSvi if (bcmp(tmp->sip_xaction_hash_digest, hindex,
28040cb5e5dSvi sizeof (tmp->sip_xaction_hash_digest)) == 0) {
28140cb5e5dSvi SIP_XACTION_REFCNT_INCR(tmp);
28240cb5e5dSvi return (B_TRUE);
28340cb5e5dSvi }
28440cb5e5dSvi return (B_FALSE);
28540cb5e5dSvi }
28640cb5e5dSvi
28740cb5e5dSvi
28840cb5e5dSvi /*
28940cb5e5dSvi * Find a transaction
29040cb5e5dSvi */
29140cb5e5dSvi static sip_xaction_t *
sip_xaction_find(char * branchid,_sip_msg_t * msg,int which)29240cb5e5dSvi sip_xaction_find(char *branchid, _sip_msg_t *msg, int which)
29340cb5e5dSvi {
29440cb5e5dSvi sip_xaction_t *tmp;
29540cb5e5dSvi uint16_t hash_index[8];
29640cb5e5dSvi int hindex;
29740cb5e5dSvi sip_method_t method;
29840cb5e5dSvi int error;
29940cb5e5dSvi sip_message_type_t *sip_msg_info;
30040cb5e5dSvi
30140cb5e5dSvi sip_msg_info = msg->sip_msg_req_res;
30240cb5e5dSvi method = sip_get_callseq_method((sip_msg_t)msg, &error);
30340cb5e5dSvi if (error != 0)
30440cb5e5dSvi return (NULL);
30540cb5e5dSvi
30640cb5e5dSvi /*
30740cb5e5dSvi * If we are getting a ACK/CANCEL we need to match with the
30840cb5e5dSvi * corresponding INVITE, if any.
30940cb5e5dSvi */
31040cb5e5dSvi if (sip_msg_info->is_request && which == SIP_SERVER_TRANSACTION &&
31140cb5e5dSvi (method == ACK || method == CANCEL)) {
31240cb5e5dSvi method = INVITE;
31340cb5e5dSvi }
31440cb5e5dSvi if (sip_find_md5_digest(branchid, msg, hash_index, method) != 0)
31540cb5e5dSvi return (NULL);
31640cb5e5dSvi hindex = SIP_DIGEST_TO_HASH(hash_index);
31740cb5e5dSvi tmp = (sip_xaction_t *)sip_hash_find(sip_xaction_hash,
31840cb5e5dSvi (void *)hash_index, hindex, sip_xaction_match);
31940cb5e5dSvi return (tmp);
32040cb5e5dSvi }
32140cb5e5dSvi
32240cb5e5dSvi /*
32340cb5e5dSvi * create a transaction.
32440cb5e5dSvi */
32540cb5e5dSvi static sip_xaction_t *
sip_xaction_create(sip_conn_object_t obj,_sip_msg_t * msg,char * branchid,int * error)32640cb5e5dSvi sip_xaction_create(sip_conn_object_t obj, _sip_msg_t *msg, char *branchid,
32740cb5e5dSvi int *error)
32840cb5e5dSvi {
32940cb5e5dSvi sip_xaction_t *trans;
33040cb5e5dSvi sip_message_type_t *sip_msg_info;
33140cb5e5dSvi int state = 0;
33240cb5e5dSvi int prev_state = 0;
33340cb5e5dSvi sip_method_t method;
33440cb5e5dSvi int ret;
33540cb5e5dSvi int timer1 = sip_timer_T1;
33640cb5e5dSvi int timer4 = sip_timer_T4;
33740cb5e5dSvi int timerd = sip_timer_TD;
33840cb5e5dSvi
33940cb5e5dSvi if (error != NULL)
34040cb5e5dSvi *error = 0;
34140cb5e5dSvi /*
34240cb5e5dSvi * Make sure we are not creating a transaction for
34340cb5e5dSvi * an ACK request.
34440cb5e5dSvi */
34540cb5e5dSvi trans = (sip_xaction_t *)malloc(sizeof (sip_xaction_t));
34640cb5e5dSvi if (trans == NULL) {
34740cb5e5dSvi if (error != NULL)
34840cb5e5dSvi *error = ENOMEM;
34940cb5e5dSvi return (NULL);
35040cb5e5dSvi }
35140cb5e5dSvi bzero(trans, sizeof (sip_xaction_t));
35240cb5e5dSvi if (branchid == NULL) {
35340cb5e5dSvi trans->sip_xaction_branch_id = (char *)sip_branchid(NULL);
35440cb5e5dSvi if (trans->sip_xaction_branch_id == NULL) {
35540cb5e5dSvi free(trans);
35640cb5e5dSvi if (error != NULL)
35740cb5e5dSvi *error = ENOMEM;
35840cb5e5dSvi return (NULL);
35940cb5e5dSvi }
36040cb5e5dSvi } else {
36140cb5e5dSvi trans->sip_xaction_branch_id = (char *)malloc(strlen(branchid)
36240cb5e5dSvi + 1);
36340cb5e5dSvi if (trans->sip_xaction_branch_id == NULL) {
36440cb5e5dSvi free(trans);
36540cb5e5dSvi if (error != NULL)
36640cb5e5dSvi *error = ENOMEM;
36740cb5e5dSvi return (NULL);
36840cb5e5dSvi }
36940cb5e5dSvi (void) strncpy(trans->sip_xaction_branch_id, branchid,
37040cb5e5dSvi strlen(branchid));
37140cb5e5dSvi trans->sip_xaction_branch_id[strlen(branchid)] = '\0';
37240cb5e5dSvi }
37340cb5e5dSvi (void) pthread_mutex_init(&trans->sip_xaction_mutex, NULL);
37440cb5e5dSvi SIP_MSG_REFCNT_INCR(msg);
37540cb5e5dSvi trans->sip_xaction_orig_msg = msg;
37640cb5e5dSvi assert(msg->sip_msg_req_res != NULL);
37740cb5e5dSvi sip_msg_info = msg->sip_msg_req_res;
37840cb5e5dSvi if (sip_msg_info->is_request) {
37940cb5e5dSvi method = sip_msg_info->sip_req_method;
38040cb5e5dSvi } else {
38140cb5e5dSvi method = sip_get_callseq_method((sip_msg_t)msg, &ret);
38240cb5e5dSvi if (ret != 0) {
38340cb5e5dSvi free(trans->sip_xaction_branch_id);
38440cb5e5dSvi free(trans);
38540cb5e5dSvi if (error != NULL)
38640cb5e5dSvi *error = ret;
38740cb5e5dSvi return (NULL);
38840cb5e5dSvi }
38940cb5e5dSvi if (method == INVITE)
39040cb5e5dSvi state = SIP_SRV_INV_PROCEEDING;
39140cb5e5dSvi else
39240cb5e5dSvi state = SIP_SRV_TRYING;
39340cb5e5dSvi }
39440cb5e5dSvi trans->sip_xaction_method = method;
39540cb5e5dSvi trans->sip_xaction_state = state;
39640cb5e5dSvi
39740cb5e5dSvi /*
39840cb5e5dSvi * Get connection object specific timeouts, if present
39940cb5e5dSvi */
40040cb5e5dSvi if (sip_conn_timer1 != NULL)
40140cb5e5dSvi timer1 = sip_conn_timer1(obj);
40240cb5e5dSvi if (sip_conn_timer4 != NULL)
40340cb5e5dSvi timer4 = sip_conn_timer4(obj);
40440cb5e5dSvi if (sip_conn_timerd != NULL)
40540cb5e5dSvi timerd = sip_conn_timerd(obj);
40640cb5e5dSvi
40740cb5e5dSvi SIP_INIT_TIMER(trans->sip_xaction_TA, 2 * timer1);
40840cb5e5dSvi SIP_INIT_TIMER(trans->sip_xaction_TB, 64 * timer1)
40940cb5e5dSvi SIP_INIT_TIMER(trans->sip_xaction_TD, timerd);
41040cb5e5dSvi SIP_INIT_TIMER(trans->sip_xaction_TE, timer1);
41140cb5e5dSvi SIP_INIT_TIMER(trans->sip_xaction_TF, 64 * timer1);
41240cb5e5dSvi SIP_INIT_TIMER(trans->sip_xaction_TG, 2 * timer1);
41340cb5e5dSvi SIP_INIT_TIMER(trans->sip_xaction_TH, 64 * timer1);
41440cb5e5dSvi SIP_INIT_TIMER(trans->sip_xaction_TI, timer4);
41540cb5e5dSvi SIP_INIT_TIMER(trans->sip_xaction_TJ, 64 * timer1);
41640cb5e5dSvi SIP_INIT_TIMER(trans->sip_xaction_TK, timer4);
41740cb5e5dSvi
41840cb5e5dSvi if ((ret = sip_xaction_add(trans, branchid, msg, method)) != 0) {
41940cb5e5dSvi (void) pthread_mutex_destroy(&trans->sip_xaction_mutex);
42040cb5e5dSvi free(trans->sip_xaction_branch_id);
42140cb5e5dSvi free(trans);
42240cb5e5dSvi if (error != NULL)
42340cb5e5dSvi *error = ret;
42440cb5e5dSvi return (NULL);
42540cb5e5dSvi }
42640cb5e5dSvi if (sip_xaction_ulp_state_cb != NULL &&
42740cb5e5dSvi prev_state != trans->sip_xaction_state) {
42840cb5e5dSvi sip_xaction_ulp_state_cb((sip_transaction_t)trans,
42940cb5e5dSvi (sip_msg_t)msg, prev_state, trans->sip_xaction_state);
43040cb5e5dSvi }
43140cb5e5dSvi return (trans);
43240cb5e5dSvi }
43340cb5e5dSvi
43440cb5e5dSvi /*
43540cb5e5dSvi * Find a transaction, create if asked for
43640cb5e5dSvi */
43740cb5e5dSvi sip_xaction_t *
sip_xaction_get(sip_conn_object_t obj,sip_msg_t msg,boolean_t create,int which,int * error)43840cb5e5dSvi sip_xaction_get(sip_conn_object_t obj, sip_msg_t msg, boolean_t create,
43940cb5e5dSvi int which, int *error)
44040cb5e5dSvi {
44140cb5e5dSvi char *branchid;
44240cb5e5dSvi sip_xaction_t *sip_trans;
44340cb5e5dSvi _sip_msg_t *_msg;
44440cb5e5dSvi sip_message_type_t *sip_msg_info;
44540cb5e5dSvi
44640cb5e5dSvi if (error != NULL)
44740cb5e5dSvi *error = 0;
44840cb5e5dSvi
44940cb5e5dSvi _msg = (_sip_msg_t *)msg;
45040cb5e5dSvi sip_msg_info = ((_sip_msg_t *)msg)->sip_msg_req_res;
45140cb5e5dSvi
45240cb5e5dSvi branchid = sip_get_branchid(msg, NULL);
45340cb5e5dSvi sip_trans = sip_xaction_find(branchid, _msg, which);
45440cb5e5dSvi if (sip_trans == NULL && create) {
45540cb5e5dSvi /*
45640cb5e5dSvi * If we are sending a request, must be conformant to RFC 3261.
45740cb5e5dSvi */
45840cb5e5dSvi if (sip_msg_info->is_request &&
45940cb5e5dSvi (branchid == NULL || strncmp(branchid,
46040cb5e5dSvi RFC_3261_BRANCH, strlen(RFC_3261_BRANCH) != 0))) {
46140cb5e5dSvi if (error != NULL)
46240cb5e5dSvi *error = EINVAL;
46340cb5e5dSvi if (branchid != NULL)
46440cb5e5dSvi free(branchid);
46540cb5e5dSvi return (NULL);
46640cb5e5dSvi }
46740cb5e5dSvi sip_trans = sip_xaction_create(obj, _msg, branchid, error);
46840cb5e5dSvi if (sip_trans != NULL)
46940cb5e5dSvi SIP_XACTION_REFCNT_INCR(sip_trans);
47040cb5e5dSvi }
47140cb5e5dSvi if (branchid != NULL)
47240cb5e5dSvi free(branchid);
47340cb5e5dSvi return (sip_trans);
47440cb5e5dSvi }
47540cb5e5dSvi
47640cb5e5dSvi
47740cb5e5dSvi /*
47840cb5e5dSvi * Delete a transaction if the reference count is 0. Passed to
47940cb5e5dSvi * sip_hash_delete().
48040cb5e5dSvi */
48140cb5e5dSvi boolean_t
sip_xaction_remove(void * obj,void * hindex,int * found)48240cb5e5dSvi sip_xaction_remove(void *obj, void *hindex, int *found)
48340cb5e5dSvi {
48440cb5e5dSvi sip_xaction_t *tmp = (sip_xaction_t *)obj;
485*943efbc3Sgm int count = 0;
486*943efbc3Sgm sip_msg_chain_t *msg_chain;
487*943efbc3Sgm sip_msg_chain_t *nmsg_chain;
48840cb5e5dSvi
48940cb5e5dSvi *found = 0;
49040cb5e5dSvi tmp = (sip_xaction_t *)obj;
49140cb5e5dSvi (void) pthread_mutex_lock(&tmp->sip_xaction_mutex);
49240cb5e5dSvi if (bcmp(tmp->sip_xaction_hash_digest, hindex,
49340cb5e5dSvi sizeof (tmp->sip_xaction_hash_digest)) == 0) {
49440cb5e5dSvi *found = 1;
49540cb5e5dSvi if (tmp->sip_xaction_ref_cnt != 0) {
49640cb5e5dSvi (void) pthread_mutex_unlock(&tmp->sip_xaction_mutex);
49740cb5e5dSvi return (B_FALSE);
49840cb5e5dSvi }
49940cb5e5dSvi (void) pthread_mutex_destroy(&tmp->sip_xaction_mutex);
50040cb5e5dSvi SIP_CANCEL_TIMER(tmp->sip_xaction_TA);
50140cb5e5dSvi SIP_CANCEL_TIMER(tmp->sip_xaction_TB);
50240cb5e5dSvi SIP_CANCEL_TIMER(tmp->sip_xaction_TD);
50340cb5e5dSvi SIP_CANCEL_TIMER(tmp->sip_xaction_TE);
50440cb5e5dSvi SIP_CANCEL_TIMER(tmp->sip_xaction_TF);
50540cb5e5dSvi SIP_CANCEL_TIMER(tmp->sip_xaction_TG);
50640cb5e5dSvi SIP_CANCEL_TIMER(tmp->sip_xaction_TH);
50740cb5e5dSvi SIP_CANCEL_TIMER(tmp->sip_xaction_TI);
50840cb5e5dSvi SIP_CANCEL_TIMER(tmp->sip_xaction_TJ);
50940cb5e5dSvi SIP_CANCEL_TIMER(tmp->sip_xaction_TK);
510*943efbc3Sgm sip_write_to_log((void *)tmp, SIP_TRANSACTION_LOG, NULL, 0);
51140cb5e5dSvi free(tmp->sip_xaction_branch_id);
51240cb5e5dSvi if (tmp->sip_xaction_last_msg != NULL) {
51340cb5e5dSvi SIP_MSG_REFCNT_DECR(tmp->sip_xaction_last_msg);
51440cb5e5dSvi tmp->sip_xaction_last_msg = NULL;
51540cb5e5dSvi }
51640cb5e5dSvi if (tmp->sip_xaction_orig_msg != NULL) {
51740cb5e5dSvi SIP_MSG_REFCNT_DECR(tmp->sip_xaction_orig_msg);
51840cb5e5dSvi tmp->sip_xaction_orig_msg = NULL;
51940cb5e5dSvi }
52040cb5e5dSvi if (tmp->sip_xaction_conn_obj != NULL) {
52140cb5e5dSvi sip_del_conn_obj_cache(tmp->sip_xaction_conn_obj,
52240cb5e5dSvi (void *)tmp);
52340cb5e5dSvi }
524*943efbc3Sgm /*
525*943efbc3Sgm * If the transaction logging is disabled before we could
526*943efbc3Sgm * write the captured messages into the transaction log, then
527*943efbc3Sgm * we need to free those captured messsages
528*943efbc3Sgm */
529*943efbc3Sgm for (count = 0; count <= SIP_SRV_NONINV_TERMINATED; count++) {
530*943efbc3Sgm msg_chain = tmp->sip_xaction_log[count].sip_msgs;
531*943efbc3Sgm while (msg_chain != NULL) {
532*943efbc3Sgm nmsg_chain = msg_chain->next;
533*943efbc3Sgm if (msg_chain->sip_msg != NULL)
534*943efbc3Sgm free(msg_chain->sip_msg);
535*943efbc3Sgm free(msg_chain);
536*943efbc3Sgm msg_chain = nmsg_chain;
537*943efbc3Sgm }
538*943efbc3Sgm }
53940cb5e5dSvi free(tmp);
54040cb5e5dSvi return (B_TRUE);
54140cb5e5dSvi }
54240cb5e5dSvi (void) pthread_mutex_unlock(&tmp->sip_xaction_mutex);
54340cb5e5dSvi return (B_FALSE);
54440cb5e5dSvi }
54540cb5e5dSvi
54640cb5e5dSvi /*
54740cb5e5dSvi * Delete a SIP transaction
54840cb5e5dSvi */
54940cb5e5dSvi void
sip_xaction_delete(sip_xaction_t * trans)55040cb5e5dSvi sip_xaction_delete(sip_xaction_t *trans)
55140cb5e5dSvi {
55240cb5e5dSvi int hindex;
55340cb5e5dSvi
55440cb5e5dSvi (void) pthread_mutex_lock(&trans->sip_xaction_mutex);
55540cb5e5dSvi hindex = SIP_DIGEST_TO_HASH(trans->sip_xaction_hash_digest);
55640cb5e5dSvi if (trans->sip_xaction_ref_cnt != 0) {
55740cb5e5dSvi (void) pthread_mutex_unlock(&trans->sip_xaction_mutex);
55840cb5e5dSvi return;
55940cb5e5dSvi }
56040cb5e5dSvi (void) pthread_mutex_unlock(&trans->sip_xaction_mutex);
56140cb5e5dSvi sip_hash_delete(sip_xaction_hash, trans->sip_xaction_hash_digest,
56240cb5e5dSvi hindex, sip_xaction_remove);
56340cb5e5dSvi }
56440cb5e5dSvi
56540cb5e5dSvi /*
56640cb5e5dSvi * Add a SIP transaction into the hash list.
56740cb5e5dSvi */
56840cb5e5dSvi int
sip_xaction_add(sip_xaction_t * trans,char * branchid,_sip_msg_t * msg,sip_method_t method)56940cb5e5dSvi sip_xaction_add(sip_xaction_t *trans, char *branchid, _sip_msg_t *msg,
57040cb5e5dSvi sip_method_t method)
57140cb5e5dSvi {
57240cb5e5dSvi uint16_t hash_index[8];
57340cb5e5dSvi
57440cb5e5dSvi if (sip_find_md5_digest(branchid, msg, hash_index, method) != 0)
57540cb5e5dSvi return (EINVAL);
57640cb5e5dSvi
57740cb5e5dSvi /*
57840cb5e5dSvi * trans is not in the list as yet, so no need to hold the lock
57940cb5e5dSvi */
58040cb5e5dSvi bcopy(hash_index, trans->sip_xaction_hash_digest, sizeof (hash_index));
58140cb5e5dSvi
58240cb5e5dSvi if (sip_hash_add(sip_xaction_hash, (void *)trans,
58340cb5e5dSvi SIP_DIGEST_TO_HASH(hash_index)) != 0) {
58440cb5e5dSvi return (ENOMEM);
58540cb5e5dSvi }
58640cb5e5dSvi return (0);
58740cb5e5dSvi }
58840cb5e5dSvi
58940cb5e5dSvi
59040cb5e5dSvi /*
59140cb5e5dSvi * Given a state, return the string - This is mostly for debug purposes
59240cb5e5dSvi */
59340cb5e5dSvi char *
sip_get_xaction_state(int state)59440cb5e5dSvi sip_get_xaction_state(int state)
59540cb5e5dSvi {
59640cb5e5dSvi switch (state) {
597*943efbc3Sgm case SIP_NEW_TRANSACTION:
598*943efbc3Sgm return ("SIP_NEW_TRANSACTION");
59940cb5e5dSvi case SIP_CLNT_CALLING:
60040cb5e5dSvi return ("SIP_CLNT_CALLING");
60140cb5e5dSvi case SIP_CLNT_INV_PROCEEDING:
60240cb5e5dSvi return ("SIP_CLNT_INV_PROCEEDING");
60340cb5e5dSvi case SIP_CLNT_INV_TERMINATED:
60440cb5e5dSvi return ("SIP_CLNT_INV_TERMINATED");
60540cb5e5dSvi case SIP_CLNT_INV_COMPLETED:
60640cb5e5dSvi return ("SIP_CLNT_INV_COMPLETED");
60740cb5e5dSvi case SIP_CLNT_TRYING:
60840cb5e5dSvi return ("SIP_CLNT_TRYING");
60940cb5e5dSvi case SIP_CLNT_NONINV_PROCEEDING:
61040cb5e5dSvi return ("SIP_CLNT_NONINV_PROCEEDING");
61140cb5e5dSvi case SIP_CLNT_NONINV_TERMINATED:
61240cb5e5dSvi return ("SIP_CLNT_NONINV_TERMINATED");
61340cb5e5dSvi case SIP_CLNT_NONINV_COMPLETED:
61440cb5e5dSvi return ("SIP_CLNT_NONINV_COMPLETED");
61540cb5e5dSvi case SIP_SRV_INV_PROCEEDING:
61640cb5e5dSvi return ("SIP_SRV_INV_PROCEEDING");
61740cb5e5dSvi case SIP_SRV_INV_COMPLETED:
61840cb5e5dSvi return ("SIP_SRV_INV_COMPLETED");
61940cb5e5dSvi case SIP_SRV_CONFIRMED:
62040cb5e5dSvi return ("SIP_SRV_CONFIRMED");
62140cb5e5dSvi case SIP_SRV_INV_TERMINATED:
62240cb5e5dSvi return ("SIP_SRV_INV_TERMINATED");
62340cb5e5dSvi case SIP_SRV_TRYING:
62440cb5e5dSvi return ("SIP_SRV_TRYING");
62540cb5e5dSvi case SIP_SRV_NONINV_PROCEEDING:
62640cb5e5dSvi return ("SIP_SRV_NONINV_PROCEEDING");
62740cb5e5dSvi case SIP_SRV_NONINV_COMPLETED:
62840cb5e5dSvi return ("SIP_SRV_NONINV_COMPLETED");
62940cb5e5dSvi case SIP_SRV_NONINV_TERMINATED:
63040cb5e5dSvi return ("SIP_SRV_NONINV_TERMINATED");
63140cb5e5dSvi default :
632*943efbc3Sgm return ("UNKNOWN");
63340cb5e5dSvi }
63440cb5e5dSvi }
63540cb5e5dSvi
63640cb5e5dSvi /*
63740cb5e5dSvi * Initialize the hash table etc.
63840cb5e5dSvi */
63940cb5e5dSvi void
sip_xaction_init(int (* ulp_trans_err)(sip_transaction_t,int,void *),void (* ulp_state_cb)(sip_transaction_t,sip_msg_t,int,int))64040cb5e5dSvi sip_xaction_init(int (*ulp_trans_err)(sip_transaction_t, int, void *),
64140cb5e5dSvi void (*ulp_state_cb)(sip_transaction_t, sip_msg_t, int, int))
64240cb5e5dSvi {
64340cb5e5dSvi int cnt;
64440cb5e5dSvi
64540cb5e5dSvi for (cnt = 0; cnt < SIP_HASH_SZ; cnt++) {
64640cb5e5dSvi sip_xaction_hash[cnt].hash_count = 0;
64740cb5e5dSvi sip_xaction_hash[cnt].hash_head = NULL;
64840cb5e5dSvi sip_xaction_hash[cnt].hash_tail = NULL;
64940cb5e5dSvi (void) pthread_mutex_init(
65040cb5e5dSvi &sip_xaction_hash[cnt].sip_hash_mutex, NULL);
65140cb5e5dSvi }
65240cb5e5dSvi if (ulp_trans_err != NULL)
65340cb5e5dSvi sip_xaction_ulp_trans_err = ulp_trans_err;
65440cb5e5dSvi if (ulp_state_cb != NULL)
65540cb5e5dSvi sip_xaction_ulp_state_cb = ulp_state_cb;
65640cb5e5dSvi }
657