deleted file mode 100644

@@ -1,3097 +0,0 @@

-/*

- * Copyright (C) 2001-2003 FhG Fokus

- *

- * This file is part of Kamailio, a free SIP server.

- *

- * Kamailio 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

- *

- * Kamailio 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

- *

- *

- *

- */

-/** Via special params:

- * requests:

- * - if the address in via is different from the src_ip or an existing

- *   received=something is found, received=src_ip is added (and any preexisting

- *   received is deleted). received is added as the first via parameter if no

- *   receive is previously present or over the old receive.

- * - if the original via contains rport / rport=something or msg->msg_flags

- *   FL_FORCE_RPORT is set (e.g. script force_rport() cmd) rport=src_port

- *   is added (over previous rport / as first via param or after received

- *   if no received was present and received is added too)

- * local replies:

- *    (see also sl_send_reply)

- *  - rport and received are added in mostly the same way as for requests, but

- *    in the reverse order (first rport and then received). See also

- *    limitations.

- *  - if reply_to_via is set (default off) the local reply will be sent to

- *    the address in via (received is ignored since it was not set by us). The

- *    destination port is either the message source port if via contains rport

- *    or the FL_FORCE_RPORT flag is set or the port from the via. If either

- *    port or rport are present a normal dns lookup (instead of a srv lookup)

- *    is performed on the address. If no port is present and a srv lookup is

- *    performed the port is taken from the srv lookup. If the srv lookup failed

- *    or it was not performed, the port is set to the default sip port (5060).

- *  - if reply_to_via is off (default) the local reply is sent to the message

- *    source ip address. The destination port is set to the source port if

- *    rport is present or FL_FORCE_RPORT flag is set, to the via port or to

- *    the default sip port (5060) if neither rport or via port are present.

- * "normal" replies:

- *  - if received is present the message is sent to the received address else

- *    if no port is present (neither a normal via port or rport) a dns srv

- *    lookup is performed on the host part and the reply is sent to the

- *    resulting ip. If a port is present or the host part is an ip address

- *    the dns lookup will be a "normal" one (A or AAAA).

- *  - if rport is present, it's value will be used as the destination port

- *   (and this will also disable srv lookups)

- *  - if no port is present the destination port will be taken from the srv

- *    lookup. If the srv lookup fails or is not performed (e.g. ip address

- *    in host) the destination port will be set to the default sip port (5060).

- *

- * Known limitations:

- * - when locally replying to a message, rport and received will be appended to

- *   the via header parameters (for forwarded requests they are inserted at the

- *   beginning).

- * - a locally generated reply might get two received via parameters if a

- *   received is already present in the original message (this should not

- *   happen though, but ...)

- *

- *--andrei

-*/

-

-/*!

- * \file

- * \brief Kamailio core :: Message translations

- * \ingroup core

- * Module: \ref core

- */

-

-#include <sys/types.h>

-#include <sys/socket.h>

-#include <netdb.h>

-#include <string.h>

-#include <stdio.h>

-#include <stdlib.h>

-

-#include "comp_defs.h"

-#include "msg_translator.h"

-#include "globals.h"

-#include "error.h"

-#include "mem/mem.h"

-#include "dprint.h"

-#include "config.h"

-#include "md5utils.h"

-#include "data_lump.h"

-#include "data_lump_rpl.h"

-#include "ip_addr.h"

-#include "resolve.h"

-#include "ut.h"

-#include "pt.h"

-#include "cfg/cfg.h"

-#include "parser/parse_to.h"

-#include "parser/parse_param.h"

-#include "forward.h"

-#include "str_list.h"

-#include "rand/kam_rand.h"

-

-#define append_str_trans(_dest,_src,_len,_msg) \

-	append_str( (_dest), (_src), (_len) );

-

-extern char version[];

-extern int version_len;

-

-

-

-/** per process fixup function for global_req_flags.

-  * It should be called from the configuration framework.

-  */

-void fix_global_req_flags(str* gname, str* name)

-{

-	global_req_flags=0;

-	switch(cfg_get(core, core_cfg, udp_mtu_try_proto)){

-		case PROTO_NONE:

-		case PROTO_UDP:

-			/* do nothing */

-			break;

-		case PROTO_TCP:

-			global_req_flags|=FL_MTU_TCP_FB;

-			break;

-		case PROTO_TLS:

-			global_req_flags|=FL_MTU_TLS_FB;

-			break;

-		case PROTO_SCTP:

-			global_req_flags|=FL_MTU_SCTP_FB;

-			break;

-	}

-	if (cfg_get(core, core_cfg, force_rport))

-		global_req_flags|=FL_FORCE_RPORT;

-}

-

-

-

-/* checks if ip is in host(name) and ?host(ip)=name?

- * ip must be in network byte order!

- *  resolver = DO_DNS | DO_REV_DNS; if 0 no dns check is made

- * return 0 if equal */

-static int check_via_address(struct ip_addr* ip, str *name,

-				unsigned short port, int resolver)

-{

-	struct hostent* he;

-	int i;

-	char* s;

-	int len;

-	char lproto;

-

-	/* maybe we are lucky and name it's an ip */

-	s=ip_addr2a(ip);

-	if (s){

-		LM_DBG("(%s, %.*s, %d)\n", s, name->len, name->s, resolver);

-

-		len=strlen(s);

-

-		/* check if name->s is an ipv6 address or an ipv6 address ref. */

-		if ((ip->af==AF_INET6) &&

-				(	((len==name->len)&&(strncasecmp(name->s, s, name->len)==0))

-					||

-					((len==(name->len-2))&&(name->s[0]=='[')&&

-						(name->s[name->len-1]==']')&&

-						(strncasecmp(name->s+1, s, len)==0))

-				)

-		   )

-			return 0;

-		else

-

-			if (strncmp(name->s, s, name->len)==0)

-				return 0;

-	}else{

-		LM_CRIT("could not convert ip address\n");

-		return -1;

-	}

-

-	if (port==0) port=SIP_PORT;

-	if (resolver&DO_DNS){

-		LM_DBG("doing dns lookup\n");

-		/* try all names ips */

-		lproto = PROTO_NONE;

-		he=sip_resolvehost(name, &port, &lproto); /* don't use naptr */

-		if (he && ip->af==he->h_addrtype){

-			for(i=0;he && he->h_addr_list[i];i++){

-				if ( memcmp(&he->h_addr_list[i], ip->u.addr, ip->len)==0)

-					return 0;

-			}

-		}

-	}

-	if (resolver&DO_REV_DNS){

-		LM_DBG("doing rev. dns lookup\n");

-		/* try reverse dns */

-		he=rev_resolvehost(ip);

-		if (he && (strncmp(he->h_name, name->s, name->len)==0))

-			return 0;

-		for (i=0; he && he->h_aliases[i];i++){

-			if (strncmp(he->h_aliases[i],name->s, name->len)==0)

-				return 0;

-		}

-	}

-	return -1;

-}

-

-

-/* check if IP address in Via != source IP address of signaling,

- * or the sender requires adding rport or received values */

-int received_test( struct sip_msg *msg )

-{

-	int rcvd;

-

-	rcvd=msg->via1->received || msg->via1->rport

-			|| check_via_address(&msg->rcv.src_ip, &msg->via1->host,

-							msg->via1->port, received_dns);

-	return rcvd;

-}

-

-/* check if IP address in Via != source IP address of signaling */

-int received_via_test( struct sip_msg *msg )

-{

-	int rcvd;

-

-	rcvd = (check_via_address(&msg->rcv.src_ip, &msg->via1->host,

-							msg->via1->port, received_dns)!=0);

-	return rcvd;

-}

-

-static char * warning_builder( struct sip_msg *msg, unsigned int *returned_len)

-{

-	static char buf[MAX_WARNING_LEN];

-	str *foo;

-	int print_len, l;

-	int clen;

-	char* t;

-

-#define str_print(string, string_len) \

-		do{ \

-			l=(string_len); \

-			if ((clen+l)>MAX_WARNING_LEN) \

-				goto error_overflow; \

-			memcpy(buf+clen, (string), l); \

-			clen+=l; \

-		}while(0)

-

-#define str_lenpair_print(string, string_len, string2, string2_len) \

-		do{ \

-			str_print(string, string_len); \

-			str_print(string2, string2_len);\

-		}while(0)

-

-#define str_pair_print( string, string2, string2_len) \

-		str_lenpair_print((string), strlen((string)), (string2), (string2_len))

-

-#define str_int_print(string, intval)\

-		do{\

-			t=int2str((intval), &print_len); \

-			str_pair_print(string, t, print_len);\

-		} while(0)

-

-#define str_su_print(sockaddr)\

-		do{\

-			t=su2a(&sockaddr, sizeof(sockaddr)); \

-			print_len=strlen(t); \

-			str_print(t, print_len); \

-		} while(0)

-

-#define str_ipaddr_print(string, ipaddr_val)\

-		do{\

-			t=ip_addr2a((ipaddr_val)); \

-			print_len=strlen(t); \

-			str_pair_print(string, t, print_len);\

-		} while(0)

-

-	clen=0;

-	str_print(WARNING, WARNING_LEN);

-	str_su_print(msg->rcv.bind_address->su);

-	str_print(WARNING_PHRASE, WARNING_PHRASE_LEN);

-

-	/*adding out_uri*/

-	if (msg->new_uri.s)

-		foo=&(msg->new_uri);

-	else

-		foo=&(msg->first_line.u.request.uri);

-	/* pid= */

-	str_int_print(" pid=", my_pid());

-	/* req_src_ip= */

-	str_ipaddr_print(" req_src_ip=", &msg->rcv.src_ip);

-	str_int_print(" req_src_port=", msg->rcv.src_port);

-	str_pair_print(" in_uri=", msg->first_line.u.request.uri.s,

-								msg->first_line.u.request.uri.len);

-	str_pair_print(" out_uri=", foo->s, foo->len);

-	str_pair_print(" via_cnt",

-					(msg->parsed_flag & HDR_EOH_F)==HDR_EOH_F ? "=" : ">", 1);

-	str_int_print("=", via_cnt);

-	if (clen<MAX_WARNING_LEN){ buf[clen]='"'; clen++; }

-	else goto error_overflow;

-

-

-	*returned_len=clen;

-	return buf;

-error_overflow:

-	LM_NOTICE("buffer size exceeded (probably too long URI)\n");

-	*returned_len=0;

-	return 0;

-}

-

-

-

-

-char* received_builder(struct sip_msg *msg, unsigned int *received_len)

-{

-	char *buf;

-	int  len;

-	struct ip_addr *source_ip;

-	char *tmp;

-	int  tmp_len;

-

-	source_ip=&msg->rcv.src_ip;

-

-	buf=pkg_malloc(sizeof(char)*MAX_RECEIVED_SIZE);

-	if (buf==0){

-		ser_error=E_OUT_OF_MEM;

-		LM_ERR("out of memory\n");

-		return 0;

-	}

-	memcpy(buf, RECEIVED, RECEIVED_LEN);

-	if ( (tmp=ip_addr2a(source_ip))==0) {

-		pkg_free(buf);

-		return 0; /* error*/

-	}

-	tmp_len=strlen(tmp);

-	len=RECEIVED_LEN+tmp_len;

-

-	memcpy(buf+RECEIVED_LEN, tmp, tmp_len);

-	buf[len]=0; /*null terminate it */

-

-	*received_len = len;

-	return buf;

-}

-

-

-

-char* rport_builder(struct sip_msg *msg, unsigned int *rport_len)

-{

-	char* buf;

-	char* tmp;

-	int tmp_len;

-	int len;

-

-	tmp_len=0;

-	tmp=int2str(msg->rcv.src_port, &tmp_len);

-	len=RPORT_LEN+tmp_len;

-	buf=pkg_malloc(sizeof(char)*(len+1));/* space for null term */

-	if (buf==0){

-		ser_error=E_OUT_OF_MEM;

-		LM_ERR("out of memory\n");

-		return 0;

-	}

-	memcpy(buf, RPORT, RPORT_LEN);

-	memcpy(buf+RPORT_LEN, tmp, tmp_len);

-	buf[len]=0; /*null terminate it*/

-

-	*rport_len=len;

-	return buf;

-}

-

-

-

-char* id_builder(struct sip_msg* msg, unsigned int *id_len)

-{

-	char* buf;

-	int len, value_len;

-	char revhex[sizeof(int)*2];

-	char* p;

-	int size;

-

-	size=sizeof(int)*2;

-	p=&revhex[0];

-	if (int2reverse_hex(&p, &size, msg->rcv.proto_reserved1)==-1){

-		LM_CRIT("not enough space for id\n");

-		return 0;

-	}

-	value_len=p-&revhex[0];

-	len=ID_PARAM_LEN+value_len;

-	buf=pkg_malloc(sizeof(char)*(len+1));/* place for ending \0 */

-	if (buf==0){

-		ser_error=E_OUT_OF_MEM;

-		LM_ERR("out of memory\n");

-		return 0;

-	}

-	memcpy(buf, ID_PARAM, ID_PARAM_LEN);

-	memcpy(buf+ID_PARAM_LEN, revhex, value_len);

-	buf[len]=0; /* null terminate it */

-	*id_len=len;

-	return buf;

-}

-

-

-

-char* clen_builder(	struct sip_msg* msg, int *clen_len, int diff,

-					int body_only)

-{

-	char* buf;

-	int len;

-	int value;

-	char* value_s;

-	int value_len;

-	char* body;

-

-

-	body=get_body(msg);

-	if (body==0){

-		ser_error=E_BAD_REQ;

-		LM_ERR("no message body found (missing crlf?) [[%.*s]]\n",

-				msg->len, msg->buf);

-		return 0;

-	}

-	value=msg->len-(int)(body-msg->buf)+diff;

-	value_s=int2str(value, &value_len);

-	LM_DBG("content-length: %d (%s)\n", value, value_s);

-

-	if (body_only) {

-		len=value_len;

-	}

-	else {

-		len=CONTENT_LENGTH_LEN+value_len+CRLF_LEN;

-	}

-	buf=pkg_malloc(sizeof(char)*(len+1));

-	if (buf==0){

-		ser_error=E_OUT_OF_MEM;

-		LM_ERR("out of memory\n");

-		return 0;

-	}

-	if (body_only) {

-		memcpy(buf, value_s, value_len);

-	}

-	else {

-		memcpy(buf, CONTENT_LENGTH, CONTENT_LENGTH_LEN);

-		memcpy(buf+CONTENT_LENGTH_LEN, value_s, value_len);

-		memcpy(buf+CONTENT_LENGTH_LEN+value_len, CRLF, CRLF_LEN);

-	}

-	buf[len]=0; /* null terminate it */

-	*clen_len=len;

-	return buf;

-}

-

-

-

-/* checks if a lump opt condition

- * returns 1 if cond is true, 0 if false */

-static inline int lump_check_opt(	struct lump *l,

-									struct sip_msg* msg,

-									struct dest_info* snd_i

-									)

-{

-	struct ip_addr* ip;

-	unsigned short port;

-	int proto;

-

-#define get_ip_port_proto \

-			if ((snd_i==0) || (snd_i->send_sock==0)){ \

-				LM_CRIT("null send socket\n"); \

-				return 1; /* we presume they are different :-) */ \

-			} \

-			if (msg->rcv.bind_address){ \

-				ip=&msg->rcv.bind_address->address; \

-				port=msg->rcv.bind_address->port_no; \

-				proto=msg->rcv.bind_address->proto; \

-			}else{ \

-				ip=&msg->rcv.dst_ip; \

-				port=msg->rcv.dst_port; \

-				proto=msg->rcv.proto; \

-			} \

-

-	switch(l->u.cond){

-		case COND_FALSE:

-			return 0;

-		case COND_TRUE:

-			LUMP_SET_COND_TRUE(l);

-			return 1;

-		case COND_IF_DIFF_REALMS:

-			get_ip_port_proto;

-			/* faster tests first */

-			if ((port==snd_i->send_sock->port_no) && 

-					(proto==snd_i->send_sock->proto) &&

-#ifdef USE_COMP

-					(msg->rcv.comp==snd_i->comp) &&

-#endif

-					(ip_addr_cmp(ip, &snd_i->send_sock->address)))

-				return 0;

-			else {

-				LUMP_SET_COND_TRUE(l);

-				return 1;

-			}

-		case COND_IF_DIFF_AF:

-			get_ip_port_proto;

-			if (ip->af!=snd_i->send_sock->address.af) {

-				LUMP_SET_COND_TRUE(l);

-				return 1;

-			} else return 0;

-		case COND_IF_DIFF_PROTO:

-			get_ip_port_proto;

-			if (proto!=snd_i->send_sock->proto) {

-				LUMP_SET_COND_TRUE(l);

-				return 1;

-			} else return 0;

-		case COND_IF_DIFF_PORT:

-			get_ip_port_proto;

-			if (port!=snd_i->send_sock->port_no) {

-				LUMP_SET_COND_TRUE(l);

-				return 1;

-			} else return 0;

-		case COND_IF_DIFF_IP:

-			get_ip_port_proto;

-			if (ip_addr_cmp(ip, &snd_i->send_sock->address)) return 0;

-			else {

-				LUMP_SET_COND_TRUE(l);

-				return 1;

-			}

-		case COND_IF_RAND:

-			if(kam_rand()>=KAM_RAND_MAX/2) {

-				LUMP_SET_COND_TRUE(l);

-				return 1;

-			} else return 0;

-		default:

-			LM_CRIT("unknown lump condition %d\n", l->u.cond);

-	}

-	return 0; /* false */

-}

-

-

-

-/* computes the "unpacked" len of a lump list,

-   code moved from build_req_from_req */

-static inline int lumps_len(struct sip_msg* msg, struct lump* lumps, 

-								struct dest_info* send_info)

-{

-	int s_offset;

-	int new_len;

-	struct lump* t;

-	struct lump* r;

-	str* send_address_str;

-	str* send_port_str;

-	str* recv_address_str = NULL;

-	str* recv_port_str = NULL;

-	int  recv_port_no = 0;

-	struct socket_info* send_sock;

-	

-

-#ifdef USE_COMP

-	#define RCVCOMP_LUMP_LEN \

-						/* add;comp=xxx */ \

-					switch(msg->rcv.comp){ \

-						case COMP_NONE: \

-								break; \

-						case COMP_SIGCOMP: \

-								new_len+=COMP_PARAM_LEN+SIGCOMP_NAME_LEN; \

-								break; \

-						case COMP_SERGZ: \

-								new_len+=COMP_PARAM_LEN+SERGZ_NAME_LEN ; \

-								break; \

-						default: \

-						LM_CRIT("unknown comp %d\n", msg->rcv.comp); \

-					}

-

-	#define SENDCOMP_LUMP_LEN \

-					/* add;comp=xxx */ \

-					switch(send_info->comp){ \

-						case COMP_NONE: \

-								break; \

-						case COMP_SIGCOMP: \

-								new_len+=COMP_PARAM_LEN+SIGCOMP_NAME_LEN; \

-								break; \

-						case COMP_SERGZ: \

-								new_len+=COMP_PARAM_LEN+SERGZ_NAME_LEN ; \

-								break; \

-						default: \

-						LM_CRIT("unknown comp %d\n", send_info->comp); \

-					}

-#else

-	#define RCVCOMP_LUMP_LEN

-	#define SENDCOMP_LUMP_LEN

-#endif /*USE_COMP */

-	

-#define SUBST_LUMP_LEN(subst_l) \

-		switch((subst_l)->u.subst){ \

-			case SUBST_RCV_IP: \

-				if (msg->rcv.bind_address){ \

-					new_len+=recv_address_str->len; \

-					if (msg->rcv.bind_address->address.af!=AF_INET) \

-						new_len+=2; \

-				}else{ \

-					/* FIXME */ \

-					LM_CRIT("FIXME: null bind_address\n"); \

-				}; \

-				break; \

-			case SUBST_RCV_PORT: \

-				if (msg->rcv.bind_address){ \

-					new_len+=recv_port_str->len; \

-				}else{ \

-					/* FIXME */ \

-					LM_CRIT("FIXME: null bind_address\n"); \

-				}; \

-				break; \

-			case SUBST_RCV_PROTO: \

-				if (msg->rcv.bind_address){ \

-					switch(msg->rcv.bind_address->proto){ \

-						case PROTO_NONE: \

-						case PROTO_UDP: \

-							new_len+=3; \

-							break; \

-						case PROTO_TCP: \

-						case PROTO_TLS: \

-							switch(msg->rcv.proto){ \

-								case PROTO_WS: \

-								case PROTO_WSS: \

-									new_len+=2; \

-									break; \

-								default: \

-									new_len+=3; \

-									break; \

-							} \

-							break; \

-						case PROTO_SCTP: \

-							new_len+=4; \

-							break; \

-						default: \

-						LM_CRIT("unknown proto %d\n", msg->rcv.bind_address->proto); \

-					}\

-				}else{ \

-					/* FIXME */ \

-					LM_CRIT("FIXME: null bind_address\n"); \

-				}; \

-				break; \

-			case SUBST_RCV_ALL: \

-				if (msg->rcv.bind_address){ \

-					new_len+=recv_address_str->len; \

-					if (msg->rcv.bind_address->address.af!=AF_INET) \

-						new_len+=2; \

-					if (recv_port_no!=SIP_PORT){ \

-						/* add :port_no */ \

-						new_len+=1+recv_port_str->len; \

-					}\

-						/*add;transport=xxx*/ \

-					switch(msg->rcv.bind_address->proto){ \

-						case PROTO_NONE: \

-						case PROTO_UDP: \

-							break; /* udp is the default */ \

-						case PROTO_TCP: \

-						case PROTO_TLS: \

-							switch(msg->rcv.proto){ \

-								case PROTO_WS: \

-								case PROTO_WSS: \

-									new_len+=TRANSPORT_PARAM_LEN+2; \

-									break; \

-								default: \

-									new_len+=TRANSPORT_PARAM_LEN+3; \

-									break; \

-							} \

-							break; \

-						case PROTO_SCTP: \

-							new_len+=TRANSPORT_PARAM_LEN+4; \

-							break; \

-						default: \

-						LM_CRIT("unknown proto %d\n", \

-								msg->rcv.bind_address->proto); \

-					}\

-					RCVCOMP_LUMP_LEN \

-				}else{ \

-					/* FIXME */ \

-					LM_CRIT("FIXME: null bind_address\n"); \

-				}; \

-				break; \

-			case SUBST_SND_IP: \

-				if (send_sock){ \

-					new_len+=send_address_str->len; \

-					if (send_sock->address.af!=AF_INET && \

-							send_address_str==&(send_sock->address_str)) \

-						new_len+=2; \

-				}else{ \

-					LM_CRIT("FIXME: null send_sock\n"); \

-				}; \

-				break; \

-			case SUBST_SND_PORT: \

-				if (send_sock){ \

-					new_len+=send_port_str->len; \

-				}else{ \

-					LM_CRIT("FIXME: null send_sock\n"); \

-				}; \

-				break; \

-			case SUBST_SND_PROTO: \

-				if (send_sock){ \

-					switch(send_sock->proto){ \

-						case PROTO_NONE: \

-						case PROTO_UDP: \

-							new_len+=3; \

-							break; \

-						case PROTO_TCP: \

-						case PROTO_TLS: \

-							switch(send_info->proto){ \

-								case PROTO_WS: \

-								case PROTO_WSS: \

-									new_len+=2; \

-									break; \

-								default: \

-									new_len+=3; \

-									break; \

-							} \

-							break; \

-						case PROTO_SCTP: \

-							new_len+=4; \

-							break; \

-						default: \

-						LM_CRIT("unknown proto %d\n", send_sock->proto); \

-					}\

-				}else{ \

-					LM_CRIT("FIXME: null send_sock\n"); \

-				}; \

-				break; \

-			case SUBST_SND_ALL: \

-				if (send_sock){ \

-					new_len+=send_address_str->len; \

-					if ((send_sock->address.af!=AF_INET) && \

-							(send_address_str==&(send_sock->address_str))) \

-						new_len+=2; \

-					if ((send_sock->port_no!=SIP_PORT) || \

-							(send_port_str!=&(send_sock->port_no_str))){ \

-						/* add :port_no */ \

-						new_len+=1+send_port_str->len; \

-					}\

-					/*add;transport=xxx*/ \

-					switch(send_sock->proto){ \

-						case PROTO_NONE: \

-						case PROTO_UDP: \

-							break; /* udp is the default */ \

-						case PROTO_TCP: \

-						case PROTO_TLS: \

-							switch(send_info->proto){ \

-								case PROTO_WS: \

-								case PROTO_WSS: \

-									new_len+=TRANSPORT_PARAM_LEN+2; \

-									break; \

-								default: \

-									new_len+=TRANSPORT_PARAM_LEN+3; \

-									break; \

-							} \

-							break; \

-						case PROTO_SCTP: \

-							new_len+=TRANSPORT_PARAM_LEN+4; \

-							break; \

-						default: \

-						LM_CRIT("unknown proto %d\n", send_sock->proto); \

-					}\

-					SENDCOMP_LUMP_LEN \

-				}else{ \

-					/* FIXME */ \

-					LM_CRIT("FIXME: null send_sock\n"); \

-				}; \

-				break; \

-			case SUBST_NOP: /* do nothing */ \

-				break; \

-			default: \

-				LM_CRIT("unknown subst type %d\n", (subst_l)->u.subst); \

-		}

-	

-	if (send_info){

-		send_sock=send_info->send_sock;

-	}else{

-		send_sock=0;

-	};

-	s_offset=0;

-	new_len=0;

-	/* init send_address_str & send_port_str */

-	if(send_sock && send_sock->useinfo.name.len>0)

-		send_address_str=&(send_sock->useinfo.name);

-	else if (msg->set_global_address.len)

-		send_address_str=&(msg->set_global_address);

-	else

-		send_address_str=&(send_sock->address_str);

-	if(send_sock && send_sock->useinfo.port_no>0)

-		send_port_str=&(send_sock->useinfo.port_no_str);

-	else if (msg->set_global_port.len)

-		send_port_str=&(msg->set_global_port);

-	else

-		send_port_str=&(send_sock->port_no_str);

-	/* init recv_address_str, recv_port_str & recv_port_no */

-	if(msg->rcv.bind_address) {

-		if(msg->rcv.bind_address->useinfo.name.len>0)

-			recv_address_str=&(msg->rcv.bind_address->useinfo.name);

-		else

-			recv_address_str=&(msg->rcv.bind_address->address_str);

-		if(msg->rcv.bind_address->useinfo.port_no>0) {

-			recv_port_str=&(msg->rcv.bind_address->useinfo.port_no_str);

-			recv_port_no = msg->rcv.bind_address->useinfo.port_no;

-		} else {

-			recv_port_str=&(msg->rcv.bind_address->port_no_str);

-			recv_port_no = msg->rcv.bind_address->port_no;

-		}

-	}

-

-	for(t=lumps;t;t=t->next){

-		/* skip if this is an OPT lump and the condition is not satisfied */

-		if ((t->op==LUMP_ADD_OPT)&& !lump_check_opt(t, msg, send_info))

-			continue;

-		for(r=t->before;r;r=r->before){

-			switch(r->op){

-				case LUMP_ADD:

-					new_len+=r->len;

-					break;

-				case LUMP_ADD_SUBST:

-					SUBST_LUMP_LEN(r);

-					break;

-				case LUMP_ADD_OPT:

-					/* skip if this is an OPT lump and the condition is

-					 * not satisfied */

-					if (!lump_check_opt(r, msg, send_info))

-						goto skip_before;

-					break;

-				default:

-					/* only ADD allowed for before/after */

-						LM_CRIT("invalid op for data lump (%x)\n", r->op);

-			}

-		}

-skip_before:

-		switch(t->op){

-			case LUMP_ADD:

-				new_len+=t->len;

-				break;

-			case LUMP_ADD_SUBST:

-				SUBST_LUMP_LEN(t);

-				break;

-			case LUMP_ADD_OPT:

-				/* we don't do anything here, it's only a condition for

-				 * before & after */

-				break;

-			case LUMP_DEL:

-				/* fix overlapping deleted zones */

-				if (t->u.offset < s_offset){

-					/* change len */

-					if (t->len>s_offset-t->u.offset)

-							t->len-=s_offset-t->u.offset;

-					else t->len=0;

-					t->u.offset=s_offset;

-				}

-				s_offset=t->u.offset+t->len;

-				new_len-=t->len;

-				break;

-			case LUMP_NOP:

-				/* fix offset if overlapping on a deleted zone */

-				if (t->u.offset < s_offset){

-					t->u.offset=s_offset;

-				}else

-					s_offset=t->u.offset;

-				/* do nothing */

-				break;

-			default:

-				LM_CRIT("invalid op for data lump (%x)\n", r->op);

-		}

-		for (r=t->after;r;r=r->after){

-			switch(r->op){

-				case LUMP_ADD:

-					new_len+=r->len;

-					break;

-				case LUMP_ADD_SUBST:

-					SUBST_LUMP_LEN(r);

-					break;

-				case LUMP_ADD_OPT:

-					/* skip if this is an OPT lump and the condition is

-					 * not satisfied */

-					if (!lump_check_opt(r, msg, send_info))

-						goto skip_after;

-					break;

-				default:

-					/* only ADD allowed for before/after */

-					LM_CRIT("invalid op for data lump (%x)\n", r->op);