/******************************************************************************
 * Copyright (c) 2005 The Regents of the University of California. 
 * This material was produced under U.S. Government contract W-7405-ENG-36 
 * for Los Alamos National Laboratory, which is operated by the University 
 * of California for the U.S. Department of Energy. The U.S. Government has 
 * rights to use, reproduce, and distribute this software. NEITHER THE 
 * GOVERNMENT NOR THE UNIVERSITY MAKES ANY WARRANTY, EXPRESS OR IMPLIED, OR 
 * ASSUMES ANY LIABILITY FOR THE USE OF THIS SOFTWARE. If software is modified 
 * to produce derivative works, such modified software should be clearly 
 * marked, so as not to confuse it with the version available from LANL.
 * 
 * Additionally, this program and the accompanying materials 
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 * 
 * LA-CC 04-115
 ******************************************************************************/
 
#ifndef _PROXY_TCP_H_
#define _PROXY_TCP_H_

#include "compat.h"

#define PROXY_TCP_PORT		12345
#define MSG_LEN_SIZE		8
#define MSG_LENGTH_MASK		0xffffffff

struct proxy_tcp_conn {
	proxy_clnt *	clnt;
	proxy_svr *		svr;
	char *			host;
	int				port;
	int				connected;
	SOCKET			sess_sock;
	SOCKET			svr_sock;
	char *			buf;
	char			msg_len_buf[11];
	int				buf_size;
	int				buf_pos;
	int				total_read;
	char *			msg;
	int				msg_len;
	void			(*event_handler)(void *, void *);
	void *			event_data;
};
typedef struct proxy_tcp_conn	proxy_tcp_conn;

extern struct timeval TCPTIMEOUT;
extern proxy_clnt_funcs proxy_tcp_clnt_funcs;
extern proxy_svr_funcs proxy_tcp_svr_funcs;

extern void		proxy_tcp_create_conn(proxy_tcp_conn **);
extern void		proxy_tcp_destroy_conn(proxy_tcp_conn *);
extern int		proxy_tcp_recv_msgs(proxy_tcp_conn *);
extern int		proxy_tcp_get_msg(proxy_tcp_conn *, char **, int *len);
extern int		proxy_tcp_send_msg(proxy_tcp_conn *, char *, int);
extern int		proxy_tcp_decode_string(char *, char **, char **);
extern void		skipspace(char *);
extern char *	getword(char **);

#endif /* _PROXY_TCP_H_*/