/*
 * Soft:        Keepalived is a failover program for the LVS project
 *              <www.linuxvirtualserver.org>. It monitor & manipulate
 *              a loadbalanced server pool using multi-layer checks.
 *
 * Part:        bfd.c include file.
 *
 * Author:      Ilya Voronin, <ivoronin@gmail.com>
 *
 *              This program is distributed in the hope that it will be useful,
 *              but WITHOUT ANY WARRANTY; without even the implied warranty of
 *              MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
 *              See the GNU General Public License for more details.
 *
 *              This program 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.
 *
 * Copyright (C) 2015-2017 Alexandre Cassen, <acassen@gmail.com>
 */
#ifndef _BFD_H_
#define _BFD_H_

#include <stdbool.h>
#include <stdint.h>
#include <sys/socket.h>

#include "scheduler.h"
#include "timer.h"

/*
 *	RFC5881
 */
#define BFD_CONTROL_PORT	"3784"
#define BFD_CONTROL_TTL		255
#define BFD_CONTROL_HOPLIMIT	64

#define	BFD_MIN_PORT		49152
#define	BFD_MAX_PORT		65535

/*
 *	Default parameters and limits
 */
#define BFD_MINRX_MIN		1U
#define BFD_MINRX_MAX_SENSIBLE	1000U
#define BFD_MINRX_MAX		(UINT32_MAX / 1000U)
#define BFD_MINRX_DEFAULT	10U

#define BFD_MINTX_MIN		1U
#define BFD_MINTX_MAX_SENSIBLE	1000U
#define BFD_MINTX_MAX		(UINT32_MAX / 1000U)
#define BFD_MINTX_DEFAULT	10U

#define BFD_IDLETX_MIN		1000U
#define BFD_IDLETX_MAX_SENSIBLE	10000U
#define BFD_IDLETX_MAX		(UINT32_MAX / 1000U)
#define BFD_IDLETX_DEFAULT	1000U

#define BFD_MULTIPLIER_MIN	1U
#define BFD_MULTIPLIER_MAX_SENSIBLE 10U
#define BFD_MULTIPLIER_MAX	255U
#define BFD_MULTIPLIER_DEFAULT	5U

#define BFD_WEIGHT_MIN		-253
#define BFD_WEIGHT_MAX		253
#define BFD_WEIGHT_DEFAULT	0

#define BFD_TTL_MAX		255

/*
 *	BFD Session
 */
/* Maximum instance name length including \0 */
#define BFD_INAME_MAX 32

typedef struct _bfd {
	/* Configuration parameters */
	char			iname[BFD_INAME_MAX];	/* Instance name */
	struct sockaddr_storage	nbr_addr;		/* Neighbor address */
	struct sockaddr_storage	src_addr;		/* Source address */
	uint32_t		local_min_rx_intv;	/* Required min RX interval */
	uint32_t		local_min_tx_intv;	/* Desired min TX interval */
	uint32_t		local_idle_tx_intv;	/* Desired idle TX interval */
	uint8_t			local_detect_mult;	/* Local detection multiplier */
	uint8_t			ttl;			/* TTL/hopcount to send */
	uint8_t			max_hops;		/* Maximum number of hops allowed to be traversed by received packet */
	bool			passive;		/* Operate in passive mode */
#ifdef _WITH_VRRP_
	bool			vrrp;			/* Only send events to VRRP process */
#endif
#ifdef _WITH_LVS_
	bool			checker;		/* Only send events to checker process */
#endif

	/* Internal variables */
	int			fd_out;			/* Output socket fd */
	thread_ref_t		thread_out;		/* Output socket thread */
	unsigned long		sands_out;		/* Output thread sands, used for suspend/resume */
	thread_ref_t		thread_exp;		/* Expire thread */
	unsigned long		sands_exp;		/* Expire thread sands, used for suspend/resume */
	thread_ref_t		thread_rst;		/* Reset thread */
	unsigned long		sands_rst;		/* Reset thread sands, used for suspend/resume */
	bool			send_error;		/* Set if last send had an error */

	/* State variables */
	uint8_t			local_state:2;		/* Local state */
	uint8_t			remote_state:2;		/* Remote state */
	uint32_t		local_discr;		/* Local discriminator */
	uint32_t		remote_discr;		/* Remote discriminator */
	uint8_t			local_diag:5;		/* Local diagnostic code */
	uint8_t			remote_diag:5;		/* Local diagnostic code */
	uint32_t		remote_min_tx_intv;	/* Remote min TX interval */
	uint32_t		remote_min_rx_intv;	/* Remote min RX interval */
	uint8_t			local_demand;		/* Local demand mode */
	uint8_t			remote_demand;		/* Remote demand mode */
	uint8_t			remote_detect_mult;	/* Remote detection multiplier */
	bool			poll;			/* Poll sequence flag */
	bool			final;			/* Final flag */

	/* Calculated values */
	uint32_t		local_tx_intv;		/* Local transmit interval */
	uint32_t		remote_tx_intv;		/* Remote transmit interval */
	uint64_t		local_detect_time;	/* Local detection time */
	uint64_t		remote_detect_time;	/* Remote detection time */
	timeval_t		last_seen;		/* Time of the last packet received */

	/* Linked list member */
	list_head_t		e_list;
} bfd_t;

/*
 * BFD Control Packet Header
 */
typedef struct _bfdhdr {
#if __BYTE_ORDER == __LITTLE_ENDIAN
	uint8_t diag:5;
	uint8_t version:3;

	/* flags */
	uint8_t multipoint:1;
	uint8_t demand:1;
	uint8_t auth:1;
	uint8_t cplane:1;
	uint8_t final:1;
	uint8_t poll:1;
	uint8_t state:2;
#elif __BYTE_ORDER == __BIG_ENDIAN
	uint8_t version:3;
	uint8_t diag:5;

	/* flags */
	uint8_t state:2;
	uint8_t poll:1;
	uint8_t final:1;
	uint8_t cplane:1;
	uint8_t auth:1;
	uint8_t demand:1;
	uint8_t multipoint:1;
#else
#error "Unsupported byte order"
#endif
	uint8_t detect_mult;
	uint8_t len;

	uint32_t local_discr;
	uint32_t remote_discr;
	uint32_t min_tx_intv;
	uint32_t min_rx_intv;
	uint32_t min_echo_rx_intv;
} bfdhdr_t;

/*
  Version
*/
#define BFD_VERSION_1			1U

/*
   State (Sta)
*/

#define BFD_STATE_ADMINDOWN		0U
#define BFD_STATE_DOWN			1U
#define BFD_STATE_INIT			2U
#define BFD_STATE_UP			3U

#define	BFD_STATE_STR(s) \
	(BFD_STATE_ADMINDOWN == s ? "AdminDown" : \
	(BFD_STATE_DOWN == s ? "Down" : \
	(BFD_STATE_INIT == s ? "Init" : \
	(BFD_STATE_UP == s ? "Up" : "Unknown"))))

#define BFD_ISADMINDOWN(b) (b->local_state == BFD_STATE_ADMINDOWN)
#define BFD_ISDOWN(b) (b->local_state == BFD_STATE_DOWN)
#define BFD_ISINIT(b) (b->local_state == BFD_STATE_INIT)
#define BFD_ISUP(b) (b->local_state == BFD_STATE_UP)

/*
   Diagnostic (Diag)
*/

#define BFD_DIAG_NO_DIAG		0U
#define BFD_DIAG_EXPIRED		1U
#define BFD_DIAG_ECHO_FAILED		2U
#define BFD_DIAG_NBR_SIGNALLED_DOWN	3U
#define BFD_DIAG_FWD_PLANE_RESET	4U
#define BFD_DIAG_PATH_DOWN		5U
#define BFD_DIAG_CAT_PATH_DOWN		6U
#define BFD_DIAG_ADMIN_DOWN		7U
#define BFD_DIAG_RCAT_PATH_DOWN		8U

#define	BFD_DIAG_STR(d) \
	(BFD_DIAG_NO_DIAG == d ? "No Diagnostic" : \
	(BFD_DIAG_EXPIRED == d ? "Control Detection Time Expired" : \
	(BFD_DIAG_ECHO_FAILED == d ? "Echo Function Failed" : \
	(BFD_DIAG_NBR_SIGNALLED_DOWN == d ? "Neighbor Signaled Session Down" : \
	(BFD_DIAG_FWD_PLANE_RESET == d ? "Forwarding Plane Reset" : \
	(BFD_DIAG_PATH_DOWN == d ? "Path Down" : \
	(BFD_DIAG_CAT_PATH_DOWN == d ? "Concatenated Path Down" : \
	(BFD_DIAG_ADMIN_DOWN == d ? "Administratively Down" : \
	(BFD_DIAG_RCAT_PATH_DOWN == d ? "Reverse Concatenated Path Down" : "Unknown")))))))))

#define BFD_VALID_DIAG(d)    (d <= 8)

/*
 * BFD Packet structure
 */
typedef struct _bfdpkt {
	bfdhdr_t *hdr;
	struct sockaddr_storage src_addr;
	struct sockaddr_storage dst_addr;
	unsigned int ttl;
	unsigned int len;
	const char *buf;
} bfdpkt_t;

extern void bfd_update_local_tx_intv(bfd_t *);
extern void bfd_update_remote_tx_intv(bfd_t *);
extern void bfd_idle_local_tx_intv(bfd_t * bfd);
extern void bfd_set_poll(bfd_t *);
extern void bfd_reset_state(bfd_t *);
extern void bfd_init_state(bfd_t *);
extern void bfd_copy_state(bfd_t *, const bfd_t *, bool);
extern void bfd_copy_sands(bfd_t *, const bfd_t *);
extern bool bfd_check_packet(const bfdpkt_t *);
extern bool bfd_check_packet_ttl(const bfdpkt_t *, const bfd_t *);
extern void bfd_build_packet(bfdpkt_t * pkt, bfd_t *, char *,
			     const ssize_t);

#endif				/* _BFD_H_ */