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/data_writer/serial.c | 88 ------------------------------------------- 1 file changed, 88 deletions(-) delete mode 100644 lib/sqfs/data_writer/serial.c (limited to 'lib/sqfs/data_writer/serial.c') diff --git a/lib/sqfs/data_writer/serial.c b/lib/sqfs/data_writer/serial.c deleted file mode 100644 index 82f7836..0000000 --- a/lib/sqfs/data_writer/serial.c +++ /dev/null @@ -1,88 +0,0 @@ -/* SPDX-License-Identifier: LGPL-3.0-or-later */ -/* - * serial.c - * - * Copyright (C) 2019 David Oberhollenzer - */ -#define SQFS_BUILDING_DLL -#include "internal.h" - -sqfs_data_writer_t *sqfs_data_writer_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_data_writer_t *proc; - - proc = alloc_flex(sizeof(*proc), 1, max_block_size); - - if (proc == NULL) - return NULL; - - if (data_writer_init(proc, max_block_size, cmp, num_workers, - max_backlog, devblksz, file)) { - data_writer_cleanup(proc); - return NULL; - } - - return proc; -} - -void sqfs_data_writer_destroy(sqfs_data_writer_t *proc) -{ - data_writer_cleanup(proc); -} - -int test_and_set_status(sqfs_data_writer_t *proc, int status) -{ - if (proc->status == 0) - proc->status = status; - - return proc->status; -} - -int append_to_work_queue(sqfs_data_writer_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 = data_writer_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_data_writer_t *proc) -{ - return proc->status; -} -- cgit v1.2.3