Code:
/ Dotnetfx_Win7_3.5.1 / Dotnetfx_Win7_3.5.1 / 3.5.1 / DEVDIV / depot / DevDiv / releases / Orcas / NetFXw7 / wpf / src / Base / MS / Internal / IO / Packaging / DeflateEmulationStream.cs / 1 / DeflateEmulationStream.cs
//------------------------------------------------------------------------------ // //// Copyright (C) Microsoft Corporation. All rights reserved. // // // Description: // Implementation of a helper class that provides a fully functional Stream on a restricted functionality // Compression stream (System.IO.Compression.DeflateStream). // // History: // 10/05/2005: BruceMac: Split out from CompressEmulationStream //----------------------------------------------------------------------------- using System; using System.IO; using System.IO.Compression; // for DeflateStream using System.Diagnostics; using System.IO.Packaging; using System.Windows; namespace MS.Internal.IO.Packaging { //----------------------------------------------------- // // Internal Members // //----------------------------------------------------- ////// Emulates a fully functional stream using restricted functionality DeflateStream /// internal class DeflateEmulationTransform : IDeflateTransform { ////// Extract from DeflateStream to temp stream /// ///Caller is responsible for correctly positioning source and sink stream pointers before calling. public void Decompress(Stream source, Stream sink) { // for non-empty stream create deflate stream that can // actually decompress using (DeflateStream deflateStream = new DeflateStream( source, // source of compressed data CompressionMode.Decompress, // compress or decompress true)) // leave base stream open when the deflate stream is closed { int bytesRead = 0; do { bytesRead = deflateStream.Read(Buffer, 0, Buffer.Length); if (bytesRead > 0) sink.Write(Buffer, 0, bytesRead); } while (bytesRead > 0); } } ////// Compress from the temp stream into the base stream /// ///Caller is responsible for correctly positioning source and sink stream pointers before calling. public void Compress(Stream source, Stream sink) { // create deflate stream that can actually compress or decompress using (DeflateStream deflateStream = new DeflateStream( sink, // destination for compressed data CompressionMode.Compress, // compress or decompress true)) // leave base stream open when the deflate stream is closed { // persist to deflated stream from working stream int bytesRead = 0; do { bytesRead = source.Read(Buffer, 0, Buffer.Length); if (bytesRead > 0) deflateStream.Write(Buffer, 0, bytesRead); } while (bytesRead > 0); } // truncate if necessary and possible if (sink.CanSeek) sink.SetLength(sink.Position); } //------------------------------------------------------ // // Private Properties // //----------------------------------------------------- private byte[] Buffer { get { if (_buffer == null) _buffer = new byte[0x1000]; // 4k return _buffer; } } //------------------------------------------------------ // // Private Members // //------------------------------------------------------ private byte[] _buffer; // alloc and re-use to reduce memory fragmentation // this is safe because we are not thread-safe } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved. //------------------------------------------------------------------------------ // //// Copyright (C) Microsoft Corporation. All rights reserved. // // // Description: // Implementation of a helper class that provides a fully functional Stream on a restricted functionality // Compression stream (System.IO.Compression.DeflateStream). // // History: // 10/05/2005: BruceMac: Split out from CompressEmulationStream //----------------------------------------------------------------------------- using System; using System.IO; using System.IO.Compression; // for DeflateStream using System.Diagnostics; using System.IO.Packaging; using System.Windows; namespace MS.Internal.IO.Packaging { //----------------------------------------------------- // // Internal Members // //----------------------------------------------------- ////// Emulates a fully functional stream using restricted functionality DeflateStream /// internal class DeflateEmulationTransform : IDeflateTransform { ////// Extract from DeflateStream to temp stream /// ///Caller is responsible for correctly positioning source and sink stream pointers before calling. public void Decompress(Stream source, Stream sink) { // for non-empty stream create deflate stream that can // actually decompress using (DeflateStream deflateStream = new DeflateStream( source, // source of compressed data CompressionMode.Decompress, // compress or decompress true)) // leave base stream open when the deflate stream is closed { int bytesRead = 0; do { bytesRead = deflateStream.Read(Buffer, 0, Buffer.Length); if (bytesRead > 0) sink.Write(Buffer, 0, bytesRead); } while (bytesRead > 0); } } ////// Compress from the temp stream into the base stream /// ///Caller is responsible for correctly positioning source and sink stream pointers before calling. public void Compress(Stream source, Stream sink) { // create deflate stream that can actually compress or decompress using (DeflateStream deflateStream = new DeflateStream( sink, // destination for compressed data CompressionMode.Compress, // compress or decompress true)) // leave base stream open when the deflate stream is closed { // persist to deflated stream from working stream int bytesRead = 0; do { bytesRead = source.Read(Buffer, 0, Buffer.Length); if (bytesRead > 0) deflateStream.Write(Buffer, 0, bytesRead); } while (bytesRead > 0); } // truncate if necessary and possible if (sink.CanSeek) sink.SetLength(sink.Position); } //------------------------------------------------------ // // Private Properties // //----------------------------------------------------- private byte[] Buffer { get { if (_buffer == null) _buffer = new byte[0x1000]; // 4k return _buffer; } } //------------------------------------------------------ // // Private Members // //------------------------------------------------------ private byte[] _buffer; // alloc and re-use to reduce memory fragmentation // this is safe because we are not thread-safe } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved.
Link Menu

This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- Pair.cs
- ConnectionStringsExpressionBuilder.cs
- ObjectStorage.cs
- DataGridTextColumn.cs
- ElasticEase.cs
- CaretElement.cs
- ApplyHostConfigurationBehavior.cs
- ProbeMatchesApril2005.cs
- UInt16.cs
- MimeTextImporter.cs
- DataGridSortCommandEventArgs.cs
- Exceptions.cs
- LinkConverter.cs
- EmbossBitmapEffect.cs
- HandoffBehavior.cs
- HttpRequest.cs
- FullTextBreakpoint.cs
- JsonSerializer.cs
- DataGridViewComboBoxColumn.cs
- RubberbandSelector.cs
- ValidatorCompatibilityHelper.cs
- QilTargetType.cs
- MsmqInputChannelListenerBase.cs
- RangeValidator.cs
- VirtualPathProvider.cs
- OrderedParallelQuery.cs
- Pkcs7Recipient.cs
- WpfSharedBamlSchemaContext.cs
- SkinBuilder.cs
- RuleSet.cs
- CellTreeNodeVisitors.cs
- XmlSchemaInclude.cs
- PersistencePipeline.cs
- DeferredTextReference.cs
- InputChannel.cs
- odbcmetadatacollectionnames.cs
- RequestResponse.cs
- SymbolMethod.cs
- EffectiveValueEntry.cs
- StringValidatorAttribute.cs
- TraceContextRecord.cs
- DecoderReplacementFallback.cs
- HttpHostedTransportConfiguration.cs
- PropertyConverter.cs
- TrackingMemoryStreamFactory.cs
- JobStaple.cs
- Transform.cs
- DispatcherFrame.cs
- ListView.cs
- HtmlWindowCollection.cs
- BackgroundWorker.cs
- SolidColorBrush.cs
- FastEncoderWindow.cs
- ManagementScope.cs
- SqlCacheDependency.cs
- _DigestClient.cs
- ColumnClickEvent.cs
- TdsParserSafeHandles.cs
- ClientBuildManager.cs
- EntityParameter.cs
- PowerStatus.cs
- SecurityDescriptor.cs
- Cursors.cs
- PersonalizationStateInfoCollection.cs
- Serializer.cs
- ContentDisposition.cs
- BinaryFormatterWriter.cs
- SatelliteContractVersionAttribute.cs
- ZipIOCentralDirectoryBlock.cs
- Label.cs
- XmlCodeExporter.cs
- LiteralText.cs
- DirectoryInfo.cs
- EditorAttributeInfo.cs
- ProjectionAnalyzer.cs
- Stack.cs
- RankException.cs
- SqlConnectionString.cs
- InputBindingCollection.cs
- Pts.cs
- ScrollViewerAutomationPeer.cs
- ArithmeticLiteral.cs
- DataConnectionHelper.cs
- ContractDescription.cs
- TableRow.cs
- DataGridViewImageColumn.cs
- InputScope.cs
- ToolStripPanelCell.cs
- HttpValueCollection.cs
- WindowsRegion.cs
- PopOutPanel.cs
- WeakHashtable.cs
- XmlComplianceUtil.cs
- TableCellCollection.cs
- TdsParserSafeHandles.cs
- TrustManagerPromptUI.cs
- GeometryValueSerializer.cs
- ToolStripContextMenu.cs
- ConstantCheck.cs
- CommonGetThemePartSize.cs