PeerNodeAddress

System\ServiceModel\Channels\ConnectAlgorithms.cs (10)

24Dictionary<Uri, PeerNodeAddress> nodeAddresses = new Dictionary<Uri, PeerNodeAddress>(); 26Dictionary<Uri, PeerNodeAddress> pendingConnectedNeighbor = new Dictionary<Uri, PeerNodeAddress>(); 95PeerNodeAddress epr = null; 189pendingConnectedNeighbor.Remove(GetEndpointUri((PeerNodeAddress)iar.AsyncState)); 245static Uri GetEndpointUri(PeerNodeAddress address) 265public void UpdateEndpointsCollection(ICollection<PeerNodeAddress> src) 271foreach (PeerNodeAddress address in src) 293void UpdateEndpointsCollection(PeerNodeAddress address)

System\ServiceModel\Channels\IPeerNeighbor.cs (1)

13PeerNodeAddress ListenAddress { get; set; } // Neighbor's listen address

System\ServiceModel\Channels\PeerConnector.cs (1)

565PeerNodeAddress listenAddress = this.config.GetListenAddress(true);

System\ServiceModel\Channels\PeerHelpers.cs (6)

58PeerNodeAddress listenAddress; // EPR + IP addresses 264public PeerNodeAddress GetListenAddress(bool maskScopeId) 266PeerNodeAddress localAddress = this.listenAddress; 270public void SetListenAddress(PeerNodeAddress address) 549public static bool ValidNodeAddress(PeerNodeAddress address) 560public static bool ValidReferralNodeAddress(PeerNodeAddress address)

System\ServiceModel\Channels\PeerMaintainer.cs (19)

34IAsyncResult BeginOpenNeighbor(PeerNodeAddress to, TimeSpan timeout, AsyncCallback callback, object asyncState); 39IPeerNeighbor FindDuplicateNeighbor(PeerNodeAddress address); 40PeerNodeAddress GetListenAddress(); 49void UpdateEndpointsCollection(ICollection<PeerNodeAddress> src); 200ReadOnlyCollection<PeerNodeAddress> addresses = ResolveNewAddresses(timeoutHelper.RemainingTime(), false); 311ReadOnlyCollection<PeerNodeAddress> addresses = ResolveNewAddresses(timeoutHelper.RemainingTime(), true); 378ReadOnlyCollection<PeerNodeAddress> addresses = ResolveNewAddresses(timeoutHelper.RemainingTime(), true); 516ReadOnlyCollection<PeerNodeAddress> ResolveNewAddresses(TimeSpan timeLeft, bool retryResolve) 519Dictionary<string, PeerNodeAddress> alreadySeen = new Dictionary<string, PeerNodeAddress>(); 520List<PeerNodeAddress> reply = new List<PeerNodeAddress>(); 523PeerNodeAddress lclNodeAddress = config.GetListenAddress(true); 538ReadOnlyCollection<PeerNodeAddress> addresses; 558foreach (PeerNodeAddress address in addresses) 571return (new ReadOnlyCollection<PeerNodeAddress>(reply)); 584IPeerNeighbor IPeerMaintainer.FindDuplicateNeighbor(PeerNodeAddress address) 589PeerNodeAddress IPeerMaintainer.GetListenAddress() 611IAsyncResult IPeerMaintainer.BeginOpenNeighbor(PeerNodeAddress address, TimeSpan timeout, AsyncCallback callback, object asyncState)

System\ServiceModel\Channels\PeerNeighborManager.cs (13)

134public IAsyncResult BeginOpenNeighbor(PeerNodeAddress remoteAddress, TimeSpan timeout, AsyncCallback callback, object asyncState) 144PeerNodeAddress address = new PeerNodeAddress(remoteAddress.EndpointAddress, sortedAddresses); 148internal IAsyncResult BeginOpenNeighborInternal(PeerNodeAddress remoteAddress, TimeSpan timeout, AsyncCallback callback, object asyncState) 333public IPeerNeighbor FindDuplicateNeighbor(PeerNodeAddress address) 339public IPeerNeighbor FindDuplicateNeighbor(PeerNodeAddress address, IPeerNeighbor skipNeighbor) 775PeerNodeAddress listenAddress; // The address that the remote endpoint is listening on 869public PeerNodeAddress ListenAddress 874PeerNodeAddress address = this.listenAddress; 1044public IAsyncResult BeginOpen(PeerNodeAddress remoteAddress, Binding binding, 1377PeerNodeAddress listenAddr = null; 1409PeerNodeAddress remoteAddress; 1416public OpenAsyncResult(PeerNeighbor neighbor, PeerNodeAddress remoteAddress, Binding binding, 1615public NeighborOpenAsyncResult(PeerNeighbor neighbor, PeerNodeAddress remoteAddress, Binding binding,

System\ServiceModel\Channels\PeerNodeImplementation.cs (3)

983PeerNodeAddress nodeAddress = null; 1056void RegisterAddress(string lclMeshId, PeerNodeAddress nodeAddress, TimeSpan timeout) 1377PeerNodeAddress nodeAddress = new PeerNodeAddress(service.GetListenAddress(), ipHelper.GetLocalAddresses());

System\ServiceModel\Channels\PeerSecurityHelpers.cs (1)

900PeerNodeAddress remoteAddress = neighbor.ListenAddress;

System\ServiceModel\Channels\PeerService.cs (1)

165PeerNodeAddress listenAddr = null;

System\ServiceModel\Channels\PeerServiceMessageContracts.cs (7)

23public PeerNodeAddress address; 26public ConnectInfoDC(ulong nodeId, PeerNodeAddress address) 41public ConnectInfo(ulong nodeId, PeerNodeAddress address) 46public PeerNodeAddress Address 213PeerNodeAddress address; // Referral address 215public Referral(ulong nodeId, PeerNodeAddress address) 221public PeerNodeAddress Address

System\ServiceModel\Channels\PnrpPeerResolver.cs (14)

227public override object Register(string meshId, PeerNodeAddress nodeAddress, TimeSpan timeout) 350PnrpPeerResolverTraceRecord record = new PnrpPeerResolverTraceRecord(meshId, new List<PeerNodeAddress>()); 357public override void Update(object registrationId, PeerNodeAddress updatedNodeAddress, TimeSpan timeout) 368PeerNodeAddress PeerNodeAddressFromPnrpRegistration(PnrpRegistration input) 371PeerNodeAddress result = null; 432void PeerNodeAddressToPnrpRegistrations(string meshName, Dictionary<uint, string> LinkCloudNames, Dictionary<uint, string> SiteCloudNames, PeerNodeAddress input, out PnrpRegistration[] linkRegs, out PnrpRegistration[] siteRegs, out PnrpRegistration global) 609void MergeResults(List<PeerNodeAddress> nodeAddressList, List<PnrpRegistration> globalRegistrations, List<PnrpRegistration> linkRegistrations, List<PnrpRegistration> siteRegistrations) 615PeerNodeAddress result; 625public override ReadOnlyCollection<PeerNodeAddress> Resolve(string meshId, int maxAddresses, TimeSpan timeout) 688return new ReadOnlyCollection<PeerNodeAddress>(new List<PeerNodeAddress>()); 705List<PeerNodeAddress> nodeAddressList = new List<PeerNodeAddress>(); 716return new ReadOnlyCollection<PeerNodeAddress>(nodeAddressList);

System\ServiceModel\Diagnostics\PeerNodeTraceRecord.cs (9)

21PeerNodeAddress address; 34public PeerNodeTraceRecord(ulong id, string meshId, PeerNodeAddress address) 72PeerNodeAddress listenAddress; 82PeerNodeAddress listenAddress, IPAddress connectIPAddress, int hashCode, bool initiator, string state, 152PeerNodeAddress listenAddress, IPAddress connectIPAddress, int hashCode, bool initiator, 173List<PeerNodeAddress> addresses; 175public PnrpPeerResolverTraceRecord(string meshId, List<PeerNodeAddress> addresses) 195foreach (PeerNodeAddress nodeAddress in addresses) 305public PeerFlooderTraceRecord(string meshId, PeerNodeAddress fromAddress, Exception e)

System\ServiceModel\PeerResolver.cs (3)

14public abstract object Register(string meshId, PeerNodeAddress nodeAddress, TimeSpan timeout); 15public abstract ReadOnlyCollection<PeerNodeAddress> Resolve(string meshId, int maxAddresses, TimeSpan timeout); 17public abstract void Update(object registrationId, PeerNodeAddress updatedNodeAddress, TimeSpan timeout);

System\ServiceModel\PeerResolvers\CustomPeerResolverService.cs (7)

29PeerNodeAddress address; 33public RegistrationEntry(Guid clientId, Guid registrationId, string meshId, DateTime expires, PeerNodeAddress address) 67public PeerNodeAddress Address 318public virtual RegisterResponseInfo Register(Guid clientId, string meshId, PeerNodeAddress address) 446List<PeerNodeAddress> results = new List<PeerNodeAddress>(); 448PeerNodeAddress address;

System\ServiceModel\PeerResolvers\PeerDefaultCustomResolverClient.cs (9)

28PeerNodeAddress nodeAddress; 102public override object Register(string meshId, PeerNodeAddress nodeAddress, TimeSpan timeout) 249public override void Update(object registrationId, PeerNodeAddress updatedNodeAddress, TimeSpan timeout) 295public override ReadOnlyCollection<PeerNodeAddress> Resolve(string meshId, int maxAddresses, TimeSpan timeout) 298IList<PeerNodeAddress> addresses = null; 299List<PeerNodeAddress> output_addresses = new List<PeerNodeAddress>(); 336foreach (PeerNodeAddress nodeaddr in addresses) 366return new ReadOnlyCollection<PeerNodeAddress>(output_addresses);

System\ServiceModel\PeerResolvers\RegisterInfo.cs (4)

23public PeerNodeAddress NodeAddress; 27public RegisterInfoDC(Guid client, string meshId, PeerNodeAddress address) 35public RegisterInfo(Guid client, string meshId, PeerNodeAddress address) 54public PeerNodeAddress NodeAddress

System\ServiceModel\PeerResolvers\ResolveResponseInfo.cs (5)

18public IList<PeerNodeAddress> Addresses; 20public ResolveResponseInfoDC(PeerNodeAddress[] addresses) 22this.Addresses = (IList<PeerNodeAddress>)addresses; 28public ResolveResponseInfo(PeerNodeAddress[] addresses) 33public IList<PeerNodeAddress> Addresses

System\ServiceModel\PeerResolvers\UpdateInfo.cs (4)

23public PeerNodeAddress NodeAddress; 28public UpdateInfoDC(Guid registrationId, Guid client, string meshId, PeerNodeAddress address) 37public UpdateInfo(Guid registrationId, Guid client, string meshId, PeerNodeAddress address) 58public PeerNodeAddress NodeAddress