check user interrupt on until timeout

shikokuchuo · Oct 21, 2023 · d606b6b · d606b6b
1 parent 331b457
commit d606b6b
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/aio.c b/src/aio.c
@@ -1725,7 +1725,7 @@ SEXP rnng_cv_until2(SEXP cvar, SEXP msec) {
     break;
   }
 
-  uint8_t signalled = 1;
+  int signalled = 1;
   nng_mtx_lock(mtx);
   while (ncv->condition == 0) {
     if (nng_cv_until(cv, time) == NNG_ETIMEDOUT) {
@@ -1735,6 +1735,7 @@ SEXP rnng_cv_until2(SEXP cvar, SEXP msec) {
   }
   if (signalled) ncv->condition--;
   nng_mtx_unlock(mtx);
+  if (!signalled) R_CheckUserInterrupt();
 
   return Rf_ScalarLogical(signalled);