ap/app/zte_log_agent/log_agent_usblog.c

/**
 * 
 * @file      log_agent_usblog.c
 * @brief     
 *            This file is part of ZCAT.
 *            zcatÓ¦Óòãlog_agent´¦Àíͨ¹ýusbµÄÊý¾ÝÁ÷
 *            
 * @details   
 * @author    Tools Team.
 * @email     
 * @copyright Copyright (C) 2013 Sanechips Technology Co., Ltd.
 * @warning   
 * @date      2019/02/22
 * @version   1.4
 * @pre       
 * @post      
 *            
 * @par       
 * Change History :
 * ---------------------------------------------------------------------------
 * date        version  author         description
 * ---------------------------------------------------------------------------
 * 2017/07/17  1.0      hou.bing       Create file
 * 2019/01/24  1.1      jiang.fenglin  1.Ìí¼Óusblog¶ÁдËø
 *                                     2.Ìí¼ÓÏß³ÌÃû³Æ
 * 2019/01/25  1.2      jiang.fenglin  Ôö¼ÓAPUSBģʽÏÂtty·¾¶ÅäÖù¦ÄÜ
 * 2019/02/02  1.3      jiang.fenglin  ÐÞ¸Ä×¢ÊÍ·½Ê½Îªdoxygen
 * 2019/02/22  1.4      jiang.fenglin  ¶¯Ì¬¿ÉÅäÖÃLOG¶Ë¿Ú,log¶Ë¿Ú¶¯Ì¬ÅäÖÃÖ»Õë¶ÔusbÅäÖÃΪÕý³£Ä£Ê½µÄÇé¿ö£¬¹¤³§Ä£Ê½±£³Ö²»±ä
 * ---------------------------------------------------------------------------
 * 
 * 
 */

#include <unistd.h>
#include <pthread.h>
#include <stdio.h>
#include <string.h>
#include <sys/prctl.h>
#include "cfg_api.h"
#include "log_agent.h"
#include "port_com.h"


#define ZCAT_FACTORY_PATH "/sys/devices/virtual/android_usb/android0/f_acm/instances"
#define ZCAT_DEFAULT_TTY  "ttyGS2"
char g_zcat_usblog[8] = { 't', 't', 'y', 'G', 'S', '2' };

int usblog_fd = -1;
pthread_t read_usb_thread = 0;
unsigned char g_UsbLogBuf[2048 + 1] = { 0 };
const struct timespec notimer_interval = {0, 300000}; // 20ms
pthread_rwlock_t usblog_rwlock = PTHREAD_RWLOCK_INITIALIZER;

extern int send_log_to_cp(unsigned char *buf, int len);
extern int deal_with_encoded_data(unsigned char *buffer, int buf_len);
extern int init_monitor_hotplug();
extern int hb_flag;

/**
 * @brief ·¢ËÍÊý¾Ýµ½usbµÄlog¿Ú
 * @param[in] buf ´ý·¢Ë͵ÄÊý¾Ý»º´æÖ¸Õë
 * @param[in] len ´ý·¢Ë͵ÄÊý¾Ý³¤¶È
 * @return void
 * @note
 * @see 
 */
int send_message_to_usblog(unsigned char* buf, int len)
{
    int write_len = 0;  
    int i = 0;
    int ret = -1;

    if ( buf && len )
    {
        for(i = 0; i < 100; i++)
        {
            pthread_rwlock_rdlock(&usblog_rwlock);
            if ( usblog_fd >= 0 )
            {
                write_len = write(usblog_fd, buf, len);
            }
            pthread_rwlock_unlock(&usblog_rwlock);

            //printf("send_message_to_usblog %8d,%8d\n", len, write_len);

            if ( write_len == len )
            {
                ret = 0;
                break;
            }
            else if( write_len )
            {
                len -= write_len;
            }
            else
            {
                nanosleep(&notimer_interval, NULL);
            }
        }
    }
    
    return ret;
}

/**
 * @brief ÐÄÌø°üºÍ¹æÔòÎļþ´¦ÀíÏ̺߳¯Êý£¬\n
 *        ½ÓÊÕpc´«Ë͵½ueµÄÊý¾Ý£¬×ª·¢¸ø¹æÔò´¦ÀíºÍÐÄÌø¼à²â
 * @param[in] args Ï̺߳¯Êý²ÎÊý
 * @return void
 * @note
 * @see 
 */
static void *read_usblog(void *args)
{
    unsigned char *pbuf = NULL;
    int read_len = 0;
    
    pbuf = g_UsbLogBuf;
	/*
    if(pbuf == NULL)
    {
        printf("[zcat] read_usblog fail.\n");
        return NULL;
    }*/

    prctl(PR_SET_NAME, "read_usblog");
    
    while(1)
    {
        pthread_rwlock_rdlock(&usblog_rwlock);
        if( usblog_fd >= 0)
        {
            read_len = read(usblog_fd, pbuf, 2*1024);
        }
        pthread_rwlock_unlock(&usblog_rwlock);

        if(read_len > 0)
        {
            //printf("[zcat] read_usblog %d bytes\n",read_len);
            send_log_to_cp(pbuf, read_len); // Ïòcp·¢Ë͹æÔò
            deal_with_encoded_data(pbuf, read_len); // Ïòap·¢Ë͹æÔò
        }

        if( usblog_fd < 0 || read_len <= 0 )
        {
            //printf("[zcat] read_usblog sleep 2\n");
            sleep(2);
        }
    }

    return NULL;
}


/**
 * @brief »ñÈ¡Îļþ´óС
 * @param[in] fp ÊäÈëÎļþÖ¸Õë
 * @return Îļþ´óС£¬µ¥Î»×Ö½Ú
 * @note
 * @see 
 */
int filelength(FILE *fp)
{
    int num;
    fseek(fp, 0, SEEK_END);
    num = ftell(fp);
    fseek(fp, 0, SEEK_SET);
    return num;
}

/**
 * @brief ¶ÁÈ¡ÎļþÄÚÈÝ
 * @param[in] path ÊäÈëÎļþ·¾¶
 * @param[out] buf »º´æÖ¸Õë
 * @param[in] len »º´æµÄ¿Õ¼ä´óС
 * @return Îļþʵ¼Ê´óС£¬µ¥Î»×Ö½Ú
 * @note
 * @see 
 */
static int readfile(char *path, char* buf, unsigned len)
{
    FILE *fp;
    int length;
    if((fp = fopen(path, "r")) == NULL)
    {
        printf("[zcat] open file %s error.\n", path);
        return -1;
    }
    length = filelength(fp);
    length = length > len ? len : length;
    //ch=(char *)malloc(length+1);
    fread(buf, (unsigned int)length, 1, fp);
    fclose(fp);
    *(buf + length) = '\0';
    return length;
}

/**
 * @brief ÅжÏÊÇ·ñΪ¹¤³§Ä£Ê½
 * @param[in] void
 * @return 1 - ¹¤³§Ä£Ê½£¬0 - Õý³£Ä£Ê½
 * @note
 * @see 
 */
static int is_factory_mode()
{
    char buf[2] = { 0 };
    int itemp;
    
    readfile(ZCAT_FACTORY_PATH, buf, 1);

    itemp = atoi(buf);
    printf("[zcat] ZCAT_FACTORY_PATH : %d\n", itemp);

    if(itemp == 2)
        return 1;
    else
        return 0;
}

#if 0
/**
 * @brief дÎļþÄÚÈÝ
 * @param[in] path ÊäÈëÎļþ·¾¶
 * @param[in] buf »º´æÖ¸Õë
 * @param[in] len »º´æµÄ¿Õ¼ä´óС
 * @return ʵ¼ÊдÈëµÄ³¤¶È£¬µ¥Î»×Ö½Ú
 * @note
 * @see 
 */
static int writefile(char*path, char*buf, unsigned len)
{
    FILE *fp;
    int rtv;
    
    if((fp = fopen(path, "w")) == NULL)
    {
        printf("[zcat] open file %s error.\n", path);
        return -1;
    }
    rtv = fwrite(buf, len, 1, fp);
    fclose(fp);
    return rtv;
}
#endif

/**
 * @brief »ñÈ¡usblogµÄtty·¾¶
 * @param[in] void
 * @return void
 * @note
 * @see 
 */
void get_usblog_tty_path()
{
    int isFactory = is_factory_mode();
    
    memset(g_zcat_usblog, 0, sizeof(g_zcat_usblog));
    
    if(isFactory)
    {
        sprintf(g_zcat_usblog, ZCAT_DEFAULT_TTY);
        g_zcat_usblog[5] = '1'; // ¹¤³§Ä£Ê½ÏÂlog¿Ú¹Ì¶¨ÎªttyGS1£¬°´ÐèÇó²»Ö¸¶¨
    }
    else
    {
        // Èç¹ûÉèÖÃÁËtty·¾¶£¬ÔòʹÓÃÉèÖõÄ·¾¶£¬·ñÔòʹÓÃĬÈϵÄ
        cfg_get_item("zcat_usblog", g_zcat_usblog, sizeof(g_zcat_usblog) - 1);
        if (strlen(g_zcat_usblog) < 3)
        {
            sprintf(g_zcat_usblog, ZCAT_DEFAULT_TTY);
        }
    }
}

/**
 * @brief ¹Ø±ÕusbÉ豸
 * @param[in] void
 * @return 0 on success, errno otherwise
 * @note
 * @see 
 */
int close_usblog()
{
    int ret = -1;

    pthread_rwlock_wrlock(&usblog_rwlock); // дËø£¬¹Ø±Õ¶Ë¿Ú¹ý³ÌÖв»ÔÊÐí¶Áд
    if(usblog_fd >= 0)
    {
        ret = close(usblog_fd);
        if (ret < 0)
        {
            printf("[zcat] close usblog_dev faild, ret = %d, error = %s\n", ret, strerror(errno));
			pthread_rwlock_unlock(&usblog_rwlock);
            return ret;  
        }
        else
        {
            usblog_fd = -1;
        }
    }
    pthread_rwlock_unlock(&usblog_rwlock);
    
    return 0;
}

/**
 * @brief ´ò¿ªusbÉ豸
 * @param[in] void
 * @return ·µ»ØÉ豸ÃèÊö·û
 * @note
 * @see 
 */
int open_usblog()
{
    int fd = -1;
    char usblog_dev[16] = { 0 };

    if ( usblog_fd >= 0 ) {
        close_usblog();
    }

    sprintf(usblog_dev, "/dev/%s", g_zcat_usblog);
    
    fd = open(usblog_dev, O_RDWR);
    if ( fd < 0 )
    {
        printf("[zcat] open %s error!\n", usblog_dev);
        return -1;
    }
    printf("[zcat] open %s\n", usblog_dev);
    
    usblog_fd = fd;
    
    PortSet(fd);

    return fd;
}

/**
 * @brief ³õʼ»¯usbģʽ£¬\n
 *        ¶ÁÈ¡usbÐéÄâµÄtty·¾¶.
 *        ´ò¿ªtty£¬¶ÁÈ¡pc²à·¢¹ýÀ´µÄÐÄÌø°ü¡¢¹æÔòÎļþµÈÊý¾Ý
 *        ´´½¨usbÈȲå°Î¼à²âÏß³Ì
 * @param[in] void
 * @return 0 on success, errno otherwise
 * @note
 * @see 
 */
int init_usblog_mode()
{
    int ret = 0;

    ret = pthread_rwlock_init(&usblog_rwlock, NULL);
    if(ret)
    {
        printf("[zcat] usblog_rwlock init error.\n"); 
        return -1;
    }
    else
    {
        ret = init_monitor_hotplug();
        if(ret < 0)
        {
            printf("[zcat] init_monitor_hotplug error.\n"); 
            goto __exit;
        }

        ret = pthread_create(&read_usb_thread, NULL, read_usblog, NULL);
        if(ret != 0)
        {   
            printf("[zcat] create read_usb_thread error.\n");
            goto __exit;
        }
        return ret;
    __exit:
        pthread_rwlock_destroy(&usblog_rwlock);
        return ret;
    }
}