zip_algorithm_bzip2.c File Reference

#include "zipint.h"
#include <bzlib.h>
#include <limits.h>
#include <stdlib.h>

Go to the source code of this file.

Classes
struct	ctx

Functions
static zip_uint64_t	maximum_compressed_size (zip_uint64_t uncompressed_size)
static void *	allocate (bool compress, int compression_flags, zip_error_t *error)
static void *	compress_allocate (zip_uint16_t method, int compression_flags, zip_error_t *error)
static void *	decompress_allocate (zip_uint16_t method, int compression_flags, zip_error_t *error)
static void	deallocate (void *ud)
static zip_uint16_t	general_purpose_bit_flags (void *ud)
static int	map_error (int ret)
static bool	start (void *ud, zip_stat_t *st, zip_file_attributes_t *attributes)
static bool	end (void *ud)
static bool	input (void *ud, zip_uint8_t *data, zip_uint64_t length)
static void	end_of_input (void *ud)
static zip_compression_status_t	process (void *ud, zip_uint8_t *data, zip_uint64_t *length)

Variables
zip_compression_algorithm_t	zip_algorithm_bzip2_compress
zip_compression_algorithm_t	zip_algorithm_bzip2_decompress

Function Documentation

allocate()

static void* allocate ( bool  compress, int  compression_flags, zip_error_t *  error  )

static

Definition at line 61 of file zip_algorithm_bzip2.c.

                                                                   {
    struct ctx *ctx;
 
    if ((ctx = (struct ctx *)malloc(sizeof(*ctx))) == NULL) {
        return NULL;
    }
 
    ctx->error = error;
    ctx->compress = compress;
    ctx->compression_flags = compression_flags;
    if (ctx->compression_flags < 1 || ctx->compression_flags > 9) {
        ctx->compression_flags = 9;
    }
    ctx->end_of_input = false;
 
    ctx->zstr.bzalloc = NULL;
    ctx->zstr.bzfree = NULL;
    ctx->zstr.opaque = NULL;
 
    return ctx;
}

References ctx::compress, compress(), ctx::compression_flags, ctx::end_of_input, ctx::error, error(), malloc(), NULL, and ctx::zstr.

Referenced by compress_allocate(), decompress_allocate(), gzfilebuf::overflow(), and gzfilebuf::underflow().

compress_allocate()

static void* compress_allocate ( zip_uint16_t  method, int  compression_flags, zip_error_t *  error  )

static

Definition at line 85 of file zip_algorithm_bzip2.c.

                                                                                  {
    return allocate(true, compression_flags, error);
}

References allocate(), ctx::compression_flags, and error().

deallocate()

static void deallocate ( void *  ud )

static

Definition at line 97 of file zip_algorithm_bzip2.c.

                     {
    struct ctx *ctx = (struct ctx *)ud;
 
    free(ctx);
}

References free().

decompress_allocate()

static void* decompress_allocate ( zip_uint16_t  method, int  compression_flags, zip_error_t *  error  )

static

Definition at line 91 of file zip_algorithm_bzip2.c.

                                                                                    {
    return allocate(false, compression_flags, error);
}

References allocate(), ctx::compression_flags, and error().

end()

static bool end ( void *  ud )

static

Definition at line 169 of file zip_algorithm_bzip2.c.

              {
    struct ctx *ctx = (struct ctx *)ud;
    int err;
 
    if (ctx->compress) {
        err = BZ2_bzCompressEnd(&ctx->zstr);
    }
    else {
        err = BZ2_bzDecompressEnd(&ctx->zstr);
    }
 
    if (err != BZ_OK) {
        zip_error_set(ctx->error, map_error(err), 0);
        return false;
    }
 
    return true;
}

References ctx::compress, err, ctx::error, map_error(), zip_error_set(), and ctx::zstr.

end_of_input()

static void end_of_input ( void *  ud )

static

Definition at line 206 of file zip_algorithm_bzip2.c.

                       {
    struct ctx *ctx = (struct ctx *)ud;
 
    ctx->end_of_input = true;
}

References ctx::end_of_input.

general_purpose_bit_flags()

static zip_uint16_t general_purpose_bit_flags ( void *  ud )

static

Definition at line 105 of file zip_algorithm_bzip2.c.

                                    {
    return 0;
}

input()

static bool input ( void *  ud, zip_uint8_t *  data, zip_uint64_t  length  )

static

Definition at line 190 of file zip_algorithm_bzip2.c.

                                                        {
    struct ctx *ctx = (struct ctx *)ud;
 
    if (length > UINT_MAX || ctx->zstr.avail_in > 0) {
        zip_error_set(ctx->error, ZIP_ER_INVAL, 0);
        return false;
    }
 
    ctx->zstr.avail_in = (unsigned int)length;
    ctx->zstr.next_in = (char *)data;
 
    return true;
}

References ctx::error, int, length, UINT_MAX, ZIP_ER_INVAL, zip_error_set(), and ctx::zstr.

Referenced by __add_cmdf_panel(), __load_cmdf(), __printPattern(), __set_filter(), autocmplt_cmd_arg_file(), autocompleteFilename(), avr_assembler(), calculate_luhn(), cmd_agraph_edge(), cmd_agraph_node(), cmd_analysis_esil(), cmd_analysis_graph(), cmd_analysis_trampoline(), cmd_dbg_map_jemalloc(), cmd_dcu(), cmd_debug_pid(), cmd_pCd(), cmd_pCD(), cmd_pCx(), cmd_print_bars(), cmd_print_blocks(), cmd_print_format(), cmd_print_fromage(), cmd_print_gadget(), cmd_print_op(), cmd_print_pv(), cmd_pxb_p(), cmd_Quit(), cmd_seek_opcode(), convert_offset_from_input(), core_cmd_tsrzcmd(), cqcheck(), deflate_index_build(), deflate_index_extract(), des_decrypt(), des_encrypt(), disasm_strings(), do_analysis_search(), do_asm_search(), do_esil_search(), do_section_search(), egg_option(), encode_addr16(), encode_addr32(), encode_atype(), encode_const_pool16(), encode_const_pool16_ut8(), encode_const_pool8(), encode_st16(), encode_st8(), encode_ut8(), encode_ut8x2(), func_walk_blocks(), FUZ_AddressOverflow(), get_bit(), get_lines(), getlistmask(), getnummemend(), getnummemendbang(), getreglist(), getregmembang(), getregmemend(), getregmemstart(), getregmemstartend(), getshiftmemend(), hash_context_create_desc_io_string(), hash_parse_cmdline(), iflag(), indx(), is_in_input(), itmask(), java_assembler(), jemalloc_get_bins(), jemalloc_get_chunks(), jemalloc_print_narenas(), kwajd_decompress(), lang_pipe_run(), lua53_assembly(), lua54_assembly(), lzxd_init(), lzxd_set_reference_data(), main(), mpcf_escape_new(), mpcf_unescape_new(), mszipd_init(), oabd_decompress(), oabd_decompress_incremental(), opmask(), parse_hints(), parser__start(), parser_parse(), print_heap_bin(), print_heap_fastbin(), print_main_arena_bins(), qtmd_init(), rop_kuery(), rz_asm_pseudo_align(), rz_asm_pseudo_arch(), rz_asm_pseudo_bits(), rz_asm_pseudo_byte(), rz_asm_pseudo_fill(), rz_asm_pseudo_incbin(), rz_asm_pseudo_int16(), rz_asm_pseudo_int32(), rz_asm_pseudo_int64(), rz_asm_pseudo_intN(), rz_asm_pseudo_org(), rz_asm_pseudo_string(), rz_cmd_alias(), rz_cmd_analysis(), rz_cmd_call(), rz_cmd_cmp_hexpair_string_handler(), rz_cmd_debug(), rz_cmd_debug_continue_syscall(), rz_cmd_debug_continue_until(), rz_cmd_debug_dmi(), rz_cmd_debug_heap_jemalloc(), rz_cmd_debug_trace_addr(), rz_cmd_heap_arena_bins_print_handler(), rz_cmd_heap_bins_list_print(), rz_cmd_heap_fastbins_print(), rz_cmd_help(), rz_cmd_hexdump(), rz_cmd_info_kuery(), rz_cmd_kuery(), rz_cmd_macro(), rz_cmd_panels(), rz_cmd_print(), rz_cmd_remote(), rz_cmd_search(), rz_cmd_shell_mkdir_handler(), rz_cmd_shell_mv_handler(), rz_cmd_visual(), rz_cons_filter(), rz_core_agraph_print(), rz_core_asm_search(), rz_core_asm_strsearch(), rz_core_debug_esil(), rz_core_debug_kill(), rz_core_graph_print(), rz_core_rtr_add(), rz_core_rtr_cmd(), rz_core_rtr_pushout(), rz_core_rtr_rap_run(), rz_core_rtr_remove(), rz_core_rtr_session(), rz_core_visual(), rz_core_visual_analysis(), rz_core_visual_browse(), rz_core_visual_debugtraces(), rz_core_yank_hud_file(), rz_core_yank_hud_path(), rz_equal_g_handler_old(), rz_equal_h_handler_old(), rz_equal_H_handler_old(), rz_hash_cfg_randomart(), rz_hash_xxhash(), rz_io_system_run_oldhandler(), rz_MD5Update(), rz_push_escaped_handler(), rz_seek_search(), rz_sys_cmd_str(), rz_sys_cmd_str_full(), rz_syscmd_ls(), sanitize_cab_filename(), stream_reset(), system_exec_stdin(), szddd_decompress(), tokens_new(), ts_lexer_set_input(), ts_parser_parse(), ts_parser_parse_string_encoding(), ts_parser_parse_wasm(), update(), utf32len(), utf32toutf8(), utf8toutf32(), XXH32(), XXH32_endian_align(), XXH32_round(), XXH32_update(), XXH32_update_endian(), XXH64(), XXH64_endian_align(), XXH64_round(), XXH64_update(), and XXH64_update_endian().

map_error()

static int map_error ( int  ret )

static

Definition at line 111 of file zip_algorithm_bzip2.c.

                   {
    switch (ret) {
    case BZ_FINISH_OK:
    case BZ_FLUSH_OK:
    case BZ_OK:
    case BZ_RUN_OK:
    case BZ_STREAM_END:
        return ZIP_ER_OK;
 
    case BZ_DATA_ERROR:
    case BZ_DATA_ERROR_MAGIC:
    case BZ_UNEXPECTED_EOF:
        return ZIP_ER_COMPRESSED_DATA;
 
    case BZ_MEM_ERROR:
        return ZIP_ER_MEMORY;
 
    case BZ_PARAM_ERROR:
        return ZIP_ER_INVAL;
 
    case BZ_CONFIG_ERROR: /* actually, bzip2 miscompiled */
    case BZ_IO_ERROR:
    case BZ_OUTBUFF_FULL:
    case BZ_SEQUENCE_ERROR:
        return ZIP_ER_INTERNAL;
 
    default:
        return ZIP_ER_INTERNAL;
    }
}

References ZIP_ER_COMPRESSED_DATA, ZIP_ER_INTERNAL, ZIP_ER_INVAL, ZIP_ER_MEMORY, and ZIP_ER_OK.

Referenced by end(), process(), and start().

maximum_compressed_size()

static zip_uint64_t maximum_compressed_size ( zip_uint64_t  uncompressed_size )

static

Definition at line 50 of file zip_algorithm_bzip2.c.

                                                        {
    zip_uint64_t compressed_size = (zip_uint64_t)((double)uncompressed_size * 1.006);
 
    if (compressed_size < uncompressed_size) {
        return ZIP_UINT64_MAX;
    }
    return compressed_size;
}

References compressed_size, uncompressed_size, and ZIP_UINT64_MAX.

process()

static zip_compression_status_t process ( void *  ud, zip_uint8_t *  data, zip_uint64_t *  length  )

static

Definition at line 214 of file zip_algorithm_bzip2.c.

                                                           {
    struct ctx *ctx = (struct ctx *)ud;
 
    int ret;
 
    if (ctx->zstr.avail_in == 0 && !ctx->end_of_input) {
        *length = 0;
        return ZIP_COMPRESSION_NEED_DATA;
    }
 
    ctx->zstr.avail_out = (unsigned int)ZIP_MIN(UINT_MAX, *length);
    ctx->zstr.next_out = (char *)data;
 
    if (ctx->compress) {
        ret = BZ2_bzCompress(&ctx->zstr, ctx->end_of_input ? BZ_FINISH : BZ_RUN);
    }
    else {
        ret = BZ2_bzDecompress(&ctx->zstr);
    }
 
    *length = *length - ctx->zstr.avail_out;
 
    switch (ret) {
    case BZ_FINISH_OK: /* compression */
        return ZIP_COMPRESSION_OK;
 
    case BZ_OK:     /* decompression */
    case BZ_RUN_OK: /* compression */
        if (ctx->zstr.avail_in == 0) {
            return ZIP_COMPRESSION_NEED_DATA;
        }
        return ZIP_COMPRESSION_OK;
 
    case BZ_STREAM_END:
        return ZIP_COMPRESSION_END;
 
    default:
        zip_error_set(ctx->error, map_error(ret), 0);
        return ZIP_COMPRESSION_ERROR;
    }
}

References ctx::compress, ctx::end_of_input, ctx::error, int, length, map_error(), UINT_MAX, ZIP_COMPRESSION_END, ZIP_COMPRESSION_ERROR, ZIP_COMPRESSION_NEED_DATA, ZIP_COMPRESSION_OK, zip_error_set(), ZIP_MIN, and ctx::zstr.

Referenced by exit_wait_callback(), rz_debug_dmp_attach(), rz_debug_dmp_init(), rz_debug_dmp_pids(), uidFromPid(), uv__chld(), uv_process_kill(), and uv_spawn().

start()

static bool start ( void *  ud, zip_stat_t *  st, zip_file_attributes_t *  attributes  )

static

Definition at line 143 of file zip_algorithm_bzip2.c.

                                                                   {
    struct ctx *ctx = (struct ctx *)ud;
    int ret;
 
    ctx->zstr.avail_in = 0;
    ctx->zstr.next_in = NULL;
    ctx->zstr.avail_out = 0;
    ctx->zstr.next_out = NULL;
 
    if (ctx->compress) {
        ret = BZ2_bzCompressInit(&ctx->zstr, ctx->compression_flags, 0, 30);
    }
    else {
        ret = BZ2_bzDecompressInit(&ctx->zstr, 0, 0);
    }
 
    if (ret != BZ_OK) {
        zip_error_set(ctx->error, map_error(ret), 0);
        return false;
    }
 
    return true;
}

References ctx::compress, ctx::compression_flags, ctx::error, map_error(), NULL, zip_error_set(), and ctx::zstr.

Variable Documentation

zip_algorithm_bzip2_compress

zip_compression_algorithm_t zip_algorithm_bzip2_compress

Initial value:

= {
    maximum_compressed_size,
    compress_allocate,
    deallocate,
    general_purpose_bit_flags,
    46,
    start,
    end,
    input,
    end_of_input,
    process
}

Definition at line 258 of file zip_algorithm_bzip2.c.

zip_algorithm_bzip2_decompress

zip_compression_algorithm_t zip_algorithm_bzip2_decompress

Initial value:

= {
    maximum_compressed_size,
    decompress_allocate,
    deallocate,
    general_purpose_bit_flags,
    46,
    start,
    end,
    input,
    end_of_input,
    process
}

Definition at line 272 of file zip_algorithm_bzip2.c.