1 write to ppd
System.ServiceModel.Activities (1)
System\ServiceModel\Activities\Dispatcher\PersistenceProviderDirectory.cs (1)
754this.ppd = ppd;
46 references to ppd
System.ServiceModel.Activities (46)
System\ServiceModel\Activities\Dispatcher\PersistenceProviderDirectory.cs (46)
864thisPtr.ppd.EndReserveThrottle(out thisPtr.loadPending, result); 866thisPtr.lockInstance = thisPtr.ppd.ConsistencyScope != DurableConsistencyScope.Local || !thisPtr.canCreateInstance; 884this.result = this.loadAny ? null : this.ppd.LoadFromCache(this.key, this.suggestedIdOrId, this.canCreateInstance); 892else if (this.ppd.store == null && !this.canCreateInstance) 908waitHandle = this.ppd.LoadInProgressWaitHandle(this.key); 921IAsyncResult reserveThrottleResult = this.ppd.BeginReserveThrottle(this.timeoutHelper.RemainingTime(), 951if (this.ppd.store == null) 957this.context = new PersistenceContext(this.ppd, this.suggestedIdOrId == Guid.Empty ? Guid.NewGuid() : this.suggestedIdOrId, this.key, this.associatedKeys); 967this.handle = this.ppd.store.CreateInstanceHandle(this.ppd.owner, this.suggestedIdOrId); 974InstancePersistenceCommand loadCommand = this.ppd.CreateLoadCommandHelper(this.key, out this.handle, this.canCreateInstance, this.suggestedIdOrId, this.associatedKeys, this.loadAny); 980executeResult = this.ppd.store.BeginExecute(this.handle, loadCommand, this.timeoutHelper.RemainingTime(), PrepareAsyncCompletion(LoadOrCreateAsyncResult.HandleExecute), this); 1024thisPtr.view = thisPtr.ppd.store.EndExecute(result); 1059this.result = this.loadAny ? null : this.ppd.LoadFromCache(this.key, this.suggestedIdOrId, this.canCreateInstance); 1115this.context = new PersistenceContext(this.ppd, this.ppd.store, this.handle, this.suggestedIdOrId, null, true, false, null, null); 1119this.context = new PersistenceContext(this.ppd, this.ppd.store, this.handle, this.view.InstanceId, this.view.InstanceKeys.Values.Select((keyView) => new InstanceKey(keyView.InstanceKey, keyView.InstanceKeyMetadata)), true, true, this.view, null); 1128this.context = new PersistenceContext(this.ppd, this.ppd.store, this.handle, this.view.InstanceId, this.view.InstanceKeys.Values.Select((keyView) => new InstanceKey(keyView.InstanceKey, keyView.InstanceKeyMetadata)), false, true, this.view, this.updatedIdentity); 1137this.ppd.RegisterPipelineInUse(this.pipeline); 1157throw FxTrace.Exception.AsError(new InstancePersistenceCommandException(SRCore.NullAssignedToValueType(this.ppd.serviceHost.DurableInstancingOptions.ScopeName))); 1160if (!this.ppd.serviceHost.DurableInstancingOptions.ScopeName.Equals(instanceValue.Value)) 1162throw FxTrace.Exception.AsError(new InstancePersistenceCommandException(SRCore.IncorrectValueType(this.ppd.serviceHost.DurableInstancingOptions.ScopeName, instanceValue.Value))); 1205lock (this.ppd.ThisLock) 1207this.ppd.ThrowIfClosedOrAborted(); 1214if (this.ppd.store == null) 1218this.ppd.instanceCache.TryGetValue(this.suggestedIdOrId, out this.result); 1222this.ppd.keyMap.TryGetValue(this.key.Value, out this.result); 1235if (this.ppd.keyMap.TryGetValue(instanceKey.Value, out conflictingContext)) 1253if (this.ppd.instanceCache.TryGetValue(this.context.InstanceId, out contextToAbort)) 1264this.ppd.DetachContext(contextToAbort, ref this.contextsToAbort); 1269if (this.ppd.keyMap.TryGetValue(loadedKey.Value, out contextToAbort)) 1271Fx.Assert(this.ppd.store != null, "When there is no store, exception should have already been thrown before we get here."); 1272this.ppd.DetachContext(contextToAbort, ref this.contextsToAbort); 1274this.ppd.keyMap.Add(loadedKey.Value, this.context); 1282this.ppd.instanceCache.Add(this.context.InstanceId, this.context); 1300thisPtr.ppd.UnregisterPipelineInUse(thisPtr.pipeline); 1304thisPtr.ppd.throttle.Exit(); 1308lock (thisPtr.ppd.ThisLock) 1310thisPtr.ppd.DetachContext(thisPtr.context, ref thisPtr.contextsToAbort); 1320thisPtr.ppd.AbortContexts(thisPtr.contextsToAbort); 1323thisPtr.ppd.LoadInProgressFinished(thisPtr.key); 1329thisPtr.ppd.serviceHost.WorkflowServiceHostPerformanceCounters.WorkflowCreated(); 1333thisPtr.ppd.serviceHost.WorkflowServiceHostPerformanceCounters.WorkflowLoaded(); 1336thisPtr.ppd.serviceHost.WorkflowServiceHostPerformanceCounters.WorkflowLoadDuration(thisPtr.GetDuration());