add req rep

zhangmeng

2022-12-12 ecf23f882ca1b8aaf0863980fc4781c515da1695

 message.h

@@ -16,7 +16,7 @@

struct cstrarr{
    struct cstr* arr;
    size_t size;
    size_t count;
};
// 进程注册信息
struct creg{
@@ -88,16 +88,10 @@
};

//////////////////////////////////////////
// request body
struct creq{
    struct cstr path;
    struct cstr body;
};
// request msg
struct creqmsg{
    struct cstr procid;
    struct creq msg;
    void* src;
    struct cstr msg;
};
// decode stack err msg
struct cstackmsgerr{
@@ -128,10 +122,8 @@

// reply msg
struct crepmsg{
    struct cstr json;

    int success;
    struct cstr msg;
    int errcode;
    struct cstr errmsg;
    struct cstr data;
};

@@ -141,7 +133,7 @@

struct cstr cstr_new(const char* str, const size_t len);
void cstr_free(struct cstr str);
struct cstrarr cstr_arr_new(const size_t len);
struct cstrarr cstr_arr_new(const size_t count);
void cstr_arr_add(struct cstrarr* arr, const char* data, const size_t len, const size_t idx);
void cstr_arr_free(struct cstrarr arr);

@@ -161,8 +153,10 @@
void free_submsg_proclist(struct cproclist* ppl);

// request msg
struct creqmsg* to_reqmsg(const char* pid, const size_t pids,
                            const char* data, const size_t size, void* src);
struct creqmsg* to_reqmsg(const char* pid,const size_t pids,const char* data,const size_t size);
struct creqmsg* make_req_msg(const char* topic, const size_t topics,
                                const char* data, const size_t datal);

void free_reqmsg(struct creqmsg* msg);
// decode err msg
struct cstackmsgerr* get_reqmsg_stackerr(struct creqmsg* msg);
@@ -172,8 +166,11 @@
void free_reqmsg_stack(struct cstackmsg* msg);

// reply msg
struct crepmsg* make_reply_msg(const int success, const char* msg, const size_t msgl,
struct cstr make_reply_msg_json(const int success, const char* msg, const size_t msgl,
                                const char* data, const size_t datal);
struct crepmsg* make_reply_msg(const int errcode, const char* errmsg, const size_t emsgl,
                                const char* data, const size_t datal);

void free_reply_msg(struct crepmsg* msg);

#ifdef __cplusplus