add macro server_expect_body_length etc.

storage_pool
YuQing 2021-03-11 15:16:43 +08:00
parent 86017c46ac
commit aa4f66c578
1 changed files with 19 additions and 2 deletions

View File

@ -309,6 +309,23 @@ static inline int sf_server_check_body_length(
body_length, max_body_length);
}
#define server_expect_body_length(task, expect_body_len) \
sf_server_expect_body_length(&RESPONSE, REQUEST.header.body_len, \
expect_body_len)
#define server_check_min_body_length(task, min_body_length) \
sf_server_check_min_body_length(&RESPONSE, REQUEST.header.body_len, \
min_body_length)
#define server_check_max_body_length(task, max_body_length) \
sf_server_check_max_body_length(&RESPONSE, REQUEST.header.body_len, \
max_body_length)
#define server_check_body_length(task, min_body_length, max_body_length) \
sf_server_check_body_length(&RESPONSE, REQUEST.header.body_len, \
min_body_length, max_body_length)
int sf_check_response(ConnectionInfo *conn, SFResponseInfo *response,
const int network_timeout, const unsigned char expect_cmd);
@ -415,6 +432,7 @@ int sf_proto_get_leader(ConnectionInfo *conn,
const int network_timeout,
SFClientServerEntry *leader);
#define SF_CLIENT_RELEASE_CONNECTION(cm, conn, result) \
do { \
if (SF_FORCE_CLOSE_CONNECTION_ERROR(result)) { \
@ -424,7 +442,6 @@ int sf_proto_get_leader(ConnectionInfo *conn,
} \
} while (0)
#ifdef __cplusplus
}
#endif