Code:
/ Net / Net / 3.5.50727.3053 / DEVDIV / depot / DevDiv / releases / Orcas / SP / 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
- XamlToRtfWriter.cs
- CodeTypeMember.cs
- MemoryFailPoint.cs
- CapabilitiesState.cs
- VirtualDirectoryMapping.cs
- WebResourceAttribute.cs
- Console.cs
- EndpointAddressAugust2004.cs
- ITextView.cs
- MetaType.cs
- XmlNavigatorStack.cs
- QilSortKey.cs
- PointAnimationBase.cs
- Bezier.cs
- ReferencedAssemblyResolver.cs
- SoapFormatExtensions.cs
- StringUtil.cs
- Condition.cs
- ReaderWriterLockWrapper.cs
- KnownAssembliesSet.cs
- Converter.cs
- AggregatePushdown.cs
- XmlSchemaObjectTable.cs
- Maps.cs
- SqlClientWrapperSmiStream.cs
- ExpressionBuilderCollection.cs
- ToolboxService.cs
- ColorContext.cs
- DiscoveryInnerClientAdhocCD1.cs
- NominalTypeEliminator.cs
- NamedPipeTransportSecurity.cs
- DSASignatureDeformatter.cs
- _ContextAwareResult.cs
- Label.cs
- HttpModuleAction.cs
- MdImport.cs
- UdpContractFilterBehavior.cs
- XamlGridLengthSerializer.cs
- ResolveNameEventArgs.cs
- WindowsListView.cs
- XmlPreloadedResolver.cs
- SystemIcons.cs
- WebBrowserEvent.cs
- ArrayList.cs
- SmtpDigestAuthenticationModule.cs
- WebPartDescription.cs
- GridViewActionList.cs
- PkcsUtils.cs
- ControlCollection.cs
- CollectionChangedEventManager.cs
- RemotingException.cs
- DrawingImage.cs
- FocusWithinProperty.cs
- XComponentModel.cs
- Token.cs
- ObjectQueryState.cs
- WrappedIUnknown.cs
- HttpCookiesSection.cs
- TabItemWrapperAutomationPeer.cs
- CodeSubDirectoriesCollection.cs
- OracleRowUpdatedEventArgs.cs
- TypeGeneratedEventArgs.cs
- XPathExpr.cs
- InkCanvasSelectionAdorner.cs
- AgileSafeNativeMemoryHandle.cs
- EmptyCollection.cs
- XamlWriter.cs
- Visual3D.cs
- WebPartHelpVerb.cs
- BezierSegment.cs
- PointIndependentAnimationStorage.cs
- SimpleFieldTemplateFactory.cs
- CounterSample.cs
- KeySplineConverter.cs
- NetworkStream.cs
- SqlTrackingWorkflowInstance.cs
- LassoSelectionBehavior.cs
- ScrollChrome.cs
- SqlDependencyUtils.cs
- OdbcConnectionFactory.cs
- PrefixHandle.cs
- IPEndPoint.cs
- QueryReaderSettings.cs
- cryptoapiTransform.cs
- DefaultValueAttribute.cs
- TraceLog.cs
- _ReceiveMessageOverlappedAsyncResult.cs
- XmlObjectSerializerReadContextComplexJson.cs
- ObjectKeyFrameCollection.cs
- DesignerInterfaces.cs
- DataGridBoolColumn.cs
- Geometry.cs
- MarginCollapsingState.cs
- SqlDataSourceParameterParser.cs
- processwaithandle.cs
- XmlUtil.cs
- MailHeaderInfo.cs
- JsonEncodingStreamWrapper.cs
- UTF7Encoding.cs
- TextAutomationPeer.cs