更新 README.md

Signed-off-by: jianf <2198972886@qq.com>

c/config.h

@@ -1,14 +1,13 @@
 #ifndef SEVERCONFG
 #define SEVERCONFG
 
-#define MAX_LOG 64
+#define MAX_LOG 256 
-#define MAX_LOG_LENGTH 4096
 
 #define TEM_MAX_BUF 256
 #define TEM_HISTORY_BUF 210
 #define TEM_PROMPT "chatbot$$ "
 
-#define NET_MAX_POOL 1
+#define NET_MAX_POOL 10
 #define NET_MAX_MESSAGE_BUF 1024
 #define HTTP_BLOCK_SIZE 512
 #define MAX_HTTP_LENGTH 20

c/interpreter/interpreter.c

@@ -139,7 +139,7 @@ int match_cmd(const Cmd* cmd_dic,char *cmd_buf)
 }
 
 
-int exec(const int command,ctx *all_ctx)
+int exce(const int command,ctx *all_ctx)
 {
 
     switch (command)
@@ -202,7 +202,7 @@ int interpret(int mod, ctx *all_ctx,Cmd *cmd_dic)
         if(cmd_buf[len-1] == '\n')
             cmd_buf[len-1] = '\0';
         //执行命令
-        exec(match_cmd(cmd_dic, cmd_buf),all_ctx);
+        exce(match_cmd(cmd_dic, cmd_buf),all_ctx);
 
         //释放所有堆内存
         free(cmd_buf);

c/main.c

@@ -34,9 +34,8 @@ int main()
     int port = (int)toml_int_in(server,"list_port").u.i;
     //加载配置文件，读取端口
     log_manager *logsmanager=(log_manager*)malloc(sizeof(log_manager));
-    //创建日志管理器与定时清理线层
     init_loger(logsmanager);
-    pthread_create(&logsmanager->pid,NULL,logsmanager->clear_log,logsmanager);
+
     Ctl *teml = init_tem(logsmanager);
     teml->config = server;
     //初始化终端对象
@@ -46,8 +45,8 @@ int main()
     netm *networkmanager = (netm*)malloc(sizeof(netm));
     init_networkmanager(networkmanager,fifo,logsmanager,port);
     //初始化网络管理器对象
-
+    pthread_t network_id;
-    pthread_create(&networkmanager->pid,NULL,networkmanager->run_network,(void*)networkmanager);
+    pthread_create(&network_id,NULL,networkmanager->run_network,(void*)networkmanager);
     //启动网络监听与线程池，并加载插件
     alres *resource = (alres*)malloc(sizeof(alres));
     resource->loger = logsmanager;
@@ -58,13 +57,8 @@ int main()
     teml->run(teml,fifo);
     
     //启动终端
-    log_manager_stop(logsmanager);
+    pthread_join(network_id,NULL);
-    pthread_join(logsmanager->pid,NULL);
-    logsmanager->pid = -1;
-    
     //等待网络管理器进程结束
-    pthread_join(networkmanager->pid,NULL);
-    close(fifo[1]);
     return 1;
 
 }

c/network/network.c

@@ -243,6 +243,7 @@ int server_run(int port,int fifo_fd,netm *self)
     {
         /*工作循环-----------------------------*/
         int nf = epoll_wait(epfd,events,10,-1);
+        printf("%d\n",nf);
         if (nf == -1) { 
                 perror("epoll_wait"); 
                 break; 
@@ -258,44 +259,22 @@ int server_run(int port,int fifo_fd,netm *self)
                 sprintf(iss_buf,"s/%d/e",nt_fd);
                 self->iss_work(self,iss_buf);
             }
-            if(events[i].data.fd == fifo_fd) {
+            if(events[i].data.fd == fifo_fd)
-                char buffer[256];
+            {
-                ssize_t bytes_read;
+                char command;
-                
+                while(read(fifo_fd,&command,1)==1)
-                // 一次性读取所有可用数据
+                {
-                bytes_read = read(fifo_fd, buffer, sizeof(buffer));
+                    switch(command){
-                
-                if (bytes_read > 0) {
-                    printf("DEBUG: Read %zd bytes from pipe: ", bytes_read);
-                    for (int j = 0; j < bytes_read; j++) {
-                        printf("%c ", buffer[j]);
-                    }
-                    printf("\n");
-                    
-                    // 处理每个命令（按接收顺序）
-                    for (int j = 0; j < bytes_read; j++) {
-                        printf("Processing command[%d]: %c\n", j, buffer[j]);
-                        
-                        switch(buffer[j]) {
                         case 'q':
-                                printf("Quit command found at position %d\n", j);
+                        //退出逻辑
                             quit_server(self);
-                                return 1;  // 立即退出，不处理后续命令
+                            return 1;
-                            case 'u':
+                            break;
-                                printf("Update command\n");
+                        case 'u':
-                                // 更新逻辑
+                        //插件更新逻辑
                             break;
-                            default:
-                                printf("Unknown command: %c (ASCII: %d)\n", 
-                                    buffer[j], buffer[j]);
                     }
                 }
-                } else if (bytes_read == 0) {
-                    printf("Pipe closed by writer\n");
-                    close(fifo_fd);
-                } else if (errno != EAGAIN && errno != EWOULDBLOCK) {
-                    perror("Error reading from pipe");
-                }
             }
         }
         /*工作循环----------------------------*/

c/network/network.h

@@ -29,7 +29,6 @@ typedef struct network_manager//网络管理器
     int (*iss_work)(struct network_manager*,char *);
     
     int fifo_fd[2];
-    pthread_t pid;
     log_manager *logmanager;
     indiector *err_indictor; 
     int last_alc;

c/tem/ctl.c

@@ -241,7 +241,9 @@ int teml(Ctl *self,int fifo[2])
     char input[TEM_MAX_BUF] = {'\0'};
     ctx *command = (ctx*)malloc(sizeof(ctx));
     Cmd cmd_dir[10];
-    init_interpreter(cmd_dir,command,fifo,self->logmanager);
+    init_interpreter(cmd_dir,command,fifo,self->logmanager);//初始化解释器
+    //创建线程用于定期清理日志
+    pthread_create(&self->logwathcher,NULL,self->logmanager->clear_log,self->logmanager);
     command->statue = 0;
     self->command = command;
     do
@@ -260,6 +262,12 @@ int teml(Ctl *self,int fifo[2])
         const char fexp[256] = {'\0'};
         memcpy(&input,&fexp,TEM_MAX_BUF);
     }while(command->statue == 0);
+    log_manager_stop(self->logmanager);
+    pthread_join(self->logwathcher,NULL);
+    //关闭log定期清理程序
+    close(fifo[0]);
+
+    close(fifo[1]);
     free_history(self);
     self->command = NULL;
     free(command);

c/tem/ctl.h

@@ -15,6 +15,7 @@ typedef struct Ctl
     int (*infifo)(struct Ctl*,const char*);
     int index;
     char *history[TEM_HISTORY_BUF];
+    pthread_t logwathcher;
     log_manager *logmanager;
     ctx *command;//解释器上下文
     toml_table_t *config;

c/tools/log/log.c

@@ -11,22 +11,18 @@
 
 int in_log(logs *log,log_manager *self)
 {
-    if(log == NULL||self == NULL)
-        return -1;
-    log->log[MAX_LOG_LENGTH-1] = '\0';
     sem_wait(&self->log_sem);//加锁
+    logs *buf = self->rear;
     if(self->log == NULL){
         self->log = log;
         self->rear = log;
         self->count++;
         sem_post(&self->log_sem);
-        return self->count;
+        return 0;
     }
-    if(self->count == 1)
-        self->log->next = log;
     self->count++;
+    buf->next = log;
     log->next = NULL;
-    self->rear->next = log;
     self->rear = log;
     sem_post(&self->log_sem);
     return self->count;
@@ -34,19 +30,15 @@ int in_log(logs *log,log_manager *self)
 
 logs *out_log(log_manager *self)
 {
-    if(self == NULL)
-        return NULL;
     sem_wait(&self->log_sem);
     logs *buf = self->log;
-    if(buf==NULL)
+    if(self->log==NULL)
     {
         sem_post(&self->log_sem);
         return NULL;
     }
     if(self->log->next ==NULL)
         self->log = self->rear = NULL;
-    else
-        self->log = self->log->next;
     self->count--;
     sem_post(&self->log_sem);
     buf->next =NULL;
@@ -98,105 +90,28 @@ int cleanup(log_manager *self)
 
     sem_post(&self->log_sem);
     //释放信号量
-    
+    int fd = open("log.txt",O_CREAT | O_WRONLY | O_APPEND, 0777);
-    char *logbuf;
-    void *logbufbk;
-    char failback[MAX_LOG_LENGTH];
-    logbuf = (char*)malloc(1);
-    logbuf[0] = '\0';
-    size_t buf_length,buf_lengthbk = 0;
     while(loc->next !=NULL)
     {
         tobeclean = loc;
         loc = loc->next;
-        if(logbuf != failback){
+        if(fd == -1)
-            logbufbk = logbuf;
+            perror("file:");
-            logbuf = (char*)realloc(logbuf,strlen(logbuf)+strlen(tobeclean->log)+1);//为日志分配新的内存
+        write(fd,tobeclean->log,strlen(tobeclean->log));
-        }
-        if(logbuf == NULL){
-            free(logbufbk);
-            logbuf = failback;//降级策略，堆空间不足时，使用预分配栈空间，保留最后一条日志
-        }
-        if(logbuf != failback){
-            buf_lengthbk = buf_length;
-            buf_length = strlen(logbuf)+strlen(tobeclean->log);
-            strcpy(logbuf+buf_lengthbk,tobeclean->log);
-        }
-        else
-        {
-            buf_length = MAX_LOG_LENGTH;
-        }
         free(tobeclean);
     }
-    int fd = open("log.txt",O_CREAT | O_WRONLY | O_APPEND, 0644);
-    if(fd == -1){
-        perror("file:");
-        free(loc);
-        if(logbuf != failback)
-            free(logbuf);
-        return -1;
-    }
-    if(logbuf != failback){
-        logbufbk = logbuf; 
-        logbuf = (char*)realloc(logbuf,strlen(logbuf)+strlen(loc->log)+2);
-        if(logbuf == NULL)
-        {
-            free(logbufbk);
-            logbuf = failback;
-            strcpy(logbuf,loc->log);
-            buf_length = strlen(loc->log);
-            
-        }
-        else{
-        buf_lengthbk = buf_length;
-        buf_length = strlen(logbuf)+strlen(loc->log);
-        strcpy(logbuf+buf_lengthbk,loc->log);
-        }
-    }
-    else{
-        strcpy(logbuf,loc->log);
-        buf_length = strlen(logbuf);
-    }
-    if(logbuf == failback&&buf_length>MAX_LOG_LENGTH)
-        logbuf[MAX_LOG_LENGTH-1] = '\0';
-    else{
-        logbuf[buf_length] = '\0';
-    }
-    free(loc);
-    int error_buf = write(fd,logbuf,strlen(logbuf));
-    if(error_buf==-1){
     close(fd);
-        if(logbuf != failback)
+    free(loc);
-            free(logbuf);
-        return -1;
-    }
-    else if(error_buf<buf_length)
-        write(fd,"unknown error case log write cut down\n",38);
-    if(logbuf != failback)
-        free(logbuf);
-    close(fd); 
-    return 0; 
 }
 
 void log_manager_stop(log_manager *self)
 {
     pthread_mutex_lock(&self->mtx);
-    if(self->stop == 1){
+    self->stop = 1;                /* 置退出标志 */
-        pthread_mutex_unlock(&self->mtx);
-        return ;
-    }
-    self->stop = 1;
-                  /* 置退出标志 */
-    printf("SYS:stopping loger\n");
-    logs *log = malloc(sizeof(logs));
-    strcpy(log->log,"SYS:stopping loger\n");
-    self->in_log(log,self);
-    log = malloc(sizeof(logs));
-    strcpy(log->log,"SYS:done\n");
-    printf("SYS:done\n");
-    self->in_log(log,self);
-    pthread_mutex_unlock(&self->mtx);
     pthread_cond_broadcast(&self->cond); /* 唤醒所有等待线程 */
+    printf("SYS:stopping loger\n");
+    pthread_mutex_unlock(&self->mtx);
+    printf("SYS:done\n");
 }
 
 //定期清理函数
@@ -207,7 +122,7 @@ void *clear_log(void *self_p)
     {
         sleep_with_signal(self);
         sem_wait(&self->log_sem);
-        if((self->count<MAX_LOG||self->log==NULL)&&self->stop !=1){
+        if((self->count<256||self->log==NULL)&&self->stop !=1){
             sem_post(&self->log_sem);
             continue;
         }
@@ -226,28 +141,9 @@ int init_loger(log_manager *self)
         perror("NULL\n");
         return -1;
     }
-    if(sem_init(&self->log_sem, 0,1)==-1)
+    sem_init(&self->log_sem, 0,1);
-        return -1;
+    pthread_mutex_init(&self->mtx,NULL);
-    if(pthread_mutex_init(&self->mtx,NULL)==-1)
+    pthread_cond_init(&self->cond,NULL);
-    {
-        if(sem_destroy(&self->log_sem)==-1)
-        {
-            perror("log:");
-        }
-        return -1;   
-    }
-    if(pthread_cond_init(&self->cond,NULL)==-1)
-    {
-        if(sem_destroy(&self->log_sem)==-1)
-        {
-            perror("log:");
-        }
-        if(pthread_mutex_destroy(&self->mtx)==-1)
-        {
-            perror("log:");
-        }
-        return -1;
-    }
     self->in_log = in_log;
     self->out_log = out_log;
     self->clear_log = clear_log;
@@ -255,5 +151,4 @@ int init_loger(log_manager *self)
     self->stop =  0;
     self->cleanup = cleanup;
     self->count = 0;
-    return 0;
 }

c/tools/log/log.h

@@ -8,13 +8,12 @@
 
 typedef struct logs
 {
-    char log[MAX_LOG_LENGTH];
+    char log[4096];
     struct logs *next;
 }logs;
 
 typedef struct log_manager
 {
-    pthread_t pid;
     int (*in_log)(logs *,struct log_manager*);
     logs* (*out_log)(struct log_manager*);
     void *(*clear_log)(void*);

c/tools/quit/quit.c

@@ -72,14 +72,8 @@ void quit_all(int status,void *self_p)
         free(resouce->tem->command);
     }
     //释放终端资源
-    //释放日志管理器
-    if(resouce->loger->pid != -1){
-        log_manager_stop(resouce->loger);
-        pthread_join(resouce->loger->pid,NULL);
-    }
     pthread_mutex_destroy(&resouce->loger->mtx);
-    pthread_cond_destroy(&resouce->loger->cond);
+    resouce->loger->cleanup(resouce->loger);
-    log_manager_stop(resouce->loger);
     sem_destroy(&resouce->loger->log_sem);
     //销毁信号量