forward.h
888ca09d
 /*
  *  $Id$
7dd0b342
  *
53c7e0f1
  * Copyright (C) 2001-2003 FhG Fokus
7dd0b342
  *
  * This file is part of ser, a free SIP server.
  *
  * ser 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
  *
  * For a license to use the ser software under conditions
  * other than those described here, or to purchase support for this
  * software, please contact iptel.org by e-mail at the following addresses:
  *    info@iptel.org
  *
  * ser 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., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
888ca09d
  */
c030910c
 /*
  * History:
  * -------
3e8c3475
  *  2001-??-?? created by andrei
  *  ????-??-?? lots of changes by a lot of people
  *  2003-02-11 added inline msg_send (andrei)
  *  2003-04-07 changed all ports to host byte order (andrei)
  *  2003-04-12  FORCE_RPORT_T added (andrei)
5dcfb23d
  *  2003-04-15  added tcp_disable support (andrei)
e6a2b12e
  *  2006-04-12  reduced msg_send() parameter list: it uses now a struct 
  *               dest_info param. (andrei)
c030910c
  */
888ca09d
 
 
7dd0b342
 
888ca09d
 #ifndef forward_h
 #define forward_h
 
5dcfb23d
 #include "globals.h"
3881f12c
 #include "parser/msg_parser.h"
888ca09d
 #include "route.h"
4ac74c03
 #include "proxy.h"
36ef0329
 #include "ip_addr.h"
888ca09d
 
c030910c
 #include "stats.h"
 #include "udp_server.h"
 #ifdef USE_TCP
 #include "tcp_server.h"
 #endif
 
1b1b19d8
 
a35ad52c
 
 struct socket_info* get_send_socket(struct sip_msg* msg,
 									union sockaddr_union* su, int proto);
2d4b798e
 struct socket_info* get_out_socket(union sockaddr_union* to, int proto);
50d5fa87
 int check_self(str* host, unsigned short port, unsigned short proto);
f2f969dd
 int forward_request( struct sip_msg* msg,  struct proxy_l* p, int proto);
4e2fdd79
 int update_sock_struct_from_via( union sockaddr_union* to,
181e7cc0
 								 struct sip_msg* msg,
 								 struct via_body* via );
20581c5a
 
 /* use src_ip, port=src_port if rport, via port if via port, 5060 otherwise */
f2f969dd
 #define update_sock_struct_from_ip(  to, msg ) \
 	init_su((to), &(msg)->rcv.src_ip, \
059afe05
 			(((msg)->via1->rport)||((msg)->msg_flags&FL_FORCE_RPORT))? \
3e8c3475
 							(msg)->rcv.src_port: \
 							((msg)->via1->port)?(msg)->via1->port: SIP_PORT )
f2f969dd
 
4ac74c03
 int forward_reply( struct sip_msg* msg);
888ca09d
 
c030910c
 
 
 /* params:
e6a2b12e
  * dst = struct dest_info containing:
  *    send_sock = 0 if not known (e.g. for udp in some cases), non-0 otherwise
  *    proto = TCP|UDP
  *    to = destination (sockaddr_union)
  *    id = only used on tcp, it will force sending on connection "id" if id!=0 
  *         and the connection exists, else it will send to "to" 
  *        (useful for sending replies on  the same connection as the request
  *         that generated them; use 0 if you don't want this)
  * buf, len = buffer
c030910c
  * returns: 0 if ok, -1 on error*/
e6a2b12e
 static inline int msg_send(struct dest_info* dst, char* buf, int len)
c030910c
 {
 	
e6a2b12e
 	if (dst->proto==PROTO_UDP){
 		if (dst->send_sock==0) 
 			dst->send_sock=get_send_socket(0, &dst->to, dst->proto);
 		if (dst->send_sock==0){
c030910c
 			LOG(L_ERR, "msg_send: ERROR: no sending socket found\n");
 			goto error;
 		}
e6a2b12e
 		if (udp_send(dst, buf, len)==-1){
c030910c
 			STATS_TX_DROPS;
 			LOG(L_ERR, "msg_send: ERROR: udp_send failed\n");
 			goto error;
 		}
 	}
 #ifdef USE_TCP
e6a2b12e
 	else if (dst->proto==PROTO_TCP){
5dcfb23d
 		if (tcp_disable){
c030910c
 			STATS_TX_DROPS;
5dcfb23d
 			LOG(L_WARN, "msg_send: WARNING: attempt to send on tcp and tcp"
 					" support is disabled\n");
c030910c
 			goto error;
5dcfb23d
 		}else{
e6a2b12e
 			if (tcp_send(dst, buf, len)<0){
5dcfb23d
 				STATS_TX_DROPS;
 				LOG(L_ERR, "msg_send: ERROR: tcp_send failed\n");
 				goto error;
 			}
c030910c
 		}
 	}
e9b02e8e
 #ifdef USE_TLS
e6a2b12e
 	else if (dst->proto==PROTO_TLS){
e9b02e8e
 		if (tls_disable){
 			STATS_TX_DROPS;
 			LOG(L_WARN, "msg_send: WARNING: attempt to send on tls and tls"
 					" support is disabled\n");
 			goto error;
 		}else{
e6a2b12e
 			if (tcp_send(dst, buf, len)<0){
e9b02e8e
 				STATS_TX_DROPS;
 				LOG(L_ERR, "msg_send: ERROR: tcp_send failed\n");
 				goto error;
 			}
 		}
 	}
 #endif /* USE_TLS */
 #endif /* USE_TCP */
c030910c
 	else{
e6a2b12e
 			LOG(L_CRIT, "BUG: msg_send: unknown proto %d\n", dst->proto);
c030910c
 			goto error;
 	}
 	return 0;
 error:
 	return -1;
 }
 
888ca09d
 #endif