diff --git a/src/idempotency/server/server_handler.c b/src/idempotency/server/server_handler.c index 2519225..a62dcf8 100644 --- a/src/idempotency/server/server_handler.c +++ b/src/idempotency/server/server_handler.c @@ -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; diff --git a/src/idempotency/server/server_handler.h b/src/idempotency/server/server_handler.h index 73d8251..74bc478 100644 --- a/src/idempotency/server/server_handler.h +++ b/src/idempotency/server/server_handler.h @@ -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); diff --git a/src/sf_proto.c b/src/sf_proto.c index ed634b4..7d7714e 100644 --- a/src/sf_proto.c +++ b/src/sf_proto.c @@ -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;