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

Diff for /mqtt/src/daemon.c between versions 1.1.2.32 and 1.2.2.2

version 1.1.2.32, 2012/01/25 10:34:14 version 1.2.2.2, 2012/01/27 16:19:04
Line 43  initSession(int sock, ait_val_t * __restrict v) Line 43  initSession(int sock, ait_val_t * __restrict v)
                 return NULL;                  return NULL;
         }          }
   
           sess->sess_srv = mqtt_srv_Init(sock, sess->sess_buf);
           if (!sess->sess_srv) {
                   ioDEBUG(3, "Error:: in srv_Init #%d - %s", mqtt_GetErrno(), mqtt_GetError());
                   mqtt_msgFree(&sess->sess_buf, 42);
                   free(sess);
                   io_freeVar(v);
                   return NULL;
           }
   
         sess->sess_sock = sock;          sess->sess_sock = sock;
         strlcpy(sess->sess_addr, (char*) AIT_GET_STR(v), sizeof sess->sess_addr);          strlcpy(sess->sess_addr, (char*) AIT_GET_STR(v), sizeof sess->sess_addr);
         io_freeVar(v);          io_freeVar(v);
Line 65  finiSession(struct tagSession *sess, int preservSock) Line 74  finiSession(struct tagSession *sess, int preservSock)
         while ((store = TAILQ_FIRST(&sess->sess_sndqueue))) {          while ((store = TAILQ_FIRST(&sess->sess_sndqueue))) {
                 TAILQ_REMOVE(&sess->sess_sndqueue, store, st_node);                  TAILQ_REMOVE(&sess->sess_sndqueue, store, st_node);
   
                if (store->st_subscr.sub_topic._base)                if (store->st_subscr.sub_topic.msg_base)
                        free(store->st_subscr.sub_topic._base);                        free(store->st_subscr.sub_topic.msg_base);
                if (store->st_subscr.sub_value._base)                if (store->st_subscr.sub_value.msg_base)
                        free(store->st_subscr.sub_value._base);                        free(store->st_subscr.sub_value.msg_base);
   
                 free(store);                  free(store);
         }          }
Line 81  finiSession(struct tagSession *sess, int preservSock) Line 90  finiSession(struct tagSession *sess, int preservSock)
         if (sess->sess_sock > STDERR_FILENO && !preservSock)          if (sess->sess_sock > STDERR_FILENO && !preservSock)
                 srv_Close(sess->sess_sock);                  srv_Close(sess->sess_sock);
   
           mqtt_srv_Fini(&sess->sess_srv);
         mqtt_msgFree(&sess->sess_buf, 42);          mqtt_msgFree(&sess->sess_buf, 42);
   
         free(sess);          free(sess);
Line 165  KASession(struct tagSession *sess) Line 175  KASession(struct tagSession *sess)
 static void *  static void *
 thrSession(struct tagSession *sess)  thrSession(struct tagSession *sess)
 {  {
         mqtt_msg_t msg = { NULL, 0 };  
         int ret, locKill = 42;          int ret, locKill = 42;
         struct pollfd pfd;          struct pollfd pfd;
         struct mqtthdr *hdr;          struct mqtthdr *hdr;
Line 211  thrSession(struct tagSession *sess) Line 220  thrSession(struct tagSession *sess)
                                 while ((store = TAILQ_FIRST(&sess->sess_sndqueue))) {                                  while ((store = TAILQ_FIRST(&sess->sess_sndqueue))) {
                                         TAILQ_REMOVE(&sess->sess_sndqueue, store, st_node);                                          TAILQ_REMOVE(&sess->sess_sndqueue, store, st_node);
   
                                        if (store->st_subscr.sub_topic._base)                                        if (store->st_subscr.sub_topic.msg_base)
                                                free(store->st_subscr.sub_topic._base);                                                free(store->st_subscr.sub_topic.msg_base);
                                        if (store->st_subscr.sub_value._base)                                        if (store->st_subscr.sub_value.msg_base)
                                                free(store->st_subscr.sub_value._base);                                                free(store->st_subscr.sub_value.msg_base);
   
                                         free(store);                                          free(store);
                                 }                                  }
Removed from v.1.1.2.32  
changed lines
  Added in v.1.2.2.2

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