From d11c1559abf07c1b513ca3e35753c635fafc7926 Mon Sep 17 00:00:00 2001
From: jianf <2198972886@qq.com>
Date: Fri, 3 Oct 2025 10:01:01 +0800
Subject: [PATCH] =?UTF-8?q?=E6=97=B6=E9=97=B4=E5=8E=9F=E5=9B=A0=EF=BC=8C?=
 =?UTF-8?q?=E6=9A=82=E5=AD=98=E9=83=A8=E5=88=86=E6=9B=B4=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 c/network/erroprocess/erroprocess.c | 11 +++++++++++
 c/network/erroprocess/erroprocess.h | 20 ++++++++++++++++++++
 c/network/network.c                 |  4 ++++
 3 files changed, 35 insertions(+)
 create mode 100644 c/network/erroprocess/erroprocess.c
 create mode 100644 c/network/erroprocess/erroprocess.h

diff --git a/c/network/erroprocess/erroprocess.c b/c/network/erroprocess/erroprocess.c
new file mode 100644
index 0000000..5905ccc
--- /dev/null
+++ b/c/network/erroprocess/erroprocess.c
@@ -0,0 +1,11 @@
+#include "erroprocess.h"
+#include <stdio.h>
+#include <stddef.h>
+
+int give_upjobs(indiector *self)
+{
+    if(self == NULL)
+    {
+
+    }
+}
\ No newline at end of file
diff --git a/c/network/erroprocess/erroprocess.h b/c/network/erroprocess/erroprocess.h
new file mode 100644
index 0000000..358a592
--- /dev/null
+++ b/c/network/erroprocess/erroprocess.h
@@ -0,0 +1,20 @@
+#ifndef ERROPROCESS
+#define EROPROCESS
+typedef struct jobs
+{
+    struct jobs* next;
+    int job;
+}jobs;
+
+
+typedef struct indiector
+{
+    int status;//熔断标志位
+    int retreat_index;//退避指数
+    jobs *head_job;
+    jobs *rear_job;
+}indiector;
+
+int give_upjobs(indiector *self);
+
+#endif
\ No newline at end of file
diff --git a/c/network/network.c b/c/network/network.c
index 9c9d59e..0a4a444 100644
--- a/c/network/network.c
+++ b/c/network/network.c
@@ -89,6 +89,7 @@ int init_network(int port)
 
 ssize_t read_req(int fd, void *buf)
 {
+    // TODO 修改读取任务函数
     ssize_t n = read(fd, buf, MAX_MESSAGE_BUF);
     if (n == 0)              /* 写端已关闭，管道永不会再有数据 */
         return -1;
@@ -97,6 +98,9 @@ ssize_t read_req(int fd, void *buf)
 
 int process_message(char *req,log_manager *logger)
 {
+    //TODO 修改管道命令解析
+    if(req[0]!='s')
+        return 0;
     const char *body = http_get_body(req);
     rbt_msg message;
     rbt_parse_json(body,&message);