diff options
| author | David Oberhollenzer <david.oberhollenzer@sigma-star.at> | 2020-02-13 14:18:53 +0100 |
|---|---|---|
| committer | David Oberhollenzer <david.oberhollenzer@sigma-star.at> | 2020-02-15 18:09:30 +0100 |
| commit | 6f4d85d2150c287432f7696659f22eeca0a0e1b2 (patch) | |
| tree | 26c62c4d3e5c9ef68fe1fca006e3db9a18093f59 /lib/sqfs/block_processor/fileapi.c | |
| parent | 6546c3f4a1d140024cb2ab2c90fbf192749a1bf7 (diff) | |
Cleanup: block processor: remove delayed thread notification
Under the assumption that block processing is CPU bound and not I/O
bound, this is entirely useless.
Signed-off-by: David Oberhollenzer <david.oberhollenzer@sigma-star.at>
Diffstat (limited to 'lib/sqfs/block_processor/fileapi.c')
| -rw-r--r-- | lib/sqfs/block_processor/fileapi.c | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/lib/sqfs/block_processor/fileapi.c b/lib/sqfs/block_processor/fileapi.c index dee1d5e..ac73a51 100644 --- a/lib/sqfs/block_processor/fileapi.c +++ b/lib/sqfs/block_processor/fileapi.c @@ -22,10 +22,7 @@ static int enqueue_block(sqfs_block_processor_t *proc, sqfs_block_t *block) return status; } - if (proc->backlog == proc->max_backlog) - proc->notify_threads = true; - - return append_to_work_queue(proc, block, proc->notify_threads); + return append_to_work_queue(proc, block); } static int add_sentinel_block(sqfs_block_processor_t *proc) @@ -174,7 +171,7 @@ int sqfs_block_processor_finish(sqfs_block_processor_t *proc) { int status = 0; - append_to_work_queue(proc, NULL, true); + append_to_work_queue(proc, NULL); while (proc->backlog > 0) { status = wait_completed(proc); @@ -183,7 +180,7 @@ int sqfs_block_processor_finish(sqfs_block_processor_t *proc) } if (proc->frag_block != NULL) { - status = append_to_work_queue(proc, proc->frag_block, true); + status = append_to_work_queue(proc, proc->frag_block); proc->frag_block = NULL; if (status) |