Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / SMSvcHost / System / ServiceModel / Activation / DupHandleConnectionReader.cs / 1 / DupHandleConnectionReader.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Activation { using System; using System.Diagnostics; using System.IO; using System.ServiceModel; using System.ServiceModel.Channels; using System.Threading; using System.ServiceModel.Activation.Diagnostics; // This class takes a connection, reads enough so that we can dispatch it to another process, // and then hands off the connection. This is done for all non-multiplexed modes (singleton, duplex, simplex) abstract class DupHandleConnectionReader : InitialServerConnectionReader { byte[] connectionBuffer; ViaDecodedCallback viaDecodedCallback; byte[] dataRead; int offset; static WaitCallback readCallback; int size; TransportType transportType; TimeoutHelper receiveTimeoutHelper; protected DupHandleConnectionReader(IConnection connection, ItemDequeuedCallback connectionDequeuedCallback, TransportType transportType, int offset, int size, ConnectionClosedCallback closedCallback, ViaDecodedCallback viaDecodedCallback) : base(connection, closedCallback, ListenerConstants.MaxUriSize, ListenerConstants.SharedMaxContentTypeSize) { this.transportType = transportType; this.offset = offset; this.size = size; this.viaDecodedCallback = viaDecodedCallback; this.ConnectionDequeuedCallback = connectionDequeuedCallback; } TimeSpan GetRemainingTimeout() { return this.receiveTimeoutHelper.RemainingTime(); } void AbortAndCount(Exception exception) { if (transportType == TransportType.Tcp) { ListenerPerfCounters.IncrementProtocolFailuresTcp(); } else if (transportType == TransportType.NamedPipe) { ListenerPerfCounters.IncrementProtocolFailuresNamedPipe(); } base.Abort(exception); } protected abstract bool CanDupHandle(out Uri viaString); void ContinueReading() { try { for (; ; ) { if (size == 0) { if (readCallback == null) readCallback = ReadCallback; if (Connection.BeginRead(0, connectionBuffer.Length, GetRemainingTimeout(), readCallback, this) == AsyncReadResult.Queued) { break; } GetReadResult(); } DiagnosticUtility.DebugAssert(size > 0, ""); for (; ; ) { int bytesDecoded = Decode(connectionBuffer, offset, size); if (bytesDecoded > 0) { offset += bytesDecoded; size -= bytesDecoded; } Uri via = null; if (CanDupHandle(out via)) { ListenerSessionConnection session = new ListenerSessionConnection( this.Connection, this.dataRead, via, this.GetConnectionDequeuedCallback()); viaDecodedCallback(this, session); this.ReleaseConnection(); return; } if (size == 0) break; } } } catch (Exception e) { if (DiagnosticUtility.IsFatal(e)) { throw; } AbortAndCount(e); } } protected abstract int Decode(byte[] buffer, int offset, int size); protected abstract Exception CreatePrematureEOFException(); void GetReadResult() { offset = 0; size = Connection.EndRead(); if (size == 0) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(CreatePrematureEOFException()); } else { // update our snapshot of data to shuttle over to the target process byte[] newDataRead = new byte[dataRead.Length + size]; Buffer.BlockCopy(dataRead, 0, newDataRead, 0, dataRead.Length); Buffer.BlockCopy(connectionBuffer, 0, newDataRead, this.dataRead.Length, size); dataRead = newDataRead; } } static void ReadCallback(object state) { DupHandleConnectionReader reader = (DupHandleConnectionReader)state; try { reader.GetReadResult(); reader.ContinueReading(); } catch (Exception e) { if (DiagnosticUtility.IsFatal(e)) { throw; } reader.AbortAndCount(e); } } public void StartReading(byte[] accruedData, TimeSpan timeout) { int accruedDataOffset = 0; this.receiveTimeoutHelper = new TimeoutHelper(timeout); if (accruedData != null) { this.dataRead = new byte[accruedData.Length + offset + size]; Buffer.BlockCopy(accruedData, 0, this.dataRead, 0, accruedData.Length); accruedDataOffset = accruedData.Length; } else { this.dataRead = new byte[offset + size]; } this.connectionBuffer = Connection.AsyncReadBuffer; Buffer.BlockCopy(this.connectionBuffer, 0, dataRead, accruedDataOffset, offset + size); ContinueReading(); } } } // 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
- TaskHelper.cs
- SchemaReference.cs
- TreeNodeBinding.cs
- linebase.cs
- BinaryWriter.cs
- TransactionFlowElement.cs
- LayoutEditorPart.cs
- DesignConnectionCollection.cs
- CharacterString.cs
- ToolStripDropDownClosedEventArgs.cs
- BuildProvider.cs
- TemplateField.cs
- CorrelationTokenTypeConvertor.cs
- SqlProviderServices.cs
- LassoHelper.cs
- RequestStatusBarUpdateEventArgs.cs
- CodeRegionDirective.cs
- OperatingSystem.cs
- AuthenticationConfig.cs
- BrushValueSerializer.cs
- PasswordDeriveBytes.cs
- SqlDataSourceSelectingEventArgs.cs
- ProgressBarRenderer.cs
- SecurityIdentifierConverter.cs
- CancelEventArgs.cs
- TypeElement.cs
- SpeechEvent.cs
- DashStyles.cs
- BypassElementCollection.cs
- HelpProvider.cs
- DataSetUtil.cs
- RemotingSurrogateSelector.cs
- CompositeTypefaceMetrics.cs
- JavaScriptObjectDeserializer.cs
- TextEmbeddedObject.cs
- PolyQuadraticBezierSegmentFigureLogic.cs
- InvalidProgramException.cs
- CharacterBufferReference.cs
- DataSourceListEditor.cs
- ProtectedConfigurationSection.cs
- PathParser.cs
- EntityDataSourceEntityTypeFilterItem.cs
- TextEditorDragDrop.cs
- WebEvents.cs
- keycontainerpermission.cs
- RequestSecurityTokenSerializer.cs
- ModulesEntry.cs
- PKCS1MaskGenerationMethod.cs
- AssemblyBuilder.cs
- CertificateReferenceElement.cs
- CounterSample.cs
- Padding.cs
- InstanceHandle.cs
- BitVector32.cs
- COM2ComponentEditor.cs
- EventPrivateKey.cs
- DataSourceCache.cs
- HttpCapabilitiesEvaluator.cs
- WebExceptionStatus.cs
- EmptyElement.cs
- odbcmetadatacollectionnames.cs
- LineVisual.cs
- BindingMemberInfo.cs
- WebPartsPersonalization.cs
- ConnectorRouter.cs
- JsonReaderWriterFactory.cs
- PathFigureCollectionConverter.cs
- OuterGlowBitmapEffect.cs
- WebPartConnectionsConfigureVerb.cs
- RtfToXamlLexer.cs
- updatecommandorderer.cs
- MailHeaderInfo.cs
- AccessDataSourceView.cs
- MenuBindingsEditorForm.cs
- DCSafeHandle.cs
- DrawingBrush.cs
- CodeMemberMethod.cs
- JournalEntryListConverter.cs
- CodeTypeDeclarationCollection.cs
- HostProtectionPermission.cs
- Translator.cs
- TraceHwndHost.cs
- _SSPISessionCache.cs
- CellTreeSimplifier.cs
- CallbackWrapper.cs
- GlyphCollection.cs
- DataStreamFromComStream.cs
- SolidBrush.cs
- ValueProviderWrapper.cs
- WebPartEditorOkVerb.cs
- LineBreakRecord.cs
- InstanceDescriptor.cs
- PrintingPermissionAttribute.cs
- Popup.cs
- DictionaryEntry.cs
- DataGridAddNewRow.cs
- AutoResetEvent.cs
- RegistrySecurity.cs
- ActivityMarkupSerializationProvider.cs
- RoleGroup.cs