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
- BidPrivateBase.cs
- DataGridViewColumn.cs
- XmlHierarchicalEnumerable.cs
- DSACryptoServiceProvider.cs
- IIS7WorkerRequest.cs
- EventEntry.cs
- ClientSettingsStore.cs
- EventRouteFactory.cs
- namescope.cs
- CharKeyFrameCollection.cs
- BidOverLoads.cs
- newitemfactory.cs
- Section.cs
- ClientEventManager.cs
- InternalCache.cs
- NetworkCredential.cs
- QueryLifecycle.cs
- ThreadTrace.cs
- FontInfo.cs
- userdatakeys.cs
- NetworkInformationException.cs
- DataGridViewCellPaintingEventArgs.cs
- SQLRoleProvider.cs
- CodeFieldReferenceExpression.cs
- SqlBulkCopyColumnMapping.cs
- ContainerUIElement3D.cs
- SQLInt64.cs
- Bitmap.cs
- grammarelement.cs
- CategoryEditor.cs
- DataGridViewButtonCell.cs
- RemoteArgument.cs
- SourceItem.cs
- XmlSchemaSubstitutionGroup.cs
- WebPartCatalogCloseVerb.cs
- BehaviorEditorPart.cs
- CroppedBitmap.cs
- TextControlDesigner.cs
- PrintPreviewControl.cs
- CryptoConfig.cs
- Native.cs
- SimpleHandlerFactory.cs
- OptionalColumn.cs
- Stacktrace.cs
- StrongNameIdentityPermission.cs
- MimeBasePart.cs
- shaperfactoryquerycachekey.cs
- ListBindableAttribute.cs
- ParameterToken.cs
- WebCategoryAttribute.cs
- Permission.cs
- TextSearch.cs
- DefaultTraceListener.cs
- OdbcConnectionOpen.cs
- WhitespaceSignificantCollectionAttribute.cs
- FormViewActionList.cs
- ContainerCodeDomSerializer.cs
- OdbcEnvironmentHandle.cs
- XamlInterfaces.cs
- InvalidPropValue.cs
- GACMembershipCondition.cs
- ToggleButtonAutomationPeer.cs
- TypeElement.cs
- DbParameterCollectionHelper.cs
- DescendantOverDescendantQuery.cs
- NameTable.cs
- EditingScopeUndoUnit.cs
- BitHelper.cs
- DateTimeOffsetConverter.cs
- SqlCacheDependencyDatabase.cs
- CharEntityEncoderFallback.cs
- Point4D.cs
- DataGridViewEditingControlShowingEventArgs.cs
- ArithmeticException.cs
- TableCellAutomationPeer.cs
- RichTextBox.cs
- AndAlso.cs
- PictureBox.cs
- IndexedDataBuffer.cs
- ButtonFlatAdapter.cs
- MediaContext.cs
- PrivacyNoticeBindingElement.cs
- ReadOnlyCollectionBase.cs
- SemanticTag.cs
- DictionaryItemsCollection.cs
- AliasedSlot.cs
- SortFieldComparer.cs
- JsonReaderWriterFactory.cs
- ConstNode.cs
- WebPart.cs
- XmlObjectSerializerReadContext.cs
- LambdaExpression.cs
- Types.cs
- Rect.cs
- recordstatefactory.cs
- SupportsEventValidationAttribute.cs
- RangeBaseAutomationPeer.cs
- Convert.cs
- BuildProviderCollection.cs
- ResourceAttributes.cs