Code:
/ FX-1434 / FX-1434 / 1.0 / untmp / whidbey / REDBITS / ndp / fx / src / xsp / System / Web / PartitionResolver.cs / 3 / PartitionResolver.cs
//------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- namespace System.Web { using System; using System.Configuration; using System.Collections; using System.Threading; using System.IO; using System.Web; using System.Web.Caching; using System.Web.Util; using System.Data; using System.Data.SqlClient; using System.Text; using System.Security.Principal; using System.Xml; using System.Collections.Specialized; using System.Configuration.Provider; using System.Globalization; using System.Web.Management; using System.Web.Hosting; using System.Web.Configuration; using System.Security.Permissions; [AspNetHostingPermission(SecurityAction.LinkDemand, Level=AspNetHostingPermissionLevel.Minimal)] [AspNetHostingPermission(SecurityAction.InheritanceDemand, Level=AspNetHostingPermissionLevel.Minimal)] public interface IPartitionResolver { void Initialize(); string ResolvePartition(Object key); } internal interface IPartitionInfo { string GetTracingPartitionString(); } internal delegate IPartitionInfo CreatePartitionInfo(string connectionString); class PartitionManager : IDisposable { internal PartitionManager(CreatePartitionInfo createCallback) { _createCallback = createCallback; } HybridDictionary _partitions = new HybridDictionary(); ReaderWriterLock _lock = new ReaderWriterLock(); CreatePartitionInfo _createCallback; internal object GetPartition(IPartitionResolver partitionResolver, string id) { if (EtwTrace.IsTraceEnabled(EtwTraceLevel.Verbose, EtwTraceFlags.Infrastructure)) EtwTrace.Trace(EtwTraceType.ETW_TYPE_SESSIONSTATE_PARTITION_START, HttpContext.Current.WorkerRequest, partitionResolver.GetType().FullName, id); string partitionString = null; string errorMessage = null; IPartitionInfo partitionInfo = null; try { try { partitionString = partitionResolver.ResolvePartition(id); if (partitionString == null) { throw new HttpException( SR.GetString(SR.Bad_partition_resolver_connection_string, partitionResolver.GetType().FullName)); } } catch (Exception e) { errorMessage = e.Message; throw; } try { _lock.AcquireReaderLock(-1); partitionInfo = (IPartitionInfo)_partitions[partitionString]; if (partitionInfo != null) { Debug.Trace("PartitionManager", "id=" + id + "; partitionString=" + partitionString); return partitionInfo; } } finally { if (_lock.IsReaderLockHeld) { _lock.ReleaseReaderLock(); } } // Not found. Has to add it. try { _lock.AcquireWriterLock(-1); // One more time partitionInfo = (IPartitionInfo)_partitions[partitionString]; if (partitionInfo == null) { partitionInfo = _createCallback(partitionString); Debug.Trace("PartitionManager", "Add a new partition; id=" + id + "; partitionString=" + partitionString); _partitions.Add(partitionString, partitionInfo); } Debug.Trace("PartitionManager", "id=" + id + "; partitionString=" + partitionString); return partitionInfo; } finally { if (_lock.IsWriterLockHeld) { _lock.ReleaseWriterLock(); } } } finally { if (EtwTrace.IsTraceEnabled(EtwTraceLevel.Verbose, EtwTraceFlags.Infrastructure)) { string msg = errorMessage; if (msg == null) { if (partitionInfo != null) { msg = partitionInfo.GetTracingPartitionString(); } else { msg = String.Empty; } } EtwTrace.Trace(EtwTraceType.ETW_TYPE_SESSIONSTATE_PARTITION_END, HttpContext.Current.WorkerRequest, msg); } } } public void Dispose() { if (_partitions == null) { return; } try { _lock.AcquireWriterLock(-1); if (_partitions != null) { foreach (PartitionInfo partitionInfo in _partitions.Values) { partitionInfo.Dispose(); } _partitions = null; } } catch { // ignore exceptions in dispose } finally { if (_lock.IsWriterLockHeld) { _lock.ReleaseWriterLock(); } } } } internal class PartitionInfo : IDisposable, IPartitionInfo { ResourcePool _rpool; internal PartitionInfo(ResourcePool rpool) { _rpool = rpool; } internal object RetrieveResource() { return _rpool.RetrieveResource(); } internal void StoreResource(IDisposable o) { _rpool.StoreResource(o); } protected virtual string TracingPartitionString { get { return String.Empty; } } string IPartitionInfo.GetTracingPartitionString() { return TracingPartitionString; } public void Dispose() { if (_rpool == null) { return; } lock (this) { if (_rpool != null) { _rpool.Dispose(); _rpool = null; } } } }; }
Link Menu

This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- ResourceDefaultValueAttribute.cs
- IgnoreSection.cs
- TextRunTypographyProperties.cs
- PersonalizationStateQuery.cs
- QuaternionKeyFrameCollection.cs
- FeatureSupport.cs
- StickyNoteContentControl.cs
- Win32PrintDialog.cs
- XmlComment.cs
- ContractCodeDomInfo.cs
- DoubleCollectionConverter.cs
- UIElement.cs
- BitmapCacheBrush.cs
- DispatcherEventArgs.cs
- WmlPageAdapter.cs
- QualificationDataItem.cs
- RsaSecurityKey.cs
- UriTemplateLiteralQueryValue.cs
- MatrixIndependentAnimationStorage.cs
- IndexerHelper.cs
- Msec.cs
- DataGridViewCellFormattingEventArgs.cs
- TextTreeTextBlock.cs
- ControlValuePropertyAttribute.cs
- SizeChangedEventArgs.cs
- ImmutableClientRuntime.cs
- CharacterString.cs
- SchemaAttDef.cs
- StreamAsIStream.cs
- WindowsStatic.cs
- ConfigurationConverterBase.cs
- SslStreamSecurityElement.cs
- DataGridViewRow.cs
- Graph.cs
- ScaleTransform.cs
- IndexedString.cs
- VectorAnimationUsingKeyFrames.cs
- ElementMarkupObject.cs
- XmlQuerySequence.cs
- InternalConfigRoot.cs
- MergeFailedEvent.cs
- ColorConverter.cs
- HtmlMeta.cs
- SymmetricSecurityProtocol.cs
- DataGridRowAutomationPeer.cs
- PositiveTimeSpanValidator.cs
- SingleObjectCollection.cs
- InvokeProviderWrapper.cs
- RequestCachePolicyConverter.cs
- AnyAllSearchOperator.cs
- CodeTypeDeclarationCollection.cs
- RemoteWebConfigurationHost.cs
- IteratorFilter.cs
- WSSecurityPolicy.cs
- BooleanToVisibilityConverter.cs
- DataProviderNameConverter.cs
- ElementFactory.cs
- ProfilePropertyNameValidator.cs
- UnsafeCollabNativeMethods.cs
- MetadataPropertyAttribute.cs
- CodeNamespaceImport.cs
- TextTreeRootTextBlock.cs
- InfoCardRequestException.cs
- ExecutionContext.cs
- ServiceProviders.cs
- JsonSerializer.cs
- XmlDictionaryReaderQuotas.cs
- OrderingQueryOperator.cs
- RegexNode.cs
- TextDpi.cs
- ColumnClickEvent.cs
- TextHidden.cs
- ResourceAttributes.cs
- APCustomTypeDescriptor.cs
- DataGridViewRowDividerDoubleClickEventArgs.cs
- Tool.cs
- HtmlGenericControl.cs
- XmlCompatibilityReader.cs
- ReachSerializableProperties.cs
- EventWaitHandleSecurity.cs
- Type.cs
- StringCollection.cs
- BuildManagerHost.cs
- CellLabel.cs
- Guid.cs
- DragEvent.cs
- WorkflowPersistenceContext.cs
- FacetValues.cs
- DataTemplateSelector.cs
- Soap.cs
- CellQuery.cs
- TemplateControlCodeDomTreeGenerator.cs
- XsltConvert.cs
- ToolStripControlHost.cs
- AssemblyBuilder.cs
- SafeCertificateContext.cs
- EnterpriseServicesHelper.cs
- RegexReplacement.cs
- RuntimeResourceSet.cs
- BitStack.cs