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
- XPathAxisIterator.cs
- SqlConnectionStringBuilder.cs
- CngKey.cs
- HiddenFieldDesigner.cs
- ConstraintStruct.cs
- InternalPermissions.cs
- NameTable.cs
- SendActivityEventArgs.cs
- OlePropertyStructs.cs
- CompilerState.cs
- LazyLoadBehavior.cs
- XPathDocumentIterator.cs
- MailDefinition.cs
- InvalidContentTypeException.cs
- UriParserTemplates.cs
- AttributeCollection.cs
- RadioButton.cs
- MultilineStringEditor.cs
- DesignerActionMethodItem.cs
- DetailsViewRowCollection.cs
- StrokeNodeEnumerator.cs
- CodeIndexerExpression.cs
- ColumnMap.cs
- MimeWriter.cs
- LoginName.cs
- CreateParams.cs
- DbConnectionStringBuilder.cs
- FileDialogCustomPlacesCollection.cs
- XPathMultyIterator.cs
- AstNode.cs
- RijndaelManaged.cs
- EntityDataSourceWrapperCollection.cs
- ConnectionsZone.cs
- NameValuePermission.cs
- TemplateControlBuildProvider.cs
- CmsInterop.cs
- ObjectDataSourceDisposingEventArgs.cs
- PreviewControlDesigner.cs
- CodeAttributeArgumentCollection.cs
- XmlSchemaSimpleType.cs
- DataGridClipboardCellContent.cs
- CompModSwitches.cs
- BounceEase.cs
- SQLDateTimeStorage.cs
- WindowsListView.cs
- PrimaryKeyTypeConverter.cs
- ServerIdentity.cs
- BevelBitmapEffect.cs
- UnmanagedMarshal.cs
- RuntimeArgumentHandle.cs
- ToolStripDropDownMenu.cs
- HybridObjectCache.cs
- EdmItemCollection.cs
- TransformationRules.cs
- ProgressBarHighlightConverter.cs
- DateTimeOffset.cs
- DragEventArgs.cs
- ControlTemplate.cs
- SelectedPathEditor.cs
- ObjectToIdCache.cs
- MaskInputRejectedEventArgs.cs
- Decimal.cs
- TripleDES.cs
- ReadOnlyObservableCollection.cs
- DesignerLoader.cs
- SQLInt16Storage.cs
- SQLBytes.cs
- SQLMembershipProvider.cs
- PointAnimationClockResource.cs
- ScrollableControl.cs
- FormViewUpdateEventArgs.cs
- DefinitionUpdate.cs
- GenerateTemporaryTargetAssembly.cs
- Brush.cs
- BoundField.cs
- CLSCompliantAttribute.cs
- SecurityKeyIdentifier.cs
- CalendarDesigner.cs
- SqlDataSource.cs
- OracleConnectionString.cs
- MatrixTransform3D.cs
- Cursor.cs
- ServicePointManagerElement.cs
- WebControl.cs
- MouseGestureConverter.cs
- Tracking.cs
- UnmanagedMemoryStream.cs
- safex509handles.cs
- DataSourceSelectArguments.cs
- _LoggingObject.cs
- SoapFormatExtensions.cs
- ClassicBorderDecorator.cs
- RecognitionResult.cs
- FixedBufferAttribute.cs
- AssociationSetEnd.cs
- Models.cs
- PackUriHelper.cs
- TypeReference.cs
- TextBox.cs
- XmlTextReaderImpl.cs