-
Notifications
You must be signed in to change notification settings - Fork 38
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
d355ba7
commit b01f3e0
Showing
15 changed files
with
168 additions
and
112 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,86 @@ | ||
| #include "BoundedFileStream.h" | ||
|
|
||
| namespace Death { namespace IO { | ||
| //###==##====#=====--==~--~=~- --- -- - - - - | ||
|
|
||
| BoundedFileStream::BoundedFileStream(const Containers::StringView path, std::uint64_t offset, std::uint32_t size) | ||
| : BoundedFileStream(Containers::String{path}, offset, size) | ||
| { | ||
| } | ||
|
|
||
| BoundedFileStream::BoundedFileStream(Containers::String&& path, std::uint64_t offset, std::uint32_t size) | ||
| : _underlyingStream(path, FileAccess::Read), _offset(offset), _size(size) | ||
| { | ||
| _underlyingStream.Seek(static_cast<std::int64_t>(offset), SeekOrigin::Begin); | ||
| } | ||
|
|
||
| void BoundedFileStream::Dispose() | ||
| { | ||
| _underlyingStream.Dispose(); | ||
| } | ||
|
|
||
| std::int64_t BoundedFileStream::Seek(std::int64_t offset, SeekOrigin origin) | ||
| { | ||
| std::int64_t newPos; | ||
| switch (origin) { | ||
| case SeekOrigin::Begin: newPos = _offset + offset; break; | ||
| case SeekOrigin::Current: newPos = _underlyingStream.GetPosition() + offset; break; | ||
| case SeekOrigin::End: newPos = _offset + _size + offset; break; | ||
| default: return Stream::OutOfRange; | ||
| } | ||
|
|
||
| if (newPos < static_cast<std::int64_t>(_offset) || newPos > static_cast<std::int64_t>(_offset + _size)) { | ||
| newPos = Stream::OutOfRange; | ||
| } else { | ||
| newPos = _underlyingStream.Seek(newPos, SeekOrigin::Begin); | ||
| if (newPos >= static_cast<std::int64_t>(_offset)) { | ||
| newPos -= _offset; | ||
| } | ||
| } | ||
| return newPos; | ||
| } | ||
|
|
||
| std::int64_t BoundedFileStream::GetPosition() const | ||
| { | ||
| return _underlyingStream.GetPosition() - static_cast<std::int64_t>(_offset); | ||
| } | ||
|
|
||
| std::int64_t BoundedFileStream::Read(void* destination, std::int64_t bytesToRead) | ||
| { | ||
| if (bytesToRead <= 0) { | ||
| return 0; | ||
| } | ||
|
|
||
| DEATH_ASSERT(destination != nullptr, "destination is null", 0); | ||
|
|
||
| std::int64_t pos = _underlyingStream.GetPosition() - _offset; | ||
| if (bytesToRead > _size - pos) { | ||
| bytesToRead = _size - pos; | ||
| } | ||
|
|
||
| return _underlyingStream.Read(destination, bytesToRead); | ||
| } | ||
|
|
||
| std::int64_t BoundedFileStream::Write(const void* source, std::int64_t bytesToWrite) | ||
| { | ||
| // Not supported | ||
| return Stream::Invalid; | ||
| } | ||
|
|
||
| bool BoundedFileStream::Flush() | ||
| { | ||
| // Not supported | ||
| return true; | ||
| } | ||
|
|
||
| bool BoundedFileStream::IsValid() | ||
| { | ||
| return _underlyingStream.IsValid(); | ||
| } | ||
|
|
||
| std::int64_t BoundedFileStream::GetSize() const | ||
| { | ||
| return _size; | ||
| } | ||
|
|
||
| }} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,32 @@ | ||
| #pragma once | ||
|
|
||
| #include "FileStream.h" | ||
|
|
||
| namespace Death { namespace IO { | ||
| //###==##====#=====--==~--~=~- --- -- - - - - | ||
|
|
||
| class BoundedFileStream : public Stream | ||
| { | ||
| public: | ||
| BoundedFileStream(const Containers::StringView path, std::uint64_t offset, std::uint32_t size); | ||
| BoundedFileStream(Containers::String&& path, std::uint64_t offset, std::uint32_t size); | ||
|
|
||
| BoundedFileStream(const BoundedFileStream&) = delete; | ||
| BoundedFileStream& operator=(const BoundedFileStream&) = delete; | ||
|
|
||
| void Dispose() override; | ||
| std::int64_t Seek(std::int64_t offset, SeekOrigin origin) override; | ||
| std::int64_t GetPosition() const override; | ||
| std::int64_t Read(void* destination, std::int64_t bytesToRead) override; | ||
| std::int64_t Write(const void* source, std::int64_t bytesToWrite) override; | ||
| bool Flush() override; | ||
| bool IsValid() override; | ||
| std::int64_t GetSize() const override; | ||
|
|
||
| private: | ||
| FileStream _underlyingStream; | ||
| std::uint64_t _offset; | ||
| std::uint64_t _size; | ||
| }; | ||
|
|
||
| }} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.