Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / WF / Activities / Executors / WorkflowWebService.cs / 1305376 / WorkflowWebService.cs
/********************************************************************************
// Copyright (C) 2000-2006 Microsoft Corporation. All rights reserved.
* ****************************************************************************/
#region Using directives
using System;
using System.Collections;
using System.Collections.Generic;
using System.Text;
using System.Diagnostics;
using System.Web;
using System.Collections.Specialized;
using System.Threading;
using System.Web.Services;
using System.Workflow.Runtime;
using System.Workflow.Runtime.Hosting;
using System.Security.Permissions;
using System.Security.Principal;
using System.Reflection;
#endregion
namespace System.Workflow.Activities
{
///
/// Abstract WorkflowWebService Base class for all the Workflow's Web Service.
///
public abstract class WorkflowWebService : WebService
{
Type workflowType;
///
/// Protected Constructor for the Workflow Web Service.
///
///
protected WorkflowWebService(Type workflowType)
{
this.workflowType = workflowType;
}
protected Object[] Invoke(Type interfaceType, String methodName, bool isActivation, Object[] parameters)
{
Guid workflowInstanceId = GetWorkflowInstanceId(ref isActivation);
WorkflowInstance wfInstance;
EventQueueName key = new EventQueueName(interfaceType, methodName);
MethodInfo mInfo = interfaceType.GetMethod(methodName);
bool responseRequired = (mInfo.ReturnType != typeof(void));
if(!responseRequired)
{
foreach (ParameterInfo parameter in mInfo.GetParameters())
{
if (parameter.ParameterType.IsByRef || parameter.IsOut)
{
responseRequired = true;
break;
}
}
}
MethodMessage methodMessage = PrepareMessage(interfaceType, methodName, parameters, responseRequired);
EventHandler workflowTerminationHandler = null;
EventHandler workflowCompletedHandler = null;
try
{
if (isActivation)
{
wfInstance = WorkflowRuntime.CreateWorkflow(this.workflowType, null, workflowInstanceId);
SafeEnqueueItem(wfInstance, key, methodMessage);
wfInstance.Start();
}
else
{
wfInstance = WorkflowRuntime.GetWorkflow(workflowInstanceId);
SafeEnqueueItem(wfInstance, key, methodMessage);
}
bool workflowTerminated = false;
//Handler for workflow termination in b/w outstanding req-response.
workflowTerminationHandler = delegate(Object sender, WorkflowTerminatedEventArgs e)
{
if (e.WorkflowInstance.InstanceId.Equals(workflowInstanceId))
{
methodMessage.SendException(e.Exception);
workflowTerminated = true;
}
};
workflowCompletedHandler = delegate(Object sender, WorkflowCompletedEventArgs e)
{
if (e.WorkflowInstance.InstanceId.Equals(workflowInstanceId))
{
methodMessage.SendException(new ApplicationException(SR.GetString(System.Globalization.CultureInfo.CurrentCulture, SR.Error_WorkflowCompleted)));
}
};
WorkflowRuntime.WorkflowTerminated += workflowTerminationHandler;
WorkflowRuntime.WorkflowCompleted += workflowCompletedHandler;
ManualWorkflowSchedulerService scheduler = WorkflowRuntime.GetService();
if (scheduler != null)
{
scheduler.RunWorkflow(wfInstance.InstanceId);
}
if (!responseRequired)
{
// no ret, out or ref
return new Object[] { };
}
IMethodResponseMessage response = methodMessage.WaitForResponseMessage();
if (response.Exception != null)
{
if(!workflowTerminated)
throw response.Exception;
else
throw new ApplicationException(SR.GetString(System.Globalization.CultureInfo.CurrentCulture, SR.Error_WorkflowTerminated), response.Exception);
}
if (response.OutArgs != null)
return ((ArrayList)response.OutArgs).ToArray();
else
return new Object[] { };
}
finally
{
if(workflowTerminationHandler != null)
WorkflowRuntime.WorkflowTerminated -= workflowTerminationHandler;
if (workflowCompletedHandler != null)
WorkflowRuntime.WorkflowCompleted -= workflowCompletedHandler;
}
}
protected WorkflowRuntime WorkflowRuntime
{
get
{
if(HttpContext.Current != null)
return WorkflowWebService.CurrentWorkflowRuntime;
return null;
}
}
#region Static Helpers
private static Guid GetWorkflowInstanceId(ref bool isActivation)
{
Guid workflowInstanceId = Guid.Empty;
Object instanceId = HttpContext.Current.Items["__WorkflowInstanceId__"];
if (instanceId == null && !isActivation)
throw new InvalidOperationException(SR.GetString(SR.Error_NoInstanceInSession));
if (instanceId != null)
{
workflowInstanceId = (Guid)instanceId;
Object isActivationContext = HttpContext.Current.Items["__IsActivationContext__"];
if (isActivationContext != null)
isActivation = (bool)isActivationContext;
else
isActivation = false;
}
else if (isActivation)
{
workflowInstanceId = Guid.NewGuid();
HttpContext.Current.Items["__WorkflowInstanceId__"] = workflowInstanceId;
}
return workflowInstanceId;
}
private static MethodMessage PrepareMessage(Type interfaceType, String operation, object[] parameters, bool responseRequired)
{
// construct IMethodMessage object
String securityIdentifier = null;
IIdentity identity = System.Threading.Thread.CurrentPrincipal.Identity;
WindowsIdentity windowsIdentity = identity as WindowsIdentity;
if (windowsIdentity != null && windowsIdentity.User != null)
securityIdentifier = windowsIdentity.User.Translate(typeof(NTAccount)).ToString();
else if (identity != null)
securityIdentifier = identity.Name;
MethodMessage msg = new MethodMessage(interfaceType, operation, parameters, securityIdentifier, responseRequired);
return msg;
}
//Back - off logic for conflicting workflow load across workflow runtime boundaries.
static void SafeEnqueueItem(WorkflowInstance instance, EventQueueName key, MethodMessage message)
{
while (true) //When Execution times out ASP.NET going to forcefully plung this request.
{
try
{
instance.EnqueueItem(key, message, null, null);
return;
}
catch (WorkflowOwnershipException)
{
WorkflowActivityTrace.Activity.TraceEvent(TraceEventType.Warning, 0, String.Format(System.Globalization.CultureInfo.InvariantCulture, "Workflow Web Host Encountered Workflow Instance Ownership conflict for instanceid {0}.", instance.InstanceId));
//Back-off for 1/2 sec. Should we make this configurable?
System.Threading.Thread.Sleep(500);
continue;
}
}
}
#endregion
#region Singleton WorkflowRuntime Accessor
internal const string ConfigSectionName = "WorkflowRuntime";
static WorkflowRuntime wRuntime;
static Object wRuntimeSync = new Object();
internal static WorkflowRuntime CurrentWorkflowRuntime
{
get
{
if (wRuntime == null)
{
lock (wRuntimeSync)
{
if (wRuntime == null)
{
WorkflowRuntime workflowRuntimeTemp = new WorkflowRuntime(ConfigSectionName);
try
{
workflowRuntimeTemp.StartRuntime();
}
catch
{
workflowRuntimeTemp.Dispose();
throw;
}
System.Threading.Thread.MemoryBarrier();
wRuntime = workflowRuntimeTemp;
}
}
}
return wRuntime;
}
}
#endregion
}
}
// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
// Copyright (c) Microsoft Corporation. All rights reserved.
/********************************************************************************
// Copyright (C) 2000-2006 Microsoft Corporation. All rights reserved.
* ****************************************************************************/
#region Using directives
using System;
using System.Collections;
using System.Collections.Generic;
using System.Text;
using System.Diagnostics;
using System.Web;
using System.Collections.Specialized;
using System.Threading;
using System.Web.Services;
using System.Workflow.Runtime;
using System.Workflow.Runtime.Hosting;
using System.Security.Permissions;
using System.Security.Principal;
using System.Reflection;
#endregion
namespace System.Workflow.Activities
{
///
/// Abstract WorkflowWebService Base class for all the Workflow's Web Service.
///
public abstract class WorkflowWebService : WebService
{
Type workflowType;
///
/// Protected Constructor for the Workflow Web Service.
///
///
protected WorkflowWebService(Type workflowType)
{
this.workflowType = workflowType;
}
protected Object[] Invoke(Type interfaceType, String methodName, bool isActivation, Object[] parameters)
{
Guid workflowInstanceId = GetWorkflowInstanceId(ref isActivation);
WorkflowInstance wfInstance;
EventQueueName key = new EventQueueName(interfaceType, methodName);
MethodInfo mInfo = interfaceType.GetMethod(methodName);
bool responseRequired = (mInfo.ReturnType != typeof(void));
if(!responseRequired)
{
foreach (ParameterInfo parameter in mInfo.GetParameters())
{
if (parameter.ParameterType.IsByRef || parameter.IsOut)
{
responseRequired = true;
break;
}
}
}
MethodMessage methodMessage = PrepareMessage(interfaceType, methodName, parameters, responseRequired);
EventHandler workflowTerminationHandler = null;
EventHandler workflowCompletedHandler = null;
try
{
if (isActivation)
{
wfInstance = WorkflowRuntime.CreateWorkflow(this.workflowType, null, workflowInstanceId);
SafeEnqueueItem(wfInstance, key, methodMessage);
wfInstance.Start();
}
else
{
wfInstance = WorkflowRuntime.GetWorkflow(workflowInstanceId);
SafeEnqueueItem(wfInstance, key, methodMessage);
}
bool workflowTerminated = false;
//Handler for workflow termination in b/w outstanding req-response.
workflowTerminationHandler = delegate(Object sender, WorkflowTerminatedEventArgs e)
{
if (e.WorkflowInstance.InstanceId.Equals(workflowInstanceId))
{
methodMessage.SendException(e.Exception);
workflowTerminated = true;
}
};
workflowCompletedHandler = delegate(Object sender, WorkflowCompletedEventArgs e)
{
if (e.WorkflowInstance.InstanceId.Equals(workflowInstanceId))
{
methodMessage.SendException(new ApplicationException(SR.GetString(System.Globalization.CultureInfo.CurrentCulture, SR.Error_WorkflowCompleted)));
}
};
WorkflowRuntime.WorkflowTerminated += workflowTerminationHandler;
WorkflowRuntime.WorkflowCompleted += workflowCompletedHandler;
ManualWorkflowSchedulerService scheduler = WorkflowRuntime.GetService();
if (scheduler != null)
{
scheduler.RunWorkflow(wfInstance.InstanceId);
}
if (!responseRequired)
{
// no ret, out or ref
return new Object[] { };
}
IMethodResponseMessage response = methodMessage.WaitForResponseMessage();
if (response.Exception != null)
{
if(!workflowTerminated)
throw response.Exception;
else
throw new ApplicationException(SR.GetString(System.Globalization.CultureInfo.CurrentCulture, SR.Error_WorkflowTerminated), response.Exception);
}
if (response.OutArgs != null)
return ((ArrayList)response.OutArgs).ToArray();
else
return new Object[] { };
}
finally
{
if(workflowTerminationHandler != null)
WorkflowRuntime.WorkflowTerminated -= workflowTerminationHandler;
if (workflowCompletedHandler != null)
WorkflowRuntime.WorkflowCompleted -= workflowCompletedHandler;
}
}
protected WorkflowRuntime WorkflowRuntime
{
get
{
if(HttpContext.Current != null)
return WorkflowWebService.CurrentWorkflowRuntime;
return null;
}
}
#region Static Helpers
private static Guid GetWorkflowInstanceId(ref bool isActivation)
{
Guid workflowInstanceId = Guid.Empty;
Object instanceId = HttpContext.Current.Items["__WorkflowInstanceId__"];
if (instanceId == null && !isActivation)
throw new InvalidOperationException(SR.GetString(SR.Error_NoInstanceInSession));
if (instanceId != null)
{
workflowInstanceId = (Guid)instanceId;
Object isActivationContext = HttpContext.Current.Items["__IsActivationContext__"];
if (isActivationContext != null)
isActivation = (bool)isActivationContext;
else
isActivation = false;
}
else if (isActivation)
{
workflowInstanceId = Guid.NewGuid();
HttpContext.Current.Items["__WorkflowInstanceId__"] = workflowInstanceId;
}
return workflowInstanceId;
}
private static MethodMessage PrepareMessage(Type interfaceType, String operation, object[] parameters, bool responseRequired)
{
// construct IMethodMessage object
String securityIdentifier = null;
IIdentity identity = System.Threading.Thread.CurrentPrincipal.Identity;
WindowsIdentity windowsIdentity = identity as WindowsIdentity;
if (windowsIdentity != null && windowsIdentity.User != null)
securityIdentifier = windowsIdentity.User.Translate(typeof(NTAccount)).ToString();
else if (identity != null)
securityIdentifier = identity.Name;
MethodMessage msg = new MethodMessage(interfaceType, operation, parameters, securityIdentifier, responseRequired);
return msg;
}
//Back - off logic for conflicting workflow load across workflow runtime boundaries.
static void SafeEnqueueItem(WorkflowInstance instance, EventQueueName key, MethodMessage message)
{
while (true) //When Execution times out ASP.NET going to forcefully plung this request.
{
try
{
instance.EnqueueItem(key, message, null, null);
return;
}
catch (WorkflowOwnershipException)
{
WorkflowActivityTrace.Activity.TraceEvent(TraceEventType.Warning, 0, String.Format(System.Globalization.CultureInfo.InvariantCulture, "Workflow Web Host Encountered Workflow Instance Ownership conflict for instanceid {0}.", instance.InstanceId));
//Back-off for 1/2 sec. Should we make this configurable?
System.Threading.Thread.Sleep(500);
continue;
}
}
}
#endregion
#region Singleton WorkflowRuntime Accessor
internal const string ConfigSectionName = "WorkflowRuntime";
static WorkflowRuntime wRuntime;
static Object wRuntimeSync = new Object();
internal static WorkflowRuntime CurrentWorkflowRuntime
{
get
{
if (wRuntime == null)
{
lock (wRuntimeSync)
{
if (wRuntime == null)
{
WorkflowRuntime workflowRuntimeTemp = new WorkflowRuntime(ConfigSectionName);
try
{
workflowRuntimeTemp.StartRuntime();
}
catch
{
workflowRuntimeTemp.Dispose();
throw;
}
System.Threading.Thread.MemoryBarrier();
wRuntime = workflowRuntimeTemp;
}
}
}
return wRuntime;
}
}
#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
- HtmlButton.cs
- OpacityConverter.cs
- FormDocumentDesigner.cs
- HyperlinkAutomationPeer.cs
- TreeNodeCollectionEditor.cs
- RawStylusInputCustomData.cs
- AppSettingsSection.cs
- DataGridViewTopRowAccessibleObject.cs
- RunWorkerCompletedEventArgs.cs
- XmlSerializerOperationFormatter.cs
- ExpandCollapsePatternIdentifiers.cs
- WindowsStatusBar.cs
- MatrixIndependentAnimationStorage.cs
- ObjectHelper.cs
- NavigationFailedEventArgs.cs
- XamlClipboardData.cs
- ConnectionStringSettingsCollection.cs
- autovalidator.cs
- WebControlParameterProxy.cs
- GraphicsPath.cs
- SignatureGenerator.cs
- ColorConvertedBitmap.cs
- PassportPrincipal.cs
- ping.cs
- DesignerActionListCollection.cs
- typedescriptorpermissionattribute.cs
- NotCondition.cs
- ValueTypeFixupInfo.cs
- StructuredTypeEmitter.cs
- FixedTextContainer.cs
- InputManager.cs
- ButtonPopupAdapter.cs
- ListBoxItemAutomationPeer.cs
- PageFunction.cs
- SerializationObjectManager.cs
- DragCompletedEventArgs.cs
- TypeToken.cs
- EmptyControlCollection.cs
- EventBuilder.cs
- XmlSerializableServices.cs
- HTTPNotFoundHandler.cs
- InvalidFilterCriteriaException.cs
- EnumUnknown.cs
- Cloud.cs
- XmlImplementation.cs
- BCryptHashAlgorithm.cs
- UrlPath.cs
- ServicesExceptionNotHandledEventArgs.cs
- EditBehavior.cs
- SiblingIterators.cs
- SelectedCellsCollection.cs
- XmlNamedNodeMap.cs
- IssuedTokenParametersEndpointAddressElement.cs
- HttpCacheVary.cs
- ErrorFormatterPage.cs
- PixelFormatConverter.cs
- KeyMatchBuilder.cs
- Debug.cs
- XmlCountingReader.cs
- AnnotationStore.cs
- SignatureHelper.cs
- BoundPropertyEntry.cs
- BuildDependencySet.cs
- invalidudtexception.cs
- SchemaSetCompiler.cs
- SchemaImporter.cs
- WebContext.cs
- ToolStripOverflow.cs
- DbConnectionClosed.cs
- Request.cs
- PasswordTextContainer.cs
- DataRow.cs
- ConnectionManagementElement.cs
- StyleSheetComponentEditor.cs
- entityreference_tresulttype.cs
- AttributeCollection.cs
- RemotingSurrogateSelector.cs
- ProjectionAnalyzer.cs
- ProfilePropertySettings.cs
- TrustLevel.cs
- MultiBindingExpression.cs
- HTMLTagNameToTypeMapper.cs
- ObjectView.cs
- ConditionCollection.cs
- ConfigurationSettings.cs
- EditingCommands.cs
- XmlBoundElement.cs
- TraceContextRecord.cs
- LocalsItemDescription.cs
- StringAnimationBase.cs
- OnOperation.cs
- AuthorizationRuleCollection.cs
- XmlSerializerAssemblyAttribute.cs
- WriteTimeStream.cs
- StyleTypedPropertyAttribute.cs
- ConvertEvent.cs
- ProfileProvider.cs
- LongValidator.cs
- BitmapCodecInfo.cs
- CheckBoxPopupAdapter.cs