lz5_decoder_mt_z.c

Go to the documentation of this file.

/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
*                                                                             *
*        Licensa de Copia (C) <2022>  <Aurora Boreal>                         *
*                                                                             *
*     Este  programa  e software livre: voce pode redistribuir isto e/ou      *
*     modificar  isto sobre os termos do  GNU Licensa Geral Pública como     12
*     publicado  pela Fundacao  de Software  Livre, tanto a versão 3  da      *
*     Licensa, ou (dependendo da sua opcao) qualquer versao posterior.        *
*                                                                             *
*     Este  programa e distribuido na  esperanca que isto vai  ser util,      *
*     mas SEM  QUALQUER GARANTIA; sem  ate mesmo a implicada garantia de      *
*     COMERCIALIZAcaO ou CABIMENTO PARA UM FIM PARTICULAR.  Veja a            *
*     Licensa Geral Publica para mais detalhes.                               *
*                                                                             *
*     Você deve ter recebido uma  cópia da LICENSA GERAL PUBLICA e a GNU      *
*     Licensa Publica Menor junto com este programa                           *
*     Se não, veja <http://www.gnu.org/licenses/>.                            *
*                                                                             *
*     Suporte: sourceforge.net github.com                                   *
*                                                                             *
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
 
*       Pereira: arsoftware25@gmail.com  ricardo@arsoftware.net.br            *
*          Koci: arsoftware10@gmail.com  amanda@arsoftware.net. br            *
 
                                              pereira1001@users.sourceforge.net
                                                                             */
 
                                                                            
int zuncompress_sha512_k_mt_decoding_multi_thread_z__6(FILE *source, FILE *dest, my_thread_struct_z *amanda)
{
    /*
    ar_data ar = {
        0,
    };
    */
    // char signature_z[5] = "AR__";
    char *buffer = malloc(CHUNK);
    char *out = malloc(CHUNK);
    int ret_arp;
    // int ret_z;
    int retvalue = 0;
    // int64_t remaining_z;
 
    pedro_dprintf(-1, "decoder multi-thread running\n");
 
    assert(NULL == dest);
 
    intcancel__6 = 0;
    intpause__6 = 0;
 
    // signature_z[3] = '_' - 9; //lz5 multi-thread
 
    pedro_dprintf(0, "seek to %lld\n", amanda->offset_z);
 
    // assert(0 <= (int64_t)amanda->offset_z - (int64_t)sizeof(int64_t) - (int64_t)sizeof(ar));
 
    // amanda->size_of_input_file_copy_z += sizeof(int64_t) + sizeof(ar);
 
    if (
        0 != _fseeki64(
                 amanda->input_file,
                 amanda->offset_z,
                 SEEK_SET))
    {
        amanda->retvalue = 403; //File access error
        goto saida_13_march_2021__21_02_12;
    }
/*
    memset(&ar, 0, sizeof(ar));
    ret_z = fread(&ar, 1, min(sizeof(ar), amanda->size_of_input_file_copy_z), amanda->input_file);
 
    if (ret_z != sizeof(ar))
    {
 
        retvalue = 122;
        goto saida_13_march_2021__21_02_12;
    }
    amanda->size_of_input_file_copy_z -= ret_z;
    */
    /*
    if (0 != memcmp(ar.string, signature_z, 4))
    {
 
        retvalue = 199;
        goto saida_13_march_2021__21_02_12;
    }
*/
/*
    ret_z = fread(&remaining_z, 1, min(sizeof(remaining_z), amanda->size_of_input_file_copy_z), amanda->input_file);
 
    if (sizeof(remaining_z) != ret_z)
    {
        retvalue = 122;
        goto saida_13_march_2021__21_02_12;
    }
*/
/*
    amanda->size_of_input_file_copy_z -=
        ret_z;
*/
/*
    if (0 > remaining_z)
    {
        retvalue = 500;
        goto saida_13_march_2021__21_02_12;
    }
 
    if (amanda->size_of_input_file_copy_z != remaining_z)
    {
        pedro_dprintf(-1, "achou amor %lld %lld\n", amanda->size_of_input_file_copy_z, remaining_z);
        retvalue = 500;
        goto saida_13_march_2021__21_02_12;
    }
 
    amanda->size_of_input_file_copy_z = remaining_z;
 
    pedro_dprintf(-1, "size internal %lld\n", amanda->size_of_input_file_copy_z);
 
    //aqui...
*/ 
 
pedro_dprintf(0, "multi thread slice %lld", amanda->size_of_input_file_copy_z);
 
amanda->dest_is_FILE_z = false;
 
     pedro_dprintf(0, "multi thread slice %lld count %d offset %lld", (uint64_t)amanda->size_of_input_file_copy_z, (int)amanda->thread_id_z, _ftelli64(source));
     
     amanda->bytes_saved_charli = 0;
     ret_arp = decompress_file_19(source, amanda->dest, amanda);
     pedro_dprintf(0, "depois da descompressao %lld saved %lld", amanda->size_of_input_file_copy_z, amanda->bytes_saved_charli);
    if (119 == amanda->internal_error_arp)
    {
        retvalue = 119;
    }
    else if (6 == amanda->internal_error_arp)
    {
        retvalue = amanda->internal_error_arp;
    }
    else
    {
        if (ret_arp)
        {
            // assert(0);
            pedro_dprintf(-1, "error 2 7 \n");
            retvalue = 7; //It isnot a valid compressed file
        }
    }
 
saida_13_march_2021__21_02_12:;
 
    pedro_dprintf(-1, "pulou e erro %d\n", retvalue);
 
    if (*(amanda->intcancel__6))
    {
        retvalue = 119;
    }
 
    *(amanda->bytes_read_z) = totalbytes_z__6;
    free(buffer);
    free(out);
    if(amanda->dest)
    {
        fclose(amanda->dest);
    }
    pedro_dprintf(-1, "erro que deu interno %d\n", retvalue);
 
    return retvalue;
}