urbackup_backend/fsimageplugin/CompressedFile.h
Martin e39f4dfd21 Thread-safe file reading and writing
(cherry picked from commit 3ebcf7d0bb02c8bd3a42398fe5f4b574dd179fe8)

Conflicts:
	Interface/File.h
	file.h
	file_linux.cpp
	file_win.cpp
	fsimageplugin/CompressedFile.cpp
	fsimageplugin/CompressedFile.h
	fsimageplugin/FileWrapper.cpp
	fsimageplugin/FileWrapper.h
	fsimageplugin/vhdfile.cpp
	fsimageplugin/vhdfile.h
2016-01-25 13:00:22 +01:00

75 lines
1.9 KiB
C++

#pragma once
#include <string>
#include <memory>
#include "../Interface/Server.h"
#include "../Interface/File.h"
#include "LRUMemCache.h"
class CompressedFile : public IFile, public ICacheEvictionCallback
{
public:
CompressedFile(std::string pFilename, int pMode);
CompressedFile(IFile* file, bool openExisting, bool readOnly);
~CompressedFile();
virtual std::string Read(_u32 tr, bool *has_error=NULL);
virtual std::string Read(int64 spos, _u32 tr, bool *has_error = NULL);
virtual _u32 Read(char* buffer, _u32 bsize, bool *has_error=NULL);
virtual _u32 Read(int64 spos, char* buffer, _u32 bsize, bool *has_error = NULL);
virtual _u32 Write(const std::string &tw, bool *has_error=NULL);
virtual _u32 Write(int64 spos, const std::string &tw, bool *has_error = NULL);
virtual _u32 Write(const char* buffer, _u32 bsize, bool *has_error=NULL);
virtual _u32 Write(int64 spos, const char* buffer, _u32 bsize, bool *has_error = NULL);
virtual bool Seek(_i64 spos);
virtual _i64 Size(void);
virtual _i64 RealSize();
virtual bool PunchHole( _i64 spos, _i64 size );
virtual std::string getFilename(void);
virtual bool Sync();
bool hasError();
bool finish();
bool hasNoMagic();
private:
void readHeader(bool *has_error);
void readIndex(bool *has_error);
bool fillCache(__int64 offset, bool errorMsg, bool *has_error);
virtual void evictFromLruCache(const SCacheItem& item);
void writeHeader();
void writeIndex();
_u32 readFromFile(char* buffer, _u32 bsize, bool *has_error);
_u32 writeToFile(const char* buffer, _u32 bsize);
__int64 filesize;
__int64 index_offset;
_u32 blocksize;
__int64 currentPosition;
std::vector<__int64> blockOffsets;
IFile* uncompressedFile;
std::auto_ptr<LRUMemCache> hotCache;
std::vector<char> compressedBuffer;
bool error;
bool finished;
bool readOnly;
bool noMagic;
};