[BACK]Return to cmds.c CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / libaitmqtt / src

Diff for /libaitmqtt/src/cmds.c between versions 1.2 and 1.3.6.1

version 1.2, 2012/06/20 15:02:24 version 1.3.6.1, 2013/07/18 15:02:52
Line 3 Line 3
   
 #pragma GCC visibility push(hidden)  #pragma GCC visibility push(hidden)
   
inline intint
 mqtt_wait4data(int sock, u_short ka, short events)  mqtt_wait4data(int sock, u_short ka, short events)
 {  {
         int ret = 0;          int ret = 0;
Line 73  mqtt_KeepAlive(int sock, u_short ka, u_char tries) Line 73  mqtt_KeepAlive(int sock, u_short ka, u_char tries)
                         ret = 2;        /* Session is broken ... must be disconnect! */                          ret = 2;        /* Session is broken ... must be disconnect! */
         }          }
 end:  end:
           free(msg.msg_base);
           return ret;
   }
   
   /*
    * mqtt_WillMessage() - Publish WILL message
    *
    * @sock = connected socket
    * @ka = keep alive timeout
    * @topic = will topic
    * @data = will message
    * return: -1 error, 1 timeout, 2 not ack or 0 ok
    */
   int
   mqtt_WillMessage(int sock, u_short ka, const char *topic, const char *data)
   {
           int ret = 0;
           mqtt_msg_t msg = { NULL, 0 };
   
           if (!topic)
                   return -1;      /* error */
   
           /* will message */
           if ((ret = mqtt_wait4data(sock, ka, POLLOUT)))
                   return ret;
           ret = mqtt_msgPUBLISH(&msg, topic, 0xDEAD, 0, 1, 0, data, data ? strlen(data) : 0);
           if (ret == -1)
                   return -1;      /* error */
           if ((ret = send(sock, msg.msg_base, ret, MSG_NOSIGNAL)) == -1) {
                   LOGERR;
                   free(msg.msg_base);
                   return -1;      /* error */
           } else
                   memset(msg.msg_base, 0, msg.msg_len);
   
           /* will ack */
           if ((ret = mqtt_wait4data(sock, ka, POLLIN | POLLPRI))) {
                   free(msg.msg_base);
                   return ret;
           }
           /* receive & decode packet */
           if ((ret = recv(sock, msg.msg_base, msg.msg_len, 0)) == -1) {
                   LOGERR;
                   free(msg.msg_base);
                   return -1;      /* error */
           }
           if (mqtt_readPUBACK(&msg))
                   ret = 0;        /* ok */
           else
                   ret = 2;        /* semi-error */
   
         free(msg.msg_base);          free(msg.msg_base);
         return ret;          return ret;
 }  }
Removed from v.1.2  
changed lines
  Added in v.1.3.6.1

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