Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / InputChannel.cs / 1 / InputChannel.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Channels { using System.Collections.Generic; using System.ServiceModel; class InputChannel : InputQueueChannel, IInputChannel { EndpointAddress localAddress; public InputChannel(ChannelManagerBase channelManager, EndpointAddress localAddress) : base(channelManager) { this.localAddress = localAddress; } public EndpointAddress LocalAddress { get { return localAddress; } } public override T GetProperty () { if (typeof(T) == typeof(IInputChannel)) { return (T)(object)this; } T baseProperty = base.GetProperty (); if (baseProperty != null) { return baseProperty; } return default(T); } protected override IAsyncResult OnBeginOpen(TimeSpan timeout, AsyncCallback callback, object state) { return new CompletedAsyncResult(callback, state); } protected override void OnEndOpen(IAsyncResult result) { CompletedAsyncResult.End(result); } protected override void OnOpen(TimeSpan timeout) { } public virtual Message Receive() { return this.Receive(this.DefaultReceiveTimeout); } public virtual Message Receive(TimeSpan timeout) { if (timeout < TimeSpan.Zero) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new ArgumentOutOfRangeException("timeout", timeout, SR.GetString(SR.SFxTimeoutOutOfRange0))); this.ThrowPending(); return InputChannel.HelpReceive(this, timeout); } public virtual IAsyncResult BeginReceive(AsyncCallback callback, object state) { return this.BeginReceive(this.DefaultReceiveTimeout, callback, state); } public virtual IAsyncResult BeginReceive(TimeSpan timeout, AsyncCallback callback, object state) { if (timeout < TimeSpan.Zero) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new ArgumentOutOfRangeException("timeout", timeout, SR.GetString(SR.SFxTimeoutOutOfRange0))); } this.ThrowPending(); return InputChannel.HelpBeginReceive(this, timeout, callback, state); } public Message EndReceive(IAsyncResult result) { return InputChannel.HelpEndReceive(result); } public virtual bool TryReceive(TimeSpan timeout, out Message message) { if (timeout < TimeSpan.Zero) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new ArgumentOutOfRangeException("timeout", timeout, SR.GetString(SR.SFxTimeoutOutOfRange0))); } this.ThrowPending(); return base.Dequeue(timeout, out message); } public virtual IAsyncResult BeginTryReceive(TimeSpan timeout, AsyncCallback callback, object state) { if (timeout < TimeSpan.Zero) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new ArgumentOutOfRangeException("timeout", timeout, SR.GetString(SR.SFxTimeoutOutOfRange0))); } this.ThrowPending(); return base.BeginDequeue(timeout, callback, state); } public virtual bool EndTryReceive(IAsyncResult result, out Message message) { return base.EndDequeue(result, out message); } public bool WaitForMessage(TimeSpan timeout) { if (timeout < TimeSpan.Zero) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new ArgumentOutOfRangeException("timeout", timeout, SR.GetString(SR.SFxTimeoutOutOfRange0))); } this.ThrowPending(); return base.WaitForItem(timeout); } public IAsyncResult BeginWaitForMessage(TimeSpan timeout, AsyncCallback callback, object state) { if (timeout < TimeSpan.Zero) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new ArgumentOutOfRangeException("timeout", timeout, SR.GetString(SR.SFxTimeoutOutOfRange0))); this.ThrowPending(); return base.BeginWaitForItem(timeout, callback, state); } public bool EndWaitForMessage(IAsyncResult result) { return base.EndWaitForItem(result); } #region static Helpers to convert TryReceive to Receive internal static Message HelpReceive(IInputChannel channel, TimeSpan timeout) { Message message; if (channel.TryReceive(timeout, out message)) { return message; } else { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(CreateReceiveTimedOutException(channel, timeout)); } } internal static IAsyncResult HelpBeginReceive(IInputChannel channel, TimeSpan timeout, AsyncCallback callback, object state) { return new HelpReceiveAsyncResult(channel, timeout, callback, state); } internal static Message HelpEndReceive(IAsyncResult result) { return HelpReceiveAsyncResult.End(result); } class HelpReceiveAsyncResult : AsyncResult { IInputChannel channel; TimeSpan timeout; static AsyncCallback onReceive = DiagnosticUtility.ThunkAsyncCallback(new AsyncCallback(OnReceive)); Message message; public HelpReceiveAsyncResult(IInputChannel channel, TimeSpan timeout, AsyncCallback callback, object state) : base(callback, state) { this.channel = channel; this.timeout = timeout; IAsyncResult result = channel.BeginTryReceive(timeout, onReceive, this); if (!result.CompletedSynchronously) { return; } HandleReceiveComplete(result); base.Complete(true); } public static Message End(IAsyncResult result) { HelpReceiveAsyncResult thisPtr = AsyncResult.End (result); return thisPtr.message; } void HandleReceiveComplete(IAsyncResult result) { if (!this.channel.EndTryReceive(result, out this.message)) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( InputChannel.CreateReceiveTimedOutException(this.channel, this.timeout)); } } static void OnReceive(IAsyncResult result) { if (result.CompletedSynchronously) { return; } HelpReceiveAsyncResult thisPtr = (HelpReceiveAsyncResult)result.AsyncState; Exception completionException = null; try { thisPtr.HandleReceiveComplete(result); } #pragma warning suppress 56500 // [....], transferring exception to another thread catch (Exception e) { if (DiagnosticUtility.IsFatal(e)) { throw; } completionException = e; } thisPtr.Complete(false, completionException); } } static Exception CreateReceiveTimedOutException(IInputChannel channel, TimeSpan timeout) { if (channel.LocalAddress != null) { return new TimeoutException(SR.GetString(SR.ReceiveTimedOut, channel.LocalAddress.Uri.AbsoluteUri, timeout)); } else { return new TimeoutException(SR.GetString(SR.ReceiveTimedOutNoLocalAddress, timeout)); } } #endregion } } // 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
- EventBindingService.cs
- HtmlInputText.cs
- IteratorFilter.cs
- PathGradientBrush.cs
- WpfGeneratedKnownProperties.cs
- DuplicateContext.cs
- DesignerProperties.cs
- RuntimeHandles.cs
- DynamicContractTypeBuilder.cs
- HttpWrapper.cs
- AppSettingsReader.cs
- UnsafeNativeMethodsMilCoreApi.cs
- HtmlHead.cs
- TerminateSequence.cs
- GridViewRowPresenterBase.cs
- CommandLibraryHelper.cs
- WebMessageBodyStyleHelper.cs
- PaintValueEventArgs.cs
- SupportingTokenBindingElement.cs
- DesignerAttribute.cs
- MasterPageBuildProvider.cs
- TextLineResult.cs
- RemoveStoryboard.cs
- ContextQuery.cs
- shaperfactoryquerycacheentry.cs
- base64Transforms.cs
- EncodingDataItem.cs
- UIElementIsland.cs
- DocumentApplicationJournalEntry.cs
- DataGridViewCellFormattingEventArgs.cs
- StoreItemCollection.cs
- DbFunctionCommandTree.cs
- FigureHelper.cs
- CodeTypeParameterCollection.cs
- PageRanges.cs
- ScrollEvent.cs
- MinMaxParagraphWidth.cs
- Stylus.cs
- TableLayoutPanel.cs
- NavigatorInvalidBodyAccessException.cs
- UrlMappingsModule.cs
- ImageMapEventArgs.cs
- MetadataItem.cs
- MemberProjectedSlot.cs
- ManualResetEventSlim.cs
- BlobPersonalizationState.cs
- FileResponseElement.cs
- MsmqIntegrationProcessProtocolHandler.cs
- LockedActivityGlyph.cs
- Console.cs
- ValueChangedEventManager.cs
- DiscoveryClientDocuments.cs
- DocumentSchemaValidator.cs
- GeneratedView.cs
- HttpListenerPrefixCollection.cs
- SvcFileManager.cs
- DoubleStorage.cs
- JsonReaderDelegator.cs
- ScrollChangedEventArgs.cs
- XmlArrayItemAttributes.cs
- PasswordRecovery.cs
- DesignerCategoryAttribute.cs
- MsmqIntegrationBinding.cs
- CompilerScopeManager.cs
- _IPv4Address.cs
- BufferModesCollection.cs
- DesignerProperties.cs
- Canvas.cs
- ApplicationBuildProvider.cs
- WebUtil.cs
- TextOnlyOutput.cs
- SizeAnimationUsingKeyFrames.cs
- CodeStatementCollection.cs
- XmlSigningNodeWriter.cs
- PrintController.cs
- FileAuthorizationModule.cs
- TextBoxAutomationPeer.cs
- CompilerResults.cs
- QilList.cs
- ConstantProjectedSlot.cs
- RootAction.cs
- XmlSignatureProperties.cs
- CodeEventReferenceExpression.cs
- CodeGeneratorOptions.cs
- PointUtil.cs
- InArgumentConverter.cs
- DispatcherOperation.cs
- Vector3DCollectionConverter.cs
- ObjectListDataBindEventArgs.cs
- ApplicationFileCodeDomTreeGenerator.cs
- NetPeerTcpBindingElement.cs
- safemediahandle.cs
- XmlSchemaType.cs
- ListParagraph.cs
- SortedDictionary.cs
- BookmarkEventArgs.cs
- BinaryReader.cs
- EntityUtil.cs
- TextTreeInsertUndoUnit.cs
- BitHelper.cs