2 writes to InstancePersistenceCommand
System.Activities.DurableInstancing (2)
System\Activities\DurableInstancing\SqlWorkflowInstanceStoreAsyncResult.cs (2)
54
this.
InstancePersistenceCommand
= command;
266
this.
InstancePersistenceCommand
= null;
29 references to InstancePersistenceCommand
System.Activities.DurableInstancing (29)
System\Activities\DurableInstancing\CreateWorkflowOwnerAsyncResult.cs (4)
104
string identityMetadataXml = SerializationUtilities.GetIdentityMetadataXml(base.
InstancePersistenceCommand
);
121
Exception exception = StoreUtilities.GetNextResultSet(this.
InstancePersistenceCommand
.Name, reader);
164
CreateWorkflowOwnerWithIdentityCommand createOwnerWithIdentityCommand = base.
InstancePersistenceCommand
as CreateWorkflowOwnerWithIdentityCommand;
172
CreateWorkflowOwnerCommand createOwnerCommand = (CreateWorkflowOwnerCommand)base.
InstancePersistenceCommand
;
System\Activities\DurableInstancing\DeleteWorkflowOwnerAsyncResult.cs (1)
54
exception = StoreUtilities.CheckRemainingResultSetForErrors(base.
InstancePersistenceCommand
.Name, reader);
System\Activities\DurableInstancing\DetectActivatableWorkflowsAsyncResult.cs (1)
61
Exception exception = StoreUtilities.GetNextResultSet(base.
InstancePersistenceCommand
.Name, reader);
System\Activities\DurableInstancing\DetectRunnableInstancesAsyncResult.cs (1)
65
Exception exception = StoreUtilities.GetNextResultSet(base.
InstancePersistenceCommand
.Name, reader);
System\Activities\DurableInstancing\ExtendLockAsyncResult.cs (1)
64
return StoreUtilities.CheckRemainingResultSetForErrors(base.
InstancePersistenceCommand
.Name, reader);
System\Activities\DurableInstancing\LoadWorkflowAsyncResult.cs (6)
80
LoadWorkflowCommand loadWorkflowCommand = base.
InstancePersistenceCommand
as LoadWorkflowCommand;
99
Exception exception = StoreUtilities.GetNextResultSet(base.
InstancePersistenceCommand
.Name, reader);
114
LoadWorkflowCommand loadWorkflowCommand = base.
InstancePersistenceCommand
as LoadWorkflowCommand;
115
LoadWorkflowByInstanceKeyCommand loadByKeycommand = base.
InstancePersistenceCommand
as LoadWorkflowByInstanceKeyCommand;
189
Exception exception = StoreUtilities.GetNextResultSet(base.
InstancePersistenceCommand
.Name, reader);
227
Exception exception = StoreUtilities.GetNextResultSet(base.
InstancePersistenceCommand
.Name, reader);
System\Activities\DurableInstancing\LoadWorkflowByKeyAsyncResult.cs (1)
31
LoadWorkflowByInstanceKeyCommand keyLoadCommand = base.
InstancePersistenceCommand
as LoadWorkflowByInstanceKeyCommand;
System\Activities\DurableInstancing\QueryActivatableWorkflowAsyncResult.cs (1)
37
Exception exception = StoreUtilities.GetNextResultSet(base.
InstancePersistenceCommand
.Name, reader);
System\Activities\DurableInstancing\RecoverInstanceLocksAsyncResult.cs (1)
60
return StoreUtilities.CheckRemainingResultSetForErrors(base.
InstancePersistenceCommand
.Name, reader);
System\Activities\DurableInstancing\SaveWorkflowAsyncResult.cs (4)
67
SaveWorkflowCommand saveWorkflowCommand = base.
InstancePersistenceCommand
as SaveWorkflowCommand;
136
Exception exception = StoreUtilities.GetNextResultSet(base.
InstancePersistenceCommand
.Name, reader);
140
SaveWorkflowCommand saveWorkflowCommand = base.
InstancePersistenceCommand
as SaveWorkflowCommand;
146
exception = StoreUtilities.GetNextResultSet(base.
InstancePersistenceCommand
.Name, reader);
System\Activities\DurableInstancing\SqlWorkflowInstanceStoreAsyncResult.cs (3)
182
throw FxTrace.Exception.AsError(new InstanceLockLostException(thisPtr.
InstancePersistenceCommand
.Name, instanceId));
209
delayedException = new InstancePersistenceCommandException(thisPtr.
InstancePersistenceCommand
.Name, instanceId, exception);
306
delayedException = new InstancePersistenceCommandException(this.
InstancePersistenceCommand
.Name, instanceId, exception);
System\Activities\DurableInstancing\TestVersionAndRunAsyncResult.cs (2)
175
this.Store.BeginTryCommandInternal(this.InstancePersistenceContext, this.
InstancePersistenceCommand
, this.currentTransaction, this.TimeoutHelper.RemainingTime(), instanceCommandCompleteCallback, this);
179
throw FxTrace.Exception.AsError(new InstancePersistenceCommandException(SR.DatabaseUpgradeRequiredForCommand(this.Store.DatabaseVersion, this.
InstancePersistenceCommand
, this.targetVersion)));
System\Activities\DurableInstancing\TryLoadRunnableWorkflowAsyncResult.cs (1)
57
Exception exception = StoreUtilities.GetNextResultSet(this.
InstancePersistenceCommand
.Name, reader);
System\Activities\DurableInstancing\UnlockInstanceAsyncResult.cs (2)
34
UnlockInstanceCommand unlockCommand = (UnlockInstanceCommand)(base.
InstancePersistenceCommand
);
53
return StoreUtilities.CheckRemainingResultSetForErrors(base.
InstancePersistenceCommand
.Name, reader);