[IOMultiplexerV2] dev snapshot

[NextIRCd.git] / src / IOSockets.h

diff --git a/src/IOSockets.h b/src/IOSockets.h
index a509bf880a9f6562126bb2c0fdc2c1fd8254c3e8..79f945e15db721f7c12bc8f1eda734ce647ef137 100644 (file)
--- a/src/IOSockets.h
+++ b/src/IOSockets.h
@@ -20,10 +20,129 @@
 #include "IOHandler.h"
 #else
 
+#define IOSOCKET_LINE_LEN 1024
 
+#define IOSOCKETFLAG_ACTIVE           0x0001
+#define IOSOCKETFLAG_LISTENING        0x0002
+#define IOSOCKETFLAG_PENDING_BINDDNS  0x0004
+#define IOSOCKETFLAG_PENDING_DESTDNS  0x0008
+#define IOSOCKETFLAG_DNSDONE_BINDDNS  0x0010
+#define IOSOCKETFLAG_DNSDONE_DESTDNS  0x0020
+#define IOSOCKETFLAG_DNSERROR         0x0040
+#define IOSOCKETFLAG_IPV6SOCKET       0x0080
+#define IOSOCKETFLAG_PARENT_PUBLIC    0x0100
+#define IOSOCKETFLAG_PARENT_DNSENGINE 0x0200
+#define IOSOCKETFLAG_SSLSOCKET        0x0400 /* use ssl after connecting */
+#define IOSOCKETFLAG_SHUTDOWN         0x0800 /* disconnect pending */
+
+struct IODNSAddress;
+struct IOSocketBuffer;
+struct IOSSLDescriptor;
+struct _IODNSQuery;
+
+struct IOSocketDNSLookup {
+       unsigned int bindlookup : 1;
+       char hostname[256];
+       struct _IOSocket *iosocket;
+       struct _IODNSQuery *query;
+       struct IODNSResult *result;
+};
+
+struct _IOSocket {
+    int fd;
+       
+       unsigned int socket_flags : 16;
+       
+       union {
+               struct IODNSAddress addr;
+               struct IOSocketDNSLookup *addrlookup;
+       } bind;
+       union {
+               struct IODNSAddress addr;
+               struct IOSocketDNSLookup *addrlookup;
+       } dest;
+       
+       unsigned int port : 16;
+       
+       struct IOSocketBuffer readbuf;
+    struct IOSocketBuffer writebuf;
+       
+       struct IOSSLDescriptor *sslnode;
+       
+       void *parent;
+       
+       struct _IOSocket *next, *prev;
+};
+
+void _init_sockets();
+void iosocket_lookup_callback(struct IOSocketDNSLookup *lookup, struct IODNSEvent *event);
 
 #endif
 
+struct IOSocketEvent;
+
+#define IOSOCKET_CALLBACK(NAME) void NAME(struct IOSocketEvent *event)
+typedef IOSOCKET_CALLBACK(iosocket_callback);
+
+enum IOSocketStatus { 
+    IOSOCKET_CLOSED, /* descriptor is dead (socket waiting for removal or timer) */
+    IOSOCKET_LISTENING, /* descriptor is waiting for connections (server socket) */
+    IOSOCKET_CONNECTING, /* descriptor is waiting for connection approval (connecting client socket) */
+    IOSOCKET_CONNECTED /* descriptor is connected (connected client socket) */
+};
+
+enum IOSocketEventType {
+    IOSOCKETEVENT_IGNORE,
+    IOSOCKETEVENT_RECV, /* client socket received something (read_lines == 1  =>  recv_str valid;  read_lines == 0  =>  recv_buf valid) */
+    IOSOCKETEVENT_CONNECTED, /* client socket connected successful */
+    IOSOCKETEVENT_NOTCONNECTED, /* client socket could not connect (errid valid) */
+    IOSOCKETEVENT_CLOSED, /* client socket lost connection (errid valid) */
+    IOSOCKETEVENT_ACCEPT, /* server socket accepted new connection (accept_socket valid) */
+    IOSOCKETEVENT_SSLFAILED, /* failed to initialize SSL session */
+       IOSOCKETEVENT_DNSFAILED /* failed to lookup DNS information */
+};
+
+struct IOSocket {
+       void *iosocket;
+       
+       enum IOSocketStatus status;
+       int listening : 1;
+       int ssl : 1;
+       int read_lines : 1;
+       
+       void *data;
+       iosocket_callback *callback;
+};
+
+struct IOSocketBuffer {
+    char *buffer;
+    size_t bufpos, buflen;
+};
+
+struct IOSocketEvent {
+    enum IOSocketEventType type;
+    struct IOSocket *socket;
+    union {
+        char *recv_str;
+               struct IOSocketBuffer *recv_buf;
+        int errid;
+        struct IOSocket *accept_socket;
+    } data;
+};
+
+
+#define IOSOCKET_ADDR_IPV4 0x01
+#define IOSOCKET_ADDR_IPV6 0x02 /* overrides IOSOCKET_ADDR_IPV4 */
 
+struct IOSocket *iosocket_connect(const char *hostname, unsigned int port, int ssl, const char *bindhost, iosocket_callback *callback);
+struct IOSocket *iosocket_connect_flags(const char *hostname, unsigned int port, int ssl, const char *bindhost, iosocket_callback *callback, int flags);
+struct IOSocket *iosocket_listen(const char *hostname, unsigned int port, iosocket_callback *callback);
+struct IOSocket *iosocket_listen_flags(const char *hostname, unsigned int port, iosocket_callback *callback, int flags);
+struct IOSocket *iosocket_listen_ssl(const char *hostname, unsigned int port, const char *certfile, const char *keyfile, iosocket_callback *callback);
+struct IOSocket *iosocket_listen_ssl_flags(const char *hostname, unsigned int port, const char *certfile, const char *keyfile, iosocket_callback *callback, int flags);
+void iosocket_write(struct IOSocket *iosocket, const char *line);
+void iosocket_send(struct IOSocket *iosocket, const char *data, size_t datalen);
+void iosocket_printf(struct IOSocket *iosocket, const char *text, ...);
+void iohandler_close(struct IOSocket *iosocket);
 
 #endif