[T106][ZXW-22]7520V3SCV2.01.01.02P42U09_VEC_V0.8_AP_VEC origin source commit
Change-Id: Ic6e05d89ecd62fc34f82b23dcf306c93764aec4b
diff --git a/ap/app/zte_log_agent/ap_log.c b/ap/app/zte_log_agent/ap_log.c
new file mode 100644
index 0000000..9e4da4d
--- /dev/null
+++ b/ap/app/zte_log_agent/ap_log.c
@@ -0,0 +1,184 @@
+/**
+ *
+ * @file ap_log.c
+ * @brief
+ * This file is part of ZCAT.
+ * zcatÓ¦Óòãlog_agent´¦Àílogcat_printf/logcat_printkÉ豸
+ *
+ * @details
+ * @author Tools Team.
+ * @email
+ * @copyright Copyright (C) 2013 Sanechips Technology Co., Ltd.
+ * @warning
+ * @date 2019/02/02
+ * @version 1.2
+ * @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/02/02 1.2 jiang.fenglin ÐÞ¸Ä×¢ÊÍ·½Ê½Îªdoxygen
+ * ---------------------------------------------------------------------------
+ *
+ *
+ */
+
+#include <string.h>
+#include <pthread.h>
+#include <sys/prctl.h>
+#include "log_agent.h"
+
+/*É豸·¾¶*/
+const char* kernellog_dev = "/dev/logcat_printk";
+const char* applog_dev = "/dev/logcat_printf";
+
+static BOOL g_KernelNewLine = TRUE;
+static BOOL g_AppNewLine = TRUE;
+extern int hb_flag;
+pthread_t read_kernellog_thread = 0;;
+pthread_t read_applog_thread = 0;;
+int kernellog_fd = -1;
+int applog_fd = -1;
+
+extern void zCatAgt_Ap_GetModAndPri(unsigned char **buf, unsigned short *bufLen, unsigned char *pPriority, unsigned char *pMod);
+extern BOOL zCatAgt_Ap_ReadBuffer(T_AP_SRC_BUFFER_TYPE *src, T_AP_DEST_BUFFER_TYPE *dest);
+extern unsigned int zCatAgt_Ap_SendMsg(unsigned char cmd_code, unsigned char priority, unsigned char mod, unsigned char *buf, unsigned int len);
+
+/**
+ * @brief ¶ÁÈ¡applogµÄÏ̺߳¯Êý£¬\n
+ * ´¦Àí´Óapplog_devÉ豸ÖеÄlogÊý¾Ý£¬²¢×ª·¢³öÈ¥.
+ * @param[in] args Ï̺߳¯Êý²ÎÊý
+ * @return void
+ * @note
+ * @see
+ */
+void *read_applog(void* args)
+{
+ int read_len = -1;
+ static unsigned char readApplogBuffer[4096] = {0};
+
+ prctl(PR_SET_NAME, "read_applog");
+ //printf("zcat: read_applog \n");
+ while(1)
+ {
+ if(hb_flag)
+ read_len = read(applog_fd, readApplogBuffer, sizeof(readApplogBuffer));
+ if(read_len>0)
+ {
+ T_AP_DEST_BUFFER_TYPE dest = {0};
+ T_AP_SRC_BUFFER_TYPE src = {0};
+ src.buf = readApplogBuffer;
+ src.beginIndex=0;
+ src.bufSize = read_len;
+ //printf("zcat: read_applog read_len %d \n", read_len);
+
+ while (zCatAgt_Ap_ReadBuffer(&src , &dest))
+ {
+ unsigned char *p = dest.buf;
+ unsigned short len = dest.len;
+ unsigned char priority = APP_LOG_DEFAULT_LEVEL;
+ unsigned char mod = 1;
+ static unsigned char curPriority = APP_LOG_DEFAULT_LEVEL;
+
+ if (g_AppNewLine)
+ {
+ g_AppNewLine = FALSE;
+ zCatAgt_Ap_GetModAndPri(&p, &len, &priority, &mod);
+ curPriority = priority;
+ }
+ else
+ {
+ priority = curPriority;
+ }
+ zCatAgt_Ap_SendMsg(ZCAT_AP_APP_LOG, priority, mod, p, len);
+ if (dest.newLine == 1)
+ {
+ g_AppNewLine = TRUE;
+ }
+ memset(&dest, 0, sizeof(T_AP_DEST_BUFFER_TYPE));
+ }
+ memset(readApplogBuffer, 0, sizeof(readApplogBuffer));
+ }
+ else
+ {
+ sleep(1);
+ }
+
+ }
+ return NULL;
+}
+
+
+/**
+ * @brief ¶ÁÈ¡kernellogµÄÏ̺߳¯Êý£¬\n
+ * ´¦Àí´Ókernellog_devÉ豸ÖеÄlogÊý¾Ý£¬²¢×ª·¢³öÈ¥.
+ * @param[in] args Ï̺߳¯Êý²ÎÊý
+ * @return void
+ * @note
+ * @see
+ */
+void *read_kernellog(void* args)
+{
+ int read_len = -1;
+ unsigned char readKernelLogBuffer[1024] = {0};
+
+ prctl(PR_SET_NAME, "read_kernellog");
+ //printf("read_kernellog kkkkkkkkkkkk fd %d\n", fd);
+ while(1)
+ {
+ if(hb_flag)
+ read_len = read(kernellog_fd, readKernelLogBuffer, sizeof(readKernelLogBuffer));
+ if(read_len > 0)
+ {
+ T_AP_DEST_BUFFER_TYPE dest = {0};
+ T_AP_SRC_BUFFER_TYPE src = {0};
+ src.buf = readKernelLogBuffer;
+ src.beginIndex=0;
+ src.bufSize = read_len;
+ //printf("read_kernellog read_len %d \n", read_len);
+ //CHAR atCmd[200] = {0};
+ //g_cp_log_count++;
+ //sprintf(atCmd, " /sbin/atlog.sh \"%s\" \"%s\" \"%s\",\"%d\",\"%d\"", "send",zte_time(),"wubo deal_with_kernellog_from_devkkkkkkkk", read_len, 0);
+ //system(atCmd);
+ while (zCatAgt_Ap_ReadBuffer(&src , &dest))
+ {
+ unsigned char *p = dest.buf;
+ unsigned short len = dest.len;
+ unsigned char priority = KERNEL_LOG_DEFAULT_LEVEL;
+ unsigned char mod = 1;
+ static unsigned char curPriority = KERNEL_LOG_DEFAULT_LEVEL;
+
+ if (g_KernelNewLine)
+ {
+ g_KernelNewLine = FALSE;
+ zCatAgt_Ap_GetModAndPri(&p, &len, &priority, &mod);
+ curPriority = priority;
+ }
+ else
+ {
+ priority = curPriority;
+ }
+ zCatAgt_Ap_SendMsg(ZCAT_AP_KERNEL_LOG, priority, mod, p, len);
+
+ if (dest.newLine == 1)
+ {
+ g_AppNewLine = TRUE;
+ }
+
+ memset(&dest, 0, sizeof(T_AP_DEST_BUFFER_TYPE));
+ }
+ memset(readKernelLogBuffer, 0, sizeof(readKernelLogBuffer));
+ }
+ else
+ {
+ sleep(1);
+ }
+ }
+}
+