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
- PasswordRecovery.cs
- StorageSetMapping.cs
- OletxResourceManager.cs
- Bind.cs
- _DomainName.cs
- CustomAssemblyResolver.cs
- AutomationFocusChangedEventArgs.cs
- ViewStateModeByIdAttribute.cs
- BrushMappingModeValidation.cs
- State.cs
- RedistVersionInfo.cs
- FileDialog.cs
- BatchStream.cs
- PersonalizationStateQuery.cs
- SoapAttributeOverrides.cs
- AndCondition.cs
- ConfigurationManager.cs
- ProxyGenerator.cs
- CodeGenerator.cs
- CollectionViewProxy.cs
- ClonableStack.cs
- Avt.cs
- IProvider.cs
- ToolStripPanel.cs
- NumericUpDownAccelerationCollection.cs
- IntegerValidatorAttribute.cs
- RoleGroup.cs
- InvalidCommandTreeException.cs
- TypeLibConverter.cs
- Exceptions.cs
- TagNameToTypeMapper.cs
- RegexTypeEditor.cs
- EntityTypeBase.cs
- FactoryGenerator.cs
- ProjectionAnalyzer.cs
- ControlPager.cs
- XmlSchemaExternal.cs
- ArrangedElement.cs
- SelectionEditingBehavior.cs
- SqlBulkCopy.cs
- SecurityPermission.cs
- CmsInterop.cs
- ExpandoClass.cs
- DataGridPagerStyle.cs
- Typography.cs
- ExpressionDumper.cs
- ToolStripDropTargetManager.cs
- DataBindingHandlerAttribute.cs
- controlskin.cs
- OneOfConst.cs
- HttpEncoder.cs
- InvalidDocumentContentsException.cs
- ExpandCollapseProviderWrapper.cs
- TransportChannelFactory.cs
- PeerCollaborationPermission.cs
- XmlSecureResolver.cs
- LessThanOrEqual.cs
- TreeSet.cs
- EntityCommandCompilationException.cs
- SystemIPAddressInformation.cs
- RawStylusInputReport.cs
- ScriptResourceDefinition.cs
- OutputWindow.cs
- DetailsViewPageEventArgs.cs
- ComboBoxItem.cs
- NativeMethods.cs
- EntityConnection.cs
- ChannelSinkStacks.cs
- WindowsListViewItemCheckBox.cs
- WebPartConnectVerb.cs
- CodeDOMUtility.cs
- WorkflowDesignerMessageFilter.cs
- ValidationSummary.cs
- SelectorAutomationPeer.cs
- WebRequestModuleElement.cs
- XhtmlBasicPanelAdapter.cs
- RemotingException.cs
- figurelength.cs
- DependencyObject.cs
- Transform.cs
- BaseDataBoundControl.cs
- ExportException.cs
- EntityDataSourceSelectedEventArgs.cs
- StylusCaptureWithinProperty.cs
- SqlCaseSimplifier.cs
- BitmapEncoder.cs
- CoTaskMemUnicodeSafeHandle.cs
- LambdaCompiler.Expressions.cs
- HttpCookie.cs
- FilterEventArgs.cs
- IncrementalHitTester.cs
- DragEvent.cs
- WriteLineDesigner.xaml.cs
- PreviewPrintController.cs
- TrackingDataItem.cs
- MinimizableAttributeTypeConverter.cs
- SafeRegistryKey.cs
- Profiler.cs
- RegexEditorDialog.cs
- DbDataSourceEnumerator.cs