Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Diagnostics / ServiceModelPerformanceCounters.cs / 1 / ServiceModelPerformanceCounters.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Diagnostics { using System; using System.ServiceModel; using System.ServiceModel.Dispatcher; using System.ServiceModel.Description; using System.Collections; using System.Collections.Generic; using System.Collections.ObjectModel; using System.Collections.Specialized; using System.Diagnostics; using System.Globalization; using System.Runtime.Remoting.Messaging; using System.ServiceModel.Channels; using System.ServiceModel.Configuration; using System.ServiceModel.Diagnostics; using System.Text; using System.Xml; internal class ServiceModelPerformanceCounters { DictionaryoperationPerfCounters; SortedList actionToOperation; EndpointPerformanceCounters endpointPerfCounters; ServicePerformanceCounters servicePerfCounters; DefaultPerformanceCounters defaultPerfCounters; bool initialized; string perfCounterId; internal ServiceModelPerformanceCounters( ServiceHostBase serviceHost, ContractDescription contractDescription, EndpointDispatcher endpointDispatcher) { this.perfCounterId = endpointDispatcher.PerfCounterId; if (PerformanceCounters.Scope == PerformanceCounterScope.All) { this.operationPerfCounters = new Dictionary (contractDescription.Operations.Count); this.actionToOperation = new SortedList (contractDescription.Operations.Count); foreach (OperationDescription opDescription in contractDescription.Operations) { DiagnosticUtility.DebugAssert(null != opDescription.Messages, "OperationDescription.Messages should not be null"); DiagnosticUtility.DebugAssert(opDescription.Messages.Count > 0, "OperationDescription.Messages should not be empty"); DiagnosticUtility.DebugAssert(null != opDescription.Messages[0], "OperationDescription.Messages[0] should not be null"); if (null != opDescription.Messages[0].Action && !this.actionToOperation.Keys.Contains(opDescription.Messages[0].Action)) { this.actionToOperation.Add(opDescription.Messages[0].Action, opDescription.Name); } OperationPerformanceCounters c; if (!this.operationPerfCounters.TryGetValue(opDescription.Name, out c)) { OperationPerformanceCounters counters = new OperationPerformanceCounters(serviceHost.Description.Name, contractDescription.Name, opDescription.Name, endpointDispatcher.PerfCounterBaseId); if (counters.Initialized) { this.operationPerfCounters.Add(opDescription.Name, counters); } else { // cleanup the others and return. this.ReleasePerformanceCounters(); this.initialized = false; return; } } } // add endpoint scoped perf counters EndpointPerformanceCounters endpointCounters = new EndpointPerformanceCounters(serviceHost.Description.Name, contractDescription.Name, endpointDispatcher.PerfCounterBaseId); if (endpointCounters.Initialized) { this.endpointPerfCounters = endpointCounters; } } if (PerformanceCounters.PerformanceCountersEnabled) { this.servicePerfCounters = serviceHost.Counters; } if (PerformanceCounters.MinimalPerformanceCountersEnabled) { this.defaultPerfCounters = serviceHost.DefaultCounters; } this.initialized = true; } internal OperationPerformanceCounters GetOperationPerformanceCountersFromMessage(Message message) { DiagnosticUtility.DebugAssert(null != message, "message must not be null"); DiagnosticUtility.DebugAssert(null != message.Headers, "message headers must not be null"); DiagnosticUtility.DebugAssert(null != message.Headers.Action, "action must not be null"); string operation; if (this.actionToOperation.TryGetValue(message.Headers.Action, out operation)) { return this.GetOperationPerformanceCounters(operation); } else { return null; } } internal OperationPerformanceCounters GetOperationPerformanceCounters(string operation) { DiagnosticUtility.DebugAssert(PerformanceCounters.Scope == PerformanceCounterScope.All, "Only call GetOparationPerformanceCounters when performance counter scope is All"); OperationPerformanceCounters counters; Dictionary opPerfCounters = this.operationPerfCounters; if (opPerfCounters != null && opPerfCounters.TryGetValue(operation, out counters)) { return counters; } return null; } internal bool Initialized { get { return this.initialized; } } internal EndpointPerformanceCounters EndpointPerformanceCounters { get { return this.endpointPerfCounters; } } internal ServicePerformanceCounters ServicePerformanceCounters { get { return this.servicePerfCounters; } } internal DefaultPerformanceCounters DefaultPerformanceCounters { get { return this.defaultPerfCounters; } } internal string PerfCounterId { get { return this.perfCounterId; } } internal void ReleasePerformanceCounters() { if (PerformanceCounters.Scope == PerformanceCounterScope.All) { if (this.operationPerfCounters != null) { try { IDictionaryEnumerator e = this.operationPerfCounters.GetEnumerator(); while (e.MoveNext()) { OperationPerformanceCounters op = (OperationPerformanceCounters)e.Value; op.ReleasePerformanceCounters(); } } #pragma warning suppress 56500 // covered by FxCOP catch (Exception e) { if (ExceptionUtility.IsFatal(e)) throw; if (DiagnosticUtility.ShouldTraceError) TraceUtility.TraceEvent(TraceEventType.Error, TraceCode.PerformanceCountersFailedOnRelease, null, e); } this.operationPerfCounters.Clear(); this.operationPerfCounters = null; } if (this.endpointPerfCounters != null) { this.endpointPerfCounters.ReleasePerformanceCounters(); this.endpointPerfCounters = null; } } // ServicePerformanceCounters will be released by ServiceHost this.servicePerfCounters = null; this.defaultPerfCounters = null; } } internal class ServiceModelPerformanceCountersEntry { ServicePerformanceCounters servicePerformanceCounters; DefaultPerformanceCounters defaultPerformanceCounters; List performanceCounters; public ServiceModelPerformanceCountersEntry(ServicePerformanceCounters serviceCounters) { this.servicePerformanceCounters = serviceCounters; this.performanceCounters = new List (); } public ServiceModelPerformanceCountersEntry(DefaultPerformanceCounters defaultServiceCounters) { this.defaultPerformanceCounters = defaultServiceCounters; this.performanceCounters = new List (); } public void Add(ServiceModelPerformanceCounters counters) { this.performanceCounters.Add(counters); } public void Remove(string id) { for (int i = 0; i < this.performanceCounters.Count; ++i) { if (this.performanceCounters[i].PerfCounterId.Equals(id)) { this.performanceCounters.RemoveAt(i); break; } } } public void Clear() { this.performanceCounters.Clear(); } public ServicePerformanceCounters ServicePerformanceCounters { get { return this.servicePerformanceCounters; } set { this.servicePerformanceCounters = value; } } public DefaultPerformanceCounters DefaultPerformanceCounters { get { return this.defaultPerformanceCounters; } set { this.defaultPerformanceCounters = value; } } public List CounterList { get { return this.performanceCounters; } } } } // 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
- XmlNode.cs
- HeaderCollection.cs
- XmlWellformedWriterHelpers.cs
- SamlAuthorizationDecisionStatement.cs
- SelectingProviderEventArgs.cs
- PropVariant.cs
- LocalizationComments.cs
- ExceptionUtil.cs
- Column.cs
- BindingGroup.cs
- PipelineModuleStepContainer.cs
- DispatcherHooks.cs
- FormsAuthenticationConfiguration.cs
- TypeToken.cs
- TemplateParser.cs
- SafeProcessHandle.cs
- MessageOperationFormatter.cs
- TreeNodeStyle.cs
- ObjectIDGenerator.cs
- CmsInterop.cs
- SharedConnectionInfo.cs
- BinaryMethodMessage.cs
- TableDetailsCollection.cs
- UrlAuthFailedErrorFormatter.cs
- LateBoundBitmapDecoder.cs
- LayoutEngine.cs
- unsafenativemethodsother.cs
- HotSpotCollection.cs
- ClosableStream.cs
- XmlSchemaComplexContentRestriction.cs
- ListChangedEventArgs.cs
- StatusInfoItem.cs
- ParameterCollection.cs
- GridViewSelectEventArgs.cs
- SharedStream.cs
- FileChangesMonitor.cs
- AsmxEndpointPickerExtension.cs
- Privilege.cs
- WebPartDescription.cs
- XomlCompiler.cs
- CalendarDayButton.cs
- FileDataSourceCache.cs
- SuppressIldasmAttribute.cs
- PackWebRequest.cs
- BindingSource.cs
- cookie.cs
- AspCompat.cs
- GenerateTemporaryTargetAssembly.cs
- QilVisitor.cs
- Repeater.cs
- NetNamedPipeBindingElement.cs
- RuntimeIdentifierPropertyAttribute.cs
- RegexStringValidatorAttribute.cs
- XPathDescendantIterator.cs
- FileUtil.cs
- WorkflowDataContext.cs
- OuterGlowBitmapEffect.cs
- ConvertersCollection.cs
- DependencyObjectPropertyDescriptor.cs
- TextDecorationCollection.cs
- AstTree.cs
- InternalsVisibleToAttribute.cs
- ExpressionBindingCollection.cs
- XmlSchemaSet.cs
- PackageDigitalSignatureManager.cs
- ExceptionValidationRule.cs
- DataServiceRequest.cs
- DataFieldConverter.cs
- TileModeValidation.cs
- SchemaComplexType.cs
- UiaCoreProviderApi.cs
- PropertyGridView.cs
- WebPartConnectionsConfigureVerb.cs
- PackagePart.cs
- AllowedAudienceUriElementCollection.cs
- CodeCommentStatement.cs
- TemplateControlParser.cs
- AssemblyCollection.cs
- CompoundFileStreamReference.cs
- CodeDelegateCreateExpression.cs
- XmlParserContext.cs
- UnsafeNativeMethods.cs
- ReadOnlyTernaryTree.cs
- TableCell.cs
- SqlDataAdapter.cs
- TableAdapterManagerGenerator.cs
- ConfigurationManagerHelper.cs
- IdnMapping.cs
- EntityCollectionChangedParams.cs
- GlyphingCache.cs
- SchemaAttDef.cs
- HtmlElementErrorEventArgs.cs
- ViewKeyConstraint.cs
- HttpAsyncResult.cs
- HybridDictionary.cs
- UncommonField.cs
- ScriptRef.cs
- PassportAuthentication.cs
- EdgeProfileValidation.cs
- OleServicesContext.cs