bugfixed: sf_server_update_prepare_and_check MUST use request->body

storage_pool
YuQing 2021-04-19 21:43:19 +08:00
parent e4d529ab29
commit 94bcf26518
3 changed files with 4 additions and 5 deletions

View File

@ -174,7 +174,7 @@ int sf_server_deal_report_req_receipt(struct fast_task_info *task,
}
IdempotencyRequest *sf_server_update_prepare_and_check(
struct fast_task_info *task, struct fast_mblock_man *
SFRequestInfo *req, struct fast_mblock_man *
request_allocator, IdempotencyChannel *channel,
SFResponseInfo *response, int *result)
{
@ -188,8 +188,7 @@ IdempotencyRequest *sf_server_update_prepare_and_check(
return NULL;
}
adheader = (SFProtoIdempotencyAdditionalHeader *)
(task->data + sizeof(SFCommonProtoHeader));
adheader = (SFProtoIdempotencyAdditionalHeader *)req->body;
request = (IdempotencyRequest *)fast_mblock_alloc_object(request_allocator);
if (request == NULL) {
*result = ENOMEM;

View File

@ -37,7 +37,7 @@ int sf_server_deal_report_req_receipt(struct fast_task_info *task,
SFResponseInfo *response);
IdempotencyRequest *sf_server_update_prepare_and_check(
struct fast_task_info *task, struct fast_mblock_man *
SFRequestInfo *req, struct fast_mblock_man *
request_allocator, IdempotencyChannel *channel,
SFResponseInfo *response, int *result);

View File

@ -56,7 +56,7 @@ int sf_check_response(ConnectionInfo *conn, SFResponseInfo *response,
response->error.message,
"response cmd: %d != expect: %d",
response->header.cmd, expect_cmd);
return ERANGE;
return EINVAL;
}
return 0;