update mqttd hal code, instead printf by logger system

guowenxue

2019-06-26 ffa48d2a646d1deb92eaf4e13ed17d5da9bfda65

update mqttd hal code, instead printf by logger system

 mqttd/hal/beep.c

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

#include <wiringPi.h>
#include "lylib/logger.h"
#include "beep.h"

/*+-----------------------------+
@@ -47,7 +48,7 @@

        if(freq<2000 || freq>5000)
        {
            printf("Beep set invalid PWM frequency[%d]!\n", freq);
            log_err("Beep set invalid PWM frequency[%d]!\n", freq);
            return -1;
        }


 mqttd/hal/ds18b20.c

@@ -20,6 +20,8 @@
#include <time.h>
#include <errno.h>

#include "lylib/logger.h"

/* File Content:
   pi@raspberrypi:~/guowenxue $ cat /sys/bus/w1/devices/28-041731f7c0ff/w1_slave 
   3a 01 4b 46 7f ff 0c 10 a5 : crc=a5 YES
@@ -48,7 +50,7 @@
     *+-------------------------------------------------------------------+*/
    if((dirp = opendir(w1_path)) == NULL)
    {
        printf("opendir error: %s\n", strerror(errno));
        log_err("opendir '%s' error: %s\n", w1_path, strerror(errno));
        return -2;
    }

@@ -66,7 +68,7 @@

    if( !found )
    {
            printf("Can not find ds18b20 in %s\n", w1_path);
            log_fatal("Can not find ds18b20 in %s\n", w1_path);
            return -3;
    }

@@ -77,20 +79,20 @@
    /* open file /sys/bus/w1/devices/28-xxxx/w1_slave to get temperature */
    if( (fd=open(w1_path, O_RDONLY)) < 0 ) 
    { 
            printf("open %s error: %s\n", w1_path, strerror(errno)); 
            log_err("open %s error: %s\n", w1_path, strerror(errno)); 
            return -4;
    } 
    
    if(read(fd, buf, sizeof(buf)) < 0)
    {
            printf("read %s error: %s\n", w1_path, strerror(errno)); 
            log_err("read %s error: %s\n", w1_path, strerror(errno)); 
            return -5;
    } 
    
    ptr = strstr(buf, "t=");
    if( !ptr )
    {
            printf("ERROR: Can not get temperature\n");
            log_err("ERROR: Can not get temperature\n");
            return -6;
    }


 mqttd/hal/sht20.c

@@ -29,6 +29,7 @@
#include <string.h>

#include "sht20.h"
#include "lylib/logger.h"

static int s_sht2x_fd = -1;

@@ -36,7 +37,7 @@
{
    close(s_sht2x_fd);
    s_sht2x_fd = -1;
    printf("Terminate SHT2X\n");
    log_warn("Terminate SHT2X\n");
}

#ifdef I2C_API_RDWR  /* Use I2C userspace driver read/write API */
@@ -47,7 +48,7 @@

    if( fd<0 )
    {
        printf("%s line [%d] %s() get invalid input arguments\n", __FILE__, __LINE__, __func__ );
        log_err("Invalid input arguments\n");
        return -1;
    }

@@ -67,7 +68,7 @@
    
    if( (s_sht2x_fd=open("/dev/i2c-1", O_RDWR)) < 0)
    {
        printf("i2c device open failed: %s\n", strerror(errno));
        log_fatal("i2c device open failed: %s\n", strerror(errno));
        return -1;
    }
    
@@ -77,7 +78,7 @@

    if( sht2x_softreset(s_sht2x_fd) < 0 )
    {
        printf("SHT2x softreset failure\n");
        log_err("SHT2x softreset failure\n");
        sht2x_term();
        return -2;
    }
@@ -91,7 +92,7 @@

    if( !temp || !rh )
    {
        printf("%s line [%d] %s() get invalid input arguments\n", __FILE__, __LINE__, __func__ );
        log_err("Invalid input arguments\n");
        return -1;
    }

@@ -99,7 +100,7 @@
    {
        if( sht2x_init() < 0)
        {
            printf("SHT2x initialise failure\n");
            log_err("SHT2x initialise failure\n");
            return -2;
        }
    }
@@ -137,7 +138,7 @@

    if( !serialnumber || size!=8 )
    {
        printf("%s line [%d] %s() get invalid input arguments\n", __FILE__, __LINE__, __func__ );
        log_err("Invalid input arguments\n");
        return -1;
    }

@@ -145,7 +146,7 @@
    {
        if( sht2x_init() < 0)
        {
            printf("SHT2x initialise failure\n");
            log_err("SHT2x initialise failure\n");
            return -2;
        }
    }
@@ -193,7 +194,7 @@

    if( fd<0 )
    {
        printf("%s line [%d] %s() get invalid input arguments\n", __FILE__, __LINE__, __func__ );
        log_err("Invalid input arguments\n");
        return -1;
    }

@@ -208,7 +209,7 @@

    if( ioctl(fd, I2C_RDWR, &sht2x_data) < 0 )
    {
        printf("%s() ioctl failure: %s\n", __func__, strerror(errno));
        log_err("sht2x I2C_RDWR ioctl failure: %s\n", strerror(errno));
        sht2x_term();
        return -2;
    }
@@ -223,13 +224,13 @@
{
    if( (s_sht2x_fd=open("/dev/i2c-1", O_RDWR)) < 0)
    {
        printf("i2c device open failed: %s\n", strerror(errno));
               return -1;
        log_err("i2c device open failed: %s\n", strerror(errno));
        return -1;
    }

    if( sht2x_softreset(s_sht2x_fd) < 0 )
    {
        printf("SHT2x softreset failure\n");
        log_err("SHT2x softreset failure\n");
        sht2x_term();
        return -2;
    }
@@ -246,7 +247,7 @@

    if( !serialnumber || size!=8 )
    {
        printf("%s line [%d] %s() get invalid input arguments\n", __FILE__, __LINE__, __func__ );
        log_err("Invalid input arguments\n");
        return -1;
    }

@@ -254,7 +255,7 @@
    {
        if( sht2x_init() < 0)
        {
            printf("SHT2x initialise failure\n");
            log_err("SHT2x initialise failure\n");
            return -2;
        }
    }
@@ -280,7 +281,7 @@

    if( ioctl(s_sht2x_fd, I2C_RDWR, &sht2x_data) < 0 )
    {
        printf("%s() ioctl failure: %s\n", __func__, strerror(errno));
        log_err("sht2x I2C_RDWR ioctl failure: %s\n", strerror(errno));
        sht2x_term();
        return -2;
    }
@@ -312,7 +313,7 @@

    if( ioctl(s_sht2x_fd, I2C_RDWR, &sht2x_data) < 0 )
    {
        printf("%s() ioctl failure: %s\n", __func__, strerror(errno));
        log_err("sht2x I2C_RDWR ioctl failure: %s\n", strerror(errno));
        sht2x_term();
        return -2;
    }
@@ -336,7 +337,7 @@

    if( !temp || !rh )
    {
        printf("%s line [%d] %s() get invalid input arguments\n", __FILE__, __LINE__, __func__ );
        log_err("Invalid input arguments\n");
        return -1;
    }

@@ -344,7 +345,7 @@
    {
        if( sht2x_init() < 0)
        {
            printf("SHT2x initialise failure\n");
            log_err("SHT2x initialise failure\n");
            return -2;
        }
    }
@@ -364,7 +365,7 @@

    if( ioctl(s_sht2x_fd, I2C_RDWR, &sht2x_data) < 0 )
    {
        printf("%s() ioctl failure: %s\n", __func__, strerror(errno));
        log_err("sht2x I2C_RDWR ioctl failure: %s\n", strerror(errno));
        sht2x_term();
        return -2;
    }
@@ -382,7 +383,7 @@

    if( ioctl(s_sht2x_fd, I2C_RDWR, &sht2x_data) < 0 )
    {
        printf("%s() ioctl failure: %s\n", __func__, strerror(errno));
        log_err("sht2x I2C_RDWR ioctl failure: %s\n", strerror(errno));
        sht2x_term();
        return -2;
    }
@@ -406,7 +407,7 @@

    if( ioctl(s_sht2x_fd, I2C_RDWR, &sht2x_data) < 0 )
    {
        printf("%s() ioctl failure: %s\n", __func__, strerror(errno));
        log_err("sht2x I2C_RDWR ioctl failure: %s\n", strerror(errno));
        sht2x_term();
        return -2;
    }
@@ -424,7 +425,7 @@

    if( ioctl(s_sht2x_fd, I2C_RDWR, &sht2x_data) < 0 )
    {
        printf("%s() ioctl failure: %s\n", __func__, strerror(errno));
        log_err("sht2x I2C_RDWR ioctl failure: %s\n", strerror(errno));
        sht2x_term();
        return -2;
    }