Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Dispatcher / SyncMethodInvoker.cs / 1 / SyncMethodInvoker.cs
//------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- namespace System.ServiceModel.Dispatcher { using System; using System.Reflection; using System.ServiceModel.Diagnostics; using System.Globalization; using System.Threading; using System.Collections; using System.Diagnostics; using System.Security; class SyncMethodInvoker : IOperationInvoker { Type type; string methodName; MethodInfo method; InvokeDelegate invokeDelegate; int inputParameterCount; int outputParameterCount; public SyncMethodInvoker(MethodInfo method) { if (method == null) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentNullException("method")); this.method = method; } public SyncMethodInvoker(Type type, string methodName) { if (type == null) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentNullException("type")); if (methodName == null) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentNullException("methodName")); this.type = type; this.methodName = methodName; } public bool IsSynchronous { get { return true; } } public MethodInfo Method { get { if (method == null) method = type.GetMethod(methodName); return method; } } public string MethodName { get { if (methodName == null) methodName = method.Name; return methodName; } } public object[] AllocateInputs() { EnsureIsInitialized(); return EmptyArray.Allocate(this.inputParameterCount); } public object Invoke(object instance, object[] inputs, out object[] outputs) { EnsureIsInitialized(); if (instance == null) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.SFxNoServiceObject))); if (inputs == null) { if (this.inputParameterCount > 0) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.SFxInputParametersToServiceNull, this.inputParameterCount))); } else if (inputs.Length != this.inputParameterCount) throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.SFxInputParametersToServiceInvalid, this.inputParameterCount, inputs.Length))); outputs = EmptyArray.Allocate(this.outputParameterCount); long startCounter = 0; long stopCounter = 0; bool callFailed = true; bool callFaulted = false; if (PerformanceCounters.PerformanceCountersEnabled) { PerformanceCounters.MethodCalled(this.MethodName); try { if (System.ServiceModel.Channels.UnsafeNativeMethods.QueryPerformanceCounter(out startCounter) == 0) { startCounter = -1; } } catch (SecurityException securityException) { if (DiagnosticUtility.ShouldTraceWarning) { DiagnosticUtility.ExceptionUtility.TraceHandledException(securityException, TraceEventType.Warning); } throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new SecurityException(SR.GetString( SR.PartialTrustPerformanceCountersNotEnabled), securityException)); } } object returnValue; try { ServiceModelActivity activity = null; IDisposable boundActivity = null; if (DiagnosticUtility.ShouldUseActivity) { activity = ServiceModelActivity.CreateBoundedActivity(true); boundActivity = activity; } else if (TraceUtility.ShouldPropagateActivity) { Guid activityId = ActivityIdHeader.ExtractActivityId(OperationContext.Current.IncomingMessage); if (activityId != Guid.Empty) { boundActivity = Activity.CreateActivity(activityId); } } using (boundActivity) { if (DiagnosticUtility.ShouldUseActivity) { ServiceModelActivity.Start(activity, SR.GetString(SR.ActivityExecuteMethod, this.method.DeclaringType.FullName, this.method.Name), ActivityType.ExecuteUserCode); } returnValue = this.invokeDelegate(instance, inputs, outputs); callFailed = false; } } catch (System.ServiceModel.FaultException) { callFaulted = true; callFailed = false; throw; } catch (System.Security.SecurityException e) { DiagnosticUtility.ExceptionUtility.TraceHandledException(e, TraceEventType.Warning); throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(AuthorizationBehavior.CreateAccessDeniedFaultException()); } finally { if (PerformanceCounters.PerformanceCountersEnabled) { if (callFailed) // call succeeded { PerformanceCounters.MethodReturnedError(this.MethodName); } else if (callFaulted) // call faulted { PerformanceCounters.MethodReturnedFault(this.MethodName); } else // call errored { long elapsedTime; if (startCounter >= 0 && System.ServiceModel.Channels.UnsafeNativeMethods.QueryPerformanceCounter(out stopCounter) != 0) { elapsedTime = stopCounter - startCounter; } else { elapsedTime = 0; } PerformanceCounters.MethodReturnedSuccess(this.MethodName, elapsedTime); } } } return returnValue; } public IAsyncResult InvokeBegin(object instance, object[] inputs, AsyncCallback callback, object state) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException()); } public object InvokeEnd(object instance, out object[] outputs, IAsyncResult result) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException()); } void EnsureIsInitialized() { if (this.invokeDelegate == null) { EnsureIsInitializedCore(); } } void EnsureIsInitializedCore() { // Only pass locals byref because InvokerUtil may store temporary results in the byref. // If two threads both reference this.count, temporary results may interact. int inputParameterCount; int outputParameterCount; InvokeDelegate invokeDelegate = new InvokerUtil().GenerateInvokeDelegate(this.Method, out inputParameterCount, out outputParameterCount); this.outputParameterCount = outputParameterCount; this.inputParameterCount = inputParameterCount; this.invokeDelegate = invokeDelegate; // must set this last due to race } } } // 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
- GenericTypeParameterBuilder.cs
- TraceUtils.cs
- cryptoapiTransform.cs
- Int16.cs
- WriteTimeStream.cs
- BindingWorker.cs
- SQLBinaryStorage.cs
- RequestCachePolicyConverter.cs
- Debugger.cs
- XmlSchemaAnnotation.cs
- TimeStampChecker.cs
- LoaderAllocator.cs
- SwitchDesigner.xaml.cs
- EdmComplexPropertyAttribute.cs
- AspNetSynchronizationContext.cs
- TiffBitmapDecoder.cs
- BaseAddressElementCollection.cs
- ThemeDirectoryCompiler.cs
- WmlObjectListAdapter.cs
- SqlDataSource.cs
- PenContexts.cs
- GifBitmapDecoder.cs
- XmlEncApr2001.cs
- ConfigurationStrings.cs
- SetIndexBinder.cs
- BooleanSwitch.cs
- StateRuntime.cs
- XmlSchemaAnnotation.cs
- Base64WriteStateInfo.cs
- RouteParameter.cs
- StyleSheetComponentEditor.cs
- ToolStripItemImageRenderEventArgs.cs
- OracleDataAdapter.cs
- HtmlLabelAdapter.cs
- XmlProcessingInstruction.cs
- safemediahandle.cs
- RenderTargetBitmap.cs
- HwndProxyElementProvider.cs
- SerializerWriterEventHandlers.cs
- RandomDelaySendsAsyncResult.cs
- DoubleStorage.cs
- RIPEMD160.cs
- ColumnHeaderConverter.cs
- Terminate.cs
- SoundPlayer.cs
- NonParentingControl.cs
- DbConnectionPoolIdentity.cs
- WindowCollection.cs
- CollectionDataContractAttribute.cs
- SecurityTokenException.cs
- WindowsRebar.cs
- ContainerSelectorBehavior.cs
- SupportingTokenSecurityTokenResolver.cs
- FormsAuthentication.cs
- StyleHelper.cs
- BreakRecordTable.cs
- QfeChecker.cs
- CaseExpr.cs
- XmlSchemaGroupRef.cs
- ImageFormatConverter.cs
- HostProtectionPermission.cs
- TextEditorThreadLocalStore.cs
- DataProtection.cs
- _AutoWebProxyScriptWrapper.cs
- TemplatedMailWebEventProvider.cs
- TrustExchangeException.cs
- ClockController.cs
- PenLineCapValidation.cs
- LinearQuaternionKeyFrame.cs
- AsyncStreamReader.cs
- DataTemplateKey.cs
- NativeMethods.cs
- MetadataArtifactLoaderCompositeResource.cs
- SettingsBindableAttribute.cs
- DirtyTextRange.cs
- ImageDesigner.cs
- InternalCompensate.cs
- ResXResourceSet.cs
- InProcStateClientManager.cs
- ObjectResult.cs
- KeyPressEvent.cs
- DataGridTextBoxColumn.cs
- MachineKeySection.cs
- CodeDirectionExpression.cs
- AliasedSlot.cs
- ExpressionList.cs
- CancelEventArgs.cs
- ParenthesizePropertyNameAttribute.cs
- NavigationExpr.cs
- DropDownButton.cs
- XmlSchema.cs
- PointCollection.cs
- Geometry3D.cs
- ValidationRuleCollection.cs
- PartialCachingAttribute.cs
- SByteConverter.cs
- UrlMappingsSection.cs
- SafeFileMappingHandle.cs
- DbConnectionOptions.cs
- SystemIPAddressInformation.cs