project/booster/iniparser.c

@@ -12,6 +12,9 @@
#include <stdarg.h>
#include "iniparser.h"

#pragma GCC diagnostic ignored "-Wformat-overflow"
#pragma GCC diagnostic ignored "-Wformat-truncation"

/*---------------------------- Defines -------------------------------------*/
#define ASCIILINESZ         (1024)
#define INI_INVALID_KEY     ((char*)-1)

 project/booster/proc.c

File was renamed from project/booster/util_proc.c
@@ -2,8 +2,8 @@
 *      Copyright:  (C) 2020 LingYun IoT System Studio
 *                  All rights reserved.
 *
 *       Filename:  util_proc.c
 *    Description:  This file is the process API
 *       Filename:  proc.c
 *    Description:  This file is the process/thread API
 *
 *        Version:  1.0.0(7/06/2020)
 *         Author:  Guo Wenxue <guowenxue@gmail.com>
@@ -22,7 +22,7 @@
#include <sys/types.h>
#include <sys/stat.h>

#include "util_proc.h"
#include "proc.h"
#include "logger.h"

proc_signal_t     g_signal={0};
@@ -59,7 +59,6 @@
            break;
    }
}


/* install default signal process functions  */
void install_default_signal(void)
@@ -184,8 +183,6 @@

    return 0;
}



/* ****************************************************************************
 * FunctionName: record_daemon_pid
@@ -345,8 +342,6 @@
    return 0;
}



/* ****************************************************************************
 * FunctionName: set_daemon_running
 * Description : Set the programe running as daemon if it's not running and record
@@ -398,8 +393,6 @@
        goto CleanUp;

CleanUp:


    if( thread_id )
    {
        if( rv )
@@ -412,7 +405,6 @@
    pthread_attr_destroy(&thread_attr);
    return rv;
}


/* excute a linux command by system() */
void exec_system_cmd(const char *format, ...)
@@ -428,5 +420,3 @@

    system(cmd);
}



 project/booster/proc.h

File was renamed from project/booster/util_proc.h
@@ -2,7 +2,7 @@
 *      Copyright:  (C) 2020 LingYun IoT System Studio
 *                  All rights reserved.
 *
 *       Filename:  util_proc.h
 *       Filename:  proc.h
 *    Description:  This head file is for Linux process/thread API
 *
 *        Version:  1.0.0(7/06/2012~)
@@ -15,7 +15,6 @@
#define __UTIL_PROC_H_

#include <signal.h>
#include <time.h>

#define PID_ASCII_SIZE  11

@@ -62,28 +61,5 @@

/* get daemon process ID from $pid_file   */
extern pid_t get_daemon_pid(const char *pid_file);

/* +------------------------+
 * |  inline functions API  |
 * +------------------------+*/
static inline void msleep(unsigned long ms)
{
    struct timespec cSleep;
    unsigned long ulTmp;

    cSleep.tv_sec = ms / 1000;
    if (cSleep.tv_sec == 0)
    {
        ulTmp = ms * 10000;
        cSleep.tv_nsec = ulTmp * 100;
    }
    else
    {
        cSleep.tv_nsec = 0;
    }

    nanosleep(&cSleep, 0);
    return ;
}

#endif

 project/booster/utils.h

New file
@@ -0,0 +1,61 @@
/********************************************************************************
 *      Copyright:  (C) 2020 LingYun IoT System Studio
 *                  All rights reserved.
 *
 *       Filename:  util.h
 *    Description:  This file is common utility functions
 *
 *        Version:  1.0.0(7/06/2012~)
 *         Author:  Guo Wenxue <guowenxue@gmail.com>
 *      ChangeLog:  1, Release initial version on "7/06/2012 09:21:33 PM"
 *
 ********************************************************************************/

#ifndef __UTIL_H_
#define __UTIL_H_

#include <time.h>
#include <stddef.h>

#define container_of(ptr, type, member) ((type *)((char *)(ptr) - offsetof(type, member)))

/* +------------------------+
 * |   time functions API   |
 * +------------------------+*/
static inline void msleep(unsigned long ms)
{
    struct timespec cSleep;
    unsigned long ulTmp;

    cSleep.tv_sec = ms / 1000;
    if (cSleep.tv_sec == 0)
    {
        ulTmp = ms * 10000;
        cSleep.tv_nsec = ulTmp * 100;
    }
    else
    {
        cSleep.tv_nsec = 0;
    }

    nanosleep(&cSleep, 0);
    return ;
}

static inline int check_timeout(time_t *last_time, int interval)
{
    int                  timeout = 0;
    time_t               now;

    time(&now);

    if( difftime(now, *last_time)>interval )
    {
        timeout = 1;
        *last_time = now;
    }

    return timeout;
}

#endif

 project/gpsd/gpsd.c

@@ -17,7 +17,7 @@

#include "logger.h"
#include "comport.h"
#include "util_proc.h"
#include "proc.h"

typedef struct gps_fix_s
{
@@ -30,7 +30,6 @@
    float      speed;     /* Speed over ground, meters/sec */
    float      track;     /* Course made good (relative to true north) */
} gps_fix_t;


int proc_gprmc(char *buf, int size, gps_fix_t *info);


 project/lightd/config.c

@@ -3,7 +3,7 @@
 *                  All rights reserved.
 *
 *       Filename:  config.c
 *    Description:  This file is mqttd configure file parser function
 *    Description:  This file is lightd configure file parser function
 *
 *        Version:  1.0.0(2019年06月25日)
 *         Author:  Guo Wenxue <guowenxue@gmail.com>
@@ -41,7 +41,6 @@
    logger = &ctx->logger;
    hwinfo = &ctx->hwinfo;
    mqtt = &ctx->mqtt;
    mqtt->userdata = (void *)hwinfo;

    ini = iniparser_load(conf_file);
    if( !ini )
@@ -87,7 +86,7 @@
        goto cleanup;
    }
    /* cJSON parser ID will get ""  */
    snprintf(mqtt->devid, sizeof(mqtt->devid), "\"%s\"", str);
    strncpy(mqtt->devid, str, sizeof(mqtt->devid));
    log_info("Parser device ID [%s]\n", mqtt->devid);


@@ -159,17 +158,20 @@
    mqtt->port = val;
    log_info("Parser MQTT broker server [%s:%d]\n", mqtt->host, mqtt->port);

    str=iniparser_getstring(ini, "broker:token", NULL);
    strncpy(mqtt->token, str, sizeof(mqtt->uid) );
    if( (str=iniparser_getstring(ini, "broker:token", NULL)) )
    {
        strncpy(mqtt->token, str, sizeof(mqtt->uid) );
        log_info("Parser broker token [%s]\n", mqtt->token);
    }

    str=iniparser_getstring(ini, "broker:username", NULL);
    strncpy(mqtt->uid, str, sizeof(mqtt->uid) );
    if( (str=iniparser_getstring(ini, "broker:username", NULL)) )
        strncpy(mqtt->uid, str, sizeof(mqtt->uid) );

    str=iniparser_getstring(ini, "broker:password", NULL);
    strncpy(mqtt->pwd, str, sizeof(mqtt->pwd) );
    if( (str=iniparser_getstring(ini, "broker:password", NULL)) )
        strncpy(mqtt->pwd, str, sizeof(mqtt->pwd) );

    if( mqtt->uid && mqtt->pwd )
        log_info("Parser broker author by [%s:%s]\n", mqtt->uid, mqtt->pwd);
    if( mqtt->uid )
        log_info("Parser broker account [%s:%s]\n", mqtt->uid, mqtt->pwd);

    mqtt->keepalive = iniparser_getint(ini, "broker:keepalive", DEF_KEEPALIVE);
    log_info("Parser broker keepalive timeout [%d] seconds\n", mqtt->keepalive);

 project/lightd/config.h

@@ -3,7 +3,7 @@
 *                  All rights reserved.
 *
 *       Filename:  config.h
 *    Description:  This file is mqttd configure file parser function
 *    Description:  This file is lightd configure file parser function
 *
 *        Version:  1.0.0(2019年06月25日)
 *         Author:  Guo Wenxue <guowenxue@gmail.com>
@@ -13,6 +13,8 @@
#ifndef  __CONF_H_
#define  __CONF_H_

#include <stddef.h>
#include "utils.h"
#include "gpio.h"

enum
@@ -73,6 +75,9 @@
    mqtt_ctx_t      mqtt;
} iotd_ctx_t;

/* get iotd_ctx address by mqtt_ctx address */
#define to_iotd(ctx)    container_of(ctx, iotd_ctx_t, mqtt);

extern int parser_conf(const char *conf_file, iotd_ctx_t *ctx, int debug);

#endif   /* ----- #ifndef _CONF_H_  ----- */

 project/lightd/etc/lightd.service

@@ -6,6 +6,7 @@
Type=simple
ExecStartPre=/bin/rm -f /tmp/.lightd.pid /var/log/lightd.log
ExecStart=/usr/bin/lightd -c /etc/lightd.conf
ExecStop=/bin/rm -f /tmp/.lightd.pid

Restart=always
RestartSec=2

 project/lightd/hal/gpio.c

@@ -17,7 +17,7 @@
#include <errno.h>

#include "logger.h"
#include "util_proc.h"
#include "utils.h"
#include "gpio.h"

#define RPI_GPIONAME        "gpiochip0"

 project/lightd/hal/tsl2561.c

@@ -37,8 +37,8 @@
#include <sys/types.h>
#include <sys/stat.h>

#include "util_proc.h"
#include "logger.h"
#include "utils.h"
#include "tsl2561.h"



 project/lightd/lightd.c

@@ -2,8 +2,8 @@
 *      Copyright:  (C) 2019 LingYun IoT System Studio
 *                  All rights reserved.
 *
 *       Filename:  main.c
 *    Description:  This file
 *       Filename:  lightd.c
 *    Description:  This file is infrared detect auto light program on RaspberryPi
 *
 *        Version:  1.0.0(29/01/19)
 *         Author:  Guo Wenxue <guowenxue@gmail.com>
@@ -23,7 +23,7 @@
#include <cjson/cJSON.h>

#include "logger.h"
#include "util_proc.h"
#include "proc.h"
#include "config.h"
#include "tsl2561.h"
#include "ds18b20.h"
@@ -31,13 +31,12 @@
#define PROG_VERSION               "v1.0.0"
#define DAEMON_PIDFILE             "/tmp/.lightd.pid"

int check_timeout(time_t *last_time, int interval);
void *thingsboard_worker(void *args);

static void program_usage(char *progname)
{
    printf("Usage: %s [OPTION]...\n", progname);
    printf(" %s is LingYun studio MQTT daemon program running on RaspberryPi\n", progname);
    printf(" %s is LingYun studio lightd program running on RaspberryPi\n", progname);

    printf("\nMandatory arguments to long options are mandatory for short options too:\n");
    printf(" -b[daemon  ]  Running in daemon mode\n");
@@ -127,17 +126,13 @@
    /* initial gpio hardware */
    gpio_init(&hwinfo->gpio);

    /*
     * +--------------------------------+
     * |    ThingsBoard MQTT Thread     |
     * +--------------------------------+
     */
    /* start thingsboard MQTT thread */
    if( thread_start(&tid, thingsboard_worker, &ctx.mqtt ) < 0 )
    {
        log_error("Start MQTT subsciber worker thread failure\n");
        log_error("Start thingsboard MQTT worker thread failure\n");
        goto cleanup;
    }
    log_info("Start MQTT subsciber worker thread ok\n");
    log_info("Start thingsboard MQTT worker thread ok\n");

    /*
     * +--------------------------------+
@@ -154,7 +149,7 @@
            if( !hwinfo->tsl2561 )
            {
                log_error("TSL2561 is not present, do not turn on the light\n");
                lux = hwinfo->lux_threshold + 100.0;
                lux = hwinfo->lux_threshold + 100.0;
                goto nextloop;
            }

@@ -162,7 +157,7 @@
            if( tsl2561_get_lux(&lux) < 0 )
            {
                log_error("TSL2561 sample failed, do not turn on the light\n");
                lux = hwinfo->lux_threshold + 100.0;
                lux = hwinfo->lux_threshold + 100.0;
                goto nextloop;
            }

@@ -210,27 +205,11 @@
 * +--------------------------------+
 */

int check_timeout(time_t *last_time, int interval)
{
    int                  timeout = 0;
    time_t               now;

    time(&now);

    if( difftime(now, *last_time)>interval )
    {
        timeout = 1;
        *last_time = now;
    }

    return timeout;
}

/* compatible with MQTT publish callback function */
/* process publisher(uplink) data */
void pub_connect_callback(struct mosquitto *mosq, void *userdata, int result)
{
    mqtt_ctx_t             *ctx = (mqtt_ctx_t *)userdata;
    hwinfo_t               *hwinfo = (hwinfo_t *)ctx->userdata;
    mqtt_ctx_t             *mqtt = (mqtt_ctx_t *)userdata;
    iotd_ctx_t             *iotd = to_iotd(mqtt);
    int                     rv = 0;
    char                    msg[128];
    float                   temp = 0.0; /* temperature */
@@ -238,24 +217,19 @@
    static time_t           last_time = 0;

    /* publish time is not arrive */
    if( !check_timeout(&last_time, ctx->interval) )
    {
    if( !check_timeout(&last_time, mqtt->interval) )
        return ;
    }

    log_debug("Publish topic '%s'\n", ctx->pubTopic);

    if( hwinfo->ds18b20 )
    log_debug("Publish topic '%s'\n", mqtt->pubTopic);
    if( iotd->hwinfo.ds18b20 )
    {
        memset(msg, 0, sizeof(msg));

        log_debug("DS18B20 temperature sensor enabled, start broadcast it\n");

        if( ds18b20_get_temperature(&temp)<0 )
            return ;

        memset(msg, 0, sizeof(msg));
        snprintf(msg, sizeof(msg), "{\"temperature\":%.2f}", temp);
        rv = mosquitto_publish(mosq, NULL, ctx->pubTopic, strlen(msg), msg, ctx->pubQos, retain);
        rv = mosquitto_publish(mosq, NULL, mqtt->pubTopic, strlen(msg), msg, mqtt->pubQos, retain);
        if( rv )
        {
            log_error("Publisher broadcast message '%s' failure: %d\n", msg, rv);
@@ -269,27 +243,7 @@
    return ;
}

void sub_connect_callback(struct mosquitto *mosq, void *userdata, int result)
{
    mqtt_ctx_t             *ctx = (mqtt_ctx_t *)userdata;

    if( result )
    {
        log_error("mosquitto connect to broker server failed, rv=%d\n", result);
        return ;
    }

    log_info("mosquitto connect to broker server[%s:%d] successfully\n", ctx->host, ctx->port);
    mosquitto_subscribe(mosq, NULL, ctx->subTopic, ctx->subQos);
}

void sub_disconnect_callback(struct mosquitto *mosq, void *userdata, int result)
{
    mqtt_ctx_t             *ctx = (mqtt_ctx_t *)userdata;

    log_warn("mosquitto disconnect to broker server[%s:%d], reason=%d\n", ctx->host, ctx->port, result);
}

/* process subscriber(downlink) data */
void proc_json_items(cJSON *root, mqtt_ctx_t *ctx)
{
    cJSON *item_method;
@@ -377,12 +331,34 @@
        return ;
    }

    /* process receive message data */
    proc_json_items(root, ctx);

    /* must delete it, or it will result memory leak */
    cJSON_Delete(root);

    return ;
}

void mqtt_connect_callback(struct mosquitto *mosq, void *userdata, int result)
{
    mqtt_ctx_t             *ctx = (mqtt_ctx_t *)userdata;

    if( result )
    {
        log_error("mosquitto connect to broker server failed, rv=%d\n", result);
        return ;
    }

    log_info("mosquitto connect to broker server[%s:%d] successfully\n", ctx->host, ctx->port);
    mosquitto_subscribe(mosq, NULL, ctx->subTopic, ctx->subQos);
}

void mqtt_disconnect_callback(struct mosquitto *mosq, void *userdata, int result)
{
    mqtt_ctx_t             *ctx = (mqtt_ctx_t *)userdata;

    log_warn("mosquitto disconnect to broker server[%s:%d], reason=%d\n", ctx->host, ctx->port, result);
}

void *thingsboard_worker(void *args)
@@ -412,8 +388,8 @@
    }

    /* set callback functions */
    mosquitto_connect_callback_set(mosq, sub_connect_callback);
    mosquitto_disconnect_callback_set(mosq, sub_disconnect_callback);
    mosquitto_connect_callback_set(mosq, mqtt_connect_callback);
    mosquitto_disconnect_callback_set(mosq, mqtt_disconnect_callback);
    mosquitto_message_callback_set(mosq, sub_message_callback);

    while( !g_signal.stop )
@@ -428,9 +404,10 @@

        while(!g_signal.stop)
        {
            /* periodically publish and report data */
            pub_connect_callback(mosq, ctx, MOSQ_ERR_SUCCESS);

            /* MQTT process in nonblock mode, timeout for 1s */
            /* MQTT process in Non-blocking mode, timeout for 1s */
            if( MOSQ_ERR_SUCCESS != (rv = mosquitto_loop(mosq, 1000, 1)) )
            {
                log_warn("MQTT loop error: %s, reconnecting...\n", mosquitto_strerror(rv));

 project/modules/pwm.c

@@ -32,7 +32,7 @@
#include <libgen.h>

#include "logger.h"
#include "util_proc.h"
#include "utils.h"
#include "pwm.h"

/* check PWM $channel export or not */
@@ -118,8 +118,6 @@
int init_pwm(int channel, int freq, int duty)
{
    int           rv;
    char          buf[32];
    char          path[256];

    if( (rv=export_pwm(channel, 1)) )
    {

 project/modules/relay.c

@@ -139,6 +139,7 @@
    }

    relay = &ctx.relay[which];
    log_info("turn Led %s %s\n", relay->name, cmd?"on":"off");

    if( OFF == cmd )
    {

 project/modules/sht20.c

@@ -40,7 +40,7 @@
#include <linux/i2c-dev.h>

#include "logger.h"
#include "util_proc.h"
#include "utils.h"
#include "sht20.h"

int i2c_write(int fd, uint8_t slave_addr, uint8_t *data, int len);
@@ -90,7 +90,7 @@

    memset(buf, 0, sizeof(buf));
    i2c_read(fd, SHT20_I2CADDR, buf, 3);
    log_dump(LOG_LEVEL_TRACE, "Temperature sample data: ", buf, 3);
    log_dump(LOG_LEVEL_TRACE, "Temperature sample data: ", (char *)buf, 3);

    if( !sht20_checksum(buf, 2, buf[2]) )
    {
@@ -113,7 +113,7 @@

    memset(buf, 0, sizeof(buf));
    i2c_read(fd, SHT20_I2CADDR, buf, 3);
    log_dump(LOG_LEVEL_TRACE, "Relative humidity sample data: ", buf, 3);
    log_dump(LOG_LEVEL_TRACE, "Relative humidity sample data: ", (char *)buf, 3);

    if( !sht20_checksum(buf, 2, buf[2]) )
    {

 project/modules/tsl2561.c

@@ -37,7 +37,7 @@
#include <sys/types.h>
#include <sys/stat.h>

#include "util_proc.h"
#include "utils.h"
#include "logger.h"
#include "tsl2561.h"


 project/thingsboard/config.c

@@ -3,7 +3,7 @@
 *                  All rights reserved.
 *
 *       Filename:  config.c
 *    Description:  This file is mqttd configure file parser function
 *    Description:  This file is thingsboard configure file parser function
 *
 *        Version:  1.0.0(2019年06月25日)
 *         Author:  Guo Wenxue <guowenxue@gmail.com>
@@ -14,12 +14,15 @@
#include "logger.h"
#include "iniparser.h"

int parser_conf(const char *conf_file, mqtt_ctx_t *ctx, int debug)
int parser_conf(const char *conf_file, iotd_ctx_t *ctx, int debug)
{
    dictionary          *ini;
    const char          *str;
    int                  val;
    int                  rv = 0;
    logger_t            *logger;
    hwinfo_t            *hwinfo;
    mqtt_ctx_t          *mqtt;

    if( !conf_file || !ctx )
    {
@@ -28,6 +31,9 @@
    }

    memset(ctx, 0, sizeof(*ctx));
    logger = &ctx->logger;
    hwinfo = &ctx->hwinfo;
    mqtt = &ctx->mqtt;

    ini = iniparser_load(conf_file);
    if( !ini )
@@ -42,18 +48,18 @@
    if( !debug )
    {
        str = iniparser_getstring(ini, "logger:file", "/tmp/thingsboard.log");
        strncpy(ctx->logfile, str, sizeof(ctx->logfile));
        ctx->logsize = iniparser_getint(ini, "logger:size", 1024);
        ctx->loglevel = iniparser_getint(ini, "logger:level", LOG_LEVEL_INFO);
        strncpy(logger->logfile, str, sizeof(logger->logfile));
        logger->logsize = iniparser_getint(ini, "logger:size", 1024);
        logger->loglevel = iniparser_getint(ini, "logger:level", LOG_LEVEL_INFO);
    }
    else
    {
        strncpy(ctx->logfile, "console", sizeof(ctx->logfile));
        ctx->loglevel = LOG_LEVEL_DEBUG;
        ctx->logsize = 0;
        strncpy(logger->logfile, "console", sizeof(logger->logfile));
        logger->loglevel = LOG_LEVEL_DEBUG;
        logger->logsize = 0;
    }

    if( log_open(ctx->logfile, ctx->loglevel, ctx->logsize, LOG_LOCK_DISABLE) < 0 )
    if( log_open(logger->logfile, logger->loglevel, logger->logsize, LOG_LOCK_DISABLE) < 0 )
    {
        fprintf(stderr, "Logger system initialise failure\n");
        return -2;
@@ -73,8 +79,8 @@
        goto cleanup;
    }
    /* cJSON parser ID will get ""  */
    snprintf(ctx->devid, sizeof(ctx->devid), "\"%s\"", str);
    log_info("Parser device ID [%s]\n", ctx->devid);
    strncpy(mqtt->devid, str, sizeof(mqtt->devid));
    log_info("Parser device ID [%s]\n", mqtt->devid);


    /*+------------------------------------------------------+
@@ -82,43 +88,43 @@
     *+------------------------------------------------------+*/

    /* relay */
    ctx->hwconf.relay=iniparser_getint(ini, "hardware:relay", 0);
    if( !ctx->hwconf.relay )
    hwinfo->relay=iniparser_getint(ini, "hardware:relay", 0);
    if( !hwinfo->relay )
        log_warn("Parser relay module disabled\n");
    else
        log_info("Parser relay module enabled\n");

    /* RGB 3-colors LED */
    ctx->hwconf.led=iniparser_getint(ini, "hardware:rgbled", 0);
    if( !ctx->hwconf.led )
    hwinfo->led=iniparser_getint(ini, "hardware:rgbled", 0);
    if( !hwinfo->led )
        log_warn("Parser RGB 3-colors Led module disabled\n");
    else
        log_info("Parser RGB 3-colors Led module enabled\n");

    /* beeper */
    ctx->hwconf.beeper=iniparser_getint(ini, "hardware:beep", 0);
    if( !ctx->hwconf.beeper )
    hwinfo->beeper=iniparser_getint(ini, "hardware:beep", 0);
    if( !hwinfo->beeper )
        log_warn("Parser beeper module disabled\n");
    else
        log_info("Parser beeper module enabled\n");

    /* DS18B20 temperature module */
    ctx->hwconf.ds18b20=iniparser_getint(ini, "hardware:ds18b20", 0);
    if( !ctx->hwconf.ds18b20 )
    hwinfo->ds18b20=iniparser_getint(ini, "hardware:ds18b20", 0);
    if( !hwinfo->ds18b20 )
        log_warn("Parser DS18B20 temperature module disabled\n");
    else
        log_info("Parser DS18B20 temperature module enabled\n");

    /* SHT20 temperature and hummidity module */
    ctx->hwconf.sht2x=iniparser_getint(ini, "hardware:sht2x", 0);
    if( !ctx->hwconf.sht2x )
    hwinfo->sht2x=iniparser_getint(ini, "hardware:sht2x", 0);
    if( !hwinfo->sht2x )
        log_warn("Parser SHT2X temperature and hummidity module disabled\n");
    else
        log_info("Parser SHT2X temperature and hummidity module enabled\n");

    /* TSL2561 light intensity sensor module */
    ctx->hwconf.tsl2561=iniparser_getint(ini, "hardware:tsl2561", 0);
    if( !ctx->hwconf.tsl2561 )
    hwinfo->tsl2561=iniparser_getint(ini, "hardware:tsl2561", 0);
    if( !hwinfo->tsl2561 )
        log_warn("Parser TSL2561 light intensity sensor module disabled\n");
    else
        log_info("Parser TSL2561 light intensity sensor module enabled\n");
@@ -133,7 +139,7 @@
        rv = -4;
        goto cleanup;
    }
    strncpy(ctx->host, str, sizeof(ctx->host) );
    strncpy(mqtt->host, str, sizeof(mqtt->host) );

    if( (val=iniparser_getint(ini, "broker:port", -1)) < 0 )
    {
@@ -141,23 +147,26 @@
        rv = -5;
        goto cleanup;
    }
    ctx->port = val;
    log_info("Parser MQTT broker server [%s:%d]\n", ctx->host, ctx->port);
    mqtt->port = val;
    log_info("Parser MQTT broker server [%s:%d]\n", mqtt->host, mqtt->port);

    str=iniparser_getstring(ini, "broker:token", NULL);
    strncpy(ctx->token, str, sizeof(ctx->uid) );
    if( (str=iniparser_getstring(ini, "broker:token", NULL)) )
    {
        strncpy(mqtt->token, str, sizeof(mqtt->uid) );
        log_info("Parser broker token [%s]\n", mqtt->token);
    }

    str=iniparser_getstring(ini, "broker:username", NULL);
    strncpy(ctx->uid, str, sizeof(ctx->uid) );
    if( (str=iniparser_getstring(ini, "broker:username", NULL)) )
        strncpy(mqtt->uid, str, sizeof(mqtt->uid) );

    str=iniparser_getstring(ini, "broker:password", NULL);
    strncpy(ctx->pwd, str, sizeof(ctx->pwd) );
    if( (str=iniparser_getstring(ini, "broker:password", NULL)) )
        strncpy(mqtt->pwd, str, sizeof(mqtt->pwd) );

    if( ctx->uid && ctx->pwd )
        log_info("Parser broker author by [%s:%s]\n", ctx->uid, ctx->pwd);
    if( mqtt->uid )
        log_info("Parser broker account [%s:%s]\n", mqtt->uid, mqtt->pwd);

    ctx->keepalive = iniparser_getint(ini, "broker:keepalive", DEF_KEEPALIVE);
    log_info("Parser broker keepalive timeout [%d] seconds\n", ctx->keepalive);
    mqtt->keepalive = iniparser_getint(ini, "broker:keepalive", DEF_KEEPALIVE);
    log_info("Parser broker keepalive timeout [%d] seconds\n", mqtt->keepalive);

    /*+------------------------------------------------------+
     *|             parser publisher settings                |
@@ -169,11 +178,11 @@
        rv = -6;
        goto cleanup;
    }
    strncpy(ctx->pubTopic, str, sizeof(ctx->pubTopic) );
    strncpy(mqtt->pubTopic, str, sizeof(mqtt->pubTopic) );

    ctx->pubQos = iniparser_getint(ini, "publisher:pubQos", DEF_QOS);
    ctx->interval = iniparser_getint(ini, "publisher:interval", DEF_PUBINTERVAL);
    log_info("Parser publisher topic \"%s\" with Qos[%d] interval[%d]\n", ctx->pubTopic, ctx->pubQos, ctx->interval);
    mqtt->pubQos = iniparser_getint(ini, "publisher:pubQos", DEF_QOS);
    mqtt->interval = iniparser_getint(ini, "publisher:interval", DEF_PUBINTERVAL);
    log_info("Parser publisher topic \"%s\" with Qos[%d] interval[%d]\n", mqtt->pubTopic, mqtt->pubQos, mqtt->interval);

    /*+------------------------------------------------------+
     *|             parser subscriber settings               |
@@ -185,10 +194,10 @@
        rv = -7;
        goto cleanup;
    }
    strncpy(ctx->subTopic, str, sizeof(ctx->subTopic) );
    strncpy(mqtt->subTopic, str, sizeof(mqtt->subTopic) );

    ctx->subQos = iniparser_getint(ini, "subsciber:subQos", DEF_QOS);
    log_info("Parser subscriber topic \"%s\" with Qos[%d]\n", ctx->subTopic, ctx->subQos);
    mqtt->subQos = iniparser_getint(ini, "subsciber:subQos", DEF_QOS);
    log_info("Parser subscriber topic \"%s\" with Qos[%d]\n", mqtt->subTopic, mqtt->subQos);

cleanup:
    if( ini )

 project/thingsboard/config.h

@@ -3,7 +3,7 @@
 *                  All rights reserved.
 *
 *       Filename:  config.h
 *    Description:  This file is mqttd configure file parser function
 *    Description:  This file is thingsboard configure file parser function
 *
 *        Version:  1.0.0(2019年06月25日)
 *         Author:  Guo Wenxue <guowenxue@gmail.com>
@@ -12,6 +12,8 @@
 ********************************************************************************/
#ifndef  __CONF_H_
#define  __CONF_H_

#include "utils.h"

enum
{
@@ -24,49 +26,58 @@
#define DEF_PUBINTERVAL     120
#define DEF_QOS             Qos2

typedef struct hwconf_s
typedef struct hwinfo_s
{
    int            relay;   /* relay aviable or not.   0:Disable  1: Enable */
    int            led;     /* RGB led aviable or not. 0:Disable  1: Enable */
    int            beeper;  /* beeper aviable or not.  0:Disable  1: Enable */
    int            ds18b20; /* DS1B820 aviable or not. 0:Disable  1: Enable */
    int            sht2x;   /* SHT20  aviable or not.  0:Disable  1: Enable */
    int            tsl2561; /* TSL2561 aviable or not.  0:Disable  1: Enable */
} hwconf_t;
    int             relay;   /* relay aviable or not.   0:Disable  1: Enable */
    int             led;     /* RGB led aviable or not. 0:Disable  1: Enable */
    int             beeper;  /* beeper aviable or not.  0:Disable  1: Enable */
    int             ds18b20; /* DS1B820 aviable or not. 0:Disable  1: Enable */
    int             sht2x;   /* SHT20  aviable or not.  0:Disable  1: Enable */
    int             tsl2561; /* TSL2561 aviable or not. 0:Disable  1: Enable */
} hwinfo_t;

/* logger settings */
typedef struct logger_s
{
    char            logfile[128]; /* logger record file */
    int             loglevel;     /* logger level  */
    int             logsize;      /* logger file maxsize, oversize will rollback */
} logger_t;

typedef struct mqtt_ctx_s
{
    char          devid[32];    /*  device ID */

    /* hardware configuration */
    hwconf_t      hwconf;

    /* logger settings */
    char          logfile[128]; /* logger record file */
    int           loglevel;     /* logger level  */
    int           logsize;      /* logger file maxsize, oversize will rollback */
    char            devid[32];    /*  device ID */
    void           *userdata;      /* user data pointer */

    /* Broker settings  */
    char          host[128];  /* MQTT broker server name  */
    int           port;       /* MQTT broker listen port  */
    char          uid[64];    /* username */
    char          pwd[64];    /* password */
    char          token[64];  /* token */
    int           keepalive;  /* MQTT broker send PING message to subsciber/publisher keepalive timeout<seconds> */
    char            host[128];  /* MQTT broker server name  */
    int             port;       /* MQTT broker listen port  */
    char            uid[64];    /* username */
    char            pwd[64];    /* password */
    char            token[64];  /* token */
    int             keepalive;  /* MQTT broker send PING message to subsciber/publisher keepalive timeout<seconds> */

    /* Publisher settings */
    char          pubTopic[256]; /* Publisher topic  */
    int           pubQos;        /* Publisher Qos */
    int           interval ;     /* Publish sensor data interval time, unit seconds */
    char            pubTopic[256]; /* Publisher topic  */
    int             pubQos;        /* Publisher Qos */
    int             interval ;     /* Publish sensor data interval time, unit seconds */

    /* Subscriber settings */
    char          subTopic[256]; /* Subscriber topic */
    int           subQos;        /* Subscriber Qos  */
    char            subTopic[256]; /* Subscriber topic */
    int             subQos;        /* Subscriber Qos  */
} mqtt_ctx_t;

typedef struct iotd_ctx_s
{
    logger_t        logger;
    hwinfo_t        hwinfo;
    mqtt_ctx_t      mqtt;
} iotd_ctx_t;

extern int parser_conf(const char *conf_file, mqtt_ctx_t *ctx, int debug);
/* get iotd_ctx address by mqtt_ctx address */
#define to_iotd(ctx)    container_of(ctx, iotd_ctx_t, mqtt);

#endif   /* ----- #ifndef _CONF_H_  ----- */
extern int parser_conf(const char *conf_file, iotd_ctx_t *ctx, int debug);

#endif


 project/thingsboard/etc/thingsboard.conf

@@ -1,7 +1,7 @@
[common]
devid="RaspberryPi#4B"

# 树莓派连接的外设信息，0:禁用或未连接  其他: 使能或相关硬件连接的Pin管脚(wPI模式)
# 树莓派连接的外设信息，0:禁用或未连接
[hardware]

# 是否使能 RGB 三色灯模块，0:禁用  1:使能
@@ -52,8 +52,14 @@

[subsciber]

# 订阅三色灯主题和收到的数据
# mosquitto_sub -h weike-iot.com -p 2262 -u "l3ie6juxf0t9wn8kjsk4" -t "v1/devices/me/rpc/request/+" 
#  {"method":"setValue","params":{"device":"RedLed","status":true}}
#
# 更新三色灯当前的默认状态
# mosquitto_pub -h weike-iot.com -p 2262 -u "l3ie6juxf0t9wn8kjsk4" -t "v1/devices/me/attributes" -m '{"redLedStatus": false}'
# mosquitto_pub -h weike-iot.com -p 2262 -u "l3ie6juxf0t9wn8kjsk4" -t "v1/devices/me/attributes" -m '{"greenLedStatus": false}'
# mosquitto_pub -h weike-iot.com -p 2262 -u "l3ie6juxf0t9wn8kjsk4" -t "v1/devices/me/attributes" -m '{"blueLedStatus": false}'
subTopic="v1/devices/me/rpc/request/+"
subQos=0


 project/thingsboard/etc/thingsboard.service

@@ -6,6 +6,7 @@
Type=simple
ExecStartPre=/bin/rm -f /tmp/.thingsboard.pid /var/log/thingsboard.log
ExecStart=/usr/bin/thingsboard -c /etc/thingsboard.conf
ExecStop=/bin/rm -f /tmp/.thingsboard.pid

Restart=always
RestartSec=2

 project/thingsboard/makefile

@@ -39,7 +39,7 @@

# libraries
libs=openlibs ${SRCS}
LDFLAGS+=-lmosquitto -lcjson -lssl -lcrypto -lgpiod
LDFLAGS+=-lmosquitto -lcjson -lssl -lcrypto -lgpiod -lm

LDFLAGS+=-lpthread

@@ -51,7 +51,7 @@

subdir:
    @for dir in ${libs} ; do if [ ! -e $${dir} ] ; then ln -s ../$${dir}; fi; done
    @for dir in ${libs} ;  do make -C $${dir} ; done
    @for dir in ${libs} ;  do CFLAGS="${CFLAGS}" make -C $${dir} ; done

install:
    cp ${APP_NAME} /tftp

 project/thingsboard/thingsboard.c

@@ -2,8 +2,8 @@
 *      Copyright:  (C) 2019 LingYun IoT System Studio
 *                  All rights reserved.
 *
 *       Filename:  main.c
 *    Description:  This file
 *       Filename:  thingsboard.c
 *    Description:  This file is thingsboard platform device daemon program.
 *
 *        Version:  1.0.0(29/01/19)
 *         Author:  Guo Wenxue <guowenxue@gmail.com>
@@ -23,7 +23,7 @@
#include <cjson/cJSON.h>

#include "logger.h"
#include "util_proc.h"
#include "proc.h"
#include "config.h"
#include "sht20.h"
#include "leds.h"
@@ -31,8 +31,7 @@
#define PROG_VERSION               "v1.0.0"
#define DAEMON_PIDFILE             "/tmp/.thingsboard.pid"

void *thingsboard_subsciber(void *args);
void *thingsboard_publisher(void *args);
void *thingsboard_worker(void *args);

static void program_usage(char *progname)
{
@@ -54,7 +53,7 @@
{
    int                daemon = 0;
    pthread_t          tid;
    mqtt_ctx_t         ctx;
    iotd_ctx_t         ctx;
    char               *conf_file="/etc/thingsboard.conf";
    int                debug = 0;
    int                opt;
@@ -99,7 +98,6 @@
            default:
                break;
        }

    }

    /* parser configure file */
@@ -119,34 +117,18 @@
    /* initial mosquitto library */
    mosquitto_lib_init();

    /*
     * +--------------------------------+
     * |    MQTT Subscriber Thread      |
     * +--------------------------------+
     */
    if( thread_start(&tid, thingsboard_subsciber, &ctx ) < 0 )
    /* start thingsboard MQTT thread */
    if( thread_start(&tid, thingsboard_worker, &ctx.mqtt ) < 0 )
    {
        log_error("Start MQTT subsciber worker thread failure\n");
        log_error("Start thingsboard MQTT worker thread failure\n");
        goto cleanup;
    }
    log_info("Start MQTT subsciber worker thread ok\n");
    log_info("Start thingsboard MQTT worker thread ok\n");

    /*
     * +--------------------------------+
     * |     MQTT publisher Thread      |
     * +--------------------------------+
     */
    if( thread_start(&tid, thingsboard_publisher, &ctx) < 0 )
    /* control thread loop */
    while( !g_signal.stop )
    {
        log_error("Start MQTT publisher worker thread failure\n");
        goto cleanup;
    }
    log_info("Start MQTT publisher worker thread ok\n");


    while( ! g_signal.stop )
    {
        msleep(1000);
        sleep(1);
    }

cleanup:
@@ -156,35 +138,39 @@
    return 0;
}


/*
 * +--------------------------------+
 * |    ThingsBoard MQTT Thread     |
 * +--------------------------------+
 */

/* process publisher(uplink) data */
void pub_connect_callback(struct mosquitto *mosq, void *userdata, int result)
{
    mqtt_ctx_t             *ctx = (mqtt_ctx_t *)userdata;
    mqtt_ctx_t             *mqtt = (mqtt_ctx_t *)userdata;
    iotd_ctx_t             *iotd = to_iotd(mqtt);
    int                     rv = 0;
    char                    msg[128];
    float                   temp = 0.0; /* temperature */
    float                   rh = 0.0;   /* relative humidity */
    int                     retain = 0;
    static time_t           last_time = 0;

    if( result )
    {
        log_error("Publisher connect to broker server[%s:%d] failed, rv=%d\n", ctx->host, ctx->port, result);
    /* publish time is not arrive */
    if( !check_timeout(&last_time, mqtt->interval) )
        return ;
    }

    log_info("Publisher connect to broker server[%s:%d] successfully\n", ctx->host, ctx->port);
    log_debug("Publish topic '%s'\n", ctx->pubTopic);

    if( ctx->hwconf.sht2x )
    log_debug("Publish topic '%s'\n", mqtt->pubTopic);
    if( iotd->hwinfo.sht2x )
    {
        memset(msg, 0, sizeof(msg));

        log_debug("SHT2X temperature and humidity sensor enabled, start broadcast it\n");

        if( sht2x_get_temp_humidity(&temp, &rh)<0 )
            return ;

        memset(msg, 0, sizeof(msg));
        snprintf(msg, sizeof(msg), "{\"temperature\":%.2f, \"humidity\":%.2f}", temp, rh);
        rv = mosquitto_publish(mosq, NULL, ctx->pubTopic, strlen(msg), msg, ctx->pubQos, retain);
        rv = mosquitto_publish(mosq, NULL, mqtt->pubTopic, strlen(msg), msg, mqtt->pubQos, retain);
        if( rv )
        {
            log_error("Publisher broadcast message '%s' failure: %d\n", msg, rv);
@@ -195,83 +181,10 @@
        }
    }

    msleep(500);
    log_info("Publisher broadcast over and disconnect broker now\n", ctx->host, ctx->port);
    mosquitto_disconnect(mosq);

    return ;
}

void *thingsboard_publisher(void *args)
{
    mqtt_ctx_t             *ctx = (mqtt_ctx_t *)args;
    struct mosquitto       *mosq;
    bool                    session = true;

    mosq = mosquitto_new(ctx->devid, session, ctx);
    if( !mosq )
    {
        log_error("mosquitto_new failure\n");
        return NULL;
    }

    /* connnect to broker by token or uid/pwd */
    if( strlen(ctx->token ) > 0)
    {
        log_info("Using token authentication\n");
        mosquitto_username_pw_set(mosq, ctx->token, NULL);
    }
    else if( strlen(ctx->uid)> 0  && strlen(ctx->pwd)> 0 )
    {
        log_info("Using username/password authentication\n");
        mosquitto_username_pw_set(mosq, ctx->uid, ctx->pwd);
    }

    /* set callback functions */
    mosquitto_connect_callback_set(mosq, pub_connect_callback);

    while( !g_signal.stop )
    {
        /* connect to MQTT broker  */
        if( mosquitto_connect(mosq, ctx->host, ctx->port, ctx->keepalive) )
        {
            log_error("Publisher connect to broker[%s:%d] failure: %s\n", ctx->host, ctx->port, strerror(errno));
            msleep(1000);
            continue;
        }

        /* -1: use default timeout 1000ms  1: unused */
        mosquitto_loop_forever(mosq, -1, 1);

        /* Publisher broadcast sensors data message interval time, unit seconds */
        sleep( ctx->interval );
    }

    mosquitto_destroy(mosq);
    return NULL;
}

void sub_connect_callback(struct mosquitto *mosq, void *userdata, int result)
{
    mqtt_ctx_t             *ctx = (mqtt_ctx_t *)userdata;

    if( result )
    {
        log_error("Subscriber connect to broker server failed, rv=%d\n", result);
        return ;
    }

    log_info("Subscriber connect to broker server[%s:%d] successfully\n", ctx->host, ctx->port);
    mosquitto_subscribe(mosq, NULL, ctx->subTopic, ctx->subQos);
}

void sub_disconnect_callback(struct mosquitto *mosq, void *userdata, int result)
{
    mqtt_ctx_t             *ctx = (mqtt_ctx_t *)userdata;

    log_warn("Subscriber disconnect to broker server[%s:%d], reason=%d\n", ctx->host, ctx->port, result);
}

/* process subscriber(downlink) data */
void proc_json_items(cJSON *root, mqtt_ctx_t *ctx)
{
    cJSON *item_method;
@@ -363,6 +276,7 @@
        return ;
    }

    /* process receive message data */
    proc_json_items(root, ctx);

    /* must delete it, or it will result memory leak */
@@ -371,11 +285,33 @@
    return ;
}

void *thingsboard_subsciber(void *args)
void mqtt_connect_callback(struct mosquitto *mosq, void *userdata, int result)
{
    mqtt_ctx_t             *ctx = (mqtt_ctx_t *)userdata;

    if( result )
    {
        log_error("mosquitto connect to broker server failed, rv=%d\n", result);
        return ;
    }

    log_info("mosquitto connect to broker server[%s:%d] successfully\n", ctx->host, ctx->port);
    mosquitto_subscribe(mosq, NULL, ctx->subTopic, ctx->subQos);
}

void mqtt_disconnect_callback(struct mosquitto *mosq, void *userdata, int result)
{
    mqtt_ctx_t             *ctx = (mqtt_ctx_t *)userdata;

    log_warn("mosquitto disconnect to broker server[%s:%d], reason=%d\n", ctx->host, ctx->port, result);
}

void *thingsboard_worker(void *args)
{
    mqtt_ctx_t             *ctx = (mqtt_ctx_t *)args;
    struct mosquitto       *mosq;
    bool                    session = true;
    int                     rv = 0;

    mosq = mosquitto_new(ctx->devid, session, ctx);
    if( !mosq )
@@ -387,7 +323,7 @@
    /* connnect to broker by token or uid/pwd */
    if( strlen(ctx->token ) > 0)
    {
        log_info("Using token authentication\n");
        log_info("Using token authentication: '%s'\n", ctx->token);
        mosquitto_username_pw_set(mosq, ctx->token, NULL);
    }
    else if( strlen(ctx->uid)> 0  && strlen(ctx->pwd)> 0 )
@@ -397,8 +333,8 @@
    }

    /* set callback functions */
    mosquitto_connect_callback_set(mosq, sub_connect_callback);
    mosquitto_disconnect_callback_set(mosq, sub_disconnect_callback);
    mosquitto_connect_callback_set(mosq, mqtt_connect_callback);
    mosquitto_disconnect_callback_set(mosq, mqtt_disconnect_callback);
    mosquitto_message_callback_set(mosq, sub_message_callback);

    while( !g_signal.stop )
@@ -406,13 +342,26 @@
        /* connect to MQTT broker  */
        if( mosquitto_connect(mosq, ctx->host, ctx->port, ctx->keepalive) )
        {
            log_error("Subscriber connect to broker[%s:%d] failure: %s\n", ctx->host, ctx->port, strerror(errno));
            msleep(1000);
            log_error("mosquitto connect to broker[%s:%d] failure: %s\n", ctx->host, ctx->port, strerror(errno));
            sleep(1);
            continue;
        }

        /* -1: use default timeout 1000ms  1: unused */
        mosquitto_loop_forever(mosq, -1, 1);
        while(!g_signal.stop)
        {
            /* periodically publish and report data */
            pub_connect_callback(mosq, ctx, MOSQ_ERR_SUCCESS);

            /* MQTT process in Non-blocking mode, timeout for 1s */
            if( MOSQ_ERR_SUCCESS != (rv = mosquitto_loop(mosq, 1000, 1)) )
            {
                log_warn("MQTT loop error: %s, reconnecting...\n", mosquitto_strerror(rv));
                break;
            }
        }

        mosquitto_disconnect(mosq);
        sleep(1);
    }

    mosquitto_destroy(mosq);