Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / WF / Common / AuthoringOM / ActivityExecutor.cs / 1305376 / ActivityExecutor.cs
using System; using System.Collections.Generic; using System.Text; using System.Collections; using System.Runtime.Serialization; using System.Security.Permissions; namespace System.Workflow.ComponentModel { #region ActivityExecutor internal abstract class ActivityExecutor { public abstract ActivityExecutionStatus Execute(Activity activity, ActivityExecutionContext executionContext); public abstract ActivityExecutionStatus Cancel(Activity activity, ActivityExecutionContext executionContext); public abstract ActivityExecutionStatus HandleFault(Activity activity, ActivityExecutionContext executionContext, Exception exception); public abstract ActivityExecutionStatus Compensate(Activity activity, ActivityExecutionContext executionContext); } internal class ActivityExecutor: ActivityExecutor where T : Activity { #region System.Workflow.ComponentModel.ActivityExecutor Methods public sealed override ActivityExecutionStatus Execute(Activity activity, ActivityExecutionContext executionContext) { return this.Execute((T)activity, executionContext); } public sealed override ActivityExecutionStatus Cancel(Activity activity, ActivityExecutionContext executionContext) { return this.Cancel((T)activity, executionContext); } public sealed override ActivityExecutionStatus HandleFault(Activity activity, ActivityExecutionContext executionContext, Exception exception) { return this.HandleFault((T)activity, executionContext, exception); } public sealed override ActivityExecutionStatus Compensate(Activity activity, ActivityExecutionContext executionContext) { return this.Compensate((T)activity, executionContext); } #endregion #region ActivityExecutor Members protected virtual ActivityExecutionStatus Execute(T activity, ActivityExecutionContext executionContext) { if (activity == null) throw new ArgumentNullException("activity"); if (executionContext == null) throw new ArgumentNullException("executionContext"); return activity.Execute(executionContext); } protected virtual ActivityExecutionStatus Cancel(T activity, ActivityExecutionContext executionContext) { if (activity == null) throw new ArgumentNullException("activity"); if (executionContext == null) throw new ArgumentNullException("executionContext"); return activity.Cancel(executionContext); } protected virtual ActivityExecutionStatus HandleFault(T activity, ActivityExecutionContext executionContext, Exception exception) { if (activity == null) throw new ArgumentNullException("activity"); if (executionContext == null) throw new ArgumentNullException("executionContext"); return activity.HandleFault(executionContext, exception); } protected virtual ActivityExecutionStatus Compensate(T activity, ActivityExecutionContext executionContext) { if (activity == null) throw new ArgumentNullException("activity"); if (executionContext == null) throw new ArgumentNullException("executionContext"); System.Diagnostics.Debug.Assert(activity is ICompensatableActivity, "should not get Compensate, if activity is not compensatable"); return ((ICompensatableActivity)activity).Compensate(executionContext); } #endregion ActivityExecutor } #endregion #region CompositeActivityExecutor internal class CompositeActivityExecutor : ActivityExecutor , ISupportWorkflowChanges where T : CompositeActivity { //@@undone:mayankm Once all ActivityExecutor is removed this method should not be virtual. void ISupportWorkflowChanges.OnActivityAdded(ActivityExecutionContext executionContext, Activity addedActivity) { if (executionContext == null) throw new ArgumentNullException("executionContext"); if (addedActivity == null) throw new ArgumentNullException("addedActivity"); CompositeActivity compositeActivity = executionContext.Activity as CompositeActivity; if (compositeActivity == null) throw new ArgumentException(SR.Error_InvalidActivityExecutionContext, "executionContext"); compositeActivity.OnActivityChangeAdd(executionContext, addedActivity); } void ISupportWorkflowChanges.OnActivityRemoved(ActivityExecutionContext executionContext, Activity removedActivity) { if (executionContext == null) throw new ArgumentNullException("executionContext"); if (removedActivity == null) throw new ArgumentNullException("removedActivity"); CompositeActivity compositeActivity = executionContext.Activity as CompositeActivity; if (compositeActivity == null) throw new ArgumentException(SR.Error_InvalidActivityExecutionContext, "executionContext"); compositeActivity.OnActivityChangeRemove(executionContext, removedActivity); } void ISupportWorkflowChanges.OnWorkflowChangesCompleted(ActivityExecutionContext executionContext) { if (executionContext == null) throw new ArgumentNullException("executionContext"); CompositeActivity compositeActivity = executionContext.Activity as CompositeActivity; if (compositeActivity == null) throw new ArgumentException(SR.Error_InvalidActivityExecutionContext, "executionContext"); compositeActivity.OnWorkflowChangesCompleted(executionContext); } // Refer Bug 9339 (VB Compilation Failure - Unable to load one or more of the requested types. Retrieve the LoaderExceptions property for more information.) //An unhandled exception of type 'System.TypeLoadException' occurred // "Signature of the body and declaration in a method implementation do not match" protected override ActivityExecutionStatus Execute(T activity, ActivityExecutionContext executionContext) { return base.Execute(activity, executionContext); } protected override ActivityExecutionStatus Cancel(T activity, ActivityExecutionContext executionContext) { return base.Cancel(activity, executionContext); } } #endregion #region ActivityExecutors Class internal static class ActivityExecutors { private static Hashtable typeToExecutorMapping = new Hashtable(); private static Hashtable executors = new Hashtable(); internal static ActivityExecutor[] GetActivityExecutors(Activity activity) { if (activity == null) throw new ArgumentNullException("activity"); Type activityType = activity.GetType(); ActivityExecutor[] activityExecutors = executors[activityType] as ActivityExecutor[]; if (activityExecutors != null) return activityExecutors; lock (executors.SyncRoot) { activityExecutors = executors[activityType] as ActivityExecutor[]; if (activityExecutors != null) return activityExecutors; object[] activityExecutorsObjects = null; try { //activityExecutorsObjects = ComponentDispenser.CreateComponents(activityType, typeof(ActivityExecutorAttribute)); activityExecutorsObjects = ComponentDispenser.CreateActivityExecutors(activity); } catch (Exception e) { throw new InvalidOperationException(SR.GetString(SR.ExecutorCreationFailedErrorMessage, activityType.FullName), e); } if (activityExecutorsObjects == null || activityExecutorsObjects.Length == 0) throw new InvalidOperationException(SR.GetString(SR.ExecutorCreationFailedErrorMessage, activityType.FullName)); activityExecutors = new ActivityExecutor[activityExecutorsObjects.Length]; for (int index = 0; index < activityExecutorsObjects.Length; index++) { if (!typeToExecutorMapping.Contains(activityExecutorsObjects[index].GetType())) { lock (typeToExecutorMapping.SyncRoot) { if (!typeToExecutorMapping.Contains(activityExecutorsObjects[index].GetType())) { System.Threading.Thread.MemoryBarrier(); typeToExecutorMapping[activityExecutorsObjects[index].GetType()] = activityExecutorsObjects[index]; } } } activityExecutors[index] = (ActivityExecutor)typeToExecutorMapping[activityExecutorsObjects[index].GetType()]; } System.Threading.Thread.MemoryBarrier(); executors[activityType] = activityExecutors; } return activityExecutors; } public static ActivityExecutor GetActivityExecutorFromType(Type executorType) { if (executorType == null) throw new ArgumentNullException("executorType"); if (!typeof(ActivityExecutor).IsAssignableFrom(executorType)) throw new ArgumentException( SR.GetString(SR.Error_NonActivityExecutor, executorType.FullName), "executorType"); ActivityExecutor activityExecutor = typeToExecutorMapping[executorType] as ActivityExecutor; if (activityExecutor != null) return activityExecutor; lock (typeToExecutorMapping.SyncRoot) { activityExecutor = typeToExecutorMapping[executorType] as ActivityExecutor; if (activityExecutor != null) return activityExecutor; System.Threading.Thread.MemoryBarrier(); typeToExecutorMapping[executorType] = Activator.CreateInstance(executorType); } return (ActivityExecutor)typeToExecutorMapping[executorType]; } public static ActivityExecutor GetActivityExecutor(Activity activity) { if (activity == null) throw new ArgumentNullException("activity"); return GetActivityExecutors(activity)[0]; } } #endregion } // 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
- PassportIdentity.cs
- Simplifier.cs
- EncryptedPackage.cs
- CodePageEncoding.cs
- GlobalAllocSafeHandle.cs
- DateBoldEvent.cs
- OdbcParameter.cs
- DeviceSpecificDialogCachedState.cs
- MarkupExtensionReturnTypeAttribute.cs
- DependencyPropertyChangedEventArgs.cs
- PrintController.cs
- ZipFileInfo.cs
- WebPartConnectionCollection.cs
- TdsParser.cs
- X509Certificate.cs
- WebResponse.cs
- SchemaTableColumn.cs
- SaveFileDialog.cs
- GeometryDrawing.cs
- Aggregates.cs
- QilExpression.cs
- BaseUriWithWildcard.cs
- SplineQuaternionKeyFrame.cs
- DocumentPageView.cs
- ReadOnlyDataSourceView.cs
- XXXInfos.cs
- HtmlWindow.cs
- InvalidProgramException.cs
- WebZone.cs
- bidPrivateBase.cs
- GZipUtils.cs
- QilNode.cs
- PageAsyncTaskManager.cs
- CacheForPrimitiveTypes.cs
- DependencyPropertyConverter.cs
- TimeSpanOrInfiniteConverter.cs
- ListViewInsertionMark.cs
- UnsafeNetInfoNativeMethods.cs
- WebBrowserPermission.cs
- securitymgrsite.cs
- KeyedHashAlgorithm.cs
- Exceptions.cs
- XXXOnTypeBuilderInstantiation.cs
- ComponentEvent.cs
- AncestorChangedEventArgs.cs
- SignalGate.cs
- DataGridColumnHeaderAutomationPeer.cs
- TypeValidationEventArgs.cs
- QilXmlReader.cs
- DataListItem.cs
- PersonalizationAdministration.cs
- URLAttribute.cs
- KerberosTicketHashIdentifierClause.cs
- Char.cs
- LinqDataSourceValidationException.cs
- XmlSchemaObjectCollection.cs
- NavigatorInput.cs
- ProgressBarRenderer.cs
- XmlDocumentViewSchema.cs
- VerificationException.cs
- WebPartUserCapability.cs
- VectorAnimationBase.cs
- ToolboxItemCollection.cs
- DateTimeFormat.cs
- SafeRightsManagementPubHandle.cs
- EntityCommandCompilationException.cs
- MetadataArtifactLoaderCompositeResource.cs
- DbgUtil.cs
- Serialization.cs
- prefixendpointaddressmessagefilter.cs
- ToolStripDropDownItemDesigner.cs
- SystemGatewayIPAddressInformation.cs
- DebugControllerThread.cs
- AutoGeneratedField.cs
- AssemblyBuilderData.cs
- AdapterUtil.cs
- DelimitedListTraceListener.cs
- DataServiceRequest.cs
- EventRouteFactory.cs
- DiscoveryClientDocuments.cs
- InvalidComObjectException.cs
- CheckBoxStandardAdapter.cs
- DataGridViewCell.cs
- DocumentPageViewAutomationPeer.cs
- OdbcConnectionStringbuilder.cs
- columnmapkeybuilder.cs
- RSAPKCS1SignatureFormatter.cs
- AssemblyResourceLoader.cs
- ApplicationFileCodeDomTreeGenerator.cs
- MemberDescriptor.cs
- CellParagraph.cs
- HttpCapabilitiesBase.cs
- ViewValidator.cs
- Rect.cs
- SamlAction.cs
- Container.cs
- MetadataArtifactLoaderFile.cs
- HitTestParameters3D.cs
- XmlDocumentFragment.cs
- TimeStampChecker.cs