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
- SafeFileMapViewHandle.cs
- AutomationEvent.cs
- Profiler.cs
- CommonXSendMessage.cs
- UnicodeEncoding.cs
- SafeThemeHandle.cs
- Directory.cs
- WebCategoryAttribute.cs
- MdImport.cs
- UrlPath.cs
- SmiRequestExecutor.cs
- Win32SafeHandles.cs
- LocatorBase.cs
- UITypeEditor.cs
- ContainerUtilities.cs
- FrameSecurityDescriptor.cs
- PeerEndPoint.cs
- SetterTriggerConditionValueConverter.cs
- IssuedTokensHeader.cs
- EventNotify.cs
- LessThan.cs
- FrameworkElement.cs
- CompiledQuery.cs
- CalendarDateRange.cs
- DelegateHelpers.Generated.cs
- StorageInfo.cs
- Clipboard.cs
- LockCookie.cs
- ExpressionPrefixAttribute.cs
- Type.cs
- LineBreakRecord.cs
- AppDomainShutdownMonitor.cs
- HtmlHistory.cs
- GeneralTransform3D.cs
- ContainerTracking.cs
- DeclarationUpdate.cs
- DispatcherExceptionFilterEventArgs.cs
- EntityDataSource.cs
- ScrollChrome.cs
- SigningCredentials.cs
- Pens.cs
- CommunicationObjectFaultedException.cs
- BooleanSwitch.cs
- SerialPinChanges.cs
- ScriptingScriptResourceHandlerSection.cs
- MultiView.cs
- TemplateColumn.cs
- TableLayoutSettingsTypeConverter.cs
- BaseAutoFormat.cs
- DateTimeValueSerializerContext.cs
- MonitorWrapper.cs
- SystemIcmpV4Statistics.cs
- NameValueSectionHandler.cs
- StorageSetMapping.cs
- InputQueueChannelAcceptor.cs
- FlagPanel.cs
- ZipIORawDataFileBlock.cs
- ListViewItem.cs
- SystemIPv4InterfaceProperties.cs
- Touch.cs
- SqlConnection.cs
- QuaternionKeyFrameCollection.cs
- NullableBoolConverter.cs
- XamlFilter.cs
- AutomationTextAttribute.cs
- CharConverter.cs
- _SingleItemRequestCache.cs
- EncryptedPackageFilter.cs
- elementinformation.cs
- StateWorkerRequest.cs
- TableLayout.cs
- InplaceBitmapMetadataWriter.cs
- RegularExpressionValidator.cs
- HeaderFilter.cs
- WinEventQueueItem.cs
- MenuBase.cs
- ToolStripPanelRenderEventArgs.cs
- X509Chain.cs
- BuildResultCache.cs
- MissingMemberException.cs
- coordinatorscratchpad.cs
- View.cs
- QilScopedVisitor.cs
- DataGridViewRowStateChangedEventArgs.cs
- designeractionlistschangedeventargs.cs
- AttachmentService.cs
- UniqueIdentifierService.cs
- AutoResetEvent.cs
- LineUtil.cs
- ItemCheckEvent.cs
- ApplicationHost.cs
- TextRangeEdit.cs
- BindingEditor.xaml.cs
- X509CertificateRecipientServiceCredential.cs
- ToolboxItemSnapLineBehavior.cs
- FileDialog_Vista.cs
- DataControlField.cs
- OleDbDataReader.cs
- MenuScrollingVisibilityConverter.cs
- DecimalFormatter.cs