1 instantiation of ConcurrencyBehavior
System.ServiceModel.Primitives (1)
System\ServiceModel\Dispatcher\ImmutableDispatchRuntime.cs (1)
43_concurrency = new ConcurrencyBehavior(dispatch);
20 references to ConcurrencyBehavior
System.ServiceModel.Primitives (20)
System\ServiceModel\Channels\ServiceChannel.cs (6)
752ConcurrencyBehavior.UnlockInstanceBeforeCallout(OperationContext.Current); 773ConcurrencyBehavior.LockInstanceAfterCallout(OperationContext.Current); 1841ConcurrencyBehavior.UnlockInstanceBeforeCallout(_operationContext); 1860ConcurrencyBehavior.LockInstanceAfterCallout(_operationContext); 1917ConcurrencyBehavior.LockInstanceAfterCallout(_operationContext); 1940ConcurrencyBehavior.LockInstanceAfterCallout(result._operationContext);
System\ServiceModel\Dispatcher\ChannelHandler.cs (1)
90_isConcurrent = ConcurrencyBehavior.IsConcurrent(channelDispatcher, _hasSession);
System\ServiceModel\Dispatcher\ConcurrencyBehavior.cs (12)
107ConcurrencyBehavior.UnlockInstance(rpc.InstanceContext); 115ConcurrencyBehavior.UnlockInstance(operationContext.InstanceContext); 227private Queue<ConcurrencyBehavior.IWaiter> _calloutMessageQueue; 228private Queue<ConcurrencyBehavior.IWaiter> _newMessageQueue; 239private ConcurrencyBehavior.IWaiter DequeueFrom(Queue<ConcurrencyBehavior.IWaiter> queue) 241ConcurrencyBehavior.IWaiter waiter = queue.Dequeue(); 251internal ConcurrencyBehavior.IWaiter DequeueWaiter() 264internal void EnqueueNewMessage(ConcurrencyBehavior.IWaiter waiter) 268_newMessageQueue = new Queue<ConcurrencyBehavior.IWaiter>(); 274internal void EnqueueCalloutMessage(ConcurrencyBehavior.IWaiter waiter) 278_calloutMessageQueue = new Queue<ConcurrencyBehavior.IWaiter>();
System\ServiceModel\Dispatcher\ImmutableDispatchRuntime.cs (1)
15private readonly ConcurrencyBehavior _concurrency;