230 references to Activity
System.Workflow.Activities (77)
ConstrainedGroup.cs (8)
221ConditionedActivityGroup currentActivity = executionContext.Activity as ConditionedActivityGroup; 242ConditionedActivityGroup cag = executionContext.Activity as ConditionedActivityGroup; 260ConditionedActivityGroup currentActivity = executionContext.Activity as ConditionedActivityGroup; 464childContext.Activity.RegisterForStatusChange(Activity.ClosedEvent, this); 467childContext.ExecuteActivity(childContext.Activity); 499ConditionedActivityGroup cag = context.Activity as ConditionedActivityGroup; 655return childContext.Activity; 679if (cag.GetActivityByName(activeContext.Activity.QualifiedName, true) != null)
Delay.cs (1)
354Activity root = parentContext.Activity;
EventHandlers.cs (12)
131switch (childContext.Activity.ExecutionStatus) 138childContext.CancelActivity(childContext.Activity); 170EventHandlersActivity activity = (EventHandlersActivity)executionContext.Activity as EventHandlersActivity; 189EventHandlersActivity activity = (EventHandlersActivity)executionContext.Activity as EventHandlersActivity; 249EventHandlersActivity eventHandlers = context.Activity as EventHandlersActivity; 271childContext.Activity.RegisterForStatusChange(Activity.ClosedEvent, this); 272childContext.ExecuteActivity(childContext.Activity); 319EventHandlersActivity handlers = context.Activity as EventHandlersActivity; 320if (context.Activity.ExecutionStatus != ActivityExecutionStatus.Executing) 397EventHandlersActivity handlers = context.Activity as EventHandlersActivity; 410childContext.Activity.RegisterForStatusChange(Activity.ClosedEvent, handlers); 411childContext.ExecuteActivity(childContext.Activity);
EventSinkActivity.cs (1)
350HandleExternalEventActivity activity = context.Activity as HandleExternalEventActivity;
Listen.cs (3)
136ListenActivity listen = executionContext.Activity as ListenActivity; 153ListenActivity listen = executionContext.Activity as ListenActivity; 262ListenActivity parentActivity = context.Activity as ListenActivity;
LocalService\CorrelationTokenInvalidatedHandler.cs (1)
42Activity activity = context.Activity;
Parallel.cs (2)
103ParallelActivity parallel = executionContext.Activity as ParallelActivity; 154ParallelActivity parallel = context.Activity as ParallelActivity;
Sequence.cs (1)
120SequenceActivity sequenceActivity = context.Activity as SequenceActivity;
SetState.cs (1)
68StateActivity parentState = StateMachineHelpers.FindEnclosingState(executionContext.Activity);
State.cs (24)
155StateActivity state = (StateActivity)context.Activity; 175StateActivity state = (StateActivity)context.Activity; 196StateActivity state = (StateActivity)context.Activity; 239StateActivity state = (StateActivity)context.Activity; 256StateActivity state = (StateActivity)context.Activity; 278Debug.Assert(executionContext.Activity == this); 285if (existingContext.Activity.Parent == this) 289if (existingContext.Activity.ExecutionStatus == ActivityExecutionStatus.Executing) 290existingContext.CancelActivity(existingContext.Activity); 301StateActivity state = (StateActivity)context.Activity; 319StateActivity state = (StateActivity)context.Activity; 326childContext.Activity.Closed += state.HandleChildActivityClosed; 327childContext.ExecuteActivity(childContext.Activity); 336StateActivity state = (StateActivity)context.Activity; 377StateActivity state = (StateActivity)context.Activity; 420throw new InvalidOperationException(SR.GetInvalidActivityStatus(context.Activity)); 443StateActivity state = (StateActivity)context.Activity; 470StateActivity state = (StateActivity)context.Activity; 523StateActivity state = (StateActivity)context.Activity; 531StateActivity state = (StateActivity)context.Activity; 539StateActivity state = (StateActivity)context.Activity; 556StateActivity state = (StateActivity)context.Activity; 588if (executionContext.Activity.ExecutionStatus != ActivityExecutionStatus.Executing) 599StateActivity rootState = StateMachineHelpers.GetRootState(executionContext.Activity as StateActivity);
StateMachineAction.cs (2)
79Debug.Assert(context.Activity.QualifiedName.Equals(this.StateName)); 80_state = (StateActivity)context.Activity;
StateMachineExecutionState.cs (1)
162StateActivity state = (StateActivity)context.Activity;
StateMachineHelpers.cs (3)
56return (context.Activity.Parent == null); 160StateActivity state = context.Activity as StateActivity; 162state = FindEnclosingState(context.Activity);
StateMachineSubscription.cs (4)
133StateActivity rootState = StateMachineHelpers.GetRootState((StateActivity)context.Activity); 140StateActivity rootState = StateMachineHelpers.GetRootState((StateActivity)context.Activity); 218StateActivity rootState = StateMachineHelpers.GetRootState((StateActivity)context.Activity); 232StateActivity rootState = StateMachineHelpers.GetRootState((StateActivity)context.Activity);
StateMachineSubscriptionManager.cs (2)
70StateActivity state = (StateActivity)context.Activity; 182StateActivity state = (StateActivity)context.Activity;
Task.cs (6)
535base.RaiseGenericEvent(ReplicatorActivity.ChildInitializedEvent, this, new ReplicatorChildEventArgs(childStateInfo.InstanceData, templateExecutionContext.Activity)); 545templateExecutionContext.ExecuteActivity(templateExecutionContext.Activity); 546templateExecutionContext.Activity.RegisterForStatusChange(Activity.ClosedEvent, new ReplicatorSubscriber(this, templateExecutionContext.ContextGuid)); 687switch (innerProvider.Activity.ExecutionStatus) 691innerProvider.CancelActivity(innerProvider.Activity); 779((ReplicatorActivity)context.Activity).HandleStatusChange(context, e, this);
WebServiceReceive.cs (1)
369WebServiceInputActivity activity = context.Activity as WebServiceInputActivity;
While.cs (4)
105if (childContext.Activity.ExecutionStatus == ActivityExecutionStatus.Executing) 106childContext.CancelActivity(childContext.Activity); 125innerContext.Activity.RegisterForStatusChange(Activity.ClosedEvent, this); 126innerContext.ExecuteActivity(innerContext.Activity);
System.Workflow.ComponentModel (152)
AuthoringOM\Activity.cs (2)
1548if (this.GetActivityByName(childContext.Activity.QualifiedName, true) != null) 1741UninitializeCompletedContext(resurrectedContext.Activity, resurrectedContext);
AuthoringOM\ActivityExecutionContext.cs (10)
406this.Activity.SetValue(LockAcquiredCallbackProperty, new ActivityExecutorDelegateInfo<EventArgs>(true, locksAcquiredCallback, this.Activity.ContextActivity)); 407return AcquireLocks(this.Activity); 466this.Activity.RemoveProperty(LockAcquiredCallbackProperty); 471ICollection<string> handles = GetAllSynchronizationHandles(this.Activity); 476Activity parent = Activity.Parent; 508else if (grantedLocks[handle].Holder != this.Activity) 510grantedLocks[handle].WaitList.Remove(this.Activity); 545waitingActivityCallback.InvokeDelegate(this.Activity.ContextActivity, EventArgs.Empty, false, transactional); 641if (activity.Enabled && activity.Parent == this.currentActivity.WorkflowCoreRuntime.CurrentActivity && (allowContextVariance || activity.Equals(this.Activity.GetActivityByName(activity.QualifiedName, true))))
AuthoringOM\ActivityExecutionContextCollection.cs (39)
32IList<Activity> activeContexts = (IList<Activity>)this.ownerContext.Activity.ContextActivity.GetValue(Activity.ActiveExecutionContextsProperty); 68((IDependencyObjectAccessor)copiedActivity).InitializeInstanceForRuntime(this.ownerContext.Activity.WorkflowCoreRuntime); 103IList<Activity> activeContexts = (IList<Activity>)this.ownerContext.Activity.ContextActivity.GetValue(Activity.ActiveExecutionContextsProperty); 107this.ownerContext.Activity.ContextActivity.SetValue(Activity.ActiveExecutionContextsProperty, activeContexts); 119this.ownerContext.Activity.WorkflowCoreRuntime.RegisterContextActivity(copiedActivity); 124newExecutionContext.InitializeActivity(newExecutionContext.Activity); 157if (childContext.Activity == null) 160if (childContext.Activity.ContextActivity == null) 166if (childContext.Activity.ContextActivity.ExecutionStatus != ActivityExecutionStatus.Closed && childContext.Activity.ContextActivity.ExecutionStatus != ActivityExecutionStatus.Initialized) 170ActivityExecutionContextInfo childContextInfo = childContext.Activity.ContextActivity.GetValue(Activity.ActivityExecutionContextInfoProperty) as ActivityExecutionContextInfo; 171IList<Activity> activeContexts = (IList<Activity>)this.ownerContext.Activity.ContextActivity.GetValue(Activity.ActiveExecutionContextsProperty); 172if (activeContexts == null || !activeContexts.Contains(childContext.Activity.ContextActivity)) 176bool needsCompensation = childContext.Activity.NeedsCompensation; 180List<ActivityExecutionContextInfo> completedContexts = this.ownerContext.Activity.ContextActivity.GetValue(Activity.CompletedExecutionContextsProperty) as List<ActivityExecutionContextInfo>; 184this.ownerContext.Activity.ContextActivity.SetValue(Activity.CompletedExecutionContextsProperty, completedContexts); 192childContextInfo.SetCompletedOrderId(this.ownerContext.Activity.IncrementCompletedOrderId()); 196this.ownerContext.Activity.WorkflowCoreRuntime.SaveContextActivity(childContext.Activity); 200activeContexts.Remove(childContext.Activity.ContextActivity); 206if (childContext.Activity.ContextActivity.CanUninitializeNow && childContext.Activity.ContextActivity.ExecutionResult != ActivityExecutionResult.Uninitialized) 208childContext.Activity.ContextActivity.Uninitialize(this.ownerContext.Activity.RootActivity.WorkflowCoreRuntime); 209childContext.Activity.ContextActivity.SetValue(Activity.ExecutionResultProperty, ActivityExecutionResult.Uninitialized); 213this.ownerContext.Activity.WorkflowCoreRuntime.UnregisterContextActivity(childContext.Activity); 217childContext.Activity.Dispose(); 236if (context.Activity.ContextActivity.QualifiedName == activity.QualifiedName) 256List<ActivityExecutionContextInfo> completedContexts = this.ownerContext.Activity.ContextActivity.GetValue(Activity.CompletedExecutionContextsProperty) as List<ActivityExecutionContextInfo>; 274IList<ActivityExecutionContextInfo> completedContexts = this.ownerContext.Activity.ContextActivity.GetValue(Activity.CompletedExecutionContextsProperty) as IList<ActivityExecutionContextInfo>; 315List<ActivityExecutionContextInfo> completedContexts = this.ownerContext.Activity.ContextActivity.GetValue(Activity.CompletedExecutionContextsProperty) as List<ActivityExecutionContextInfo>; 327IList<ActivityExecutionContextInfo> completedContexts = this.ownerContext.Activity.ContextActivity.GetValue(Activity.CompletedExecutionContextsProperty) as IList<ActivityExecutionContextInfo>; 332Activity revokedActivity = this.ownerContext.WorkflowCoreRuntime.LoadContextActivity(contextInfo, this.ownerContext.Activity.ContextActivity.GetActivityByName(contextInfo.ActivityQualifiedName)); 333((IDependencyObjectAccessor)revokedActivity).InitializeInstanceForRuntime(this.ownerContext.Activity.WorkflowCoreRuntime); 336IList<Activity> activeContexts = (IList<Activity>)this.ownerContext.Activity.ContextActivity.GetValue(Activity.ActiveExecutionContextsProperty); 340this.ownerContext.Activity.ContextActivity.SetValue(Activity.ActiveExecutionContextsProperty, activeContexts); 345this.ownerContext.Activity.WorkflowCoreRuntime.RegisterContextActivity(revokedActivity); 350System.Workflow.Runtime.WorkflowTrace.Runtime.TraceEvent(TraceEventType.Information, 0, "Revoking context {0}:{1}", revokedContext.ContextId, revokedContext.Activity.ContextActivity.QualifiedName);
AuthoringOM\ActivityExecutor.cs (3)
96CompositeActivity compositeActivity = executionContext.Activity as CompositeActivity; 110CompositeActivity compositeActivity = executionContext.Activity as CompositeActivity; 122CompositeActivity compositeActivity = executionContext.Activity as CompositeActivity;
AuthoringOM\Behaviors\Compensate.cs (12)
98Activity commonParentActivity = context.Activity; 112return context.Activity.ExecutionStatus; 122if (targetActivity.GetActivityByName(activeContext.Activity.QualifiedName, true) != null) 124if (activeContext.Activity.ExecutionStatus == ActivityExecutionStatus.Compensating || 125activeContext.Activity.ExecutionStatus == ActivityExecutionStatus.Faulting || 126activeContext.Activity.ExecutionStatus == ActivityExecutionStatus.Canceling 128return context.Activity.ExecutionStatus; 140if (revokedExecutionContext.Activity is ICompensatableActivity) 142revokedExecutionContext.Activity.RegisterForStatusChange(Activity.ClosedEvent, this); 143revokedExecutionContext.CompensateActivity(revokedExecutionContext.Activity); 145return context.Activity.ExecutionStatus; 153return context.Activity.ExecutionStatus;
AuthoringOM\Filters\ActivityExecutionFilter.cs (9)
19NextDynamicChangeExecutorInChain(executionContext.Activity).OnActivityAdded(executionContext, addedActivity); 28NextDynamicChangeExecutorInChain(executionContext.Activity).OnActivityRemoved(executionContext, removedActivity); 35NextDynamicChangeExecutorInChain(executionContext.Activity).OnWorkflowChangesCompleted(executionContext); 48return NextActivityExecutorInChain(executionContext.Activity).Execute(activity, executionContext); 62ActivityExecutor nextActivityExecutor = NextActivityExecutorInChain(executionContext.Activity); 63if (!(nextActivityExecutor is ActivityExecutionFilter) && executionContext.Activity.HasPrimaryClosed) 79ActivityExecutor nextActivityExecutor = NextActivityExecutorInChain(executionContext.Activity); 80if (!(nextActivityExecutor is ActivityExecutionFilter) && executionContext.Activity.HasPrimaryClosed) 92return NextActivityExecutorInChain(executionContext.Activity).Compensate(activity, executionContext);
AuthoringOM\Filters\CompensationHandlingFilter.cs (33)
21executionContext.Activity.HoldLockOnStatusChange(this); 34if (e.Activity == context.Activity) 36if (context.Activity.HasPrimaryClosed && !(bool)context.Activity.GetValue(CompensateProcessedProperty)) 38context.Activity.SetValue(CompensateProcessedProperty, true); 39if (context.Activity.ExecutionResult == ActivityExecutionResult.Compensated) 42Activity compensationHandler = GetCompensationHandler(context.Activity); 54if (!CompensationUtils.TryCompensateLastCompletedChildActivity(context, context.Activity, this)) 57context.Activity.ReleaseLockOnStatusChange(this); 64context.Activity.ReleaseLockOnStatusChange(this); 74context.Activity.ReleaseLockOnStatusChange(this); 81if (!CompensationUtils.TryCompensateLastCompletedChildActivity(context, context.Activity, this)) 84context.Activity.ReleaseLockOnStatusChange(this); 196if (revokedExecutionContext.Activity is ICompensatableActivity) 198revokedExecutionContext.Activity.RegisterForStatusChange(Activity.StatusChangedEvent, statusChangeHandler); 199revokedExecutionContext.CompensateActivity(revokedExecutionContext.Activity); 202else if (revokedExecutionContext.Activity is CompositeActivity) 205Activity compensatableChild = GetLastCompensatableChild(revokedExecutionContext.Activity as CompositeActivity); 213return TryCompensateLastCompletedChildActivity(revokedExecutionContext, revokedExecutionContext.Activity, statusChangeHandler, false); 218if (lastCompensatableTarget.TargetExecutionContext.Activity is CompositeActivity) 221Activity compensatableChild = GetLastCompensatableChild(lastCompensatableTarget.TargetExecutionContext.Activity as CompositeActivity); 229return TryCompensateLastCompletedChildActivity(lastCompensatableTarget.TargetExecutionContext, lastCompensatableTarget.TargetExecutionContext.Activity, statusChangeHandler, false); 242if (targetActivity.GetActivityByName(childContext.Activity.QualifiedName, true) != null) 244if (childContext.Activity.ExecutionStatus == ActivityExecutionStatus.Closed) 245CompleteRevokedExecutionContext(childContext.Activity, childContext); 330if (targetActivity.GetActivityByName(activeContext.Activity.QualifiedName, true) != null) 333if (immediateCompensation && IsActivityInBackWorkBranch(targetActivity, activeContext.Activity)) 336if (activeContext.Activity is ICompensatableActivity && (activeContext.Activity.ExecutionStatus == ActivityExecutionStatus.Compensating || activeContext.Activity.ExecutionStatus == ActivityExecutionStatus.Faulting || activeContext.Activity.ExecutionStatus == ActivityExecutionStatus.Canceling)) 338else if (activeContext.Activity is CompositeActivity) 340Activity[] activities = GetCompensatableChildren(activeContext.Activity as CompositeActivity);
AuthoringOM\Filters\FaultHandlingFilter.cs (20)
26executionContext.Activity.HoldLockOnStatusChange(this); 36Activity handlersActivity = FaultAndCancellationHandlingFilter.GetFaultHandlers(executionContext.Activity); 46handlersActivity = FaultAndCancellationHandlingFilter.GetCancellationHandler(executionContext.Activity); 73if (e.Activity == context.Activity) 75if (context.Activity.HasPrimaryClosed && 76!(bool)context.Activity.GetValue(FaultAndCancellationHandlingFilter.FaultProcessedProperty)) 78context.Activity.SetValue(FaultAndCancellationHandlingFilter.FaultProcessedProperty, true); 80if (context.Activity.WasExecuting && 81context.Activity.ExecutionResult == ActivityExecutionResult.Faulted && 82context.Activity.GetValue(ActivityExecutionContext.CurrentExceptionProperty) != null) 85CompositeActivity exceptionHandlersActivity = FaultAndCancellationHandlingFilter.GetFaultHandlers(context.Activity); 97if (!CompensationUtils.TryCompensateLastCompletedChildActivity(context, context.Activity, this)) 101else if (context.Activity.ExecutionResult == ActivityExecutionResult.Canceled) 104Activity cancelHandler = FaultAndCancellationHandlingFilter.GetCancellationHandler(context.Activity); 114if (!CompensationUtils.TryCompensateLastCompletedChildActivity(context, context.Activity, this)) 131if (context.Activity.GetValue(ActivityExecutionContext.CurrentExceptionProperty) != null) 135if (!CompensationUtils.TryCompensateLastCompletedChildActivity(context, context.Activity, this)) 147if (!CompensationUtils.TryCompensateLastCompletedChildActivity(context, context.Activity, this)) 156context.Activity.ReleaseLockOnStatusChange(this); 160context.Activity.RemoveProperty(FaultAndCancellationHandlingFilter.FaultProcessedProperty);
AuthoringOM\Filters\SynchronizationFilter.cs (7)
39return ((ActivityExecutor)NextActivityExecutorInChain(context.Activity)).Execute(context.Activity, context); 47if (context.Activity.HasPrimaryClosed && context.Activity.LockCountOnStatusChange == 1) 51context.Activity.UnregisterForStatusChange(Activity.LockCountOnStatusChangeChangedEvent, this); 52context.Activity.ReleaseLockOnStatusChange(this); 65if (context.Activity.ExecutionStatus == ActivityExecutionStatus.Executing)
AuthoringOM\Filters\TransactionFilter.cs (14)
60if (context.Activity.HasPrimaryClosed && context.Activity.LockCountOnStatusChange == 1) 63Exception exception = (Exception)context.Activity.GetValue(ActivityExecutionContext.CurrentExceptionProperty); 66WorkflowTransactionOptions transactionOptions = TransactedContextFilter.GetTransactionOptions(context.Activity); 76context.Activity.UnregisterForStatusChange(Activity.LockCountOnStatusChangeChangedEvent, this); 77context.Activity.ReleaseLockOnStatusChange(this); 87context.Activity.UnregisterForStatusChange(Activity.LockCountOnStatusChangeChangedEvent, this); 88context.Activity.ReleaseLockOnStatusChange(this); 94context.Activity.RegisterForStatusChange(Activity.LockCountOnStatusChangeChangedEvent, this); 115context.Activity.SetValueCommon(ActivityExecutionContext.CurrentExceptionProperty, args.Exception, ActivityExecutionContext.CurrentExceptionProperty.DefaultMetadata, false); 119context.Activity.UnregisterForStatusChange(Activity.LockCountOnStatusChangeChangedEvent, this); 120context.Activity.ReleaseLockOnStatusChange(this); 132if (context.Activity.ExecutionStatus == ActivityExecutionStatus.Executing) 134ActivityExecutionStatus newStatus = TransactedContextFilter.ExecuteActivity(context.Activity, context, true);
AuthoringOM\ScheduleChanges.cs (3)
414addedActivity.OnActivityExecutionContextLoad(executionContext.Activity.RootActivity.WorkflowCoreRuntime); 427removedActivityAction.OriginalRemovedActivity.Uninitialize(executionContext.Activity.RootActivity.WorkflowCoreRuntime); 430removedActivityAction.OriginalRemovedActivity.OnActivityExecutionContextUnload(executionContext.Activity.RootActivity.WorkflowCoreRuntime);
System.Workflow.Runtime (1)
DebugEngine\DebugController.cs (1)
926Activity instanceActivity = executionContext.Activity;