/dports/science/conduit/conduit-0.8.0/src/tests/relay/python/ |
H A D | t_python_relay_mpi.py | 42 comm_id = MPI.COMM_WORLD.py2f() 43 rank = relay.mpi.rank(comm_id) 44 size = relay.mpi.size(comm_id) 55 comm_id = MPI.COMM_WORLD.py2f() 56 rank = relay.mpi.rank(comm_id) 93 comm_id = MPI.COMM_WORLD.py2f() 94 rank = relay.mpi.rank(comm_id) 102 relay.mpi.send(n,1,0,comm_id); 104 relay.mpi.recv(n,0,0,comm_id); 117 comm_id = MPI.COMM_WORLD.py2f() [all …]
|
/dports/devel/py-ipykernel5/ipykernel-5.5.0/ipykernel/comm/ |
H A D | manager.py | 47 comm_id = comm.comm_id 49 self.comms[comm_id] = comm 50 return comm_id 57 def get_comm(self, comm_id): argument 66 return self.comms[comm_id] 77 comm_id = content['comm_id'] 80 comm = Comm(comm_id=comm_id, 104 comm_id = content['comm_id'] 105 comm = self.get_comm(comm_id) 117 comm_id = content['comm_id'] [all …]
|
H A D | comm.py | 24 comm_id = Unicode() variable in Comm 40 return ('comm-%s' % self.comm_id).encode('ascii') 65 content = json_clean(dict(data=data, comm_id=self.comm_id, **keys)) 150 self.log.debug("handle_close[%s](%s)", self.comm_id, msg) 156 self.log.debug("handle_msg[%s](%s)", self.comm_id, msg)
|
/dports/devel/py-ipykernel/ipykernel-6.6.0/ipykernel/comm/ |
H A D | manager.py | 46 comm_id = comm.comm_id 48 self.comms[comm_id] = comm 49 return comm_id 56 def get_comm(self, comm_id): argument 65 return self.comms[comm_id] 76 comm_id = content['comm_id'] 79 comm = Comm(comm_id=comm_id, 103 comm_id = content['comm_id'] 104 comm = self.get_comm(comm_id) 116 comm_id = content['comm_id'] [all …]
|
H A D | comm.py | 24 comm_id = Unicode() variable in Comm 40 return ('comm-%s' % self.comm_id).encode('ascii') 65 content = json_clean(dict(data=data, comm_id=self.comm_id, **keys)) 150 self.log.debug("handle_close[%s](%s)", self.comm_id, msg) 156 self.log.debug("handle_msg[%s](%s)", self.comm_id, msg)
|
/dports/science/conduit/conduit-0.8.0/src/tests/docs/ |
H A D | t_conduit_docs_tutorial_python_relay_mpi_examples.py | 44 comm_id = MPI.COMM_WORLD.py2f() 46 comm_rank = relay.mpi.rank(comm_id) 47 comm_size = relay.mpi.size(comm_id) 87 comm_id = MPI.COMM_WORLD.py2f() 89 comm_rank = relay.mpi.rank(comm_id) 90 comm_size = relay.mpi.size(comm_id) 130 comm_id = MPI.COMM_WORLD.py2f() 132 comm_rank = relay.mpi.rank(comm_id) 169 comm_id = MPI.COMM_WORLD.py2f() 207 comm_id = MPI.COMM_WORLD.py2f() [all …]
|
/dports/devel/py-qtconsole/qtconsole-5.1.1/qtconsole/ |
H A D | comms.py | 89 comm_id = comm.comm_id 91 self.comms[comm_id] = comm 93 return comm_id 100 self.comms.pop(comm.comm_id) 113 return self.comms[comm_id] 126 comm_id = content['comm_id'] 155 comm_id = content['comm_id'] 171 comm_id = content['comm_id'] 172 comm = self.get_comm(comm_id) 197 if comm_id is None: [all …]
|
/dports/devel/py-spyder-kernels/spyder-kernels-2.2.1/spyder_kernels/comms/ |
H A D | commbase.py | 162 if comm_id is None: 165 id_list = [comm_id] 168 def close(self, comm_id=None): argument 172 for comm_id in id_list: 179 def is_open(self, comm_id=None): argument 181 if comm_id is None: 221 comm_id=None): argument 240 for comm_id in id_list: 299 del self._comms[comm_id] 417 comm_id=comm_id) [all …]
|
H A D | frontendcomm.py | 101 def close(self, comm_id=None): argument 104 return super(FrontendComm, self).close(comm_id) 178 def remote_call(self, comm_id=None, blocking=False, callback=None, argument 183 comm_id=comm_id, 221 self.calling_comm_id = comm.comm_id 238 comm_id = msg['content']['comm_id'] 241 self.close(comm_id)
|
/dports/science/ascent/ascent-0.7.1-66-gbcf2742a/src/ascent/utils/ |
H A D | ascent_mpi_utils.cpp | 31 int comm_id = flow::Workspace::default_mpi_comm(); in global_agreement() local 32 MPI_Comm mpi_comm = MPI_Comm_f2c(comm_id); in global_agreement() 55 int comm_id = flow::Workspace::default_mpi_comm(); in global_someone_agrees() local 56 MPI_Comm mpi_comm = MPI_Comm_f2c(comm_id); in global_someone_agrees() 80 int comm_id = flow::Workspace::default_mpi_comm(); in mpi_size() local 81 MPI_Comm mpi_comm = MPI_Comm_f2c(comm_id); in mpi_size() 91 int comm_id = flow::Workspace::default_mpi_comm(); in mpi_rank() local 92 MPI_Comm mpi_comm = MPI_Comm_f2c(comm_id); in mpi_rank() 101 int comm_id = flow::Workspace::default_mpi_comm(); in gather_strings() local 102 MPI_Comm mpi_comm = MPI_Comm_f2c(comm_id); in gather_strings()
|
/dports/devel/py-nbclient/nbclient-0.5.9/nbclient/ |
H A D | output_widget.py | 13 self, comm_id: str, state: Dict[str, Any], kernel_client: KernelClient, executor 16 self.comm_id: str = comm_id 20 self.topic: bytes = ('comm-%s' % self.comm_id).encode('ascii') 36 self.executor.widget_state[self.comm_id]['outputs'] = self.outputs 54 content = json_clean(dict(data=data, comm_id=self.comm_id, **keys)) 93 self.executor.widget_state[self.comm_id]['outputs'] = self.outputs 107 comm_id = content['comm_id'] 108 assert comm_id == self.comm_id
|
/dports/net/openmpi/openmpi-4.1.1/ompi/mca/mtl/ofi/ |
H A D | mtl_ofi_types.h | 149 mtl_ofi_create_send_tag_CQD(int comm_id, int tag) in mtl_ofi_create_send_tag_CQD() argument 151 uint64_t match_bits = comm_id; in mtl_ofi_create_send_tag_CQD() 161 int comm_id, int tag) in mtl_ofi_create_recv_tag_CQD() argument 164 *match_bits = (uint64_t) comm_id; in mtl_ofi_create_recv_tag_CQD() 216 mtl_ofi_create_send_tag(int comm_id, int source, int tag) in mtl_ofi_create_send_tag() argument 218 uint64_t match_bits = comm_id; in mtl_ofi_create_send_tag() 230 int comm_id, int source, int tag) in mtl_ofi_create_recv_tag() argument 233 *match_bits = comm_id; in mtl_ofi_create_recv_tag()
|
/dports/emulators/qemu/qemu-6.2.0/contrib/rdmacm-mux/ |
H A D | main.c | 197 static int hash_tbl_search_fd_by_comm_id(uint32_t comm_id, int *fd, in hash_tbl_search_fd_by_comm_id() argument 270 g_memdup(&comm_id, sizeof(comm_id)), in hash_tbl_save_fd_comm_id_pair() 307 int32_t comm_id = 0; in get_fd() local 353 data += sizeof(comm_id); in get_fd() 356 if (unlikely(umad_len < sizeof(*hdr) + sizeof(comm_id))) { in get_fd() 363 memcpy(&comm_id, data, sizeof(comm_id)); in get_fd() 364 if (comm_id) { in get_fd() 423 uint32_t *comm_id = 0; in read_and_process() local 462 comm_id = (uint32_t *)(msg.umad.mad + sizeof(*hdr)); in read_and_process() 463 hash_tbl_save_fd_comm_id_pair(fd, *comm_id, in read_and_process() [all …]
|
/dports/emulators/qemu42/qemu-4.2.1/contrib/rdmacm-mux/ |
H A D | main.c | 197 static int hash_tbl_search_fd_by_comm_id(uint32_t comm_id, int *fd, in hash_tbl_search_fd_by_comm_id() argument 270 g_memdup(&comm_id, sizeof(comm_id)), in hash_tbl_save_fd_comm_id_pair() 307 int32_t comm_id = 0; in get_fd() local 353 data += sizeof(comm_id); in get_fd() 356 if (unlikely(umad_len < sizeof(*hdr) + sizeof(comm_id))) { in get_fd() 363 memcpy(&comm_id, data, sizeof(comm_id)); in get_fd() 364 if (comm_id) { in get_fd() 423 uint32_t *comm_id = 0; in read_and_process() local 462 comm_id = (uint32_t *)(msg.umad.mad + sizeof(*hdr)); in read_and_process() 463 hash_tbl_save_fd_comm_id_pair(fd, *comm_id, in read_and_process() [all …]
|
/dports/emulators/qemu60/qemu-6.0.0/contrib/rdmacm-mux/ |
H A D | main.c | 197 static int hash_tbl_search_fd_by_comm_id(uint32_t comm_id, int *fd, in hash_tbl_search_fd_by_comm_id() argument 270 g_memdup(&comm_id, sizeof(comm_id)), in hash_tbl_save_fd_comm_id_pair() 307 int32_t comm_id = 0; in get_fd() local 353 data += sizeof(comm_id); in get_fd() 356 if (unlikely(umad_len < sizeof(*hdr) + sizeof(comm_id))) { in get_fd() 363 memcpy(&comm_id, data, sizeof(comm_id)); in get_fd() 364 if (comm_id) { in get_fd() 423 uint32_t *comm_id = 0; in read_and_process() local 462 comm_id = (uint32_t *)(msg.umad.mad + sizeof(*hdr)); in read_and_process() 463 hash_tbl_save_fd_comm_id_pair(fd, *comm_id, in read_and_process() [all …]
|
/dports/emulators/qemu5/qemu-5.2.0/contrib/rdmacm-mux/ |
H A D | main.c | 197 static int hash_tbl_search_fd_by_comm_id(uint32_t comm_id, int *fd, in hash_tbl_search_fd_by_comm_id() argument 270 g_memdup(&comm_id, sizeof(comm_id)), in hash_tbl_save_fd_comm_id_pair() 307 int32_t comm_id = 0; in get_fd() local 353 data += sizeof(comm_id); in get_fd() 356 if (unlikely(umad_len < sizeof(*hdr) + sizeof(comm_id))) { in get_fd() 363 memcpy(&comm_id, data, sizeof(comm_id)); in get_fd() 364 if (comm_id) { in get_fd() 423 uint32_t *comm_id = 0; in read_and_process() local 462 comm_id = (uint32_t *)(msg.umad.mad + sizeof(*hdr)); in read_and_process() 463 hash_tbl_save_fd_comm_id_pair(fd, *comm_id, in read_and_process() [all …]
|
/dports/emulators/qemu-utils/qemu-4.2.1/contrib/rdmacm-mux/ |
H A D | main.c | 197 static int hash_tbl_search_fd_by_comm_id(uint32_t comm_id, int *fd, in hash_tbl_search_fd_by_comm_id() argument 270 g_memdup(&comm_id, sizeof(comm_id)), in hash_tbl_save_fd_comm_id_pair() 307 int32_t comm_id = 0; in get_fd() local 353 data += sizeof(comm_id); in get_fd() 356 if (unlikely(umad_len < sizeof(*hdr) + sizeof(comm_id))) { in get_fd() 363 memcpy(&comm_id, data, sizeof(comm_id)); in get_fd() 364 if (comm_id) { in get_fd() 423 uint32_t *comm_id = 0; in read_and_process() local 462 comm_id = (uint32_t *)(msg.umad.mad + sizeof(*hdr)); in read_and_process() 463 hash_tbl_save_fd_comm_id_pair(fd, *comm_id, in read_and_process() [all …]
|
/dports/emulators/qemu-cheri/qemu-0a323821042c36e21ea80e58b9545dfc3b0cb8ef/contrib/rdmacm-mux/ |
H A D | main.c | 197 static int hash_tbl_search_fd_by_comm_id(uint32_t comm_id, int *fd, in hash_tbl_search_fd_by_comm_id() argument 270 g_memdup(&comm_id, sizeof(comm_id)), in hash_tbl_save_fd_comm_id_pair() 307 int32_t comm_id = 0; in get_fd() local 353 data += sizeof(comm_id); in get_fd() 356 if (unlikely(umad_len < sizeof(*hdr) + sizeof(comm_id))) { in get_fd() 363 memcpy(&comm_id, data, sizeof(comm_id)); in get_fd() 364 if (comm_id) { in get_fd() 423 uint32_t *comm_id = 0; in read_and_process() local 462 comm_id = (uint32_t *)(msg.umad.mad + sizeof(*hdr)); in read_and_process() 463 hash_tbl_save_fd_comm_id_pair(fd, *comm_id, in read_and_process() [all …]
|
/dports/emulators/qemu-guest-agent/qemu-5.0.1/contrib/rdmacm-mux/ |
H A D | main.c | 197 static int hash_tbl_search_fd_by_comm_id(uint32_t comm_id, int *fd, in hash_tbl_search_fd_by_comm_id() argument 270 g_memdup(&comm_id, sizeof(comm_id)), in hash_tbl_save_fd_comm_id_pair() 307 int32_t comm_id = 0; in get_fd() local 353 data += sizeof(comm_id); in get_fd() 356 if (unlikely(umad_len < sizeof(*hdr) + sizeof(comm_id))) { in get_fd() 363 memcpy(&comm_id, data, sizeof(comm_id)); in get_fd() 364 if (comm_id) { in get_fd() 423 uint32_t *comm_id = 0; in read_and_process() local 462 comm_id = (uint32_t *)(msg.umad.mad + sizeof(*hdr)); in read_and_process() 463 hash_tbl_save_fd_comm_id_pair(fd, *comm_id, in read_and_process() [all …]
|
/dports/emulators/qemu-devel/qemu-de8ed1055c2ce18c95f597eb10df360dcb534f99/contrib/rdmacm-mux/ |
H A D | main.c | 197 static int hash_tbl_search_fd_by_comm_id(uint32_t comm_id, int *fd, in hash_tbl_search_fd_by_comm_id() argument 270 g_memdup(&comm_id, sizeof(comm_id)), in hash_tbl_save_fd_comm_id_pair() 307 int32_t comm_id = 0; in get_fd() local 353 data += sizeof(comm_id); in get_fd() 356 if (unlikely(umad_len < sizeof(*hdr) + sizeof(comm_id))) { in get_fd() 363 memcpy(&comm_id, data, sizeof(comm_id)); in get_fd() 364 if (comm_id) { in get_fd() 423 uint32_t *comm_id = 0; in read_and_process() local 462 comm_id = (uint32_t *)(msg.umad.mad + sizeof(*hdr)); in read_and_process() 463 hash_tbl_save_fd_comm_id_pair(fd, *comm_id, in read_and_process() [all …]
|
/dports/science/code_saturne/code_saturne-7.1.0/src/base/ |
H A D | cs_base.c | 828 int comm_id; in _finalize_reduced_communicators() local 830 for (comm_id = 1; comm_id < _n_step_comms; comm_id++) { in _finalize_reduced_communicators() 833 MPI_Comm_free(&(_step_comm[comm_id])); in _finalize_reduced_communicators() 1361 int comm_id = 0; in cs_base_get_rank_step_comm() local 1363 while ( _step_ranks[comm_id] != n_ranks in cs_base_get_rank_step_comm() 1364 && comm_id < _n_step_comms) in cs_base_get_rank_step_comm() 1365 comm_id++; in cs_base_get_rank_step_comm() 1370 if (comm_id >= _n_step_comms) { in cs_base_get_rank_step_comm() 1376 _step_ranks[comm_id] = n_ranks; in cs_base_get_rank_step_comm() 1382 _step_comm[comm_id] = MPI_COMM_NULL; in cs_base_get_rank_step_comm() [all …]
|
/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/coll/fca/ |
H A D | coll_fca_module.c | 232 fca_module->fca_comm_desc.comm_id); in __fca_comm_new() 237 fca_module->fca_comm_desc.comm_id, fca_module->local_proc_idx, in __fca_comm_new() 386 fca_module->fca_comm_desc.comm_id, fca_module->local_proc_idx, in __create_fca_comm() 407 fca_module->fca_comm_desc.comm_id); in __create_fca_comm() 419 c_item_new->fca_comm_wrap->comm_id = fca_module->fca_comm_desc.comm_id; in __create_fca_comm() 443 fca_module->fca_comm_desc.comm_id); in __destroy_fca_comm() 450 fca_module->fca_comm_desc.comm_id); in __destroy_fca_comm() 649 item->comm_id = -1; in mca_coll_fca_comm_wrap_constructor() 662 item->comm_id); in mca_coll_fca_comm_wrap_destruct()
|
/dports/net/openmpi/openmpi-4.1.1/ompi/mca/coll/fca/ |
H A D | coll_fca_module.c | 232 fca_module->fca_comm_desc.comm_id); in __fca_comm_new() 237 fca_module->fca_comm_desc.comm_id, fca_module->local_proc_idx, in __fca_comm_new() 386 fca_module->fca_comm_desc.comm_id, fca_module->local_proc_idx, in __create_fca_comm() 407 fca_module->fca_comm_desc.comm_id); in __create_fca_comm() 419 c_item_new->fca_comm_wrap->comm_id = fca_module->fca_comm_desc.comm_id; in __create_fca_comm() 443 fca_module->fca_comm_desc.comm_id); in __destroy_fca_comm() 450 fca_module->fca_comm_desc.comm_id); in __destroy_fca_comm() 649 item->comm_id = -1; in mca_coll_fca_comm_wrap_constructor() 662 item->comm_id); in mca_coll_fca_comm_wrap_destruct()
|
/dports/devel/py-qtconsole/qtconsole-5.1.1/qtconsole/tests/ |
H A D | test_comms.py | 90 assert handler.comm.comm_id == msg['content']['comm_id'] 96 assert handler.comm.comm_id == msg['content']['comm_id'] 102 assert handler.comm.comm_id == msg['content']['comm_id']
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/tools/perf/scripts/python/ |
H A D | export-to-postgresql.py | 991 def comm_table(comm_id, comm_str, thread_id, time, exec_flag, *x): argument 995 value = struct.pack(fmt, 5, 8, comm_id, n, comm_str, 8, thread_id, 8, time, 1, exec_flag) 998 def comm_thread_table(comm_thread_id, comm_id, thread_id, *x): argument 1000 value = struct.pack(fmt, 3, 8, comm_thread_id, 8, comm_id, 8, thread_id) 1028 def sample_table(sample_id, evsel_id, machine_id, thread_id, comm_id, dso_id, symbol_id, sym_offset… argument 1030 …Biqiqiq", 20, 8, sample_id, 8, evsel_id, 8, machine_id, 8, thread_id, 8, comm_id, 8, dso_id, 8, sy… 1032 …Biqiqiq", 24, 8, sample_id, 8, evsel_id, 8, machine_id, 8, thread_id, 8, comm_id, 8, dso_id, 8, sy… 1040 def call_return_table(cr_id, thread_id, comm_id, call_path_id, call_time, return_time, branch_count… argument 1042 …value = struct.pack(fmt, 14, 8, cr_id, 8, thread_id, 8, comm_id, 8, call_path_id, 8, call_time, 8,…
|