Diff for /mqtt/src/mqttd_calls.c between versions 1.4.4.1 and 1.4.4.2

version 1.4.4.1, 2013/01/18 10:17:22 version 1.4.4.2, 2013/07/16 14:34:58
Line 148  sendRetain(sched_task_t *task) Line 148  sendRetain(sched_task_t *task)
         struct tagSession *sess;          struct tagSession *sess;
         int siz;          int siz;
   
        ETRACE(2);        ETRACE();
   
         assert(task);          assert(task);
   
Line 183  pubWill(struct tagSession * __restrict sess) Line 183  pubWill(struct tagSession * __restrict sess)
 {  {
         int datlen;          int datlen;
   
        ETRACE(2);        ETRACE();
   
         /* prepare will packet */          /* prepare will packet */
         datlen = mqtt_msgPUBLISH(sess->sess_buf, sess->sess_will.topic, 0xDEAD, 0, 1, 0,           datlen = mqtt_msgPUBLISH(sess->sess_buf, sess->sess_will.topic, 0xDEAD, 0, 1, 0, 
Line 246  cmdPUBLISH(void *srv, int len, void *arg) Line 246  cmdPUBLISH(void *srv, int len, void *arg)
         u_short mid = 0;          u_short mid = 0;
         ait_val_t *p = NULL;          ait_val_t *p = NULL;
   
        ETRACE(2);        ETRACE();
   
         if (!sess)          if (!sess)
                 return -1;                  return -1;
Line 300  cmdPUBREL(void *srv, int len, void *arg) Line 300  cmdPUBREL(void *srv, int len, void *arg)
         u_short mid = 0;          u_short mid = 0;
         ait_val_t *p = NULL;          ait_val_t *p = NULL;
   
        ETRACE(2);        ETRACE();
   
         if (!sess)          if (!sess)
                 return -1;                  return -1;
Line 341  cmdSUBSCRIBE(void *srv, int len, void *arg) Line 341  cmdSUBSCRIBE(void *srv, int len, void *arg)
         void *ptr;          void *ptr;
         ait_val_t *p = NULL;          ait_val_t *p = NULL;
   
        ETRACE(2);        ETRACE();
   
         if (!sess)          if (!sess)
                 return -1;                  return -1;
Line 423  cmdUNSUBSCRIBE(void *srv, int len, void *arg) Line 423  cmdUNSUBSCRIBE(void *srv, int len, void *arg)
         struct tagStore *store, *tmp;          struct tagStore *store, *tmp;
         ait_val_t *p = NULL;          ait_val_t *p = NULL;
   
        ETRACE(2);        ETRACE();
   
         if (!sess)          if (!sess)
                 return -1;                  return -1;
Line 479  cmdPINGREQ(void *srv, int len, void *arg) Line 479  cmdPINGREQ(void *srv, int len, void *arg)
         int siz = 0;          int siz = 0;
         ait_val_t *p = NULL;          ait_val_t *p = NULL;
   
        ETRACE(2);        ETRACE();
   
         if (!sess)          if (!sess)
                 return -1;                  return -1;
Line 504  cmdCONNECT(void *srv, int len, void *arg) Line 504  cmdCONNECT(void *srv, int len, void *arg)
         struct tagStore *store;          struct tagStore *store;
         struct tagSession *sess = (struct tagSession*) arg;          struct tagSession *sess = (struct tagSession*) arg;
   
        ETRACE(2);        ETRACE();
   
         if (!sess)          if (!sess)
                 return -1;                  return -1;
Line 553  cmdDISCONNECT(void *srv, int len, void *arg) Line 553  cmdDISCONNECT(void *srv, int len, void *arg)
 {  {
         struct tagSession *sess = (struct tagSession*) arg;          struct tagSession *sess = (struct tagSession*) arg;
   
        ETRACE(2);        ETRACE();
   
         if (!sess)          if (!sess)
                 return -1;                  return -1;

Removed from v.1.4.4.1  
changed lines
  Added in v.1.4.4.2


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