Code:
/ Net / Net / 3.5.50727.3053 / DEVDIV / depot / DevDiv / releases / whidbey / netfxsp / ndp / clr / src / BCL / System / Runtime / Remoting / LeaseManager.cs / 1 / LeaseManager.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== //+---------------------------------------------------------------------------- // // Microsoft Windows // File: LeaseManager.cs // // Contents: Administers the leases in an appdomain // // History: 1/5/00[....] Created // //+--------------------------------------------------------------------------- namespace System.Runtime.Remoting.Lifetime { using System; using System.Collections; using System.Threading; internal class LeaseManager { // Lease Lists private Hashtable leaseToTimeTable = new Hashtable(); // Async Sponsor Calls //private SortedList sponsorCallList = new SortedList(); private Hashtable sponsorTable = new Hashtable(); // LeaseTimeAnalyzer thread private TimeSpan pollTime; AutoResetEvent waitHandle; TimerCallback leaseTimeAnalyzerDelegate; private volatile Timer leaseTimer; internal static bool IsInitialized() { DomainSpecificRemotingData remotingData = Thread.GetDomain().RemotingData; LeaseManager leaseManager = remotingData.LeaseManager; return leaseManager != null; } internal static LeaseManager GetLeaseManager(TimeSpan pollTime) { DomainSpecificRemotingData remotingData = Thread.GetDomain().RemotingData; LeaseManager leaseManager = remotingData.LeaseManager; if (leaseManager == null) { lock (remotingData) { if (remotingData.LeaseManager == null) { remotingData.LeaseManager = new LeaseManager(pollTime); } leaseManager = remotingData.LeaseManager; } } return leaseManager; } internal static LeaseManager GetLeaseManager() { DomainSpecificRemotingData remotingData = Thread.GetDomain().RemotingData; LeaseManager leaseManager = remotingData.LeaseManager; BCLDebug.Assert(leaseManager != null, "[LeaseManager.GetLeaseManager()]leaseManager !=null"); return leaseManager; } private LeaseManager(TimeSpan pollTime) { BCLDebug.Trace("REMOTE","LeaseManager Constructor"); this.pollTime = pollTime; leaseTimeAnalyzerDelegate = new TimerCallback(this.LeaseTimeAnalyzer); waitHandle = new AutoResetEvent(false); // We need to create a Timer with Infinite dueTime to ensure that // leaseTimeAnalyzerDelegate doesnt get invoked before leaseTimer is initialized // Once initialized we can change it to the appropriate dueTime leaseTimer = new Timer(leaseTimeAnalyzerDelegate, null, Timeout.Infinite, Timeout.Infinite); leaseTimer.Change((int)pollTime.TotalMilliseconds, Timeout.Infinite); } internal void ChangePollTime(TimeSpan pollTime) { BCLDebug.Trace("REMOTE","LeaseManager ChangePollTime ", pollTime); this.pollTime = pollTime; } internal void ActivateLease(Lease lease) { BCLDebug.Trace("REMOTE","LeaseManager AddLease ",lease.id," ",lease.managedObject); lock(leaseToTimeTable) { leaseToTimeTable[lease] = lease.leaseTime; } } internal void DeleteLease(Lease lease) { BCLDebug.Trace("REMOTE","LeaseManager DeleteLease ",lease.id); lock(leaseToTimeTable) { leaseToTimeTable.Remove(lease); } } [System.Diagnostics.Conditional("_LOGGING")] internal void DumpLeases(Lease[] leases) { for (int i=0; i[....] Created // //+--------------------------------------------------------------------------- namespace System.Runtime.Remoting.Lifetime { using System; using System.Collections; using System.Threading; internal class LeaseManager { // Lease Lists private Hashtable leaseToTimeTable = new Hashtable(); // Async Sponsor Calls //private SortedList sponsorCallList = new SortedList(); private Hashtable sponsorTable = new Hashtable(); // LeaseTimeAnalyzer thread private TimeSpan pollTime; AutoResetEvent waitHandle; TimerCallback leaseTimeAnalyzerDelegate; private volatile Timer leaseTimer; internal static bool IsInitialized() { DomainSpecificRemotingData remotingData = Thread.GetDomain().RemotingData; LeaseManager leaseManager = remotingData.LeaseManager; return leaseManager != null; } internal static LeaseManager GetLeaseManager(TimeSpan pollTime) { DomainSpecificRemotingData remotingData = Thread.GetDomain().RemotingData; LeaseManager leaseManager = remotingData.LeaseManager; if (leaseManager == null) { lock (remotingData) { if (remotingData.LeaseManager == null) { remotingData.LeaseManager = new LeaseManager(pollTime); } leaseManager = remotingData.LeaseManager; } } return leaseManager; } internal static LeaseManager GetLeaseManager() { DomainSpecificRemotingData remotingData = Thread.GetDomain().RemotingData; LeaseManager leaseManager = remotingData.LeaseManager; BCLDebug.Assert(leaseManager != null, "[LeaseManager.GetLeaseManager()]leaseManager !=null"); return leaseManager; } private LeaseManager(TimeSpan pollTime) { BCLDebug.Trace("REMOTE","LeaseManager Constructor"); this.pollTime = pollTime; leaseTimeAnalyzerDelegate = new TimerCallback(this.LeaseTimeAnalyzer); waitHandle = new AutoResetEvent(false); // We need to create a Timer with Infinite dueTime to ensure that // leaseTimeAnalyzerDelegate doesnt get invoked before leaseTimer is initialized // Once initialized we can change it to the appropriate dueTime leaseTimer = new Timer(leaseTimeAnalyzerDelegate, null, Timeout.Infinite, Timeout.Infinite); leaseTimer.Change((int)pollTime.TotalMilliseconds, Timeout.Infinite); } internal void ChangePollTime(TimeSpan pollTime) { BCLDebug.Trace("REMOTE","LeaseManager ChangePollTime ", pollTime); this.pollTime = pollTime; } internal void ActivateLease(Lease lease) { BCLDebug.Trace("REMOTE","LeaseManager AddLease ",lease.id," ",lease.managedObject); lock(leaseToTimeTable) { leaseToTimeTable[lease] = lease.leaseTime; } } internal void DeleteLease(Lease lease) { BCLDebug.Trace("REMOTE","LeaseManager DeleteLease ",lease.id); lock(leaseToTimeTable) { leaseToTimeTable.Remove(lease); } } [System.Diagnostics.Conditional("_LOGGING")] internal void DumpLeases(Lease[] leases) { for (int i=0; i
Link Menu

This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- ColumnMapVisitor.cs
- MenuCommand.cs
- SoapEnumAttribute.cs
- WebResourceAttribute.cs
- XsdBuilder.cs
- DecryptedHeader.cs
- MemberPathMap.cs
- SapiGrammar.cs
- XmlElement.cs
- MasterPageParser.cs
- QueryReaderSettings.cs
- ParseNumbers.cs
- DesignerRegion.cs
- GraphicsPathIterator.cs
- DataGridColumn.cs
- TextViewElement.cs
- Constants.cs
- ConnectionPoint.cs
- ObjectStateEntry.cs
- CacheOutputQuery.cs
- _ListenerAsyncResult.cs
- ObjectListDataBindEventArgs.cs
- RegexCode.cs
- CacheDependency.cs
- StylusButton.cs
- ResourceWriter.cs
- WebPartCancelEventArgs.cs
- DefaultValueMapping.cs
- ProcessModuleCollection.cs
- AutomationElement.cs
- HtmlObjectListAdapter.cs
- ServiceAppDomainAssociationProvider.cs
- FieldMetadata.cs
- SyndicationCategory.cs
- EmptyTextWriter.cs
- UnsafeNativeMethodsTablet.cs
- AnnotationHighlightLayer.cs
- SymbolEqualComparer.cs
- DateTimeHelper.cs
- AssemblyHash.cs
- ToolTipAutomationPeer.cs
- RuleSettings.cs
- Header.cs
- RichTextBox.cs
- PriorityRange.cs
- ArithmeticException.cs
- XPathNodeIterator.cs
- UniformGrid.cs
- smtppermission.cs
- DeviceContexts.cs
- OperatingSystem.cs
- MasterPageParser.cs
- WebPartHelpVerb.cs
- SystemKeyConverter.cs
- ScriptIgnoreAttribute.cs
- ManipulationLogic.cs
- UInt64Storage.cs
- wmiprovider.cs
- InternalConfigConfigurationFactory.cs
- StsCommunicationException.cs
- CompleteWizardStep.cs
- LocatorGroup.cs
- objectresult_tresulttype.cs
- _NegoState.cs
- DecimalKeyFrameCollection.cs
- DropTarget.cs
- CrossAppDomainChannel.cs
- DataSourceXmlTextReader.cs
- WebColorConverter.cs
- RawStylusInputCustomDataList.cs
- EasingKeyFrames.cs
- HttpRuntime.cs
- CryptoHelper.cs
- CharStorage.cs
- DateTimeOffsetStorage.cs
- MdiWindowListStrip.cs
- WebPartZoneBaseDesigner.cs
- StylusTip.cs
- SQLInt32.cs
- BindingCollection.cs
- Setter.cs
- ScriptingProfileServiceSection.cs
- PingReply.cs
- CrossSiteScriptingValidation.cs
- ImpersonateTokenRef.cs
- URI.cs
- DocumentPageViewAutomationPeer.cs
- DragEvent.cs
- ConfigUtil.cs
- MethodBuilder.cs
- FrameworkContextData.cs
- DataRelation.cs
- OleDbEnumerator.cs
- RemoteWebConfigurationHostServer.cs
- InputBindingCollection.cs
- CompressionTracing.cs
- PolyLineSegment.cs
- TypedReference.cs
- DateRangeEvent.cs
- Vector3DAnimationUsingKeyFrames.cs