krak/zstd
1
0
Fork 0
mirror of https://github.com/facebook/zstd.git synced 2025-07-17 12:37:51 +02:00
Code Issues Releases 1 Activity

Fix AsyncIO reading seed queueing (#3940)

Browse Source 
Fixes a bug in AsyncIO where we queue reads after opening a file so our queue will always be saturated (or as saturated as possible).
Previous code was looping up to `availableJobsCount` not realizing `availableJobsCount` was also decreasing in each iteration, so instead of queueing 10 jobs we'd queue 5 (and instead of 2 we'd queue 1).
This PR fixes the loop to queue as long as `availableJobsCount` is not 0.
This commit is contained in:
Yonatan Komornik
2024-03-11 16:28:32 -07:00
committed by GitHub
parent a4db145900
commit edab9eed66
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
programs/fileio_asyncio.c
View File

@ -514,8 +514,7 @@ static void AIO_ReadPool_enqueueRead(ReadPoolCtx_t* ctx) {
} }
static void AIO_ReadPool_startReading(ReadPoolCtx_t* ctx) { static void AIO_ReadPool_startReading(ReadPoolCtx_t* ctx) {
int i; while(ctx->base.availableJobsCount) {
for (i = 0; i < ctx->base.availableJobsCount; i++) {
AIO_ReadPool_enqueueRead(ctx); AIO_ReadPool_enqueueRead(ctx);
} }
} }