summaryrefslogtreecommitdiff
path: root/lib/sqfs/block_processor/common.c
diff options
context:
space:
mode:
authorDavid Oberhollenzer <david.oberhollenzer@sigma-star.at>2021-01-14 04:40:36 +0100
committerDavid Oberhollenzer <david.oberhollenzer@sigma-star.at>2021-01-19 04:03:37 +0100
commit1fc10c7115f71d9338bc79da72db2ee9e1a87073 (patch)
treed092d4de8f2e223d6f4360488b1aed066ef10733 /lib/sqfs/block_processor/common.c
parentcd3346a66910f02722e60c6a136405b6e2e4e0fe (diff)
Fix: Move fragment consolidation back to block processor serial part
Keeping a list of fragments stored away in the current fragment block and consolidating them in the thread pool takes them out of circulation. If we have a lot of tiny fragments, this can lead to a situation where all the limit is reached, but we cannot do anything, because we are waiting for a block to complete, but they are all attached to the current fragment block and the queue is empty. Signed-off-by: David Oberhollenzer <david.oberhollenzer@sigma-star.at>
Diffstat (limited to 'lib/sqfs/block_processor/common.c')
-rw-r--r--lib/sqfs/block_processor/common.c35
1 files changed, 5 insertions, 30 deletions
diff --git a/lib/sqfs/block_processor/common.c b/lib/sqfs/block_processor/common.c
index 9c80502..b2657e6 100644
--- a/lib/sqfs/block_processor/common.c
+++ b/lib/sqfs/block_processor/common.c
@@ -46,18 +46,6 @@ static int set_block_size(sqfs_inode_generic_t **inode,
static void release_old_block(sqfs_block_processor_t *proc, sqfs_block_t *blk)
{
- sqfs_block_t *it;
-
- if (blk->flags & SQFS_BLK_FRAGMENT_BLOCK && blk->frag_list != NULL) {
- it = blk->frag_list;
-
- while (it->next != NULL)
- it = it->next;
-
- it->next = proc->free_list;
- proc->free_list = blk->frag_list;
- }
-
blk->next = proc->free_list;
proc->free_list = blk;
}
@@ -128,26 +116,11 @@ static bool is_zero_block(unsigned char *ptr, size_t size)
static int process_block(sqfs_block_t *block, sqfs_compressor_t *cmp,
sqfs_u8 *scratch, size_t scratch_size)
{
- sqfs_block_t *it;
- size_t offset;
sqfs_s32 ret;
if (block->size == 0)
return 0;
- if (block->flags & SQFS_BLK_FRAGMENT_BLOCK) {
- offset = block->size;
-
- for (it = block->frag_list; it != NULL; it = it->next) {
- assert(offset >= it->size);
- offset -= it->size;
-
- memcpy(block->data + offset, it->data, it->size);
-
- block->flags |= (it->flags & SQFS_BLK_DONT_COMPRESS);
- }
- }
-
if (!(block->flags & SQFS_BLK_IGNORE_SPARSE) &&
is_zero_block(block->data, block->size)) {
block->flags |= SQFS_BLK_IS_SPARSE;
@@ -241,15 +214,17 @@ static int process_completed_fragment(sqfs_block_processor_t *proc,
proc->frag_block->index = index;
proc->frag_block->flags &= SQFS_BLK_DONT_COMPRESS;
proc->frag_block->flags |= SQFS_BLK_FRAGMENT_BLOCK;
- proc->frag_block->frag_list = NULL;
} else {
index = proc->frag_block->index;
offset = proc->frag_block->size;
- frag->next = proc->frag_block->frag_list;
- proc->frag_block->frag_list = frag;
+ memcpy(proc->frag_block->data + proc->frag_block->size,
+ frag->data, frag->size);
proc->frag_block->size += frag->size;
+ proc->frag_block->flags |=
+ (frag->flags & SQFS_BLK_DONT_COMPRESS);
+ release_old_block(proc, frag);
}
if (proc->frag_tbl != NULL) {