sip_pinger.h

/*
 * Copyright (C) 2005 Voice System SRL
 *
 * This file is part of opensips, a free SIP server.
 *
 * opensips is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version
 *
 * opensips is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301  USA
 *
 * History:
 * ---------
 * 2005-07-11  created (bogdan)
 */


#ifndef NATHELPER_OPTIONS_H_
#define NATHELPER_OPTIONS_H_

#include <stdlib.h>
#include <string.h>

#include "../../parser/parse_rr.h"
#include "../../str.h"
#include "../../ut.h"
#include "../../ip_addr.h"
#include "nh_table.h"

/* size of buffer used for building SIP PING req */
#define MAX_SIPPING_SIZE 65536

/* maximum number of hops */
#define MAX_FORWARD "70"

/* branch magic */
#define BMAGIC "z9hG4bK"
#define BMAGIC_LEN (sizeof(BMAGIC) - 1)

#define BSTART ";branch="

/* helping macros for building SIP PING ping request */
#define append_str( _p, _s) \
	do {\
		memcpy(_p,(_s).s,(_s).len);\
		_p += (_s).len;\
	}while(0)

#define append_fix( _p, _s) \
	do {\
		memcpy(_p, _s, sizeof(_s)-1);\
		_p += sizeof(_s)-1;\
	}while(0)

extern  usrloc_api_t ul;
/* info used to generate SIP ping requests */
static int  sipping_fromtag = 0;
static char sipping_callid_buf[8];
static int  sipping_callid_cnt = 0;
static str  sipping_callid = {0,0};
static str  sipping_from = {0,0};
static str  sipping_method = {"OPTIONS",7};
static int  match_ctid=0;


static void init_sip_ping(int _match_ctid)
{
	int len;
	char *p;

	/* FROM tag - some random number */
	sipping_fromtag = rand();
	/* callid fix part - hexa string */
	len = 8;
	p = sipping_callid_buf;
	int2reverse_hex( &p, &len, rand() );
	sipping_callid.s = sipping_callid_buf;
	sipping_callid.len = 8-len;
	/* callid counter part */
	sipping_callid_cnt = rand();
	match_ctid=(_match_ctid>0?1:0);
}


static int parse_branch(str branch)
{
	unsigned int hash_id, label;
	int sipping_latency;
	char *end;
	ucontact_coords ct_coords;
	struct timeval timeval_st;

	struct ping_cell *p_cell;
	gettimeofday(&timeval_st, NULL);

	if (branch.len < BMAGIC_LEN
			|| memcmp(branch.s, BMAGIC, BMAGIC_LEN)) {
		LM_ERR("invalid branch\n");
		return -1;
	}

	branch.s += BMAGIC_LEN;
	branch.len -= BMAGIC_LEN;

	end = q_memchr(branch.s, '.', branch.len);
	if (!end) {
		/* if reverse hex2int succeeds on this it's a simple
		 * ping based on sipping_callid_cnt label */
		if (reverse_hex2int(branch.s, branch.len, &label) == 0)
			return 0;

		return 1;
	}

	if (reverse_hex2int(branch.s, end - branch.s, &hash_id)<0
	|| hash_id>=NH_TABLE_ENTRIES ) {
		// invalid hash ID received
		return -1;
	}

	branch.len -= (end - branch.s + 1);
	branch.s = end + 1;

	/* reverse_hex2int64() cannot fail in unsafe mode and it will return 
	   whatever it was able to parse (0 if nothing )*/
	reverse_hex2int64(branch.s, branch.len, 1, &ct_coords);

	lock_hash(hash_id);
	p_cell = get_cell(hash_id, ct_coords);
	if (!p_cell) {
		LM_WARN("received ping response for a removed contact\n");
		unlock_hash(hash_id);
		return 0;
	}
	LM_DBG("ping received for %llu\n", (unsigned long long)ct_coords);

	sipping_latency =
	    (timeval_st.tv_sec - p_cell->last_send_time.tv_sec) * 1000000 +
		(timeval_st.tv_usec - p_cell->last_send_time.tv_usec);

	if (p_cell->ct_flags & sipping_latency_flag) {
		LM_DBG("update_sipping_latency with %d us\n", sipping_latency);
		if(ul.update_sipping_latency(p_cell->d, ct_coords, sipping_latency)<0){
			/* we keep going since it might work for other contacts */
			LM_ERR("failed to update ucontact sipping_latency\n");
		}
	}
	/* when we receive answer to a ping we consider all pings sent
	 * confirmed, because what we want to know is that the contact
	 * is alive; only remove the cell from the hash; will be
	 * completely removed when the timer will be up */
	p_cell->not_responded = 0;
	/* mark for removal */
	p_cell->state = PING_CELL_STATE_ANSWERED;
	p_cell->timestamp = 0;

	remove_from_hash(p_cell);
	unlock_hash(hash_id);
	return 0;
}

static inline int ignore_reply(const struct sip_msg *rpl)
{
	extern unsigned short *ignore_rpl_codes;
	unsigned short *code;

	if (!ignore_rpl_codes)
		return 0;

	for (code = ignore_rpl_codes; *code; code++)
		if (*code == (unsigned short)rpl->REPLY_STATUS)
			return 1;

	return 0;
}

static int sipping_rpl_filter(struct sip_msg *rpl)
{
	struct cseq_body* cseq_b;

	/* first check number of vias -> must be only one */
	if (parse_headers( rpl, HDR_VIA2_F, 0 )==-1 || (rpl->via2!=0))
		goto skip;

	/* check the method -> we need CSeq header */
	if ( (!rpl->cseq && parse_headers(rpl,HDR_CSEQ_F,0)!=0) || rpl->cseq==0 ) {
		LM_ERR("failed to parse CSeq\n");
		goto error;
	}
	cseq_b = (struct cseq_body*)rpl->cseq->parsed;
	if (cseq_b->method.len!=sipping_method.len ||
	strncmp(cseq_b->method.s,sipping_method.s,sipping_method.len)!=0)
		goto skip;

	/* check constant part of callid */
	if ( (!rpl->callid && parse_headers(rpl,HDR_CALLID_F,0)!=0) ||
	rpl->callid==0 ) {
		LM_ERR("failed to parse Call-ID\n");
		goto error;
	}
	if ( rpl->callid->body.len<=sipping_callid.len+1 ||
	strncmp(rpl->callid->body.s,sipping_callid.s,sipping_callid.len)!=0 ||
	rpl->callid->body.s[sipping_callid.len]!='-')
		goto skip;

	LM_DBG("reply for SIP natping filtered (%d)\n", match_ctid);
	/* it's a reply to a SIP NAT ping -> absorb it and stop any
	 * further processing of it */
	if (!ignore_reply(rpl) && match_ctid &&
	     (rpl->via1 && rpl->via1->branch &&
	      parse_branch(rpl->via1->branch->value)))
			goto skip;

	return 0;
skip:
	return 1;
error:
	return -1;
}


/*
 */
static inline int
build_branch(char *branch, int *size,
		str *curi, udomain_t *d, ucontact_coords ct_coords, int ct_flags)
{
	int hash_id, ret, label;
	time_t timestamp;
	struct ping_cell *p_cell;
	struct nh_table *htable;
	struct timeval timeval_st;
	int dangling_coords = 0;
	int old_state;
	int reply_matching;

	/* we want all contact pings from a contact in one bucket*/
	hash_id = core_hash(curi, NULL, 0) & (NH_TABLE_ENTRIES-1);

	/* do we need to track and match the replies for this ping?
	 * We do if latency or remove on timeout flags are set for the contact */
	reply_matching = ((ct_flags) & (rm_on_to_flag | sipping_latency_flag));

	if (reply_matching) {
		/* get the time before the lock - we may wait a little bit
		 * on this lock */
		timestamp=now;
		gettimeofday(&timeval_st, NULL);

		htable = get_htable();

		lock_hash(hash_id);

		if ((p_cell=get_cell(hash_id, ct_coords))==NULL) {
			if (0 == (p_cell = build_p_cell(hash_id, d, ct_coords))) {
				unlock_hash(hash_id);
				goto out_memfault;
			}
			insert_into_hash(p_cell);
		} else {
			dangling_coords = 1;
		}

		old_state = p_cell->state;
		p_cell->state = PING_CELL_STATE_PINGING;
		p_cell->ct_flags = ct_flags;
		p_cell->timestamp = timestamp;
		p_cell->last_send_time = timeval_st;

		/* we get the label that assures us that the via is unique */
		label = htable->entries[hash_id].next_via_label++;

		unlock_hash(hash_id);

		/* put the cell in timer list */
		lock_get(&htable->timer_list.mutex);
		/* if record found in WAIT (and moved into PINGING), remove first
		 * from old timer list */
		if (old_state==PING_CELL_STATE_WAITING)
			list_del(&p_cell->t_linker);
		/* add to pinging list*/
		list_add_tail( &p_cell->t_linker, &htable->timer_list.pg_timer);

		lock_release(&htable->timer_list.mutex);

		LM_DBG("ping cell acquired (new=%d, old_state=%d) for %llu\n",
			(old_state==PING_CELL_STATE_NONE)?1:0, old_state, (unsigned long long)ct_coords);
	} else {
		label = sipping_callid_cnt;
	}

	memcpy( branch, BMAGIC, BMAGIC_LEN);

	branch += BMAGIC_LEN;
	*size -= BMAGIC_LEN;

	if (reply_matching) {
		ret=int2reverse_hex(&branch, size, hash_id);
		if (ret < 0)
			goto out_nospace;

		if (*size <= 0)
			goto out_nospace;

		*branch = '.';
		branch++;
		*size -= 1;

		ret=int64_2reverse_hex(&branch, size, ct_coords);
		if (ret < 0)
			goto out_nospace;
	} else {
		ret=int2reverse_hex(&branch, size, label);
		if (ret < 0)
			goto out_nospace;
	}

	if (dangling_coords)
		ul.free_ucontact_coords(ct_coords);

	if (*size <= 0)
		goto out_nospace;

	*branch = '\0';
	*size -= 1;

	return 0;

out_memfault:
	LM_ERR("no more shared memory\n");
	return -1;
out_nospace:
	LM_ERR("not enough space in send buffer\n");
	return -1;
}



/* build the buffer of a SIP ping request */
static inline char*
build_sipping(udomain_t *d, str *curi, struct socket_info* s,str *path,
		int *len_p, ucontact_coords ct_coords, int ct_flags)
{
#define s_len(_s) (sizeof(_s)-1)
	static char buf[MAX_SIPPING_SIZE];
	char *p, proto_str[PROTO_NAME_MAX_SIZE+1];
	str *address, *port;
	str st;
	int len;

	int  bsize = 120;
	str  sbranch;
	char branch[120];
	char *bbuild = branch;

	memcpy(bbuild, BSTART, sizeof(BSTART) - 1);
	bbuild += sizeof(BSTART) - 1;
	bsize -= (bbuild - branch);

	build_branch( bbuild, &bsize, curi, d, ct_coords, ct_flags);

	sbranch.s = branch;
	sbranch.len = strlen(branch);

	p = proto2upper(s->proto, proto_str);
	*(p++) = ' ';
	st.s = proto_str;
	st.len = p - proto_str;

	if (s->adv_name_str.len)
		address = &s->adv_name_str;
	else if (default_global_address->len)
		address = default_global_address;
	else
		address = &s->address_str;
	if (s->adv_port_str.len)
		port = &s->adv_port_str;
	else if (default_global_port->len)
		port = default_global_port;
	else
		port = &s->port_no_str;

	if ( sipping_method.len + 1 + curi->len + s_len(" SIP/2.0"CRLF) +
		s_len("Via: SIP/2.0/") + st.len + address->len +
		1 + port->len + strlen(branch) +
		(path->len ? (s_len(CRLF"Route: ") + path->len) : 0) +
		s_len(CRLF"From: ") +  sipping_from.len + s_len(";tag=") + 8 +
		s_len(CRLF"To: ") + curi->len +
		s_len(CRLF"Call-ID: ") + sipping_callid.len + 1 + 8 + 1 + 8 + 1 +
		address->len +
		s_len(CRLF"CSeq: 1 ") + sipping_method.len +
		s_len(CRLF"Max-Forwards: "MAX_FORWARD) +
		s_len(CRLF"Content-Length: 0" CRLF CRLF)
		> MAX_SIPPING_SIZE )
	{
		LM_ERR("len exceeds %d\n",MAX_SIPPING_SIZE);
		return 0;
	}

	p = buf;
	append_str( p, sipping_method);
	*(p++) = ' ';
	append_str( p, *curi);
	append_fix( p, " SIP/2.0"CRLF"Via: SIP/2.0/");
	append_str( p, st);
	append_str( p, *address);
	*(p++) = ':';
	append_str( p, *port);
	append_str( p, sbranch);
	if (path->len) {
		append_fix( p, CRLF"Route: ");
		append_str( p, *path);
	}
	append_fix( p, CRLF"From: ");
	append_str( p, sipping_from);
	append_fix( p, ";tag=");
	len = 8;
	int2reverse_hex( &p, &len, sipping_fromtag++ );
	append_fix( p, CRLF"To: ");
	append_str( p, *curi);
	append_fix( p, CRLF"Call-ID: ");
	append_str( p, sipping_callid);
	*(p++) = '-';
	len = 8;
	int2reverse_hex( &p, &len, sipping_callid_cnt++ );
	*(p++) = '-';
	len = 8;
	int2reverse_hex( &p, &len, get_ticks() );
	*(p++) = '@';
	append_str( p, *address);
	append_fix( p, CRLF"CSeq: 1 ");
	append_str( p, sipping_method);
	append_fix( p, CRLF"Max-Forwards: "MAX_FORWARD);
	append_fix( p, CRLF"Content-Length: 0" CRLF CRLF);

	*len_p = p - buf;
	return buf;
}

#endif