Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / WF / RunTime / WorkflowStateRollbackService.cs / 1305376 / WorkflowStateRollbackService.cs
using System; using System.Collections.Generic; using System.Collections; using System.Diagnostics; using System.Reflection; using System.Text; using System.IO; using System.IO.Compression; using System.Transactions; using System.Workflow.ComponentModel; namespace System.Workflow.Runtime { internal sealed class WorkflowStateRollbackService { WorkflowExecutor workflowExecutor; // cache the revert back data MemoryStream clonedInstanceStateStream; Activity workflowDefinition = null; bool isInstanceStateRevertRequested = false; // revert back notification info string activityQualifiedName; int activityContextId; EventArgs callbackData; EventHandlercallbackHandler; bool suspendOnRevert; string suspendOnRevertInfo; Hashtable completedContextActivities = new Hashtable(); public WorkflowStateRollbackService(WorkflowExecutor workflowExecutor) { this.workflowExecutor = workflowExecutor; } internal bool IsInstanceStateRevertRequested { get { return this.isInstanceStateRevertRequested; } } internal void CheckpointInstanceState() { Debug.Assert(this.workflowExecutor.InstanceId != null, "instance id null at checkpoint time"); // serialize the instance state this.clonedInstanceStateStream = new MemoryStream(10240); this.workflowExecutor.RootActivity.Save(this.clonedInstanceStateStream); this.workflowDefinition = this.workflowExecutor.WorkflowDefinition; this.completedContextActivities = (Hashtable)this.workflowExecutor.CompletedContextActivities.Clone(); this.clonedInstanceStateStream.Position = 0; } internal void RequestRevertToCheckpointState(Activity currentActivity, EventHandler callbackHandler, EventArgs callbackData, bool suspendOnRevert, string suspendInfo) { if (this.clonedInstanceStateStream == null) throw new InvalidOperationException(ExecutionStringManager.InvalidRevertRequest); // cache the after revert information this.activityContextId = ContextActivityUtils.ContextId(ContextActivityUtils.ContextActivity(currentActivity)); this.activityQualifiedName = currentActivity.QualifiedName; this.callbackData = callbackData; this.callbackHandler = callbackHandler; this.suspendOnRevert = suspendOnRevert; this.suspendOnRevertInfo = suspendInfo; // ask scheduler to stop this.isInstanceStateRevertRequested = true; this.workflowExecutor.Scheduler.CanRun = false; } internal void DisposeCheckpointState() { this.clonedInstanceStateStream = null; } internal void RevertToCheckpointState() { Debug.Assert(this.clonedInstanceStateStream != null, "cloned instance-state stream null at restore time"); // deserialize only on first access Activity clonedRootActivity = null; this.clonedInstanceStateStream.Position = 0; using (RuntimeEnvironment runtimeEnv = new RuntimeEnvironment(this.workflowExecutor.WorkflowRuntime)) { clonedRootActivity = Activity.Load(this.clonedInstanceStateStream, (Activity)this.workflowDefinition); } Debug.Assert(clonedRootActivity != null); // // Set the trackingListenerBroker before initializing the executor so the tracking // runtime gets a reference to the correct object clonedRootActivity.SetValue(WorkflowExecutor.TrackingListenerBrokerProperty, workflowExecutor.RootActivity.GetValue(WorkflowExecutor.TrackingListenerBrokerProperty)); // create the new workflowExecutor WorkflowExecutor newWorkflowExecutor = new WorkflowExecutor(Guid.Empty); // use a dummy guid while swapping executors newWorkflowExecutor.Initialize(clonedRootActivity, this.workflowExecutor.WorkflowRuntime, this.workflowExecutor); // enqueue the activity notifier Activity activityContext = newWorkflowExecutor.GetContextActivityForId(this.activityContextId); Activity activity = activityContext.GetActivityByName(this.activityQualifiedName); using (new ServiceEnvironment(activity)) { using (newWorkflowExecutor.SetCurrentActivity(activity)) { using (ActivityExecutionContext executionContext = new ActivityExecutionContext(activity)) executionContext.Invoke (this.callbackHandler, this.callbackData); } } // // Push the batch item ordering id to the new instance newWorkflowExecutor.BatchCollection.WorkItemOrderId = this.workflowExecutor.BatchCollection.WorkItemOrderId; // replace pending batch items foreach (KeyValuePair
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- CacheOutputQuery.cs
- CodeObject.cs
- DbConvert.cs
- DeploymentExceptionMapper.cs
- Int64Storage.cs
- LayoutDump.cs
- CodeTypeParameterCollection.cs
- EntityClientCacheKey.cs
- streamingZipPartStream.cs
- DbConnectionPoolGroup.cs
- QueuedDeliveryRequirementsMode.cs
- InternalConfigEventArgs.cs
- CodePropertyReferenceExpression.cs
- TableLayoutColumnStyleCollection.cs
- DigestTraceRecordHelper.cs
- GenerateScriptTypeAttribute.cs
- AsymmetricKeyExchangeDeformatter.cs
- formatter.cs
- IndicShape.cs
- RelationshipDetailsCollection.cs
- JsonReader.cs
- BoundColumn.cs
- ContentPropertyAttribute.cs
- MatchingStyle.cs
- DbConnectionPool.cs
- PageParser.cs
- ClonableStack.cs
- PriorityBinding.cs
- SystemKeyConverter.cs
- GridViewPageEventArgs.cs
- DateTimeFormatInfoScanner.cs
- EastAsianLunisolarCalendar.cs
- DBAsyncResult.cs
- TogglePatternIdentifiers.cs
- _NetRes.cs
- SoapTypeAttribute.cs
- WorkflowViewElement.cs
- IUnknownConstantAttribute.cs
- ResourceDefaultValueAttribute.cs
- MemberRelationshipService.cs
- XmlSchemaSimpleType.cs
- LinqExpressionNormalizer.cs
- SerialStream.cs
- BindingMemberInfo.cs
- EpmContentSerializerBase.cs
- Border.cs
- InputProcessorProfiles.cs
- EndpointDispatcher.cs
- DateTimeConverter.cs
- HealthMonitoringSectionHelper.cs
- Win32PrintDialog.cs
- NamespaceList.cs
- ReferencedAssembly.cs
- ComPlusAuthorization.cs
- oledbmetadatacollectionnames.cs
- AssemblyFilter.cs
- HttpWebRequestElement.cs
- ChannelSinkStacks.cs
- CallbackValidatorAttribute.cs
- XmlSerializationReader.cs
- MethodBody.cs
- FunctionParameter.cs
- MarshalByValueComponent.cs
- DesignerAutoFormatStyle.cs
- UdpUtility.cs
- InkCanvasFeedbackAdorner.cs
- WebPartConnectionsCancelEventArgs.cs
- ExpressionParser.cs
- SqlBooleanMismatchVisitor.cs
- BitmapEffectDrawing.cs
- ToolTipAutomationPeer.cs
- HyperLink.cs
- UIElement.cs
- WaitHandle.cs
- FlowPosition.cs
- WindowsFormsDesignerOptionService.cs
- AsyncPostBackTrigger.cs
- IDictionary.cs
- XMLUtil.cs
- DeviceSpecificChoice.cs
- AvtEvent.cs
- AccessDataSourceView.cs
- StatusBarDesigner.cs
- TransactionWaitAsyncResult.cs
- TryExpression.cs
- WindowVisualStateTracker.cs
- ReflectTypeDescriptionProvider.cs
- MarshalDirectiveException.cs
- InputLangChangeEvent.cs
- TypeUsage.cs
- SqlErrorCollection.cs
- EnglishPluralizationService.cs
- BmpBitmapEncoder.cs
- ExternalDataExchangeClient.cs
- XamlStyleSerializer.cs
- LinkArea.cs
- AndMessageFilter.cs
- ChangeTracker.cs
- ClientSettings.cs
- ItemContainerGenerator.cs