pdxx
/
libserverframe
mirror of https://github.com/happyfish100/libserverframe.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

sf_proto_get_server_status_pack use struct

vote_node
YuQing 2022-05-06 09:48:49 +08:00
parent b38bf00a28
commit 07bbf65847
1 changed files with 17 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/sf_proto.h
View File

@ -51,6 +51,7 @@
#define SF_CLUSTER_PROTO_GET_SERVER_STATUS_REQ 201 #define SF_CLUSTER_PROTO_GET_SERVER_STATUS_REQ 201
#define SF_CLUSTER_PROTO_GET_SERVER_STATUS_RESP 202 #define SF_CLUSTER_PROTO_GET_SERVER_STATUS_RESP 202
#define SF_PROTO_MAGIC_CHAR '@' #define SF_PROTO_MAGIC_CHAR '@'
#define SF_PROTO_SET_MAGIC(m) \ #define SF_PROTO_SET_MAGIC(m) \
m[0] = m[1] = m[2] = m[3] = SF_PROTO_MAGIC_CHAR m[0] = m[1] = m[2] = m[3] = SF_PROTO_MAGIC_CHAR
@ -208,6 +209,16 @@ typedef struct sf_proto_get_server_status_req {
char padding[3]; char padding[3];
} SFProtoGetServerStatusReq; } SFProtoGetServerStatusReq;
typedef struct sf_get_server_status_request {
const unsigned char *servers_sign;
const unsigned char *cluster_sign;
int server_id; //my server id
union {
bool is_leader;
bool is_master;
};
} SFGetServerStatusRequest;
typedef struct sf_group_server_info { typedef struct sf_group_server_info {
int id; int id;
bool is_leader; bool is_leader;
@ -558,17 +569,15 @@ int sf_proto_get_leader(ConnectionInfo *conn,
SFClientServerEntry *leader); SFClientServerEntry *leader);
static inline void sf_proto_get_server_status_pack( static inline void sf_proto_get_server_status_pack(
const int server_id, const bool is_leader, const SFGetServerStatusRequest *r,
const unsigned char *servers_sign,
const unsigned char *cluster_sign,
SFProtoGetServerStatusReq *req) SFProtoGetServerStatusReq *req)
{ {
int2buff(server_id, req->server_id); int2buff(r->server_id, req->server_id);
req->is_leader = (is_leader ? 1 : 0); req->is_leader = (r->is_leader ? 1 : 0);
memcpy(req->config_signs.servers, servers_sign, memcpy(req->config_signs.servers, r->servers_sign,
SF_CLUSTER_CONFIG_SIGN_LEN); SF_CLUSTER_CONFIG_SIGN_LEN);
if (cluster_sign != NULL) { if (r->cluster_sign != NULL) {
memcpy(req->config_signs.cluster, cluster_sign, memcpy(req->config_signs.cluster, r->cluster_sign,
SF_CLUSTER_CONFIG_SIGN_LEN); SF_CLUSTER_CONFIG_SIGN_LEN);
} else { } else {
memset(req->config_signs.cluster, 0, memset(req->config_signs.cluster, 0,