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
- MatcherBuilder.cs
- CorrelationResolver.cs
- FragmentQuery.cs
- XmlRootAttribute.cs
- AsyncSerializedWorker.cs
- ParserExtension.cs
- PropertyGeneratedEventArgs.cs
- CodeGroup.cs
- SqlTriggerAttribute.cs
- AssemblyBuilderData.cs
- CommandDevice.cs
- _CacheStreams.cs
- ObjectDataSourceView.cs
- ThicknessConverter.cs
- DateTime.cs
- TextViewBase.cs
- TypeExtensionConverter.cs
- WeakReferenceEnumerator.cs
- OptimizedTemplateContentHelper.cs
- ChameleonKey.cs
- DesignColumn.cs
- SafePEFileHandle.cs
- DataGridViewImageCell.cs
- Memoizer.cs
- PageEventArgs.cs
- Geometry3D.cs
- GroupByQueryOperator.cs
- PathNode.cs
- SortedList.cs
- PageParser.cs
- Visual.cs
- ParallelTimeline.cs
- SiteMapDataSource.cs
- PrivilegeNotHeldException.cs
- TemplatePropertyEntry.cs
- SettingsPropertyWrongTypeException.cs
- Figure.cs
- HitTestDrawingContextWalker.cs
- MultiPageTextView.cs
- CommandID.cs
- EventRoute.cs
- SequenceNumber.cs
- ParseNumbers.cs
- HttpRawResponse.cs
- ImpersonateTokenRef.cs
- DispatchRuntime.cs
- HMACSHA384.cs
- AdapterDictionary.cs
- SiteMapPath.cs
- MimeMultiPart.cs
- ProcessModuleCollection.cs
- EditCommandColumn.cs
- Helper.cs
- ProviderCommandInfoUtils.cs
- OleDbWrapper.cs
- MethodBody.cs
- SafeBitVector32.cs
- InnerItemCollectionView.cs
- RectAnimationBase.cs
- Attachment.cs
- WindowsStatic.cs
- StateWorkerRequest.cs
- ApplicationCommands.cs
- EventData.cs
- Identity.cs
- MethodBody.cs
- ProviderCollection.cs
- TrustManager.cs
- SchemaLookupTable.cs
- Int64.cs
- Win32PrintDialog.cs
- TdsEnums.cs
- UnderstoodHeaders.cs
- PassportAuthenticationModule.cs
- PropertyEmitter.cs
- WarningException.cs
- SqlDataSourceCommandEventArgs.cs
- MetaTable.cs
- LongAverageAggregationOperator.cs
- PeerNameRecord.cs
- BuiltInPermissionSets.cs
- ToolStripHighContrastRenderer.cs
- CodeActivityContext.cs
- ISCIIEncoding.cs
- NativeMethods.cs
- WindowsAltTab.cs
- NotificationContext.cs
- CompressionTransform.cs
- DescendantQuery.cs
- MasterPageBuildProvider.cs
- ContractNamespaceAttribute.cs
- LogArchiveSnapshot.cs
- AdornerPresentationContext.cs
- Vector.cs
- NativeMethods.cs
- AllowedAudienceUriElementCollection.cs
- OleServicesContext.cs
- SqlWebEventProvider.cs
- ComponentChangingEvent.cs
- ListViewDataItem.cs