--- libaitmqtt/inc/mqttapi.h	2012/06/20 15:02:23	1.2
+++ libaitmqtt/inc/mqttapi.h	2012/06/29 13:54:48	1.3
@@ -3,7 +3,7 @@
 *  by Michael Pounov <misho@openbsd-bg.org>
 *
 * $Author: misho $
-* $Id: mqttapi.h,v 1.2 2012/06/20 15:02:23 misho Exp $
+* $Id: mqttapi.h,v 1.3 2012/06/29 13:54:48 misho Exp $
 *
 **************************************************************************
 The ELWIX and AITNET software is distributed under the following
@@ -67,30 +67,57 @@ typedef struct {
 
 
 /*
- * mqtt_srv_Init() Init server side actor
+ * mqtt_srv_cliInit() Init MQTT server side support for clients
  *
  * @sock = Client socket from accept()
  * @buf = Message buffer
  * @timeout = timeout
+ * @nb = Non block socket
  * return: NULL error or !=NULL allocated server handle
  */
-mqtt_srv_t *mqtt_srv_Init(int sock, mqtt_msg_t * __restrict buf, unsigned short timeout);
+mqtt_srv_t *mqtt_srv_cliInit(int sock, mqtt_msg_t * __restrict buf, 
+		unsigned short timeout, int nb);
 /*
- * mqtt_srv_Fini() Finish MQTT server side support
+ * mqtt_srv_Fini() Finish MQTT server side support for clients
  *
  * @psrv = Server handle
  * return: none
  */
-void mqtt_srv_Fini(mqtt_srv_t ** __restrict psrv);
+void mqtt_srv_cliFini(mqtt_srv_t ** __restrict psrv);
 /*
- * mqtt_srv_Dispatch() MQTT server dispatcher
+ * mqtt_srv_Dispatch() MQTT server dispatcher for clients
  *
  * @srv = Server handle
  * @rlen = Ready bytes to parse
  * @arg = Argument pass to command callback
  * return: -1 error or 0 ok
  */
-int mqtt_srv_Dispatch(mqtt_srv_t * __restrict srv, int rlen, void *arg);
+int mqtt_srv_cliDispatch(mqtt_srv_t * __restrict srv, int rlen, void *arg);
+
+/*
+ * mqtt_srv_Create() - Create server socket
+ *
+ * @sa = Server bind address
+ * @salen = Server struct sockaddr size
+ * return: -1 error or >-1 server socket
+ */
+int mqtt_srv_Create(struct sockaddr * __restrict sa, int salen);
+/*
+ * mqtt_srv_Destroy() - Close server socket
+ *
+ * @sock = Server socket
+ * return: -1 error or 0 ok
+ */
+int mqtt_srv_Destroy(int sock);
+/*
+ * mqtt_srv_Listen() - Listen server socket
+ *
+ * @sock = Server socket
+ * @maxconn = max number of pending connections
+ * @nb = Non block socket
+ * return: -1 error or 0 ok
+ */
+int mqtt_srv_Listen(int sock, int maxconn, int nb);
 #endif
 
 /*