Code:
/ Dotnetfx_Vista_SP2 / Dotnetfx_Vista_SP2 / 8.0.50727.4016 / DEVDIV / depot / DevDiv / releases / Orcas / QFE / 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
- COM2PropertyDescriptor.cs
- MetafileHeaderWmf.cs
- Component.cs
- FacetEnabledSchemaElement.cs
- LicenseException.cs
- TypedTableBaseExtensions.cs
- OwnerDrawPropertyBag.cs
- ConstraintConverter.cs
- MediaContextNotificationWindow.cs
- TemplateControlBuildProvider.cs
- WsrmMessageInfo.cs
- WebBrowserHelper.cs
- XPathConvert.cs
- Int16Converter.cs
- SchemaComplexType.cs
- SqlBulkCopyColumnMapping.cs
- TemplateControlBuildProvider.cs
- FileFormatException.cs
- RedistVersionInfo.cs
- LineServicesRun.cs
- VirtualPathUtility.cs
- XmlName.cs
- HandleCollector.cs
- EdmType.cs
- exports.cs
- ActivityValidationServices.cs
- ConfigXmlCDataSection.cs
- AlphaSortedEnumConverter.cs
- WebSysDescriptionAttribute.cs
- UnmanagedBitmapWrapper.cs
- DataGridViewColumnDesigner.cs
- GlyphTypeface.cs
- ObjectStateFormatter.cs
- CheckedListBox.cs
- PropertyGridCommands.cs
- GroupBoxDesigner.cs
- uribuilder.cs
- ThumbButtonInfoCollection.cs
- ToolStripControlHost.cs
- FormViewInsertedEventArgs.cs
- AstTree.cs
- OptimizedTemplateContent.cs
- WebConfigurationManager.cs
- PageContent.cs
- StringComparer.cs
- DiffuseMaterial.cs
- ProviderManager.cs
- SizeAnimationBase.cs
- DocumentPage.cs
- EntityCommand.cs
- JsonCollectionDataContract.cs
- HttpCachePolicyElement.cs
- WindowsSolidBrush.cs
- ReflectionHelper.cs
- BitmapEffectGroup.cs
- SoapInteropTypes.cs
- DataGridViewRowConverter.cs
- ObjectDataSourceEventArgs.cs
- ConfigurationManagerHelperFactory.cs
- HostingEnvironment.cs
- ExceptionUtility.cs
- XmlTextWriter.cs
- DataException.cs
- JsonFormatReaderGenerator.cs
- ServiceThrottle.cs
- WebPartCatalogCloseVerb.cs
- PeerNameRegistration.cs
- Attributes.cs
- SafeEventLogWriteHandle.cs
- Hashtable.cs
- CopyAction.cs
- ItemDragEvent.cs
- MessageQuerySet.cs
- StreamInfo.cs
- TdsRecordBufferSetter.cs
- messageonlyhwndwrapper.cs
- TemplatedMailWebEventProvider.cs
- SQLBytesStorage.cs
- AssemblySettingAttributes.cs
- ConcurrencyMode.cs
- FastEncoder.cs
- ParamArrayAttribute.cs
- FontStretch.cs
- TreeNode.cs
- HierarchicalDataSourceControl.cs
- SelectionEditor.cs
- SocketElement.cs
- LayoutTable.cs
- SmiEventSink_Default.cs
- QilParameter.cs
- SolidColorBrush.cs
- ListManagerBindingsCollection.cs
- ComboBoxRenderer.cs
- StrongNameMembershipCondition.cs
- ListSortDescriptionCollection.cs
- CompositeClientFormatter.cs
- DataObjectCopyingEventArgs.cs
- TrustSection.cs
- FocusManager.cs
- ReflectionServiceProvider.cs