236 #include <inttypes.h> 281 #include "sip/include/dialplan_functions.h" 688 .resync_threshold = 1000,
724 {
NONE,
"-",
"unknown",
"unknown" },
726 {
DIALOG_INFO_XML,
"dialog",
"application/dialog-info+xml",
"dialog-info+xml" },
727 {
CPIM_PIDF_XML,
"presence",
"application/cpim-pidf+xml",
"cpim-pidf+xml" },
728 {
PIDF_XML,
"presence",
"application/pidf+xml",
"pidf+xml" },
729 {
XPIDF_XML,
"presence",
"application/xpidf+xml",
"xpidf+xml" },
730 {
MWI_NOTIFICATION,
"message-summary",
"application/simple-message-summary",
"mwi" }
817 #define SIP_PEDANTIC_DECODE(str) \ 818 if (sip_cfg.pedanticsipchecking && !ast_strlen_zero(str)) { \ 819 ast_uri_decode(str, ast_uri_sip_user); \ 952 static const struct {
962 static const struct {
1048 #define sip_pvt_lock(x) ao2_lock(x) 1049 #define sip_pvt_trylock(x) ao2_trylock(x) 1050 #define sip_pvt_unlock(x) ao2_unlock(x) 1062 #define BOGUS_PEER_MD5SECRET "intentionally_invalid_md5_string" 1080 #define SIP_TRANSPORT_STR_BUFSIZE 128 1161 #define UNLINK(element, head, prev) do { \ 1163 (prev)->next = (element)->next; \ 1165 (head) = (element)->next; \ 1243 const char *
file,
int line,
const char *func);
1244 #define find_call(req, addr, intended_method) \ 1245 __find_call(req, addr, intended_method, __FILE__, __LINE__, __PRETTY_FUNCTION__) 1283 int debug,
int *min_packet_size,
int *max_packet_size);
1295 const char *secret,
const char *md5secret,
int sipmethod,
1341 #define peer_in_destruction(peer) (ao2_ref(peer, 0) == 0) 1393 const char *
name,
int flag,
unsigned int transport);
1452 static const char *
find_alias(
const char *
name,
const char *_default);
1555 static int parse_minse(
const char *p_hdrval,
int *
const p_interval);
1579 .description =
"Session Initiation Protocol (SIP)",
1677 .name =
"call-completion",
1705 if (!(epa_entry =
ao2_t_alloc(
sizeof(*epa_entry), static_data->
destructor,
"Allocate new EPA entry"))) {
1805 expires_ms = expires * 1000;
1847 const char *uri = arg;
1862 const char *uri = arg;
1877 struct sip_pvt *call_pvt = arg;
2029 return monitor_instance->
core_id;
2053 ao2_t_ref(monitor_instance->
suspension_entry, -1,
"Decrementing suspension entry refcount in sip_monitor_instance_destructor");
2062 if (!monitor_instance) {
2067 ao2_ref(monitor_instance, -1);
2075 ao2_link(sip_monitor_instances, monitor_instance);
2076 return monitor_instance;
2112 if (!monitor_instance) {
2133 ao2_t_ref(monitor, +1,
"Adding a ref to the monitor for the scheduler");
2148 ast_str_append(&body, 0,
"<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n");
2155 ast_str_append(&body, 0,
"<presence xmlns=\"urn:ietf:params:xml:ns:pidf\" entity=\"%s\">\n", presentity);
2157 ast_str_append(&body, 0,
"<status><basic>%s</basic></status>\n", state ==
CC_OPEN ?
"open" :
"closed");
2170 if (!monitor_instance) {
2178 ao2_ref(monitor_instance, -1);
2181 if (!(cc_entry =
ast_calloc(1,
sizeof(*cc_entry)))) {
2182 ast_log(
LOG_WARNING,
"Unable to allocate space for instance data of EPA entry for call-completion\n");
2183 ao2_ref(monitor_instance, -1);
2220 if (!monitor_instance) {
2241 if (*sched_id != -1) {
2243 ao2_t_ref(monitor, -1,
"Removing scheduler's reference to the monitor");
2251 ao2_unlink(sip_monitor_instances, monitor_instance);
2261 static const char cc_purpose[] =
"purpose=call-completion";
2262 static const int cc_purpose_len =
sizeof(cc_purpose) - 1;
2269 uri =
strsep(&call_info,
";");
2271 while ((purpose =
strsep(&call_info,
";"))) {
2272 if (!strncmp(purpose, cc_purpose, cc_purpose_len)) {
2282 while ((service_str =
strsep(&call_info,
";"))) {
2283 if (!strncmp(service_str,
"m=", 2)) {
2296 strsep(&service_str,
"=");
2367 ao2_ref(monitor_instance, -1);
2392 .name =
"SIP TCP server",
2403 .name =
"SIP TLS server",
2410 #define append_history(p, event, fmt , args... ) append_history_full(p, "%-15s " fmt, event, ## args) 2419 for (cur = table; cur->
s; cur++) {
2434 for (cur = table; cur->
s; cur++) {
2435 if (!strcasecmp(cur->
s, s)) {
2465 && !strchr(
"-.!%*_+`'~", *str)) {
2485 code = reason->
code;
2502 #define check_request_transport(peer, tmpl) ({ \ 2504 if (peer->socket.type == tmpl->socket.type) \ 2506 else if (!(peer->transports & tmpl->socket.type)) {\ 2507 ast_log(LOG_ERROR, \ 2508 "'%s' is not a valid transport for '%s'. we only use '%s'! ending call.\n", \ 2509 sip_get_transport(tmpl->socket.type), peer->name, get_transport_list(peer->transports) \ 2512 } else if (peer->socket.type & AST_TRANSPORT_TLS) { \ 2513 ast_log(LOG_WARNING, \ 2514 "peer '%s' HAS NOT USED (OR SWITCHED TO) TLS in favor of '%s' (but this was allowed in sip.conf)!\n", \ 2515 peer->name, sip_get_transport(tmpl->socket.type) \ 2519 "peer '%s' has contacted us over %s even though we prefer %s.\n", \ 2520 peer->name, sip_get_transport(tmpl->socket.type), sip_get_transport(peer->socket.type) \ 2533 for (v = src ; v ; v = v->
next) {
2579 ao2_t_ref(packet, -1,
"thread destruction, removing packet from frame queue");
2599 ao2_t_ref(th, -1,
"Failed to open alert pipe on sip_threadinfo");
2600 ast_log(
LOG_ERROR,
"Could not create sip alert pipe in tcptls thread, error %s\n", strerror(
errno));
2603 ao2_t_ref(tcptls_session, +1,
"tcptls_session ref for sip_threadinfo object");
2606 ao2_t_link(threadt, th,
"Adding new tcptls helper thread");
2607 ao2_t_ref(th, -1,
"Decrementing threadinfo ref from alloc, only table ref remains");
2618 .tcptls_session = tcptls_session,
2622 if (!tcptls_session) {
2628 if (!tcptls_session->
stream ||
2631 goto tcptls_write_setup_error;
2634 if (!(th =
ao2_t_find(threadt, &tmp,
OBJ_POINTER,
"ao2_find, getting sip_threadinfo in tcp helper thread"))) {
2636 goto tcptls_write_setup_error;
2647 if (write(th->
alert_pipe[1], &alert,
sizeof(alert)) == -1) {
2649 ao2_t_ref(packet, -1,
"could not write to alert pipe, remove packet");
2658 ao2_t_ref(th, -1,
"In sip_tcptls_write, unref threadinfo object after finding it");
2661 tcptls_write_setup_error:
2663 ao2_t_ref(th, -1,
"In sip_tcptls_write, unref threadinfo obj, could not create packet");
2666 ao2_t_ref(packet, -1,
"could not allocate packet's data");
2696 uint64_t payload_len;
2707 char data[payload_len + 1];
2713 strncpy(data, payload, payload_len);
2714 data[payload_len] =
'\0';
2748 if(time(&now) == -1) {
2795 char *content_length_str;
2796 int content_length = -1;
2814 if ((content_length_str =
strcasestr(msg,
"\nContent-Length:"))) {
2815 content_length_str +=
sizeof(
"\nContent-Length:") - 1;
2816 }
else if ((content_length_str =
strcasestr(msg,
"\nl:"))) {
2817 content_length_str +=
sizeof(
"\nl:") - 1;
2828 if (!strchr(content_length_str,
'\n')) {
2832 if (sscanf(content_length_str,
"%30d", &content_length) != 1) {
2833 content_length = -1;
2838 return content_length;
2866 body = strstr(message,
"\r\n\r\n");
2873 body +=
sizeof(
"\r\n\r\n") - 1;
2874 body_len = message_len - (body - message);
2880 if (content_length < 0) {
2882 }
else if (content_length == 0) {
2887 if (body_len == 0) {
2898 if (body_len < content_length) {
2901 }
else if (body_len > content_length) {
2923 int authenticated, time_t start)
2934 if (!tcptls_session->
client && !authenticated) {
2940 ast_debug(2,
"SIP TCP/TLS server timed out\n");
2948 ast_debug(2,
"SIP TCP/TLS server :: ast_wait_for_input returned %d\n", res);
2950 }
else if (res == 0) {
2951 ast_debug(2,
"SIP TCP/TLS server timed out\n");
2960 ast_debug(2,
"SIP TCP/TLS server error when receiving data\n");
2962 }
else if (res == 0) {
2963 ast_debug(2,
"SIP TCP/TLS server has shut down\n");
2966 readbuf[res] =
'\0';
2975 ast_log(
LOG_WARNING,
"Rejecting TCP/TLS packet from '%s' because way too large: %zu\n",
2991 int res, timeout = -1, authenticated = 0, flags;
2993 struct sip_request req = { 0, } , reqcpy = { 0, };
2995 char buf[1024] =
"";
2996 struct pollfd fds[2] = { { 0 }, { 0 }, };
3010 if (!tcptls_session->
client) {
3021 ao2_t_ref(me, +1,
"Adding threadinfo ref for tcp_helper_thread");
3024 .tcptls_session = tcptls_session,
3027 if ((!(ca = tcptls_session->
parent)) ||
3028 (!(me =
ao2_t_find(threadt, &tmp,
OBJ_POINTER,
"ao2_find, getting sip_threadinfo in tcp helper thread")))) {
3050 fds[0].events = fds[1].events = POLLIN | POLLPRI;
3059 if(time(&start) == -1) {
3083 if (!tcptls_session->
client && !authenticated ) {
3101 }
else if (res == 0) {
3116 str_save = req.
data;
3117 memset(&req, 0,
sizeof(req));
3118 req.
data = str_save;
3121 str_save = reqcpy.data;
3122 memset(&reqcpy, 0,
sizeof(reqcpy));
3123 reqcpy.data = str_save;
3126 memset(buf, 0,
sizeof(buf));
3145 if (fds[1].revents) {
3151 if (read(me->
alert_pipe[0], &alert,
sizeof(alert)) == -1) {
3162 ast_log(
LOG_WARNING,
"TCPTLS thread alert_pipe indicated packet should be sent, but frame_q is empty\n");
3170 ao2_t_ref(packet, -1,
"tcptls packet sent, this is no longer needed");
3185 if (tcptls_session && !tcptls_session->
client && !authenticated) {
3190 ao2_t_unlink(threadt, me,
"Removing tcptls helper thread, thread is closing");
3191 ao2_t_ref(me, -1,
"Removing tcp_helper_threads threadinfo ref");
3198 ao2_t_ref(ca, -1,
"closing tcptls thread, getting rid of client tcptls_session arguments");
3201 if (tcptls_session) {
3208 tcptls_session =
NULL;
3219 if (peer->
expire != -1) {
3318 while ((cp = dialog->
packets)) {
3322 ao2_t_ref(cp, -1,
"Stop scheduled packet retransmission"));
3323 ao2_t_ref(cp, -1,
"Packet retransmission list");
3340 dialog_unref(dialog,
"Stop scheduled request_queue_sched_id"));
3343 dialog_unref(dialog,
"Stop scheduled provisional keepalive"));
3357 struct sip_pvt *dialog = (
void *) data;
3360 dialog_unref(dialog,
"Stop scheduled items for unlink action");
3375 dialog_ref(dialog,
"Let's bump the count in the unlink so it doesn't accidentally become dead before we are done");
3377 ao2_t_unlink(dialogs, dialog,
"unlinking dialog via ao2_unlink");
3378 ao2_t_unlink(dialogs_needdestroy, dialog,
"unlinking dialog_needdestroy via ao2_unlink");
3379 ao2_t_unlink(dialogs_rtpcheck, dialog,
"unlinking dialog_rtpcheck via ao2_unlink");
3410 dialog_ref(dialog,
"Stop scheduled items for unlink action");
3416 dialog_unref(dialog,
"Failed to schedule stop scheduled items for unlink action");
3420 dialog_unref(dialog,
"Let's unbump the count in the unlink so the poor pvt can disappear if it is time");
3424 __attribute__((
format(printf, 2, 3)));
3430 return map_x_s(referstatusstrings, rstatus,
"");
3438 append_history(pvt,
"NeedDestroy",
"Setting needdestroy because %s", reason);
3441 ao2_t_link(dialogs_needdestroy, pvt,
"link pvt into dialogs_needdestroy container");
3451 ast_debug(1,
"Initializing already initialized SIP dialog %s (presumably reinvite)\n", p->
callid);
3466 ast_debug(3,
"Setting SIP_ALREADYGONE on dialog %s\n", dialog->
callid);
3497 char *mutable_proxy, *sep, *
name;
3511 sep = strchr(mutable_proxy,
',');
3526 dest->
name[0] =
'\0';
3544 int port = standard;
3545 if (
ast_strlen_zero(pt) || (sscanf(pt,
"%30d", &port) != 1) || (port < 1) || (port > 65535)) {
3557 ast_debug(1,
"OBPROXY: Applying dialplan set OBproxy to this call\n");
3564 ast_debug(1,
"OBPROXY: Applying peer OBproxy to this call\n");
3571 ast_debug(1,
"OBPROXY: Applying global OBproxy to this call\n");
3577 ast_debug(1,
"OBPROXY: Not applying OBproxy to this call\n");
3591 int l_name = name ? strlen(name) : 0;
3593 return (l_name >= len && name && name[len] < 33 &&
3670 if (!strcasecmp(transport,
"udp")) {
3673 if (!strcasecmp(transport,
"tcp")) {
3676 if (!strcasecmp(transport,
"tls")) {
3679 if (!strcasecmp(transport,
"ws")) {
3682 if (!strcasecmp(transport,
"wss")) {
3722 buf[strlen(buf) - 1] = 0;
3829 ast_debug(2,
"Socket type is TCP but no tcptls_session is present to write to\n");
3857 snprintf(p->
via,
sizeof(p->
via),
"SIP/2.0/%s %s;branch=z9hG4bK%08x%s",
3860 (
unsigned)p->
branch, rport);
3896 "but we're using IPv6, which doesn't need it. Please " 3897 "remove \"localnet\" and/or \"externaddr\" settings.\n");
3900 want_remap = localaddr &&
3948 ast_debug(1,
"Target address %s is not local, substituting externaddr\n",
3996 vsnprintf(buf,
sizeof(buf), fmt, ap);
3998 l = strlen(buf) + 1;
3999 if (!(hist =
ast_calloc(1,
sizeof(*hist) + l))) {
4002 if (!p->history && !(p->history =
ast_calloc(1,
sizeof(*p->history)))) {
4006 memcpy(hist->
event, buf, l);
4010 p->history_entries--;
4014 p->history_entries++;
4070 ast_debug(4,
"SIP TIMER: Not rescheduling id #%d:%s (Method %d) (No timer T1)\n",
4079 ast_debug(4,
"SIP TIMER: Rescheduling retransmission #%d (%d) %s - %d\n",
4105 reschedule = siptimer_a;
4106 ast_debug(4,
"** SIP timers: Rescheduling retransmission %d to %d ms (t1 %d ms (Retrans id #%d)) \n",
4116 ast_verbose(
"Retransmitting #%d (%s) to %s:\n%s\n---\n",
4131 if (reschedule >= diff) {
4147 ast_log(
LOG_WARNING,
"Retransmission timeout reached on transmission %s for seqno %u (%s %s) -- See https://wiki.asterisk.org/wiki/display/AST/SIP+Retransmissions\n" 4148 "Packet timed out after %dms with no response\n",
4151 pkt->
is_fatal ?
"Critical" :
"Non-critical",
4152 pkt->
is_resp ?
"Response" :
"Request",
4156 ast_log(
LOG_WARNING,
"Cancelling retransmit of OPTIONs (call id %s) -- See https://wiki.asterisk.org/wiki/display/AST/SIP+Retransmissions\n", pkt->
owner->
callid);
4171 ast_log(
LOG_WARNING,
"Hanging up call %s - no reply to our critical packet (see https://wiki.asterisk.org/wiki/display/AST/SIP+Retransmissions).\n", pkt->
owner->
callid);
4220 append_history(pkt->
owner,
"ByeFailure",
"Remote peer doesn't respond to bye. Destroying call anyway.");
4229 ao2_t_ref(pkt, -1,
"Packet retransmission list (retransmission complete)");
4240 ao2_t_ref(pkt, -1,
"Scheduled packet retransmission complete");
4247 struct sip_pkt *pkt = (
void *) data;
4250 ao2_t_ref(pkt, -1,
"Stop scheduled packet retransmission"));
4251 ao2_t_ref(pkt, -1,
"Stop packet retransmission action");
4257 ao2_t_ref(pkt, +1,
"Stop packet retransmission action");
4260 ao2_t_ref(pkt, -1,
"Failed to schedule stop packet retransmission action");
4266 struct sip_pkt *pkt = (
void *) vdoomed;
4298 ao2_t_ref(pkt, -1,
"Failed to initialize");
4307 pkt->
owner =
dialog_ref(p,
"__sip_reliable_xmit: setting pkt->owner");
4335 ao2_t_ref(pkt, +1,
"Schedule packet retransmission");
4338 ao2_t_ref(pkt, -1,
"Failed to schedule packet retransmission");
4342 ast_debug(4,
"*** SIP TIMER: Initializing retransmit timer on packet: Id #%d\n", pkt->
retransid);
4349 ast_log(
LOG_ERROR,
"Serious Network Trouble; __sip_xmit returns error for pkt data\n");