// Copyright 2019 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include <trace-reader/file_reader.h>

namespace trace {

// static
bool FileReader::Create(const char* file_path,
                        RecordConsumer record_consumer,
                        ErrorHandler error_handler,
                        std::unique_ptr<FileReader>* out_reader) {
    ZX_DEBUG_ASSERT(out_reader != nullptr);
    FILE* f = fopen(file_path, "rb");
    if (f == nullptr) {
        return false;
    }

    out_reader->reset(new FileReader(f, std::move(record_consumer),
                                     std::move(error_handler)));
    return true;
}

FileReader::FileReader(FILE* file, RecordConsumer record_consumer,
                       ErrorHandler error_handler)
    : TraceReader(std::move(record_consumer),
                  std::move(error_handler)),
      file_(file) {
}

void FileReader::ReadFile() {
    for (;;) {
        size_t to_read = buffer_.size() - buffer_end_;
        size_t actual = fread(buffer_.data() + buffer_end_, 1u, to_read, file_);

        if (actual == 0) {
            break;
        }

        buffer_end_ += actual;
        size_t bytes_available = buffer_end_;

        size_t bytes_consumed;
        trace::Chunk chunk(reinterpret_cast<const uint64_t*>(buffer_.data()),
                           trace::BytesToWords(bytes_available));
        if (!ReadRecords(chunk)) {
            ReportError("Trace stream is corrupted");
            break;
        }
        bytes_consumed =
            bytes_available - trace::WordsToBytes(chunk.remaining_words());

        bytes_available -= bytes_consumed;
        memmove(buffer_.data(), buffer_.data() + bytes_consumed, bytes_available);
        buffer_end_ = bytes_available;
    }
}

} // namespace trace