LingYun IoT Studio NB-IoT research project
guowenxue
2018-11-20 e361b1654fefd1a563a82d335795f94b794b4873
src/nbiotd/iotd.c
@@ -23,21 +23,11 @@
#include <sys/stat.h>
#include <fcntl.h>
#include "cp_logger.h"
#include "cp_proc.h"
#include "iotd_conf.h"
#define DEF_LOG_FILE         "/var/log/iotd.log"
#define DEF_LOG_LEVEL        LOG_LEVEL_NRML
void *watchdog_worker(void *arg);
typedef struct iotd_conf_s
{
    cp_logger       logger;
} iotd_conf_t;
typedef struct iotd_ctx_s 
@@ -85,7 +75,7 @@
    pthread_t             tid;
    iotd_conf_t          *conf; 
    cp_logger            *logger;
    logger_t             *logger;
    memset(&iotd_ctx, 0, sizeof(iotd_ctx));
    conf = &iotd_ctx.conf;
@@ -149,6 +139,7 @@
        printf("Logger initialize failure with file: %s\n", logger->file);
        return -1;
    }
    log_nrml("Init default logger file \"%s\" ok\n", log_file);
    /*  Parser configure file and start the initialize log */
    rv = parser_iotd_conf(conf_file, conf);
@@ -187,16 +178,25 @@
    thread_start(&tid, watchdog_worker, NULL);
    /* Start MQTT thread worker */
    log_nrml("start MQTT socket process thread\n");
    //thread_start(&tid, mqtt_worker, (void *)&iotd_ctx );
    if( conf->mqtt_conf.enable )
    {
        log_nrml("start MQTT publish process thread\n");
        //thread_start(&tid, mqtt_worker, (void *)&iotd_ctx );
    }
    /* Start NB-IoT thread worker */
    log_nrml("start NB-IoT process thread\n");
    //thread_start(&tid, nbiot_worker, (void *)&iotd_ctx );
    if( conf->nbiot_conf.enable )
    {
        log_nrml("start NB-IoT process thread\n");
        //thread_start(&tid, nbiot_worker, (void *)&iotd_ctx );
    }
    /* Start LoRa thread worker */
    log_nrml("start LoRa AP process thread\n");
    //thread_start(&tid, nbiot_worker, (void *)&iotd_ctx );
    if( conf->nbiot_conf.enable )
    {
        log_nrml("start LoRa AP process thread\n");
        //thread_start(&tid, nbiot_worker, (void *)&iotd_ctx );
    }
    while( !g_cp_signal.stop )
    {