#ifndef RECVBUFF_H
#define RECVBUFF_H
#ifdef HAVE_CONFIG_H
# include <config.h>
#endif
#include "ntp.h"
#include "ntp_fp.h"
#include "ntp_lists.h"
#include <isc/result.h>
#define RECV_INIT 10
#define RECV_LOWAT 3
#define RECV_INC 5
#define RECV_TOOMANY 40
#if defined HAVE_IO_COMPLETION_PORT
# include "ntp_iocompletionport.h"
#include "ntp_timer.h"
# define RECV_BLOCK_IO() EnterCriticalSection(&RecvCritSection)
# define RECV_UNBLOCK_IO() LeaveCriticalSection(&RecvCritSection)
extern HANDLE get_recv_buff_event (void);
#else
# define RECV_BLOCK_IO()
# define RECV_UNBLOCK_IO()
#endif
#define RX_BUFF_SIZE 1000
typedef struct recvbuf recvbuf_t;
struct recvbuf {
ISC_LINK(recvbuf_t) link;
union {
sockaddr_u X_recv_srcadr;
caddr_t X_recv_srcclock;
struct peer *X_recv_peer;
} X_from_where;
#define recv_srcadr X_from_where.X_recv_srcadr
#define recv_srcclock X_from_where.X_recv_srcclock
#define recv_peer X_from_where.X_recv_peer
#ifndef HAVE_IO_COMPLETION_PORT
sockaddr_u srcadr;
#else
int recv_srcadr_len;
#endif
struct interface *dstadr;
SOCKET fd;
int msg_flags;
l_fp recv_time;
void (*receiver) (struct recvbuf *);
int recv_length;
union {
struct pkt X_recv_pkt;
u_char X_recv_buffer[RX_BUFF_SIZE];
} recv_space;
#define recv_pkt recv_space.X_recv_pkt
#define recv_buffer recv_space.X_recv_buffer
int used;
};
extern void init_recvbuff (int);
extern void freerecvbuf (struct recvbuf *);
extern struct recvbuf *get_free_recv_buffer (void);
extern struct recvbuf *get_free_recv_buffer_alloc (void);
extern void add_full_recv_buffer (struct recvbuf *);
extern u_long free_recvbuffs (void);
extern u_long full_recvbuffs (void);
extern u_long total_recvbuffs (void);
extern u_long lowater_additions (void);
extern struct recvbuf *get_full_recv_buffer (void);
extern isc_boolean_t has_full_recv_buffer (void);
#endif