From f5ffd013f186edce3cd2b0f3dd058507c322e881 Mon Sep 17 00:00:00 2001
From: YuQing <384681@qq.com>
Date: Tue, 22 Sep 2020 22:40:20 +0800
Subject: [PATCH] check task length

---
 src/idempotency/client/receipt_handler.c | 10 +---------
 1 file changed, 1 insertion(+), 9 deletions(-)

diff --git a/src/idempotency/client/receipt_handler.c b/src/idempotency/client/receipt_handler.c
index bd47897..0fbdc9d 100644
--- a/src/idempotency/client/receipt_handler.c
+++ b/src/idempotency/client/receipt_handler.c
@@ -111,14 +111,6 @@ static int check_report_req_receipt(struct fast_task_info *task)
     char *buff_end;
     int count;
 
-    if (task->length > 0) {
-        logWarning("file: "__FILE__", line: %d, "
-                "server %s:%d, task length: %d != 0, skip check "
-                "and report receipt request!", __LINE__,
-                task->server_ip, task->port, task->length);
-        return 0;
-    }
-
     channel = (IdempotencyClientChannel *)task->arg;
     if (channel->waiting_resp_qinfo.head != NULL) {
         return 0;
@@ -328,7 +320,7 @@ static int receipt_deal_task(struct fast_task_info *task)
             setup_channel_request(task);
             result = 0;
             break;
-        } else if (stage == SF_NIO_STAGE_CONTINUE) {
+        } else if (stage == SF_NIO_STAGE_CONTINUE && task->length == 0) {
             if (((IdempotencyClientChannel *)task->arg)->established) {
                 report_req_receipt_request(task, true);
             } else {