/******************************************************************************
 * 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_H_
#define _PROXY_H_

#include <stdarg.h>
#include <list.h>

#include "proxy_msg.h"
#include "proxy_cmd.h"
#include "proxy_event.h"
#include "proxy_attr.h"

#define PROXY_RES_OK		0
#define PROXY_RES_ERR		-1

#define PROXY_ERR_CLIENT	0
#define PROXY_ERR_SERVER	1
#define PROXY_ERR_PROTO		2
#define PROXY_ERR_SYSTEM	3

#define PROXY_EVENT_HANDLER		1
#define PROXY_CMD_HANDLER		2

struct proxy;
struct proxy_clnt;
struct proxy_svr;

struct proxy_clnt_helper_funcs {
	void (*eventhandler)(void *, void *);
	void *eventdata;
};
typedef struct proxy_clnt_helper_funcs	proxy_clnt_helper_funcs;

struct proxy_clnt_funcs {
	/*
	 * Service functions
	 */
	int (*init)(struct proxy_clnt *, void **, char *, va_list);
	int (*connect)(struct proxy_clnt *);
	int (*create)(struct proxy_clnt *);
	int (*progress)(struct proxy_clnt *);
};
typedef struct proxy_clnt_funcs	proxy_clnt_funcs;

struct proxy_svr_helper_funcs {
	/*
	 * Service functions
	 */
	int (*newconn)(void);
	int (*numservers)(void);
};
typedef struct proxy_svr_helper_funcs	proxy_svr_helper_funcs;

/*
 * Functions for managing proxy server.
 */
struct proxy_svr_funcs {
	int (*init)(struct proxy_svr *, void **);
	int (*create)(struct proxy_svr *, int);
	int (*connect)(struct proxy_svr *, char *, int);
	int (*progress)(struct proxy_svr *);
	void (*finish)(struct proxy_svr *);
};
typedef struct proxy_svr_funcs	proxy_svr_funcs;

/*
 * A proxy client send commands to and receives events from a server.
 */
struct proxy_clnt {
	struct proxy *						proxy;
	struct proxy_clnt_helper_funcs *	clnt_helper_funcs;
	void *								clnt_data;
	struct timeval *					clnt_timeout;
	List *								clnt_events;
};
typedef struct proxy_clnt	proxy_clnt;

/*
 * A proxy server receives commands from and sends events to a client.
 */
struct proxy_svr {
	struct proxy *					proxy;
	struct proxy_svr_helper_funcs *	svr_helper_funcs;
	struct proxy_commands *			svr_commands;
	void *							svr_data;
	struct timeval *				svr_timeout;
	List *							svr_events;
};
typedef struct proxy_svr	proxy_svr;

/*
 * The proxy structure encapsulates both the client and server sides
 * of the communication protocol.
 */
struct proxy {
	char *							name;
	struct proxy_handler_funcs *	handler_funcs;
	struct proxy_clnt_funcs *		clnt_funcs;
	struct proxy_svr_funcs *		svr_funcs;
};
typedef struct proxy	proxy;

extern proxy 	proxies[];

extern int		find_proxy(char *, proxy **);
extern void		proxy_set_error(int, char *);
extern int		proxy_get_error(void);
extern char *	proxy_get_error_str(void);
extern void		proxy_event_callback(proxy *, char *);

extern int		proxy_svr_init(char *, struct timeval *, proxy_svr_helper_funcs *, proxy_commands *cmds, proxy_svr **);
extern int		proxy_svr_create(proxy_svr *, int);
extern int		proxy_svr_connect(proxy_svr *, char *, int);
extern int		proxy_svr_progress(proxy_svr *);
extern void		proxy_svr_finish(proxy_svr *);
extern void		proxy_svr_queue_msg(proxy_svr *, proxy_msg *);

extern int		proxy_clnt_init(char *, struct timeval *, proxy_clnt_helper_funcs *, proxy_clnt **, char *, va_list);
extern int 		proxy_clnt_connect(proxy_clnt *);
extern int 		proxy_clnt_create(proxy_clnt *);
extern int 		proxy_clnt_progress(proxy_clnt *);
extern void		proxy_clnt_queue_msg(proxy_clnt *, proxy_msg *);

#endif /* _PROXY_H_*/