123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366 |
- using System;
- using System.IO;
- using System.Text;
- namespace SharpCompress.Compressors.Deflate
- {
- public class DeflateStream : Stream
- {
- private readonly ZlibBaseStream _baseStream;
- private bool _disposed;
- public DeflateStream(Stream stream, CompressionMode mode,
- CompressionLevel level = CompressionLevel.Default,
- Encoding forceEncoding = null)
- {
- _baseStream = new ZlibBaseStream(stream, mode, level, ZlibStreamFlavor.DEFLATE, forceEncoding);
- }
- #region Zlib properties
-
-
-
-
-
- public virtual FlushType FlushMode
- {
- get => (_baseStream._flushMode);
- set
- {
- if (_disposed)
- {
- throw new ObjectDisposedException("DeflateStream");
- }
- _baseStream._flushMode = value;
- }
- }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- public int BufferSize
- {
- get => _baseStream._bufferSize;
- set
- {
- if (_disposed)
- {
- throw new ObjectDisposedException("DeflateStream");
- }
- if (_baseStream._workingBuffer != null)
- {
- throw new ZlibException("The working buffer is already set.");
- }
- if (value < ZlibConstants.WorkingBufferSizeMin)
- {
- throw new ZlibException(
- String.Format("Don't be silly. {0} bytes?? Use a bigger buffer, at least {1}.", value,
- ZlibConstants.WorkingBufferSizeMin));
- }
- _baseStream._bufferSize = value;
- }
- }
-
-
-
-
-
-
-
-
- public CompressionStrategy Strategy
- {
- get => _baseStream.Strategy;
- set
- {
- if (_disposed)
- {
- throw new ObjectDisposedException("DeflateStream");
- }
- _baseStream.Strategy = value;
- }
- }
-
- public virtual long TotalIn => _baseStream._z.TotalBytesIn;
-
- public virtual long TotalOut => _baseStream._z.TotalBytesOut;
- #endregion
- #region System.IO.Stream methods
-
-
-
-
-
-
- public override bool CanRead
- {
- get
- {
- if (_disposed)
- {
- throw new ObjectDisposedException("DeflateStream");
- }
- return _baseStream._stream.CanRead;
- }
- }
-
-
-
-
-
-
- public override bool CanSeek => false;
-
-
-
-
-
-
- public override bool CanWrite
- {
- get
- {
- if (_disposed)
- {
- throw new ObjectDisposedException("DeflateStream");
- }
- return _baseStream._stream.CanWrite;
- }
- }
-
-
-
- public override long Length => throw new NotSupportedException();
-
-
-
-
-
-
-
-
-
-
- public override long Position
- {
- get
- {
- if (_baseStream._streamMode == ZlibBaseStream.StreamMode.Writer)
- {
- return _baseStream._z.TotalBytesOut;
- }
- if (_baseStream._streamMode == ZlibBaseStream.StreamMode.Reader)
- {
- return _baseStream._z.TotalBytesIn;
- }
- return 0;
- }
- set => throw new NotSupportedException();
- }
-
-
-
-
-
-
- protected override void Dispose(bool disposing)
- {
- try
- {
- if (!_disposed)
- {
- if (disposing)
- {
- _baseStream?.Dispose();
- }
- _disposed = true;
- }
- }
- finally
- {
- base.Dispose(disposing);
- }
- }
-
-
-
- public override void Flush()
- {
- if (_disposed)
- {
- throw new ObjectDisposedException("DeflateStream");
- }
- _baseStream.Flush();
- }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- public override int Read(byte[] buffer, int offset, int count)
- {
- if (_disposed)
- {
- throw new ObjectDisposedException("DeflateStream");
- }
- return _baseStream.Read(buffer, offset, count);
- }
- public override int ReadByte()
- {
- if (_disposed)
- {
- throw new ObjectDisposedException("DeflateStream");
- }
- return _baseStream.ReadByte();
- }
-
-
-
-
-
-
- public override long Seek(long offset, SeekOrigin origin)
- {
- throw new NotSupportedException();
- }
-
-
-
-
- public override void SetLength(long value)
- {
- throw new NotSupportedException();
- }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- public override void Write(byte[] buffer, int offset, int count)
- {
- if (_disposed)
- {
- throw new ObjectDisposedException("DeflateStream");
- }
- _baseStream.Write(buffer, offset, count);
- }
- public override void WriteByte(byte value)
- {
- if (_disposed)
- {
- throw new ObjectDisposedException("DeflateStream");
- }
- _baseStream.WriteByte(value);
- }
- #endregion
- public MemoryStream InputBuffer => new MemoryStream(_baseStream._z.InputBuffer, _baseStream._z.NextIn,
- _baseStream._z.AvailableBytesIn);
- }
- }
|