From f92c2211933fbb318d72503385081aae2aa814cd Mon Sep 17 00:00:00 2001
From: kyle <kyle_derrick@foxmail.com>
Date: Mon, 25 Sep 2023 18:02:22 +0800
Subject: [PATCH] =?UTF-8?q?socket=E6=93=8D=E4=BD=9Cnio=20notify=E6=9C=AA?=
 =?UTF-8?q?=E5=8F=98=E6=9B=B4=E6=97=B6=EF=BC=8Cnio=20notify=20CAS=E6=93=8D?=
 =?UTF-8?q?=E4=BD=9C=E5=A4=B1=E8=B4=A5=E5=AF=BC=E8=87=B4=E6=97=A0=E5=93=8D?=
 =?UTF-8?q?=E5=BA=94=E7=84=B6=E5=90=8E=E8=B6=85=E6=97=B6=E5=85=B3=E9=97=AD?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 storage/storage_dio.c | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/storage/storage_dio.c b/storage/storage_dio.c
index a30b338..0016216 100644
--- a/storage/storage_dio.c
+++ b/storage/storage_dio.c
@@ -762,6 +762,11 @@ static void *dio_thread_entrance(void* arg)
 	{
 		while ((pTask=blocked_queue_pop(&(pContext->queue))) != NULL)
         {
+			if (FC_ATOMIC_GET(pTask->nio_stages.notify) != SF_NIO_STAGE_NONE) {
+				if ((blocked_queue_push(&(pContext->queue), pTask)) == 0) {
+					continue;
+				}
+			}
             ((StorageClientInfo *)pTask->arg)->deal_func(pTask);
             storage_release_task(pTask);
         }