2 writes to InstancePersistenceContext
System.Activities.DurableInstancing (2)
System\Activities\DurableInstancing\SqlWorkflowInstanceStoreAsyncResult.cs (2)
53
this.
InstancePersistenceContext
= context;
267
this.
InstancePersistenceContext
= null;
56 references to InstancePersistenceContext
System.Activities.DurableInstancing (56)
System\Activities\DurableInstancing\CreateWorkflowOwnerAsyncResult.cs (4)
125
base.
InstancePersistenceContext
.BindInstanceOwner(this.lockOwnerId, this.lockOwnerId);
131
base.
InstancePersistenceContext
.BindEvent(HasActivatableWorkflowEvent.Value);
135
base.
InstancePersistenceContext
.BindEvent(HasRunnableWorkflowEvent.Value);
138
base.StoreLock.MarkInstanceOwnerCreated(this.lockOwnerId, surrogateLockOwnerId, base.
InstancePersistenceContext
.InstanceHandle, this.fireRunnableInstancesEvent, this.fireActivatableInstancesEvent);
System\Activities\DurableInstancing\DeleteWorkflowOwnerAsyncResult.cs (1)
58
base.
InstancePersistenceContext
.InstanceHandle.Free();
System\Activities\DurableInstancing\LoadWorkflowAsyncResult.cs (15)
69
parameters.Add(new SqlParameter { ParameterName = "@handleInstanceVersion", SqlDbType = SqlDbType.BigInt, Value = base.
InstancePersistenceContext
.InstanceVersion });
70
parameters.Add(new SqlParameter { ParameterName = "@handleIsBoundToLock", SqlDbType = SqlDbType.Bit, Value = base.
InstancePersistenceContext
.InstanceView.IsBoundToLock });
82
Guid instanceId = base.
InstancePersistenceContext
.InstanceView.InstanceId;
117
if (!base.
InstancePersistenceContext
.InstanceView.IsBoundToInstance)
119
base.
InstancePersistenceContext
.BindInstance(instanceId);
121
if (!base.
InstancePersistenceContext
.InstanceView.IsBoundToInstanceOwner)
123
base.
InstancePersistenceContext
.BindInstanceOwner(base.StoreLock.LockOwnerId, base.StoreLock.LockOwnerId);
125
if (!base.
InstancePersistenceContext
.InstanceView.IsBoundToLock)
127
InstanceLockTracking instanceLockTracking = (InstanceLockTracking)(base.
InstancePersistenceContext
.UserContext);
129
base.
InstancePersistenceContext
.BindAcquiredLock(version);
149
base.
InstancePersistenceContext
.AssociatedInstanceKey(loadByKeycommand.LookupInstanceKey);
158
base.
InstancePersistenceContext
.AssociatedInstanceKey(keyEntry.Key);
164
base.
InstancePersistenceContext
.WroteInstanceKeyMetadataValue(keyEntry.Key, property.Key, property.Value);
170
base.
InstancePersistenceContext
.LoadedInstance
181
base.
InstancePersistenceContext
.InstanceHandle.Free();
System\Activities\DurableInstancing\QueryActivatableWorkflowAsyncResult.cs (1)
60
base.
InstancePersistenceContext
.QueriedInstanceStore(new ActivatableWorkflowsQueryResult(activationParametersList));
System\Activities\DurableInstancing\SaveWorkflowAsyncResult.cs (16)
74
parameters.Add(new SqlParameter { ParameterName = "@instanceId", SqlDbType = SqlDbType.UniqueIdentifier, Value = base.
InstancePersistenceContext
.InstanceView.InstanceId });
76
parameters.Add(new SqlParameter { ParameterName = "@handleInstanceVersion", SqlDbType = SqlDbType.BigInt, Value = base.
InstancePersistenceContext
.InstanceVersion });
77
parameters.Add(new SqlParameter { ParameterName = "@handleIsBoundToLock", SqlDbType = SqlDbType.Bit, Value = base.
InstancePersistenceContext
.InstanceView.IsBoundToLock });
141
InstanceLockTracking instanceLockTracking = (InstanceLockTracking)(base.
InstancePersistenceContext
.UserContext);
151
if (!base.
InstancePersistenceContext
.InstanceView.IsBoundToLock)
154
instanceLockTracking.TrackStoreLock(base.
InstancePersistenceContext
.InstanceView.InstanceId, instanceVersion, this.DependentTransaction);
155
base.
InstancePersistenceContext
.BindAcquiredLock(instanceVersion);
160
base.
InstancePersistenceContext
.PersistedInstance(saveWorkflowCommand.InstanceData);
163
SaveWorkflowAsyncResult.UpdateKeyData(base.
InstancePersistenceContext
, saveWorkflowCommand);
167
base.
InstancePersistenceContext
.WroteInstanceMetadataValue(property.Key, property.Value);
172
base.
InstancePersistenceContext
.CompletedInstance();
178
base.
InstancePersistenceContext
.InstanceHandle.Free();
183
base.
InstancePersistenceContext
.InstanceHandle.Free();
502
ArraySegment<byte> metadataProperties = SerializationUtilities.SerializeMetadataPropertyBag(saveWorkflowCommand, base.
InstancePersistenceContext
, base.Store.InstanceEncodingOption);
504
bool metadataConsistency = (base.
InstancePersistenceContext
.InstanceView.InstanceMetadataConsistency == InstanceValueConsistency.None);
598
parameters.Add(new SqlParameter() { SqlDbType = SqlDbType.UniqueIdentifier, ParameterName = instanceIdArgument, Value = base.
InstancePersistenceContext
.InstanceView.InstanceId });
System\Activities\DurableInstancing\SqlWorkflowInstanceStoreAsyncResult.cs (16)
174
thisPtr.
InstancePersistenceContext
.EndBindReclaimedLock(result);
175
Guid instanceId = thisPtr.
InstancePersistenceContext
.InstanceView.InstanceId;
176
long lockVersion = thisPtr.
InstancePersistenceContext
.InstanceVersion;
178
InstanceLockTracking instanceLockTracking = (InstanceLockTracking)(thisPtr.
InstancePersistenceContext
.UserContext);
180
thisPtr.
InstancePersistenceContext
.InstanceHandle.Free();
208
Guid instanceId = (thisPtr.
InstancePersistenceContext
!= null) ? thisPtr.
InstancePersistenceContext
.InstanceView.InstanceId : Guid.Empty;
217
if (!thisPtr.
InstancePersistenceContext
.InstanceView.IsBoundToInstance)
219
thisPtr.
InstancePersistenceContext
.BindInstance(alreadyLockedException.InstanceId);
222
IAsyncResult bindReclaimedAsyncResult = thisPtr.
InstancePersistenceContext
.BeginBindReclaimedLock(reclaimLockAtVersion, thisPtr.TimeoutHelper.RemainingTime(), thisPtr.PrepareAsyncCompletion(SqlWorkflowInstanceStoreAsyncResult.onBindReclaimed), thisPtr);
274
Guid instanceId = (this.
InstancePersistenceContext
!= null) ? this.
InstancePersistenceContext
.InstanceView.InstanceId : Guid.Empty;
286
(this.
InstancePersistenceContext
!= null) ? this.
InstancePersistenceContext
.EventTraceActivity : null,
334
TD.FoundProcessingError((this.
InstancePersistenceContext
!= null) ? this.
InstancePersistenceContext
.EventTraceActivity : null,
System\Activities\DurableInstancing\TestVersionAndRunAsyncResult.cs (1)
175
this.Store.BeginTryCommandInternal(this.
InstancePersistenceContext
, this.InstancePersistenceCommand, this.currentTransaction, this.TimeoutHelper.RemainingTime(), instanceCommandCompleteCallback, this);
System\Activities\DurableInstancing\TryLoadRunnableWorkflowAsyncResult.cs (2)
44
command.Parameters.Add(new SqlParameter { ParameterName = "@handleInstanceVersion", SqlDbType = SqlDbType.BigInt, Value = base.
InstancePersistenceContext
.InstanceVersion });
45
command.Parameters.Add(new SqlParameter { ParameterName = "@handleIsBoundToLock", SqlDbType = SqlDbType.Bit, Value = base.
InstancePersistenceContext
.InstanceView.IsBoundToLock });