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
- IdentityModelDictionary.cs
- EntityTypeEmitter.cs
- SystemIcmpV4Statistics.cs
- ContentValidator.cs
- COM2IVsPerPropertyBrowsingHandler.cs
- OutOfMemoryException.cs
- DataGridViewCellEventArgs.cs
- TypeToken.cs
- ReadOnlyNameValueCollection.cs
- ReachUIElementCollectionSerializer.cs
- ReadOnlyHierarchicalDataSourceView.cs
- HelpKeywordAttribute.cs
- PropertyGridEditorPart.cs
- ObjectSpanRewriter.cs
- WsdlImporter.cs
- safemediahandle.cs
- OleDbDataReader.cs
- SafeNativeMethods.cs
- View.cs
- __Error.cs
- SqlCommand.cs
- AutomationPeer.cs
- MemberPath.cs
- XPathNodeInfoAtom.cs
- Polyline.cs
- ForEachAction.cs
- UiaCoreProviderApi.cs
- TreeViewEvent.cs
- RSAOAEPKeyExchangeFormatter.cs
- CollectionViewGroupInternal.cs
- HtmlInputControl.cs
- WindowShowOrOpenTracker.cs
- Literal.cs
- SerializerProvider.cs
- DataServiceResponse.cs
- XmlNodeChangedEventArgs.cs
- PreloadedPackages.cs
- ServiceBusyException.cs
- IconConverter.cs
- ChildDocumentBlock.cs
- XamlClipboardData.cs
- TreePrinter.cs
- DataContractSerializer.cs
- DiscreteKeyFrames.cs
- AnimationTimeline.cs
- XamlFxTrace.cs
- ValidationSummaryDesigner.cs
- HashHelper.cs
- KeyConverter.cs
- Emitter.cs
- AutoCompleteStringCollection.cs
- XamlSerializationHelper.cs
- NavigationPropertyAccessor.cs
- FactoryGenerator.cs
- ColumnMap.cs
- SHA256Managed.cs
- BigInt.cs
- FixedSOMImage.cs
- LinqDataView.cs
- WithParamAction.cs
- GrammarBuilderRuleRef.cs
- SqlConnectionHelper.cs
- FilterRepeater.cs
- HttpGetServerProtocol.cs
- CompensatableTransactionScopeActivityDesigner.cs
- SuppressIldasmAttribute.cs
- ResourceProviderFactory.cs
- CodeStatementCollection.cs
- ComboBox.cs
- ExpressionParser.cs
- StructuredTypeEmitter.cs
- XmlSortKey.cs
- GrammarBuilder.cs
- PreProcessInputEventArgs.cs
- BCryptSafeHandles.cs
- ProfileSettings.cs
- RadioButtonBaseAdapter.cs
- ReferenceEqualityComparer.cs
- DataSourceXmlElementAttribute.cs
- XNodeValidator.cs
- RemotingConfiguration.cs
- parserscommon.cs
- BrowserDefinition.cs
- CodeExporter.cs
- PriorityQueue.cs
- XPathParser.cs
- WindowsGraphicsCacheManager.cs
- LogEntrySerializer.cs
- MethodSignatureGenerator.cs
- Triplet.cs
- PopupEventArgs.cs
- PolicyValidationException.cs
- WizardStepBase.cs
- HttpCachePolicyElement.cs
- ConnectionManagementSection.cs
- DataKeyCollection.cs
- ToolStripDropDownButton.cs
- ChtmlPageAdapter.cs
- DataGridViewAccessibleObject.cs
- DataListComponentEditor.cs