40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi/*
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * CDDL HEADER START
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi *
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * The contents of this file are subject to the terms of the
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * Common Development and Distribution License (the "License").
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * You may not use this file except in compliance with the License.
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi *
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * or http://www.opensolaris.org/os/licensing.
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * See the License for the specific language governing permissions
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * and limitations under the License.
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi *
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * When distributing Covered Code, include this CDDL HEADER in each
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * If applicable, add the following below this CDDL HEADER, with the
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * fields enclosed by brackets "[]" replaced with your own identifying
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * information: Portions Copyright [yyyy] [name of copyright owner]
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi *
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * CDDL HEADER END
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi */
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi/*
2c2c41837e330b002c4220a39638150db504fe0evi * Copyright 2007 Sun Microsystems, Inc. All rights reserved.
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * Use is subject to license terms.
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi */
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi#pragma ident "%Z%%M% %I% %E% SMI"
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi
2c2c41837e330b002c4220a39638150db504fe0evi#include <stdlib.h>
2c2c41837e330b002c4220a39638150db504fe0evi#include <assert.h>
2c2c41837e330b002c4220a39638150db504fe0evi#include <errno.h>
2c2c41837e330b002c4220a39638150db504fe0evi#include <strings.h>
2c2c41837e330b002c4220a39638150db504fe0evi#include <pthread.h>
2c2c41837e330b002c4220a39638150db504fe0evi#include <sip.h>
2c2c41837e330b002c4220a39638150db504fe0evi
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi#include "sip_msg.h"
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi#include "sip_miscdefs.h"
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi#include "sip_xaction.h"
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi/*
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * Hold transaction
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi */
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vivoid
40cb5e5daa7b80bb70fcf8dadfb20f9281566331visip_hold_trans(sip_transaction_t sip_trans)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi{
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi sip_xaction_t *_trans;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (sip_trans == NULL)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi return;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi _trans = (sip_xaction_t *)sip_trans;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi (void) pthread_mutex_lock(&((_trans)->sip_xaction_mutex));
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi SIP_XACTION_REFCNT_INCR(_trans);
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi (void) pthread_mutex_unlock(&((_trans)->sip_xaction_mutex));
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi}
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi/*
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * Release transaction
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi */
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vivoid
40cb5e5daa7b80bb70fcf8dadfb20f9281566331visip_release_trans(sip_transaction_t sip_trans)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi{
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi sip_xaction_t *_trans;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (sip_trans == NULL)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi return;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi _trans = (sip_xaction_t *)sip_trans;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi SIP_XACTION_REFCNT_DECR(_trans);
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi}
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi/*
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * Given a message get the client/server transaction. The caller is
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * responsible for doing a sip_release_trans().
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi */
40cb5e5daa7b80bb70fcf8dadfb20f9281566331viconst struct sip_xaction *
40cb5e5daa7b80bb70fcf8dadfb20f9281566331visip_get_trans(sip_msg_t sip_msg, int which, int *error)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi{
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (error != NULL)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi *error = 0;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (sip_msg == NULL) {
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (error != NULL)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi *error = EINVAL;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi return (NULL);
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi }
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi return ((sip_transaction_t)sip_xaction_get(NULL, sip_msg, B_FALSE,
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi which, NULL));
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi}
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi/*
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * Get the last response sent for this transaction
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi */
40cb5e5daa7b80bb70fcf8dadfb20f9281566331viconst struct sip_message *
40cb5e5daa7b80bb70fcf8dadfb20f9281566331visip_get_trans_resp_msg(sip_transaction_t sip_trans, int *error)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi{
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi sip_xaction_t *_trans;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (error != NULL)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi *error = 0;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (sip_trans == NULL) {
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (error != NULL)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi *error = EINVAL;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi return (NULL);
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi }
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi _trans = (sip_xaction_t *)sip_trans;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if ((_trans->sip_xaction_last_msg != NULL) &&
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi !sip_msg_is_request((sip_msg_t)_trans->sip_xaction_last_msg,
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi error)) {
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi return (_trans->sip_xaction_last_msg);
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi } else if (!sip_msg_is_request((sip_msg_t)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi _trans->sip_xaction_orig_msg, error)) {
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi return (_trans->sip_xaction_orig_msg);
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi }
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi return (NULL);
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi}
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi/*
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * Get the SIP message that created this transaction
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi */
40cb5e5daa7b80bb70fcf8dadfb20f9281566331viconst struct sip_message *
40cb5e5daa7b80bb70fcf8dadfb20f9281566331visip_get_trans_orig_msg(sip_transaction_t sip_trans, int *error)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi{
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (error != NULL)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi *error = 0;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (sip_trans == NULL) {
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (error != NULL)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi *error = EINVAL;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi return (NULL);
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi }
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi return (((sip_xaction_t *)sip_trans)->sip_xaction_orig_msg);
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi}
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi/*
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * Get the connection object that was used to send the last message for this
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * transaction.
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi */
40cb5e5daa7b80bb70fcf8dadfb20f9281566331viconst struct sip_conn_object *
40cb5e5daa7b80bb70fcf8dadfb20f9281566331visip_get_trans_conn_obj(sip_transaction_t sip_trans, int *error)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi{
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (error != NULL)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi *error = 0;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (sip_trans == NULL) {
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (error != NULL)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi *error = EINVAL;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi return (NULL);
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi }
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi return (((sip_xaction_t *)sip_trans)->sip_xaction_conn_obj);
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi}
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi/*
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * Get the transaction method
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi */
40cb5e5daa7b80bb70fcf8dadfb20f9281566331visip_method_t
40cb5e5daa7b80bb70fcf8dadfb20f9281566331visip_get_trans_method(sip_transaction_t sip_trans, int *error)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi{
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (error != NULL)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi *error = 0;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (sip_trans == NULL) {
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (error != NULL)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi *error = EINVAL;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi return (-1);
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi }
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi return (((sip_xaction_t *)sip_trans)->sip_xaction_method);
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi}
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi/*
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * Get the transaction id. Caller frees string
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi */
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vichar *
40cb5e5daa7b80bb70fcf8dadfb20f9281566331visip_get_trans_branchid(sip_transaction_t trans, int *error)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi{
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi sip_xaction_t *xaction = (sip_xaction_t *)trans;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi char *bid;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (error != NULL)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi *error = 0;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (xaction == NULL || xaction->sip_xaction_branch_id == NULL) {
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (error != NULL)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi *error = EINVAL;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi return (NULL);
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi }
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi bid = malloc(strlen(xaction->sip_xaction_branch_id) + 1);
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (bid == NULL) {
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (error != NULL)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi *error = ENOMEM;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi return (NULL);
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi }
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi (void) strncpy(bid, xaction->sip_xaction_branch_id,
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi strlen(xaction->sip_xaction_branch_id));
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi bid[strlen(xaction->sip_xaction_branch_id)] = '\0';
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi return (bid);
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi}
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi/*
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi * Get the transaction state
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi */
40cb5e5daa7b80bb70fcf8dadfb20f9281566331viint
40cb5e5daa7b80bb70fcf8dadfb20f9281566331visip_get_trans_state(sip_transaction_t trans, int *error)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi{
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi sip_xaction_t *xaction = (sip_xaction_t *)trans;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (error != NULL)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi *error = 0;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (xaction == NULL) {
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi if (error != NULL)
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi *error = EINVAL;
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi return (NULL);
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi }
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi return (xaction->sip_xaction_state);
40cb5e5daa7b80bb70fcf8dadfb20f9281566331vi}