diff --git a/src/idempotency/client/client_channel.c b/src/idempotency/client/client_channel.c index 6d50c65..cf7c0e3 100644 --- a/src/idempotency/client/client_channel.c +++ b/src/idempotency/client/client_channel.c @@ -170,9 +170,9 @@ void client_channel_destroy() { } -struct fast_task_info *alloc_channel_task(IdempotencyClientChannel *channel, - const uint32_t hash_code, const char *server_ip, const uint16_t port, - int *err_no) +static struct fast_task_info *alloc_channel_task(IdempotencyClientChannel + *channel, const uint32_t hash_code, const char *server_ip, + const uint16_t port, int *err_no) { struct fast_task_info *task; diff --git a/src/idempotency/server/server_handler.c b/src/idempotency/server/server_handler.c index 68a338a..2519225 100644 --- a/src/idempotency/server/server_handler.c +++ b/src/idempotency/server/server_handler.c @@ -201,6 +201,9 @@ IdempotencyRequest *sf_server_update_prepare_and_check( *result = idempotency_channel_add_request(channel, request); if (*result == EEXIST) { if (!request->finished) { + response->error.length = sprintf(response->error.message, + "idempotency req id: %"PRId64" exists but NOT " + "finished", request->req_id); *result = EAGAIN; } }