update socket.c for listen socket

GuoWenxue

2022-04-22 0fd2ff9f9aca1f30d6b4620f90802223cc221fe0

 mqttd/etc/conf.c

@@ -25,28 +25,43 @@

    if( !conf_file )
    { 
        fprintf(stderr, "\nWARNNING: Use default MQTT configure\n");
        strncpy(ctx->id, "\"rpi3b001\"", sizeof(ctx->id));

        /* logger settings */
        strncpy(ctx->logfile, DBG_LOG_FILE, sizeof(ctx->logfile));
        ctx->loglevel = LOG_LEVEL_DEBUG;
        ctx->logsize = 1024;

        if( logger_init(ctx->logfile, ctx->loglevel, ctx->logsize) < 0 ) 
        {
            fprintf(stderr, "Logger system initialise failure\n");
            return -2;
        } 
        log_nrml("Logger system initialise ok\n");
        log_warn("WARNNING: Use default MQTT configure\n");

        /* Broker settings */
        strncpy(ctx->host, DEF_BORKER_HOSTNAME, sizeof(ctx->host));
        ctx->port = DEF_BROKER_PORT;
        log_nrml("Use default broker server [%s:%d]\n", ctx->host, ctx->port);

        strncpy(ctx->uid, DEF_BROKER_USERNAME, sizeof(ctx->uid));
        strncpy(ctx->pwd, DEF_BROKER_PASSWD, sizeof(ctx->pwd));
        log_nrml("Use default broker author by [%s:%s]\n", ctx->uid, ctx->pwd);

        ctx->keepalive = DEF_BROKER_KEEPALIVE;
        log_nrml("Use default broker keepalive timeout [%d] seconds\n", ctx->keepalive);
        
        /* Publisher settings */
        strncpy(ctx->pubTopic, DEF_PUBTOPIC, sizeof(ctx->pubTopic));
        ctx->pubQos = DEF_PUBQOS;
        ctx->interval = DEF_PUBINTERVAL;
        log_nrml("Use default publisher topic \"%s\" with Qos[%d] interval[%d]\n", ctx->pubTopic, ctx->pubQos, ctx->interval);

        /* Subscriber settings */
        strncpy(ctx->subTopic, DEF_SUBTOPIC, sizeof(ctx->subTopic));
        ctx->subQos = DEF_SUBQOS;
        log_nrml("Use default subscriber topic \"%s\" with Qos[%d]\n", ctx->subTopic, ctx->subQos);

        return 0;
    }
@@ -85,6 +100,107 @@
    log_nrml("Logger system initialise ok\n");


    /*+------------------------------------------------------+
     *|      parser hardware module configuration ID         |
     *+------------------------------------------------------+*/

    /* hardware module enable or not */
    ctx->hwconf.enable=iniparser_getint(ini, "hardware:enable", 0);
    log_nrml("Parser hardware modules [%s]\n", ctx->hwconf.enable ? "enable" : "disable");

    /* relay control light  */
    ctx->hwconf.relay_pin=iniparser_getint(ini, "hardware:relay_pin", 0);
    if( !ctx->hwconf.relay_pin )
        log_nrml("Parser relay module disabled\n");
    else
        log_nrml("Parser relay connected wPI #pin number [%d]\n", ctx->hwconf.relay_pin); 

    /* buzzer */
    ctx->hwconf.beep_pin=iniparser_getint(ini, "hardware:beep_pin", 0); 
    log_nrml("Parser buzzer connected wPI #pin number [%d]\n", ctx->hwconf.beep_pin); 

    /* Beep max. times set beep 10 */ 
    ctx->hwconf.beep_times = iniparser_getint(ini, "hardware:beep_times", 0); 
    log_nrml("Parser inbreak buzzer beep times [%d]\n", ctx->hwconf.beep_times);


    /* RGB 3-colors LED  */
    ctx->hwconf.red_pin=iniparser_getint(ini, "hardware:red_pin", 0);
    ctx->hwconf.green_pin=iniparser_getint(ini, "hardware:green_pin", 0);
    ctx->hwconf.blue_pin=iniparser_getint(ini, "hardware:blue_pin", 0);
    if( !ctx->hwconf.red_pin && !ctx->hwconf.green_pin && !ctx->hwconf.blue_pin )
    {
        ctx->hwconf.leds = 0;
        log_nrml("Parser RGB leds module disabled\n");
    }
    else
    {
        ctx->hwconf.leds = 1;
        log_nrml("Parser RGB led connected wPI #pin number [%d,%d,%d]\n", 
            ctx->hwconf.red_pin, ctx->hwconf.green_pin, ctx->hwconf.blue_pin);
    }

    /* temperature sensor ds18b20  */
    ctx->hwconf.ds18b20=iniparser_getint(ini, "hardware:ds18b20", 0);
    log_nrml("Parser temperature sensor DS18B20 modules [%s]\n", ctx->hwconf.ds18b20 ? "enable" : "disable");

    /* temperature and hummidity sensor sht2x  */
    ctx->hwconf.sht2x=iniparser_getint(ini, "hardware:sht2x", 0);
    log_nrml("Parser temperature and hummidity sensor sht2x modules [%s]\n", ctx->hwconf.sht2x ? "enable" : "disable");

    /* light intensity sensor TSL2561 */
    ctx->hwconf.lux=iniparser_getint(ini, "hardware:lux", 0);
    log_nrml("Parser light intensity sensor TSL2561 modules [%s]\n", ctx->hwconf.ds18b20 ? "enable" : "disable");

    ctx->hwconf.infrared_pin=iniparser_getint(ini, "hardware:infrared_pin", 0);
    log_nrml("Parser infrared pin connected wPI #pin number [%d]\n", ctx->hwconf.infrared_pin);

    if( ctx->hwconf.infrared_pin )
    {
        ctx->hwconf.inbreak_beep = iniparser_getint(ini, "hardware:inbreak_beep", 0); 
        log_nrml("Parser %s inbreak beep\n", ctx->hwconf.inbreak_beep? "enable" : "disable");
        if( !ctx->hwconf.beep_pin ) 
        {
            log_warn("WARNNING: beep hardware not enable and will disable inbreak beep\n");
            ctx->hwconf.inbreak_beep = 0;
        }

        ctx->hwconf.fillin_light = iniparser_getint(ini, "hardware:fillin_light", 0);
        log_nrml("Parser inbreak fill-in light mode [%d]\n", ctx->hwconf.fillin_light);

        if( !ctx->hwconf.relay_pin )
        {
            log_warn("WARNNING: Relay hardware not enable and change fill-in light mode to OFF\n");
            ctx->hwconf.fillin_light = FILLIN_LIGHT_OFF;
        }

        if( !ctx->hwconf.lux )
        {
            log_warn("WARNNING: LUX sensor hardware not enable and change fill-in light mode to ON\n");
            ctx->hwconf.fillin_light = FILLIN_LIGHT_ON;
        }

        ctx->hwconf.light_intval = iniparser_getint(ini, "hardware:light_intval", 20);
        log_nrml("Parser inbreak fill-in light interval time [%d]\n", ctx->hwconf.light_intval);

        ctx->hwconf.lux_threshold = iniparser_getdouble(ini, "hardware:lux_threshold", 0.1);
        log_nrml("Parser fill-in light threshold lux [%.03f]\n", ctx->hwconf.lux_threshold);
    }


    /*+------------------------------------------------------+
     *|               parser production ID                   |
     *+------------------------------------------------------+*/

    if( !(str=iniparser_getstring(ini, "common:id", NULL)) )
    {
        log_err("ERROR: Parser production ID failure\n");
        return -2;
    }
    /* cJSON parser ID will get ""  */
    snprintf(ctx->id, sizeof(ctx->id), "\"%s\"", str);
    log_nrml("Parser production ID [%s]\n", ctx->id);


    /*+------------------------------------------------------+
     *|              parser broker settings                  |
@@ -103,7 +219,7 @@
        return -2;
    }
    ctx->port = val;
    log_nrml("Parser and get broker server [%s:%d]\n", ctx->host, ctx->port);
    log_nrml("Parser broker server [%s:%d]\n", ctx->host, ctx->port);

    str=iniparser_getstring(ini, "broker:username", DEF_BROKER_USERNAME);
    strncpy(ctx->uid, str, sizeof(ctx->uid) );
@@ -111,10 +227,10 @@
    str=iniparser_getstring(ini, "broker:password", DEF_BROKER_PASSWD);
    strncpy(ctx->pwd, str, sizeof(ctx->pwd) );

    log_nrml("Parser and get broker author by [%s:%s]\n", ctx->uid, ctx->pwd);
    log_nrml("Parser broker author by [%s:%s]\n", ctx->uid, ctx->pwd);

    ctx->keepalive = iniparser_getint(ini, "broker:keepalive", DEF_BROKER_KEEPALIVE);
    log_nrml("Parser and get broker keepalive timeout [%d] seconds\n", ctx->keepalive);
    log_nrml("Parser broker keepalive timeout [%d] seconds\n", ctx->keepalive);

    /*+------------------------------------------------------+
     *|             parser publisher settings                |
@@ -122,11 +238,10 @@

    str=iniparser_getstring(ini, "publisher:pubTopic", DEF_PUBTOPIC);
    strncpy(ctx->pubTopic, str, sizeof(ctx->pubTopic) );
    log_nrml("Parser and get publisher topic \"%s\"\n", ctx->pubTopic);

    ctx->pubQos = iniparser_getint(ini, "publisher:pubQos", DEF_PUBQOS);
    ctx->interval = iniparser_getint(ini, "publisher:interval", DEF_PUBINTERVAL);
    log_nrml("Parser and get publisher Qos[%d] and interval [%d] seconds\n", ctx->pubQos, ctx->interval);
    log_nrml("Parser publisher topic \"%s\" with Qos[%d] interval[%d]\n", ctx->pubTopic, ctx->pubQos, ctx->interval);

    /*+------------------------------------------------------+
     *|             parser subscriber settings               |
@@ -134,10 +249,9 @@

    str=iniparser_getstring(ini, "subsciber:subTopic", DEF_SUBTOPIC);
    strncpy(ctx->subTopic, str, sizeof(ctx->subTopic) );
    log_nrml("Parser and get subscriber topic \"%s\"\n", ctx->subTopic);

    ctx->subQos = iniparser_getint(ini, "subsciber:subQos", DEF_SUBQOS);
    log_nrml("Parser and get subscriber Qos[%d]\n", ctx->subQos);
    log_nrml("Parser subscriber topic \"%s\" with Qos[%d]\n", ctx->subTopic, ctx->subQos);

    return 0;
}