Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / WF / Common / AuthoringOM / ActivityExecutorOperation.cs / 1305376 / ActivityExecutorOperation.cs
namespace System.Workflow.ComponentModel { using System; using System.Diagnostics; using System.Globalization; using System.Collections.Generic; [Serializable] internal abstract class SchedulableItem { private int contextId = -1; string activityId = null; protected SchedulableItem(int contextId, string activityId) { this.contextId = contextId; this.activityId = activityId; } public int ContextId { get { return this.contextId; } } public string ActivityId { get { return this.activityId; } } public abstract bool Run(IWorkflowCoreRuntime workflowCoreRuntime); } internal enum ActivityOperationType : byte { Execute = 0, Cancel = 1, Compensate = 2, HandleFault = 3 } [Serializable] internal sealed class ActivityExecutorOperation : SchedulableItem { private string activityName; private ActivityOperationType operation; private Exception exceptionToDeliver; public ActivityExecutorOperation(Activity activity, ActivityOperationType opt, int contextId) : base(contextId, activity.QualifiedName) { this.activityName = activity.QualifiedName; this.operation = opt; } public ActivityExecutorOperation(Activity activity, ActivityOperationType opt, int contextId, Exception e) : this(activity, opt, contextId) { this.exceptionToDeliver = e; } public override bool Run(IWorkflowCoreRuntime workflowCoreRuntime) { // get state reader Activity contextActivity = workflowCoreRuntime.GetContextActivityForId(this.ContextId); Activity activity = contextActivity.GetActivityByName(this.activityName); using (workflowCoreRuntime.SetCurrentActivity(activity)) { using (ActivityExecutionContext activityExecutionContext = new ActivityExecutionContext(activity)) { ActivityExecutor activityExecutor = ActivityExecutors.GetActivityExecutor(activity); switch (this.operation) { case ActivityOperationType.Execute: if (activity.ExecutionStatus == ActivityExecutionStatus.Executing) { try { workflowCoreRuntime.RaiseActivityExecuting(activity); ActivityExecutionStatus newStatus = activityExecutor.Execute(activity, activityExecutionContext); if (newStatus == ActivityExecutionStatus.Closed) activityExecutionContext.CloseActivity(); else if (newStatus != ActivityExecutionStatus.Executing) throw new InvalidOperationException(SR.GetString(SR.InvalidExecutionStatus, activity.QualifiedName, newStatus.ToString(), ActivityExecutionStatus.Executing.ToString())); } catch (Exception e) { System.Workflow.Runtime.WorkflowTrace.Runtime.TraceEvent(TraceEventType.Error, 1, "Execute of Activity {0} threw {1}", activity.QualifiedName, e.ToString()); throw; } } break; case ActivityOperationType.Cancel: if (activity.ExecutionStatus == ActivityExecutionStatus.Canceling) { try { ActivityExecutionStatus newStatus = activityExecutor.Cancel(activity, activityExecutionContext); if (newStatus == ActivityExecutionStatus.Closed) activityExecutionContext.CloseActivity(); else if (newStatus != ActivityExecutionStatus.Canceling) throw new InvalidOperationException(SR.GetString(SR.InvalidExecutionStatus, activity.QualifiedName, newStatus.ToString(), ActivityExecutionStatus.Canceling.ToString())); } catch (Exception e) { System.Workflow.Runtime.WorkflowTrace.Runtime.TraceEvent(TraceEventType.Error, 1, "Cancel of Activity {0} threw {1}", activity.QualifiedName, e.ToString()); throw; } } break; case ActivityOperationType.Compensate: if (activity.ExecutionStatus == ActivityExecutionStatus.Compensating) { try { ActivityExecutionStatus newStatus = activityExecutor.Compensate(activity, activityExecutionContext); if (newStatus == ActivityExecutionStatus.Closed) activityExecutionContext.CloseActivity(); else if (newStatus != ActivityExecutionStatus.Compensating) throw new InvalidOperationException(SR.GetString(SR.InvalidExecutionStatus, activity.QualifiedName, newStatus.ToString(), ActivityExecutionStatus.Compensating.ToString())); } catch (Exception e) { System.Workflow.Runtime.WorkflowTrace.Runtime.TraceEvent(TraceEventType.Error, 1, "Compensate of Activity {0} threw {1}", activity.QualifiedName, e.ToString()); throw; } } break; case ActivityOperationType.HandleFault: if (activity.ExecutionStatus == ActivityExecutionStatus.Faulting) { try { ActivityExecutionStatus newStatus = activityExecutor.HandleFault(activity, activityExecutionContext, this.exceptionToDeliver); if (newStatus == ActivityExecutionStatus.Closed) activityExecutionContext.CloseActivity(); else if (newStatus != ActivityExecutionStatus.Faulting) throw new InvalidOperationException(SR.GetString(SR.InvalidExecutionStatus, activity.QualifiedName, newStatus.ToString(), ActivityExecutionStatus.Faulting.ToString())); } catch (Exception e) { System.Workflow.Runtime.WorkflowTrace.Runtime.TraceEvent(TraceEventType.Error, 1, "Compensate of Activity {0} threw {1}", activity.QualifiedName, e.ToString()); throw; } } break; } } } return true; } public override string ToString() { return "ActivityOperation(" + "(" + this.ContextId.ToString(CultureInfo.CurrentCulture) + ")" + this.activityName + ", " + ActivityOperationToString(this.operation) + ")"; } private string ActivityOperationToString(ActivityOperationType operationType) { string retVal = string.Empty; switch (operationType) { case ActivityOperationType.Execute: retVal = "Execute"; break; case ActivityOperationType.Cancel: retVal = "Cancel"; break; case ActivityOperationType.HandleFault: retVal = "HandleFault"; break; case ActivityOperationType.Compensate: retVal = "Compensate"; break; } return retVal; } } } // 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
- Line.cs
- ToolStripPanelRow.cs
- PrefixQName.cs
- EmptyEnumerator.cs
- State.cs
- UpdateCommandGenerator.cs
- XmlSchemaAttributeGroup.cs
- IntPtr.cs
- CollectionBuilder.cs
- BindingWorker.cs
- GetPageCompletedEventArgs.cs
- StreamGeometry.cs
- TranslateTransform3D.cs
- UnionCodeGroup.cs
- MediaPlayer.cs
- WebPartConnectionsEventArgs.cs
- NativeStructs.cs
- XmlILOptimizerVisitor.cs
- UserValidatedEventArgs.cs
- CreateUserErrorEventArgs.cs
- BindingMemberInfo.cs
- BitmapSourceSafeMILHandle.cs
- RegistryKey.cs
- HttpHandlerAction.cs
- DeleteMemberBinder.cs
- StylusTouchDevice.cs
- XMLSyntaxException.cs
- LambdaExpression.cs
- SqlDataSourceEnumerator.cs
- Root.cs
- TypeBuilder.cs
- EntityType.cs
- Registry.cs
- DefaultObjectMappingItemCollection.cs
- XsltContext.cs
- ExceptionHelpers.cs
- PointAnimationBase.cs
- FileUtil.cs
- DiscoveryDocumentReference.cs
- TreeViewHitTestInfo.cs
- GridViewCellAutomationPeer.cs
- InvokePattern.cs
- TraceHwndHost.cs
- RequestCachePolicyConverter.cs
- RMEnrollmentPage1.cs
- SchemaExporter.cs
- EventLogTraceListener.cs
- DeploymentExceptionMapper.cs
- WmlControlAdapter.cs
- SelectionItemPattern.cs
- SamlAction.cs
- ModelPerspective.cs
- XamlToRtfWriter.cs
- CompilerParameters.cs
- ServiceModelConfigurationElementCollection.cs
- X509AudioLogo.cs
- StyleSheetComponentEditor.cs
- DbConnectionPoolGroup.cs
- Util.cs
- StorageConditionPropertyMapping.cs
- KoreanLunisolarCalendar.cs
- SqlFunctionAttribute.cs
- DataGridState.cs
- CfgParser.cs
- InertiaRotationBehavior.cs
- Drawing.cs
- MailAddress.cs
- RecordsAffectedEventArgs.cs
- DataGrid.cs
- Clock.cs
- IISMapPath.cs
- DataColumnPropertyDescriptor.cs
- unsafenativemethodsother.cs
- DetailsView.cs
- SemanticTag.cs
- FloatAverageAggregationOperator.cs
- FileDataSourceCache.cs
- ActivityExecutionWorkItem.cs
- WebPartTransformer.cs
- NotConverter.cs
- KeyNotFoundException.cs
- SqlUtil.cs
- AuthenticationModulesSection.cs
- MergablePropertyAttribute.cs
- SettingsSection.cs
- FocusWithinProperty.cs
- HttpClientCertificate.cs
- MultipleViewPattern.cs
- RunWorkerCompletedEventArgs.cs
- TabControl.cs
- PreservationFileWriter.cs
- RegistryPermission.cs
- TreeViewHitTestInfo.cs
- BadImageFormatException.cs
- OracleParameterBinding.cs
- IPPacketInformation.cs
- PriorityBinding.cs
- BuildResult.cs
- RichTextBoxConstants.cs
- Console.cs