| /dports/net-p2p/vuze/vuze-5.7.4.0_2/com/aelitis/azureus/core/peermanager/uploadslots/ |
| H A D | SeedingRanker.java | 42 private PEPeerTransport getNextOptimisticPeerExec( ArrayList all_peers ) { in getNextOptimisticPeerExec() argument
44 if( all_peers.isEmpty() ) { //no connected peers in getNextOptimisticPeerExec()
49 int pos = RandomUtils.nextInt( all_peers.size() ); //pick a random peer to start in getNextOptimisticPeerExec()
51 for( int i=0; i < all_peers.size(); i++ ) { //ensure we only loop once in getNextOptimisticPeerExec()
53 PEPeerTransport peer = (PEPeerTransport)all_peers.get( pos ); //get next potential peer in getNextOptimisticPeerExec()
62 if( pos >= all_peers.size() ) { //loop 'round if necessary in getNextOptimisticPeerExec()
72 public PEPeerTransport getNextOptimisticPeer( ArrayList all_peers ) { in getNextOptimisticPeer() argument
73 PEPeerTransport picked = getNextOptimisticPeerExec( all_peers ); in getNextOptimisticPeer()
|
| H A D | DownloadingRanker.java | 42 public PEPeer getNextOptimisticPeer( ArrayList<PEPeer> all_peers ) { in getNextOptimisticPeer() argument
43 return UnchokerUtil.getNextOptimisticPeer( all_peers, true, true ); //TODO extract and optimize? in getNextOptimisticPeer()
49 public ArrayList<PEPeer> rankPeers( int max_to_unchoke, ArrayList<PEPeer> all_peers ) { in rankPeers() argument
56 for( int i=0; i < all_peers.size(); i++ ) { in rankPeers()
57 PEPeer peer = all_peers.get( i ); in rankPeers()
73 for( int i=0; i < all_peers.size(); i++ ) { in rankPeers()
74 PEPeer peer = all_peers.get( i ); in rankPeers()
|
| H A D | UploadSessionPicker.java | 198 ArrayList<PEPeer> all_peers = globalGetAllDownloadPeers(); in pickBestDownloadSessions() local
200 if( all_peers.isEmpty() ) return new LinkedList(); in pickBestDownloadSessions()
202 ArrayList<PEPeer> best = down_ranker.rankPeers( max_sessions, all_peers ); in pickBestDownloadSessions()
|
| /dports/net-p2p/vuze/vuze-5.7.4.0_2/com/aelitis/azureus/core/peermanager/unchoker/ |
| H A D | DownloadingUnchoker.java | 48 public ArrayList<PEPeer> getImmediateUnchokes( int max_to_unchoke, ArrayList<PEPeer> all_peers ) { in getImmediateUnchokes() argument
53 for( int i=0; i < all_peers.size(); i++ ) { in getImmediateUnchokes()
54 PEPeer peer = all_peers.get( i ); in getImmediateUnchokes()
62 PEPeer peer = UnchokerUtil.getNextOptimisticPeer( all_peers, true, true ); in getImmediateUnchokes()
83 for( int i=0; i < all_peers.size(); i++ ) { in calculateUnchokes()
84 PEPeer peer = all_peers.get( i ); in calculateUnchokes()
116 for( int i=0; i < all_peers.size(); i++ ) { in calculateUnchokes()
117 PEPeer peer = all_peers.get( i ); in calculateUnchokes()
133 for( int i=0; i < all_peers.size(); i++ ) { in calculateUnchokes()
134 PEPeer peer = all_peers.get( i ); in calculateUnchokes()
[all …]
|
| H A D | SeedingUnchoker.java | 64 public ArrayList<PEPeer> getImmediateUnchokes( int max_to_unchoke, ArrayList<PEPeer> all_peers ) { in getImmediateUnchokes() argument
66 int peer_count = all_peers.size(); in getImmediateUnchokes()
75 for( int i=0; i < all_peers.size(); i++ ) { in getImmediateUnchokes()
76 PEPeer peer = all_peers.get( i ); in getImmediateUnchokes()
112 for( int i=0; i < all_peers.size(); i++ ) { in calculateUnchokes()
113 PEPeer peer = all_peers.get( i ); in calculateUnchokes()
191 PEPeer optimistic_peer = UnchokerUtil.getNextOptimisticPeer( all_peers, false, false ); in calculateUnchokes()
211 setPriorityUnchokes( max_to_unchoke - max_optimistic, all_peers ); in calculateUnchokes()
223 private void setPriorityUnchokes( int max_priority, ArrayList<PEPeer> all_peers ) { in setPriorityUnchokes() argument
229 for ( int i=0; i < all_peers.size(); i++ ){ in setPriorityUnchokes()
[all …]
|
| H A D | UnchokerUtil.java | 91 …public static PEPeer getNextOptimisticPeer( ArrayList<PEPeer> all_peers, boolean factor_reciprocat… in getNextOptimisticPeer() argument
93 …ArrayList<PEPeer> peers = getNextOptimisticPeers( all_peers, factor_reciprocated, allow_snubbed, 1… in getNextOptimisticPeer()
103 …public static ArrayList<PEPeer> getNextOptimisticPeers( ArrayList<PEPeer> all_peers, boolean facto… in getNextOptimisticPeers() argument
106 for( int i=0; i < all_peers.size(); i++ ) { in getNextOptimisticPeers()
107 PEPeer peer = all_peers.get( i ); in getNextOptimisticPeers()
115 for( int i=0; i < all_peers.size(); i++ ) { in getNextOptimisticPeers()
116 PEPeer peer = all_peers.get( i ); in getNextOptimisticPeers()
|
| H A D | Unchoker.java | 41 public ArrayList<PEPeer> getImmediateUnchokes( int max_to_unchoke, ArrayList<PEPeer> all_peers ); in getImmediateUnchokes() argument
49 …public void calculateUnchokes( int max_to_unchoke, ArrayList<PEPeer> all_peers, boolean force_refr… in calculateUnchokes() argument
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/mojo/core/ |
| H A D | node_controller.cc | 712 std::vector<scoped_refptr<NodeChannel>> all_peers; in DropAllPeers() local
722 all_peers.push_back(bootstrap_inviter_channel_); in DropAllPeers()
729 all_peers.push_back(peer.second); in DropAllPeers()
731 all_peers.push_back(peer.second); in DropAllPeers()
739 for (const auto& peer : all_peers) in DropAllPeers()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/mojo/core/ |
| H A D | node_controller.cc | 717 std::vector<scoped_refptr<NodeChannel>> all_peers; in DropAllPeers() local
727 all_peers.push_back(bootstrap_inviter_channel_); in DropAllPeers()
734 all_peers.push_back(peer.second); in DropAllPeers()
736 all_peers.push_back(peer.second); in DropAllPeers()
744 for (const auto& peer : all_peers) in DropAllPeers()
|
| /dports/www/websocat/websocat-1.9.0/src/ |
| H A D | lib.rs | 160 pub mod all_peers; module
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/app/netcache/ |
| H A D | periodic_sync.cpp | 349 set<CNCPeerControl*> all_peers; in ReConfig() local
367 all_peers.insert((*it_srv)->peer); in ReConfig()
385 all_peers.insert(peer); in ReConfig()
396 ITERATE( set<CNCPeerControl*>, it_peer, all_peers) { in ReConfig()
|
| /dports/lang/erlang-runtime22/otp-OTP-22.3.4.24/lib/diameter/src/base/ |
| H A D | diameter_service.erl | 1638 all_peers(Alias, T);
1673 {Ts, Fs} = filter(all_peers(Alias, T), RH, Filter),
1745 all_peers(Alias, {PeerT, AppT, _}) -> function
|
| /dports/lang/erlang-runtime23/otp-OTP-23.3.4.10/lib/diameter/src/base/ |
| H A D | diameter_service.erl | 1638 all_peers(Alias, T);
1673 {Ts, Fs} = filter(all_peers(Alias, T), RH, Filter),
1745 all_peers(Alias, {PeerT, AppT, _}) -> function
|
| /dports/lang/erlang-runtime24/otp-OTP-24.1.7/lib/diameter/src/base/ |
| H A D | diameter_service.erl | 1638 all_peers(Alias, T);
1673 {Ts, Fs} = filter(all_peers(Alias, T), RH, Filter),
1745 all_peers(Alias, {PeerT, AppT, _}) -> function
|
| /dports/lang/erlang-wx/otp-OTP-24.1.7/lib/diameter/src/base/ |
| H A D | diameter_service.erl | 1638 all_peers(Alias, T);
1673 {Ts, Fs} = filter(all_peers(Alias, T), RH, Filter),
1745 all_peers(Alias, {PeerT, AppT, _}) -> function
|
| /dports/lang/erlang/otp-OTP-24.1.7/lib/diameter/src/base/ |
| H A D | diameter_service.erl | 1638 all_peers(Alias, T);
1673 {Ts, Fs} = filter(all_peers(Alias, T), RH, Filter),
1745 all_peers(Alias, {PeerT, AppT, _}) -> function
|
| /dports/lang/erlang-runtime21/otp-OTP-21.3.8.24/lib/diameter/src/base/ |
| H A D | diameter_service.erl | 1617 all_peers(Alias, T);
1652 {Ts, Fs} = filter(all_peers(Alias, T), RH, Filter),
1724 all_peers(Alias, {PeerT, AppT, _}) -> function
|
| /dports/lang/erlang-java/otp-OTP-24.1.7/lib/diameter/src/base/ |
| H A D | diameter_service.erl | 1638 all_peers(Alias, T);
1673 {Ts, Fs} = filter(all_peers(Alias, T), RH, Filter),
1745 all_peers(Alias, {PeerT, AppT, _}) -> function
|