bool zofits::CompressBuffer ( const CompressionTarget &  target )

inlineprotected

Compress a given buffer based on the target. This is the method executed by the threads

Parameters

target

the struct hosting the parameters of the compression

Returns

number of bytes of the compressed data, or always 1 when used by the Queues

Definition at line 692 of file zofits.h.

References zofits::CompressionTarget::catalog_entry, zofits::WriteTarget::data, i, zofits::CompressionTarget::num_rows, zofits::CompressionTarget::src, zofits::CompressionTarget::target, and zofits::CompressionTarget::transposed_src.

Referenced by SetNumThreads().

        {
            //Can't get this to work in the thread. Printed the adresses, and they seem to be correct.
            //Really do not understand what's wrong...
            //calibrate data if required
            const uint32_t thisRoundNumRows  = (target.num_rows%fNumRowsPerTile) ? target.num_rows%fNumRowsPerTile : fNumRowsPerTile;
            for (uint32_t i=0;i<thisRoundNumRows;i++)
            {
                char* target_location = target.src.get() + fRealRowWidth*i;
                DrsOffsetCalibrate(target_location);
            }
#ifdef __EXCEPTIONS
            try
            {
#endif
                //transpose the original data
                copyTransposeTile(target.src.get(), target.transposed_src.get(), target.num_rows);

                //compress the buffer
                const uint64_t compressed_size = compressBuffer(target.target.data.get(), target.transposed_src.get(), target.num_rows, target.catalog_entry);

                //post the result to the writing queue
                //get a copy so that it becomes non-const
                fWriteToDiskQueue.emplace(target.target, compressed_size);

#ifdef __EXCEPTIONS
            }
            catch (...)
            {
                fThreadsException = std::current_exception();
                if (fNumQueues == 0)
                    std::rethrow_exception(fThreadsException);
            }
#endif

            return true;
        }

Here is the caller graph for this function: