| | |
| | | #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 |
| | |
| | | |
| | | pthread_t tid; |
| | | iotd_conf_t *conf; |
| | | cp_logger *logger; |
| | | logger_t *logger; |
| | | |
| | | memset(&iotd_ctx, 0, sizeof(iotd_ctx)); |
| | | conf = &iotd_ctx.conf; |
| | |
| | | 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); |
| | |
| | | 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 ) |
| | | { |