/*
 * This file and its contents are supplied under the terms of the
 * Common Development and Distribution License ("CDDL"), version 1.0.
 * You may only use this file in accordance with the terms of version
 * 1.0 of the CDDL.
 *
 * A full copy of the text of the CDDL should have accompanied this
 * source.  A copy of the CDDL is also available via the Internet at
 * http://www.illumos.org/license/CDDL.
 */

/*
 * Copyright 2015 Joyent, Inc.
 */

#ifndef _LIBVARPD_IMPL_H
#define	_LIBVARPD_IMPL_H

/*
 * varpd internal interfaces
 */

#include <libvarpd.h>
#include <libvarpd_provider.h>
#include <sys/avl.h>
#include <thread.h>
#include <synch.h>
#include <limits.h>
#include <libidspace.h>
#include <umem.h>

#ifdef __cplusplus
extern "C" {
#endif

#define	LIBVARPD_ID_MIN	1
#define	LIBVARPD_ID_MAX	INT32_MAX

typedef struct varpd_plugin {
	avl_node_t		vpp_node;
	const char		*vpp_name;
	overlay_target_mode_t	vpp_mode;
	const varpd_plugin_ops_t *vpp_ops;
	mutex_t			vpp_lock;
	uint_t			vpp_active;
} varpd_plugin_t;

typedef struct varpd_impl {
	mutex_t		vdi_lock;
	rwlock_t	vdi_pfdlock;
	avl_tree_t	vdi_plugins;	/* vdi_lock */
	avl_tree_t	vdi_instances;	/* vdi_lock */
	avl_tree_t	vdi_linstances;	/* vdi_lock */
	id_space_t	*vdi_idspace;	/* RO */
	umem_cache_t	*vdi_qcache;	/* RO */
	int		vdi_overlayfd;	/* RO */
	int		vdi_doorfd;	/* vdi_lock */
	int		vdi_persistfd;	/* vdi_plock */
	cond_t		vdi_lthr_cv;	/* vdi_lock */
	boolean_t	vdi_lthr_quiesce;	/* vdi_lock */
	uint_t		vdi_lthr_count;	/* vdi_lock */
} varpd_impl_t;

typedef enum varpd_instance_flags {
	VARPD_INSTANCE_F_ACTIVATED = 0x01
} varpd_instance_flags_t;

typedef struct varpd_instance {
	avl_node_t	vri_inode;
	avl_node_t	vri_lnode;
	uint64_t	vri_id;			/* RO */
	uint64_t	vri_vnetid;		/* RO */
	datalink_id_t	vri_linkid;		/* RO */
	overlay_target_mode_t vri_mode;		/* RO */
	overlay_plugin_dest_t vri_dest;		/* RO */
	varpd_impl_t	*vri_impl;		/* RO */
	varpd_plugin_t	*vri_plugin;		/* RO */
	void		*vri_private;		/* RO */
	mutex_t		vri_lock;
	varpd_instance_flags_t vri_flags;	/* vri_lock */
} varpd_instance_t;

typedef struct varpd_query {
	overlay_targ_lookup_t	vq_lookup;
	overlay_targ_resp_t	vq_response;
	varpd_instance_t	*vq_instance;
} varpd_query_t;

typedef struct varpd_client_create_arg {
	datalink_id_t	vcca_linkid;
	uint64_t	vcca_id;
	char		vcca_plugin[LIBVARPD_PROP_NAMELEN];
} varpd_client_create_arg_t;

typedef struct varpd_client_instance_arg {
	uint64_t	vcia_id;
} varpd_client_instance_arg_t;

typedef struct varpd_client_nprops_arg {
	uint64_t	vcna_id;
	uint_t		vcna_nprops;
	uint8_t		vcna_pad[4];
} varpd_client_nprops_arg_t;

typedef struct varpd_client_propinfo_arg {
	uint64_t	vcfa_id;
	uint_t		vcfa_propid;
	uint_t		vcfa_type;
	uint_t		vcfa_prot;
	uint32_t	vcfa_defsize;
	uint32_t	vcfa_psize;
	uint8_t		vcfa_pad[4];
	char		vcfa_name[LIBVARPD_PROP_NAMELEN];
	uint8_t		vcfa_default[LIBVARPD_PROP_SIZEMAX];
	uint8_t		vcfa_poss[LIBVARPD_PROP_SIZEMAX];
} varpd_client_propinfo_arg_t;

typedef struct varpd_client_prop_arg {
	uint64_t	vcpa_id;
	uint_t		vcpa_propid;
	uint8_t		vcpa_buf[LIBVARPD_PROP_SIZEMAX];
	size_t		vcpa_bufsize;
} varpd_client_prop_arg_t;

typedef struct varpd_client_lookup_arg {
	datalink_id_t	vcla_linkid;
	uint32_t	vcla_pad;
	uint64_t	vcla_id;
} varpd_client_lookup_arg_t;

typedef struct varpd_client_target_mode_arg {
	uint64_t	vtma_id;
	uint32_t	vtma_dest;
	uint32_t	vtma_mode;
} varpd_client_target_mode_arg_t;

typedef struct varpd_client_target_cache_arg {
	uint64_t	vtca_id;
	uint8_t		vtca_key[ETHERADDRL];
	uint8_t		vtca_pad[2];
	varpd_client_cache_entry_t vtca_entry;
} varpd_client_target_cache_arg_t;

typedef struct varpd_client_target_walk_arg {
	uint64_t	vtcw_id;
	uint64_t	vtcw_marker;
	uint64_t	vtcw_count;
	overlay_targ_cache_entry_t vtcw_ents[];
} varpd_client_target_walk_arg_t;

typedef enum varpd_client_command {
	VARPD_CLIENT_INVALID = 0x0,
	VARPD_CLIENT_CREATE,
	VARPD_CLIENT_ACTIVATE,
	VARPD_CLIENT_DESTROY,
	VARPD_CLIENT_NPROPS,
	VARPD_CLIENT_PROPINFO,
	VARPD_CLIENT_GETPROP,
	VARPD_CLIENT_SETPROP,
	VARPD_CLIENT_LOOKUP,
	VARPD_CLIENT_TARGET_MODE,
	VARPD_CLIENT_CACHE_FLUSH,
	VARPD_CLIENT_CACHE_DELETE,
	VARPD_CLIENT_CACHE_GET,
	VARPD_CLIENT_CACHE_SET,
	VARPD_CLIENT_CACHE_WALK,
	VARPD_CLIENT_MAX
} varpd_client_command_t;

typedef struct varpd_client_arg {
	uint_t	vca_command;
	uint_t	vca_errno;
	union {
		varpd_client_create_arg_t vca_create;
		varpd_client_instance_arg_t vca_instance;
		varpd_client_nprops_arg_t vca_nprops;
		varpd_client_propinfo_arg_t vca_info;
		varpd_client_prop_arg_t vca_prop;
		varpd_client_lookup_arg_t vca_lookup;
		varpd_client_target_mode_arg_t vca_mode;
		varpd_client_target_cache_arg_t vca_cache;
		varpd_client_target_walk_arg_t vca_walk;
	} vca_un;
} varpd_client_arg_t;

typedef struct varpd_client_eresp {
	uint_t vce_command;
	uint_t vce_errno;
} varpd_client_eresp_t;

extern void libvarpd_plugin_init(void);
extern void libvarpd_plugin_prefork(void);
extern void libvarpd_plugin_postfork(void);
extern void libvarpd_plugin_fini(void);
extern int libvarpd_plugin_comparator(const void *, const void *);
extern varpd_plugin_t *libvarpd_plugin_lookup(varpd_impl_t *, const char *);

extern varpd_instance_t *libvarpd_instance_lookup_by_dlid(varpd_impl_t *,
    datalink_id_t);

extern void libvarpd_prop_door_convert(const varpd_prop_handle_t *,
    varpd_client_propinfo_arg_t *);

extern const char *libvarpd_isaext(void);
typedef int (*libvarpd_dirwalk_f)(varpd_impl_t *, const char *, void *);
extern int libvarpd_dirwalk(varpd_impl_t *, const char *, const char *,
    libvarpd_dirwalk_f, void *);

extern int libvarpd_overlay_init(varpd_impl_t *);
extern void libvarpd_overlay_fini(varpd_impl_t *);
extern int libvarpd_overlay_info(varpd_impl_t *, datalink_id_t,
    overlay_plugin_dest_t *, uint64_t *, uint64_t *);
extern int libvarpd_overlay_associate(varpd_instance_t *);
extern int libvarpd_overlay_disassociate(varpd_instance_t *);
extern int libvarpd_overlay_degrade(varpd_instance_t *, const char *);
extern int libvarpd_overlay_degrade_datalink(varpd_impl_t *, datalink_id_t,
    const char *);
extern int libvarpd_overlay_restore(varpd_instance_t *);
extern int libvarpd_overlay_packet(varpd_impl_t *,
    const overlay_targ_lookup_t *, void *, size_t *);
extern int libvarpd_overlay_inject(varpd_impl_t *,
    const overlay_targ_lookup_t *, void *, size_t);
extern int libvarpd_overlay_instance_inject(varpd_instance_t *, void *, size_t);
extern int libvarpd_overlay_resend(varpd_impl_t *,
    const overlay_targ_lookup_t *, void *, size_t);
typedef int (*libvarpd_overlay_iter_f)(varpd_impl_t *, datalink_id_t, void *);
extern int libvarpd_overlay_iter(varpd_impl_t *, libvarpd_overlay_iter_f,
    void *);
extern int libvarpd_overlay_cache_flush(varpd_instance_t *);
extern int libvarpd_overlay_cache_delete(varpd_instance_t *, const uint8_t *);
extern int libvarpd_overlay_cache_delete(varpd_instance_t *, const uint8_t *);
extern int libvarpd_overlay_cache_get(varpd_instance_t *, const uint8_t *,
    varpd_client_cache_entry_t *);
extern int libvarpd_overlay_cache_set(varpd_instance_t *, const uint8_t *,
    const varpd_client_cache_entry_t *);
extern int libvarpd_overlay_cache_walk_fill(varpd_instance_t *, uint64_t *,
    uint64_t *, overlay_targ_cache_entry_t *);

extern void libvarpd_persist_init(varpd_impl_t *);
extern void libvarpd_persist_fini(varpd_impl_t *);
extern int libvarpd_persist_instance(varpd_impl_t *, varpd_instance_t *);
extern void libvarpd_torch_instance(varpd_impl_t *,  varpd_instance_t *);

#ifdef __cplusplus
}
#endif

#endif /* _LIBVARPD_IMPL_H */