Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / ConnectionModeReader.cs / 1 / ConnectionModeReader.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Channels { using System.Threading; using System.ServiceModel; using System.Collections.Generic; using System.Diagnostics; delegate void ConnectionModeCallback(ConnectionModeReader connectionModeReader); sealed class ConnectionModeReader : InitialServerConnectionReader { Exception readException; ServerModeDecoder decoder; byte[] buffer; int offset; int size; ConnectionModeCallback callback; static WaitCallback readCallback; TimeoutHelper receiveTimeoutHelper; public ConnectionModeReader(IConnection connection, ConnectionModeCallback callback, ConnectionClosedCallback closedCallback) : base(connection, closedCallback) { this.callback = callback; } public int BufferOffset { get { return offset; } } public int BufferSize { get { return size; } } public long StreamPosition { get { return decoder.StreamPosition; } } public TimeSpan GetRemainingTimeout() { return this.receiveTimeoutHelper.RemainingTime(); } void Complete(Exception e) { // exception will be logged by the caller readException = e; Complete(); } void Complete() { callback(this); } bool ContinueReading() { for (; ; ) { if (size == 0) { if (readCallback == null) { readCallback = new WaitCallback(ReadCallback); } if (Connection.BeginRead(0, Connection.AsyncReadBufferSize, GetRemainingTimeout(), readCallback, this) == AsyncReadResult.Queued) { break; } if (!GetReadResult()) // we're at EOF, bail { return false; } } for (; ; ) { int bytesDecoded; try { bytesDecoded = decoder.Decode(buffer, offset, size); } catch (CommunicationException e) { // see if we need to send back a framing fault string framingFault; if (FramingEncodingString.TryGetFaultString(e, out framingFault)) { byte[] drainBuffer = new byte[128]; InitialServerConnectionReader.SendFault( Connection, framingFault, drainBuffer, GetRemainingTimeout(), MaxViaSize + MaxContentTypeSize); base.Close(GetRemainingTimeout()); } throw; } if (bytesDecoded > 0) { offset += bytesDecoded; size -= bytesDecoded; } if (decoder.CurrentState == ServerModeDecoder.State.Done) { return true; } if (size == 0) { break; } } } return false; } static void ReadCallback(object state) { ConnectionModeReader reader = (ConnectionModeReader)state; bool completeSelf = false; Exception completionException = null; try { if (reader.GetReadResult()) { completeSelf = reader.ContinueReading(); } } #pragma warning suppress 56500 // [....], transferring exception to caller catch (Exception e) { if (DiagnosticUtility.IsFatal(e)) { throw; } completeSelf = true; completionException = e; } if (completeSelf) { reader.Complete(completionException); } } bool GetReadResult() { offset = 0; size = Connection.EndRead(); if (size == 0) { if (this.decoder.StreamPosition == 0) // client timed out a cached connection { base.Close(GetRemainingTimeout()); return false; } else { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(decoder.CreatePrematureEOFException()); } } // restore ExceptionEventType to Error after the initial read for cached connections Connection.ExceptionEventType = TraceEventType.Error; if (buffer == null) { buffer = Connection.AsyncReadBuffer; } return true; } public FramingMode GetConnectionMode() { if (readException != null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelper(readException, Connection.ExceptionEventType); } return decoder.Mode; } public void StartReading(TimeSpan receiveTimeout, ItemDequeuedCallback connectionDequeuedCallback) { this.decoder = new ServerModeDecoder(); this.receiveTimeoutHelper = new TimeoutHelper(receiveTimeout); this.ConnectionDequeuedCallback = connectionDequeuedCallback; bool completeSelf = false; Exception completionException = null; try { completeSelf = ContinueReading(); } #pragma warning suppress 56500 // [....], transferring exception to caller catch (Exception e) { if (DiagnosticUtility.IsFatal(e)) { throw; } completeSelf = true; completionException = e; } if (completeSelf) { Complete(completionException); } } } } // 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
- WebDescriptionAttribute.cs
- ToolStripRenderer.cs
- MyContact.cs
- ListBox.cs
- MapPathBasedVirtualPathProvider.cs
- SqlSelectStatement.cs
- ErrorLog.cs
- NominalTypeEliminator.cs
- StackSpiller.Temps.cs
- ReadOnlyObservableCollection.cs
- DecimalAnimationBase.cs
- RoutedUICommand.cs
- SvcMapFile.cs
- XmlSchemaAny.cs
- DataGridViewCellStyleChangedEventArgs.cs
- CaretElement.cs
- DummyDataSource.cs
- UpdateExpressionVisitor.cs
- designeractionbehavior.cs
- ExpressionBuilder.cs
- UInt64Storage.cs
- NavigatingCancelEventArgs.cs
- StorageEntityContainerMapping.cs
- CollectionsUtil.cs
- LinearKeyFrames.cs
- StyleBamlTreeBuilder.cs
- ReferenceConverter.cs
- URLAttribute.cs
- AvtEvent.cs
- EventMap.cs
- OleDbConnection.cs
- XhtmlBasicCommandAdapter.cs
- ToolStripProfessionalLowResolutionRenderer.cs
- TextParagraphView.cs
- TaskFormBase.cs
- RenamedEventArgs.cs
- HistoryEventArgs.cs
- FormsAuthenticationEventArgs.cs
- MouseBinding.cs
- ObjectListFieldsPage.cs
- MediaElementAutomationPeer.cs
- ColumnCollectionEditor.cs
- DockAndAnchorLayout.cs
- OletxDependentTransaction.cs
- VerificationException.cs
- ClockController.cs
- ListViewDesigner.cs
- GridPatternIdentifiers.cs
- Expression.cs
- XmlBinaryWriterSession.cs
- GridViewUpdateEventArgs.cs
- HostedElements.cs
- Literal.cs
- DependencyObject.cs
- GridViewColumnHeader.cs
- BindingExpressionBase.cs
- FontFamily.cs
- Viewport3DAutomationPeer.cs
- Token.cs
- XLinq.cs
- WebConfigurationManager.cs
- SymbolTable.cs
- DynamicPropertyReader.cs
- DocumentOrderQuery.cs
- X509Certificate2Collection.cs
- FixedSOMTableRow.cs
- TextElementEditingBehaviorAttribute.cs
- PropertyMapper.cs
- DoubleLink.cs
- XPathParser.cs
- ListenerSessionConnection.cs
- TextHidden.cs
- BaseProcessor.cs
- ToolstripProfessionalRenderer.cs
- DataGridHeadersVisibilityToVisibilityConverter.cs
- FullTextBreakpoint.cs
- DesignerHost.cs
- MultilineStringConverter.cs
- DataGridViewColumnCollection.cs
- NegotiateStream.cs
- FunctionMappingTranslator.cs
- OdbcConnectionStringbuilder.cs
- ReadOnlyNameValueCollection.cs
- NameSpaceExtractor.cs
- MouseEvent.cs
- LinkDesigner.cs
- Duration.cs
- MasterPage.cs
- StreamGeometry.cs
- SoapAttributeAttribute.cs
- HierarchicalDataSourceControl.cs
- PasswordPropertyTextAttribute.cs
- InternalConfigEventArgs.cs
- ISO2022Encoding.cs
- OracleSqlParser.cs
- MsmqIntegrationProcessProtocolHandler.cs
- BaseDataBoundControl.cs
- CssClassPropertyAttribute.cs
- ImportRequest.cs
- SatelliteContractVersionAttribute.cs