--- libaitio/inc/aitio.h	2013/07/09 00:35:35	1.33
+++ libaitio/inc/aitio.h	2013/09/02 11:16:27	1.35
@@ -3,7 +3,7 @@
 *  by Michael Pounov <misho@elwix.org>
 *
 * $Author: misho $
-* $Id: aitio.h,v 1.33 2013/07/09 00:35:35 misho Exp $
+* $Id: aitio.h,v 1.35 2013/09/02 11:16:27 misho Exp $
 *
 **************************************************************************
 The ELWIX and AITNET software is distributed under the following
@@ -61,18 +61,93 @@ SUCH DAMAGE.
 #include <net/if_dl.h>
 #include <net/bpf.h>
 #include <netinet/in.h>
+#include <elwix.h>
 
 
 #ifndef STRSIZ
-#define STRSIZ		256
+#define STRSIZ			256
 #endif
 
+#define IO_SOCK_ROLE_CLIENT	0
+#define IO_SOCK_ROLE_SERVER	1
 
+
+typedef struct tagCliSock sock_cli_t;
+typedef void *(*sock_cb_t)(sock_cli_t*);
+struct tagCliSock {
+	void				*cli_parent;
+	pthread_t			cli_tid;
+	int				cli_fd;
+	int				cli_pty;
+	sockaddr_t			cli_addr;
+	char				cli_name[64];
+
+	sock_cb_t			cli_func;
+	void				*cli_arg;
+
+	ait_val_t			cli_buf;
+
+	TAILQ_ENTRY(tagCliSock)		cli_node;
+};
+typedef struct {
+	int				sock_role;
+	int				sock_backq;
+	int				sock_type;
+	int				sock_proto;
+	int 				sock_fd;
+	sockaddr_t			sock_addr;
+	sockaddr_t			sock_peer;
+
+	ait_val_t			sock_buf;
+
+	pthread_mutex_t			sock_mtx;
+	TAILQ_HEAD(, tagCliSock)	sock_cli;
+} sock_t;
+
+
 // io_GetErrno() Get error code of last operation
 int io_GetErrno();
 // io_GetError() Get error text of last operation
 const char *io_GetError();
 
+
+/*
+ * ioInitSocket() - Init socket and allocate resources
+ *
+ * @role = Socket role
+ * @type = Socket type
+ * @proto = Socket protocol
+ * @addr = Bind to address
+ * @port = Bind to port
+ * @buflen = Socket buffer, optional if =0 == BUFSIZ
+ * return: NULL error or !=NULL created socket
+ */
+sock_t *ioInitSocket(int role, int type, int proto, 
+		const char *addr, unsigned short port, size_t buflen);
+/*
+ * ioCloseSocket() - Close socket and free resources
+ *
+ * @s = Socket
+ * return: none
+ */
+void ioCloseSocket(sock_t ** __restrict s);
+/*
+ * ioUpSocket() - Setup socket for use
+ *
+ * @s = Socket
+ * @arg = Server role = listen backlog queue and Client role = peer address
+ * return: -1 error or 0 ok
+ */
+int ioUpSocket(sock_t * __restrict s, void *arg);
+/*
+ * ioAcceptSocket() - Accept clients
+ *
+ * @s = Socket
+ * @f = callback function for client handling
+ * @arg = optional argument for callback function
+ * return: -1 error or 0 ok
+ */
+int ioAcceptSocket(sock_t * __restrict s, sock_cb_t f, void *arg);
 
 /*
  * ioPromptRead() - Read data from input h[0] with prompt to output h[1]