Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / WF / Activities / Rules / RuleSet.cs / 1305376 / RuleSet.cs
// ---------------------------------------------------------------------------- // Copyright (C) 2005 Microsoft Corporation All Rights Reserved // --------------------------------------------------------------------------- using System.Collections.Generic; using System.ComponentModel; using System.Workflow.ComponentModel; using System.Workflow.ComponentModel.Compiler; using System.Workflow.Activities.Common; namespace System.Workflow.Activities.Rules { public enum RuleChainingBehavior { None, UpdateOnly, Full }; [Serializable] public class RuleSet { internal const string RuleSetTrackingKey = "RuleSet."; internal string name; internal string description; internal Listrules; internal RuleChainingBehavior behavior = RuleChainingBehavior.Full; private bool runtimeInitialized; private object syncLock = new object(); // keep track of cached data [NonSerialized] private RuleEngine cachedEngine; [NonSerialized] private RuleValidation cachedValidation; public RuleSet() { this.rules = new List (); } public RuleSet(string name) : this() { this.name = name; } public RuleSet(string name, string description) : this(name) { this.description = description; } public string Name { get { return name; } set { if (runtimeInitialized) throw new InvalidOperationException(SR.GetString(SR.Error_CanNotChangeAtRuntime)); name = value; } } public string Description { get { return description; } set { if (runtimeInitialized) throw new InvalidOperationException(SR.GetString(SR.Error_CanNotChangeAtRuntime)); description = value; } } public RuleChainingBehavior ChainingBehavior { get { return behavior; } set { if (runtimeInitialized) throw new InvalidOperationException(SR.GetString(SR.Error_CanNotChangeAtRuntime)); behavior = value; } } [DesignerSerializationVisibility(DesignerSerializationVisibility.Content)] public ICollection Rules { get { return rules; } } public bool Validate(RuleValidation validation) { if (validation == null) throw new ArgumentNullException("validation"); // Validate each rule. Dictionary ruleNames = new Dictionary (); foreach (Rule r in rules) { if (!string.IsNullOrEmpty(r.Name)) // invalid names caught when validating the rule { if (ruleNames.ContainsKey(r.Name)) { // Duplicate rule name found. ValidationError error = new ValidationError(Messages.Error_DuplicateRuleName, ErrorNumbers.Error_DuplicateConditions); error.UserData[RuleUserDataKeys.ErrorObject] = r; validation.AddError(error); } else { ruleNames.Add(r.Name, null); } } r.Validate(validation); } if (validation.Errors == null || validation.Errors.Count == 0) return true; return false; } public void Execute(RuleExecution ruleExecution) { // we have no way of knowing if the ruleset has been changed, so no caching done if (ruleExecution == null) throw new ArgumentNullException("ruleExecution"); if (ruleExecution.Validation == null) throw new ArgumentException(SR.GetString(SR.Error_MissingValidationProperty), "ruleExecution"); RuleEngine engine = new RuleEngine(this, ruleExecution.Validation, ruleExecution.ActivityExecutionContext); engine.Execute(ruleExecution); } internal void Execute(Activity activity, ActivityExecutionContext executionContext) { // this can be called from multiple threads if multiple workflows are // running at the same time (only a single workflow is single-threaded) // we want to only lock around the validation and preprocessing, so that // execution can run in parallel. if (activity == null) throw new ArgumentNullException("activity"); Type activityType = activity.GetType(); RuleEngine engine = null; lock (syncLock) { // do we have something useable cached? if ((cachedEngine == null) || (cachedValidation == null) || (cachedValidation.ThisType != activityType)) { // no cache (or its invalid) RuleValidation validation = new RuleValidation(activityType, null); engine = new RuleEngine(this, validation, executionContext); cachedValidation = validation; cachedEngine = engine; } else { // this will happen if the ruleset has already been processed // we can simply use the previously processed engine engine = cachedEngine; } } // when we get here, we have a local RuleEngine all ready to go // we are outside the lock, so these can run in parallel engine.Execute(activity, executionContext); } public RuleSet Clone() { RuleSet newRuleSet = (RuleSet)this.MemberwiseClone(); newRuleSet.runtimeInitialized = false; if (this.rules != null) { newRuleSet.rules = new List (); foreach (Rule r in this.rules) newRuleSet.rules.Add(r.Clone()); } return newRuleSet; } public override bool Equals(object obj) { RuleSet other = obj as RuleSet; if (other == null) return false; if ((this.Name != other.Name) || (this.Description != other.Description) || (this.ChainingBehavior != other.ChainingBehavior) || (this.Rules.Count != other.Rules.Count)) return false; // look similar, compare each rule for (int i = 0; i < this.rules.Count; ++i) { if (!this.rules[i].Equals(other.rules[i])) return false; } return true; } public override int GetHashCode() { return base.GetHashCode(); } internal void OnRuntimeInitialized() { lock (syncLock) { if (runtimeInitialized) return; foreach (Rule rule in rules) { rule.OnRuntimeInitialized(); } runtimeInitialized = true; } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved. // ---------------------------------------------------------------------------- // Copyright (C) 2005 Microsoft Corporation All Rights Reserved // --------------------------------------------------------------------------- using System.Collections.Generic; using System.ComponentModel; using System.Workflow.ComponentModel; using System.Workflow.ComponentModel.Compiler; using System.Workflow.Activities.Common; namespace System.Workflow.Activities.Rules { public enum RuleChainingBehavior { None, UpdateOnly, Full }; [Serializable] public class RuleSet { internal const string RuleSetTrackingKey = "RuleSet."; internal string name; internal string description; internal List rules; internal RuleChainingBehavior behavior = RuleChainingBehavior.Full; private bool runtimeInitialized; private object syncLock = new object(); // keep track of cached data [NonSerialized] private RuleEngine cachedEngine; [NonSerialized] private RuleValidation cachedValidation; public RuleSet() { this.rules = new List (); } public RuleSet(string name) : this() { this.name = name; } public RuleSet(string name, string description) : this(name) { this.description = description; } public string Name { get { return name; } set { if (runtimeInitialized) throw new InvalidOperationException(SR.GetString(SR.Error_CanNotChangeAtRuntime)); name = value; } } public string Description { get { return description; } set { if (runtimeInitialized) throw new InvalidOperationException(SR.GetString(SR.Error_CanNotChangeAtRuntime)); description = value; } } public RuleChainingBehavior ChainingBehavior { get { return behavior; } set { if (runtimeInitialized) throw new InvalidOperationException(SR.GetString(SR.Error_CanNotChangeAtRuntime)); behavior = value; } } [DesignerSerializationVisibility(DesignerSerializationVisibility.Content)] public ICollection Rules { get { return rules; } } public bool Validate(RuleValidation validation) { if (validation == null) throw new ArgumentNullException("validation"); // Validate each rule. Dictionary ruleNames = new Dictionary (); foreach (Rule r in rules) { if (!string.IsNullOrEmpty(r.Name)) // invalid names caught when validating the rule { if (ruleNames.ContainsKey(r.Name)) { // Duplicate rule name found. ValidationError error = new ValidationError(Messages.Error_DuplicateRuleName, ErrorNumbers.Error_DuplicateConditions); error.UserData[RuleUserDataKeys.ErrorObject] = r; validation.AddError(error); } else { ruleNames.Add(r.Name, null); } } r.Validate(validation); } if (validation.Errors == null || validation.Errors.Count == 0) return true; return false; } public void Execute(RuleExecution ruleExecution) { // we have no way of knowing if the ruleset has been changed, so no caching done if (ruleExecution == null) throw new ArgumentNullException("ruleExecution"); if (ruleExecution.Validation == null) throw new ArgumentException(SR.GetString(SR.Error_MissingValidationProperty), "ruleExecution"); RuleEngine engine = new RuleEngine(this, ruleExecution.Validation, ruleExecution.ActivityExecutionContext); engine.Execute(ruleExecution); } internal void Execute(Activity activity, ActivityExecutionContext executionContext) { // this can be called from multiple threads if multiple workflows are // running at the same time (only a single workflow is single-threaded) // we want to only lock around the validation and preprocessing, so that // execution can run in parallel. if (activity == null) throw new ArgumentNullException("activity"); Type activityType = activity.GetType(); RuleEngine engine = null; lock (syncLock) { // do we have something useable cached? if ((cachedEngine == null) || (cachedValidation == null) || (cachedValidation.ThisType != activityType)) { // no cache (or its invalid) RuleValidation validation = new RuleValidation(activityType, null); engine = new RuleEngine(this, validation, executionContext); cachedValidation = validation; cachedEngine = engine; } else { // this will happen if the ruleset has already been processed // we can simply use the previously processed engine engine = cachedEngine; } } // when we get here, we have a local RuleEngine all ready to go // we are outside the lock, so these can run in parallel engine.Execute(activity, executionContext); } public RuleSet Clone() { RuleSet newRuleSet = (RuleSet)this.MemberwiseClone(); newRuleSet.runtimeInitialized = false; if (this.rules != null) { newRuleSet.rules = new List (); foreach (Rule r in this.rules) newRuleSet.rules.Add(r.Clone()); } return newRuleSet; } public override bool Equals(object obj) { RuleSet other = obj as RuleSet; if (other == null) return false; if ((this.Name != other.Name) || (this.Description != other.Description) || (this.ChainingBehavior != other.ChainingBehavior) || (this.Rules.Count != other.Rules.Count)) return false; // look similar, compare each rule for (int i = 0; i < this.rules.Count; ++i) { if (!this.rules[i].Equals(other.rules[i])) return false; } return true; } public override int GetHashCode() { return base.GetHashCode(); } internal void OnRuntimeInitialized() { lock (syncLock) { if (runtimeInitialized) return; foreach (Rule rule in rules) { rule.OnRuntimeInitialized(); } runtimeInitialized = true; } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- InvalidOleVariantTypeException.cs
- FontInfo.cs
- TableItemProviderWrapper.cs
- ListViewTableCell.cs
- COM2PropertyPageUITypeConverter.cs
- LocatorGroup.cs
- XmlTypeMapping.cs
- Stack.cs
- EdmSchemaError.cs
- DeferredSelectedIndexReference.cs
- DataGridToolTip.cs
- FileRegion.cs
- ObjectDataSourceDisposingEventArgs.cs
- SchemaImporterExtension.cs
- InlineCollection.cs
- Image.cs
- EnvironmentPermission.cs
- XmlSerializableWriter.cs
- URLMembershipCondition.cs
- CollectionBuilder.cs
- TextAction.cs
- ObjectDataSourceStatusEventArgs.cs
- FilteredAttributeCollection.cs
- WebPartDisplayModeCancelEventArgs.cs
- DateTimeStorage.cs
- AccessKeyManager.cs
- BaseTemplatedMobileComponentEditor.cs
- GridViewCancelEditEventArgs.cs
- HtmlShimManager.cs
- ExitEventArgs.cs
- InfoCardSchemas.cs
- RelationshipEndMember.cs
- StylusPlugin.cs
- ToolZone.cs
- QueryCacheKey.cs
- IncrementalHitTester.cs
- FormsAuthenticationEventArgs.cs
- FactoryRecord.cs
- SerialPinChanges.cs
- IBuiltInEvidence.cs
- Faults.cs
- PriorityBindingExpression.cs
- EnumerableValidator.cs
- DummyDataSource.cs
- WindowsScrollBarBits.cs
- Evidence.cs
- HostDesigntimeLicenseContext.cs
- ButtonFlatAdapter.cs
- ColumnMap.cs
- CriticalExceptions.cs
- storepermission.cs
- InputLanguage.cs
- ManipulationPivot.cs
- FormViewModeEventArgs.cs
- ItemMap.cs
- StringExpressionSet.cs
- StructuralObject.cs
- HttpListenerPrefixCollection.cs
- JulianCalendar.cs
- Int16Converter.cs
- SwitchExpression.cs
- ConvertEvent.cs
- InvalidDataContractException.cs
- TraceSection.cs
- LocatorManager.cs
- DbCommandTree.cs
- X509Certificate.cs
- RegexBoyerMoore.cs
- ImportOptions.cs
- RepeaterItemCollection.cs
- MetadataItemCollectionFactory.cs
- ProcessProtocolHandler.cs
- ResXResourceReader.cs
- ThreadSafeList.cs
- XmlSchemaSearchPattern.cs
- HttpApplication.cs
- GeometryConverter.cs
- StylusPointPropertyUnit.cs
- XmlSchemaGroupRef.cs
- Int16.cs
- SemaphoreSecurity.cs
- ExtensionSimplifierMarkupObject.cs
- SqlDataSourceCommandEventArgs.cs
- ExchangeUtilities.cs
- BinHexDecoder.cs
- MetadataStore.cs
- sqlser.cs
- SimplePropertyEntry.cs
- TypeLoadException.cs
- ReflectionPermission.cs
- DebugHandleTracker.cs
- MarkupCompilePass1.cs
- HttpSessionStateWrapper.cs
- MessagePropertyAttribute.cs
- _NTAuthentication.cs
- CfgParser.cs
- GreenMethods.cs
- RuntimeEnvironment.cs
- AlternateView.cs
- RawStylusActions.cs