Code:
/ Dotnetfx_Win7_3.5.1 / Dotnetfx_Win7_3.5.1 / 3.5.1 / DEVDIV / depot / DevDiv / releases / whidbey / NetFXspW7 / ndp / clr / src / BCL / System / Runtime / Remoting / TrackingServices.cs / 1 / TrackingServices.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== /*============================================================ ** ** File: TrackingServices.cs ** ** ** Purpose: Defines the services for tracking lifetime and other ** operations on objects. ** ** ===========================================================*/ namespace System.Runtime.Remoting.Services { using System.Security.Permissions; using System; using System.Threading; using System.Globalization; [System.Runtime.InteropServices.ComVisible(true)] public interface ITrackingHandler { // Notify a handler that an object has been marshaled [SecurityPermissionAttribute(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.Infrastructure)] void MarshaledObject(Object obj, ObjRef or); // Notify a handler that an object has been unmarshaled [SecurityPermissionAttribute(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.Infrastructure)] void UnmarshaledObject(Object obj, ObjRef or); // Notify a handler that an object has been disconnected [SecurityPermissionAttribute(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.Infrastructure)] void DisconnectedObject(Object obj); } [SecurityPermissionAttribute(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.Infrastructure)] [System.Runtime.InteropServices.ComVisible(true)] public class TrackingServices { // Private member variables private static ITrackingHandler[] _Handlers = new ITrackingHandler[0]; // Array of registered tracking handlers private static int _Size = 0; // Number of elements in the array private static Object s_TrackingServicesSyncObject = null; private static Object TrackingServicesSyncObject { get { if (s_TrackingServicesSyncObject == null) { Object o = new Object(); Interlocked.CompareExchange(ref s_TrackingServicesSyncObject, o, null); } return s_TrackingServicesSyncObject; } } public static void RegisterTrackingHandler(ITrackingHandler handler) { lock(TrackingServicesSyncObject) { // Validate arguments if(null == handler) { throw new ArgumentNullException("handler"); } // Check to make sure that the handler has not been registered if(-1 == Match(handler)) { // Allocate a new array if necessary if((null == _Handlers) || (_Size == _Handlers.Length)) { ITrackingHandler[] temp = new ITrackingHandler[_Size*2+4]; if(null != _Handlers) { Array.Copy(_Handlers, temp, _Size); } _Handlers = temp; } _Handlers[_Size++] = handler; } else { throw new RemotingException(String.Format(CultureInfo.CurrentCulture, Environment.GetResourceString("Remoting_TrackingHandlerAlreadyRegistered"), "handler")); } } } public static void UnregisterTrackingHandler(ITrackingHandler handler) { lock(TrackingServicesSyncObject) { // Validate arguments if(null == handler) { throw new ArgumentNullException("handler"); } // Check to make sure that the channel has been registered int matchingIdx = Match(handler); if(-1 == matchingIdx) { throw new RemotingException(String.Format(CultureInfo.CurrentCulture, Environment.GetResourceString("Remoting_HandlerNotRegistered"), handler)); } // Delete the entry by copying the remaining entries Array.Copy(_Handlers, matchingIdx+1, _Handlers, matchingIdx, _Size-matchingIdx-1); _Size--; } } public static ITrackingHandler[] RegisteredHandlers { get { lock(TrackingServicesSyncObject) { if(0 == _Size) { return new ITrackingHandler[0]; } else { // Copy the array of registered handlers into a new array // and return ITrackingHandler[] temp = new ITrackingHandler[_Size]; for(int i = 0; i < _Size; i++) { temp[i] = _Handlers[i]; } return temp; } } } } // Notify all the handlers that an object has been marshaled internal static void MarshaledObject(Object obj, ObjRef or) { try{ ITrackingHandler[] temp = _Handlers; for(int i = 0; i < _Size; i++) { temp[i].MarshaledObject(obj, or); } } catch {} } // Notify all the handlers that an object has been unmarshaled internal static void UnmarshaledObject(Object obj, ObjRef or) { try{ ITrackingHandler[] temp = _Handlers; for(int i = 0; i < _Size; i++) { temp[i].UnmarshaledObject(obj, or); } } catch {} } // Notify all the handlers that an object has been disconnected internal static void DisconnectedObject(Object obj) { try{ ITrackingHandler[] temp = _Handlers; for(int i = 0; i < _Size; i++) { temp[i].DisconnectedObject(obj); } } catch {} } private static int Match(ITrackingHandler handler) { int idx = -1; for(int i = 0; i < _Size; i++) { if(_Handlers[i] == handler) { idx = i; break; } } return idx; } } } // namespace // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== /*============================================================ ** ** File: TrackingServices.cs ** ** ** Purpose: Defines the services for tracking lifetime and other ** operations on objects. ** ** ===========================================================*/ namespace System.Runtime.Remoting.Services { using System.Security.Permissions; using System; using System.Threading; using System.Globalization; [System.Runtime.InteropServices.ComVisible(true)] public interface ITrackingHandler { // Notify a handler that an object has been marshaled [SecurityPermissionAttribute(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.Infrastructure)] void MarshaledObject(Object obj, ObjRef or); // Notify a handler that an object has been unmarshaled [SecurityPermissionAttribute(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.Infrastructure)] void UnmarshaledObject(Object obj, ObjRef or); // Notify a handler that an object has been disconnected [SecurityPermissionAttribute(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.Infrastructure)] void DisconnectedObject(Object obj); } [SecurityPermissionAttribute(SecurityAction.LinkDemand, Flags=SecurityPermissionFlag.Infrastructure)] [System.Runtime.InteropServices.ComVisible(true)] public class TrackingServices { // Private member variables private static ITrackingHandler[] _Handlers = new ITrackingHandler[0]; // Array of registered tracking handlers private static int _Size = 0; // Number of elements in the array private static Object s_TrackingServicesSyncObject = null; private static Object TrackingServicesSyncObject { get { if (s_TrackingServicesSyncObject == null) { Object o = new Object(); Interlocked.CompareExchange(ref s_TrackingServicesSyncObject, o, null); } return s_TrackingServicesSyncObject; } } public static void RegisterTrackingHandler(ITrackingHandler handler) { lock(TrackingServicesSyncObject) { // Validate arguments if(null == handler) { throw new ArgumentNullException("handler"); } // Check to make sure that the handler has not been registered if(-1 == Match(handler)) { // Allocate a new array if necessary if((null == _Handlers) || (_Size == _Handlers.Length)) { ITrackingHandler[] temp = new ITrackingHandler[_Size*2+4]; if(null != _Handlers) { Array.Copy(_Handlers, temp, _Size); } _Handlers = temp; } _Handlers[_Size++] = handler; } else { throw new RemotingException(String.Format(CultureInfo.CurrentCulture, Environment.GetResourceString("Remoting_TrackingHandlerAlreadyRegistered"), "handler")); } } } public static void UnregisterTrackingHandler(ITrackingHandler handler) { lock(TrackingServicesSyncObject) { // Validate arguments if(null == handler) { throw new ArgumentNullException("handler"); } // Check to make sure that the channel has been registered int matchingIdx = Match(handler); if(-1 == matchingIdx) { throw new RemotingException(String.Format(CultureInfo.CurrentCulture, Environment.GetResourceString("Remoting_HandlerNotRegistered"), handler)); } // Delete the entry by copying the remaining entries Array.Copy(_Handlers, matchingIdx+1, _Handlers, matchingIdx, _Size-matchingIdx-1); _Size--; } } public static ITrackingHandler[] RegisteredHandlers { get { lock(TrackingServicesSyncObject) { if(0 == _Size) { return new ITrackingHandler[0]; } else { // Copy the array of registered handlers into a new array // and return ITrackingHandler[] temp = new ITrackingHandler[_Size]; for(int i = 0; i < _Size; i++) { temp[i] = _Handlers[i]; } return temp; } } } } // Notify all the handlers that an object has been marshaled internal static void MarshaledObject(Object obj, ObjRef or) { try{ ITrackingHandler[] temp = _Handlers; for(int i = 0; i < _Size; i++) { temp[i].MarshaledObject(obj, or); } } catch {} } // Notify all the handlers that an object has been unmarshaled internal static void UnmarshaledObject(Object obj, ObjRef or) { try{ ITrackingHandler[] temp = _Handlers; for(int i = 0; i < _Size; i++) { temp[i].UnmarshaledObject(obj, or); } } catch {} } // Notify all the handlers that an object has been disconnected internal static void DisconnectedObject(Object obj) { try{ ITrackingHandler[] temp = _Handlers; for(int i = 0; i < _Size; i++) { temp[i].DisconnectedObject(obj); } } catch {} } private static int Match(ITrackingHandler handler) { int idx = -1; for(int i = 0; i < _Size; i++) { if(_Handlers[i] == handler) { idx = i; break; } } return idx; } } } // namespace // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- FeedUtils.cs
- DESCryptoServiceProvider.cs
- MarshalByValueComponent.cs
- MenuItemBindingCollection.cs
- FormsAuthenticationConfiguration.cs
- PngBitmapDecoder.cs
- SecurityRuntime.cs
- Enum.cs
- AssemblySettingAttributes.cs
- ListViewEditEventArgs.cs
- Visual3D.cs
- ConfigXmlWhitespace.cs
- EmptyImpersonationContext.cs
- SamlAudienceRestrictionCondition.cs
- MetadataSet.cs
- WebPartHelpVerb.cs
- Debugger.cs
- GeometryHitTestParameters.cs
- _SslSessionsCache.cs
- DataMemberListEditor.cs
- ChannelBinding.cs
- DataGridViewRowPrePaintEventArgs.cs
- WorkflowDesigner.cs
- FontStretches.cs
- ObjectItemCachedAssemblyLoader.cs
- ActivatableWorkflowsQueryResult.cs
- precedingquery.cs
- ConditionBrowserDialog.cs
- SerializerWriterEventHandlers.cs
- CursorInteropHelper.cs
- XPathCompileException.cs
- MatrixAnimationUsingPath.cs
- ScrollBar.cs
- FocusTracker.cs
- HtmlInputFile.cs
- QuarticEase.cs
- HtmlTextArea.cs
- CachedBitmap.cs
- JoinTreeSlot.cs
- HostedBindingBehavior.cs
- ClientFormsIdentity.cs
- Substitution.cs
- X500Name.cs
- DataSetMappper.cs
- NotImplementedException.cs
- GridViewColumnCollectionChangedEventArgs.cs
- BinaryObjectInfo.cs
- ParameterToken.cs
- ColorMatrix.cs
- Translator.cs
- CompilerWrapper.cs
- ChineseLunisolarCalendar.cs
- StrongName.cs
- HttpConfigurationContext.cs
- CharacterMetricsDictionary.cs
- ProxyDataContractResolver.cs
- OpacityConverter.cs
- ImageSourceValueSerializer.cs
- errorpatternmatcher.cs
- TransactionInformation.cs
- grammarelement.cs
- _Connection.cs
- QueryReaderSettings.cs
- SqlFlattener.cs
- SimpleRecyclingCache.cs
- RpcResponse.cs
- WebPartConnectVerb.cs
- PropertyExpression.cs
- PeerApplication.cs
- ServerIdentity.cs
- RPIdentityRequirement.cs
- TrustSection.cs
- StorageAssociationTypeMapping.cs
- ValidatedControlConverter.cs
- SafeHandles.cs
- TextTreeFixupNode.cs
- Int64.cs
- SapiRecoInterop.cs
- ClientEventManager.cs
- XsdDuration.cs
- OdbcFactory.cs
- RelativeSource.cs
- GradientBrush.cs
- XmlAttributeHolder.cs
- ZipIOFileItemStream.cs
- URIFormatException.cs
- IPAddressCollection.cs
- XhtmlStyleClass.cs
- SecurityDescriptor.cs
- WebPartTracker.cs
- MembershipValidatePasswordEventArgs.cs
- CreateParams.cs
- Matrix3DConverter.cs
- SqlVersion.cs
- UxThemeWrapper.cs
- ParserContext.cs
- GridViewAutomationPeer.cs
- DynamicMetaObject.cs
- Point.cs
- IdentifierCreationService.cs