* FIX nanomsg#1486 by waking up latest aio each time. (nanomsg#1487)

nanomq · Aug 11, 2021 · f716cca · f716cca
1 parent 4cdd582
commit f716cca
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/src/core/aio.c b/src/core/aio.c
@@ -530,9 +530,8 @@ nni_aio_expire_add(nni_aio *aio)
 	}
 
 	eq->eq_list[eq->eq_len++] = aio;
-	if (eq->eq_len == 1) {
-		nni_cv_wake(&eq->eq_cv);
-	}
+	// Fire the latest aio, but it cames with performance punishment
+	nni_cv_wake(&eq->eq_cv);
 }
 
 static void