Searched refs:neighborManager (Results 1 – 4 of 4) sorted by relevance
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.ServiceModel/System/ServiceModel/Channels/ |
H A D | PeerMaintainer.cs | 60 PeerNeighborManager neighborManager; field in System.ServiceModel.Channels.PeerMaintainerBase 78 this.neighborManager = neighborManager; in PeerMaintainerBase() 225 if (neighborManager.ConnectedNeighborCount < 1) in InitialConnection() 287 int currentlyConnected = neighborManager.ConnectedNeighborCount; in MaintainConnections() 586 return neighborManager.FindDuplicateNeighbor(address); in IPeerMaintainer.FindDuplicateNeighbor() 627 return neighborManager.EndOpenNeighbor(result); in IPeerMaintainer.EndOpenNeighbor() 632 get { return neighborManager.ConnectedNeighborCount; } 637 get { return neighborManager.NonClosingNeighborCount; } 647 neighborManager.PingNeighbors(); in PingConnections() 653 if (this.neighborManager.ConnectedNeighborCount < this.config.IdealNeighbors) in PingAndRefresh() [all …]
|
H A D | PeerConnector.cs | 27 PeerNeighborManager neighborManager; field in System.ServiceModel.Channels.PeerConnector 40 public PeerConnector(PeerNodeConfig config, PeerNeighborManager neighborManager, in PeerConnector() argument 44 Fx.Assert(neighborManager != null, "NeighborManager is expected to be non-null"); in PeerConnector() 52 this.neighborManager = neighborManager; in PeerConnector() 182 this.neighborManager.CloseNeighbor(neighbor, reason, in CleanupOnConnectFailure() 222 … this.neighborManager.CloseNeighbor(neighbor, closeReason, PeerCloseInitiator.RemoteNode); in CompleteTerminateMessageProcessing() 293 if (this.neighborManager.ConnectedNeighborCount < this.config.MaxNeighbors) in OnNeighborAuthenticated() 298 this.neighborManager.CloseNeighbor(neighbor, PeerCloseReason.NodeBusy, in OnNeighborAuthenticated() 345 if (this.neighborManager.ConnectedNeighborCount >= this.config.MaxNeighbors) in Connect() 662 this.neighborManager.FindDuplicateNeighbor(neighborNodeId, neighbor); in ValidateNeighbor() [all …]
|
H A D | PeerFlooder.cs | 21 …erFlooder(PeerNodeConfig config, PeerNeighborManager neighborManager) : base(config, neighborManag… in PeerFlooder() argument 25 PeerFlooder flooder = new PeerFlooder(config, neighborManager); in CreateFlooder() 40 protected PeerNeighborManager neighborManager; field in System.ServiceModel.Channels.PeerFlooderBase 56 this.neighborManager = neighborManager; in PeerFlooderBase() 59 this.neighbors = this.neighborManager.GetConnectedNeighbors(); in PeerFlooderBase() 85 if (null != CloseNeighborIfKnownException(neighborManager, e, peer)) in PruneNeighborCallback() 103 IPeerNeighbor peer = this.neighborManager.SlowestNeighbor(); in IFlooderForThrottle.OnThrottleReached() 242 IPeerNeighbor neighbor = this.neighborManager.SlowestNeighbor(); in KillSlowNeighbor() 299 this.neighbors = this.neighborManager.GetConnectedNeighbors(); in OnNeighborConnected() 304 this.neighbors = this.neighborManager.GetConnectedNeighbors(); in OnNeighborClosed() [all …]
|
H A D | PeerNodeImplementation.cs | 67 PeerNeighborManager neighborManager; field in System.ServiceModel.Channels.PeerNodeImplementation 135 return neighborManager.IsOnline; 245 get { return neighborManager; } 505 lclNeighborManager = neighborManager; in CloseCore() 646 neighborManager = null; in CloseCore() 1341 neighborManager = new PeerNeighborManager(ipHelper, in OpenCore() 1356 neighborManager.ProcessIncomingChannel, in OpenCore() 1357 neighborManager.GetNeighborFromProxy, in OpenCore() 1369 neighborManager.Online += new EventHandler(FireOnline); in OpenCore() 1370 neighborManager.Offline += new EventHandler(FireOffline); in OpenCore() [all …]
|