/*
* 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_ */