Add toolchain and mbtk source
Change-Id: Ie12546301367ea59240bf23d5e184ad7e36e40b3
diff --git a/mbtk/mbtk_logd/common_read.c b/mbtk/mbtk_logd/common_read.c
new file mode 100755
index 0000000..90f2f7f
--- /dev/null
+++ b/mbtk/mbtk_logd/common_read.c
@@ -0,0 +1,146 @@
+#include <stdio.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <netdb.h>
+#include <arpa/inet.h>
+#include <fcntl.h>
+#include <time.h>
+#include <unistd.h>
+#include <errno.h>
+#include "log_config.h"
+
+#define ALOG_DEV "/dev/log_radio"
+
+static const char *log_file, *log_ip, *log_port, *log_prefix, *pid_file, *hostname;
+static int log_size = 1 * 1024 * 1024;
+
+static log_config_entry *config = NULL;
+static char tmp_log[48] = {0};
+
+
+static int fileter_log(int pri, char *tag, struct filter_list_t *filter)
+{
+ struct filter_list_t *_filter = filter;
+
+ while(_filter)
+ {
+ // _filter->priority
+ // 获取 筛选的等级 p
+ int p = 0;
+ if(_filter->tag)
+ {
+ int len = strlen(_filter->tag);
+ // tag and priority
+ if(0 == memcmp(_filter->tag, tag, len) && ((pri > p) || (pri == p)))
+ return 0;
+ }else{ // have no tag
+ if(pri < p)
+ return -1;
+ else
+ return 0;
+ }
+ _filter = _filter->next;
+ }
+
+ return -1;
+}
+
+int common_log_print(
+ int fd,
+ struct file_list_t *_file_list,
+ char *entry)
+{
+ char priChar;
+ char timeBuf[32];
+ char defaultBuffer[512];
+ size_t totalLen;
+ int fd_new = fd;
+ struct stat s;
+ time_t timetemp; // 定义一个时间结构体变量
+ char * ret = NULL;
+
+ if (log_size && (!stat(tmp_log, &s)) && (s.st_size > log_size)) {
+ fd_new = get_rotate_file(fd_new, log_file, _file_list);
+ if (fd_new < 0) {
+ fprintf(stderr, "failed to open %s: %s\n", log_file, strerror(errno));
+ exit(-1);
+ }
+ }
+
+ // if(fileter_log(entry->priority, entry->tag, config->filter_list))
+ // {
+ // printf("%s %d: fileter pri:%d tag:%s!\n", __FUNCTION__, __LINE__, entry->priority, entry->tag);
+ // return -1;
+ // }
+ time(&timetemp); // 获得时间参数
+ struct tm* ptm = localtime(&timetemp);
+ strftime(timeBuf, sizeof(timeBuf), "%Y-%m-%d %H:%M:%S", ptm);
+
+ totalLen = snprintf(defaultBuffer, sizeof(defaultBuffer),
+ "%s : %s\n", timeBuf, entry);
+
+ ret = write(fd_new, defaultBuffer, totalLen);
+
+ return ret;
+}
+
+void* common_log_thread(void* argv)
+{
+ int dev_fd, ret;
+ int log_fd;
+ char buf[512] = {0};
+ static struct file_list_t file_list;
+ config = (log_config_entry *)argv;
+
+ pthread_detach(pthread_self());
+ if (NULL == argv || NULL == config->name)
+ return NULL;
+
+ dev_fd = open(config->name, O_RDONLY, 0600);
+ if (dev_fd < 0) {
+ fprintf(stderr, "failed to open %s: %s\n", config->name, strerror(errno));
+ exit(-1);
+ }
+
+ memset(&file_list, 0, sizeof(struct file_list_t));
+ file_list.total = config->rotate_file_count;
+ log_file = config->out_path;
+
+ if (config->ip && config->port) {
+ int port = atoi(config->port);
+ printf("%s %d : %s:%s\n", __FUNCTION__, __LINE__, config->ip, config->port);
+ log_fd = tcp_connect(config->ip, port);
+ } else if (log_file) {
+ sprintf(tmp_log, "/tmp/log%s", strstr_tail(log_file, "/"));
+ // 先将文件保存到 /tmp/log/ 目录下，后面到达 rotate_file_size 后，转移到out_path
+ log_fd = open(tmp_log, O_CREAT | O_WRONLY| O_APPEND, 0600);
+ if (log_fd < 0) {
+ fprintf(stderr, "failed to open %s: %s\n", tmp_log, strerror(errno));
+ exit(-1);
+ }
+ } else {
+ log_fd = STDOUT_FILENO;
+ }
+ if(config->rotate_file_size)
+ log_size = config->rotate_file_size;
+
+ printf("uart log start...\n");
+ while (1) {
+ ret = read(dev_fd, buf, sizeof(buf));
+ if (ret < 0) {
+ printf("read error\n");
+ break;
+ }
+ // common_log_process(buf, ret, &entry);
+ common_log_print(log_fd, &file_list, buf);
+ memset(buf, 0, sizeof(buf));
+ }
+ close(dev_fd);
+ close(log_fd);
+
+ printf("%s exit \n", __FUNCTION__);
+ pthread_exit(NULL);
+ return NULL;
+}