Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / BufferedConnection.cs / 1 / BufferedConnection.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Channels { using System.Collections.Generic; using System.ServiceModel; using System.IO; using System.Text; class BufferedConnection : DelegatingConnection { byte[] writeBuffer; int writeBufferSize; int pendingWriteSize; Exception pendingWriteException; IOThreadTimer flushTimer; long flushTimeout; TimeSpan pendingTimeout; const int maxFlushSkew = 100; public BufferedConnection(IConnection connection, TimeSpan flushTimeout, int writeBufferSize) : base(connection) { this.flushTimeout = Ticks.FromTimeSpan(flushTimeout); this.writeBufferSize = writeBufferSize; } object ThisLock { get { return this; } } public override void Close(TimeSpan timeout) { TimeoutHelper timeoutHelper = new TimeoutHelper(timeout); Flush(timeoutHelper.RemainingTime()); base.Close(timeoutHelper.RemainingTime()); } void CancelFlushTimer() { if (flushTimer != null) { flushTimer.Cancel(); pendingTimeout = TimeSpan.Zero; } } void Flush(TimeSpan timeout) { ThrowPendingWriteException(); lock (ThisLock) { FlushCore(timeout); } } void FlushCore(TimeSpan timeout) { if (pendingWriteSize > 0) { ThreadTrace.Trace("BC:Flush"); Connection.Write(writeBuffer, 0, pendingWriteSize, false, timeout); pendingWriteSize = 0; } } void OnFlushTimer(object state) { ThreadTrace.Trace("BC:Flush timer"); lock (ThisLock) { try { FlushCore(pendingTimeout); pendingTimeout = TimeSpan.Zero; } catch (Exception e) { if (DiagnosticUtility.IsFatal(e)) { throw; } pendingWriteException = e; CancelFlushTimer(); } } } void SetFlushTimer() { if (flushTimer == null) { int flushSkew = Ticks.ToMilliseconds(Math.Min(flushTimeout / 10, Ticks.FromMilliseconds(maxFlushSkew))); flushTimer = new IOThreadTimer(OnFlushTimer, null, true, flushSkew); } flushTimer.Set(Ticks.ToTimeSpan(flushTimeout)); } public override void Write(byte[] buffer, int offset, int size, bool immediate, TimeSpan timeout, BufferManager bufferManager) { if (size <= 0) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentOutOfRangeException("size", size, SR.GetString( SR.ValueMustBePositive))); } ThrowPendingWriteException(); if (immediate || flushTimeout == 0) { ThreadTrace.Trace("BC:Write now"); WriteNow(buffer, offset, size, timeout, bufferManager); } else { ThreadTrace.Trace("BC:Write later"); WriteLater(buffer, offset, size, timeout); bufferManager.ReturnBuffer(buffer); } ThreadTrace.Trace("BC:Write done"); } public override void Write(byte[] buffer, int offset, int size, bool immediate, TimeSpan timeout) { if (size <= 0) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentOutOfRangeException("size", size, SR.GetString( SR.ValueMustBePositive))); } ThrowPendingWriteException(); if (immediate || flushTimeout == 0) { ThreadTrace.Trace("BC:Write now"); WriteNow(buffer, offset, size, timeout); } else { ThreadTrace.Trace("BC:Write later"); WriteLater(buffer, offset, size, timeout); } ThreadTrace.Trace("BC:Write done"); } void WriteNow(byte[] buffer, int offset, int size, TimeSpan timeout) { WriteNow(buffer, offset, size, timeout, null); } void WriteNow(byte[] buffer, int offset, int size, TimeSpan timeout, BufferManager bufferManager) { lock (ThisLock) { if (pendingWriteSize > 0) { int remainingSize = writeBufferSize - pendingWriteSize; CancelFlushTimer(); if (size <= remainingSize) { Buffer.BlockCopy(buffer, offset, writeBuffer, pendingWriteSize, size); if (bufferManager != null) { bufferManager.ReturnBuffer(buffer); } pendingWriteSize += size; FlushCore(timeout); return; } else { TimeoutHelper timeoutHelper = new TimeoutHelper(timeout); FlushCore(timeoutHelper.RemainingTime()); timeout = timeoutHelper.RemainingTime(); } } if (bufferManager == null) { Connection.Write(buffer, offset, size, true, timeout); } else { Connection.Write(buffer, offset, size, true, timeout, bufferManager); } } } void WriteLater(byte[] buffer, int offset, int size, TimeSpan timeout) { lock (ThisLock) { bool setTimer = (pendingWriteSize == 0); TimeoutHelper timeoutHelper = new TimeoutHelper(timeout); while (size > 0) { if (size >= writeBufferSize && pendingWriteSize == 0) { Connection.Write(buffer, offset, size, false, timeoutHelper.RemainingTime()); size = 0; } else { if (writeBuffer == null) { writeBuffer = DiagnosticUtility.Utility.AllocateByteArray(writeBufferSize); } int remainingSize = writeBufferSize - pendingWriteSize; int copySize = size; if (copySize > remainingSize) { copySize = remainingSize; } Buffer.BlockCopy(buffer, offset, writeBuffer, pendingWriteSize, copySize); pendingWriteSize += copySize; if (pendingWriteSize == writeBufferSize) { FlushCore(timeoutHelper.RemainingTime()); setTimer = true; } size -= copySize; offset += copySize; } } if (pendingWriteSize > 0) { if (setTimer) { SetFlushTimer(); pendingTimeout = TimeoutHelper.Add(pendingTimeout, timeoutHelper.RemainingTime()); } } else { CancelFlushTimer(); } } } public override IAsyncResult BeginWrite(byte[] buffer, int offset, int size, bool immediate, TimeSpan timeout, AsyncCallback callback, object state) { ThreadTrace.Trace("BC:BeginWrite"); TimeoutHelper timeoutHelper = new TimeoutHelper(timeout); Flush(timeoutHelper.RemainingTime()); return base.BeginWrite(buffer, offset, size, immediate, timeoutHelper.RemainingTime(), callback, state); } public override void EndWrite(IAsyncResult result) { ThreadTrace.Trace("BC:EndWrite"); base.EndWrite(result); } public override void Shutdown(TimeSpan timeout) { TimeoutHelper timeoutHelper = new TimeoutHelper(timeout); Flush(timeoutHelper.RemainingTime()); base.Shutdown(timeoutHelper.RemainingTime()); } void ThrowPendingWriteException() { if (pendingWriteException != null) { lock (ThisLock) { if (pendingWriteException != null) { Exception exceptionTothrow = pendingWriteException; pendingWriteException = null; throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(exceptionTothrow); } } } } } class BufferedConnectionInitiator : IConnectionInitiator { int writeBufferSize; TimeSpan flushTimeout; IConnectionInitiator connectionInitiator; public BufferedConnectionInitiator(IConnectionInitiator connectionInitiator, TimeSpan flushTimeout, int writeBufferSize) { this.connectionInitiator = connectionInitiator; this.flushTimeout = flushTimeout; this.writeBufferSize = writeBufferSize; } protected TimeSpan FlushTimeout { get { return this.flushTimeout; } } protected int WriteBufferSize { get { return this.writeBufferSize; } } public IConnection Connect(Uri uri, TimeSpan timeout) { return new BufferedConnection(connectionInitiator.Connect(uri, timeout), flushTimeout, writeBufferSize); } public IAsyncResult BeginConnect(Uri uri, TimeSpan timeout, AsyncCallback callback, object state) { return connectionInitiator.BeginConnect(uri, timeout, callback, state); } public IConnection EndConnect(IAsyncResult result) { return new BufferedConnection(connectionInitiator.EndConnect(result), flushTimeout, writeBufferSize); } } class BufferedConnectionListener : IConnectionListener { int writeBufferSize; TimeSpan flushTimeout; IConnectionListener connectionListener; public BufferedConnectionListener(IConnectionListener connectionListener, TimeSpan flushTimeout, int writeBufferSize) { this.connectionListener = connectionListener; this.flushTimeout = flushTimeout; this.writeBufferSize = writeBufferSize; } public void Dispose() { connectionListener.Dispose(); } public void Listen() { connectionListener.Listen(); } public IAsyncResult BeginAccept(AsyncCallback callback, object state) { return connectionListener.BeginAccept(callback, state); } public IConnection EndAccept(IAsyncResult result) { IConnection connection = connectionListener.EndAccept(result); if (connection == null) { return connection; } return new BufferedConnection(connection, flushTimeout, writeBufferSize); } } } // 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
- DynamicILGenerator.cs
- TextParagraph.cs
- SystemInfo.cs
- VirtualizingStackPanel.cs
- wgx_exports.cs
- XslCompiledTransform.cs
- SecurityRuntime.cs
- LoginStatusDesigner.cs
- SizeKeyFrameCollection.cs
- OleDbInfoMessageEvent.cs
- fixedPageContentExtractor.cs
- CompilerState.cs
- MethodBuilderInstantiation.cs
- SlipBehavior.cs
- ProfileProvider.cs
- QueryConverter.cs
- AmbiguousMatchException.cs
- WeakRefEnumerator.cs
- Command.cs
- IpcServerChannel.cs
- AsymmetricAlgorithm.cs
- MessageEnumerator.cs
- SqlUserDefinedAggregateAttribute.cs
- ConditionCollection.cs
- ReferencedType.cs
- PersonalizableAttribute.cs
- PointHitTestParameters.cs
- SingleAnimationBase.cs
- ForwardPositionQuery.cs
- SecurityProtocolCorrelationState.cs
- ColorContext.cs
- objectquery_tresulttype.cs
- OperatingSystem.cs
- assemblycache.cs
- DesignerActionItem.cs
- ActiveXSite.cs
- XPathNodeHelper.cs
- GenerateTemporaryTargetAssembly.cs
- DataGridViewColumnStateChangedEventArgs.cs
- EncoderNLS.cs
- StrokeCollection.cs
- AnnotationService.cs
- XamlSerializer.cs
- AppModelKnownContentFactory.cs
- X509ScopedServiceCertificateElementCollection.cs
- ChannelManager.cs
- AnnotationAdorner.cs
- SqlDataRecord.cs
- PenThreadPool.cs
- ValueOfAction.cs
- SQLResource.cs
- SafeViewOfFileHandle.cs
- DrawingCollection.cs
- WasEndpointConfigContainer.cs
- TypeUsageBuilder.cs
- ChannelSinkStacks.cs
- Expression.cs
- ConfigurationSchemaErrors.cs
- SqlConnectionManager.cs
- XmlSchemaProviderAttribute.cs
- KeyConstraint.cs
- ConstraintConverter.cs
- CreationContext.cs
- TimeStampChecker.cs
- TypeUtil.cs
- Activator.cs
- ImageListUtils.cs
- DataKeyArray.cs
- CodeAccessPermission.cs
- ImageAutomationPeer.cs
- mediaclock.cs
- PlainXmlWriter.cs
- ResetableIterator.cs
- StringUtil.cs
- LocalFileSettingsProvider.cs
- DataGridViewCellStyleChangedEventArgs.cs
- DesignTimeTemplateParser.cs
- CompositionCommandSet.cs
- FullTextLine.cs
- SqlCommandAsyncResult.cs
- ContainerUtilities.cs
- IconHelper.cs
- CanonicalFormWriter.cs
- ResXResourceSet.cs
- MarshalByRefObject.cs
- IndentedWriter.cs
- ProcessInfo.cs
- KeySpline.cs
- XmlILModule.cs
- MsmqIntegrationBindingElement.cs
- SByteStorage.cs
- DataGridViewSelectedCellCollection.cs
- GCHandleCookieTable.cs
- GenericPrincipal.cs
- StrongNameMembershipCondition.cs
- Application.cs
- FrameworkContentElement.cs
- OLEDB_Enum.cs
- AppDomainManager.cs
- MemberCollection.cs