UncompressedFile.h

// SPDX-FileCopyrightText: 2013-2021 Tobias Lorenz <tobias.lorenz@gmx.net>
//
// SPDX-License-Identifier: GPL-3.0-or-later
 
#pragma once
 
#include <Vector/BLF/platform.h>
 
#include <condition_variable>
#include <limits>
#include <list>
#include <memory>
#include <mutex>
 
#include <Vector/BLF/AbstractFile.h>
#include <Vector/BLF/LogContainer.h>
 
#include <Vector/BLF/vector_blf_export.h>
 
namespace Vector {
namespace BLF {

class VECTOR_BLF_EXPORT UncompressedFile final : public AbstractFile {
  public:
    UncompressedFile() = default;
    ~UncompressedFile() override;
 
    std::streamsize gcount() const override;
    void read(char * s, std::streamsize n) override;
    std::streampos tellg() override;
    void seekg(std::streamoff off, const std::ios_base::seekdir way = std::ios_base::cur) override;
    void write(const char * s, std::streamsize n) override;
    std::streampos tellp() override;
    bool good() const override;
    bool eof() const override;

    virtual void abort();

    virtual void write(const std::shared_ptr<LogContainer> & logContainer);

    virtual void nextLogContainer();

    virtual std::streamsize fileSize() const;

    virtual void setFileSize(std::streamsize fileSize);

    virtual void setBufferSize(std::streamsize bufferSize);

    virtual void dropOldData();

    virtual uint32_t defaultLogContainerSize() const;

    virtual void setDefaultLogContainerSize(uint32_t defaultLogContainerSize);

    std::condition_variable tellgChanged;

    std::condition_variable tellpChanged;
 
  private:
    bool m_abort {};

    std::list<std::shared_ptr<LogContainer>> m_data {};

    std::streampos m_tellg {};

    std::streampos m_tellp {};

    std::streamsize m_gcount {};

    std::streamsize m_fileSize {std::numeric_limits<std::streamsize>::max()};

    std::streamsize m_bufferSize {std::numeric_limits<std::streamsize>::max()};

    std::ios_base::iostate m_rdstate {std::ios_base::goodbit};

    mutable std::mutex m_mutex {};

    uint32_t m_defaultLogContainerSize {0x20000};

    std::shared_ptr<LogContainer> logContainerContaining(const std::streampos pos) const;
};
 
}
}