mqtt/src/daemon.c - diff

Return to daemon.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / mqtt / src

Diff for /mqtt/src/daemon.c between versions 1.1.2.25 and 1.1.2.26

-version 1.1.2.25, 2011/12/16 12:22:26
+version 1.1.2.26, 2011/12/16 12:55:30
  Line 79  stopSession(struct tagSession *sess)
          mqtt_msg_t msg = { NULL, 0 };
          int ret;
+         ioTRACE(4);
+         assert(sess);
          pthread_mutex_lock(&mtx_sess);
          TAILQ_REMOVE(&Sessions, sess, sess_node);
          pthread_mutex_unlock(&mtx_sess);
- Line 96  stopSession(struct tagSession *sess)
+ Line 100  stopSession(struct tagSession *sess)
          finiSession(sess);
  }
+ static int
+ KASession(struct tagSession *sess)
+ {
+         u_char basebuf[USHRT_MAX];
+         mqtt_msg_t msg = { NULL, 0 }, buf = { basebuf, sizeof basebuf };
+         int ret;
+         struct pollfd pfd;
+         ioTRACE(4);
+         assert(sess);
+         /* ping request */
+         ret = mqtt_msgPINGREQ(&msg);
+         if ((ret = send(sess->sess_sock, msg.msg_base, ret, 0)) == -1) {
+                 ioDEBUG(3, "Error:: send(%d) #%d - %s", sess->sess_sock, errno, strerror(errno));
+                 stopSession(sess);
+                 return -1;
+         } else {
+                 ioDEBUG(5, "Sended %d bytes for ping request", ret);
+                 free(msg.msg_base);
+                 memset(&msg, 0, sizeof msg);
+         }
+         pfd.fd = sess->sess_sock;
+         pfd.events = POLLIN | POLLPRI;
+         if ((ret = poll(&pfd, 1, sess->sess_ka)) == -1) {
+                 ioDEBUG(3, "Error:: poll(%d) #%d - %s", sess->sess_sock, errno, strerror(errno));
+                 stopSession(sess);
+                 return -1;
+         } else if (!ret) {
+                 /* problem!!! session is abandoned ... must be disconnect! */
+                 stopSession(sess);
+                 return 1;
+         }
+         /* receive & decode packet */
+         if (recv(sess->sess_sock, buf.msg_base, buf.msg_len, 0) == -1) {
+                 ioDEBUG(3, "Error:: recv(%d) #%d - %s", sess->sess_sock, errno, strerror(errno));
+                 stopSession(sess);
+                 return -1;
+         }
+         if (mqtt_readPINGRESP(&buf)) {
+                 /* problem!!! session is broken, not hear ping response ... must be disconnect! */
+                 stopSession(sess);
+                 return 2;
+         }
+         /* Keep Alive is OK! */
+         return 0;
+ }
  static void *
  thrSession(struct tagSession *sess)
  {
- Line 119  startSession(sched_task_t *task)
+ Line 174  startSession(sched_task_t *task)
          pthread_attr_t attr;
          ioTRACE(4);
+         assert(task);
          sess = initSession(TASK_FD(task), TASK_ARG(task));
          if (!sess) {

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

Removed from v.1.1.2.25
changed lines
	Added in v.1.1.2.26