From 0c6d37d6eb4eae9a91c7433adc7e76ba54c67c0f Mon Sep 17 00:00:00 2001
From: guowenxue <guowenxue@gmail.com>
Date: Tue, 25 Jun 2019 01:48:18 +0800
Subject: [PATCH] add and add mqttd proc.c and main.c, set 3 threads running
---
mqttd/main.c | 158 +++++++++++++++++++++++++++++++++++-----------------
1 files changed, 107 insertions(+), 51 deletions(-)
diff --git a/mqttd/main.c b/mqttd/main.c
index a5989a2..001c5fd 100644
--- a/mqttd/main.c
+++ b/mqttd/main.c
@@ -14,79 +14,135 @@
#include <time.h>
#include <unistd.h>
-#include "led.h"
-#include "ds18b20.h"
-#include "sht20.h"
+#include "logger.h"
+#include "proc.h"
+#include "hal.h"
-int hal_init(void);
+#define DAEMON_PIDFILE "/tmp/.mqtt.pid"
-/********************************************************************************
- * Description:
- * Input Args:
- * Output Args:
- * Return Value:
- ********************************************************************************/
+
+typedef struct mqtt_ctx_s
+{
+ int conf;
+} mqtt_ctx_t;
+
+
+int check_set_program_running(int daemon);
+void *mqtt_sub_worker(void *args);
+void *mqtt_pub_worker(void *args);
+
+
int main (int argc, char **argv)
{
float temp;
float rh;
+ int daemon = 0;
+ pthread_t tid;
+ mqtt_ctx_t ctx;
+ //if( logger_init("mqttd.log", LOG_LEVEL_DEBUG, 1024) < 0 )
+ if( logger_init(DBG_LOG_FILE, LOG_LEVEL_DEBUG, 1024) < 0 )
+ {
+ fprintf(stderr, "Logger system initialise failure\n");
+ return -2;
+ }
+ log_dbg("Logger system initialise ok\n");
+
+ install_proc_signal();
+
+ if( check_set_program_running(daemon) < 0 )
+ {
+ goto OUT;
+ }
+
+ if( thread_start(&tid, mqtt_sub_worker, &ctx ) < 0 )
+ {
+ log_fatal("Start MQTT subscibe worker thread failure\n");
+ goto OUT;
+ }
+
+ if( thread_start(&tid, mqtt_pub_worker, &ctx) < 0 )
+ {
+ log_fatal("Start MQTT publish worker thread failure\n");
+ goto OUT;
+ }
+
+
+#if 0
if( hal_init() < 0 )
{
- printf("Initialise hardware failure\n");
+ log_err("Initialise hardware failure\n");
return -1;
}
+ log_nrml("HAL initialise ok\n");
+#endif
- while(1)
+
+ while( ! g_signal.stop )
{
- turn_led(LED_R, ON);
- sleep(1);
- turn_led(LED_R, OFF);
- sleep(1);
-
- turn_led(LED_G, ON);
- sleep(1);
- turn_led(LED_G, OFF);
- sleep(1);
-
- turn_led(LED_B, ON);
- sleep(1);
- turn_led(LED_B, OFF);
- sleep(1);
-
- if(sht2x_get_temp_humidity(&temp, &rh) < 0)
- {
- printf("SHT2X get temperature and relative humidity failure\n");
- }
- else
- {
- printf("SHT2X Temperature=%lfC, Relative humidity=%lf%% \n", temp, rh);
- }
-
-
- if( ds18b20_get_temperature(&temp) < 0)
- {
- printf("DS18B20 get temperature failure\n");
- }
- else
- {
- printf("DS18B20 get temperature=%lf ℃ \n", temp);
- }
+ msleep(1000);
+ log_nrml("Main control thread continue running\n");
}
+
+OUT:
+ logger_term();
+
return 0;
} /* ----- End of main() ----- */
-int hal_init(void)
+int check_set_program_running(int daemon)
{
- init_led();
-
- if( sht2x_init() < 0 )
+ if( check_daemon_running(DAEMON_PIDFILE) )
{
- printf("Initialise SHT20 failure\n");
- return -2;
+ log_err("Program already running, process exit now");
+ return -1;
+ }
+
+ if( daemon )
+ {
+ if( set_daemon_running(DAEMON_PIDFILE) < 0 )
+ {
+ log_err("set program running as daemon failure\n");
+ return -2;
+ }
+ }
+ else
+ {
+ if( record_daemon_pid(DAEMON_PIDFILE) < 0 )
+ {
+ log_err("record program running PID failure\n");
+ return -3;
+ }
}
return 0;
}
+
+void *mqtt_pub_worker(void *args)
+{
+ mqtt_ctx_t *ctx = (mqtt_ctx_t *)args;
+
+ while( !g_signal.stop )
+ {
+ msleep(1000);
+ log_nrml("MQTT publish thread running\n");
+ }
+
+ return NULL;
+}
+
+void *mqtt_sub_worker(void *args)
+{
+ mqtt_ctx_t *ctx = (mqtt_ctx_t *)args;
+
+ while( !g_signal.stop )
+ {
+ msleep(1000);
+ log_nrml("MQTT subscibe thread running\n");
+ }
+
+ return NULL;
+}
+
--
Gitblit v1.9.1