[BACK]Return to mqttapi.h CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / libaitmqtt / inc

Diff for /libaitmqtt/inc/mqttapi.h between versions 1.1.2.10 and 1.2.4.1

version 1.1.2.10, 2012/05/09 13:48:31 version 1.2.4.1, 2012/06/29 08:22:49
Line 67  typedef struct { Line 67  typedef struct {
   
   
 /*  /*
 * mqtt_srv_Init() Init server side actor * mqtt_srv_cliInit() Init MQTT server side support for clients
  *   *
  * @sock = Client socket from accept()   * @sock = Client socket from accept()
  * @buf = Message buffer   * @buf = Message buffer
  * @timeout = timeout   * @timeout = timeout
  * return: NULL error or !=NULL allocated server handle   * 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);
 /*  /*
 * mqtt_srv_Fini() Finish MQTT server side support * mqtt_srv_Fini() Finish MQTT server side support for clients
  *   *
  * @psrv = Server handle   * @psrv = Server handle
  * return: none   * 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   * @srv = Server handle
  * @rlen = Ready bytes to parse   * @rlen = Ready bytes to parse
  * @arg = Argument pass to command callback   * @arg = Argument pass to command callback
  * return: -1 error or 0 ok   * 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  #endif
   
 /*  /*
Line 168  int mqtt_cli_Unsubscribe(mqtt_cli_t * __restrict cli,  Line 193  int mqtt_cli_Unsubscribe(mqtt_cli_t * __restrict cli, 
  * @csTopic = Topic   * @csTopic = Topic
  * @pData = Data   * @pData = Data
  * @datLen = Data length   * @datLen = Data length
 * return: -1 error or 0 ok * return: -1 error or > -1 sended bytes
  */   */
 int mqtt_cli_Publish(mqtt_cli_t * __restrict cli, unsigned short msgID,   int mqtt_cli_Publish(mqtt_cli_t * __restrict cli, unsigned short msgID, 
                 unsigned char Dup, unsigned char QoS, unsigned char Retain,                   unsigned char Dup, unsigned char QoS, unsigned char Retain, 
Removed from v.1.1.2.10  
changed lines
  Added in v.1.2.4.1

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>