Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Core / System / Diagnostics / PerformanceData / CounterSetInstanceCounterDataSet.cs / 1305376 / CounterSetInstanceCounterDataSet.cs
//------------------------------------------------------------------------------
//
// Copyright (c) Microsoft Corporation. All rights reserved.
//
//-----------------------------------------------------------------------------
namespace System.Diagnostics.PerformanceData {
using System;
using System.Threading;
using System.Runtime.InteropServices;
using System.ComponentModel;
using System.Collections.Generic;
using System.Diagnostics;
using System.Diagnostics.CodeAnalysis;
using Microsoft.Win32;
///
/// CounterData class is used to store actual raw counter data. It is the value element within
/// CounterSetInstanceCounterDataSet, which is part of CounterSetInstance.
///
[System.Security.Permissions.HostProtection(MayLeakOnAbort = true)]
public sealed class CounterData {
unsafe private Int64 * m_offset;
///
/// CounterData constructor
///
/// counterId would come from CounterSet::AddCounter() parameter
/// The memory location to store raw counter data
//
//
[System.Security.SecurityCritical]
unsafe internal CounterData(Int64 * pCounterData) {
m_offset = pCounterData;
* m_offset = 0;
}
///
/// Value property it used to query/update actual raw counter data.
///
public Int64 Value {
//
//
[System.Security.SecurityCritical]
get {
unsafe {
return Interlocked.Read(ref (* m_offset));
}
}
//
//
[System.Security.SecurityCritical]
set {
unsafe {
Interlocked.Exchange(ref (* m_offset), value);
}
}
}
[System.Security.SecurityCritical]
public void Increment() {
unsafe {
Interlocked.Increment (ref (*m_offset));
}
}
[System.Security.SecurityCritical]
public void Decrement() {
unsafe {
Interlocked.Decrement (ref (*m_offset));
}
}
[System.Security.SecurityCritical]
public void IncrementBy(Int64 value) {
unsafe {
Interlocked.Add (ref (*m_offset), value);
}
}
///
/// RawValue property it used to query/update actual raw counter data.
/// This property is not thread-safe and should only be used
/// for performance-critical single-threaded access.
///
public Int64 RawValue {
//
//
[System.Security.SecurityCritical]
get {
unsafe {
return (* m_offset);
}
}
//
//
[System.Security.SecurityCritical]
set {
unsafe {
* m_offset = value;
}
}
}
}
///
/// CounterSetInstanceCounterDataSet is part of CounterSetInstance class, and is used to store raw counter data
/// for all counters added in CounterSet.
///
[System.Security.Permissions.HostProtection(MayLeakOnAbort = true)]
public sealed class CounterSetInstanceCounterDataSet : IDisposable {
internal CounterSetInstance m_instance;
private Dictionary m_counters;
private Int32 m_disposed;
unsafe internal byte * m_dataBlock;
//
//
[System.Security.SecurityCritical]
[SuppressMessage("Microsoft.Usage", "CA2208:InstantiateArgumentExceptionsCorrectly")]
internal CounterSetInstanceCounterDataSet(CounterSetInstance thisInst) {
m_instance = thisInst;
m_counters = new Dictionary();
unsafe {
if (m_instance.m_counterSet.m_provider == null) {
throw new ArgumentException(SR.GetString(SR.Perflib_Argument_ProviderNotFound, m_instance.m_counterSet.m_providerGuid), "ProviderGuid");
}
if (m_instance.m_counterSet.m_provider.m_hProvider.IsInvalid) {
throw new InvalidOperationException(SR.GetString(SR.Perflib_InvalidOperation_NoActiveProvider, m_instance.m_counterSet.m_providerGuid));
}
m_dataBlock = (byte *) Marshal.AllocHGlobal(m_instance.m_counterSet.m_idToCounter.Count * sizeof(Int64));
if (m_dataBlock == null) {
throw new InsufficientMemoryException(SR.GetString(SR.Perflib_InsufficientMemory_InstanceCounterBlock, m_instance.m_counterSet.m_counterSet, m_instance.m_instName));
}
Int32 CounterOffset = 0;
foreach (KeyValuePair CounterDef in m_instance.m_counterSet.m_idToCounter) {
CounterData thisCounterData = new CounterData((Int64 *) (m_dataBlock + CounterOffset * sizeof(Int64)));
m_counters.Add(CounterDef.Key, thisCounterData);
// ArgumentNullException - CounterName is NULL
// ArgumentException - CounterName already exists.
uint Status = UnsafeNativeMethods.PerfSetCounterRefValue(
m_instance.m_counterSet.m_provider.m_hProvider,
m_instance.m_nativeInst,
(uint) CounterDef.Key,
(void *) (m_dataBlock + CounterOffset * sizeof(Int64)));
if (Status != (uint) UnsafeNativeMethods.ERROR_SUCCESS) {
Dispose(true);
// ERROR_INVALID_PARAMETER or ERROR_NOT_FOUND
switch (Status) {
case (uint) UnsafeNativeMethods.ERROR_NOT_FOUND:
throw new InvalidOperationException(SR.GetString(SR.Perflib_InvalidOperation_CounterRefValue, m_instance.m_counterSet.m_counterSet, CounterDef.Key, m_instance.m_instName));
default:
throw new Win32Exception((int) Status);
}
}
CounterOffset ++;
}
}
}
//
//
[System.Security.SecurityCritical]
public void Dispose() {
Dispose(true);
GC.SuppressFinalize(this);
}
//
//
[System.Security.SecurityCritical]
~CounterSetInstanceCounterDataSet() {
Dispose(false);
}
//
//
[System.Security.SecurityCritical]
private void Dispose(bool disposing) {
if (Interlocked.Exchange(ref m_disposed, 1) == 0) {
unsafe {
if (m_dataBlock != null) {
// Need to free allocated heap memory that is used to store all raw counter data.
Marshal.FreeHGlobal((System.IntPtr)m_dataBlock);
m_dataBlock = null;
}
}
}
}
///
/// CounterId indexer to access specific CounterData object.
///
/// CounterId that matches one CounterSet::AddCounter()call
/// CounterData object with matched counterId
public CounterData this[Int32 counterId] {
get {
if (m_disposed != 0) {
return null;
}
try {
return m_counters[counterId];
}
catch (KeyNotFoundException) {
return null;
}
catch {
throw;
}
}
}
///
/// CounterName indexer to access specific CounterData object.
///
/// CounterName that matches one CounterSet::AddCounter() call
/// CounterData object with matched counterName
[SuppressMessage("Microsoft.Usage", "CA2208:InstantiateArgumentExceptionsCorrectly")]
public CounterData this[String counterName] {
get {
if (counterName == null) {
throw new ArgumentNullException("CounterName");
}
if (counterName.Length == 0) {
throw new ArgumentNullException("CounterName");
}
if (m_disposed != 0) {
return null;
}
try {
Int32 CounterId = m_instance.m_counterSet.m_stringToId[counterName];
try {
return m_counters[CounterId];
}
catch (KeyNotFoundException) {
return null;
}
catch {
throw;
}
}
catch (KeyNotFoundException) {
return null;
}
catch {
throw;
}
}
}
}
}
// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
//------------------------------------------------------------------------------
//
// Copyright (c) Microsoft Corporation. All rights reserved.
//
//-----------------------------------------------------------------------------
namespace System.Diagnostics.PerformanceData {
using System;
using System.Threading;
using System.Runtime.InteropServices;
using System.ComponentModel;
using System.Collections.Generic;
using System.Diagnostics;
using System.Diagnostics.CodeAnalysis;
using Microsoft.Win32;
///
/// CounterData class is used to store actual raw counter data. It is the value element within
/// CounterSetInstanceCounterDataSet, which is part of CounterSetInstance.
///
[System.Security.Permissions.HostProtection(MayLeakOnAbort = true)]
public sealed class CounterData {
unsafe private Int64 * m_offset;
///
/// CounterData constructor
///
/// counterId would come from CounterSet::AddCounter() parameter
/// The memory location to store raw counter data
//
//
[System.Security.SecurityCritical]
unsafe internal CounterData(Int64 * pCounterData) {
m_offset = pCounterData;
* m_offset = 0;
}
///
/// Value property it used to query/update actual raw counter data.
///
public Int64 Value {
//
//
[System.Security.SecurityCritical]
get {
unsafe {
return Interlocked.Read(ref (* m_offset));
}
}
//
//
[System.Security.SecurityCritical]
set {
unsafe {
Interlocked.Exchange(ref (* m_offset), value);
}
}
}
[System.Security.SecurityCritical]
public void Increment() {
unsafe {
Interlocked.Increment (ref (*m_offset));
}
}
[System.Security.SecurityCritical]
public void Decrement() {
unsafe {
Interlocked.Decrement (ref (*m_offset));
}
}
[System.Security.SecurityCritical]
public void IncrementBy(Int64 value) {
unsafe {
Interlocked.Add (ref (*m_offset), value);
}
}
///
/// RawValue property it used to query/update actual raw counter data.
/// This property is not thread-safe and should only be used
/// for performance-critical single-threaded access.
///
public Int64 RawValue {
//
//
[System.Security.SecurityCritical]
get {
unsafe {
return (* m_offset);
}
}
//
//
[System.Security.SecurityCritical]
set {
unsafe {
* m_offset = value;
}
}
}
}
///
/// CounterSetInstanceCounterDataSet is part of CounterSetInstance class, and is used to store raw counter data
/// for all counters added in CounterSet.
///
[System.Security.Permissions.HostProtection(MayLeakOnAbort = true)]
public sealed class CounterSetInstanceCounterDataSet : IDisposable {
internal CounterSetInstance m_instance;
private Dictionary m_counters;
private Int32 m_disposed;
unsafe internal byte * m_dataBlock;
//
//
[System.Security.SecurityCritical]
[SuppressMessage("Microsoft.Usage", "CA2208:InstantiateArgumentExceptionsCorrectly")]
internal CounterSetInstanceCounterDataSet(CounterSetInstance thisInst) {
m_instance = thisInst;
m_counters = new Dictionary();
unsafe {
if (m_instance.m_counterSet.m_provider == null) {
throw new ArgumentException(SR.GetString(SR.Perflib_Argument_ProviderNotFound, m_instance.m_counterSet.m_providerGuid), "ProviderGuid");
}
if (m_instance.m_counterSet.m_provider.m_hProvider.IsInvalid) {
throw new InvalidOperationException(SR.GetString(SR.Perflib_InvalidOperation_NoActiveProvider, m_instance.m_counterSet.m_providerGuid));
}
m_dataBlock = (byte *) Marshal.AllocHGlobal(m_instance.m_counterSet.m_idToCounter.Count * sizeof(Int64));
if (m_dataBlock == null) {
throw new InsufficientMemoryException(SR.GetString(SR.Perflib_InsufficientMemory_InstanceCounterBlock, m_instance.m_counterSet.m_counterSet, m_instance.m_instName));
}
Int32 CounterOffset = 0;
foreach (KeyValuePair CounterDef in m_instance.m_counterSet.m_idToCounter) {
CounterData thisCounterData = new CounterData((Int64 *) (m_dataBlock + CounterOffset * sizeof(Int64)));
m_counters.Add(CounterDef.Key, thisCounterData);
// ArgumentNullException - CounterName is NULL
// ArgumentException - CounterName already exists.
uint Status = UnsafeNativeMethods.PerfSetCounterRefValue(
m_instance.m_counterSet.m_provider.m_hProvider,
m_instance.m_nativeInst,
(uint) CounterDef.Key,
(void *) (m_dataBlock + CounterOffset * sizeof(Int64)));
if (Status != (uint) UnsafeNativeMethods.ERROR_SUCCESS) {
Dispose(true);
// ERROR_INVALID_PARAMETER or ERROR_NOT_FOUND
switch (Status) {
case (uint) UnsafeNativeMethods.ERROR_NOT_FOUND:
throw new InvalidOperationException(SR.GetString(SR.Perflib_InvalidOperation_CounterRefValue, m_instance.m_counterSet.m_counterSet, CounterDef.Key, m_instance.m_instName));
default:
throw new Win32Exception((int) Status);
}
}
CounterOffset ++;
}
}
}
//
//
[System.Security.SecurityCritical]
public void Dispose() {
Dispose(true);
GC.SuppressFinalize(this);
}
//
//
[System.Security.SecurityCritical]
~CounterSetInstanceCounterDataSet() {
Dispose(false);
}
//
//
[System.Security.SecurityCritical]
private void Dispose(bool disposing) {
if (Interlocked.Exchange(ref m_disposed, 1) == 0) {
unsafe {
if (m_dataBlock != null) {
// Need to free allocated heap memory that is used to store all raw counter data.
Marshal.FreeHGlobal((System.IntPtr)m_dataBlock);
m_dataBlock = null;
}
}
}
}
///
/// CounterId indexer to access specific CounterData object.
///
/// CounterId that matches one CounterSet::AddCounter()call
/// CounterData object with matched counterId
public CounterData this[Int32 counterId] {
get {
if (m_disposed != 0) {
return null;
}
try {
return m_counters[counterId];
}
catch (KeyNotFoundException) {
return null;
}
catch {
throw;
}
}
}
///
/// CounterName indexer to access specific CounterData object.
///
/// CounterName that matches one CounterSet::AddCounter() call
/// CounterData object with matched counterName
[SuppressMessage("Microsoft.Usage", "CA2208:InstantiateArgumentExceptionsCorrectly")]
public CounterData this[String counterName] {
get {
if (counterName == null) {
throw new ArgumentNullException("CounterName");
}
if (counterName.Length == 0) {
throw new ArgumentNullException("CounterName");
}
if (m_disposed != 0) {
return null;
}
try {
Int32 CounterId = m_instance.m_counterSet.m_stringToId[counterName];
try {
return m_counters[CounterId];
}
catch (KeyNotFoundException) {
return null;
}
catch {
throw;
}
}
catch (KeyNotFoundException) {
return null;
}
catch {
throw;
}
}
}
}
}
// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- DescendentsWalker.cs
- cookiecollection.cs
- RegexCompilationInfo.cs
- DesignerEditorPartChrome.cs
- TemplateKeyConverter.cs
- Trace.cs
- FunctionQuery.cs
- Compiler.cs
- UserPreferenceChangingEventArgs.cs
- JpegBitmapEncoder.cs
- WindowsClaimSet.cs
- JobStaple.cs
- Help.cs
- DetailsViewInsertEventArgs.cs
- documentation.cs
- SQLInt32.cs
- Control.cs
- ListSortDescription.cs
- ProcessModule.cs
- TreeNodeStyleCollection.cs
- PtsHelper.cs
- SqlUDTStorage.cs
- SkinBuilder.cs
- DefaultEventAttribute.cs
- TypeNameConverter.cs
- formatter.cs
- ExpressionConverter.cs
- DiscoveryExceptionDictionary.cs
- ReturnType.cs
- InternalBufferOverflowException.cs
- WeakReference.cs
- SAPICategories.cs
- CompilerWrapper.cs
- SemaphoreFullException.cs
- HtmlWindowCollection.cs
- WorkItem.cs
- Invariant.cs
- PasswordBoxAutomationPeer.cs
- PreProcessInputEventArgs.cs
- AnimationClock.cs
- LocationFactory.cs
- CodeIdentifier.cs
- SourceElementsCollection.cs
- ProfileInfo.cs
- CachingHintValidation.cs
- StylusPoint.cs
- DataSvcMapFileSerializer.cs
- InputLanguageSource.cs
- SetStoryboardSpeedRatio.cs
- SortQuery.cs
- DefaultTextStore.cs
- ToolStripDropDownButton.cs
- SaveFileDialog.cs
- SystemIcons.cs
- PathData.cs
- RbTree.cs
- OdbcException.cs
- DataGridColumnCollection.cs
- EventListener.cs
- XmlDataProvider.cs
- TextChange.cs
- DataSourceHelper.cs
- DrawingContextDrawingContextWalker.cs
- RowUpdatedEventArgs.cs
- _IPv4Address.cs
- HierarchicalDataTemplate.cs
- BoundPropertyEntry.cs
- RemotingConfiguration.cs
- VisualTreeUtils.cs
- TextOptionsInternal.cs
- SqlDataAdapter.cs
- TextServicesDisplayAttribute.cs
- MessageDecoder.cs
- FamilyCollection.cs
- EmissiveMaterial.cs
- TextEditorThreadLocalStore.cs
- SiteMap.cs
- MsmqIntegrationElement.cs
- CodeMemberProperty.cs
- XmlSchemaProviderAttribute.cs
- SplitterDesigner.cs
- StartUpEventArgs.cs
- XmlWhitespace.cs
- DeferredSelectedIndexReference.cs
- ToolboxBitmapAttribute.cs
- Pipe.cs
- CatalogPartCollection.cs
- VirtualizedContainerService.cs
- DesignerProperties.cs
- TransformValueSerializer.cs
- DeploymentSectionCache.cs
- DataReaderContainer.cs
- TemplatingOptionsDialog.cs
- InputReport.cs
- SoapIncludeAttribute.cs
- TypeGeneratedEventArgs.cs
- TemplateInstanceAttribute.cs
- FastEncoderWindow.cs
- AllMembershipCondition.cs
- COM2DataTypeToManagedDataTypeConverter.cs