//
// Copyright 2016 Garrett D'Amore <garrett@damore.org>
//
// This software is supplied under the terms of the MIT License, a
// copy of which should be located in the distribution where this
// file was obtained (LICENSE.txt).  A copy of the license may also be
// found online at https://opensource.org/licenses/MIT.
//

#ifndef CORE_ENDPT_H
#define CORE_ENDPT_H

#include "core/defs.h"
#include "core/list.h"
#include "core/thread.h"
#include "core/transport.h"

// NB: This structure is supplied here for use by the CORE. Use of this
// OUSIDE of the core is STRICTLY VERBOTEN.  NO DIRECT ACCESS BY PROTOCOLS
// OR TRANSPORTS.
struct nni_ep {
	nni_tran_ep	ep_ops;         // transport ops
	nni_tran *	ep_tran;        // transport pointer
	void *		ep_data;        // transport private
	uint32_t	ep_id;          // endpoint id
	nni_list_node	ep_node;        // per socket list
	nni_sock *	ep_sock;
	char		ep_addr[NNG_MAXADDRLEN];
	nni_thr		ep_thr;
	int		ep_mode;
	int		ep_closed;      // full shutdown
	int		ep_bound;       // true if we bound locally
	nni_mtx		ep_mtx;
	nni_cv		ep_cv;
	nni_pipe *	ep_pipe;        // Connected pipe (dialers only)
	nni_list	ep_pipes;
};

#define NNI_EP_MODE_IDLE	0
#define NNI_EP_MODE_DIAL	1
#define NNI_EP_MODE_LISTEN	2

extern int nni_ep_sys_init(void);
extern void nni_ep_sys_fini(void);
extern int nni_ep_find(nni_ep **, uint32_t);
extern void nni_ep_hold(nni_ep *);
extern void nni_ep_rele(nni_ep *);
extern uint32_t nni_ep_id(nni_ep *);
extern int nni_ep_create(nni_ep **, nni_sock *, const char *);
extern void nni_ep_stop(nni_ep *);
extern void nni_ep_close(nni_ep *);
extern void nni_ep_remove(nni_ep *);
extern int nni_ep_dial(nni_ep *, int);
extern int nni_ep_listen(nni_ep *, int);
extern void nni_ep_list_init(nni_list *);
extern int nni_ep_pipe_add(nni_ep *, nni_pipe *);
extern void nni_ep_pipe_remove(nni_ep *, nni_pipe *);

#endif // CORE_ENDPT_H