Method internalDecompressUnordered

runtime/Log.cc:1702–1761

* Decompress the log file that was open()-ed and print the message out in * an arbitrary order (i.e. dependent on runtime implementation and not * necessarily in chronological order). * * \param outputFd * The file descriptor to print the log messages to * \param aggregationTargetId * Target logId to run the aggregation function on * \param aggregationFn * Aggregation funct

 *      outputted to outputFd;
 */
bool
Log::Decoder::internalDecompressUnordered(FILE* outputFd,
                                        uint32_t aggregationTargetId,
                                        void(*aggregationFn)(const char*,...))
{
    if (filename.empty() || !inputFd)
       return false;

    LogMessage logArguments;
    BufferFragment *bf = allocateBufferFragment();
    while(!feof(inputFd) && good) {
        bool wrapAround = false;

        EntryType entry = peekEntryType(inputFd);
        switch (entry) {
            case EntryType::BUFFER_EXTENT:
            {
                if (!bf->readBufferExtent(inputFd, &wrapAround)){
                    fprintf(stderr,
                            "Internal Error: Corrupted BufferExtent\r\n");
                    break;
                }

                ++numBufferFragmentsRead;
                while (bf->hasNext()) {
                    bf->decompressNextLogStatement(outputFd,
                                                    logMsgsPrinted,
                                                    logArguments,
                                                    checkpoint,
                                                    fmtId2metadata,
                                                    aggregationTargetId,
                                                    aggregationFn);
                }
                break;
            }
            case EntryType::CHECKPOINT:
                if (!readDictionary(inputFd, true))
                    good = false;
                else if (outputFd)
                    fprintf(outputFd, "\r\n# New execution started\r\n");

                break;
            case EntryType::LOG_MSGS_OR_DIC:
                good = readDictionaryFragment(inputFd);
                break;
            case EntryType::INVALID:
                // Consume whitespace
                while (!feof(inputFd) && peekEntryType(inputFd) == INVALID)
                    fgetc(inputFd);
                break;
        }
    }

    if (outputFd)
        fprintf(outputFd, "\r\n\r\n# Decompression Complete after printing "
                            "%lu log messages\r\n", logMsgsPrinted);

    freeBufferFragment(bf);