| [148] | 1 | /* |
|---|
| 2 | ----------------------------------------------------------------------------- |
|---|
| 3 | This source file is part of OGRE |
|---|
| 4 | (Object-oriented Graphics Rendering Engine) |
|---|
| 5 | For the latest info, see http://www.ogre3d.org/ |
|---|
| 6 | |
|---|
| 7 | Copyright (c) 2000-2013 Torus Knot Software Ltd |
|---|
| 8 | |
|---|
| 9 | Permission is hereby granted, free of charge, to any person obtaining a copy |
|---|
| 10 | of this software and associated documentation files (the "Software"), to deal |
|---|
| 11 | in the Software without restriction, including without limitation the rights |
|---|
| 12 | to use, copy, modify, merge, publish, distribute, sublicense, and/or sell |
|---|
| 13 | copies of the Software, and to permit persons to whom the Software is |
|---|
| 14 | furnished to do so, subject to the following conditions: |
|---|
| 15 | |
|---|
| 16 | The above copyright notice and this permission notice shall be included in |
|---|
| 17 | all copies or substantial portions of the Software. |
|---|
| 18 | |
|---|
| 19 | THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR |
|---|
| 20 | IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, |
|---|
| 21 | FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE |
|---|
| 22 | AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER |
|---|
| 23 | LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, |
|---|
| 24 | OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN |
|---|
| 25 | THE SOFTWARE. |
|---|
| 26 | ----------------------------------------------------------------------------- |
|---|
| 27 | */ |
|---|
| 28 | #ifndef __OGRE_DEFLATE_H__ |
|---|
| 29 | #define __OGRE_DEFLATE_H__ |
|---|
| 30 | |
|---|
| 31 | #include "OgrePrerequisites.h" |
|---|
| 32 | #include "OgreDataStream.h" |
|---|
| 33 | #include "OgreHeaderPrefix.h" |
|---|
| 34 | |
|---|
| 35 | /// forward decls |
|---|
| 36 | struct z_stream_s; |
|---|
| 37 | typedef struct z_stream_s z_stream; |
|---|
| 38 | |
|---|
| 39 | namespace Ogre |
|---|
| 40 | { |
|---|
| 41 | /** Stream which compresses / uncompresses data using the 'deflate' compression |
|---|
| 42 | algorithm. |
|---|
| 43 | @remarks |
|---|
| 44 | This stream is designed to wrap another stream for the actual source / destination |
|---|
| 45 | of the compressed data, it has no concrete source / data itself. The idea is |
|---|
| 46 | that you pass uncompressed data through this stream, and the underlying |
|---|
| 47 | stream reads/writes compressed data to the final source. |
|---|
| 48 | @note |
|---|
| 49 | This is an alternative to using a compressed archive since it is able to |
|---|
| 50 | compress & decompress regardless of the actual source of the stream. |
|---|
| 51 | You should avoid using this with already compressed archives. |
|---|
| 52 | Also note that this cannot be used as a read / write stream, only a read-only |
|---|
| 53 | or write-only stream. |
|---|
| 54 | */ |
|---|
| 55 | class _OgreExport DeflateStream : public DataStream |
|---|
| 56 | { |
|---|
| 57 | protected: |
|---|
| 58 | DataStreamPtr mCompressedStream; |
|---|
| 59 | DataStreamPtr mTmpWriteStream; |
|---|
| 60 | String mTempFileName; |
|---|
| 61 | z_stream* mZStream; |
|---|
| 62 | size_t mCurrentPos; |
|---|
| 63 | size_t mAvailIn; |
|---|
| 64 | |
|---|
| 65 | /// Cache for read data in case skipping around |
|---|
| 66 | StaticCache<16 * OGRE_STREAM_TEMP_SIZE> mReadCache; |
|---|
| 67 | |
|---|
| 68 | /// Intermediate buffer for read / write |
|---|
| 69 | unsigned char *mTmp; |
|---|
| 70 | |
|---|
| 71 | /// Whether the underlying stream is valid compressed data |
|---|
| 72 | bool mIsCompressedValid; |
|---|
| 73 | |
|---|
| 74 | void init(); |
|---|
| 75 | void destroy(); |
|---|
| 76 | void compressFinal(); |
|---|
| 77 | |
|---|
| 78 | size_t getAvailInForSinglePass(); |
|---|
| 79 | public: |
|---|
| 80 | /** Constructor for creating unnamed stream wrapping another stream. |
|---|
| 81 | @param compressedStream The stream that this stream will use when reading / |
|---|
| 82 | writing compressed data. The access mode from this stream will be matched. |
|---|
| 83 | @param tmpFileName Path/Filename to be used for temporary storage of incoming data |
|---|
| 84 | @param avail_in Available data length to be uncompressed. With it we can uncompress |
|---|
| 85 | DataStream partly. |
|---|
| 86 | */ |
|---|
| 87 | DeflateStream(const DataStreamPtr& compressedStream, const String& tmpFileName = "", |
|---|
| 88 | size_t avail_in = 0); |
|---|
| 89 | /** Constructor for creating named stream wrapping another stream. |
|---|
| 90 | @param name The name to give this stream |
|---|
| 91 | @param compressedStream The stream that this stream will use when reading / |
|---|
| 92 | writing compressed data. The access mode from this stream will be matched. |
|---|
| 93 | @param tmpFileName Path/Filename to be used for temporary storage of incoming data |
|---|
| 94 | @param avail_in Available data length to be uncompressed. With it we can uncompress |
|---|
| 95 | DataStream partly. |
|---|
| 96 | */ |
|---|
| 97 | DeflateStream(const String& name, const DataStreamPtr& compressedStream, const String& tmpFileName="", |
|---|
| 98 | size_t avail_in = 0); |
|---|
| 99 | |
|---|
| 100 | ~DeflateStream(); |
|---|
| 101 | |
|---|
| 102 | /** Returns whether the compressed stream is valid deflated data. |
|---|
| 103 | @remarks |
|---|
| 104 | If you pass this class a READ stream which is not compressed with the |
|---|
| 105 | deflate algorithm, this method returns false and all read commands |
|---|
| 106 | will actually be executed as passthroughs as a fallback. |
|---|
| 107 | */ |
|---|
| 108 | bool isCompressedStreamValid() const { return mIsCompressedValid; } |
|---|
| 109 | |
|---|
| 110 | /** @copydoc DataStream::read |
|---|
| 111 | */ |
|---|
| 112 | size_t read(void* buf, size_t count); |
|---|
| 113 | |
|---|
| 114 | /** @copydoc DataStream::write |
|---|
| 115 | */ |
|---|
| 116 | size_t write(const void* buf, size_t count); |
|---|
| 117 | |
|---|
| 118 | /** @copydoc DataStream::skip |
|---|
| 119 | */ |
|---|
| 120 | void skip(long count); |
|---|
| 121 | |
|---|
| 122 | /** @copydoc DataStream::seek |
|---|
| 123 | */ |
|---|
| 124 | void seek( size_t pos ); |
|---|
| 125 | |
|---|
| 126 | /** @copydoc DataStream::tell |
|---|
| 127 | */ |
|---|
| 128 | size_t tell(void) const; |
|---|
| 129 | |
|---|
| 130 | /** @copydoc DataStream::eof |
|---|
| 131 | */ |
|---|
| 132 | bool eof(void) const; |
|---|
| 133 | |
|---|
| 134 | /** @copydoc DataStream::close |
|---|
| 135 | */ |
|---|
| 136 | void close(void); |
|---|
| 137 | |
|---|
| 138 | }; |
|---|
| 139 | } |
|---|
| 140 | |
|---|
| 141 | #include "OgreHeaderSuffix.h" |
|---|
| 142 | |
|---|
| 143 | #endif |
|---|