mirror of
https://github.com/jpd002/Play-.git
synced 2025-04-28 13:47:57 +03:00
45 lines
967 B
C++
45 lines
967 B
C++
#pragma once
|
|
|
|
#include <vector>
|
|
#include "Singleton.h"
|
|
#include "Stream.h"
|
|
#include "filesystem_def.h"
|
|
#include "amazon/AmazonS3Client.h"
|
|
|
|
class CS3ObjectStream : public Framework::CStream
|
|
{
|
|
public:
|
|
class CConfig : public CSingleton<CConfig>
|
|
{
|
|
public:
|
|
CConfig();
|
|
CAmazonCredentials GetCredentials();
|
|
};
|
|
|
|
CS3ObjectStream(const char*, const char*);
|
|
|
|
uint64 Read(void*, uint64) override;
|
|
uint64 Write(const void*, uint64) override;
|
|
void Seek(int64, Framework::STREAM_SEEK_DIRECTION) override;
|
|
uint64 Tell() override;
|
|
bool IsEOF() override;
|
|
|
|
private:
|
|
static fs::path GetCachePath();
|
|
std::string GenerateReadCacheKey(const std::pair<uint64, uint64>&) const;
|
|
void GetObjectInfo();
|
|
void SyncBuffer();
|
|
|
|
std::string m_bucketName;
|
|
std::string m_bucketRegion;
|
|
std::string m_objectKey;
|
|
|
|
//Object Metadata
|
|
uint64 m_objectSize = 0;
|
|
std::string m_objectEtag;
|
|
|
|
uint64 m_objectPosition = 0;
|
|
|
|
std::vector<uint8> m_buffer;
|
|
uint64 m_bufferPosition = ~0ULL;
|
|
};
|