Home
last modified time | relevance | path

Searched refs:comm_id (Results 1 – 25 of 83) sorted by relevance

1234

/dports/science/conduit/conduit-0.8.0/src/tests/relay/python/
H A Dt_python_relay_mpi.py42 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 Dmanager.py47 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 Dcomm.py24 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 Dmanager.py46 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 Dcomm.py24 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 Dt_conduit_docs_tutorial_python_relay_mpi_examples.py44 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 Dcomms.py89 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 Dcommbase.py162 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 Dfrontendcomm.py101 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 Dascent_mpi_utils.cpp31 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 Doutput_widget.py13 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 Dmtl_ofi_types.h149 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 Dmain.c197 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 Dmain.c197 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 Dmain.c197 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 Dmain.c197 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 Dmain.c197 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 Dmain.c197 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 Dmain.c197 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 Dmain.c197 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 Dcs_base.c828 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 Dcoll_fca_module.c232 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 Dcoll_fca_module.c232 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 Dtest_comms.py90 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 Dexport-to-postgresql.py991 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,…

1234