/*
 * Copyright (c) 2010-2011, Red Hat, Inc.
 *
 * Permission to use, copy, modify, and/or distribute this software for any
 * purpose with or without fee is hereby granted, provided that the above
 * copyright notice and this permission notice appear in all copies.
 *
 * THE SOFTWARE IS PROVIDED "AS IS" AND RED HAT, INC. DISCLAIMS ALL WARRANTIES
 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL RED HAT, INC. BE LIABLE
 * FOR ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION
 * OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN
 * CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 */

/*
 * Author: Jan Friesse <jfriesse@redhat.com>
 */

#ifndef _RHFUNC_H_
#define _RHFUNC_H_

#include <sys/types.h>

#include <sys/queue.h>
#include <sys/socket.h>

#include <ifaddrs.h>
#include <netdb.h>

#include "addrfunc.h"
#include "gcra.h"
#include "util.h"

#ifdef __cplusplus
extern "C" {
#endif

enum rh_client_state {
	RH_CS_INITIAL,
	RH_CS_QUERY,
	RH_CS_STOP
};

enum rh_server_state {
	RH_SS_INITIAL,
	RH_SS_ANSWER,
	RH_SS_FINISHING,
};

enum rh_client_stop_reason {
	RH_CSR_NONE,
	RH_CSR_SERVER,
	RH_CSR_TO_SEND_EXHAUSTED,
	RH_CSR_SEND_MAXIMUM,
	RH_CSR_REMOTE_VERSION_RECEIVED,
};

enum rh_list_finish_state {
	RH_LFS_CLIENT,
	RH_LFS_SERVER,
	RH_LFS_BOTH,
};

/*
 * Remote host info item, client info part
 */
struct rh_item_ci {
	enum		rh_client_state state;
	char		client_id[CLIENTID_LEN];
	struct timeval	last_init_ts;
	struct timeval	last_query_ts;
	char		*server_info;
	char		*ses_id;
	uint32_t	*dup_buffer[2];
	size_t		server_info_len;
	size_t		ses_id_len;
	double		avg_rtt[2];
	double		m2_rtt[2];
	double		rtt_max[2];
	double		rtt_min[2];
	uint64_t	no_err_msgs;
	uint64_t	no_dups[2];
	uint64_t	no_received[2];
	uint64_t	no_sent;
	uint32_t	first_mcast_seq;
	uint32_t	lru_seq_num; /* Last Received Unicast seq number */
	uint32_t	seq_num;
	int		dup_buf_items;
	int		seq_num_overflow;
};

/*
 * Remote host info item, server info part
 */
struct rh_item_si {
	enum			rh_server_state state;
	char			ses_id[SESSIONID_LEN];
	struct gcra_item	gcra;
	struct timeval		last_init_ts;
};

/*
 * Remote host info item. This is intended to use with TAILQ list.
 */
struct rh_item {
	struct ai_item	*addr;
	struct rh_item_ci client_info;
	struct rh_item_si server_info;
	TAILQ_ENTRY(rh_item) entries;
};

/*
 * Typedef of TAILQ head of list of rh_item(s)
 */
TAILQ_HEAD(rh_list, rh_item);

extern struct rh_item	*rh_list_add_item(struct rh_list *rh_list, struct ai_item *addr,
    int dup_buf_items, int rate_limit_time);

extern void		 rh_list_create(struct rh_list *rh_list, struct ai_list *remote_addrs,
    int dup_buf_items, int rate_limit_time);

extern struct rh_item	*rh_list_find(struct rh_list *rh_list, const struct sockaddr *sa);
extern void		 rh_list_free(struct rh_list *rh_list);

extern void		 rh_list_gen_cid(struct rh_list *rh_list,
    const struct ai_item *local_addr);

extern int		 rh_list_hn_max_len(struct rh_list *rh_list);

extern unsigned int	 rh_list_length(const struct rh_list *rh_list);

extern void		 rh_list_put_to_finish_state(struct rh_list *rh_list,
    enum rh_list_finish_state fs);

#ifdef __cplusplus
}
#endif

#endif /* _RHFUNC_H_ */