From 9d5b0c381a7961a14d2a94a6b31a4e25a2543eae Mon Sep 17 00:00:00 2001 From: David Oberhollenzer Date: Tue, 28 Jan 2020 21:23:21 +0100 Subject: Rename sqfs_data_writer_t back to sqfs_block_processor_t Signed-off-by: David Oberhollenzer --- lib/sqfs/block_processor/serial.c | 88 +++++++++++++++++++++++++++++++++++++++ 1 file changed, 88 insertions(+) create mode 100644 lib/sqfs/block_processor/serial.c (limited to 'lib/sqfs/block_processor/serial.c') diff --git a/lib/sqfs/block_processor/serial.c b/lib/sqfs/block_processor/serial.c new file mode 100644 index 0000000..eedb19c --- /dev/null +++ b/lib/sqfs/block_processor/serial.c @@ -0,0 +1,88 @@ +/* SPDX-License-Identifier: LGPL-3.0-or-later */ +/* + * serial.c + * + * Copyright (C) 2019 David Oberhollenzer + */ +#define SQFS_BUILDING_DLL +#include "internal.h" + +sqfs_block_processor_t *sqfs_block_processor_create(size_t max_block_size, + sqfs_compressor_t *cmp, + unsigned int num_workers, + size_t max_backlog, + size_t devblksz, + sqfs_file_t *file) +{ + sqfs_block_processor_t *proc; + + proc = alloc_flex(sizeof(*proc), 1, max_block_size); + + if (proc == NULL) + return NULL; + + if (block_processor_init(proc, max_block_size, cmp, num_workers, + max_backlog, devblksz, file)) { + block_processor_cleanup(proc); + return NULL; + } + + return proc; +} + +void sqfs_block_processor_destroy(sqfs_block_processor_t *proc) +{ + block_processor_cleanup(proc); +} + +int test_and_set_status(sqfs_block_processor_t *proc, int status) +{ + if (proc->status == 0) + proc->status = status; + + return proc->status; +} + +int append_to_work_queue(sqfs_block_processor_t *proc, sqfs_block_t *block, + bool signal_threads) +{ + sqfs_block_t *fragblk = NULL; + (void)signal_threads; + + if (proc->status != 0 || block == NULL) { + free(block); + return proc->status; + } + + if (block->flags & SQFS_BLK_IS_FRAGMENT) { + block->checksum = crc32(0, block->data, block->size); + + proc->status = process_completed_fragment(proc, block, + &fragblk); + free(block); + + if (proc->status != 0) { + free(fragblk); + return proc->status; + } + + if (fragblk == NULL) + return 0; + + block = fragblk; + } + + proc->status = block_processor_do_block(block, proc->cmp, proc->scratch, + proc->max_block_size); + + if (proc->status == 0) + proc->status = process_completed_block(proc, block); + + free(block); + return proc->status; +} + +int wait_completed(sqfs_block_processor_t *proc) +{ + return proc->status; +} -- cgit v1.2.3