Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / System.Runtime.DurableInstancing / System / Runtime / BufferedOutputStream.cs / 1305376 / BufferedOutputStream.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.Runtime { using System; using System.Globalization; using System.IO; class BufferedOutputStream : Stream { [Fx.Tag.Cache(typeof(byte), Fx.Tag.CacheAttrition.None, Scope = Fx.Tag.Strings.ExternallyManaged, SizeLimit = Fx.Tag.Strings.ExternallyManaged)] InternalBufferManager bufferManager; [Fx.Tag.Queue(typeof(byte), SizeLimit = "BufferedOutputStream(maxSize)", StaleElementsRemovedImmediately = true, EnqueueThrowsIfFull = true)] byte[][] chunks; int chunkCount; byte[] currentChunk; int currentChunkSize; int maxSize; int maxSizeQuota; int totalSize; bool callerReturnsBuffer; bool bufferReturned; bool initialized; // requires an explicit call to Init() by the caller public BufferedOutputStream() { this.chunks = new byte[4][]; } public BufferedOutputStream(int initialSize, int maxSize, InternalBufferManager bufferManager) : this() { Reinitialize(initialSize, maxSize, bufferManager); } public BufferedOutputStream(int maxSize) : this(0, maxSize, InternalBufferManager.Create(0, int.MaxValue)) { } public override bool CanRead { get { return false; } } public override bool CanSeek { get { return false; } } public override bool CanWrite { get { return true; } } public override long Length { get { return this.totalSize; } } public override long Position { get { throw Fx.Exception.AsError(new NotSupportedException(SRCore.SeekNotSupported)); } set { throw Fx.Exception.AsError(new NotSupportedException(SRCore.SeekNotSupported)); } } public void Reinitialize(int initialSize, int maxSizeQuota, InternalBufferManager bufferManager) { Reinitialize(initialSize, maxSizeQuota, maxSizeQuota, bufferManager); } public void Reinitialize(int initialSize, int maxSizeQuota, int effectiveMaxSize, InternalBufferManager bufferManager) { Fx.Assert(!this.initialized, "Clear must be called before re-initializing stream"); this.maxSizeQuota = maxSizeQuota; this.maxSize = effectiveMaxSize; this.bufferManager = bufferManager; this.currentChunk = bufferManager.TakeBuffer(initialSize); this.currentChunkSize = 0; this.totalSize = 0; this.chunkCount = 1; this.chunks[0] = this.currentChunk; this.initialized = true; } void AllocNextChunk(int minimumChunkSize) { int newChunkSize; if (this.currentChunk.Length > (int.MaxValue / 2)) { newChunkSize = int.MaxValue; } else { newChunkSize = this.currentChunk.Length * 2; } if (minimumChunkSize > newChunkSize) { newChunkSize = minimumChunkSize; } byte[] newChunk = this.bufferManager.TakeBuffer(newChunkSize); if (this.chunkCount == this.chunks.Length) { byte[][] newChunks = new byte[this.chunks.Length * 2][]; Array.Copy(this.chunks, newChunks, this.chunks.Length); this.chunks = newChunks; } this.chunks[this.chunkCount++] = newChunk; this.currentChunk = newChunk; this.currentChunkSize = 0; } public override IAsyncResult BeginRead(byte[] buffer, int offset, int size, AsyncCallback callback, object state) { throw Fx.Exception.AsError(new NotSupportedException(SRCore.ReadNotSupported)); } public override int EndRead(IAsyncResult result) { throw Fx.Exception.AsError(new NotSupportedException(SRCore.ReadNotSupported)); } public override IAsyncResult BeginWrite(byte[] buffer, int offset, int size, AsyncCallback callback, object state) { Write(buffer, offset, size); return new CompletedAsyncResult(callback, state); } public override void EndWrite(IAsyncResult result) { CompletedAsyncResult.End(result); } public void Clear() { if (!this.callerReturnsBuffer) { for (int i = 0; i < this.chunkCount; i++) { this.bufferManager.ReturnBuffer(this.chunks[i]); this.chunks[i] = null; } } this.callerReturnsBuffer = false; this.initialized = false; this.bufferReturned = false; this.chunkCount = 0; this.currentChunk = null; } public override void Close() { } public override void Flush() { } public override int Read(byte[] buffer, int offset, int size) { throw Fx.Exception.AsError(new NotSupportedException(SRCore.ReadNotSupported)); } public override int ReadByte() { throw Fx.Exception.AsError(new NotSupportedException(SRCore.ReadNotSupported)); } public override long Seek(long offset, SeekOrigin origin) { throw Fx.Exception.AsError(new NotSupportedException(SRCore.SeekNotSupported)); } public override void SetLength(long value) { throw Fx.Exception.AsError(new NotSupportedException(SRCore.SeekNotSupported)); } public MemoryStream ToMemoryStream() { int bufferSize; byte[] buffer = ToArray(out bufferSize); return new MemoryStream(buffer, 0, bufferSize); } public byte[] ToArray(out int bufferSize) { Fx.Assert(this.initialized, "No data to return from uninitialized stream"); Fx.Assert(!this.bufferReturned, "ToArray cannot be called more than once"); byte[] buffer; if (this.chunkCount == 1) { buffer = this.currentChunk; bufferSize = this.currentChunkSize; this.callerReturnsBuffer = true; } else { buffer = this.bufferManager.TakeBuffer(this.totalSize); int offset = 0; int count = this.chunkCount - 1; for (int i = 0; i < count; i++) { byte[] chunk = this.chunks[i]; Buffer.BlockCopy(chunk, 0, buffer, offset, chunk.Length); offset += chunk.Length; } Buffer.BlockCopy(this.currentChunk, 0, buffer, offset, this.currentChunkSize); bufferSize = this.totalSize; } this.bufferReturned = true; return buffer; } public void Skip(int size) { WriteCore(null, 0, size); } public override void Write(byte[] buffer, int offset, int size) { WriteCore(buffer, offset, size); } protected virtual Exception CreateQuotaExceededException(int maxSizeQuota) { return new InvalidOperationException(SRCore.BufferedOutputStreamQuotaExceeded(maxSizeQuota)); } void WriteCore(byte[] buffer, int offset, int size) { Fx.Assert(this.initialized, "Cannot write to uninitialized stream"); Fx.Assert(!this.bufferReturned, "Cannot write to stream once ToArray has been called."); if (size < 0) { throw Fx.Exception.ArgumentOutOfRange("size", size, SRCore.ValueMustBeNonNegative); } if ((int.MaxValue - size) < this.totalSize) { throw Fx.Exception.AsError(CreateQuotaExceededException(this.maxSizeQuota)); } int newTotalSize = this.totalSize + size; if (newTotalSize > this.maxSize) { throw Fx.Exception.AsError(CreateQuotaExceededException(this.maxSizeQuota)); } int remainingSizeInChunk = this.currentChunk.Length - this.currentChunkSize; if (size > remainingSizeInChunk) { if (remainingSizeInChunk > 0) { if (buffer != null) { Buffer.BlockCopy(buffer, offset, this.currentChunk, this.currentChunkSize, remainingSizeInChunk); } this.currentChunkSize = this.currentChunk.Length; offset += remainingSizeInChunk; size -= remainingSizeInChunk; } AllocNextChunk(size); } if (buffer != null) { Buffer.BlockCopy(buffer, offset, this.currentChunk, this.currentChunkSize, size); } this.totalSize = newTotalSize; this.currentChunkSize += size; } public override void WriteByte(byte value) { Fx.Assert(this.initialized, "Cannot write to uninitialized stream"); Fx.Assert(!this.bufferReturned, "Cannot write to stream once ToArray has been called."); if (this.totalSize == this.maxSize) { throw Fx.Exception.AsError(CreateQuotaExceededException(this.maxSize)); } if (this.currentChunkSize == this.currentChunk.Length) { AllocNextChunk(1); } this.currentChunk[this.currentChunkSize++] = value; } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- GeneralTransform2DTo3D.cs
- DataTableExtensions.cs
- DefaultTextStore.cs
- NullExtension.cs
- NativeWrapper.cs
- BaseCAMarshaler.cs
- BuiltInPermissionSets.cs
- ShapingEngine.cs
- PageWrapper.cs
- ComponentDesigner.cs
- CheckBoxPopupAdapter.cs
- Vector3DAnimation.cs
- _Rfc2616CacheValidators.cs
- MultipartContentParser.cs
- ComponentCache.cs
- Cursors.cs
- TemplateBamlTreeBuilder.cs
- AmbientEnvironment.cs
- FlowDocumentReader.cs
- StringComparer.cs
- DataGridViewColumnDesignTimeVisibleAttribute.cs
- FixedPageStructure.cs
- Utils.cs
- TreeViewImageIndexConverter.cs
- SmtpMail.cs
- DrawingGroupDrawingContext.cs
- Set.cs
- XhtmlBasicLinkAdapter.cs
- DataGridViewElement.cs
- EventMap.cs
- Win32Native.cs
- ListDataHelper.cs
- RadioButtonFlatAdapter.cs
- InternalBufferOverflowException.cs
- TypeDependencyAttribute.cs
- TabItemAutomationPeer.cs
- WorkingDirectoryEditor.cs
- WebPartDeleteVerb.cs
- FileReader.cs
- BitmapMetadataBlob.cs
- UnsafeMethods.cs
- RawTextInputReport.cs
- ThumbButtonInfo.cs
- Model3DGroup.cs
- DefaultValueAttribute.cs
- SqlMethodCallConverter.cs
- XmlSchemaGroup.cs
- DelegatedStream.cs
- DataSetUtil.cs
- EventListenerClientSide.cs
- MatchingStyle.cs
- ServiceMoniker.cs
- InheritablePropertyChangeInfo.cs
- CompilerHelpers.cs
- SqlGenericUtil.cs
- ToolStripButton.cs
- IpcClientChannel.cs
- CacheAxisQuery.cs
- CrossAppDomainChannel.cs
- XmlNullResolver.cs
- RoutingTable.cs
- XsltSettings.cs
- messageonlyhwndwrapper.cs
- XmlAttribute.cs
- InstanceHandle.cs
- TextTreeDeleteContentUndoUnit.cs
- PropertyBuilder.cs
- SiteMapPath.cs
- WebUtil.cs
- WorkflowQueue.cs
- ProgressBar.cs
- SqlRowUpdatingEvent.cs
- Mutex.cs
- TableRowGroup.cs
- ResourceDefaultValueAttribute.cs
- AccessKeyManager.cs
- SafeNativeMethodsMilCoreApi.cs
- QuadraticBezierSegment.cs
- HtmlInputButton.cs
- CompareInfo.cs
- CollectionBuilder.cs
- InheritanceContextChangedEventManager.cs
- WorkerRequest.cs
- QueryGenerator.cs
- BaseCodePageEncoding.cs
- ByteStream.cs
- SQLMembershipProvider.cs
- XPathScanner.cs
- SoapObjectInfo.cs
- ChangeProcessor.cs
- Point3DConverter.cs
- HelpEvent.cs
- CodeSnippetStatement.cs
- ElementNotEnabledException.cs
- BrowserTree.cs
- BuildProvidersCompiler.cs
- NumericUpDown.cs
- AuthorizationContext.cs
- NamespaceCollection.cs
- ExpandCollapsePattern.cs