Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Dispatcher / ConcurrencyBehavior.cs / 1 / ConcurrencyBehavior.cs
//------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- namespace System.ServiceModel.Dispatcher { using System; using System.ServiceModel; using System.ServiceModel.Channels; using System.Threading; using System.Collections.Generic; class ConcurrencyBehavior { ConcurrencyMode mode; bool supportsTransactedBatch; internal ConcurrencyBehavior(DispatchRuntime runtime) { this.mode = runtime.ConcurrencyMode; this.supportsTransactedBatch = ConcurrencyBehavior.SupportsTransactedBatch(runtime.ChannelDispatcher); } static bool SupportsTransactedBatch(ChannelDispatcher channelDispatcher) { return channelDispatcher.IsTransactedReceive && (channelDispatcher.MaxTransactedBatchSize > 0); } internal bool IsConcurrent(ref MessageRpc rpc) { return IsConcurrent(this.mode, rpc.Channel.HasSession, this.supportsTransactedBatch); } internal static bool IsConcurrent(ConcurrencyMode mode, bool hasSession, bool supportsTransactedBatch) { return !supportsTransactedBatch && ((mode != ConcurrencyMode.Single) || !hasSession); } internal static bool IsConcurrent(ChannelDispatcher runtime, bool hasSession) { if (ConcurrencyBehavior.SupportsTransactedBatch(runtime)) { return false; } if (!hasSession) { return true; } foreach (EndpointDispatcher endpointDispatcher in runtime.Endpoints) { if (endpointDispatcher.DispatchRuntime.ConcurrencyMode != ConcurrencyMode.Single) { return true; } } return false; } internal void LockInstance(ref MessageRpc rpc) { if (this.mode != ConcurrencyMode.Multiple) { ConcurrencyInstanceContextFacet resource = rpc.InstanceContext.Concurrency; lock (rpc.InstanceContext.ThisLock) { if (!resource.Locked) { resource.Locked = true; } else { MessageRpcWaiter waiter = new MessageRpcWaiter(rpc.Pause()); resource.EnqueueNewMessage(waiter); } } if (this.mode == ConcurrencyMode.Reentrant) { rpc.OperationContext.IsServiceReentrant = true; } } } internal void UnlockInstance(ref MessageRpc rpc) { if (this.mode != ConcurrencyMode.Multiple) { ConcurrencyBehavior.UnlockInstance(rpc.InstanceContext); } } internal static void UnlockInstanceBeforeCallout(OperationContext operationContext) { if (operationContext != null && operationContext.IsServiceReentrant) { ConcurrencyBehavior.UnlockInstance(operationContext.InstanceContext); } } static void UnlockInstance(InstanceContext instanceContext) { ConcurrencyInstanceContextFacet resource = instanceContext.Concurrency; lock (instanceContext.ThisLock) { if (resource.HasWaiters) { IWaiter nextWaiter = resource.DequeueWaiter(); nextWaiter.Signal(); } else { //We have no pending Callouts and no new Messages to process resource.Locked = false; } } } internal static void LockInstanceAfterCallout(OperationContext operationContext) { if (operationContext != null) { InstanceContext instanceContext = operationContext.InstanceContext; if (operationContext.IsServiceReentrant) { ConcurrencyInstanceContextFacet resource = instanceContext.Concurrency; ThreadWaiter waiter = null; lock (instanceContext.ThisLock) { if (!resource.Locked) { resource.Locked = true; } else { waiter = new ThreadWaiter(); resource.EnqueueCalloutMessage(waiter); } } if (waiter != null) { waiter.Wait(); } } } } internal interface IWaiter { void Signal(); } class MessageRpcWaiter : IWaiter { IResumeMessageRpc resume; internal MessageRpcWaiter(IResumeMessageRpc resume) { this.resume = resume; } void IWaiter.Signal() { try { bool alreadyResumedNoLock; this.resume.Resume(out alreadyResumedNoLock); if (alreadyResumedNoLock) { DiagnosticUtility.DebugAssert("ConcurrencyBehavior resumed more than once for same call."); } } catch (Exception e) { if (DiagnosticUtility.IsFatal(e)) { throw; } throw DiagnosticUtility.ExceptionUtility.ThrowHelperCallback(e); } } } class ThreadWaiter : IWaiter { ManualResetEvent wait = new ManualResetEvent(false); void IWaiter.Signal() { this.wait.Set(); } internal void Wait() { this.wait.WaitOne(); this.wait.Close(); } } } internal class ConcurrencyInstanceContextFacet { internal bool Locked; QueuecalloutMessageQueue; Queue newMessageQueue; internal bool HasWaiters { get { return (((this.calloutMessageQueue != null) && (this.calloutMessageQueue.Count > 0)) || ((this.newMessageQueue != null) && (this.newMessageQueue.Count > 0))); } } ConcurrencyBehavior.IWaiter DequeueFrom(Queue queue) { ConcurrencyBehavior.IWaiter waiter = queue.Dequeue(); if (queue.Count == 0) { queue.TrimExcess(); } return waiter; } internal ConcurrencyBehavior.IWaiter DequeueWaiter() { // Finishing old work takes precedence over new work. if ((this.calloutMessageQueue != null) && (this.calloutMessageQueue.Count > 0)) { return this.DequeueFrom(this.calloutMessageQueue); } else { return this.DequeueFrom(this.newMessageQueue); } } internal void EnqueueNewMessage(ConcurrencyBehavior.IWaiter waiter) { if (this.newMessageQueue == null) this.newMessageQueue = new Queue (); this.newMessageQueue.Enqueue(waiter); } internal void EnqueueCalloutMessage(ConcurrencyBehavior.IWaiter waiter) { if (this.calloutMessageQueue == null) this.calloutMessageQueue = new Queue (); this.calloutMessageQueue.Enqueue(waiter); } } } // 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
- RowsCopiedEventArgs.cs
- WS2007HttpBindingElement.cs
- AdornerHitTestResult.cs
- TreeViewImageIndexConverter.cs
- FilterRepeater.cs
- JpegBitmapEncoder.cs
- FileLogRecord.cs
- UserPreferenceChangingEventArgs.cs
- EventManager.cs
- XmlRawWriter.cs
- List.cs
- SerializableAttribute.cs
- LayoutExceptionEventArgs.cs
- ReadContentAsBinaryHelper.cs
- FontResourceCache.cs
- ToolStripItemEventArgs.cs
- ClaimTypeElement.cs
- _HeaderInfoTable.cs
- FtpRequestCacheValidator.cs
- LinkConverter.cs
- MouseActionValueSerializer.cs
- FormsAuthenticationTicket.cs
- HwndSourceKeyboardInputSite.cs
- Rect3DConverter.cs
- mansign.cs
- WsdlExporter.cs
- ViewCellSlot.cs
- XamlWriter.cs
- ItemMap.cs
- SelectionProviderWrapper.cs
- TempFiles.cs
- RemotingSurrogateSelector.cs
- WebPartConnectionsCancelVerb.cs
- VirtualDirectoryMapping.cs
- CollectionChange.cs
- ExpressionBuilderContext.cs
- ChannelManager.cs
- ModelFunctionTypeElement.cs
- ProcessProtocolHandler.cs
- FieldMetadata.cs
- HtmlTableRowCollection.cs
- Utils.cs
- BackgroundWorker.cs
- ThicknessKeyFrameCollection.cs
- UnsafeNativeMethods.cs
- BCryptSafeHandles.cs
- HideDisabledControlAdapter.cs
- DataSourceExpressionCollection.cs
- BitmapData.cs
- QilReplaceVisitor.cs
- SoapHttpTransportImporter.cs
- BamlTreeMap.cs
- CollaborationHelperFunctions.cs
- CacheModeValueSerializer.cs
- DynamicScriptObject.cs
- FunctionOverloadResolver.cs
- LocalizationComments.cs
- ValidationEventArgs.cs
- MutexSecurity.cs
- Soap12ProtocolReflector.cs
- CompilerResults.cs
- Nullable.cs
- GridViewSortEventArgs.cs
- TypeNameHelper.cs
- CompositeActivityValidator.cs
- HierarchicalDataTemplate.cs
- SignerInfo.cs
- ExcCanonicalXml.cs
- util.cs
- PersonalizationProviderHelper.cs
- DataGridViewIntLinkedList.cs
- XamlInt32CollectionSerializer.cs
- ComboBox.cs
- SessionStateModule.cs
- PictureBox.cs
- BrowsableAttribute.cs
- DesignerDataSourceView.cs
- SystemInformation.cs
- StreamingContext.cs
- Thumb.cs
- RecipientInfo.cs
- TextParagraphView.cs
- CapabilitiesPattern.cs
- ToolboxControl.cs
- MinimizableAttributeTypeConverter.cs
- Ppl.cs
- MessageQueuePermissionEntry.cs
- ScriptIgnoreAttribute.cs
- GroupItemAutomationPeer.cs
- SafeSecurityHandles.cs
- MatrixAnimationUsingPath.cs
- ErrorTolerantObjectWriter.cs
- EventWaitHandleSecurity.cs
- OracleFactory.cs
- Menu.cs
- MouseEvent.cs
- QilScopedVisitor.cs
- ColumnPropertiesGroup.cs
- UrlAuthFailedErrorFormatter.cs
- Attributes.cs