| /dports/science/py-chainer/chainer-7.8.0/chainermn/functions/ |
| H A D | point_to_point_communication.py | 9 def __init__(self, comm, peer_rank, peer_tag): argument
12 self.peer_rank = peer_rank
19 self.peer_rank)
31 self.comm.send(xs, self.peer_rank, self.peer_tag)
39 grad = self.comm.recv(self.peer_rank, self.peer_tag)
49 def __init__(self, comm, peer_rank, peer_tag): argument
52 self.peer_rank = peer_rank
72 self.peer_rank)
75 data = self.comm.recv(self.peer_rank, self.peer_tag)
189 peer_rank=rank,
[all …]
|
| /dports/net/openmpi/openmpi-4.1.1/ompi/patterns/comm/ |
| H A D | bcast.c | 40 int node_rank, peer_rank; in ompi_comm_bcast_pml() local
65 peer_rank=node_data.parent_rank; in ompi_comm_bcast_pml()
66 peer_rank=(peer_rank+root)%n_peers; in ompi_comm_bcast_pml()
68 rc=MCA_PML_CALL(recv(buffer, count,dtype,peer_rank, in ompi_comm_bcast_pml()
78 peer_rank=node_data.children_ranks[i]; in ompi_comm_bcast_pml()
79 peer_rank=(peer_rank+root)%n_peers; in ompi_comm_bcast_pml()
81 count,dtype,peer_rank, in ompi_comm_bcast_pml()
|
| /dports/net/openmpi3/openmpi-3.1.6/ompi/patterns/comm/ |
| H A D | bcast.c | 40 int node_rank, peer_rank; in ompi_comm_bcast_pml() local
65 peer_rank=node_data.parent_rank; in ompi_comm_bcast_pml()
66 peer_rank=(peer_rank+root)%n_peers; in ompi_comm_bcast_pml()
68 rc=MCA_PML_CALL(recv(buffer, count,dtype,peer_rank, in ompi_comm_bcast_pml()
78 peer_rank=node_data.children_ranks[i]; in ompi_comm_bcast_pml()
79 peer_rank=(peer_rank+root)%n_peers; in ompi_comm_bcast_pml()
81 count,dtype,peer_rank, in ompi_comm_bcast_pml()
|
| /dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/thrill/data/ |
| H A D | stream_sink.cpp | 30 size_t peer_rank, size_t peer_local_worker) in StreamSink() argument
37 peer_rank_(peer_rank), in StreamSink()
52 size_t peer_rank, size_t peer_local_worker) in StreamSink() argument
58 peer_rank_(peer_rank), in StreamSink()
73 size_t peer_rank, size_t peer_local_worker) in StreamSink() argument
79 peer_rank_(peer_rank), in StreamSink()
|
| H A D | stream_sink.hpp | 54 size_t peer_rank, size_t peer_local_worker);
61 size_t peer_rank, size_t peer_local_worker);
68 size_t peer_rank, size_t peer_local_worker);
|
| /dports/net-p2p/libtorrent-rasterbar/libtorrent-rasterbar-1.2.14/src/ |
| H A D | torrent_peer.cpp | 140 , peer_rank(0) in torrent_peer()
176 if (peer_rank == 0) in rank()
177 peer_rank = peer_priority( in rank()
180 return peer_rank; in rank()
|
| H A D | peer_list.cpp | 236 p->peer_rank = 0; in clear_peer_prio()
|
| H A D | torrent.cpp | 1796 if (lowest_rank == end() || (*lowest_rank)->peer_rank() > (*i)->peer_rank()) in find_lowest_ranking_peer()
7249 if (peer != nullptr && peer->peer_rank() < p->peer_rank()) in attach_peer()
|
| H A D | peer_connection.cpp | 1414 std::uint32_t peer_connection::peer_rank() const in peer_rank() function in libtorrent::peer_connection
|
| /dports/net-p2p/py-libtorrent-rasterbar/libtorrent-1.2.13/src/ |
| H A D | torrent_peer.cpp | 140 , peer_rank(0) in torrent_peer()
175 if (peer_rank == 0) in rank()
176 peer_rank = peer_priority( in rank()
179 return peer_rank; in rank()
|
| H A D | peer_list.cpp | 178 p->peer_rank = 0; in clear_peer_prio()
|
| H A D | torrent.cpp | 1796 if (lowest_rank == end() || (*lowest_rank)->peer_rank() > (*i)->peer_rank()) in find_lowest_ranking_peer()
7249 if (peer != nullptr && peer->peer_rank() < p->peer_rank()) in attach_peer()
|
| H A D | peer_connection.cpp | 1414 std::uint32_t peer_connection::peer_rank() const in peer_rank() function in libtorrent::peer_connection
|
| /dports/net/openmpi3/openmpi-3.1.6/ompi/mca/common/monitoring/ |
| H A D | common_monitoring.c | 440 int peer_rank; in mca_common_monitoring_add_procs() local
476 for( peer_rank = 0; peer_rank < nprocs_world; peer_rank++ ) { in mca_common_monitoring_add_procs()
477 … ompi_group_get_proc_name(((ompi_communicator_t*)&ompi_mpi_comm_world)->c_remote_group, peer_rank); in mca_common_monitoring_add_procs()
484 … key, (void*)(uintptr_t)peer_rank) ) { in mca_common_monitoring_add_procs()
|
| /dports/net/openmpi/openmpi-4.1.1/ompi/mca/common/monitoring/ |
| H A D | common_monitoring.c | 440 int peer_rank; in mca_common_monitoring_add_procs() local
476 for( peer_rank = 0; peer_rank < nprocs_world; peer_rank++ ) { in mca_common_monitoring_add_procs()
477 … ompi_group_get_proc_name(((ompi_communicator_t*)&ompi_mpi_comm_world)->c_remote_group, peer_rank); in mca_common_monitoring_add_procs()
484 … key, (void*)(uintptr_t)peer_rank) ) { in mca_common_monitoring_add_procs()
|
| /dports/net/openmpi/openmpi-4.1.1/ompi/mca/osc/rdma/ |
| H A D | osc_rdma_component.c | 730 int peer_rank = temp[i].rank; in allocate_state_shared() local
732 ret = ompi_osc_rdma_new_peer (module, peer_rank, &peer); in allocate_state_shared()
754 if (my_rank == peer_rank) { in allocate_state_shared()
760 peer->data_endpoint = ompi_osc_rdma_peer_btl_endpoint (module, peer_rank); in allocate_state_shared()
769 if (module->use_cpu_atomics && peer_rank == my_rank) { in allocate_state_shared()
785 …if (module->use_cpu_atomics && (MPI_WIN_FLAVOR_ALLOCATE == module->flavor || peer_rank == my_rank)… in allocate_state_shared()
|
| /dports/net-p2p/py-libtorrent-rasterbar/libtorrent-1.2.13/include/libtorrent/ |
| H A D | torrent_peer.hpp | 100 mutable std::uint32_t peer_rank; member
|
| H A D | peer_connection.hpp | 357 std::uint32_t peer_rank() const;
|
| /dports/net-p2p/libtorrent-rasterbar/libtorrent-rasterbar-1.2.14/include/libtorrent/ |
| H A D | torrent_peer.hpp | 100 mutable std::uint32_t peer_rank; member
|
| H A D | peer_connection.hpp | 357 std::uint32_t peer_rank() const;
|
| /dports/net/openmpi3/openmpi-3.1.6/ompi/mca/osc/rdma/ |
| H A D | osc_rdma_component.c | 729 int peer_rank = temp[i].rank; in allocate_state_shared() local
731 ret = ompi_osc_rdma_new_peer (module, peer_rank, &peer); in allocate_state_shared()
753 if (my_rank == peer_rank) { in allocate_state_shared()
759 peer->data_endpoint = ompi_osc_rdma_peer_btl_endpoint (module, peer_rank); in allocate_state_shared()
|