Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / wpf / src / Base / MS / Internal / IO / Packaging / DeflateEmulationStream.cs / 1305600 / 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
- SystemWebExtensionsSectionGroup.cs
- StretchValidation.cs
- PersonalizationState.cs
- DataGridPagerStyle.cs
- DataGridItem.cs
- CustomGrammar.cs
- HierarchicalDataSourceDesigner.cs
- TokenBasedSetEnumerator.cs
- WindowAutomationPeer.cs
- WMICapabilities.cs
- WebReference.cs
- SoapCodeExporter.cs
- ProcessModuleCollection.cs
- DetailsViewPageEventArgs.cs
- ReverseComparer.cs
- SqlCommandSet.cs
- LayoutInformation.cs
- IpcClientChannel.cs
- UIElementIsland.cs
- HtmlControl.cs
- Int32Collection.cs
- WorkflowApplicationException.cs
- MimePart.cs
- StateMachineExecutionState.cs
- TraceShell.cs
- OutgoingWebRequestContext.cs
- DataColumnChangeEvent.cs
- GreenMethods.cs
- SecurityTokenTypes.cs
- RuntimeHandles.cs
- MessageDroppedTraceRecord.cs
- PathParser.cs
- FirstQueryOperator.cs
- WithStatement.cs
- PermissionSetTriple.cs
- EmptyEnumerator.cs
- XhtmlConformanceSection.cs
- HtmlInputReset.cs
- TypedTableHandler.cs
- CreatingCookieEventArgs.cs
- MsmqHostedTransportManager.cs
- ModulesEntry.cs
- EmissiveMaterial.cs
- PerspectiveCamera.cs
- AppDomain.cs
- ToolBarButtonClickEvent.cs
- SettingsAttributes.cs
- DefaultAssemblyResolver.cs
- SqlDataSourceSelectingEventArgs.cs
- NativeObjectSecurity.cs
- XMLSchema.cs
- WindowsListView.cs
- ContentElement.cs
- CodeMethodReturnStatement.cs
- SignatureHelper.cs
- MenuItem.cs
- BoundPropertyEntry.cs
- BypassElement.cs
- ContextMenu.cs
- Pair.cs
- IOThreadScheduler.cs
- WebEventCodes.cs
- CrossAppDomainChannel.cs
- BuildResultCache.cs
- FieldCollectionEditor.cs
- JulianCalendar.cs
- MD5HashHelper.cs
- Pair.cs
- control.ime.cs
- MappingException.cs
- ButtonBase.cs
- DataTrigger.cs
- Span.cs
- RsaSecurityTokenAuthenticator.cs
- IfAction.cs
- RenderContext.cs
- ExceptionUtility.cs
- BufferedGraphicsManager.cs
- EqualityComparer.cs
- AssemblyNameProxy.cs
- CodeAttributeDeclarationCollection.cs
- XmlUtf8RawTextWriter.cs
- SqlConnection.cs
- SystemException.cs
- MDIControlStrip.cs
- RectConverter.cs
- TextServicesContext.cs
- SecurityPolicySection.cs
- Bitmap.cs
- UserInitiatedNavigationPermission.cs
- SafeNativeMethods.cs
- AsyncSerializedWorker.cs
- TextDecoration.cs
- TypeResolver.cs
- SchemaTypeEmitter.cs
- NativeMethods.cs
- ReadOnlyCollectionBase.cs
- CodeGroup.cs
- DataObject.cs
- DataList.cs