Code:
/ Dotnetfx_Win7_3.5.1 / Dotnetfx_Win7_3.5.1 / 3.5.1 / DEVDIV / depot / DevDiv / releases / Orcas / NetFXw7 / ndp / fx / src / SystemNet / Net / PeerToPeer / Collaboration / PeerEndPoint.cs / 1 / PeerEndPoint.cs
//------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- namespace System.Net.PeerToPeer.Collaboration { using System; using System.Collections; using System.Collections.Generic; using System.Collections.ObjectModel; using System.Text; using System.Runtime.InteropServices; using System.Net.Sockets; using System.ComponentModel; using System.Threading; using System.Diagnostics; using System.Runtime.Serialization; using System.Security.Permissions; ////// This is the event args class we give back when /// we have have a name changed event fired by native /// public class NameChangedEventArgs : EventArgs { private PeerEndPoint m_peerEndPoint; private PeerContact m_peerContact; private string m_name; internal NameChangedEventArgs(PeerEndPoint peerEndPoint, PeerContact peerContact, string name) { m_peerEndPoint = peerEndPoint; m_peerContact = peerContact; m_name = name; } public PeerEndPoint PeerEndPoint { get{ return m_peerEndPoint; } } public PeerContact PeerContact { get{ return m_peerContact; } } public string Name { get{ return m_name; } } } ////// PeerEndpoint class encapsulates the functionality of an /// endpoint in the peer collaboration scope. /// [Serializable] public class PeerEndPoint : IDisposable, IEquatable, ISerializable { private string m_endPointName; private IPEndPoint m_endPoint; private ISynchronizeInvoke m_synchronizingObject; public PeerEndPoint() { } public PeerEndPoint(IPEndPoint endPoint):this(endPoint, null) { } public PeerEndPoint(IPEndPoint endPoint, string endPointName) { if (endPoint == null){ throw new ArgumentNullException("endPoint"); } // // Validate that this is an IPv6 address // if ((m_endPoint != null) && (m_endPoint.AddressFamily != AddressFamily.InterNetworkV6)){ Logging.P2PTraceSource.TraceEvent(TraceEventType.Error, 0, "PeerEndPoint Endpoint set parameter is not IPv6."); throw new ArgumentException("endPoint", SR.GetString(SR.Collab_EndPointNotIPv6Error)); } m_endPoint = endPoint; m_endPointName = endPointName; } /// /// Constructor to enable serialization /// protected PeerEndPoint(SerializationInfo serializationInfo, StreamingContext streamingContext) { m_endPointName = serializationInfo.GetString("_EndPointName"); m_endPoint = (IPEndPoint)serializationInfo.GetValue("_EndPoint", typeof(IPEndPoint)); } public string Name { get { return m_endPointName; } set { m_endPointName = value; } } public IPEndPoint EndPoint { get { return m_endPoint; } set { // // Validate that this is an IPv6 address // if ((m_endPoint != null) && (m_endPoint.AddressFamily != AddressFamily.InterNetworkV6)){ Logging.P2PTraceSource.TraceEvent(TraceEventType.Error, 0, "PeerEndPoint Endpoint set parameter is not IPv6."); throw new PeerToPeerException(SR.GetString(SR.Collab_EndPointNotIPv6Error)); } m_endPoint = value; } } ////// Gets and set the object used to marshall event handlers calls for stand alone /// events /// [Browsable(false), DefaultValue(null), Description(SR.SynchronizingObject)] public ISynchronizeInvoke SynchronizingObject { get { if (m_Disposed) throw new ObjectDisposedException(this.GetType().FullName); return m_synchronizingObject; } set { if (m_Disposed) throw new ObjectDisposedException(this.GetType().FullName); m_synchronizingObject = value; } } private event EventHandlerm_nameChanged; public event EventHandler NameChanged { // // [System.Security.SecurityCritical] add{ if (m_Disposed) throw new ObjectDisposedException(this.GetType().FullName); CollaborationHelperFunctions.Initialize(); PeerCollaborationPermission.UnrestrictedPeerCollaborationPermission.Demand(); AddNameChanged(value); } //// // // [System.Security.SecurityCritical] remove{ if (m_Disposed) throw new ObjectDisposedException(this.GetType().FullName); CollaborationHelperFunctions.Initialize(); PeerCollaborationPermission.UnrestrictedPeerCollaborationPermission.Demand(); RemoveNameChanged(value); } } #region Name changed event variables private object m_lockNameChangedEvent; private object LockNameChangedEvent { get{ if (m_lockNameChangedEvent == null){ object o = new object(); Interlocked.CompareExchange(ref m_lockNameChangedEvent, o, null); } return m_lockNameChangedEvent; } } private RegisteredWaitHandle m_regNameChangedWaitHandle; private AutoResetEvent m_nameChangedEvent; private SafeCollabEvent m_safeNameChangedEvent; #endregion //// // // [System.Security.SecurityCritical] private void AddNameChanged(EventHandler// // // // // callback) { Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "Entering AddNameChanged()."); // // Register a wait handle if one has not been registered already // lock (LockNameChangedEvent){ if (m_nameChanged == null){ m_nameChangedEvent = new AutoResetEvent(false); // // Register callback with a wait handle // m_regNameChangedWaitHandle = ThreadPool.RegisterWaitForSingleObject(m_nameChangedEvent, //Event that triggers the callback new WaitOrTimerCallback(NameChangedCallback), //callback to be called null, //state to be passed -1, //Timeout - aplicable only for timers false //call us everytime the event is set ); PEER_COLLAB_EVENT_REGISTRATION pcer = new PEER_COLLAB_EVENT_REGISTRATION(); pcer.eventType = PeerCollabEventType.EndPointChanged; pcer.pInstance = IntPtr.Zero; // // Register event with collab // int errorCode = UnsafeCollabNativeMethods.PeerCollabRegisterEvent( m_nameChangedEvent.SafeWaitHandle, 1, ref pcer, out m_safeNameChangedEvent); if (errorCode != 0){ Logging.P2PTraceSource.TraceEvent(TraceEventType.Error, 0, "PeerCollabRegisterEvent returned with errorcode {0}", errorCode); throw PeerToPeerException.CreateFromHr(SR.GetString(SR.Collab_NameChangedRegFailed), errorCode); } } m_nameChanged += callback; } Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "AddNameChanged() successful."); } // // [System.Security.SecurityCritical] private void RemoveNameChanged(EventHandler// // callback) { Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "RemoveNameChanged() called."); lock (LockNameChangedEvent){ m_nameChanged -= callback; if (m_nameChanged == null){ CollaborationHelperFunctions.CleanEventVars(ref m_regNameChangedWaitHandle, ref m_safeNameChangedEvent, ref m_nameChangedEvent); Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "Clean NameChanged variables successful."); } } Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "RemoveNameChanged() successful."); } // // [System.Security.SecurityCritical] private void NameChangedCallback(object state, bool timedOut) { SafeCollabData eventData = null; int errorCode = 0; Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "NameChangedCallback() called."); if (m_Disposed) return; while (true){ NameChangedEventArgs nameChangedArgs = null; // // Get the event data for the fired event // try{ lock (LockNameChangedEvent) { if (m_safeNameChangedEvent.IsInvalid) return; errorCode = UnsafeCollabNativeMethods.PeerCollabGetEventData(m_safeNameChangedEvent, out eventData); } if (errorCode == UnsafeCollabReturnCodes.PEER_S_NO_EVENT_DATA) break; else if (errorCode != 0){ Logging.P2PTraceSource.TraceEvent(TraceEventType.Error, 0, "PeerCollabGetEventData returned with errorcode {0}", errorCode); throw PeerToPeerException.CreateFromHr(SR.GetString(SR.Collab_GetNameChangedDataFailed), errorCode); } PEER_COLLAB_EVENT_DATA ped = (PEER_COLLAB_EVENT_DATA)Marshal.PtrToStructure(eventData.DangerousGetHandle(), typeof(PEER_COLLAB_EVENT_DATA)); if (ped.eventType == PeerCollabEventType.EndPointChanged){ PEER_EVENT_ENDPOINT_CHANGED_DATA epData = ped.endpointChangedData; PeerEndPoint peerEndPoint = null; if (epData.pEndPoint != IntPtr.Zero){ PEER_ENDPOINT pe = (PEER_ENDPOINT)Marshal.PtrToStructure(epData.pEndPoint, typeof(PEER_ENDPOINT)); peerEndPoint = CollaborationHelperFunctions.ConvertPEER_ENDPOINTToPeerEndPoint(pe); } if ((peerEndPoint != null) && Equals(peerEndPoint)){ PeerContact peerContact = null; if (epData.pContact != IntPtr.Zero){ PEER_CONTACT pc = (PEER_CONTACT)Marshal.PtrToStructure(epData.pContact, typeof(PEER_CONTACT)); peerContact = CollaborationHelperFunctions.ConvertPEER_CONTACTToPeerContact(pc); } nameChangedArgs = new NameChangedEventArgs(peerEndPoint, peerContact, peerEndPoint.Name); } } } finally{ if (eventData != null) eventData.Dispose(); } // // Fire the callback with the marshalled event args data // if (nameChangedArgs != null){ OnNameChanged(nameChangedArgs); // // Change the name with the new name // Name = nameChangedArgs.PeerEndPoint.Name; } } Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "Leaving NameChangedCallback()."); } protected void OnNameChanged(NameChangedEventArgs nameChangedArgs) { EventHandler// // // // // // // // // // handlerCopy = m_nameChanged; if (handlerCopy != null){ if (SynchronizingObject != null && SynchronizingObject.InvokeRequired) SynchronizingObject.BeginInvoke(handlerCopy, new object[] { this, nameChangedArgs }); else handlerCopy(this, nameChangedArgs); Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "Fired the name changed event callback."); } } public bool Equals(PeerEndPoint other) { if (m_Disposed) throw new ObjectDisposedException(this.GetType().FullName); // // Equality means same ipendpoints // if (other != null){ return other.EndPoint.Equals(EndPoint); } return false; } public override bool Equals(object obj) { PeerEndPoint comparandPeerEndPoint = obj as PeerEndPoint; if (comparandPeerEndPoint != null){ return comparandPeerEndPoint.EndPoint.Equals(EndPoint); } return false; } public new static bool Equals(object objA, object objB) { PeerEndPoint comparandPeerEndPoint1 = objA as PeerEndPoint; PeerEndPoint comparandPeerEndPoint2 = objB as PeerEndPoint; if ((comparandPeerEndPoint1 != null) && (comparandPeerEndPoint2 != null)){ return comparandPeerEndPoint1.EndPoint.Equals(comparandPeerEndPoint2.EndPoint); } return false; } public override int GetHashCode() { if (m_Disposed) throw new ObjectDisposedException(this.GetType().FullName); return EndPoint.GetHashCode(); } public override string ToString() { if (m_Disposed) throw new ObjectDisposedException(this.GetType().FullName); return m_endPointName; } private bool m_Disposed; // // [System.Security.SecurityCritical] public void Dispose() { Dispose(true); GC.SuppressFinalize(this); } //// // [System.Security.SecurityCritical] protected virtual void Dispose(bool disposing) { if (!m_Disposed){ CollaborationHelperFunctions.CleanEventVars(ref m_regNameChangedWaitHandle, ref m_safeNameChangedEvent, ref m_nameChangedEvent); Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "Clean NameChanged variables successful."); } m_Disposed = true; } //// // // [System.Security.SecurityCritical] [SecurityPermission(SecurityAction.LinkDemand, Flags = SecurityPermissionFlag.SerializationFormatter, SerializationFormatter = true)] void ISerializable.GetObjectData(SerializationInfo info, StreamingContext context) { GetObjectData(info, context); } ///// /// This is made virtual so that derived types can be implemented correctly /// [SecurityPermission(SecurityAction.LinkDemand, SerializationFormatter = true)] protected virtual void GetObjectData(SerializationInfo info, StreamingContext context) { info.AddValue("_EndPointName", m_endPointName); info.AddValue("_EndPoint", m_endPoint); } internal void TracePeerEndPoint() { Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "Contents of the PeerEndPoint"); Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "\tEndPoint: {0}", (EndPoint != null? EndPoint.ToString(): null)); Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "\tDescription: {0}", Name); } } ////// Represents a collection of PeerEndPoints /// [Serializable] public class PeerEndPointCollection : Collection, IEquatable { internal PeerEndPointCollection() { } protected override void SetItem(int index, PeerEndPoint item) { // // Null peerendpoints not allowed // if (item == null){ throw new ArgumentNullException("item"); } base.SetItem(index, item); } protected override void InsertItem(int index, PeerEndPoint item) { // // Null peerendpoints not allowed // if (item == null){ throw new ArgumentNullException("item"); } base.InsertItem(index, item); } public override string ToString() { bool first = true; StringBuilder builder = new StringBuilder(); foreach (PeerEndPoint peerEndPoint in this){ if (!first){ builder.Append(", "); } else{ first = false; } builder.Append(peerEndPoint.ToString()); } return builder.ToString(); } public bool Equals(PeerEndPointCollection other) { bool equal = false; if (other != null){ foreach (PeerEndPoint peerEndPoint1 in other) foreach (PeerEndPoint peerEndPoint2 in this) if (!peerEndPoint1.Equals(peerEndPoint2)){ return equal; } equal = true; } return equal; } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. //------------------------------------------------------------------------------ // // Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- namespace System.Net.PeerToPeer.Collaboration { using System; using System.Collections; using System.Collections.Generic; using System.Collections.ObjectModel; using System.Text; using System.Runtime.InteropServices; using System.Net.Sockets; using System.ComponentModel; using System.Threading; using System.Diagnostics; using System.Runtime.Serialization; using System.Security.Permissions; ////// This is the event args class we give back when /// we have have a name changed event fired by native /// public class NameChangedEventArgs : EventArgs { private PeerEndPoint m_peerEndPoint; private PeerContact m_peerContact; private string m_name; internal NameChangedEventArgs(PeerEndPoint peerEndPoint, PeerContact peerContact, string name) { m_peerEndPoint = peerEndPoint; m_peerContact = peerContact; m_name = name; } public PeerEndPoint PeerEndPoint { get{ return m_peerEndPoint; } } public PeerContact PeerContact { get{ return m_peerContact; } } public string Name { get{ return m_name; } } } ////// PeerEndpoint class encapsulates the functionality of an /// endpoint in the peer collaboration scope. /// [Serializable] public class PeerEndPoint : IDisposable, IEquatable, ISerializable { private string m_endPointName; private IPEndPoint m_endPoint; private ISynchronizeInvoke m_synchronizingObject; public PeerEndPoint() { } public PeerEndPoint(IPEndPoint endPoint):this(endPoint, null) { } public PeerEndPoint(IPEndPoint endPoint, string endPointName) { if (endPoint == null){ throw new ArgumentNullException("endPoint"); } // // Validate that this is an IPv6 address // if ((m_endPoint != null) && (m_endPoint.AddressFamily != AddressFamily.InterNetworkV6)){ Logging.P2PTraceSource.TraceEvent(TraceEventType.Error, 0, "PeerEndPoint Endpoint set parameter is not IPv6."); throw new ArgumentException("endPoint", SR.GetString(SR.Collab_EndPointNotIPv6Error)); } m_endPoint = endPoint; m_endPointName = endPointName; } /// /// Constructor to enable serialization /// protected PeerEndPoint(SerializationInfo serializationInfo, StreamingContext streamingContext) { m_endPointName = serializationInfo.GetString("_EndPointName"); m_endPoint = (IPEndPoint)serializationInfo.GetValue("_EndPoint", typeof(IPEndPoint)); } public string Name { get { return m_endPointName; } set { m_endPointName = value; } } public IPEndPoint EndPoint { get { return m_endPoint; } set { // // Validate that this is an IPv6 address // if ((m_endPoint != null) && (m_endPoint.AddressFamily != AddressFamily.InterNetworkV6)){ Logging.P2PTraceSource.TraceEvent(TraceEventType.Error, 0, "PeerEndPoint Endpoint set parameter is not IPv6."); throw new PeerToPeerException(SR.GetString(SR.Collab_EndPointNotIPv6Error)); } m_endPoint = value; } } ////// Gets and set the object used to marshall event handlers calls for stand alone /// events /// [Browsable(false), DefaultValue(null), Description(SR.SynchronizingObject)] public ISynchronizeInvoke SynchronizingObject { get { if (m_Disposed) throw new ObjectDisposedException(this.GetType().FullName); return m_synchronizingObject; } set { if (m_Disposed) throw new ObjectDisposedException(this.GetType().FullName); m_synchronizingObject = value; } } private event EventHandlerm_nameChanged; public event EventHandler NameChanged { // // [System.Security.SecurityCritical] add{ if (m_Disposed) throw new ObjectDisposedException(this.GetType().FullName); CollaborationHelperFunctions.Initialize(); PeerCollaborationPermission.UnrestrictedPeerCollaborationPermission.Demand(); AddNameChanged(value); } //// // // [System.Security.SecurityCritical] remove{ if (m_Disposed) throw new ObjectDisposedException(this.GetType().FullName); CollaborationHelperFunctions.Initialize(); PeerCollaborationPermission.UnrestrictedPeerCollaborationPermission.Demand(); RemoveNameChanged(value); } } #region Name changed event variables private object m_lockNameChangedEvent; private object LockNameChangedEvent { get{ if (m_lockNameChangedEvent == null){ object o = new object(); Interlocked.CompareExchange(ref m_lockNameChangedEvent, o, null); } return m_lockNameChangedEvent; } } private RegisteredWaitHandle m_regNameChangedWaitHandle; private AutoResetEvent m_nameChangedEvent; private SafeCollabEvent m_safeNameChangedEvent; #endregion //// // // [System.Security.SecurityCritical] private void AddNameChanged(EventHandler// // // // // callback) { Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "Entering AddNameChanged()."); // // Register a wait handle if one has not been registered already // lock (LockNameChangedEvent){ if (m_nameChanged == null){ m_nameChangedEvent = new AutoResetEvent(false); // // Register callback with a wait handle // m_regNameChangedWaitHandle = ThreadPool.RegisterWaitForSingleObject(m_nameChangedEvent, //Event that triggers the callback new WaitOrTimerCallback(NameChangedCallback), //callback to be called null, //state to be passed -1, //Timeout - aplicable only for timers false //call us everytime the event is set ); PEER_COLLAB_EVENT_REGISTRATION pcer = new PEER_COLLAB_EVENT_REGISTRATION(); pcer.eventType = PeerCollabEventType.EndPointChanged; pcer.pInstance = IntPtr.Zero; // // Register event with collab // int errorCode = UnsafeCollabNativeMethods.PeerCollabRegisterEvent( m_nameChangedEvent.SafeWaitHandle, 1, ref pcer, out m_safeNameChangedEvent); if (errorCode != 0){ Logging.P2PTraceSource.TraceEvent(TraceEventType.Error, 0, "PeerCollabRegisterEvent returned with errorcode {0}", errorCode); throw PeerToPeerException.CreateFromHr(SR.GetString(SR.Collab_NameChangedRegFailed), errorCode); } } m_nameChanged += callback; } Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "AddNameChanged() successful."); } // // [System.Security.SecurityCritical] private void RemoveNameChanged(EventHandler// // callback) { Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "RemoveNameChanged() called."); lock (LockNameChangedEvent){ m_nameChanged -= callback; if (m_nameChanged == null){ CollaborationHelperFunctions.CleanEventVars(ref m_regNameChangedWaitHandle, ref m_safeNameChangedEvent, ref m_nameChangedEvent); Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "Clean NameChanged variables successful."); } } Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "RemoveNameChanged() successful."); } // // [System.Security.SecurityCritical] private void NameChangedCallback(object state, bool timedOut) { SafeCollabData eventData = null; int errorCode = 0; Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "NameChangedCallback() called."); if (m_Disposed) return; while (true){ NameChangedEventArgs nameChangedArgs = null; // // Get the event data for the fired event // try{ lock (LockNameChangedEvent) { if (m_safeNameChangedEvent.IsInvalid) return; errorCode = UnsafeCollabNativeMethods.PeerCollabGetEventData(m_safeNameChangedEvent, out eventData); } if (errorCode == UnsafeCollabReturnCodes.PEER_S_NO_EVENT_DATA) break; else if (errorCode != 0){ Logging.P2PTraceSource.TraceEvent(TraceEventType.Error, 0, "PeerCollabGetEventData returned with errorcode {0}", errorCode); throw PeerToPeerException.CreateFromHr(SR.GetString(SR.Collab_GetNameChangedDataFailed), errorCode); } PEER_COLLAB_EVENT_DATA ped = (PEER_COLLAB_EVENT_DATA)Marshal.PtrToStructure(eventData.DangerousGetHandle(), typeof(PEER_COLLAB_EVENT_DATA)); if (ped.eventType == PeerCollabEventType.EndPointChanged){ PEER_EVENT_ENDPOINT_CHANGED_DATA epData = ped.endpointChangedData; PeerEndPoint peerEndPoint = null; if (epData.pEndPoint != IntPtr.Zero){ PEER_ENDPOINT pe = (PEER_ENDPOINT)Marshal.PtrToStructure(epData.pEndPoint, typeof(PEER_ENDPOINT)); peerEndPoint = CollaborationHelperFunctions.ConvertPEER_ENDPOINTToPeerEndPoint(pe); } if ((peerEndPoint != null) && Equals(peerEndPoint)){ PeerContact peerContact = null; if (epData.pContact != IntPtr.Zero){ PEER_CONTACT pc = (PEER_CONTACT)Marshal.PtrToStructure(epData.pContact, typeof(PEER_CONTACT)); peerContact = CollaborationHelperFunctions.ConvertPEER_CONTACTToPeerContact(pc); } nameChangedArgs = new NameChangedEventArgs(peerEndPoint, peerContact, peerEndPoint.Name); } } } finally{ if (eventData != null) eventData.Dispose(); } // // Fire the callback with the marshalled event args data // if (nameChangedArgs != null){ OnNameChanged(nameChangedArgs); // // Change the name with the new name // Name = nameChangedArgs.PeerEndPoint.Name; } } Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "Leaving NameChangedCallback()."); } protected void OnNameChanged(NameChangedEventArgs nameChangedArgs) { EventHandler// // // // // // // // // // handlerCopy = m_nameChanged; if (handlerCopy != null){ if (SynchronizingObject != null && SynchronizingObject.InvokeRequired) SynchronizingObject.BeginInvoke(handlerCopy, new object[] { this, nameChangedArgs }); else handlerCopy(this, nameChangedArgs); Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "Fired the name changed event callback."); } } public bool Equals(PeerEndPoint other) { if (m_Disposed) throw new ObjectDisposedException(this.GetType().FullName); // // Equality means same ipendpoints // if (other != null){ return other.EndPoint.Equals(EndPoint); } return false; } public override bool Equals(object obj) { PeerEndPoint comparandPeerEndPoint = obj as PeerEndPoint; if (comparandPeerEndPoint != null){ return comparandPeerEndPoint.EndPoint.Equals(EndPoint); } return false; } public new static bool Equals(object objA, object objB) { PeerEndPoint comparandPeerEndPoint1 = objA as PeerEndPoint; PeerEndPoint comparandPeerEndPoint2 = objB as PeerEndPoint; if ((comparandPeerEndPoint1 != null) && (comparandPeerEndPoint2 != null)){ return comparandPeerEndPoint1.EndPoint.Equals(comparandPeerEndPoint2.EndPoint); } return false; } public override int GetHashCode() { if (m_Disposed) throw new ObjectDisposedException(this.GetType().FullName); return EndPoint.GetHashCode(); } public override string ToString() { if (m_Disposed) throw new ObjectDisposedException(this.GetType().FullName); return m_endPointName; } private bool m_Disposed; // // [System.Security.SecurityCritical] public void Dispose() { Dispose(true); GC.SuppressFinalize(this); } //// // [System.Security.SecurityCritical] protected virtual void Dispose(bool disposing) { if (!m_Disposed){ CollaborationHelperFunctions.CleanEventVars(ref m_regNameChangedWaitHandle, ref m_safeNameChangedEvent, ref m_nameChangedEvent); Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "Clean NameChanged variables successful."); } m_Disposed = true; } //// // // [System.Security.SecurityCritical] [SecurityPermission(SecurityAction.LinkDemand, Flags = SecurityPermissionFlag.SerializationFormatter, SerializationFormatter = true)] void ISerializable.GetObjectData(SerializationInfo info, StreamingContext context) { GetObjectData(info, context); } ///// /// This is made virtual so that derived types can be implemented correctly /// [SecurityPermission(SecurityAction.LinkDemand, SerializationFormatter = true)] protected virtual void GetObjectData(SerializationInfo info, StreamingContext context) { info.AddValue("_EndPointName", m_endPointName); info.AddValue("_EndPoint", m_endPoint); } internal void TracePeerEndPoint() { Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "Contents of the PeerEndPoint"); Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "\tEndPoint: {0}", (EndPoint != null? EndPoint.ToString(): null)); Logging.P2PTraceSource.TraceEvent(TraceEventType.Information, 0, "\tDescription: {0}", Name); } } ////// Represents a collection of PeerEndPoints /// [Serializable] public class PeerEndPointCollection : Collection, IEquatable { internal PeerEndPointCollection() { } protected override void SetItem(int index, PeerEndPoint item) { // // Null peerendpoints not allowed // if (item == null){ throw new ArgumentNullException("item"); } base.SetItem(index, item); } protected override void InsertItem(int index, PeerEndPoint item) { // // Null peerendpoints not allowed // if (item == null){ throw new ArgumentNullException("item"); } base.InsertItem(index, item); } public override string ToString() { bool first = true; StringBuilder builder = new StringBuilder(); foreach (PeerEndPoint peerEndPoint in this){ if (!first){ builder.Append(", "); } else{ first = false; } builder.Append(peerEndPoint.ToString()); } return builder.ToString(); } public bool Equals(PeerEndPointCollection other) { bool equal = false; if (other != null){ foreach (PeerEndPoint peerEndPoint1 in other) foreach (PeerEndPoint peerEndPoint2 in this) if (!peerEndPoint1.Equals(peerEndPoint2)){ return equal; } equal = true; } return equal; } } } // 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
- shaperfactoryquerycachekey.cs
- BatchParser.cs
- DiagnosticTraceSchemas.cs
- ProtectedProviderSettings.cs
- NCryptSafeHandles.cs
- UIElementParaClient.cs
- ThicknessAnimationBase.cs
- KeyInstance.cs
- TypeListConverter.cs
- FormViewInsertedEventArgs.cs
- Tool.cs
- DbConnectionStringBuilder.cs
- CachedPathData.cs
- BamlTreeMap.cs
- HealthMonitoringSectionHelper.cs
- RIPEMD160.cs
- HostUtils.cs
- DriveNotFoundException.cs
- ClientProxyGenerator.cs
- MarkupCompiler.cs
- InfoCardSymmetricAlgorithm.cs
- CultureInfoConverter.cs
- DeploymentSection.cs
- DocComment.cs
- EventEntry.cs
- XmlSchemaSimpleContent.cs
- XamlRtfConverter.cs
- PointCollectionValueSerializer.cs
- ConvertEvent.cs
- LayoutEvent.cs
- MsmqOutputChannel.cs
- TemplateAction.cs
- TreeNodeCollection.cs
- EmptyCollection.cs
- WorkerRequest.cs
- XmlDictionaryReader.cs
- CloudCollection.cs
- CommandBinding.cs
- MarkupCompiler.cs
- InternalDispatchObject.cs
- TypeForwardedToAttribute.cs
- FrameworkContentElement.cs
- ParseHttpDate.cs
- SimpleExpression.cs
- HtmlElementEventArgs.cs
- WindowsGraphicsWrapper.cs
- DesignerSerializationVisibilityAttribute.cs
- GetPolicyDetailsRequest.cs
- PropertyEntry.cs
- COM2IManagedPerPropertyBrowsingHandler.cs
- DispatcherProcessingDisabled.cs
- SubstitutionList.cs
- Part.cs
- MessageBox.cs
- EventMappingSettingsCollection.cs
- XmlSchemaType.cs
- DiscoveryDocument.cs
- WindowManager.cs
- Rfc2898DeriveBytes.cs
- Trace.cs
- PropertyConverter.cs
- DisplayInformation.cs
- xsdvalidator.cs
- ObjectSet.cs
- XmlSchemaCollection.cs
- TdsRecordBufferSetter.cs
- DbConnectionPoolIdentity.cs
- SolidBrush.cs
- ProtocolViolationException.cs
- QilDataSource.cs
- WorkflowMarkupSerializationManager.cs
- DataTable.cs
- InstanceLockQueryResult.cs
- TypefaceMetricsCache.cs
- TextElementEditingBehaviorAttribute.cs
- DocumentViewerAutomationPeer.cs
- RewritingProcessor.cs
- ProxyWebPart.cs
- ExceptionValidationRule.cs
- UnsafeNativeMethods.cs
- EditableRegion.cs
- BorderGapMaskConverter.cs
- QueryableFilterRepeater.cs
- TargetInvocationException.cs
- HtmlTernaryTree.cs
- Latin1Encoding.cs
- followingsibling.cs
- AQNBuilder.cs
- LinkGrep.cs
- KerberosRequestorSecurityToken.cs
- SqlClientWrapperSmiStream.cs
- EntityDataSourceDesignerHelper.cs
- OracleEncoding.cs
- SettingsAttributes.cs
- AdornerLayer.cs
- DataGridViewRow.cs
- BinaryReader.cs
- CustomAttributeSerializer.cs
- CompilerGlobalScopeAttribute.cs
- Exceptions.cs