* $Id$
 * Copyright (C) 2001-2003 Fhg Fokus
 * 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
 * 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

#ifndef _T_FUNCS_H
#define _T_FUNCS_H

#include <errno.h>
#include <netdb.h>

#include "../../mem/shm_mem.h"
#include "../../parser/msg_parser.h"
#include "../../globals.h"
#include "../../udp_server.h"
#include "../../msg_translator.h"
#include "../../timer.h"
#include "../../forward.h"
#include "../../mem/mem.h"
#include "../../md5utils.h"
#include "../../ip_addr.h"
#include "../../parser/parse_uri.h"

#include "config.h"
#include "lock.h"
#include "timer.h"
#include "sip_msg.h"
#include "h_table.h"
#include "ut.h"

struct s_table;
struct timer;
struct entry;
struct cell;

extern int noisy_ctimer;

/* send a private buffer: utilize a retransmission structure
   but take a separate buffer not refered by it; healthy
   for reducing time spend in REPLIES locks

int send_pr_buffer( struct retr_buf *rb,
	void *buf, int len, char *function, int line );

/* send a buffer -- 'PR' means private, i.e., it is assumed noone
   else can affect the buffer during sending time
#define SEND_PR_BUFFER(_rb,_bf,_le ) \
	send_pr_buffer( (_rb), (_bf), (_le),  __FUNCTION__, __LINE__ )

#define SEND_BUFFER( _rb ) \
	SEND_PR_BUFFER( (_rb) , (_rb)->buffer , (_rb)->buffer_len )

#define UNREF_UNSAFE(_T_cell) ({  (_T_cell)->ref_count--; })
#define UNREF(_T_cell) ({ \
	LOCK_HASH( (_T_cell)->hash_index ); \
	UNREF_UNSAFE(_T_cell); \
	UNLOCK_HASH( (_T_cell)->hash_index ); })
#define REF_UNSAFE(_T_cell) ({  (_T_cell)->ref_count++; })
#define REF(_T_cell) ({ \
	LOCK_HASH( (_T_cell)->hash_index ); \
	REF_UNSAFE(_T_cell); \
	UNLOCK_HASH( (_T_cell)->hash_index ); })
#define INIT_REF_UNSAFE(_T_cell) (_T_cell)->ref_count=1
#define IS_REFFED_UNSAFE(_T_cell) ((_T_cell)->ref_count!=0)

int   tm_startup();
void tm_shutdown();

/* function returns:
 *       1 - a new transaction was created
 *      -1 - error, including retransmission
int  t_add_transaction( struct sip_msg* p_msg  );

/* returns 1 if everything was OK or -1 for error
int t_release_transaction( struct cell *trans );

/* int forward_serial_branch(struct cell* Trans,int branch); */
int t_put_on_wait(  struct cell  *Trans  );
int get_ip_and_port_from_uri( str* uri , unsigned int *param_ip,
	unsigned int *param_port);

int t_newtran( struct sip_msg* p_msg );

void put_on_wait(  struct cell  *Trans  );

void start_retr( struct retr_buf *rb );

void cleanup_localcancel_timers( struct cell *t );

int t_relay_to( struct sip_msg  *p_msg ,
	struct proxy_l *proxy, int replicate ) ;