2 writes to Store
System.Activities.DurableInstancing (2)
System\Activities\DurableInstancing\SqlWorkflowInstanceStoreAsyncResult.cs (2)
55this.Store = store; 268this.Store = null;
45 references to Store
System.Activities.DurableInstancing (45)
System\Activities\DurableInstancing\CreateWorkflowOwnerAsyncResult.cs (10)
50SqlConnectionStringBuilder builder = new SqlConnectionStringBuilder(base.Store.CachedConnectionString); 68double lockTimeout = base.Store.BufferedHostLockRenewalPeriod.TotalSeconds; 86ArraySegment<byte>[] properties = SerializationUtilities.SerializePropertyBag(commandMetadata, base.Store.InstanceEncodingOption); 90parameters.Add(new SqlParameter { ParameterName = "@workflowHostType", SqlDbType = SqlDbType.UniqueIdentifier, Value = (base.Store.WorkflowHostType != Guid.Empty) ? base.Store.WorkflowHostType : (object) DBNull.Value }); 91parameters.Add(new SqlParameter { ParameterName = "@enqueueCommand", SqlDbType = SqlDbType.Bit, Value = base.Store.EnqueueRunCommands }); 92parameters.Add(new SqlParameter { ParameterName = "@deleteInstanceOnCompletion", SqlDbType = SqlDbType.Bit, Value = (base.Store.InstanceCompletionAction == InstanceCompletionAction.DeleteAll) }); 97parameters.Add(new SqlParameter { ParameterName = "@encodingOption", SqlDbType = SqlDbType.TinyInt, Value = base.Store.InstanceEncodingOption }); 102Fx.Assert(base.Store.DatabaseVersion >= StoreUtilities.Version45, "Should never get here if the db version isn't 4.5 or higher"); 157base.Store.WorkflowHostType = new Guid(HashHelper.ComputeHash(workflowHostTypeBuffer));
System\Activities\DurableInstancing\DetectActivatableWorkflowsAsyncResult.cs (3)
38SqlConnectionStringBuilder builder = new SqlConnectionStringBuilder(base.Store.CachedConnectionString); 70base.Store.UpdateEventStatus(true, HasActivatableWorkflowEvent.Value); 74base.Store.UpdateEventStatus(false, HasActivatableWorkflowEvent.Value);
System\Activities\DurableInstancing\DetectRunnableInstancesAsyncResult.cs (5)
38SqlConnectionStringBuilder builder = new SqlConnectionStringBuilder(base.Store.CachedConnectionString); 46sqlCommand.Parameters.Add(new SqlParameter { ParameterName = "@workflowHostType", SqlDbType = SqlDbType.UniqueIdentifier, Value = base.Store.WorkflowHostType }); 47if (base.Store.DatabaseVersion >= StoreUtilities.Version45) 89base.Store.UpdateEventStatus(true, HasRunnableWorkflowEvent.Value); 93base.Store.UpdateEventStatus(false, HasRunnableWorkflowEvent.Value);
System\Activities\DurableInstancing\ExtendLockAsyncResult.cs (2)
37SqlConnectionStringBuilder builder = new SqlConnectionStringBuilder(base.Store.CachedConnectionString); 46double lockTimeout = base.Store.BufferedHostLockRenewalPeriod.TotalSeconds;
System\Activities\DurableInstancing\LoadWorkflowAsyncResult.cs (1)
72parameters.Add(new SqlParameter { ParameterName = "@encodingOption", SqlDbType = SqlDbType.TinyInt, Value = base.Store.InstanceEncodingOption });
System\Activities\DurableInstancing\LoadWorkflowByKeyAsyncResult.cs (1)
34List<CorrelationKey> keysToAssociate = CorrelationKey.BuildKeyList(keyLoadCommand.InstanceKeysToAssociate, base.Store.InstanceEncodingOption);
System\Activities\DurableInstancing\QueryActivatableWorkflowAsyncResult.cs (1)
57base.Store.UpdateEventStatus(false, HasActivatableWorkflowEvent.Value);
System\Activities\DurableInstancing\RecoverInstanceLocksAsyncResult.cs (1)
37SqlConnectionStringBuilder builder = new SqlConnectionStringBuilder(base.Store.CachedConnectionString);
System\Activities\DurableInstancing\SaveWorkflowAsyncResult.cs (8)
89if (base.Store.DatabaseVersion >= StoreUtilities.Version45) 477if (saveWorkflowCommand.CompleteInstance && base.Store.InstanceCompletionAction == InstanceCompletionAction.DeleteAll) 498List<CorrelationKey> keysToAssociate = CorrelationKey.BuildKeyList(saveWorkflowCommand.InstanceKeysToAssociate, base.Store.InstanceEncodingOption); 501ArraySegment<byte>[] dataProperties = SerializationUtilities.SerializePropertyBag(saveWorkflowCommand.InstanceData, base.Store.InstanceEncodingOption); 502ArraySegment<byte> metadataProperties = SerializationUtilities.SerializeMetadataPropertyBag(saveWorkflowCommand, base.InstancePersistenceContext, base.Store.InstanceEncodingOption); 513parameters.Add(new SqlParameter { ParameterName = "@encodingOption", SqlDbType = SqlDbType.TinyInt, Value = base.Store.InstanceEncodingOption }); 536foreach (KeyValuePair<string, Tuple<List<XName>, List<XName>>> promotion in base.Store.Promotions) 579IObjectSerializer serializer = ObjectSerializerFactory.GetObjectSerializer(base.Store.InstanceEncodingOption);
System\Activities\DurableInstancing\SqlWorkflowInstanceStoreAsyncResult.cs (2)
66return this.Store.CachedConnectionString; 327if (this.Store.IsLockRetryEnabled() && (exception is InstanceLockedException))
System\Activities\DurableInstancing\TestVersionAndRunAsyncResult.cs (7)
43if (this.Store.DatabaseVersion != null) 81this.Store.DatabaseVersion = GetVersion(reader) ?? StoreUtilities.Version40; 114this.Store.DatabaseVersion = StoreUtilities.Version40; 126thisPtr.Store.EndTryCommand(result); 173if (this.Store.DatabaseVersion >= this.targetVersion) 175this.Store.BeginTryCommandInternal(this.InstancePersistenceContext, this.InstancePersistenceCommand, this.currentTransaction, this.TimeoutHelper.RemainingTime(), instanceCommandCompleteCallback, this); 179throw FxTrace.Exception.AsError(new InstancePersistenceCommandException(SR.DatabaseUpgradeRequiredForCommand(this.Store.DatabaseVersion, this.InstancePersistenceCommand, this.targetVersion)));
System\Activities\DurableInstancing\TryLoadRunnableWorkflowAsyncResult.cs (4)
31if (base.Store.WorkflowHostType == Guid.Empty) 42command.Parameters.Add(new SqlParameter { ParameterName = "@workflowHostType", SqlDbType = SqlDbType.UniqueIdentifier, Value = base.Store.WorkflowHostType }); 46command.Parameters.Add(new SqlParameter { ParameterName = "@encodingOption", SqlDbType = SqlDbType.TinyInt, Value = base.Store.InstanceEncodingOption }); 64base.Store.UpdateEventStatus(false, HasRunnableWorkflowEvent.Value);