avoid an infinite loop

This commit is contained in:
Evan Tschannen 2021-05-20 16:45:29 -07:00
parent cc18022e7d
commit d1287be445
1 changed files with 1 additions and 1 deletions

View File

@ -733,7 +733,7 @@ static int asyncSleep(sqlite3_vfs* pVfs, int microseconds) {
if (g_network->isSimulated()) if (g_network->isSimulated())
simCancel = success(g_simulator.getCurrentProcess()->shutdownSignal.getFuture()); simCancel = success(g_simulator.getCurrentProcess()->shutdownSignal.getFuture());
if (simCancel.isReady()) { if (simCancel.isReady()) {
waitFor(delay(FLOW_KNOBS->MAX_BUGGIFIED_DELAY)); waitFor(delay(FLOW_KNOBS->MAX_BUGGIFIED_DELAY + FLOW_KNOBS->MAX_RUNLOOP_TIME_BATCHING));
return 0; return 0;
} }
waitFor(g_network->delay(microseconds * 1e-6, TaskPriority::DefaultDelay) || simCancel); waitFor(g_network->delay(microseconds * 1e-6, TaskPriority::DefaultDelay) || simCancel);