123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732 |
- using System;
- using System.IO;
- #if !NETCF_1_0
- using System.Security.Cryptography;
- #endif
- namespace CommonMPQ.SharpZipLib.Zip.Compression.Streams
- {
-
-
-
-
-
-
- public class InflaterInputBuffer
- {
- #region Constructors
-
-
-
-
- public InflaterInputBuffer(Stream stream) : this(stream , 4096)
- {
- }
-
-
-
-
-
-
-
- public InflaterInputBuffer(Stream stream, int bufferSize)
- {
- inputStream = stream;
- if ( bufferSize < 1024 ) {
- bufferSize = 1024;
- }
- rawData = new byte[bufferSize];
- clearText = rawData;
- }
- #endregion
-
-
-
- public int RawLength
- {
- get {
- return rawLength;
- }
- }
-
-
-
-
-
- public byte[] RawData
- {
- get {
- return rawData;
- }
- }
-
-
-
-
- public int ClearTextLength
- {
- get {
- return clearTextLength;
- }
- }
-
-
-
-
- public byte[] ClearText
- {
- get {
- return clearText;
- }
- }
-
-
-
-
- public int Available
- {
- get { return available; }
- set { available = value; }
- }
-
-
-
-
- public void SetInflaterInput(Inflater inflater)
- {
- if ( available > 0 ) {
- inflater.SetInput(clearText, clearTextLength - available, available);
- available = 0;
- }
- }
-
-
-
- public void Fill()
- {
- rawLength = 0;
- int toRead = rawData.Length;
-
- while (toRead > 0) {
- int count = inputStream.Read(rawData, rawLength, toRead);
- if ( count <= 0 ) {
- break;
- }
- rawLength += count;
- toRead -= count;
- }
-
- #if !NETCF_1_0
- if ( cryptoTransform != null ) {
- clearTextLength = cryptoTransform.TransformBlock(rawData, 0, rawLength, clearText, 0);
- }
- else
- #endif
- {
- clearTextLength = rawLength;
- }
- available = clearTextLength;
- }
-
-
-
-
-
-
- public int ReadRawBuffer(byte[] buffer)
- {
- return ReadRawBuffer(buffer, 0, buffer.Length);
- }
-
-
-
-
-
-
-
- public int ReadRawBuffer(byte[] outBuffer, int offset, int length)
- {
- if ( length < 0 ) {
- throw new ArgumentOutOfRangeException("length");
- }
-
- int currentOffset = offset;
- int currentLength = length;
-
- while ( currentLength > 0 ) {
- if ( available <= 0 ) {
- Fill();
- if (available <= 0) {
- return 0;
- }
- }
- int toCopy = Math.Min(currentLength, available);
- System.Array.Copy(rawData, rawLength - (int)available, outBuffer, currentOffset, toCopy);
- currentOffset += toCopy;
- currentLength -= toCopy;
- available -= toCopy;
- }
- return length;
- }
-
-
-
-
-
-
-
-
- public int ReadClearTextBuffer(byte[] outBuffer, int offset, int length)
- {
- if ( length < 0 ) {
- throw new ArgumentOutOfRangeException("length");
- }
-
- int currentOffset = offset;
- int currentLength = length;
-
- while ( currentLength > 0 ) {
- if ( available <= 0 ) {
- Fill();
- if (available <= 0) {
- return 0;
- }
- }
-
- int toCopy = Math.Min(currentLength, available);
- Array.Copy(clearText, clearTextLength - (int)available, outBuffer, currentOffset, toCopy);
- currentOffset += toCopy;
- currentLength -= toCopy;
- available -= toCopy;
- }
- return length;
- }
-
-
-
-
-
- public int ReadLeByte()
- {
- if (available <= 0) {
- Fill();
- if (available <= 0) {
- throw new ZipException("EOF in header");
- }
- }
- byte result = rawData[rawLength - available];
- available -= 1;
- return result;
- }
-
-
-
-
-
- public int ReadLeShort()
- {
- return ReadLeByte() | (ReadLeByte() << 8);
- }
-
-
-
-
-
- public int ReadLeInt()
- {
- return ReadLeShort() | (ReadLeShort() << 16);
- }
-
-
-
-
-
- public long ReadLeLong()
- {
- return (uint)ReadLeInt() | ((long)ReadLeInt() << 32);
- }
- #if !NETCF_1_0
-
-
-
-
- public ICryptoTransform CryptoTransform
- {
- set {
- cryptoTransform = value;
- if ( cryptoTransform != null ) {
- if ( rawData == clearText ) {
- if ( internalClearText == null ) {
- internalClearText = new byte[rawData.Length];
- }
- clearText = internalClearText;
- }
- clearTextLength = rawLength;
- if ( available > 0 ) {
- cryptoTransform.TransformBlock(rawData, rawLength - available, available, clearText, rawLength - available);
- }
- } else {
- clearText = rawData;
- clearTextLength = rawLength;
- }
- }
- }
- #endif
- #region Instance Fields
- int rawLength;
- byte[] rawData;
-
- int clearTextLength;
- byte[] clearText;
- #if !NETCF_1_0
- byte[] internalClearText;
- #endif
-
- int available;
-
- #if !NETCF_1_0
- ICryptoTransform cryptoTransform;
- #endif
- Stream inputStream;
- #endregion
- }
-
-
-
-
-
-
-
-
-
-
- public class InflaterInputStream : Stream
- {
- #region Constructors
-
-
-
-
-
-
-
- public InflaterInputStream(Stream baseInputStream)
- : this(baseInputStream, new Inflater(), 4096)
- {
- }
-
-
-
-
-
-
-
-
-
-
-
- public InflaterInputStream(Stream baseInputStream, Inflater inf)
- : this(baseInputStream, inf, 4096)
- {
- }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- public InflaterInputStream(Stream baseInputStream, Inflater inflater, int bufferSize)
- {
- if (baseInputStream == null) {
- throw new ArgumentNullException("baseInputStream");
- }
-
- if (inflater == null) {
- throw new ArgumentNullException("inflater");
- }
-
- if (bufferSize <= 0) {
- throw new ArgumentOutOfRangeException("bufferSize");
- }
-
- this.baseInputStream = baseInputStream;
- this.inf = inflater;
-
- inputBuffer = new InflaterInputBuffer(baseInputStream, bufferSize);
- }
-
- #endregion
-
-
-
-
-
-
-
- public bool IsStreamOwner
- {
- get { return isStreamOwner; }
- set { isStreamOwner = value; }
- }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- public long Skip(long count)
- {
- if (count <= 0) {
- throw new ArgumentOutOfRangeException("count");
- }
-
-
- if (baseInputStream.CanSeek) {
- baseInputStream.Seek(count, SeekOrigin.Current);
- return count;
- }
- else {
- int length = 2048;
- if (count < length) {
- length = (int) count;
- }
- byte[] tmp = new byte[length];
- int readCount = 1;
- long toSkip = count;
- while ((toSkip > 0) && (readCount > 0) ) {
- if (toSkip < length) {
- length = (int)toSkip;
- }
- readCount = baseInputStream.Read(tmp, 0, length);
- toSkip -= readCount;
- }
- return count - toSkip;
- }
- }
-
-
-
-
- protected void StopDecrypting()
- {
- #if !NETCF_1_0
- inputBuffer.CryptoTransform = null;
- #endif
- }
-
-
-
-
- public virtual int Available
- {
- get {
- return inf.IsFinished ? 0 : 1;
- }
- }
-
-
-
-
-
-
-
- protected void Fill()
- {
-
- if (inputBuffer.Available <= 0) {
- inputBuffer.Fill();
- if (inputBuffer.Available <= 0) {
- throw new SharpZipBaseException("Unexpected EOF");
- }
- }
- inputBuffer.SetInflaterInput(inf);
- }
- #region Stream Overrides
-
-
-
- public override bool CanRead
- {
- get {
- return baseInputStream.CanRead;
- }
- }
-
-
-
-
- public override bool CanSeek {
- get {
- return false;
- }
- }
-
-
-
-
- public override bool CanWrite {
- get {
- return false;
- }
- }
-
-
-
-
- public override long Length {
- get {
- return inputBuffer.RawLength;
- }
- }
-
-
-
-
-
-
- public override long Position {
- get {
- return baseInputStream.Position;
- }
- set {
- throw new NotSupportedException("InflaterInputStream Position not supported");
- }
- }
-
-
-
-
- public override void Flush()
- {
- baseInputStream.Flush();
- }
-
-
-
-
-
-
-
-
-
- public override long Seek(long offset, SeekOrigin origin)
- {
- throw new NotSupportedException("Seek not supported");
- }
-
-
-
-
-
-
-
- public override void SetLength(long value)
- {
- throw new NotSupportedException("InflaterInputStream SetLength not supported");
- }
-
-
-
-
-
-
-
-
-
- public override void Write(byte[] buffer, int offset, int count)
- {
- throw new NotSupportedException("InflaterInputStream Write not supported");
- }
-
-
-
-
-
-
-
- public override void WriteByte(byte value)
- {
- throw new NotSupportedException("InflaterInputStream WriteByte not supported");
- }
-
-
-
-
-
-
-
-
-
-
-
- public override IAsyncResult BeginWrite(byte[] buffer, int offset, int count, AsyncCallback callback, object state)
- {
- throw new NotSupportedException("InflaterInputStream BeginWrite not supported");
- }
-
-
-
-
-
- public override void Close()
- {
- if ( !isClosed ) {
- isClosed = true;
- if ( isStreamOwner ) {
- baseInputStream.Close();
- }
- }
- }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- public override int Read(byte[] buffer, int offset, int count)
- {
- if (inf.IsNeedingDictionary)
- {
- throw new SharpZipBaseException("Need a dictionary");
- }
- int remainingBytes = count;
- while (true) {
- int bytesRead = inf.Inflate(buffer, offset, remainingBytes);
- offset += bytesRead;
- remainingBytes -= bytesRead;
- if (remainingBytes == 0 || inf.IsFinished) {
- break;
- }
- if ( inf.IsNeedingInput ) {
- Fill();
- }
- else if ( bytesRead == 0 ) {
- throw new ZipException("Dont know what to do");
- }
- }
- return count - remainingBytes;
- }
- #endregion
- #region Instance Fields
-
-
-
- protected Inflater inf;
-
-
-
- protected InflaterInputBuffer inputBuffer;
-
-
-
- private Stream baseInputStream;
-
-
-
-
- protected long csize;
-
-
-
- bool isClosed;
-
-
-
-
- bool isStreamOwner = true;
- #endregion
- }
- }
|