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 <stdio.h> 30 #include <stdlib.h> 31 #include <assert.h> 32 #include <ctype.h> 33 #include <errno.h> 34 #include <strings.h> 35 #include <pthread.h> 36 #include <sip.h> 37 38 #include "sip_msg.h" 39 #include "sip_miscdefs.h" 40 #include "sip_parse_uri.h" 41 #include "sip_xaction.h" 42 43 #define SIP_BUF_SIZE 128 44 45 /* 46 * Find the header named header, consecutive calls with old_header 47 * passed in will return next header of the same type. 48 * If no name is passed the first header is returned. consectutive calls 49 * with no name but an old header will return the next header. 50 */ 51 const struct sip_header * sip_get_header(sip_msg_t sip_msg,char * header_name,sip_header_t old_header,int * error)52 sip_get_header(sip_msg_t sip_msg, char *header_name, sip_header_t old_header, 53 int *error) 54 { 55 _sip_msg_t *_sip_msg; 56 const struct sip_header *sip_hdr; 57 58 if (error != NULL) 59 *error = 0; 60 if (sip_msg == NULL) { 61 if (error != NULL) 62 *error = EINVAL; 63 return (NULL); 64 } 65 _sip_msg = (_sip_msg_t *)sip_msg; 66 (void) pthread_mutex_lock(&_sip_msg->sip_msg_mutex); 67 sip_hdr = (sip_header_t)sip_search_for_header((_sip_msg_t *)sip_msg, 68 header_name, (_sip_header_t *)old_header); 69 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 70 if (sip_hdr == NULL && error != NULL) 71 *error = EINVAL; 72 return (sip_hdr); 73 } 74 75 /* 76 * Return the request line as a string. Caller releases the returned string. 77 */ 78 char * sip_reqline_to_str(sip_msg_t sip_msg,int * error)79 sip_reqline_to_str(sip_msg_t sip_msg, int *error) 80 { 81 char *reqstr; 82 83 if (error != NULL) 84 *error = 0; 85 if (sip_msg == NULL || !sip_msg_is_request(sip_msg, error)) { 86 if (error != NULL) 87 *error = EINVAL; 88 return (NULL); 89 } 90 reqstr = _sip_startline_to_str((_sip_msg_t *)sip_msg, error); 91 return (reqstr); 92 } 93 94 /* 95 * Return the response line as a string. Caller releases the returned string. 96 */ 97 char * sip_respline_to_str(sip_msg_t sip_msg,int * error)98 sip_respline_to_str(sip_msg_t sip_msg, int *error) 99 { 100 char *respstr; 101 102 if (error != NULL) 103 *error = 0; 104 if (sip_msg == NULL || sip_msg_is_request(sip_msg, error)) { 105 if (error != NULL) 106 *error = EINVAL; 107 return (NULL); 108 } 109 respstr = _sip_startline_to_str((_sip_msg_t *)sip_msg, error); 110 return (respstr); 111 } 112 113 /* 114 * return the first value of the header 115 */ 116 const struct sip_value * sip_get_header_value(const struct sip_header * sip_header,int * error)117 sip_get_header_value(const struct sip_header *sip_header, int *error) 118 { 119 _sip_header_t *_sip_header; 120 sip_parsed_header_t *sip_parsed_header; 121 int ret = 0; 122 const struct sip_value *value; 123 124 if (error != NULL) 125 *error = 0; 126 if (sip_header == NULL) { 127 if (error != NULL) 128 *error = EINVAL; 129 return (NULL); 130 } 131 _sip_header = (_sip_header_t *)sip_header; 132 if (_sip_header->sip_hdr_sipmsg != NULL) { 133 (void) pthread_mutex_lock( 134 &_sip_header->sip_hdr_sipmsg->sip_msg_mutex); 135 } 136 if (_sip_header->sip_header_state == SIP_HEADER_DELETED) { 137 if (_sip_header->sip_hdr_sipmsg != NULL) { 138 (void) pthread_mutex_unlock( 139 &_sip_header->sip_hdr_sipmsg->sip_msg_mutex); 140 } 141 if (error != NULL) 142 *error = EINVAL; 143 return (NULL); 144 } 145 ret = _sip_header->sip_header_functions->header_parse_func( 146 _sip_header, &sip_parsed_header); 147 if (_sip_header->sip_hdr_sipmsg != NULL) { 148 (void) pthread_mutex_unlock 149 (&_sip_header->sip_hdr_sipmsg->sip_msg_mutex); 150 } 151 if (error != NULL) 152 *error = ret; 153 154 if (ret != 0) 155 return (NULL); 156 value = (sip_header_value_t)sip_parsed_header->value; 157 while (value != NULL && value->value_state == SIP_VALUE_DELETED) 158 value = value->next; 159 if (value != NULL && value->value_state == SIP_VALUE_BAD && 160 error != NULL) { 161 *error = EPROTO; 162 } 163 return ((sip_header_value_t)value); 164 } 165 166 /* 167 * Return the next value of the header. 168 */ 169 const struct sip_value * sip_get_next_value(sip_header_value_t old_value,int * error)170 sip_get_next_value(sip_header_value_t old_value, int *error) 171 { 172 const struct sip_value *value; 173 174 if (error != NULL) 175 *error = 0; 176 if (old_value == NULL || old_value->next == NULL) { 177 if (error != NULL) 178 *error = EINVAL; 179 return (NULL); 180 } 181 /* 182 * We never free the deleted values so no need to hold a lock. 183 */ 184 value = (sip_header_value_t)old_value->next; 185 while (value != NULL && value->value_state == SIP_VALUE_DELETED) 186 value = value->next; 187 if (value != NULL && value->value_state == SIP_VALUE_BAD && 188 error != NULL) { 189 *error = EPROTO; 190 } 191 return ((sip_header_value_t)value); 192 } 193 194 /* 195 * Given a SIP message, delete the header "header_name". 196 */ 197 int sip_delete_header_by_name(sip_msg_t msg,char * header_name)198 sip_delete_header_by_name(sip_msg_t msg, char *header_name) 199 { 200 _sip_msg_t *_msg = (_sip_msg_t *)msg; 201 sip_header_t sip_hdr; 202 _sip_header_t *_sip_hdr; 203 204 if (_msg == NULL || header_name == NULL) 205 return (EINVAL); 206 (void) pthread_mutex_lock(&_msg->sip_msg_mutex); 207 if (_msg->sip_msg_cannot_be_modified) { 208 (void) pthread_mutex_unlock(&_msg->sip_msg_mutex); 209 return (EPERM); 210 } 211 sip_hdr = (sip_header_t)sip_search_for_header(_msg, header_name, NULL); 212 if (sip_hdr == NULL) { 213 (void) pthread_mutex_unlock(&_msg->sip_msg_mutex); 214 return (EINVAL); 215 } 216 _sip_hdr = (_sip_header_t *)sip_hdr; 217 _sip_hdr->sip_header_state = SIP_HEADER_DELETED; 218 _sip_hdr->sip_hdr_sipmsg->sip_msg_len -= _sip_hdr->sip_hdr_end - 219 _sip_hdr->sip_hdr_start; 220 assert(_sip_hdr->sip_hdr_sipmsg->sip_msg_len >= 0); 221 if (_msg->sip_msg_buf != NULL) 222 _msg->sip_msg_modified = B_TRUE; 223 (void) pthread_mutex_unlock(&_msg->sip_msg_mutex); 224 225 return (0); 226 } 227 228 /* 229 * Mark the header as deleted. 230 */ 231 int sip_delete_header(sip_header_t sip_header)232 sip_delete_header(sip_header_t sip_header) 233 { 234 _sip_header_t *_sip_header; 235 236 if (sip_header == NULL) 237 return (EINVAL); 238 _sip_header = (_sip_header_t *)sip_header; 239 (void) pthread_mutex_lock(&_sip_header->sip_hdr_sipmsg->sip_msg_mutex); 240 if (_sip_header->sip_hdr_sipmsg->sip_msg_cannot_be_modified) { 241 (void) pthread_mutex_unlock 242 (&_sip_header->sip_hdr_sipmsg->sip_msg_mutex); 243 return (EPERM); 244 } 245 if (_sip_header->sip_header_state == SIP_HEADER_DELETED) { 246 (void) pthread_mutex_unlock( 247 &_sip_header->sip_hdr_sipmsg->sip_msg_mutex); 248 return (EINVAL); 249 } 250 _sip_header->sip_header_state = SIP_HEADER_DELETED; 251 _sip_header->sip_hdr_sipmsg->sip_msg_len -= _sip_header->sip_hdr_end - 252 _sip_header->sip_hdr_start; 253 assert(_sip_header->sip_hdr_sipmsg->sip_msg_len >= 0); 254 if (_sip_header->sip_hdr_sipmsg->sip_msg_buf != NULL) 255 _sip_header->sip_hdr_sipmsg->sip_msg_modified = B_TRUE; 256 (void) pthread_mutex_unlock 257 (&_sip_header->sip_hdr_sipmsg->sip_msg_mutex); 258 return (0); 259 } 260 261 /* 262 * Mark the value as deleted. 263 */ 264 int sip_delete_value(sip_header_t sip_header,sip_header_value_t sip_header_value)265 sip_delete_value(sip_header_t sip_header, sip_header_value_t sip_header_value) 266 { 267 _sip_header_t *_sip_header; 268 sip_value_t *_sip_header_value; 269 int vlen; 270 char *c; 271 272 if (sip_header == NULL || sip_header_value == NULL) 273 return (EINVAL); 274 _sip_header = (_sip_header_t *)sip_header; 275 (void) pthread_mutex_lock(&_sip_header->sip_hdr_sipmsg->sip_msg_mutex); 276 if (_sip_header->sip_hdr_sipmsg->sip_msg_cannot_be_modified) { 277 (void) pthread_mutex_unlock(&_sip_header-> 278 sip_hdr_sipmsg->sip_msg_mutex); 279 return (EPERM); 280 } 281 if (_sip_header->sip_header_state == SIP_HEADER_DELETED) { 282 (void) pthread_mutex_unlock( 283 &_sip_header->sip_hdr_sipmsg->sip_msg_mutex); 284 return (EINVAL); 285 } 286 _sip_header_value = (sip_value_t *)sip_header_value; 287 if (_sip_header_value->value_state == SIP_VALUE_DELETED) { 288 (void) pthread_mutex_unlock( 289 &_sip_header->sip_hdr_sipmsg->sip_msg_mutex); 290 return (EINVAL); 291 } 292 _sip_header->sip_header_state = SIP_HEADER_DELETED_VAL; 293 _sip_header_value->value_state = SIP_VALUE_DELETED; 294 vlen = _sip_header_value->value_end - _sip_header_value->value_start; 295 if (_sip_header->sip_hdr_parsed->value == _sip_header_value) { 296 c = _sip_header_value->value_start; 297 while (*c-- != SIP_HCOLON) 298 vlen++; 299 } else { 300 c = _sip_header_value->value_start; 301 while (*c-- != SIP_COMMA) 302 vlen++; 303 } 304 if (_sip_header_value->next == NULL) { 305 sip_value_t *value = _sip_header->sip_hdr_parsed->value; 306 boolean_t crlf_present = B_FALSE; 307 char *s; 308 309 while (value != NULL && value != _sip_header_value) { 310 crlf_present = B_FALSE; 311 312 if (value->value_state == SIP_VALUE_DELETED) { 313 value = value->next; 314 continue; 315 } 316 s = value->value_end; 317 while (s != value->value_start) { 318 if (*s == '\r' && strncmp(s, SIP_CRLF, 319 strlen(SIP_CRLF)) == 0) { 320 crlf_present = B_TRUE; 321 break; 322 } 323 s--; 324 } 325 value = value->next; 326 } 327 if (!crlf_present) { 328 c = _sip_header_value->value_end; 329 while (*c-- != '\r') 330 vlen--; 331 assert(vlen > 0); 332 } 333 } 334 _sip_header->sip_hdr_sipmsg->sip_msg_len -= vlen; 335 if (_sip_header->sip_hdr_sipmsg->sip_msg_buf != NULL) 336 _sip_header->sip_hdr_sipmsg->sip_msg_modified = B_TRUE; 337 (void) pthread_mutex_unlock 338 (&_sip_header->sip_hdr_sipmsg->sip_msg_mutex); 339 return (0); 340 } 341 342 /* 343 * Given a param list, check if a param name exists. 344 */ 345 boolean_t sip_is_param_present(const sip_param_t * param_list,char * param_name,int param_len)346 sip_is_param_present(const sip_param_t *param_list, char *param_name, 347 int param_len) 348 { 349 const sip_param_t *param = param_list; 350 351 while (param != NULL) { 352 if (param->param_name.sip_str_len == param_len && 353 strncasecmp(param->param_name.sip_str_ptr, param_name, 354 param_len) == 0) { 355 return (B_TRUE); 356 } 357 param = param->param_next; 358 } 359 return (B_FALSE); 360 } 361 362 363 /* 364 * Given a value header return the value of the named param. 365 */ 366 const sip_str_t * sip_get_param_value(sip_header_value_t header_value,char * param_name,int * error)367 sip_get_param_value(sip_header_value_t header_value, char *param_name, 368 int *error) 369 { 370 sip_value_t *_sip_header_value; 371 sip_param_t *sip_param; 372 373 if (error != NULL) 374 *error = 0; 375 if (header_value == NULL || param_name == NULL) { 376 if (error != NULL) 377 *error = EINVAL; 378 return (NULL); 379 } 380 _sip_header_value = (sip_value_t *)header_value; 381 if (_sip_header_value->value_state == SIP_VALUE_DELETED) { 382 if (error != NULL) 383 *error = EINVAL; 384 return (NULL); 385 } 386 if (_sip_header_value->param_list == NULL) { 387 if (error != NULL) 388 *error = EINVAL; 389 return (NULL); 390 } 391 sip_param = sip_get_param_from_list(_sip_header_value->param_list, 392 param_name); 393 if (sip_param != NULL) 394 return (&sip_param->param_value); 395 return (NULL); 396 } 397 398 /* 399 * Return the list of params in the header 400 */ 401 const sip_param_t * sip_get_params(sip_header_value_t header_value,int * error)402 sip_get_params(sip_header_value_t header_value, int *error) 403 { 404 sip_value_t *sip_header_value; 405 406 if (error != NULL) 407 *error = 0; 408 if (header_value == NULL) { 409 if (error != NULL) 410 *error = EINVAL; 411 return (NULL); 412 } 413 sip_header_value = (sip_value_t *)header_value; 414 if (sip_header_value->value_state == SIP_VALUE_DELETED) { 415 if (error != NULL) 416 *error = EINVAL; 417 return (NULL); 418 } 419 return (sip_header_value->param_list); 420 } 421 422 /* 423 * Return true if this is a SIP request 424 */ 425 boolean_t sip_msg_is_request(sip_msg_t sip_msg,int * error)426 sip_msg_is_request(sip_msg_t sip_msg, int *error) 427 { 428 _sip_msg_t *_sip_msg; 429 sip_message_type_t *sip_msg_info; 430 boolean_t ret; 431 432 if (error != NULL) 433 *error = 0; 434 if (sip_msg == NULL) { 435 if (error != NULL) 436 *error = EINVAL; 437 return (B_FALSE); 438 } 439 _sip_msg = (_sip_msg_t *)sip_msg; 440 (void) pthread_mutex_lock(&_sip_msg->sip_msg_mutex); 441 if (_sip_msg->sip_msg_req_res == NULL) { 442 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 443 if (error != NULL) 444 *error = EINVAL; 445 return (B_FALSE); 446 } 447 sip_msg_info = _sip_msg->sip_msg_req_res; 448 ret = sip_msg_info->is_request; 449 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 450 return (ret); 451 } 452 453 /* 454 * Return true if this is a SIP response 455 */ 456 boolean_t sip_msg_is_response(sip_msg_t sip_msg,int * error)457 sip_msg_is_response(sip_msg_t sip_msg, int *error) 458 { 459 boolean_t is_resp; 460 _sip_msg_t *_sip_msg; 461 sip_message_type_t *sip_msg_info; 462 463 if (error != NULL) 464 *error = 0; 465 if (sip_msg == NULL) { 466 if (error != NULL) 467 *error = EINVAL; 468 return (B_FALSE); 469 } 470 _sip_msg = (_sip_msg_t *)sip_msg; 471 (void) pthread_mutex_lock(&_sip_msg->sip_msg_mutex); 472 if (_sip_msg->sip_msg_req_res == NULL) { 473 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 474 if (error != NULL) 475 *error = EINVAL; 476 return (B_FALSE); 477 } 478 sip_msg_info = _sip_msg->sip_msg_req_res; 479 is_resp = !sip_msg_info->is_request; 480 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 481 return (is_resp); 482 } 483 484 /* 485 * Return the method in the request line 486 */ 487 sip_method_t sip_get_request_method(sip_msg_t sip_msg,int * error)488 sip_get_request_method(sip_msg_t sip_msg, int *error) 489 { 490 _sip_msg_t *_sip_msg; 491 sip_message_type_t *sip_msg_info; 492 sip_method_t ret = -1; 493 494 if (error != NULL) 495 *error = 0; 496 if (sip_msg == NULL) { 497 if (error != NULL) 498 *error = EINVAL; 499 return (ret); 500 } 501 _sip_msg = (_sip_msg_t *)sip_msg; 502 (void) pthread_mutex_lock(&_sip_msg->sip_msg_mutex); 503 sip_msg_info = _sip_msg->sip_msg_req_res; 504 if (_sip_msg->sip_msg_req_res == NULL) { 505 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 506 if (error != NULL) 507 *error = EINVAL; 508 return (ret); 509 } 510 if (sip_msg_info->is_request) 511 ret = sip_msg_info->sip_req_method; 512 else if (error != NULL) 513 *error = EINVAL; 514 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 515 return (ret); 516 } 517 518 /* 519 * Return the URI from the request line 520 */ 521 const sip_str_t * sip_get_request_uri_str(sip_msg_t sip_msg,int * error)522 sip_get_request_uri_str(sip_msg_t sip_msg, int *error) 523 { 524 _sip_msg_t *_sip_msg; 525 sip_message_type_t *sip_msg_info; 526 sip_str_t *ret = NULL; 527 struct sip_uri *parsed_uri; 528 529 if (error != NULL) 530 *error = 0; 531 if (sip_msg == NULL) { 532 if (error != NULL) 533 *error = EINVAL; 534 return (NULL); 535 } 536 _sip_msg = (_sip_msg_t *)sip_msg; 537 (void) pthread_mutex_lock(&_sip_msg->sip_msg_mutex); 538 if (_sip_msg->sip_msg_req_res == NULL) { 539 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 540 if (error != NULL) 541 *error = EINVAL; 542 return (NULL); 543 } 544 sip_msg_info = _sip_msg->sip_msg_req_res; 545 if (sip_msg_info->is_request) 546 ret = &sip_msg_info->sip_req_uri; 547 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 548 549 /* 550 * If the error is required, check the validity of the URI via 551 * sip_uri_parse(). 552 */ 553 if (error != NULL) { 554 parsed_uri = sip_parse_uri(ret, error); 555 if (parsed_uri != NULL) 556 sip_free_parsed_uri((sip_uri_t)parsed_uri); 557 } 558 return (ret); 559 } 560 561 /* 562 * Return the response code 563 */ 564 int sip_get_response_code(sip_msg_t sip_msg,int * error)565 sip_get_response_code(sip_msg_t sip_msg, int *error) 566 { 567 _sip_msg_t *_sip_msg; 568 sip_message_type_t *sip_msg_info; 569 int ret = -1; 570 571 if (error != NULL) 572 *error = 0; 573 if (sip_msg == NULL) { 574 if (error != NULL) 575 *error = EINVAL; 576 return (ret); 577 } 578 _sip_msg = (_sip_msg_t *)sip_msg; 579 (void) pthread_mutex_lock(&_sip_msg->sip_msg_mutex); 580 if (_sip_msg->sip_msg_req_res == NULL) { 581 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 582 if (error != NULL) 583 *error = EINVAL; 584 return (ret); 585 } 586 sip_msg_info = _sip_msg->sip_msg_req_res; 587 if (!sip_msg_info->is_request) 588 ret = sip_msg_info->sip_resp_code; 589 else if (error != NULL) 590 *error = EINVAL; 591 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 592 return (ret); 593 } 594 595 /* 596 * Get the response phrase 597 */ 598 const sip_str_t * sip_get_response_phrase(sip_msg_t sip_msg,int * error)599 sip_get_response_phrase(sip_msg_t sip_msg, int *error) 600 { 601 _sip_msg_t *_sip_msg; 602 sip_message_type_t *sip_msg_info; 603 sip_str_t *ret = NULL; 604 605 if (error != NULL) 606 *error = 0; 607 if (sip_msg == NULL) { 608 if (error != NULL) 609 *error = EINVAL; 610 return (ret); 611 } 612 _sip_msg = (_sip_msg_t *)sip_msg; 613 (void) pthread_mutex_lock(&_sip_msg->sip_msg_mutex); 614 if (_sip_msg->sip_msg_req_res == NULL) { 615 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 616 if (error != NULL) 617 *error = EINVAL; 618 return (ret); 619 } 620 sip_msg_info = _sip_msg->sip_msg_req_res; 621 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 622 if (!sip_msg_info->is_request) { 623 if (sip_msg_info->sip_resp_phrase_len == 0) 624 ret = NULL; 625 else 626 ret = &sip_msg_info->sip_resp_phrase; 627 } else if (error != NULL) { 628 *error = EINVAL; 629 } 630 return (ret); 631 } 632 633 /* 634 * Get the SIP version string 635 */ 636 const sip_str_t * sip_get_sip_version(sip_msg_t sip_msg,int * error)637 sip_get_sip_version(sip_msg_t sip_msg, int *error) 638 { 639 _sip_msg_t *_sip_msg; 640 sip_message_type_t *sip_msg_info; 641 sip_str_t *ret = NULL; 642 643 if (error != NULL) 644 *error = 0; 645 if (sip_msg == NULL) { 646 if (error != NULL) 647 *error = EINVAL; 648 return (ret); 649 } 650 _sip_msg = (_sip_msg_t *)sip_msg; 651 (void) pthread_mutex_lock(&_sip_msg->sip_msg_mutex); 652 if (_sip_msg->sip_msg_req_res == NULL) { 653 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 654 if (error != NULL) 655 *error = EINVAL; 656 return (ret); 657 } 658 sip_msg_info = _sip_msg->sip_msg_req_res; 659 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 660 ret = &sip_msg_info->sip_proto_version.version; 661 return (ret); 662 } 663 664 /* 665 * Return the length of the SIP message 666 */ 667 int sip_get_msg_len(sip_msg_t sip_msg,int * error)668 sip_get_msg_len(sip_msg_t sip_msg, int *error) 669 { 670 _sip_msg_t *_sip_msg; 671 672 if (error != NULL) 673 *error = 0; 674 if (sip_msg == NULL) { 675 if (error != NULL) 676 *error = EINVAL; 677 return (-1); 678 } 679 _sip_msg = (_sip_msg_t *)sip_msg; 680 681 return (_sip_msg->sip_msg_len); 682 } 683 684 /* 685 * Get content as a string. Caller frees the string 686 */ 687 char * sip_get_content(sip_msg_t sip_msg,int * error)688 sip_get_content(sip_msg_t sip_msg, int *error) 689 { 690 _sip_msg_t *_sip_msg; 691 sip_content_t *sip_content; 692 char *content; 693 int len; 694 char *p; 695 696 if (error != NULL) 697 *error = 0; 698 699 if (sip_msg == NULL) { 700 if (error != NULL) 701 *error = EINVAL; 702 return (NULL); 703 } 704 _sip_msg = (_sip_msg_t *)sip_msg; 705 (void) pthread_mutex_lock(&_sip_msg->sip_msg_mutex); 706 if (_sip_msg->sip_msg_content == NULL) { 707 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 708 if (error != NULL) 709 *error = EINVAL; 710 return (NULL); 711 } 712 content = malloc(_sip_msg->sip_msg_content_len + 1); 713 if (content == NULL) { 714 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 715 if (error != NULL) 716 *error = ENOMEM; 717 return (NULL); 718 } 719 p = content; 720 sip_content = _sip_msg->sip_msg_content; 721 while (sip_content != NULL) { 722 len = sip_content->sip_content_end - 723 sip_content->sip_content_start; 724 (void) strncpy(p, sip_content->sip_content_start, len); 725 p += len; 726 sip_content = sip_content->sip_content_next; 727 } 728 content[_sip_msg->sip_msg_content_len] = '\0'; 729 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 730 return (content); 731 } 732 733 /* 734 * copy sip_header with param, if any, to sip_msg 735 */ 736 int sip_copy_header(sip_msg_t sip_msg,sip_header_t sip_header,char * param)737 sip_copy_header(sip_msg_t sip_msg, sip_header_t sip_header, char *param) 738 { 739 _sip_msg_t *_sip_msg; 740 _sip_header_t *_sip_header; 741 int ret; 742 743 if (sip_msg == NULL || sip_header == NULL) 744 return (EINVAL); 745 _sip_msg = (_sip_msg_t *)sip_msg; 746 _sip_header = (_sip_header_t *)sip_header; 747 (void) pthread_mutex_lock(&_sip_msg->sip_msg_mutex); 748 if (_sip_msg->sip_msg_cannot_be_modified) { 749 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 750 return (EPERM); 751 } 752 if (_sip_header->sip_header_state == SIP_HEADER_DELETED) { 753 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 754 return (EINVAL); 755 } 756 757 ret = _sip_copy_header(_sip_msg, _sip_header, param, B_TRUE); 758 if (_sip_msg->sip_msg_buf != NULL) 759 _sip_msg->sip_msg_modified = B_TRUE; 760 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 761 return (ret); 762 } 763 764 /* 765 * copy the header specified by header_name, with param, if any 766 */ 767 int sip_copy_header_by_name(sip_msg_t old_msg,sip_msg_t new_msg,char * header_name,char * param)768 sip_copy_header_by_name(sip_msg_t old_msg, sip_msg_t new_msg, 769 char *header_name, char *param) 770 { 771 int ret; 772 _sip_msg_t *_old_msg = (_sip_msg_t *)old_msg; 773 _sip_msg_t *_new_msg = (_sip_msg_t *)new_msg; 774 775 if (_old_msg == NULL || _new_msg == NULL || header_name == NULL || 776 _old_msg == _new_msg) { 777 return (EINVAL); 778 } 779 (void) pthread_mutex_lock(&_new_msg->sip_msg_mutex); 780 if (_new_msg->sip_msg_cannot_be_modified) { 781 (void) pthread_mutex_unlock(&_new_msg->sip_msg_mutex); 782 return (EPERM); 783 } 784 785 (void) pthread_mutex_lock(&_old_msg->sip_msg_mutex); 786 ret = _sip_find_and_copy_header(_old_msg, _new_msg, header_name, param, 787 B_FALSE); 788 (void) pthread_mutex_unlock(&_old_msg->sip_msg_mutex); 789 if (_new_msg->sip_msg_buf != NULL) 790 _new_msg->sip_msg_modified = B_TRUE; 791 (void) pthread_mutex_unlock(&_new_msg->sip_msg_mutex); 792 return (ret); 793 } 794 795 /* 796 * add the given header to sip_message 797 */ 798 int sip_add_header(sip_msg_t sip_msg,char * header_string)799 sip_add_header(sip_msg_t sip_msg, char *header_string) 800 { 801 int header_size; 802 _sip_header_t *new_header; 803 _sip_msg_t *_sip_msg; 804 805 if (sip_msg == NULL || header_string == NULL) 806 return (EINVAL); 807 _sip_msg = (_sip_msg_t *)sip_msg; 808 (void) pthread_mutex_lock(&_sip_msg->sip_msg_mutex); 809 if (_sip_msg->sip_msg_cannot_be_modified) { 810 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 811 return (EPERM); 812 } 813 header_size = strlen(header_string) + strlen(SIP_CRLF); 814 new_header = sip_new_header(header_size); 815 if (new_header == NULL) { 816 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 817 return (ENOMEM); 818 } 819 820 (void) snprintf(new_header->sip_hdr_start, header_size + 1, "%s%s", 821 header_string, SIP_CRLF); 822 _sip_add_header(_sip_msg, new_header, B_TRUE, B_FALSE, NULL); 823 if (_sip_msg->sip_msg_buf != NULL) 824 _sip_msg->sip_msg_modified = B_TRUE; 825 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 826 return (0); 827 } 828 829 /* 830 * add the given param to the sip_header. create a new header with the param 831 * and mark the old header as deleted. 832 */ 833 sip_header_t sip_add_param(sip_header_t sip_header,char * param,int * error)834 sip_add_param(sip_header_t sip_header, char *param, int *error) 835 { 836 _sip_header_t *_sip_header; 837 _sip_header_t *new_header; 838 int hdrlen; 839 _sip_msg_t *_sip_msg; 840 int param_len; 841 char *tmp_ptr; 842 843 if (error != NULL) 844 *error = 0; 845 846 if (param == NULL || sip_header == NULL) { 847 if (error != NULL) 848 *error = EINVAL; 849 return (NULL); 850 } 851 852 _sip_header = (_sip_header_t *)sip_header; 853 854 (void) pthread_mutex_lock(&_sip_header->sip_hdr_sipmsg->sip_msg_mutex); 855 if (_sip_header->sip_hdr_sipmsg->sip_msg_cannot_be_modified) { 856 if (error != NULL) 857 *error = EPERM; 858 (void) pthread_mutex_unlock( 859 &_sip_header->sip_hdr_sipmsg->sip_msg_mutex); 860 return (NULL); 861 } 862 if (_sip_header->sip_header_state == SIP_HEADER_DELETED) { 863 if (error != NULL) 864 *error = EINVAL; 865 (void) pthread_mutex_unlock( 866 &_sip_header->sip_hdr_sipmsg->sip_msg_mutex); 867 return (NULL); 868 } 869 870 param_len = SIP_SPACE_LEN + sizeof (char) + SIP_SPACE_LEN + 871 strlen(param); 872 hdrlen = _sip_header->sip_hdr_end - _sip_header->sip_hdr_start; 873 new_header = sip_new_header(hdrlen + param_len); 874 if (new_header == NULL) { 875 if (error != NULL) 876 *error = ENOMEM; 877 (void) pthread_mutex_unlock( 878 &_sip_header->sip_hdr_sipmsg->sip_msg_mutex); 879 return (NULL); 880 } 881 (void) memcpy(new_header->sip_hdr_start, _sip_header->sip_hdr_start, 882 hdrlen); 883 new_header->sip_hdr_end = new_header->sip_hdr_start + hdrlen; 884 hdrlen = param_len + 1; 885 /* 886 * Find CRLF 887 */ 888 tmp_ptr = new_header->sip_hdr_end; 889 while (*tmp_ptr-- != '\n') { 890 hdrlen++; 891 if (tmp_ptr == new_header->sip_hdr_start) { 892 sip_free_header(new_header); 893 if (error != NULL) 894 *error = EINVAL; 895 (void) pthread_mutex_unlock( 896 &_sip_header->sip_hdr_sipmsg->sip_msg_mutex); 897 return (NULL); 898 } 899 } 900 (void) snprintf(tmp_ptr, hdrlen + 1, 901 " %c %s%s", SIP_SEMI, param, SIP_CRLF); 902 new_header->sip_hdr_end += param_len; 903 new_header->sip_header_functions = _sip_header->sip_header_functions; 904 _sip_msg = _sip_header->sip_hdr_sipmsg; 905 _sip_add_header(_sip_msg, new_header, B_TRUE, B_FALSE, NULL); 906 if (_sip_header->sip_hdr_sipmsg->sip_msg_buf != NULL) 907 _sip_header->sip_hdr_sipmsg->sip_msg_modified = B_TRUE; 908 (void) pthread_mutex_unlock(&new_header->sip_hdr_sipmsg->sip_msg_mutex); 909 (void) sip_delete_header(sip_header); 910 return ((sip_header_t)new_header); 911 } 912 913 /* 914 * Get Request URI 915 */ 916 const struct sip_uri * sip_get_request_uri(sip_msg_t sip_msg,int * error)917 sip_get_request_uri(sip_msg_t sip_msg, int *error) 918 { 919 _sip_msg_t *_sip_msg; 920 sip_message_type_t *sip_msg_info; 921 const struct sip_uri *ret = NULL; 922 923 if (error != NULL) 924 *error = 0; 925 926 if (sip_msg == NULL) { 927 if (error != NULL) 928 *error = EINVAL; 929 return (NULL); 930 } 931 _sip_msg = (_sip_msg_t *)sip_msg; 932 (void) pthread_mutex_lock(&_sip_msg->sip_msg_mutex); 933 sip_msg_info = _sip_msg->sip_msg_req_res; 934 if (sip_msg_info != NULL && sip_msg_info->is_request) { 935 ret = sip_msg_info->sip_req_parse_uri; 936 } else { 937 if (error != NULL) 938 *error = EINVAL; 939 } 940 (void) pthread_mutex_unlock(&_sip_msg->sip_msg_mutex); 941 942 if (ret != NULL) { 943 if (ret->sip_uri_scheme.sip_str_len == 0 || 944 ret->sip_uri_scheme.sip_str_ptr == NULL) { 945 ret = NULL; 946 if (error != NULL) 947 *error = EINVAL; 948 } else if (ret->sip_uri_errflags != 0 && error != NULL) { 949 *error = EINVAL; 950 } 951 } 952 return ((sip_uri_t)ret); 953 } 954 955 /* 956 * returns a comma separated string of all the sent-by values registered by 957 * the UA. 958 */ 959 char * sip_sent_by_to_str(int * error)960 sip_sent_by_to_str(int *error) 961 { 962 sent_by_list_t *sb; 963 int sb_len = 0; 964 int slen; 965 char *sb_str; 966 char *p; 967 int count = 0; 968 int cnt = 0; 969 970 if (error != NULL) 971 *error = 0; 972 973 (void) pthread_mutex_lock(&sip_sent_by_lock); 974 if (sip_sent_by == NULL) { 975 (void) pthread_mutex_unlock(&sip_sent_by_lock); 976 return (NULL); 977 } 978 sb = sip_sent_by; 979 for (cnt = 0; cnt < sip_sent_by_count; cnt++) { 980 sb_len += strlen(sb->sb_val); 981 sb = sb->sb_next; 982 } 983 /* 984 * for the commas 985 */ 986 sb_len += sip_sent_by_count - 1; 987 sb_str = malloc(sb_len + 1); 988 if (sb_str == NULL) { 989 if (error != NULL) 990 *error = ENOMEM; 991 (void) pthread_mutex_unlock(&sip_sent_by_lock); 992 return (NULL); 993 } 994 sb = sip_sent_by; 995 p = sb_str; 996 slen = sb_len + 1; 997 for (cnt = 0; cnt < sip_sent_by_count; cnt++) { 998 if (cnt == 0) { 999 count = snprintf(p, slen, "%s", sb->sb_val); 1000 } else { 1001 count = snprintf(p, slen, "%c%s", SIP_COMMA, 1002 sb->sb_val); 1003 } 1004 p += count; 1005 slen -= count; 1006 sb = sb->sb_next; 1007 } 1008 sb_str[sb_len] = '\0'; 1009 (void) pthread_mutex_unlock(&sip_sent_by_lock); 1010 return (sb_str); 1011 } 1012 1013 /* 1014 * A comma separated list of sent-by values. 1015 */ 1016 int sip_register_sent_by(char * val)1017 sip_register_sent_by(char *val) 1018 { 1019 sent_by_list_t *sb = NULL; 1020 sent_by_list_t *sb_tail = NULL; 1021 char *str; 1022 int count = 0; 1023 1024 if (val == NULL) 1025 return (EINVAL); 1026 str = strtok(val, ","); 1027 while (str != NULL) { 1028 int slen; 1029 char *start = str; 1030 char *end = str + strlen(str) - 1; 1031 1032 while (isspace(*start)) 1033 start++; 1034 while (isspace(*end)) 1035 end--; 1036 if (end <= start) 1037 goto err_ret; 1038 slen = end - start + 1; 1039 sb_tail = (sent_by_list_t *)malloc(sizeof (*sb_tail)); 1040 if (sb_tail == NULL) 1041 goto err_ret; 1042 sb_tail->sb_next = sb_tail->sb_prev = NULL; 1043 if ((sb_tail->sb_val = (char *)malloc(slen + 1)) == NULL) { 1044 free(sb_tail); 1045 goto err_ret; 1046 } 1047 (void) strncpy(sb_tail->sb_val, start, slen); 1048 sb_tail->sb_val[slen] = '\0'; 1049 if (sb == NULL) { 1050 sb = sb_tail; 1051 } else { 1052 sb_tail->sb_next = sb; 1053 sb->sb_prev = sb_tail; 1054 sb = sb_tail; 1055 } 1056 count++; 1057 str = strtok(NULL, ","); 1058 } 1059 sb_tail = sb; 1060 while (sb_tail->sb_next != NULL) 1061 sb_tail = sb_tail->sb_next; 1062 (void) pthread_mutex_lock(&sip_sent_by_lock); 1063 if (sip_sent_by != NULL) { 1064 sb_tail->sb_next = sip_sent_by; 1065 sip_sent_by->sb_prev = sb_tail; 1066 } 1067 sip_sent_by = sb; 1068 sip_sent_by_count += count; 1069 (void) pthread_mutex_unlock(&sip_sent_by_lock); 1070 return (0); 1071 err_ret: 1072 sb_tail = sb; 1073 for (; count > 0; count--) { 1074 sb = sb_tail->sb_next; 1075 free(sb_tail->sb_val); 1076 sb_tail->sb_next = NULL; 1077 sb_tail->sb_prev = NULL; 1078 free(sb_tail); 1079 sb_tail = sb; 1080 } 1081 return (EINVAL); 1082 } 1083 1084 /* 1085 * Un-register sent-by values; 'val' contains a comma separated list 1086 */ 1087 void sip_unregister_sent_by(char * val)1088 sip_unregister_sent_by(char *val) 1089 { 1090 sent_by_list_t *sb; 1091 char *str; 1092 int count = 0; 1093 1094 (void) pthread_mutex_lock(&sip_sent_by_lock); 1095 str = strtok(val, ","); 1096 while (str != NULL) { 1097 sb = sip_sent_by; 1098 for (count = 0; count < sip_sent_by_count; count++) { 1099 if (strncmp(sb->sb_val, str, strlen(str)) == 0) { 1100 if (sb == sip_sent_by) { 1101 if (sb->sb_next != NULL) 1102 sip_sent_by = sb->sb_next; 1103 else 1104 sip_sent_by = NULL; 1105 } else if (sb->sb_next == NULL) { 1106 sb->sb_prev->sb_next = NULL; 1107 } else { 1108 sb->sb_prev->sb_next = sb->sb_next; 1109 sb->sb_next->sb_prev = sb->sb_prev; 1110 } 1111 sip_sent_by_count--; 1112 sb->sb_next = NULL; 1113 sb->sb_prev = NULL; 1114 free(sb->sb_val); 1115 free(sb); 1116 break; 1117 } 1118 sb = sb->sb_next; 1119 } 1120 str = strtok(NULL, ","); 1121 } 1122 (void) pthread_mutex_unlock(&sip_sent_by_lock); 1123 } 1124 1125 /* 1126 * Un-register all the sent-by values 1127 */ 1128 void sip_unregister_all_sent_by()1129 sip_unregister_all_sent_by() 1130 { 1131 sent_by_list_t *sb; 1132 int count; 1133 1134 (void) pthread_mutex_lock(&sip_sent_by_lock); 1135 sb = sip_sent_by; 1136 for (count = 0; count < sip_sent_by_count; count++) { 1137 sip_sent_by = sb->sb_next; 1138 free(sb->sb_val); 1139 sb->sb_next = NULL; 1140 sb->sb_prev = NULL; 1141 free(sb); 1142 sb = sip_sent_by; 1143 } 1144 sip_sent_by = NULL; 1145 sip_sent_by_count = 0; 1146 (void) pthread_mutex_unlock(&sip_sent_by_lock); 1147 } 1148 1149 /* 1150 * Given a response code, return the corresponding phrase 1151 */ 1152 char * sip_get_resp_desc(int resp_code)1153 sip_get_resp_desc(int resp_code) 1154 { 1155 switch (resp_code) { 1156 case SIP_TRYING: 1157 return ("TRYING"); 1158 case SIP_RINGING: 1159 return ("RINGING"); 1160 case SIP_CALL_IS_BEING_FORWARDED: 1161 return ("CALL_IS_BEING_FORWARDED"); 1162 case SIP_QUEUED: 1163 return ("QUEUED"); 1164 case SIP_SESSION_PROGRESS: 1165 return ("SESSION_PROGRESS"); 1166 case SIP_OK: 1167 return ("OK"); 1168 case SIP_ACCEPTED: 1169 return ("ACCEPTED"); 1170 case SIP_MULTIPLE_CHOICES: 1171 return ("MULTIPLE_CHOICES"); 1172 case SIP_MOVED_PERMANENTLY: 1173 return ("MOVED_PERMANENTLY"); 1174 case SIP_MOVED_TEMPORARILY: 1175 return ("MOVED_TEMPORARILY"); 1176 case SIP_USE_PROXY: 1177 return ("USE_PROXY"); 1178 case SIP_ALTERNATIVE_SERVICE: 1179 return ("ALTERNATIVE_SERVICE"); 1180 case SIP_BAD_REQUEST: 1181 return ("BAD_REQUEST"); 1182 case SIP_UNAUTHORIZED: 1183 return ("UNAUTHORIZED"); 1184 case SIP_PAYMENT_REQUIRED: 1185 return ("PAYMENT_REQUIRED"); 1186 case SIP_FORBIDDEN: 1187 return ("FORBIDDEN"); 1188 case SIP_NOT_FOUND: 1189 return ("NOT_FOUND"); 1190 case SIP_METHOD_NOT_ALLOWED: 1191 return ("METHOD_NOT_ALLOWED"); 1192 case SIP_NOT_ACCEPTABLE: 1193 return ("NOT_ACCEPTABLE"); 1194 case SIP_PROXY_AUTH_REQUIRED: 1195 return ("PROXY_AUTH_REQUIRED"); 1196 case SIP_REQUEST_TIMEOUT: 1197 return ("REQUEST_TIMEOUT"); 1198 case SIP_GONE: 1199 return ("GONE"); 1200 case SIP_REQUEST_ENTITY_2_LARGE: 1201 return ("REQUEST_ENTITY_2_LARGE"); 1202 case SIP_REQUEST_URI_2_LONG: 1203 return ("REQUEST_URI_2_LONG"); 1204 case SIP_UNSUPPORTED_MEDIA_TYPE: 1205 return ("UNSUPPORTED_MEDIA_TYPE"); 1206 case SIP_UNSUPPORTED_URI_SCHEME: 1207 return ("UNSUPPORTED_URI_SCHEME"); 1208 case SIP_BAD_EXTENSION: 1209 return ("BAD_EXTENSION"); 1210 case SIP_EXTENSION_REQUIRED: 1211 return ("EXTENSION_REQUIRED"); 1212 case SIP_INTERVAL_2_BRIEF: 1213 return ("INTERVAL_2_BRIEF"); 1214 case SIP_TEMPORARILY_UNAVAIL: 1215 return ("TEMPORARILY_UNAVAIL"); 1216 case SIP_CALL_NON_EXISTANT: 1217 return ("CALL_NON_EXISTANT"); 1218 case SIP_LOOP_DETECTED: 1219 return ("LOOP_DETECTED"); 1220 case SIP_TOO_MANY_HOOPS: 1221 return ("TOO_MANY_HOOPS"); 1222 case SIP_ADDRESS_INCOMPLETE: 1223 return ("ADDRESS_INCOMPLETE"); 1224 case SIP_AMBIGUOUS: 1225 return ("AMBIGUOUS"); 1226 case SIP_BUSY_HERE: 1227 return ("BUSY_HERE"); 1228 case SIP_REQUEST_TERMINATED: 1229 return ("REQUEST_TERMINATED"); 1230 case SIP_NOT_ACCEPTABLE_HERE: 1231 return ("NOT_ACCEPTABLE_HERE"); 1232 case SIP_BAD_EVENT: 1233 return ("BAD_EVENT"); 1234 case SIP_REQUEST_PENDING: 1235 return ("REQUEST_PENDING"); 1236 case SIP_UNDECIPHERABLE: 1237 return ("UNDECIPHERABLE"); 1238 case SIP_SERVER_INTERNAL_ERROR: 1239 return ("SERVER_INTERNAL_ERROR"); 1240 case SIP_NOT_IMPLEMENTED: 1241 return ("NOT_IMPLEMENTED"); 1242 case SIP_BAD_GATEWAY: 1243 return ("BAD_GATEWAY"); 1244 case SIP_SERVICE_UNAVAILABLE: 1245 return ("SERVICE_UNAVAILABLE"); 1246 case SIP_SERVER_TIMEOUT: 1247 return ("SERVER_TIMEOUT"); 1248 case SIP_VERSION_NOT_SUPPORTED: 1249 return ("VERSION_NOT_SUPPORTED"); 1250 case SIP_MESSAGE_2_LARGE: 1251 return ("MESSAGE_2_LARGE"); 1252 case SIP_BUSY_EVERYWHERE: 1253 return ("BUSY_EVERYWHERE"); 1254 case SIP_DECLINE: 1255 return ("DECLINE"); 1256 case SIP_DOES_NOT_EXIST_ANYWHERE: 1257 return ("DOES_NOT_EXIST_ANYWHERE"); 1258 case SIP_NOT_ACCEPTABLE_ANYWHERE: 1259 return ("NOT_ACCEPTABLE_ANYWHERE"); 1260 default: 1261 return ("UNKNOWN"); 1262 } 1263 } 1264 1265 /* 1266 * The following three fns initialize and destroy the private library 1267 * data in sip_conn_object_t. The assumption is that the 1st member 1268 * of sip_conn_object_t is reserved for library use. The private data 1269 * is used only for byte-stream protocols such as TCP to accumulate 1270 * a complete SIP message, based on the CONTENT-LENGTH value, before 1271 * processing it. 1272 */ 1273 int sip_init_conn_object(sip_conn_object_t obj)1274 sip_init_conn_object(sip_conn_object_t obj) 1275 { 1276 void **obj_val; 1277 sip_conn_obj_pvt_t *pvt_data; 1278 1279 if (obj == NULL) 1280 return (EINVAL); 1281 pvt_data = malloc(sizeof (sip_conn_obj_pvt_t)); 1282 if (pvt_data == NULL) 1283 return (ENOMEM); 1284 pvt_data->sip_conn_obj_cache = NULL; 1285 pvt_data->sip_conn_obj_reass = malloc(sizeof (sip_reass_entry_t)); 1286 if (pvt_data->sip_conn_obj_reass == NULL) { 1287 free(pvt_data); 1288 return (ENOMEM); 1289 } 1290 bzero(pvt_data->sip_conn_obj_reass, sizeof (sip_reass_entry_t)); 1291 (void) pthread_mutex_init(&pvt_data->sip_conn_obj_reass_lock, NULL); 1292 (void) pthread_mutex_init(&pvt_data->sip_conn_obj_cache_lock, NULL); 1293 sip_refhold_conn(obj); 1294 obj_val = (void *)obj; 1295 *obj_val = (void *)pvt_data; 1296 1297 return (0); 1298 } 1299 1300 /* 1301 * Clear private date, if any 1302 */ 1303 void sip_clear_stale_data(sip_conn_object_t obj)1304 sip_clear_stale_data(sip_conn_object_t obj) 1305 { 1306 void **obj_val; 1307 sip_conn_obj_pvt_t *pvt_data; 1308 sip_reass_entry_t *reass; 1309 1310 if (obj == NULL) 1311 return; 1312 obj_val = (void *)obj; 1313 pvt_data = (sip_conn_obj_pvt_t *)*obj_val; 1314 (void) pthread_mutex_lock(&pvt_data->sip_conn_obj_reass_lock); 1315 reass = pvt_data->sip_conn_obj_reass; 1316 if (reass->sip_reass_msg != NULL) { 1317 assert(reass->sip_reass_msglen > 0); 1318 free(reass->sip_reass_msg); 1319 reass->sip_reass_msglen = 0; 1320 } 1321 assert(reass->sip_reass_msglen == 0); 1322 (void) pthread_mutex_unlock(&pvt_data->sip_conn_obj_reass_lock); 1323 } 1324 1325 /* 1326 * Walk through all the transactions, remove if this obj has been cached 1327 * by any. 1328 */ 1329 void sip_conn_destroyed(sip_conn_object_t obj)1330 sip_conn_destroyed(sip_conn_object_t obj) 1331 { 1332 void **obj_val; 1333 sip_conn_obj_pvt_t *pvt_data; 1334 1335 if (obj == NULL) 1336 return; 1337 obj_val = (void *)obj; 1338 pvt_data = (sip_conn_obj_pvt_t *)*obj_val; 1339 1340 sip_clear_stale_data(obj); 1341 free(pvt_data->sip_conn_obj_reass); 1342 pvt_data->sip_conn_obj_reass = NULL; 1343 (void) pthread_mutex_destroy(&pvt_data->sip_conn_obj_reass_lock); 1344 1345 sip_del_conn_obj_cache(obj, NULL); 1346 (void) pthread_mutex_destroy(&pvt_data->sip_conn_obj_cache_lock); 1347 1348 free(pvt_data); 1349 *obj_val = NULL; 1350 sip_refrele_conn(obj); 1351 } 1352