/*
 *  socket_efuns.h -- definitions and prototypes for socket_efuns.c
 *                    5-92 : Dwayne Fontenot : original coding.
 *                   10-92 : Dave Richards : less original coding.
 */

#ifndef _SOCKET_EFUNS_H_
#define _SOCKET_EFUNS_H_

#include "lpc_incl.h"
#include "network_incl.h"

#ifdef MINGW
#include <ws2tcpip.h>
#endif

enum socket_mode {
    MUD, STREAM, DATAGRAM, STREAM_BINARY, DATAGRAM_BINARY
};

enum socket_state {
    STATE_CLOSED, STATE_FLUSHING, STATE_UNBOUND, STATE_BOUND, STATE_LISTEN, STATE_DATA_XFER
};

#define BUF_SIZE        2048    /* max reliable packet size        */
#ifdef IPV6
#define ADDR_BUF_SIZE INET6_ADDRSTRLEN
#else
#define ADDR_BUF_SIZE   64      /* max length of address string    */
#endif
typedef struct {
    int fd;
    short flags;
    enum socket_mode mode;
    enum socket_state state;
#ifdef IPV6
    struct sockaddr_in6 l_addr;
    struct sockaddr_in6 r_addr;
#else
    struct sockaddr_in l_addr;
    struct sockaddr_in r_addr;
#endif
    object_t *owner_ob;
    object_t *release_ob;
    union string_or_func read_callback;
    union string_or_func write_callback;
    union string_or_func close_callback;
    char *r_buf;
    int r_off;
    int r_len;
    char *w_buf;
    int w_off;
    int w_len;
} lpc_socket_t;

extern lpc_socket_t *lpc_socks;
extern int max_lpc_socks;

#define S_RELEASE       0x001
#define S_BLOCKED       0x002
#define S_HEADER        0x004
#define S_WACCEPT       0x008
#define S_BINARY        0x010
#define S_READ_FP       0x020
#define S_WRITE_FP      0x040
#define S_CLOSE_FP      0x080
#define S_EXTERNAL      0x100
#define S_LINKDEAD      0x200

array_t *socket_status (int);
array_t *socket_status_by_fd (int);
int check_valid_socket (const char * const, int, object_t *, const char * const, int);
void socket_read_select_handler (int);
void socket_write_select_handler (int);
void assign_socket_owner (svalue_t *, object_t *);
object_t *get_socket_owner (int);
void dump_socket_status (outbuffer_t *);
void close_referencing_sockets (object_t *);
int get_socket_address (int, char *, int *, int);
int socket_bind (int, int, const char *);
int socket_create (enum socket_mode, svalue_t *, svalue_t *);
int socket_listen (int, svalue_t *);
int socket_accept (int, svalue_t *, svalue_t *);
int socket_connect (int, const char *, svalue_t *, svalue_t *);
int socket_write (int, svalue_t *, const char *);
int socket_close (int, int);
int socket_release (int, object_t *, svalue_t *);
int socket_acquire (int, svalue_t *, svalue_t *, svalue_t *);
const char *socket_error (int);
int find_new_socket (void);
void set_read_callback (int, svalue_t *);
void set_write_callback (int, svalue_t *);
void set_close_callback (int, svalue_t *);

#endif                          /* _SOCKET_EFUNS_H_ */