AuroraSupport/AuroraRuntime
2
1
Fork 0
Code Issues 27 Pull Requests Releases Wiki Activity

I messed up

Browse Source
This commit is contained in:
Reece Wilson 2021-07-12 13:02:36 +01:00
parent be7b080c56
commit 8233825353
4 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Source/Compression/BlockCompressor.cpp
View File

@ -46,7 +46,7 @@ namespace Aurora::Compression
} }
} }
return !buffer || StreamRead(buffer, len, this->_outbuffer); return StreamRead(buffer, len, this->_outbuffer);
} }
AUKN_SYM ICompressionStream *CompressorNew(IO::IStreamReader *reader, const CompressionInfo &info) AUKN_SYM ICompressionStream *CompressorNew(IO::IStreamReader *reader, const CompressionInfo &info)

2
Source/Compression/BlockDecompressor.cpp
View File

@ -33,7 +33,7 @@ namespace Aurora::Compression
} }
} }
return !buffer || StreamRead(buffer, len, this->_outbuffer); return StreamRead(buffer, len, this->_outbuffer);
} }
class ZSTDInflate : public BaseStream class ZSTDInflate : public BaseStream

1
Source/Compression/Compression.hpp
View File

@ -16,6 +16,7 @@ namespace Aurora::Compression
{ {
len = std::min(AuUInt32(vec.size()), len); len = std::min(AuUInt32(vec.size()), len);
if (len == 0) return false; if (len == 0) return false;
if (!buffer) return true;
std::memcpy(buffer, vec.data(), len); std::memcpy(buffer, vec.data(), len);
auto rem = vec.size() - len; auto rem = vec.size() - len;
std::memmove(vec.data(), vec.data() + len, rem); std::memmove(vec.data(), vec.data() + len, rem);

2
Source/Compression/StreamCompression.cpp
View File

@ -446,7 +446,7 @@ namespace Aurora::Compression
{ {
auto &inBuf = inBuffers[inBufState = !inBufState]; auto &inBuf = inBuffers[inBufState = !inBufState];
auto read = stream.inPipe(inBuf.get() , 64 * 1024); auto read = stream.inPipe(inBuf.get(), size);
if (!read) break; if (!read) break;
AuUInt32 bufferedBytes = LZ4_compress_fast_continue(lz4Stream, inBuf.get(), outBuf.get(), read, size, 1); AuUInt32 bufferedBytes = LZ4_compress_fast_continue(lz4Stream, inBuf.get(), outBuf.get(), read, size, 1);