Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / TransactionBridge / Microsoft / Transactions / Wsat / Clusters / ClusterRegistryConfigurationProvider.cs / 1 / ClusterRegistryConfigurationProvider.cs
//------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- // Implement the ConfigurationProvider base class for the cluster registry using System; using System.Collections.Generic; using System.Diagnostics; using System.Runtime.InteropServices; using System.Security.AccessControl; using System.Text; using System.ServiceModel.Diagnostics; using Microsoft.Transactions.Bridge; using Microsoft.Transactions.Wsat.Messaging; using Microsoft.Transactions.Wsat.Protocol; using Microsoft.Win32; namespace Microsoft.Transactions.Wsat.Clusters { class ClusterRegistryConfigurationProvider : ConfigurationProvider { SafeHKey hKey; public ClusterRegistryConfigurationProvider(SafeHResource hResource) { this.hKey = SafeNativeMethods.GetClusterResourceKey(hResource, RegistryRights.ReadKey | RegistryRights.EnumerateSubKeys | RegistryRights.QueryValues); if (this.hKey.IsInvalid) { int gle = Marshal.GetLastWin32Error(); this.hKey.SetHandleAsInvalid(); throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new ConfigurationProviderException(SR.GetString(SR.GetClusterResourceKeyFailed, gle))); } if (DebugTrace.Verbose) DebugTrace.Trace(TraceLevel.Verbose, "Opened cluster resource key"); } ClusterRegistryConfigurationProvider(SafeHKey rootKey, string subKey) { // If the rootKey is null or invalid, we just nod and return default values if (rootKey != null && !rootKey.IsInvalid) { int ret = SafeNativeMethods.ClusterRegOpenKey(rootKey, subKey, RegistryRights.ReadKey | RegistryRights.EnumerateSubKeys | RegistryRights.QueryValues, out this.hKey); if (ret != SafeNativeMethods.ERROR_SUCCESS) { Utility.CloseInvalidOutSafeHandle(this.hKey); if (ret != SafeNativeMethods.ERROR_FILE_NOT_FOUND) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new ConfigurationProviderException(SR.GetString(SR.ClusterRegOpenKeyFailed, ret))); } } if (DebugTrace.Verbose) DebugTrace.Trace(TraceLevel.Verbose, "ClusterRegOpenKey for {0} returned {1}", subKey, ret); } } public override void Dispose() { if (this.hKey != null && !this.hKey.IsInvalid) this.hKey.Dispose(); } byte[] QueryValue(string value, RegistryValueKind valueType) { if (this.hKey == null || this.hKey.IsInvalid) return null; RegistryValueKind type; uint cb = 0; int ret = SafeNativeMethods.ClusterRegQueryValue(this.hKey, value, out type, null, ref cb); if (ret == SafeNativeMethods.ERROR_SUCCESS || ret == SafeNativeMethods.ERROR_MORE_DATA) { if (valueType != type) return null; byte[] buffer = new byte[cb]; ret = SafeNativeMethods.ClusterRegQueryValue(this.hKey, value, out type, buffer, ref cb); if (ret == SafeNativeMethods.ERROR_SUCCESS) { if (valueType != type) return null; return buffer; } } if (DebugTrace.Verbose) DebugTrace.Trace(TraceLevel.Verbose, "ClusterRegQueryValue for {0} returned {1}", value, ret); if (ret == SafeNativeMethods.ERROR_FILE_NOT_FOUND) return null; throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new ConfigurationProviderException(SR.GetString(SR.ClusterRegQueryValueFailed, ret))); } public override int ReadInteger(string value, int defaultValue) { byte[] buffer = QueryValue(value, RegistryValueKind.DWord); if (buffer == null) return defaultValue; return (int)BitConverter.ToUInt32(buffer, 0); } public override string ReadString(string value, string defaultValue) { byte[] buffer = QueryValue(value, RegistryValueKind.String); if (buffer == null) return defaultValue; try { return Encoding.Unicode.GetString(buffer, 0, buffer.Length - 2); } catch (ArgumentException e) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new ConfigurationProviderException(SR.GetString(SR.ClusterRegQueryValueInvalidResults, value), e)); } } public override string[] ReadMultiString(string value, string[] defaultValue) { byte[] buffer = QueryValue(value, RegistryValueKind.MultiString); if (buffer == null) return defaultValue; Listlist = new List (5); string item; int index = 0; while ((item = GetStringFromMultiSz(value, buffer, ref index)) != null) { list.Add(item); } return list.ToArray(); } public override ConfigurationProvider OpenKey(string key) { return new ClusterRegistryConfigurationProvider(this.hKey, key); } string GetStringFromMultiSz(string value, byte[] buffer, ref int index) { // E.g. abc\0def\0\0 // This loop terminates when it finds a null terminating character // The index will be left pointing at the first null terminator it finds int start = index; for (; index < buffer.Length - 1 && BitConverter.ToChar(buffer, index) != 0; index += 2) ; // If we found no valid characters, we're done if (start == index) return null; // Skip past the null terminator at which we stopped index += 2; // Convert the characters we found to a string try { return Encoding.Unicode.GetString(buffer, start, index - start - 2); } catch (ArgumentException e) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError( new ConfigurationProviderException(SR.GetString(SR.ClusterRegQueryValueInvalidResults, value), e)); } } } } // 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
- TraceSection.cs
- OleDbDataAdapter.cs
- InvalidEnumArgumentException.cs
- XmlStreamedByteStreamReader.cs
- ScriptHandlerFactory.cs
- Rfc4050KeyFormatter.cs
- PseudoWebRequest.cs
- DataGridTable.cs
- Rect3D.cs
- XPathNodeList.cs
- ListViewItem.cs
- ControlsConfig.cs
- ModifierKeysConverter.cs
- SoapAttributeOverrides.cs
- Highlights.cs
- NegotiateStream.cs
- DetailsViewAutoFormat.cs
- DropDownButton.cs
- Rijndael.cs
- RootNamespaceAttribute.cs
- TypeInfo.cs
- ToolStripItemClickedEventArgs.cs
- SqlDeflator.cs
- DataTrigger.cs
- InputBuffer.cs
- SessionStateModule.cs
- DbDataReader.cs
- LinqExpressionNormalizer.cs
- TextStore.cs
- RegistryKey.cs
- SafeNativeMethodsOther.cs
- InteropBitmapSource.cs
- ControlPropertyNameConverter.cs
- MethodAccessException.cs
- EndpointDiscoveryBehavior.cs
- IndexerNameAttribute.cs
- WebServiceParameterData.cs
- DataObjectSettingDataEventArgs.cs
- TextStore.cs
- DatasetMethodGenerator.cs
- NativeMethods.cs
- DataGridViewDataConnection.cs
- MultipartIdentifier.cs
- FlowchartDesigner.Helpers.cs
- ReservationNotFoundException.cs
- DataKeyArray.cs
- IntegerCollectionEditor.cs
- ICollection.cs
- XmlUtilWriter.cs
- ItemCollection.cs
- TrailingSpaceComparer.cs
- HostingEnvironment.cs
- XmlResolver.cs
- MethodExpr.cs
- HwndSourceKeyboardInputSite.cs
- QuaternionAnimation.cs
- ProgressBarAutomationPeer.cs
- ObjectStateEntryOriginalDbUpdatableDataRecord.cs
- Hex.cs
- IntSecurity.cs
- HtmlInputFile.cs
- GridSplitter.cs
- DataTable.cs
- CheckBoxAutomationPeer.cs
- DataObjectCopyingEventArgs.cs
- DynamicDataResources.Designer.cs
- DecimalAnimationUsingKeyFrames.cs
- _TimerThread.cs
- SuppressMergeCheckAttribute.cs
- PageSettings.cs
- KerberosSecurityTokenProvider.cs
- CodeTypeMemberCollection.cs
- RoleBoolean.cs
- TrustLevelCollection.cs
- FrameworkRichTextComposition.cs
- TypeDescriptionProviderAttribute.cs
- KnownTypesProvider.cs
- CodeMemberField.cs
- BoundColumn.cs
- ProfileSettings.cs
- BinarySecretSecurityToken.cs
- ChannelCacheSettings.cs
- LinqDataSource.cs
- WebPartCloseVerb.cs
- CroppedBitmap.cs
- SerializationException.cs
- GregorianCalendarHelper.cs
- ContextMenuService.cs
- TextRunCacheImp.cs
- InfoCardAsymmetricCrypto.cs
- IdentityNotMappedException.cs
- WmlCalendarAdapter.cs
- InfoCardCryptoHelper.cs
- IsolatedStorageFilePermission.cs
- SystemIcmpV4Statistics.cs
- ConfigPathUtility.cs
- FontStretches.cs
- ListView.cs
- LiteralControl.cs
- DbException.cs