Home
last modified time | relevance | path

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 DPeerMaintainer.cs60 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 DPeerConnector.cs27 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 DPeerFlooder.cs21 …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 DPeerNodeImplementation.cs67 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 …]