Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / WF / RunTime / WorkflowInstance.cs / 1305376 / WorkflowInstance.cs
// ****************************************************************************
// Copyright (C) Microsoft Corporation. All rights reserved.
//
using System;
using System.IO;
using System.Threading;
using System.Diagnostics;
using System.Globalization;
using System.Collections;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Workflow.Runtime;
using System.Workflow.ComponentModel;
using System.Workflow.Runtime.Hosting;
namespace System.Workflow.Runtime
{
///
/// Schedule Instance handed over to the client
///
public sealed class WorkflowInstance
{
private WorkflowRuntime _runtime;
private Guid _instanceId;
private WorkflowExecutor _deadWorkflow;
internal WorkflowInstance(Guid instanceId, WorkflowRuntime workflowRuntime)
{
if (instanceId == Guid.Empty)
throw new ArgumentException(String.Format(CultureInfo.CurrentCulture, ExecutionStringManager.CantBeEmptyGuid, "instanceId"));
if (workflowRuntime == null)
throw new ArgumentNullException("workflowRuntime");
this._instanceId = instanceId;
this._runtime = workflowRuntime;
}
public Guid InstanceId
{
get
{
return _instanceId;
}
}
public WorkflowRuntime WorkflowRuntime
{
get
{
return _runtime;
}
}
internal WorkflowExecutor DeadWorkflow
{
set
{
Debug.Assert(value.WorkflowStatus == WorkflowStatus.Completed || value.WorkflowStatus == WorkflowStatus.Terminated,
"Dead workflow is not dead.");
_deadWorkflow = value;
}
}
public ReadOnlyCollection GetWorkflowQueueData()
{
if (_deadWorkflow != null)
return _deadWorkflow.GetWorkflowQueueInfos();
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
return executor.GetWorkflowQueueInfos();
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
public DateTime GetWorkflowNextTimerExpiration()
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
return executor.GetWorkflowNextTimerExpiration();
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
public Activity GetWorkflowDefinition()
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
// Make sure to get the clone here since the
// definition is mutable and shared across all
// instances.
return executor.GetWorkflowDefinitionClone("");
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
public void Load()
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
this._runtime.Load(this);
}
}
public bool TryUnload()
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
WorkflowExecutor executor = _runtime.Load(this);
using (executor.ExecutorLock.Enter())
{
if (executor.IsInstanceValid)
{
try
{
return executor.TryUnload();
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
return false;
}
}
public void Suspend(string error)
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
if (executor.WorkflowStatus == WorkflowStatus.Created)
throw new InvalidOperationException(ExecutionStringManager.CannotSuspendBeforeStart);
try
{
executor.Suspend(error);
return;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
catch (ExecutorLocksHeldException e)
{
try
{
e.Handle.WaitOne();
}
catch (ObjectDisposedException)
{
// If an ObjectDisposedException is thrown because
// the WaitHandle has already closed, nothing to worry
// about. Move on.
}
}
}
}
}
}
public void Unload()
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
if (_runtime == null || _runtime.GetService() == null)
throw new InvalidOperationException(String.Format(CultureInfo.CurrentCulture, ExecutionStringManager.MissingPersistenceService, this.InstanceId));
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
executor.Unload();
return;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
catch (ExecutorLocksHeldException e)
{
try
{
e.Handle.WaitOne(/* maybe should have a timeout here?*/);
}
catch (ObjectDisposedException)
{
// If an ObjectDisposedException is thrown because
// the WaitHandle has already closed, nothing to worry
// about. Move on.
}
}
}
}
}
}
public void Resume()
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
executor.Resume();
break;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
}
internal void ProcessTimers(object ignored)
{
ProcessTimers();
}
internal void ProcessTimers()
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = null;
try
{
executor = _runtime.Load(this);
}
catch (InvalidOperationException)
{
break;
}
if (executor != null && executor.IsInstanceValid)
{
try
{
executor.DeliverTimerSubscriptions();
break;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
}
public void Terminate(string error)
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
executor.Terminate(error);
break;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
}
public void Abort()
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
if (executor.WorkflowStatus == WorkflowStatus.Created)
throw new InvalidOperationException(ExecutionStringManager.CannotAbortBeforeStart);
try
{
executor.Abort();
break;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
}
public void ReloadTrackingProfiles()
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
_runtime.TrackingListenerFactory.ReloadProfiles(executor);
break;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
}
public void ApplyWorkflowChanges(WorkflowChanges workflowChanges)
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
executor.ApplyWorkflowChanges(workflowChanges);
break;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
}
public void EnqueueItem(IComparable queueName, Object item, IPendingWork pendingWork, Object workItem)
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
try
{
executor.EnqueueItem(queueName, item, pendingWork, workItem);
break;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
public void EnqueueItemOnIdle(IComparable queueName, Object item, IPendingWork pendingWork, Object workItem)
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
executor.EnqueueItemOnIdle(queueName, item, pendingWork, workItem);
break;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
}
internal WorkflowExecutor GetWorkflowResourceUNSAFE()
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
return executor;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
public override bool Equals(Object obj)
{
WorkflowInstance instance = obj as WorkflowInstance;
if (instance == null)
return false;
return this._instanceId == instance._instanceId;
}
public override int GetHashCode()
{
return this._instanceId.GetHashCode();
}
public void Start()
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
executor.Start();
break;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
}
}
}
// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
// Copyright (c) Microsoft Corporation. All rights reserved.
// ****************************************************************************
// Copyright (C) Microsoft Corporation. All rights reserved.
//
using System;
using System.IO;
using System.Threading;
using System.Diagnostics;
using System.Globalization;
using System.Collections;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Workflow.Runtime;
using System.Workflow.ComponentModel;
using System.Workflow.Runtime.Hosting;
namespace System.Workflow.Runtime
{
///
/// Schedule Instance handed over to the client
///
public sealed class WorkflowInstance
{
private WorkflowRuntime _runtime;
private Guid _instanceId;
private WorkflowExecutor _deadWorkflow;
internal WorkflowInstance(Guid instanceId, WorkflowRuntime workflowRuntime)
{
if (instanceId == Guid.Empty)
throw new ArgumentException(String.Format(CultureInfo.CurrentCulture, ExecutionStringManager.CantBeEmptyGuid, "instanceId"));
if (workflowRuntime == null)
throw new ArgumentNullException("workflowRuntime");
this._instanceId = instanceId;
this._runtime = workflowRuntime;
}
public Guid InstanceId
{
get
{
return _instanceId;
}
}
public WorkflowRuntime WorkflowRuntime
{
get
{
return _runtime;
}
}
internal WorkflowExecutor DeadWorkflow
{
set
{
Debug.Assert(value.WorkflowStatus == WorkflowStatus.Completed || value.WorkflowStatus == WorkflowStatus.Terminated,
"Dead workflow is not dead.");
_deadWorkflow = value;
}
}
public ReadOnlyCollection GetWorkflowQueueData()
{
if (_deadWorkflow != null)
return _deadWorkflow.GetWorkflowQueueInfos();
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
return executor.GetWorkflowQueueInfos();
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
public DateTime GetWorkflowNextTimerExpiration()
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
return executor.GetWorkflowNextTimerExpiration();
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
public Activity GetWorkflowDefinition()
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
// Make sure to get the clone here since the
// definition is mutable and shared across all
// instances.
return executor.GetWorkflowDefinitionClone("");
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
public void Load()
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
this._runtime.Load(this);
}
}
public bool TryUnload()
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
WorkflowExecutor executor = _runtime.Load(this);
using (executor.ExecutorLock.Enter())
{
if (executor.IsInstanceValid)
{
try
{
return executor.TryUnload();
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
return false;
}
}
public void Suspend(string error)
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
if (executor.WorkflowStatus == WorkflowStatus.Created)
throw new InvalidOperationException(ExecutionStringManager.CannotSuspendBeforeStart);
try
{
executor.Suspend(error);
return;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
catch (ExecutorLocksHeldException e)
{
try
{
e.Handle.WaitOne();
}
catch (ObjectDisposedException)
{
// If an ObjectDisposedException is thrown because
// the WaitHandle has already closed, nothing to worry
// about. Move on.
}
}
}
}
}
}
public void Unload()
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
if (_runtime == null || _runtime.GetService() == null)
throw new InvalidOperationException(String.Format(CultureInfo.CurrentCulture, ExecutionStringManager.MissingPersistenceService, this.InstanceId));
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
executor.Unload();
return;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
catch (ExecutorLocksHeldException e)
{
try
{
e.Handle.WaitOne(/* maybe should have a timeout here?*/);
}
catch (ObjectDisposedException)
{
// If an ObjectDisposedException is thrown because
// the WaitHandle has already closed, nothing to worry
// about. Move on.
}
}
}
}
}
}
public void Resume()
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
executor.Resume();
break;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
}
internal void ProcessTimers(object ignored)
{
ProcessTimers();
}
internal void ProcessTimers()
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = null;
try
{
executor = _runtime.Load(this);
}
catch (InvalidOperationException)
{
break;
}
if (executor != null && executor.IsInstanceValid)
{
try
{
executor.DeliverTimerSubscriptions();
break;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
}
public void Terminate(string error)
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
executor.Terminate(error);
break;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
}
public void Abort()
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
if (executor.WorkflowStatus == WorkflowStatus.Created)
throw new InvalidOperationException(ExecutionStringManager.CannotAbortBeforeStart);
try
{
executor.Abort();
break;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
}
public void ReloadTrackingProfiles()
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
_runtime.TrackingListenerFactory.ReloadProfiles(executor);
break;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
}
public void ApplyWorkflowChanges(WorkflowChanges workflowChanges)
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
executor.ApplyWorkflowChanges(workflowChanges);
break;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
}
public void EnqueueItem(IComparable queueName, Object item, IPendingWork pendingWork, Object workItem)
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
try
{
executor.EnqueueItem(queueName, item, pendingWork, workItem);
break;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
public void EnqueueItemOnIdle(IComparable queueName, Object item, IPendingWork pendingWork, Object workItem)
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
executor.EnqueueItemOnIdle(queueName, item, pendingWork, workItem);
break;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
}
internal WorkflowExecutor GetWorkflowResourceUNSAFE()
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
return executor;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
public override bool Equals(Object obj)
{
WorkflowInstance instance = obj as WorkflowInstance;
if (instance == null)
return false;
return this._instanceId == instance._instanceId;
}
public override int GetHashCode()
{
return this._instanceId.GetHashCode();
}
public void Start()
{
using (new WorkflowTraceTransfer(this.InstanceId))
{
while (true)
{
WorkflowExecutor executor = _runtime.Load(this);
if (executor.IsInstanceValid)
{
try
{
executor.Start();
break;
}
catch (InvalidOperationException)
{
if (executor.IsInstanceValid)
throw;
}
}
}
}
}
}
}
// 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
- ToolStripSystemRenderer.cs
- HMAC.cs
- Control.cs
- BitmapEffectGeneralTransform.cs
- XsdBuildProvider.cs
- Operators.cs
- Int16.cs
- BamlLocalizerErrorNotifyEventArgs.cs
- FileLogRecordHeader.cs
- BinaryExpression.cs
- ZipIOExtraFieldElement.cs
- Currency.cs
- ButtonBase.cs
- CFGGrammar.cs
- AttributeCollection.cs
- EntityDataSourceReferenceGroup.cs
- PermissionAttributes.cs
- MessageSmuggler.cs
- TransactionChannelFactory.cs
- WorkflowEnvironment.cs
- CodeTypeOfExpression.cs
- StylusButton.cs
- JapaneseLunisolarCalendar.cs
- XmlWrappingReader.cs
- XamlPointCollectionSerializer.cs
- ErrorHandler.cs
- SendMailErrorEventArgs.cs
- PropertyDescriptorGridEntry.cs
- TeredoHelper.cs
- HMACSHA384.cs
- SqlDataSourceQueryConverter.cs
- DataGridViewDataErrorEventArgs.cs
- SqlBulkCopyColumnMapping.cs
- MappedMetaModel.cs
- DefinitionBase.cs
- SessionStateContainer.cs
- KerberosTicketHashIdentifierClause.cs
- SspiSecurityTokenParameters.cs
- ResourceAttributes.cs
- propertytag.cs
- HttpsChannelFactory.cs
- VScrollBar.cs
- DataGridViewBand.cs
- ParallelEnumerableWrapper.cs
- InstanceLockQueryResult.cs
- diagnosticsswitches.cs
- DataContractSerializer.cs
- GroupLabel.cs
- TableLayoutSettingsTypeConverter.cs
- OleDbWrapper.cs
- ValueProviderWrapper.cs
- BamlRecordReader.cs
- BadImageFormatException.cs
- MultipartIdentifier.cs
- ZoneLinkButton.cs
- DropShadowEffect.cs
- DataGridToolTip.cs
- GraphicsContainer.cs
- NativeMethods.cs
- SingleAnimationUsingKeyFrames.cs
- DesignerActionHeaderItem.cs
- DateTimeOffset.cs
- IISMapPath.cs
- GeneralTransform.cs
- BitmapEffectDrawingContextState.cs
- Themes.cs
- DataServiceOperationContext.cs
- ConnectionInterfaceCollection.cs
- DbConnectionStringBuilder.cs
- DescendentsWalkerBase.cs
- TopClause.cs
- Section.cs
- ObjectToken.cs
- InsufficientMemoryException.cs
- EncryptedKeyIdentifierClause.cs
- UniqueIdentifierService.cs
- DbParameterHelper.cs
- PropertyTabChangedEvent.cs
- JapaneseLunisolarCalendar.cs
- QueueAccessMode.cs
- ViewEventArgs.cs
- DbConnectionStringCommon.cs
- WpfWebRequestHelper.cs
- DelegatingTypeDescriptionProvider.cs
- Int32EqualityComparer.cs
- BufferModesCollection.cs
- CancelRequestedRecord.cs
- StringUtil.cs
- BindingExpressionBase.cs
- MessageHeader.cs
- SecurityListenerSettingsLifetimeManager.cs
- GregorianCalendar.cs
- TableRow.cs
- ToolboxComponentsCreatedEventArgs.cs
- SafeArrayRankMismatchException.cs
- DataKeyArray.cs
- PersonalizableAttribute.cs
- ResXResourceSet.cs
- DesignBindingPicker.cs
- ManipulationBoundaryFeedbackEventArgs.cs