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
- BlockCollection.cs
- MethodBody.cs
- ScopedKnownTypes.cs
- TagElement.cs
- DataGridViewCellStyle.cs
- ExtendedPropertyDescriptor.cs
- UnsafeNativeMethods.cs
- SafeTimerHandle.cs
- DataGridHelper.cs
- DataServiceQueryProvider.cs
- XmlSchemaAll.cs
- WmpBitmapDecoder.cs
- EditingScope.cs
- PageContent.cs
- ProcessInfo.cs
- BitmapEffectDrawing.cs
- ListViewVirtualItemsSelectionRangeChangedEvent.cs
- SQLDouble.cs
- Msmq4SubqueuePoisonHandler.cs
- HttpHandlerAction.cs
- UrlPropertyAttribute.cs
- MatrixTransform3D.cs
- OwnerDrawPropertyBag.cs
- File.cs
- SerialReceived.cs
- PropertyChangedEventArgs.cs
- XmlWellformedWriter.cs
- ToolStripMenuItem.cs
- HostProtectionException.cs
- MaskedTextProvider.cs
- XmlSchemaException.cs
- ZipIORawDataFileBlock.cs
- TextTreePropertyUndoUnit.cs
- DataBinding.cs
- FileIOPermission.cs
- TabPanel.cs
- Aggregates.cs
- PassportAuthenticationEventArgs.cs
- sortedlist.cs
- WindowsUserNameSecurityTokenAuthenticator.cs
- RepeaterItemEventArgs.cs
- updateconfighost.cs
- ToolStripOverflow.cs
- ProviderBase.cs
- Calendar.cs
- SqlClientWrapperSmiStreamChars.cs
- CaseInsensitiveOrdinalStringComparer.cs
- BrowserDefinitionCollection.cs
- SqlCommandBuilder.cs
- XmlHierarchyData.cs
- FontResourceCache.cs
- WindowsFormsSectionHandler.cs
- DefaultTextStore.cs
- ApplicationActivator.cs
- ProcessThread.cs
- ToolStripSystemRenderer.cs
- SqlFlattener.cs
- ListChangedEventArgs.cs
- ListViewSelectEventArgs.cs
- NameValueSectionHandler.cs
- ValueUtilsSmi.cs
- DecoderExceptionFallback.cs
- CustomAttributeFormatException.cs
- Stream.cs
- SimpleApplicationHost.cs
- FlowDocumentReaderAutomationPeer.cs
- MatcherBuilder.cs
- HybridWebProxyFinder.cs
- PageContentCollection.cs
- ValueType.cs
- ServiceModelConfigurationSectionGroup.cs
- X509Certificate2Collection.cs
- BaseDataBoundControl.cs
- NetTcpSection.cs
- InfocardExtendedInformationEntry.cs
- TextBoxAutoCompleteSourceConverter.cs
- HtmlInputCheckBox.cs
- SecurityKeyIdentifierClause.cs
- FixedTextSelectionProcessor.cs
- MatchingStyle.cs
- FixUpCollection.cs
- TextRunCacheImp.cs
- SimpleTextLine.cs
- XmlReflectionMember.cs
- SchemaAttDef.cs
- ActivityInstance.cs
- SimplePropertyEntry.cs
- RowType.cs
- PassportIdentity.cs
- WriteFileContext.cs
- ProtocolsInstallComponent.cs
- SoapReflectionImporter.cs
- SecondaryIndex.cs
- XmlSchemaDatatype.cs
- FileDetails.cs
- EnumBuilder.cs
- CancelEventArgs.cs
- SystemResourceHost.cs
- CatalogPartChrome.cs
- CreateRefExpr.cs