Code:
/ Dotnetfx_Vista_SP2 / Dotnetfx_Vista_SP2 / 8.0.50727.4016 / DEVDIV / depot / DevDiv / releases / whidbey / NetFxQFE / 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
- TraceContextRecord.cs
- BrowserCapabilitiesFactory.cs
- XhtmlBasicListAdapter.cs
- BindUriHelper.cs
- ReservationNotFoundException.cs
- wgx_exports.cs
- FileFormatException.cs
- DebugInfoExpression.cs
- Expander.cs
- HttpCachePolicy.cs
- StateItem.cs
- XmlEntity.cs
- _AutoWebProxyScriptHelper.cs
- WorkflowOwnershipException.cs
- JournalEntry.cs
- BitmapFrame.cs
- MsmqQueue.cs
- SafeTokenHandle.cs
- DataGridViewColumnStateChangedEventArgs.cs
- XsltConvert.cs
- AliasGenerator.cs
- ToolTipService.cs
- XmlDocumentType.cs
- ResourcePool.cs
- SecurityDocument.cs
- NameSpaceEvent.cs
- FormViewCommandEventArgs.cs
- CodeExpressionStatement.cs
- DataGridPagerStyle.cs
- RequestQueue.cs
- Setter.cs
- AuthenticationService.cs
- ObjectHandle.cs
- SQLDateTime.cs
- DefaultPrintController.cs
- UniqueEventHelper.cs
- HtmlCalendarAdapter.cs
- SqlDataSourceStatusEventArgs.cs
- PassportPrincipal.cs
- ConfigurationSchemaErrors.cs
- ResumeStoryboard.cs
- TextFormatterHost.cs
- AsyncDataRequest.cs
- SiteMap.cs
- _CacheStreams.cs
- BaseHashHelper.cs
- MenuCommand.cs
- DbDeleteCommandTree.cs
- mediaclock.cs
- ContainerVisual.cs
- RadioButtonPopupAdapter.cs
- SmiEventStream.cs
- XmlMemberMapping.cs
- HeaderCollection.cs
- Timer.cs
- AmbientValueAttribute.cs
- FileDialog_Vista.cs
- ProjectionAnalyzer.cs
- Funcletizer.cs
- EntityProviderServices.cs
- XmlJsonWriter.cs
- BStrWrapper.cs
- DelegatedStream.cs
- FixedSOMTableCell.cs
- StorageFunctionMapping.cs
- PrimitiveXmlSerializers.cs
- NetworkCredential.cs
- ClientData.cs
- GridItemProviderWrapper.cs
- DragDrop.cs
- PkcsUtils.cs
- Int32Collection.cs
- relpropertyhelper.cs
- State.cs
- handlecollector.cs
- PointCollectionValueSerializer.cs
- RequestFactory.cs
- MetabaseServerConfig.cs
- NetworkInterface.cs
- TypeToken.cs
- LiteralControl.cs
- ShapingWorkspace.cs
- SettingsPropertyIsReadOnlyException.cs
- FixedPageProcessor.cs
- TextProviderWrapper.cs
- CfgParser.cs
- DBPropSet.cs
- CacheEntry.cs
- PageContentAsyncResult.cs
- CatalogPart.cs
- BindingContext.cs
- InvalidCardException.cs
- RegisteredArrayDeclaration.cs
- ExtentCqlBlock.cs
- IBuiltInEvidence.cs
- TextEffectCollection.cs
- FilteredXmlReader.cs
- HtmlInputCheckBox.cs
- ObjectListTitleAttribute.cs
- EntityContainerEntitySet.cs