1 /*
2 * CDDL HEADER START
3 *
4 * The contents of this file are subject to the terms of the
5 * Common Development and Distribution License (the "License").
6 * You may not use this file except in compliance with the License.
7 *
8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9 * or http://www.opensolaris.org/os/licensing.
10 * See the License for the specific language governing permissions
11 * and limitations under the License.
12 *
13 * When distributing Covered Code, include this CDDL HEADER in each
14 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15 * If applicable, add the following below this CDDL HEADER, with the
16 * fields enclosed by brackets "[]" replaced with your own identifying
17 * information: Portions Copyright [yyyy] [name of copyright owner]
18 *
19 * CDDL HEADER END
20 */
21
22 /*
23 * Copyright 2007 Sun Microsystems, Inc. All rights reserved.
24 * Use is subject to license terms.
25 */
26
27 #pragma ident "%Z%%M% %I% %E% SMI"
28
29 #include <stdlib.h>
30 #include <assert.h>
31 #include <errno.h>
32 #include <strings.h>
33 #include <pthread.h>
34 #include <sip.h>
35
36 #include "sip_msg.h"
37 #include "sip_miscdefs.h"
38 #include "sip_xaction.h"
39
40 /*
41 * Hold transaction
42 */
43 void
sip_hold_trans(sip_transaction_t sip_trans)44 sip_hold_trans(sip_transaction_t sip_trans)
45 {
46 sip_xaction_t *_trans;
47
48 if (sip_trans == NULL)
49 return;
50 _trans = (sip_xaction_t *)sip_trans;
51 (void) pthread_mutex_lock(&((_trans)->sip_xaction_mutex));
52 SIP_XACTION_REFCNT_INCR(_trans);
53 (void) pthread_mutex_unlock(&((_trans)->sip_xaction_mutex));
54 }
55
56 /*
57 * Release transaction
58 */
59 void
sip_release_trans(sip_transaction_t sip_trans)60 sip_release_trans(sip_transaction_t sip_trans)
61 {
62 sip_xaction_t *_trans;
63
64 if (sip_trans == NULL)
65 return;
66 _trans = (sip_xaction_t *)sip_trans;
67 SIP_XACTION_REFCNT_DECR(_trans);
68 }
69
70 /*
71 * Given a message get the client/server transaction. The caller is
72 * responsible for doing a sip_release_trans().
73 */
74 const struct sip_xaction *
sip_get_trans(sip_msg_t sip_msg,int which,int * error)75 sip_get_trans(sip_msg_t sip_msg, int which, int *error)
76 {
77 if (error != NULL)
78 *error = 0;
79 if (sip_msg == NULL) {
80 if (error != NULL)
81 *error = EINVAL;
82 return (NULL);
83 }
84 return ((sip_transaction_t)sip_xaction_get(NULL, sip_msg, B_FALSE,
85 which, NULL));
86 }
87
88 /*
89 * Get the last response sent for this transaction
90 */
91 const struct sip_message *
sip_get_trans_resp_msg(sip_transaction_t sip_trans,int * error)92 sip_get_trans_resp_msg(sip_transaction_t sip_trans, int *error)
93 {
94 sip_xaction_t *_trans;
95
96 if (error != NULL)
97 *error = 0;
98 if (sip_trans == NULL) {
99 if (error != NULL)
100 *error = EINVAL;
101 return (NULL);
102 }
103 _trans = (sip_xaction_t *)sip_trans;
104 if ((_trans->sip_xaction_last_msg != NULL) &&
105 !sip_msg_is_request((sip_msg_t)_trans->sip_xaction_last_msg,
106 error)) {
107 return (_trans->sip_xaction_last_msg);
108 } else if (!sip_msg_is_request((sip_msg_t)
109 _trans->sip_xaction_orig_msg, error)) {
110 return (_trans->sip_xaction_orig_msg);
111 }
112 return (NULL);
113 }
114
115 /*
116 * Get the SIP message that created this transaction
117 */
118 const struct sip_message *
sip_get_trans_orig_msg(sip_transaction_t sip_trans,int * error)119 sip_get_trans_orig_msg(sip_transaction_t sip_trans, int *error)
120 {
121 if (error != NULL)
122 *error = 0;
123 if (sip_trans == NULL) {
124 if (error != NULL)
125 *error = EINVAL;
126 return (NULL);
127 }
128 return (((sip_xaction_t *)sip_trans)->sip_xaction_orig_msg);
129 }
130
131 /*
132 * Get the connection object that was used to send the last message for this
133 * transaction.
134 */
135 const struct sip_conn_object *
sip_get_trans_conn_obj(sip_transaction_t sip_trans,int * error)136 sip_get_trans_conn_obj(sip_transaction_t sip_trans, int *error)
137 {
138 if (error != NULL)
139 *error = 0;
140 if (sip_trans == NULL) {
141 if (error != NULL)
142 *error = EINVAL;
143 return (NULL);
144 }
145 return (((sip_xaction_t *)sip_trans)->sip_xaction_conn_obj);
146 }
147
148 /*
149 * Get the transaction method
150 */
151 sip_method_t
sip_get_trans_method(sip_transaction_t sip_trans,int * error)152 sip_get_trans_method(sip_transaction_t sip_trans, int *error)
153 {
154 if (error != NULL)
155 *error = 0;
156
157 if (sip_trans == NULL) {
158 if (error != NULL)
159 *error = EINVAL;
160 return (-1);
161 }
162 return (((sip_xaction_t *)sip_trans)->sip_xaction_method);
163 }
164
165 /*
166 * Get the transaction id. Caller frees string
167 */
168 char *
sip_get_trans_branchid(sip_transaction_t trans,int * error)169 sip_get_trans_branchid(sip_transaction_t trans, int *error)
170 {
171 sip_xaction_t *xaction = (sip_xaction_t *)trans;
172 char *bid;
173
174 if (error != NULL)
175 *error = 0;
176 if (xaction == NULL || xaction->sip_xaction_branch_id == NULL) {
177 if (error != NULL)
178 *error = EINVAL;
179 return (NULL);
180 }
181 bid = malloc(strlen(xaction->sip_xaction_branch_id) + 1);
182 if (bid == NULL) {
183 if (error != NULL)
184 *error = ENOMEM;
185 return (NULL);
186 }
187 (void) strncpy(bid, xaction->sip_xaction_branch_id,
188 strlen(xaction->sip_xaction_branch_id));
189 bid[strlen(xaction->sip_xaction_branch_id)] = '\0';
190 return (bid);
191 }
192
193 /*
194 * Get the transaction state
195 */
196 int
sip_get_trans_state(sip_transaction_t trans,int * error)197 sip_get_trans_state(sip_transaction_t trans, int *error)
198 {
199 sip_xaction_t *xaction = (sip_xaction_t *)trans;
200
201 if (error != NULL)
202 *error = 0;
203 if (xaction == NULL) {
204 if (error != NULL)
205 *error = EINVAL;
206 return (NULL);
207 }
208 return (xaction->sip_xaction_state);
209 }
210