Return to mqttapi.h CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / libaitmqtt / inc

add new API for client/server side

    1: #ifndef __MQTTAPI_H
    2: #define __MQTTAPI_H
    3: 
    4: 
    5: #include "aitmqtt.h"
    6: 
    7: 
    8: /* MQTT server structure & hooks */
    9: 
   10: /* MQTT command callback. 1st argument is (mqtt_srv_t*) server handle */
   11: typedef int (*mqtt_cb_t)(void* /*mqtt_srv_t**/, void *);
   12: typedef struct {
   13: 	mqtt_cb_t	cmds[MQTT_TYPE_MAX];
   14: 
   15: 	int		sock;
   16: 	mqtt_msg_t	*buf;
   17: } mqtt_srv_t;
   18: #define mqtt_srv_setCmd(x, _cmd, _func)	(assert((x)), (x)->cmds[(_cmd)] = (_func))
   19: #define mqtt_srv_getCmd(x, _cmd)	(assert((x)), (x)->cmds[(_cmd)])
   20: 
   21: 
   22: #ifdef API_SERVER_SIDE
   23: /*
   24:  * mqtt_srv_Init() Init server side actor
   25:  *
   26:  * @sock = Client socket from accept()
   27:  * @buf = Message buffer
   28:  * return: NULL error or !=NULL allocated server handle
   29:  */
   30: mqtt_srv_t *mqtt_srv_Init(int sock, mqtt_msg_t * __restrict buf);
   31: /*
   32:  * mqtt_srv_Fini() Finish MQTT server side support
   33:  *
   34:  * @psrv = Server handle
   35:  * return: none
   36:  */
   37: void mqtt_srv_Fini(mqtt_srv_t ** __restrict psrv);
   38: /*
   39:  * mqtt_srv_Dispatch() MQTT server dispatcher
   40:  *
   41:  * @srv = Server handle
   42:  * @arg = Argument pass to command callback
   43:  * return: -1 error or 0 ok
   44:  */
   45: int mqtt_srv_Dispatch(mqtt_srv_t * __restrict srv, void *arg);
   46: #endif
   47: 
   48: /*
   49:  * mqtt_KeepAlive() - Keep Alive check routine
   50:  *
   51:  * @sock = connected socket
   52:  * @ka = keep alive timeout
   53:  * @tries = tries for receive correct ping response, usually ==1
   54:  * return: -1 error, 0 host is alive, 1 timeout session or 2 broken session
   55:  */
   56: int mqtt_KeepAlive(int sock, unsigned short ka, unsigned char tries);
   57: 
   58: #ifdef API_CLIENT_SIDE
   59: #endif
   60: 
   61: 
   62: #endif