Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / SynchronizedMessageSource.cs / 1 / SynchronizedMessageSource.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Channels { using System.ServiceModel; using System.Threading; class SynchronizedMessageSource { IMessageSource source; ThreadNeutralSemaphore sourceLock; public SynchronizedMessageSource(IMessageSource source) { this.source = source; sourceLock = new ThreadNeutralSemaphore(1); } public IAsyncResult BeginWaitForMessage(TimeSpan timeout, AsyncCallback callback, object state) { return new WaitForMessageAsyncResult(this, timeout, callback, state); } public bool EndWaitForMessage(IAsyncResult result) { return WaitForMessageAsyncResult.End(result); } public bool WaitForMessage(TimeSpan timeout) { TimeoutHelper timeoutHelper = new TimeoutHelper(timeout); if (!sourceLock.TryEnter(timeoutHelper.RemainingTime())) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new TimeoutException(SR.GetString(SR.WaitForMessageTimedOut, timeout), ThreadNeutralSemaphore.CreateEnterTimedOutException(timeout))); } try { return source.WaitForMessage(timeoutHelper.RemainingTime()); } finally { sourceLock.Exit(); } } public IAsyncResult BeginReceive(TimeSpan timeout, AsyncCallback callback, object state) { return new ReceiveAsyncResult(this, timeout, callback, state); } public Message EndReceive(IAsyncResult result) { return ReceiveAsyncResult.End(result); } public Message Receive(TimeSpan timeout) { TimeoutHelper timeoutHelper = new TimeoutHelper(timeout); if (!sourceLock.TryEnter(timeoutHelper.RemainingTime())) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new TimeoutException(SR.GetString(SR.ReceiveTimedOut2, timeout), ThreadNeutralSemaphore.CreateEnterTimedOutException(timeout))); } try { return source.Receive(timeoutHelper.RemainingTime()); } finally { sourceLock.Exit(); } } abstract class SynchronizedAsyncResult: AsyncResult { T returnValue; bool exitLock; SynchronizedMessageSource syncSource; static WaitCallback onEnterComplete = new WaitCallback(OnEnterComplete); TimeoutHelper timeoutHelper; public SynchronizedAsyncResult(SynchronizedMessageSource syncSource, TimeSpan timeout, AsyncCallback callback, object state) : base(callback, state) { this.syncSource = syncSource; this.timeoutHelper = new TimeoutHelper(timeout); if (!syncSource.sourceLock.Enter(onEnterComplete, this)) return; exitLock = true; bool success = false; bool completeSelf; try { completeSelf = PerformOperation(timeoutHelper.RemainingTime()); success = true; } finally { if (!success) { ExitLock(); } } if (completeSelf) { CompleteWithUnlock(true); } } protected IMessageSource Source { get { return syncSource.source; } } protected void SetReturnValue(T returnValue) { this.returnValue = returnValue; } protected abstract bool PerformOperation(TimeSpan timeout); void ExitLock() { if (exitLock) { syncSource.sourceLock.Exit(); exitLock = false; } } protected void CompleteWithUnlock(bool synchronous) { CompleteWithUnlock(synchronous, null); } protected void CompleteWithUnlock(bool synchronous, Exception exception) { ExitLock(); base.Complete(synchronous, exception); } public static T End(IAsyncResult result) { SynchronizedAsyncResult thisPtr = AsyncResult.End >(result); return thisPtr.returnValue; } static void OnEnterComplete(object state) { SynchronizedAsyncResult thisPtr = (SynchronizedAsyncResult )state; Exception completionException = null; bool completeSelf; try { thisPtr.exitLock = true; completeSelf = thisPtr.PerformOperation(thisPtr.timeoutHelper.RemainingTime()); } #pragma warning suppress 56500 // [....], transferring exception to another thread catch (Exception e) { if (DiagnosticUtility.IsFatal(e)) { throw; } completeSelf = true; completionException = e; } if (completeSelf) { thisPtr.CompleteWithUnlock(false, completionException); } } } class ReceiveAsyncResult : SynchronizedAsyncResult { static WaitCallback onReceiveComplete = new WaitCallback(OnReceiveComplete); public ReceiveAsyncResult(SynchronizedMessageSource syncSource, TimeSpan timeout, AsyncCallback callback, object state) : base(syncSource, timeout, callback, state) { } protected override bool PerformOperation(TimeSpan timeout) { if (Source.BeginReceive(timeout, onReceiveComplete, this) == AsyncReceiveResult.Completed) { SetReturnValue(Source.EndReceive()); return true; } return false; } static void OnReceiveComplete(object state) { ReceiveAsyncResult thisPtr = ((ReceiveAsyncResult)state); Exception completionException = null; try { thisPtr.SetReturnValue(thisPtr.Source.EndReceive()); } #pragma warning suppress 56500 // [....], transferring exception to another thread catch (Exception e) { if (DiagnosticUtility.IsFatal(e)) { throw; } completionException = e; } thisPtr.CompleteWithUnlock(false, completionException); } } class WaitForMessageAsyncResult : SynchronizedAsyncResult { static WaitCallback onWaitForMessageComplete = new WaitCallback(OnWaitForMessageComplete); public WaitForMessageAsyncResult(SynchronizedMessageSource syncSource, TimeSpan timeout, AsyncCallback callback, object state) : base(syncSource, timeout, callback, state) { } protected override bool PerformOperation(TimeSpan timeout) { if (Source.BeginWaitForMessage(timeout, onWaitForMessageComplete, this) == AsyncReceiveResult.Completed) { SetReturnValue(Source.EndWaitForMessage()); return true; } return false; } static void OnWaitForMessageComplete(object state) { WaitForMessageAsyncResult thisPtr = (WaitForMessageAsyncResult)state; Exception completionException = null; try { thisPtr.SetReturnValue(thisPtr.Source.EndWaitForMessage()); } #pragma warning suppress 56500 // [....], transferring exception to another thread catch (Exception e) { if (DiagnosticUtility.IsFatal(e)) { throw; } completionException = e; } thisPtr.CompleteWithUnlock(false, 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
- FileSystemInfo.cs
- InfoCardArgumentException.cs
- SessionIDManager.cs
- ClientSettingsSection.cs
- ProxyWebPart.cs
- TagNameToTypeMapper.cs
- SerTrace.cs
- CacheMemory.cs
- ThousandthOfEmRealPoints.cs
- ContentDisposition.cs
- UIPropertyMetadata.cs
- DBDataPermissionAttribute.cs
- QilLiteral.cs
- MsmqIntegrationSecurityMode.cs
- SecureConversationServiceElement.cs
- SettingsAttributes.cs
- DbConnectionHelper.cs
- SamlSubjectStatement.cs
- LiteralSubsegment.cs
- TreeBuilderBamlTranslator.cs
- WebBrowserHelper.cs
- RequestReplyCorrelator.cs
- GroupQuery.cs
- RenderingEventArgs.cs
- ParserExtension.cs
- ActivityDelegate.cs
- ConditionedDesigner.cs
- SurrogateSelector.cs
- EncodingDataItem.cs
- XsdValidatingReader.cs
- SortableBindingList.cs
- Scene3D.cs
- SqlNodeTypeOperators.cs
- Int32KeyFrameCollection.cs
- LookupBindingPropertiesAttribute.cs
- AutoGeneratedField.cs
- bindurihelper.cs
- Hash.cs
- StrokeCollectionConverter.cs
- MenuItemCollectionEditorDialog.cs
- SqlRewriteScalarSubqueries.cs
- DoubleAverageAggregationOperator.cs
- AttributeQuery.cs
- HostedHttpRequestAsyncResult.cs
- RuleProcessor.cs
- RoutedCommand.cs
- SafeEventLogWriteHandle.cs
- SafeCryptoHandles.cs
- ListViewPagedDataSource.cs
- DispatcherTimer.cs
- AuthorizationRule.cs
- HtmlFormParameterReader.cs
- JavaScriptObjectDeserializer.cs
- FieldBuilder.cs
- Animatable.cs
- ADConnectionHelper.cs
- MultiPageTextView.cs
- AuthenticatingEventArgs.cs
- SafeTimerHandle.cs
- DragAssistanceManager.cs
- WarningException.cs
- ViewLoader.cs
- ByteAnimationUsingKeyFrames.cs
- BaseParser.cs
- ReversePositionQuery.cs
- SqlInfoMessageEvent.cs
- SignedInfo.cs
- _LoggingObject.cs
- TraceSource.cs
- HtmlGenericControl.cs
- CustomSignedXml.cs
- Queue.cs
- FrameSecurityDescriptor.cs
- StringFunctions.cs
- ModelUIElement3D.cs
- SecurityUtils.cs
- ActivityPropertyReference.cs
- ProfileSettings.cs
- RepeatEnumerable.cs
- MenuItemBinding.cs
- AuthorizationSection.cs
- ExpressionLexer.cs
- TargetFrameworkAttribute.cs
- LocalValueEnumerator.cs
- CredentialCache.cs
- WebBrowserNavigatedEventHandler.cs
- RC2CryptoServiceProvider.cs
- ToolStripPanelRow.cs
- SqlInternalConnectionSmi.cs
- PeerNameRecord.cs
- StatusCommandUI.cs
- ADMembershipProvider.cs
- DataSourceSerializationException.cs
- GenericUriParser.cs
- DeploymentSectionCache.cs
- ConfigurationElementCollection.cs
- ByValueEqualityComparer.cs
- Utils.cs
- FrameworkElementAutomationPeer.cs
- XmlBinaryWriter.cs