| /dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/storage/ |
| H A D | BlockManagerReplicationSuite.scala | 118 assert(master.getPeers(stores(0).blockManagerId).toSet ===
120 assert(master.getPeers(stores(1).blockManagerId).toSet ===
122 assert(master.getPeers(stores(2).blockManagerId).toSet ===
127 assert(master.getPeers(stores(0).blockManagerId).forall(!_.isDriver))
128 assert(master.getPeers(stores(1).blockManagerId).forall(!_.isDriver))
133 assert(master.getPeers(stores(0).blockManagerId).toSet ===
135 assert(master.getPeers(stores(1).blockManagerId).toSet ===
137 assert(master.getPeers(stores(2).blockManagerId).toSet ===
139 assert(master.getPeers(newStore.blockManagerId).toSet === storeIds)
149 assert(master.getPeers(stores(0).blockManagerId).isEmpty)
[all …]
|
| /dports/net-p2p/vuze/vuze-5.7.4.0_2/org/gudy/azureus2/pluginsimpl/local/download/ |
| H A D | DownloadAnnounceResultImpl.java | 95 return( response==null||response.getPeers()==null?0:response.getPeers().length ); in getReportedPeerCount()
137 getPeers() in getPeers() method in DownloadAnnounceResultImpl
144 return( response.getPeers()); in getPeers()
|
| /dports/net-p2p/vuze/vuze-5.7.4.0_2/org/gudy/azureus2/plugins/peers/ |
| H A D | PeerManager.java | 95 getPeers(); in getPeers() method
104 getPeers( in getPeers() method
|
| /dports/www/aria2/aria2-1.36.0/test/ |
| H A D | DHTPeerAnnounceEntryTest.cc | 95 entry.getPeers(peers); in testGetPeers()
104 entry.getPeers(peers); in testGetPeers()
|
| /dports/www/aria2/aria2-1.36.0/src/ |
| H A D | DHTPeerAnnounceStorage.cc | 101 void DHTPeerAnnounceStorage::getPeers(std::vector<std::shared_ptr<Peer>>& peers, in getPeers() function in aria2::DHTPeerAnnounceStorage
108 (*i)->getPeers(peers); in getPeers()
|
| H A D | DHTPeerAnnounceEntry.h | 85 void getPeers(std::vector<std::shared_ptr<Peer>>& peers) const;
|
| /dports/games/supertuxkart/SuperTuxKart-1.2-src/src/network/ |
| H A D | network_console.cpp | 125 auto peers = host->getPeers(); in mainLoop()
158 auto peers = host->getPeers(); in mainLoop()
|
| /dports/net-p2p/vuze/vuze-5.7.4.0_2/org/gudy/azureus2/pluginsimpl/local/peers/ |
| H A D | PeerManagerImpl.java | 381 getPeers() in getPeers() method in PeerManagerImpl
383 List l = manager.getPeers(); in getPeers()
399 getPeers( in getPeers() method in PeerManagerImpl
402 List l = manager.getPeers( address ); in getPeers()
730 List<PEPeer> peers = manager.getPeers( ip ); in getReservedFor()
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/server/embedded/ |
| H A D | ZookeeperServerClusterTest.java | 110 … if (status.isLeader() && !status.isStandaloneMode() && status.getPeers().size() == 3) { in testStart()
118 assertEquals(3, status.getPeers().size()); in testStart()
|
| H A D | ZookeeperServerClusterMutualAuthTest.java | 129 … if (status.isLeader() && !status.isStandaloneMode() && status.getPeers().size() == 3) { in testStart()
137 assertEquals(3, status.getPeers().size()); in testStart()
|
| /dports/net-p2p/vuze/vuze-5.7.4.0_2/org/gudy/azureus2/plugins/download/ |
| H A D | DownloadAnnounceResult.java | 118 getPeers(); in getPeers() method
|
| /dports/net-p2p/vuze/vuze-5.7.4.0_2/org/gudy/azureus2/core3/peer/ |
| H A D | PEPeerManager.java | 215 getPeers(); in getPeers() method
218 getPeers( in getPeers() method
|
| /dports/net-p2p/libktorrent/libktorrent-21.12.3/src/torrent/ |
| H A D | advancedchokealgorithm.cpp | 89 QList<Peer::Ptr> ppl = pman.getPeers(); in doChokingLeechingState()
133 QList<Peer::Ptr> ppl = pman.getPeers(); in doChokingSeedingState()
|
| /dports/net-p2p/vuze/vuze-5.7.4.0_2/com/aelitis/azureus/core/tracker/ |
| H A D | TrackerPeerSourceAdapter.java | 66 getPeers() in getPeers() method in TrackerPeerSourceAdapter
|
| H A D | TrackerPeerSource.java | 66 getPeers(); in getPeers() method
|
| /dports/net-p2p/vuze/vuze-5.7.4.0_2/org/gudy/azureus2/core3/tracker/client/ |
| H A D | TRTrackerAnnouncerResponse.java | 76 getPeers(); in getPeers() method
|
| H A D | TRTrackerScraperResponse.java | 53 getPeers(); in getPeers() method
|
| /dports/net-p2p/vuze/vuze-5.7.4.0_2/org/gudy/azureus2/pluginsimpl/local/tracker/ |
| H A D | TrackerTorrentImpl.java | 128 getPeers() in getPeers() method in TrackerTorrentImpl
130 TRHostPeer[] peers = host_torrent.getPeers(); in getPeers()
|
| /dports/net-p2p/vuze/vuze-5.7.4.0_2/org/gudy/azureus2/core3/tracker/host/impl/ |
| H A D | TRHostTorrentPublishImpl.java | 176 getPeers() in getPeers() method in TRHostTorrentPublishImpl
240 peer_count = resp.getPeers(); in updateStats()
|
| /dports/security/lego/lego-4.5.3/vendor/github.com/golang/groupcache/ |
| H A D | peers.go | 73 func getPeers(groupName string) PeerPicker { func
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/golang/groupcache/ |
| H A D | peers.go | 73 func getPeers(groupName string) PeerPicker { func
|
| /dports/www/gohugo/hugo-0.91.2/vendor/github.com/golang/groupcache/ |
| H A D | peers.go | 73 func getPeers(groupName string) PeerPicker { func
|
| /dports/sysutils/chaoskube/chaoskube-0.22.0/vendor/github.com/golang/groupcache/ |
| H A D | peers.go | 73 func getPeers(groupName string) PeerPicker { func
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/golang/groupcache/ |
| H A D | peers.go | 73 func getPeers(groupName string) PeerPicker { func
|
| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/golang/groupcache/ |
| H A D | peers.go | 76 func getPeers(groupName string) PeerPicker { func
|