1 implementation of IPeerNeighbor
System.ServiceModel (1)
System\ServiceModel\Channels\PeerNeighborManager.cs (1)
753class PeerNeighbor : IPeerNeighbor, IInputSessionShutdown
158 references to IPeerNeighbor
System.ServiceModel (158)
System\ServiceModel\Channels\ConnectAlgorithms.cs (5)
180IPeerNeighbor neighbor = null; 257IPeerNeighbor leastUseful = maintainer.GetLeastUsefulNeighbor(); 307void OnNeighborClosed(IPeerNeighbor neighbor) 331void OnNeighborConnected(IPeerNeighbor neighbor) 366void OnReferralsAdded(IList<Referral> referrals, IPeerNeighbor neighbor)
System\ServiceModel\Channels\IPeerNeighbor.cs (1)
10interface IPeerNeighbor : IExtensibleObject<IPeerNeighbor>
System\ServiceModel\Channels\PeerConnector.cs (25)
38Dictionary<IPeerNeighbor, IOThreadTimer> timerTable; 54this.timerTable = new Dictionary<IPeerNeighbor, IOThreadTimer>(); 117bool AddTimer(IPeerNeighbor neighbor) 136void SendMessageToNeighbor(IPeerNeighbor neighbor, Message message, PeerMessageHelpers.CleanupCallback cleanupCallback) 176void CleanupOnConnectFailure(IPeerNeighbor neighbor, PeerCloseReason reason, 189Dictionary<IPeerNeighbor, IOThreadTimer> table; 216void CompleteTerminateMessageProcessing(IPeerNeighbor neighbor, 233void OnConnectFailure(IPeerNeighbor neighbor, PeerCloseReason reason, 241CleanupOnConnectFailure((IPeerNeighbor)asyncState, PeerCloseReason.ConnectTimedOut, null); 245public void OnNeighborClosed(IPeerNeighbor neighbor) 253public void OnNeighborClosing(IPeerNeighbor neighbor, PeerCloseReason closeReason) 261public void OnNeighborAuthenticated(IPeerNeighbor neighbor) 319public void Connect(IPeerNeighbor neighbor, ConnectInfo connectInfo) 358IPeerNeighbor neighborToClose; 401public void Disconnect(IPeerNeighbor neighbor, DisconnectInfo disconnectInfo) 430public void Refuse(IPeerNeighbor neighbor, RefuseInfo refuseInfo) 462public void Welcome(IPeerNeighbor neighbor, WelcomeInfo welcomeInfo) 486IPeerNeighbor neighborToClose; 530bool RemoveTimer(IPeerNeighbor neighbor) 557void SendConnect(IPeerNeighbor neighbor) 576void SendTerminatingMessage(IPeerNeighbor neighbor, string action, PeerCloseReason closeReason) 611void SendWelcome(IPeerNeighbor neighbor) 627void ValidateNeighbor(IPeerNeighbor neighbor, ulong neighborNodeId, 628out IPeerNeighbor neighborToClose, out PeerCloseReason closeReason, out string action) 661IPeerNeighbor duplicateNeighbor =
System\ServiceModel\Channels\PeerFlooder.cs (22)
41protected List<IPeerNeighbor> neighbors; 57this.neighbors = new List<IPeerNeighbor>(); 64void PruneNeighborCallback(IPeerNeighbor peer) 103IPeerNeighbor peer = this.neighborManager.SlowestNeighbor(); 160protected virtual IAsyncResult BeginFloodReceivedMessage(IPeerNeighbor sender, MessageBuffer messageBuffer, 195protected IAsyncResult BeginSendHelper(IPeerNeighbor neighbor, TimeSpan timeout, Message message, FloodAsyncResult fresult) 242IPeerNeighbor neighbor = this.neighborManager.SlowestNeighbor(); 250int index, MessageHeader hopHeader, IPeerNeighbor except, 256List<IPeerNeighbor> neighbors = this.Neighbors; 258foreach (IPeerNeighbor neighbor in neighbors) 297public virtual void OnNeighborConnected(IPeerNeighbor neighbor) 302public virtual void OnNeighborClosed(IPeerNeighbor neighbor) 307public abstract void ProcessLinkUtility(IPeerNeighbor neighbor, TLinkContract utilityInfo); 347public virtual IAsyncResult OnFloodedMessage(IPeerNeighbor neighbor, TFloodContract floodInfo, AsyncCallback callback, object state) 468protected List<IPeerNeighbor> Neighbors 474static internal Exception CloseNeighborIfKnownException(PeerNeighborManager neighborManager, Exception exception, IPeerNeighbor peer) 619public override IAsyncResult OnFloodedMessage(IPeerNeighbor neighbor, Message floodInfo, AsyncCallback callback, object state) 630public override void ProcessLinkUtility(IPeerNeighbor neighbor, UtilityInfo utilityInfo) 829Dictionary<IAsyncResult, IPeerNeighbor> results = new Dictionary<IAsyncResult, IPeerNeighbor>(); 852public void AddResult(IAsyncResult result, IPeerNeighbor neighbor) 949IPeerNeighbor neighbor = null;
System\ServiceModel\Channels\PeerHelpers.cs (1)
315public delegate void CleanupCallback(IPeerNeighbor neighbor, PeerCloseReason reason, Exception exception);
System\ServiceModel\Channels\PeerMaintainer.cs (17)
18delegate void NeighborClosedHandler(IPeerNeighbor neighbor); 19delegate void NeighborConnectedHandler(IPeerNeighbor neighbor); 21delegate void ReferralsAddedHandler(IList<Referral> referrals, IPeerNeighbor neighbor); 35IPeerNeighbor EndOpenNeighbor(IAsyncResult result); 37void CloseNeighbor(IPeerNeighbor neighbor, PeerCloseReason closeReason); 39IPeerNeighbor FindDuplicateNeighbor(PeerNodeAddress address); 41IPeerNeighbor GetLeastUsefulNeighbor(); 91public bool AddReferrals(IList<Referral> referrals, IPeerNeighbor neighbor) 449List<IPeerNeighbor> neighbors = this.neighborManager.GetConnectedNeighbors(); 465public virtual void OnNeighborClosed(IPeerNeighbor neighbor) 490public virtual void OnNeighborConnected(IPeerNeighbor neighbor) 579void IPeerMaintainer.CloseNeighbor(IPeerNeighbor neighbor, PeerCloseReason closeReason) 584IPeerNeighbor IPeerMaintainer.FindDuplicateNeighbor(PeerNodeAddress address) 594IPeerNeighbor IPeerMaintainer.GetLeastUsefulNeighbor() 596IPeerNeighbor leastUsefulNeighbor = null; 599foreach (IPeerNeighbor neighbor in this.neighborManager.GetConnectedNeighbors()) 625IPeerNeighbor IPeerMaintainer.EndOpenNeighbor(IAsyncResult result)
System\ServiceModel\Channels\PeerNeighborManager.cs (26)
47List<IPeerNeighbor> connectedNeighborList; 69this.connectedNeighborList = new List<IPeerNeighbor>(); 209public void CloseNeighbor(IPeerNeighbor neighbor, PeerCloseReason closeReason, 215public void CloseNeighbor(IPeerNeighbor neighbor, PeerCloseReason closeReason, 244public IPeerNeighbor EndOpenNeighbor(IAsyncResult result) 274public IPeerNeighbor FindDuplicateNeighbor(ulong nodeId) 280public IPeerNeighbor FindDuplicateNeighbor(ulong nodeId, IPeerNeighbor skipNeighbor) 304public bool PingNeighbor(IPeerNeighbor peer) 325List<IPeerNeighbor> neighbors = GetConnectedNeighbors(); 326foreach (IPeerNeighbor neighbor in neighbors) 333public IPeerNeighbor FindDuplicateNeighbor(PeerNodeAddress address) 339public IPeerNeighbor FindDuplicateNeighbor(PeerNodeAddress address, IPeerNeighbor skipNeighbor) 363public List<IPeerNeighbor> GetConnectedNeighbors() 367return new List<IPeerNeighbor>(this.connectedNeighborList); 373public IPeerNeighbor GetNeighborFromProxy(IPeerProxy proxy) 469this.connectedNeighborList.Remove((IPeerNeighbor)source); 772ExtensionCollection<IPeerNeighbor> extensions; 798this.extensions = new ExtensionCollection<IPeerNeighbor>(this, thisLock); 841public IExtensionCollection<IPeerNeighbor> Extensions 1666public static IPeerNeighbor End(IAsyncResult result) 1703public IPeerNeighbor SlowestNeighbor() 1705List<IPeerNeighbor> neighbors = this.GetConnectedNeighbors(); 1706IPeerNeighbor slowNeighbor = null; 1710foreach (IPeerNeighbor peer in neighbors)
System\ServiceModel\Channels\PeerNodeImplementation.cs (8)
1129IPeerNeighbor neighbor = (IPeerNeighbor)sender; 1158IPeerNeighbor neighbor = (IPeerNeighbor)sender; 1176IPeerNeighbor neighbor = (IPeerNeighbor)sender; 1199IPeerNeighbor n = (IPeerNeighbor)sender;
System\ServiceModel\Channels\PeerSecurityHelpers.cs (11)
681class PeerChannelAuthenticatorExtension : IExtension<IPeerNeighbor> 683IPeerNeighbor host; 717public void Attach(IPeerNeighbor host) 726static public void OnNeighborClosed(IPeerNeighbor neighbor) 733public void Detach(IPeerNeighbor host) 747IPeerNeighbor neighbor = host; 758IPeerNeighbor neighbor = host; 815IPeerNeighbor neighbor = host; 855public void ProcessRstr(IPeerNeighbor neighbor, Message message, Claim claim) 875IPeerNeighbor neighbor = null; 888void OnFailed(IPeerNeighbor neighbor)
System\ServiceModel\Channels\PeerSecurityManager.cs (4)
603IPeerNeighbor neighbor = sender as IPeerNeighbor; 628public Message ProcessRequest(IPeerNeighbor neighbor, Message request) 644void Abort(IPeerNeighbor neighbor)
System\ServiceModel\Channels\PeerService.cs (20)
19void Connect(IPeerNeighbor neighbor, ConnectInfo connectInfo); 20void Disconnect(IPeerNeighbor neighbor, DisconnectInfo disconnectInfo); 21void Refuse(IPeerNeighbor neighbor, RefuseInfo refuseInfo); 22void Welcome(IPeerNeighbor neighbor, WelcomeInfo welcomeInfo); 29IAsyncResult OnFloodedMessage(IPeerNeighbor neighbor, TFloodContract floodedInfo, AsyncCallback callback, object state); 31void ProcessLinkUtility(IPeerNeighbor neighbor, TLinkContract utilityInfo); 43public delegate IPeerNeighbor GetNeighborCallback(IPeerProxy channel); 145IPeerNeighbor GetNeighbor() 147IPeerNeighbor neighbor = (IPeerNeighbor)getNeighborCallback(OperationContext.Current.GetCallbackChannel<IPeerProxy>()); 261IPeerNeighbor neighbor = GetNeighbor(); 270IPeerNeighbor neighbor = GetNeighbor(); 279IPeerNeighbor neighbor = GetNeighbor(); 288IPeerNeighbor neighbor = GetNeighbor(); 297IPeerNeighbor neighbor = GetNeighbor(); 313IPeerNeighbor neighbor = GetNeighbor(); 322IPeerNeighbor neighbor = GetNeighbor(); 324throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ObjectDisposedException(typeof(IPeerNeighbor).ToString())); 337IPeerNeighbor neighbor = GetNeighbor(); 339throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ObjectDisposedException(typeof(IPeerNeighbor).ToString()));
System\ServiceModel\Channels\UtilityExtension.cs (18)
12class UtilityExtension : IExtension<IPeerNeighbor> 22IPeerNeighbor owner; 37public delegate void PruneNeighborCallback(IPeerNeighbor peer); 73public void Attach(IPeerNeighbor host) 79static public void OnNeighborConnected(IPeerNeighbor neighbor) 85static public void OnNeighborClosed(IPeerNeighbor neighbor) 92public void Detach(IPeerNeighbor host) 111public static void OnMessageSent(IPeerNeighbor neighbor) 126public static void OnEndSend(IPeerNeighbor neighbor, FloodAsyncResult fresult) 143IPeerNeighbor peer = owner; 151static public void ProcessLinkUtility(IPeerNeighbor neighbor, UtilityInfo umessage) 210public static uint UpdateLinkUtility(IPeerNeighbor neighbor, bool useful) 267IPeerNeighbor host = owner; 307IPeerNeighbor host = this.owner; 351Exception HandleSendException(IPeerNeighbor host, Exception e, UtilityInfo umessage) 375static internal void ReportCacheMiss(IPeerNeighbor neighbor, int missedBy) 432IPeerNeighbor peer = (IPeerNeighbor)owner;