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 +#include + +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);