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

Diff for /mqtt/src/mqttd.c between versions 1.2.2.2 and 1.2.2.5

version 1.2.2.2, 2012/04/15 21:44:33 version 1.2.2.5, 2012/04/24 08:06:09
Line 9  io_enableDEBUG; Line 9  io_enableDEBUG;
   
 cfg_root_t cfg;  cfg_root_t cfg;
 sessions_t Sessions;  sessions_t Sessions;
   pubs_t Pubs;
 sched_root_task_t *root;  sched_root_task_t *root;
 sqlite3 *acc, *pub;  sqlite3 *acc, *pub;
 pthread_mutex_t mtx_sess, mtx_pub;  pthread_mutex_t mtx_sess, mtx_pub;
Line 43  sigHand(int sig) Line 44  sigHand(int sig)
                                 break;                                  break;
                         }                          }
   
                        syslog(LOG_ERR, "Error:: can't reload #%d - %s", cfg_GetErrno(), cfg_GetError());                        ioLIBERR(cfg);
                 case SIGTERM:                  case SIGTERM:
                         ioDEBUG(1, "Terminate MQTT service in progress");                          ioDEBUG(1, "Terminate MQTT service in progress");
                         Kill++;                          Kill++;
Line 68  main(int argc, char **argv) Line 69  main(int argc, char **argv)
         ait_val_t v;          ait_val_t v;
   
         TAILQ_INIT(&Sessions);          TAILQ_INIT(&Sessions);
           TAILQ_INIT(&Pubs);
   
         strlcpy(szCfgName, DEFAULT_CONFIG, sizeof szCfgName);          strlcpy(szCfgName, DEFAULT_CONFIG, sizeof szCfgName);
         while ((ch = getopt(argc, argv, "hvbc:")) != -1)          while ((ch = getopt(argc, argv, "hvbc:")) != -1)
Line 155  main(int argc, char **argv) Line 157  main(int argc, char **argv)
                                 goto end;                                  goto end;
                 }                  }
         else          else
                ioVERBOSE(1) printf("Start service in batch mode ...\n");                ioDEBUG(1, "Start service in batch mode ...");
   
         memset(&sa, 0, sizeof sa);          memset(&sa, 0, sizeof sa);
         sigemptyset(&sa.sa_mask);          sigemptyset(&sa.sa_mask);
Line 181  main(int argc, char **argv) Line 183  main(int argc, char **argv)
         }          }
   
         if (!(root = schedBegin())) {          if (!(root = schedBegin())) {
                printf("Error:: scheduler #%d - %s\n", sched_GetErrno(), sched_GetError());                ioLIBERR(sched);
                 ret = 6;                  ret = 6;
                 goto end;                  goto end;
         }          }
   
           /* go catch the cat ... */
         Run(sock);          Run(sock);
   
         schedEnd(&root);          schedEnd(&root);
end:end:    /* free all resources */
         srv_Close(sock);          srv_Close(sock);
         call.CloseLOG(logg);          call.CloseLOG(logg);
         call.ClosePUB(pub);          call.ClosePUB(pub);
Removed from v.1.2.2.2  
changed lines
  Added in v.1.2.2.5

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