LCI v2.0.0-dev
For Asynchronous Multithreaded Communication
Loading...
Searching...
No Matches
lci_binding_post.hpp
Go to the documentation of this file.
1
2// Copyright (c) 2025 The LCI Project Authors
3// SPDX-License-Identifier: NCSA
4
5// clang-format off
6// This file is generated by generate_binding.py
7#ifndef LCI_BINDING_POST_HPP_
8#define LCI_BINDING_POST_HPP_
9
10namespace lci {
11
12
41
47 public:
48 // args declaration
50 int m_rank;
52 size_t m_size;
70
71 // constructor
72 post_comm_x(direction_t direction_in, int rank_in, void* local_buffer_in, size_t size_in, comp_t local_comp_in) : m_direction(direction_in), m_rank(rank_in), m_local_buffer(local_buffer_in), m_size(size_in), m_local_comp(local_comp_in) {}
73
74 // setter
75 inline post_comm_x&& direction(direction_t direction_in) { m_direction = direction_in; return std::move(*this); }
76 inline post_comm_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
77 inline post_comm_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
78 inline post_comm_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
79 inline post_comm_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
80 inline post_comm_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
81 inline post_comm_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
82 inline post_comm_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
83 inline post_comm_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
84 inline post_comm_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
85 inline post_comm_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
86 inline post_comm_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
87 inline post_comm_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
88 inline post_comm_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
89 inline post_comm_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
90 inline post_comm_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
91 inline post_comm_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
92 inline post_comm_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
93 inline post_comm_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
94 inline post_comm_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
95 inline post_comm_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
96
98 status_t call() const;
99 inline status_t operator()() const { return call(); }
100};
101
102inline status_t post_comm(direction_t direction_in, int rank_in, void* local_buffer_in, size_t size_in, comp_t local_comp_in) {
103 return post_comm_x(direction_in, rank_in, local_buffer_in, size_in, local_comp_in).call();
104}
105
106
130
136 public:
137 // args declaration
140 size_t m_size;
154
155 // constructor
156 post_am_x(int rank_in, void* local_buffer_in, size_t size_in, comp_t local_comp_in, rcomp_t remote_comp_in) : m_rank(rank_in), m_local_buffer(local_buffer_in), m_size(size_in), m_local_comp(local_comp_in), m_remote_comp(remote_comp_in) {}
157
158 // setter
159 inline post_am_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
160 inline post_am_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
161 inline post_am_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
162 inline post_am_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
163 inline post_am_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
164 inline post_am_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
165 inline post_am_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
166 inline post_am_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
167 inline post_am_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
168 inline post_am_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
169 inline post_am_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
170 inline post_am_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
171 inline post_am_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
172 inline post_am_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
173 inline post_am_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
174 inline post_am_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
175
177 status_t call() const;
178 inline status_t operator()() const { return call(); }
179};
180
181inline status_t post_am(int rank_in, void* local_buffer_in, size_t size_in, comp_t local_comp_in, rcomp_t remote_comp_in) {
182 return post_am_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_comp_in).call();
183}
184
185
210
216 public:
217 // args declaration
220 size_t m_size;
235
236 // constructor
237 post_send_x(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) : m_rank(rank_in), m_local_buffer(local_buffer_in), m_size(size_in), m_tag(tag_in), m_local_comp(local_comp_in) {}
238
239 // setter
240 inline post_send_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
241 inline post_send_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
242 inline post_send_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
243 inline post_send_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
244 inline post_send_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
245 inline post_send_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
246 inline post_send_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
247 inline post_send_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
248 inline post_send_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
249 inline post_send_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
250 inline post_send_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
251 inline post_send_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
252 inline post_send_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
253 inline post_send_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
254 inline post_send_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
255 inline post_send_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
256 inline post_send_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
257
259 status_t call() const;
260 inline status_t operator()() const { return call(); }
261};
262
263inline status_t post_send(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) {
264 return post_send_x(rank_in, local_buffer_in, size_in, tag_in, local_comp_in).call();
265}
266
267
292
298 public:
299 // args declaration
302 size_t m_size;
317
318 // constructor
319 post_recv_x(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) : m_rank(rank_in), m_local_buffer(local_buffer_in), m_size(size_in), m_tag(tag_in), m_local_comp(local_comp_in) {}
320
321 // setter
322 inline post_recv_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
323 inline post_recv_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
324 inline post_recv_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
325 inline post_recv_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
326 inline post_recv_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
327 inline post_recv_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
328 inline post_recv_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
329 inline post_recv_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
330 inline post_recv_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
331 inline post_recv_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
332 inline post_recv_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
333 inline post_recv_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
334 inline post_recv_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
335 inline post_recv_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
336 inline post_recv_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
337 inline post_recv_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
338 inline post_recv_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
339
341 status_t call() const;
342 inline status_t operator()() const { return call(); }
343};
344
345inline status_t post_recv(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) {
346 return post_recv_x(rank_in, local_buffer_in, size_in, tag_in, local_comp_in).call();
347}
348
349
375
381 public:
382 // args declaration
385 size_t m_size;
387 uintptr_t m_remote_disp;
401
402 // constructor
403 post_put_x(int rank_in, void* local_buffer_in, size_t size_in, comp_t local_comp_in, uintptr_t remote_disp_in, rmr_t rmr_in) : m_rank(rank_in), m_local_buffer(local_buffer_in), m_size(size_in), m_local_comp(local_comp_in), m_remote_disp(remote_disp_in), m_rmr(rmr_in) {}
404
405 // setter
406 inline post_put_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
407 inline post_put_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
408 inline post_put_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
409 inline post_put_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
410 inline post_put_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
411 inline post_put_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
412 inline post_put_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
413 inline post_put_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
414 inline post_put_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
415 inline post_put_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
416 inline post_put_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
417 inline post_put_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
418 inline post_put_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
419 inline post_put_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
420 inline post_put_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
421 inline post_put_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
422 inline post_put_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
423 inline post_put_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
424
426 status_t call() const;
427 inline status_t operator()() const { return call(); }
428};
429
430inline status_t post_put(int rank_in, void* local_buffer_in, size_t size_in, comp_t local_comp_in, uintptr_t remote_disp_in, rmr_t rmr_in) {
431 return post_put_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_disp_in, rmr_in).call();
432}
433
434
460
466 public:
467 // args declaration
470 size_t m_size;
472 uintptr_t m_remote_disp;
486
487 // constructor
488 post_get_x(int rank_in, void* local_buffer_in, size_t size_in, comp_t local_comp_in, uintptr_t remote_disp_in, rmr_t rmr_in) : m_rank(rank_in), m_local_buffer(local_buffer_in), m_size(size_in), m_local_comp(local_comp_in), m_remote_disp(remote_disp_in), m_rmr(rmr_in) {}
489
490 // setter
491 inline post_get_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
492 inline post_get_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
493 inline post_get_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
494 inline post_get_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
495 inline post_get_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
496 inline post_get_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
497 inline post_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
498 inline post_get_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
499 inline post_get_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
500 inline post_get_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
501 inline post_get_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
502 inline post_get_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
503 inline post_get_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
504 inline post_get_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
505 inline post_get_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
506 inline post_get_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
507 inline post_get_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
508 inline post_get_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
509
511 status_t call() const;
512 inline status_t operator()() const { return call(); }
513};
514
515inline status_t post_get(int rank_in, void* local_buffer_in, size_t size_in, comp_t local_comp_in, uintptr_t remote_disp_in, rmr_t rmr_in) {
516 return post_get_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_disp_in, rmr_in).call();
517}
518
519
530
536 public:
537 // args declaration
541
542 // constructor
544
545 // setter
546 inline progress_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
547 inline progress_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
548 inline progress_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
549
551 error_t call() const;
552 inline error_t operator()() const { return call(); }
553};
554
556 return progress_x().call();
557}
558
559
569
575 public:
576 // args declaration
579
580 // constructor
582
583 // setter
584 inline test_drained_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
585 inline test_drained_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
586
588 error_t call() const;
589 inline error_t operator()() const { return call(); }
590};
591
593 return test_drained_x().call();
594}
595
596
606
612 public:
613 // args declaration
616
617 // constructor
619
620 // setter
621 inline wait_drained_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
622 inline wait_drained_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
623
625 void call() const;
626 inline void operator()() const { return call(); }
627};
628
629inline void wait_drained() {
630 return wait_drained_x().call();
631}
632
633
653
659 public:
660 // args declaration
673
674 // constructor
676
677 // setter
678 inline alloc_net_context_x&& backend(attr_backend_t backend_in) { m_backend = backend_in; return std::move(*this); }
679 inline alloc_net_context_x&& ofi_provider_name(std::string ofi_provider_name_in) { m_ofi_provider_name = ofi_provider_name_in; return std::move(*this); }
680 inline alloc_net_context_x&& max_msg_size(size_t max_msg_size_in) { m_max_msg_size = max_msg_size_in; return std::move(*this); }
681 inline alloc_net_context_x&& max_inject_size(size_t max_inject_size_in) { m_max_inject_size = max_inject_size_in; return std::move(*this); }
682 inline alloc_net_context_x&& ibv_gid_idx(int ibv_gid_idx_in) { m_ibv_gid_idx = ibv_gid_idx_in; return std::move(*this); }
683 inline alloc_net_context_x&& ibv_force_gid_auto_select(bool ibv_force_gid_auto_select_in) { m_ibv_force_gid_auto_select = ibv_force_gid_auto_select_in; return std::move(*this); }
684 inline alloc_net_context_x&& ibv_odp_strategy(attr_ibv_odp_strategy_t ibv_odp_strategy_in) { m_ibv_odp_strategy = ibv_odp_strategy_in; return std::move(*this); }
685 inline alloc_net_context_x&& ibv_prefetch_strategy(attr_ibv_prefetch_strategy_t ibv_prefetch_strategy_in) { m_ibv_prefetch_strategy = ibv_prefetch_strategy_in; return std::move(*this); }
686 inline alloc_net_context_x&& use_dmabuf(bool use_dmabuf_in) { m_use_dmabuf = use_dmabuf_in; return std::move(*this); }
687 inline alloc_net_context_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
688 inline alloc_net_context_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
689 inline alloc_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
690
692 net_context_t call() const;
693 inline net_context_t operator()() const { return call(); }
694};
695
699
700
710
716 public:
717 // args declaration
720
721 // constructor
722 free_net_context_x(net_context_t* net_context_in) : m_net_context(net_context_in) {}
723
724 // setter
725 inline free_net_context_x&& net_context(net_context_t* net_context_in) { m_net_context = net_context_in; return std::move(*this); }
726 inline free_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
727
729 void call() const;
730 inline void operator()() const { return call(); }
731};
732
733inline void free_net_context(net_context_t* net_context_in) {
734 return free_net_context_x(net_context_in).call();
735}
736
737
759
765 public:
766 // args declaration
781
782 // constructor
784
785 // setter
786 inline alloc_device_x&& net_max_sends(size_t net_max_sends_in) { m_net_max_sends = net_max_sends_in; return std::move(*this); }
787 inline alloc_device_x&& net_max_recvs(size_t net_max_recvs_in) { m_net_max_recvs = net_max_recvs_in; return std::move(*this); }
788 inline alloc_device_x&& net_max_cqes(size_t net_max_cqes_in) { m_net_max_cqes = net_max_cqes_in; return std::move(*this); }
789 inline alloc_device_x&& net_send_reserved_pct(double net_send_reserved_pct_in) { m_net_send_reserved_pct = net_send_reserved_pct_in; return std::move(*this); }
790 inline alloc_device_x&& ofi_lock_mode(uint64_t ofi_lock_mode_in) { m_ofi_lock_mode = ofi_lock_mode_in; return std::move(*this); }
791 inline alloc_device_x&& alloc_default_endpoint(bool alloc_default_endpoint_in) { m_alloc_default_endpoint = alloc_default_endpoint_in; return std::move(*this); }
792 inline alloc_device_x&& alloc_progress_endpoint(bool alloc_progress_endpoint_in) { m_alloc_progress_endpoint = alloc_progress_endpoint_in; return std::move(*this); }
793 inline alloc_device_x&& use_reg_cache(bool use_reg_cache_in) { m_use_reg_cache = use_reg_cache_in; return std::move(*this); }
794 inline alloc_device_x&& ibv_td_strategy(attr_ibv_td_strategy_t ibv_td_strategy_in) { m_ibv_td_strategy = ibv_td_strategy_in; return std::move(*this); }
795 inline alloc_device_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
796 inline alloc_device_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
797 inline alloc_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
798 inline alloc_device_x&& net_context(net_context_t net_context_in) { m_net_context = net_context_in; return std::move(*this); }
799 inline alloc_device_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
800
802 device_t call() const;
803 inline device_t operator()() const { return call(); }
804};
805
807 return alloc_device_x().call();
808}
809
810
820
826 public:
827 // args declaration
830
831 // constructor
832 free_device_x(device_t* device_in) : m_device(device_in) {}
833
834 // setter
835 inline free_device_x&& device(device_t* device_in) { m_device = device_in; return std::move(*this); }
836 inline free_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
837
839 void call() const;
840 inline void operator()() const { return call(); }
841};
842
843inline void free_device(device_t* device_in) {
844 return free_device_x(device_in).call();
845}
846
847
859
865 public:
866 // args declaration
868 size_t m_size;
871
872 // constructor
873 register_memory_x(void* address_in, size_t size_in) : m_address(address_in), m_size(size_in) {}
874
875 // setter
876 inline register_memory_x&& address(void* address_in) { m_address = address_in; return std::move(*this); }
877 inline register_memory_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
878 inline register_memory_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
879 inline register_memory_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
880
882 mr_t call() const;
883 inline mr_t operator()() const { return call(); }
884};
885
886inline mr_t register_memory(void* address_in, size_t size_in) {
887 return register_memory_x(address_in, size_in).call();
888}
889
890
900
906 public:
907 // args declaration
910
911 // constructor
912 deregister_memory_x(mr_t* mr_in) : m_mr(mr_in) {}
913
914 // setter
915 inline deregister_memory_x&& mr(mr_t* mr_in) { m_mr = mr_in; return std::move(*this); }
916 inline deregister_memory_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
917
919 void call() const;
920 inline void operator()() const { return call(); }
921};
922
923inline void deregister_memory(mr_t* mr_in) {
924 return deregister_memory_x(mr_in).call();
925}
926
927
937
943 public:
944 // args declaration
947
948 // constructor
949 get_rmr_x(mr_t mr_in) : m_mr(mr_in) {}
950
951 // setter
952 inline get_rmr_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
953 inline get_rmr_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
954
956 rmr_t call() const;
957 inline rmr_t operator()() const { return call(); }
958};
959
960inline rmr_t get_rmr(mr_t mr_in) {
961 return get_rmr_x(mr_in).call();
962}
963
964
976
982 public:
983 // args declaration
988
989 // constructor
991
992 // setter
993 inline alloc_endpoint_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
994 inline alloc_endpoint_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
995 inline alloc_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
996 inline alloc_endpoint_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
997
999 endpoint_t call() const;
1000 inline endpoint_t operator()() const { return call(); }
1001};
1002
1004 return alloc_endpoint_x().call();
1005}
1006
1007
1017
1023 public:
1024 // args declaration
1027
1028 // constructor
1029 free_endpoint_x(endpoint_t* endpoint_in) : m_endpoint(endpoint_in) {}
1030
1031 // setter
1032 inline free_endpoint_x&& endpoint(endpoint_t* endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1033 inline free_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1034
1036 void call() const;
1037 inline void operator()() const { return call(); }
1038};
1039
1040inline void free_endpoint(endpoint_t* endpoint_in) {
1041 return free_endpoint_x(endpoint_in).call();
1042}
1043
1044
1056
1062 public:
1063 // args declaration
1068
1069 // constructor
1070 net_poll_cq_x(size_t max_polls_in, net_status_t* statuses_in) : m_max_polls(max_polls_in), m_statuses(statuses_in) {}
1071
1072 // setter
1073 inline net_poll_cq_x&& max_polls(size_t max_polls_in) { m_max_polls = max_polls_in; return std::move(*this); }
1074 inline net_poll_cq_x&& statuses(net_status_t* statuses_in) { m_statuses = statuses_in; return std::move(*this); }
1075 inline net_poll_cq_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1076 inline net_poll_cq_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1077
1079 size_t call() const;
1080 inline size_t operator()() const { return call(); }
1081};
1082
1083inline size_t net_poll_cq(size_t max_polls_in, net_status_t* statuses_in) {
1084 return net_poll_cq_x(max_polls_in, statuses_in).call();
1085}
1086
1087
1101
1107 public:
1108 // args declaration
1110 size_t m_size;
1115
1116 // constructor
1117 net_post_recv_x(void* buffer_in, size_t size_in, mr_t mr_in) : m_buffer(buffer_in), m_size(size_in), m_mr(mr_in) {}
1118
1119 // setter
1120 inline net_post_recv_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1121 inline net_post_recv_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1122 inline net_post_recv_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1123 inline net_post_recv_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1124 inline net_post_recv_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1125 inline net_post_recv_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1126
1128 error_t call() const;
1129 inline error_t operator()() const { return call(); }
1130};
1131
1132inline error_t net_post_recv(void* buffer_in, size_t size_in, mr_t mr_in) {
1133 return net_post_recv_x(buffer_in, size_in, mr_in).call();
1134}
1135
1136
1152
1158 public:
1159 // args declaration
1162 size_t m_size;
1168
1169 // constructor
1170 net_post_sends_x(int rank_in, void* buffer_in, size_t size_in) : m_rank(rank_in), m_buffer(buffer_in), m_size(size_in) {}
1171
1172 // setter
1173 inline net_post_sends_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1174 inline net_post_sends_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1175 inline net_post_sends_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1176 inline net_post_sends_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1177 inline net_post_sends_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1178 inline net_post_sends_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1179 inline net_post_sends_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1180 inline net_post_sends_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1181
1183 error_t call() const;
1184 inline error_t operator()() const { return call(); }
1185};
1186
1187inline error_t net_post_sends(int rank_in, void* buffer_in, size_t size_in) {
1188 return net_post_sends_x(rank_in, buffer_in, size_in).call();
1189}
1190
1191
1208
1214 public:
1215 // args declaration
1218 size_t m_size;
1225
1226 // constructor
1227 net_post_send_x(int rank_in, void* buffer_in, size_t size_in, mr_t mr_in) : m_rank(rank_in), m_buffer(buffer_in), m_size(size_in), m_mr(mr_in) {}
1228
1229 // setter
1230 inline net_post_send_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1231 inline net_post_send_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1232 inline net_post_send_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1233 inline net_post_send_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1234 inline net_post_send_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1235 inline net_post_send_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1236 inline net_post_send_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1237 inline net_post_send_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1238 inline net_post_send_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1239
1241 error_t call() const;
1242 inline error_t operator()() const { return call(); }
1243};
1244
1245inline error_t net_post_send(int rank_in, void* buffer_in, size_t size_in, mr_t mr_in) {
1246 return net_post_send_x(rank_in, buffer_in, size_in, mr_in).call();
1247}
1248
1249
1266
1272 public:
1273 // args declaration
1276 size_t m_size;
1277 uint64_t m_offset;
1283
1284 // constructor
1285 net_post_puts_x(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) : m_rank(rank_in), m_buffer(buffer_in), m_size(size_in), m_offset(offset_in), m_rmr(rmr_in) {}
1286
1287 // setter
1288 inline net_post_puts_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1289 inline net_post_puts_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1290 inline net_post_puts_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1291 inline net_post_puts_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1292 inline net_post_puts_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1293 inline net_post_puts_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1294 inline net_post_puts_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1295 inline net_post_puts_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1296 inline net_post_puts_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1297
1299 error_t call() const;
1300 inline error_t operator()() const { return call(); }
1301};
1302
1303inline error_t net_post_puts(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) {
1304 return net_post_puts_x(rank_in, buffer_in, size_in, offset_in, rmr_in).call();
1305}
1306
1307
1325
1331 public:
1332 // args declaration
1335 size_t m_size;
1337 uint64_t m_offset;
1343
1344 // constructor
1345 net_post_put_x(int rank_in, void* buffer_in, size_t size_in, mr_t mr_in, uint64_t offset_in, rmr_t rmr_in) : m_rank(rank_in), m_buffer(buffer_in), m_size(size_in), m_mr(mr_in), m_offset(offset_in), m_rmr(rmr_in) {}
1346
1347 // setter
1348 inline net_post_put_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1349 inline net_post_put_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1350 inline net_post_put_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1351 inline net_post_put_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1352 inline net_post_put_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1353 inline net_post_put_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1354 inline net_post_put_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1355 inline net_post_put_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1356 inline net_post_put_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1357 inline net_post_put_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1358
1360 error_t call() const;
1361 inline error_t operator()() const { return call(); }
1362};
1363
1364inline error_t net_post_put(int rank_in, void* buffer_in, size_t size_in, mr_t mr_in, uint64_t offset_in, rmr_t rmr_in) {
1365 return net_post_put_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
1366}
1367
1368
1386
1392 public:
1393 // args declaration
1396 size_t m_size;
1397 uint64_t m_offset;
1404
1405 // constructor
1406 net_post_putImms_x(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) : m_rank(rank_in), m_buffer(buffer_in), m_size(size_in), m_offset(offset_in), m_rmr(rmr_in) {}
1407
1408 // setter
1409 inline net_post_putImms_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1410 inline net_post_putImms_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1411 inline net_post_putImms_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1412 inline net_post_putImms_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1413 inline net_post_putImms_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1414 inline net_post_putImms_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1415 inline net_post_putImms_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1416 inline net_post_putImms_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1417 inline net_post_putImms_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1418 inline net_post_putImms_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1419
1421 error_t call() const;
1422 inline error_t operator()() const { return call(); }
1423};
1424
1425inline error_t net_post_putImms(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) {
1426 return net_post_putImms_x(rank_in, buffer_in, size_in, offset_in, rmr_in).call();
1427}
1428
1429
1448
1454 public:
1455 // args declaration
1458 size_t m_size;
1460 uint64_t m_offset;
1467
1468 // constructor
1469 net_post_putImm_x(int rank_in, void* buffer_in, size_t size_in, mr_t mr_in, uint64_t offset_in, rmr_t rmr_in) : m_rank(rank_in), m_buffer(buffer_in), m_size(size_in), m_mr(mr_in), m_offset(offset_in), m_rmr(rmr_in) {}
1470
1471 // setter
1472 inline net_post_putImm_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1473 inline net_post_putImm_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1474 inline net_post_putImm_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1475 inline net_post_putImm_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1476 inline net_post_putImm_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1477 inline net_post_putImm_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1478 inline net_post_putImm_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1479 inline net_post_putImm_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1480 inline net_post_putImm_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1481 inline net_post_putImm_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1482 inline net_post_putImm_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1483
1485 error_t call() const;
1486 inline error_t operator()() const { return call(); }
1487};
1488
1489inline error_t net_post_putImm(int rank_in, void* buffer_in, size_t size_in, mr_t mr_in, uint64_t offset_in, rmr_t rmr_in) {
1490 return net_post_putImm_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
1491}
1492
1493
1511
1517 public:
1518 // args declaration
1521 size_t m_size;
1523 uint64_t m_offset;
1529
1530 // constructor
1531 net_post_get_x(int rank_in, void* buffer_in, size_t size_in, mr_t mr_in, uint64_t offset_in, rmr_t rmr_in) : m_rank(rank_in), m_buffer(buffer_in), m_size(size_in), m_mr(mr_in), m_offset(offset_in), m_rmr(rmr_in) {}
1532
1533 // setter
1534 inline net_post_get_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1535 inline net_post_get_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1536 inline net_post_get_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1537 inline net_post_get_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1538 inline net_post_get_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1539 inline net_post_get_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1540 inline net_post_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1541 inline net_post_get_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1542 inline net_post_get_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1543 inline net_post_get_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1544
1546 error_t call() const;
1547 inline error_t operator()() const { return call(); }
1548};
1549
1550inline error_t net_post_get(int rank_in, void* buffer_in, size_t size_in, mr_t mr_in, uint64_t offset_in, rmr_t rmr_in) {
1551 return net_post_get_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
1552}
1553
1554
1571
1577 public:
1578 // args declaration
1588
1589 // constructor
1591
1592 // setter
1593 inline alloc_runtime_x&& packet_return_threshold(size_t packet_return_threshold_in) { m_packet_return_threshold = packet_return_threshold_in; return std::move(*this); }
1594 inline alloc_runtime_x&& imm_nbits_tag(int imm_nbits_tag_in) { m_imm_nbits_tag = imm_nbits_tag_in; return std::move(*this); }
1595 inline alloc_runtime_x&& imm_nbits_rcomp(int imm_nbits_rcomp_in) { m_imm_nbits_rcomp = imm_nbits_rcomp_in; return std::move(*this); }
1596 inline alloc_runtime_x&& rdv_protocol(attr_rdv_protocol_t rdv_protocol_in) { m_rdv_protocol = rdv_protocol_in; return std::move(*this); }
1597 inline alloc_runtime_x&& alloc_default_device(bool alloc_default_device_in) { m_alloc_default_device = alloc_default_device_in; return std::move(*this); }
1598 inline alloc_runtime_x&& alloc_default_packet_pool(bool alloc_default_packet_pool_in) { m_alloc_default_packet_pool = alloc_default_packet_pool_in; return std::move(*this); }
1599 inline alloc_runtime_x&& alloc_default_matching_engine(bool alloc_default_matching_engine_in) { m_alloc_default_matching_engine = alloc_default_matching_engine_in; return std::move(*this); }
1600 inline alloc_runtime_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
1601 inline alloc_runtime_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1602
1604 runtime_t call() const;
1605 inline runtime_t operator()() const { return call(); }
1606};
1607
1609 return alloc_runtime_x().call();
1610}
1611
1612
1621
1627 public:
1628 // args declaration
1630
1631 // constructor
1632 free_runtime_x(runtime_t* runtime_in) : m_runtime(runtime_in) {}
1633
1634 // setter
1635 inline free_runtime_x&& runtime(runtime_t* runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1636
1638 void call() const;
1639 inline void operator()() const { return call(); }
1640};
1641
1642inline void free_runtime(runtime_t* runtime_in) {
1643 return free_runtime_x(runtime_in).call();
1644}
1645
1646
1663
1669 public:
1670 // args declaration
1680
1681 // constructor
1683
1684 // setter
1685 inline g_runtime_init_x&& packet_return_threshold(size_t packet_return_threshold_in) { m_packet_return_threshold = packet_return_threshold_in; return std::move(*this); }
1686 inline g_runtime_init_x&& imm_nbits_tag(int imm_nbits_tag_in) { m_imm_nbits_tag = imm_nbits_tag_in; return std::move(*this); }
1687 inline g_runtime_init_x&& imm_nbits_rcomp(int imm_nbits_rcomp_in) { m_imm_nbits_rcomp = imm_nbits_rcomp_in; return std::move(*this); }
1688 inline g_runtime_init_x&& rdv_protocol(attr_rdv_protocol_t rdv_protocol_in) { m_rdv_protocol = rdv_protocol_in; return std::move(*this); }
1689 inline g_runtime_init_x&& alloc_default_device(bool alloc_default_device_in) { m_alloc_default_device = alloc_default_device_in; return std::move(*this); }
1690 inline g_runtime_init_x&& alloc_default_packet_pool(bool alloc_default_packet_pool_in) { m_alloc_default_packet_pool = alloc_default_packet_pool_in; return std::move(*this); }
1691 inline g_runtime_init_x&& alloc_default_matching_engine(bool alloc_default_matching_engine_in) { m_alloc_default_matching_engine = alloc_default_matching_engine_in; return std::move(*this); }
1692 inline g_runtime_init_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
1693 inline g_runtime_init_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1694
1696 runtime_t call() const;
1697 inline runtime_t operator()() const { return call(); }
1698};
1699
1701 return g_runtime_init_x().call();
1702}
1703
1704
1713
1719 public:
1720 // args declaration
1721
1722 // constructor
1724
1725 // setter
1726
1727 void call_impl() const;
1728 void call() const;
1729 inline void operator()() const { return call(); }
1730};
1731
1732inline void g_runtime_fina() {
1733 return g_runtime_fina_x().call();
1734}
1735
1736
1745
1751 public:
1752 // args declaration
1753
1754 // constructor
1756
1757 // setter
1758
1760 runtime_t call() const;
1761 inline runtime_t operator()() const { return call(); }
1762};
1763
1765 return get_g_runtime_x().call();
1766}
1767
1768
1781
1787 public:
1788 // args declaration
1794
1795 // constructor
1797
1798 // setter
1799 inline alloc_packet_pool_x&& packet_size(size_t packet_size_in) { m_packet_size = packet_size_in; return std::move(*this); }
1800 inline alloc_packet_pool_x&& npackets(size_t npackets_in) { m_npackets = npackets_in; return std::move(*this); }
1801 inline alloc_packet_pool_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
1802 inline alloc_packet_pool_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1803 inline alloc_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1804
1805 packet_pool_t call_impl(size_t packet_size, size_t npackets, const char* name, void* user_context, runtime_t runtime) const;
1806 packet_pool_t call() const;
1807 inline packet_pool_t operator()() const { return call(); }
1808};
1809
1813
1814
1824
1830 public:
1831 // args declaration
1834
1835 // constructor
1836 free_packet_pool_x(packet_pool_t* packet_pool_in) : m_packet_pool(packet_pool_in) {}
1837
1838 // setter
1839 inline free_packet_pool_x&& packet_pool(packet_pool_t* packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1840 inline free_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1841
1843 void call() const;
1844 inline void operator()() const { return call(); }
1845};
1846
1847inline void free_packet_pool(packet_pool_t* packet_pool_in) {
1848 return free_packet_pool_x(packet_pool_in).call();
1849}
1850
1851
1862
1868 public:
1869 // args declaration
1873
1874 // constructor
1875 register_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in) : m_packet_pool(packet_pool_in), m_device(device_in) {}
1876
1877 // setter
1878 inline register_packet_pool_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1879 inline register_packet_pool_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1880 inline register_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1881
1883 void call() const;
1884 inline void operator()() const { return call(); }
1885};
1886
1887inline void register_packet_pool(packet_pool_t packet_pool_in, device_t device_in) {
1888 return register_packet_pool_x(packet_pool_in, device_in).call();
1889}
1890
1891
1902
1908 public:
1909 // args declaration
1913
1914 // constructor
1915 deregister_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in) : m_packet_pool(packet_pool_in), m_device(device_in) {}
1916
1917 // setter
1918 inline deregister_packet_pool_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1919 inline deregister_packet_pool_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1920 inline deregister_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1921
1923 void call() const;
1924 inline void operator()() const { return call(); }
1925};
1926
1927inline void deregister_packet_pool(packet_pool_t packet_pool_in, device_t device_in) {
1928 return deregister_packet_pool_x(packet_pool_in, device_in).call();
1929}
1930
1931
1941
1947 public:
1948 // args declaration
1951
1952 // constructor
1954
1955 // setter
1956 inline get_upacket_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1957 inline get_upacket_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1958
1960 void* call() const;
1961 inline void* operator()() const { return call(); }
1962};
1963
1964inline void* get_upacket() {
1965 return get_upacket_x().call();
1966}
1967
1968
1978
1984 public:
1985 // args declaration
1988
1989 // constructor
1990 put_upacket_x(void* packet_in) : m_packet(packet_in) {}
1991
1992 // setter
1993 inline put_upacket_x&& packet(void* packet_in) { m_packet = packet_in; return std::move(*this); }
1994 inline put_upacket_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1995
1996 void call_impl(void* packet, runtime_t runtime) const;
1997 void call() const;
1998 inline void operator()() const { return call(); }
1999};
2000
2001inline void put_upacket(void* packet_in) {
2002 return put_upacket_x(packet_in).call();
2003}
2004
2005
2017
2023 public:
2024 // args declaration
2029
2030 // constructor
2032
2033 // setter
2034 inline alloc_matching_engine_x&& matching_engine_type(attr_matching_engine_type_t matching_engine_type_in) { m_matching_engine_type = matching_engine_type_in; return std::move(*this); }
2035 inline alloc_matching_engine_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2036 inline alloc_matching_engine_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2037 inline alloc_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2038
2040 matching_engine_t call() const;
2041 inline matching_engine_t operator()() const { return call(); }
2042};
2043
2047
2048
2058
2064 public:
2065 // args declaration
2068
2069 // constructor
2070 free_matching_engine_x(matching_engine_t* matching_engine_in) : m_matching_engine(matching_engine_in) {}
2071
2072 // setter
2073 inline free_matching_engine_x&& matching_engine(matching_engine_t* matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2074 inline free_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2075
2077 void call() const;
2078 inline void operator()() const { return call(); }
2079};
2080
2081inline void free_matching_engine(matching_engine_t* matching_engine_in) {
2082 return free_matching_engine_x(matching_engine_in).call();
2083}
2084
2085
2098
2104 public:
2105 // args declaration
2111
2112 // constructor
2113 matching_engine_insert_x(matching_engine_t matching_engine_in, matching_entry_key_t key_in, matching_entry_val_t value_in, matching_entry_type_t entry_type_in) : m_matching_engine(matching_engine_in), m_key(key_in), m_value(value_in), m_entry_type(entry_type_in) {}
2114
2115 // setter
2116 inline matching_engine_insert_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2117 inline matching_engine_insert_x&& key(matching_entry_key_t key_in) { m_key = key_in; return std::move(*this); }
2118 inline matching_engine_insert_x&& value(matching_entry_val_t value_in) { m_value = value_in; return std::move(*this); }
2119 inline matching_engine_insert_x&& entry_type(matching_entry_type_t entry_type_in) { m_entry_type = entry_type_in; return std::move(*this); }
2120 inline matching_engine_insert_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2121
2123 matching_entry_val_t call() const;
2124 inline matching_entry_val_t operator()() const { return call(); }
2125};
2126
2128 return matching_engine_insert_x(matching_engine_in, key_in, value_in, entry_type_in).call();
2129}
2130
2131
2141
2147 public:
2148 // args declaration
2151
2152 // constructor
2153 set_allocator_x(allocator_base_t* allocator_in) : m_allocator(allocator_in) {}
2154
2155 // setter
2156 inline set_allocator_x&& allocator(allocator_base_t* allocator_in) { m_allocator = allocator_in; return std::move(*this); }
2157 inline set_allocator_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2158
2160 void call() const;
2161 inline void operator()() const { return call(); }
2162};
2163
2164inline void set_allocator(allocator_base_t* allocator_in) {
2165 return set_allocator_x(allocator_in).call();
2166}
2167
2168
2177
2183 public:
2184 // args declaration
2186
2187 // constructor
2189
2190 // setter
2191 inline get_allocator_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2192
2194 allocator_base_t* call() const;
2195 inline allocator_base_t* operator()() const { return call(); }
2196};
2197
2199 return get_allocator_x().call();
2200}
2201
2202
2211
2217 public:
2218 // args declaration
2220
2221 // constructor
2223
2224 // setter
2225 inline get_default_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2226
2228 net_context_t call() const;
2229 inline net_context_t operator()() const { return call(); }
2230};
2231
2235
2236
2245
2251 public:
2252 // args declaration
2254
2255 // constructor
2257
2258 // setter
2259 inline get_default_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2260
2262 device_t call() const;
2263 inline device_t operator()() const { return call(); }
2264};
2265
2267 return get_default_device_x().call();
2268}
2269
2270
2280
2286 public:
2287 // args declaration
2290
2291 // constructor
2293
2294 // setter
2295 inline get_default_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2296 inline get_default_endpoint_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2297
2299 endpoint_t call() const;
2300 inline endpoint_t operator()() const { return call(); }
2301};
2302
2306
2307
2316
2322 public:
2323 // args declaration
2325
2326 // constructor
2328
2329 // setter
2330 inline get_default_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2331
2333 packet_pool_t call() const;
2334 inline packet_pool_t operator()() const { return call(); }
2335};
2336
2340
2341
2350
2356 public:
2357 // args declaration
2359
2360 // constructor
2362
2363 // setter
2364 inline get_default_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2365
2367 matching_engine_t call() const;
2368 inline matching_engine_t operator()() const { return call(); }
2369};
2370
2374
2375
2385
2391 public:
2392 // args declaration
2395
2396 // constructor
2398
2399 // setter
2400 inline get_max_bcopy_size_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2401 inline get_max_bcopy_size_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2402
2404 size_t call() const;
2405 inline size_t operator()() const { return call(); }
2406};
2407
2408inline size_t get_max_bcopy_size() {
2409 return get_max_bcopy_size_x().call();
2410}
2411
2412
2426
2432 public:
2433 // args declaration
2440
2441 // constructor
2443
2444 // setter
2445 inline barrier_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2446 inline barrier_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2447 inline barrier_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2448 inline barrier_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2449 inline barrier_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
2450 inline barrier_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2451
2453 void call() const;
2454 inline void operator()() const { return call(); }
2455};
2456
2457inline void barrier() {
2458 return barrier_x().call();
2459}
2460
2461
2479
2485 public:
2486 // args declaration
2488 size_t m_size;
2497
2498 // constructor
2499 broadcast_x(void* buffer_in, size_t size_in, int root_in) : m_buffer(buffer_in), m_size(size_in), m_root(root_in) {}
2500
2501 // setter
2502 inline broadcast_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
2503 inline broadcast_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2504 inline broadcast_x&& root(int root_in) { m_root = root_in; return std::move(*this); }
2505 inline broadcast_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2506 inline broadcast_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2507 inline broadcast_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2508 inline broadcast_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2509 inline broadcast_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2510 inline broadcast_x&& algorithm(broadcast_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
2511 inline broadcast_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
2512
2514 void call() const;
2515 inline void operator()() const { return call(); }
2516};
2517
2518inline void broadcast(void* buffer_in, size_t size_in, int root_in) {
2519 return broadcast_x(buffer_in, size_in, root_in).call();
2520}
2521
2522
2540
2546 public:
2547 // args declaration
2548 const void* m_sendbuf;
2550 size_t m_count;
2558
2559 // constructor
2560 reduce_x(const void* sendbuf_in, void* recvbuf_in, size_t count_in, size_t item_size_in, reduce_op_t op_in, int root_in) : m_sendbuf(sendbuf_in), m_recvbuf(recvbuf_in), m_count(count_in), m_item_size(item_size_in), m_op(op_in), m_root(root_in) {}
2561
2562 // setter
2563 inline reduce_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2564 inline reduce_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2565 inline reduce_x&& count(size_t count_in) { m_count = count_in; return std::move(*this); }
2566 inline reduce_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
2567 inline reduce_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
2568 inline reduce_x&& root(int root_in) { m_root = root_in; return std::move(*this); }
2569 inline reduce_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2570 inline reduce_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2571 inline reduce_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2572 inline reduce_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2573
2575 void call() const;
2576 inline void operator()() const { return call(); }
2577};
2578
2579inline void reduce(const void* sendbuf_in, void* recvbuf_in, size_t count_in, size_t item_size_in, reduce_op_t op_in, int root_in) {
2580 return reduce_x(sendbuf_in, recvbuf_in, count_in, item_size_in, op_in, root_in).call();
2581}
2582
2583
2603
2609 public:
2610 // args declaration
2611 const void* m_sendbuf;
2623
2624 // constructor
2625 reduce_scatter_x(const void* sendbuf_in, void* recvbuf_in, size_t recvcount_in, size_t item_size_in, reduce_op_t op_in) : m_sendbuf(sendbuf_in), m_recvbuf(recvbuf_in), m_recvcount(recvcount_in), m_item_size(item_size_in), m_op(op_in) {}
2626
2627 // setter
2628 inline reduce_scatter_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2629 inline reduce_scatter_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2630 inline reduce_scatter_x&& recvcount(size_t recvcount_in) { m_recvcount = recvcount_in; return std::move(*this); }
2631 inline reduce_scatter_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
2632 inline reduce_scatter_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
2633 inline reduce_scatter_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2634 inline reduce_scatter_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2635 inline reduce_scatter_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2636 inline reduce_scatter_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2637 inline reduce_scatter_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2638 inline reduce_scatter_x&& algorithm(reduce_scatter_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
2639 inline reduce_scatter_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
2640
2642 void call() const;
2643 inline void operator()() const { return call(); }
2644};
2645
2646inline void reduce_scatter(const void* sendbuf_in, void* recvbuf_in, size_t recvcount_in, size_t item_size_in, reduce_op_t op_in) {
2647 return reduce_scatter_x(sendbuf_in, recvbuf_in, recvcount_in, item_size_in, op_in).call();
2648}
2649
2650
2670
2676 public:
2677 // args declaration
2678 const void* m_sendbuf;
2680 size_t m_count;
2690
2691 // constructor
2692 allreduce_x(const void* sendbuf_in, void* recvbuf_in, size_t count_in, size_t item_size_in, reduce_op_t op_in) : m_sendbuf(sendbuf_in), m_recvbuf(recvbuf_in), m_count(count_in), m_item_size(item_size_in), m_op(op_in) {}
2693
2694 // setter
2695 inline allreduce_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2696 inline allreduce_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2697 inline allreduce_x&& count(size_t count_in) { m_count = count_in; return std::move(*this); }
2698 inline allreduce_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
2699 inline allreduce_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
2700 inline allreduce_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2701 inline allreduce_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2702 inline allreduce_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2703 inline allreduce_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2704 inline allreduce_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2705 inline allreduce_x&& algorithm(allreduce_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
2706 inline allreduce_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
2707
2709 void call() const;
2710 inline void operator()() const { return call(); }
2711};
2712
2713inline void allreduce(const void* sendbuf_in, void* recvbuf_in, size_t count_in, size_t item_size_in, reduce_op_t op_in) {
2714 return allreduce_x(sendbuf_in, recvbuf_in, count_in, item_size_in, op_in).call();
2715}
2716
2717
2732
2738 public:
2739 // args declaration
2740 const void* m_sendbuf;
2742 size_t m_size;
2747
2748 // constructor
2749 allgather_x(const void* sendbuf_in, void* recvbuf_in, size_t size_in) : m_sendbuf(sendbuf_in), m_recvbuf(recvbuf_in), m_size(size_in) {}
2750
2751 // setter
2752 inline allgather_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2753 inline allgather_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2754 inline allgather_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2755 inline allgather_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2756 inline allgather_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2757 inline allgather_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2758 inline allgather_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2759
2761 void call() const;
2762 inline void operator()() const { return call(); }
2763};
2764
2765inline void allgather(const void* sendbuf_in, void* recvbuf_in, size_t size_in) {
2766 return allgather_x(sendbuf_in, recvbuf_in, size_in).call();
2767}
2768
2769
2785
2791 public:
2792 // args declaration
2793 const void* m_sendbuf;
2795 size_t m_size;
2801
2802 // constructor
2803 alltoall_x(const void* sendbuf_in, void* recvbuf_in, size_t size_in) : m_sendbuf(sendbuf_in), m_recvbuf(recvbuf_in), m_size(size_in) {}
2804
2805 // setter
2806 inline alltoall_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2807 inline alltoall_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2808 inline alltoall_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2809 inline alltoall_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2810 inline alltoall_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2811 inline alltoall_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2812 inline alltoall_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2813 inline alltoall_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
2814
2816 void call() const;
2817 inline void operator()() const { return call(); }
2818};
2819
2820inline void alltoall(const void* sendbuf_in, void* recvbuf_in, size_t size_in) {
2821 return alltoall_x(sendbuf_in, recvbuf_in, size_in).call();
2822}
2823
2824
2834
2840 public:
2841 // args declaration
2844
2845 // constructor
2846 free_comp_x(comp_t* comp_in) : m_comp(comp_in) {}
2847
2848 // setter
2849 inline free_comp_x&& comp(comp_t* comp_in) { m_comp = comp_in; return std::move(*this); }
2850 inline free_comp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2851
2853 void call() const;
2854 inline void operator()() const { return call(); }
2855};
2856
2857inline void free_comp(comp_t* comp_in) {
2858 return free_comp_x(comp_in).call();
2859}
2860
2861
2872
2878 public:
2879 // args declaration
2883
2884 // constructor
2885 comp_signal_x(comp_t comp_in, status_t status_in) : m_comp(comp_in), m_status(status_in) {}
2886
2887 // setter
2888 inline comp_signal_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2889 inline comp_signal_x&& status(status_t status_in) { m_status = status_in; return std::move(*this); }
2890 inline comp_signal_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2891
2893 void call() const;
2894 inline void operator()() const { return call(); }
2895};
2896
2897inline void comp_signal(comp_t comp_in, status_t status_in) {
2898 return comp_signal_x(comp_in, status_in).call();
2899}
2900
2901
2911
2917 public:
2918 // args declaration
2921
2922 // constructor
2924
2925 // setter
2926 inline reserve_rcomps_x&& n(rcomp_t n_in) { m_n = n_in; return std::move(*this); }
2927 inline reserve_rcomps_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2928
2930 rcomp_t call() const;
2931 inline rcomp_t operator()() const { return call(); }
2932};
2933
2935 return reserve_rcomps_x(n_in).call();
2936}
2937
2938
2949
2955 public:
2956 // args declaration
2960
2961 // constructor
2962 register_rcomp_x(comp_t comp_in) : m_comp(comp_in) {}
2963
2964 // setter
2965 inline register_rcomp_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2966 inline register_rcomp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2967 inline register_rcomp_x&& rcomp(rcomp_t rcomp_in) { m_rcomp = rcomp_in; return std::move(*this); }
2968
2970 rcomp_t call() const;
2971 inline rcomp_t operator()() const { return call(); }
2972};
2973
2975 return register_rcomp_x(comp_in).call();
2976}
2977
2978
2988
2994 public:
2995 // args declaration
2998
2999 // constructor
3000 deregister_rcomp_x(rcomp_t rcomp_in) : m_rcomp(rcomp_in) {}
3001
3002 // setter
3003 inline deregister_rcomp_x&& rcomp(rcomp_t rcomp_in) { m_rcomp = rcomp_in; return std::move(*this); }
3004 inline deregister_rcomp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3005
3007 void call() const;
3008 inline void operator()() const { return call(); }
3009};
3010
3011inline void deregister_rcomp(rcomp_t rcomp_in) {
3012 return deregister_rcomp_x(rcomp_in).call();
3013}
3014
3015
3028
3034 public:
3035 // args declaration
3041
3042 // constructor
3044
3045 // setter
3046 inline alloc_sync_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3047 inline alloc_sync_x&& threshold(int threshold_in) { m_threshold = threshold_in; return std::move(*this); }
3048 inline alloc_sync_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
3049 inline alloc_sync_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3050 inline alloc_sync_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3051
3053 comp_t call() const;
3054 inline comp_t operator()() const { return call(); }
3055};
3056
3058 return alloc_sync_x().call();
3059}
3060
3061
3072
3078 public:
3079 // args declaration
3083
3084 // constructor
3085 sync_test_x(comp_t comp_in, status_t* p_out_in) : m_comp(comp_in), m_p_out(p_out_in) {}
3086
3087 // setter
3088 inline sync_test_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3089 inline sync_test_x&& p_out(status_t* p_out_in) { m_p_out = p_out_in; return std::move(*this); }
3090 inline sync_test_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3091
3093 bool call() const;
3094 inline bool operator()() const { return call(); }
3095};
3096
3097inline bool sync_test(comp_t comp_in, status_t* p_out_in) {
3098 return sync_test_x(comp_in, p_out_in).call();
3099}
3100
3101
3114
3120 public:
3121 // args declaration
3127
3128 // constructor
3129 sync_wait_x(comp_t comp_in, status_t* p_out_in) : m_comp(comp_in), m_p_out(p_out_in) {}
3130
3131 // setter
3132 inline sync_wait_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3133 inline sync_wait_x&& p_out(status_t* p_out_in) { m_p_out = p_out_in; return std::move(*this); }
3134 inline sync_wait_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3135 inline sync_wait_x&& do_progress(bool do_progress_in) { m_do_progress = do_progress_in; return std::move(*this); }
3136 inline sync_wait_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3137
3139 void call() const;
3140 inline void operator()() const { return call(); }
3141};
3142
3143inline void sync_wait(comp_t comp_in, status_t* p_out_in) {
3144 return sync_wait_x(comp_in, p_out_in).call();
3145}
3146
3147
3158
3164 public:
3165 // args declaration
3169
3170 // constructor
3172
3173 // setter
3174 inline alloc_counter_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3175 inline alloc_counter_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3176 inline alloc_counter_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3177
3179 comp_t call() const;
3180 inline comp_t operator()() const { return call(); }
3181};
3182
3184 return alloc_counter_x().call();
3185}
3186
3187
3197
3203 public:
3204 // args declaration
3207
3208 // constructor
3209 counter_get_x(comp_t comp_in) : m_comp(comp_in) {}
3210
3211 // setter
3212 inline counter_get_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3213 inline counter_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3214
3216 int64_t call() const;
3217 inline int64_t operator()() const { return call(); }
3218};
3219
3220inline int64_t counter_get(comp_t comp_in) {
3221 return counter_get_x(comp_in).call();
3222}
3223
3224
3235
3241 public:
3242 // args declaration
3244 int64_t m_value;
3246
3247 // constructor
3248 counter_set_x(comp_t comp_in, int64_t value_in) : m_comp(comp_in), m_value(value_in) {}
3249
3250 // setter
3251 inline counter_set_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3252 inline counter_set_x&& value(int64_t value_in) { m_value = value_in; return std::move(*this); }
3253 inline counter_set_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3254
3256 void call() const;
3257 inline void operator()() const { return call(); }
3258};
3259
3260inline void counter_set(comp_t comp_in, int64_t value_in) {
3261 return counter_set_x(comp_in, value_in).call();
3262}
3263
3264
3278
3284 public:
3285 // args declaration
3292
3293 // constructor
3295
3296 // setter
3297 inline alloc_cq_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3298 inline alloc_cq_x&& default_length(int default_length_in) { m_default_length = default_length_in; return std::move(*this); }
3299 inline alloc_cq_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
3300 inline alloc_cq_x&& cq_type(attr_cq_type_t cq_type_in) { m_cq_type = cq_type_in; return std::move(*this); }
3301 inline alloc_cq_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3302 inline alloc_cq_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3303
3305 comp_t call() const;
3306 inline comp_t operator()() const { return call(); }
3307};
3308
3310 return alloc_cq_x().call();
3311}
3312
3313
3323
3329 public:
3330 // args declaration
3333
3334 // constructor
3335 cq_pop_x(comp_t comp_in) : m_comp(comp_in) {}
3336
3337 // setter
3338 inline cq_pop_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3339 inline cq_pop_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3340
3342 status_t call() const;
3343 inline status_t operator()() const { return call(); }
3344};
3345
3346inline status_t cq_pop(comp_t comp_in) {
3347 return cq_pop_x(comp_in).call();
3348}
3349
3350
3363
3369 public:
3370 // args declaration
3376
3377 // constructor
3378 alloc_handler_x(comp_handler_t handler_in) : m_handler(handler_in) {}
3379
3380 // setter
3381 inline alloc_handler_x&& handler(comp_handler_t handler_in) { m_handler = handler_in; return std::move(*this); }
3382 inline alloc_handler_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3383 inline alloc_handler_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
3384 inline alloc_handler_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3385 inline alloc_handler_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3386
3388 comp_t call() const;
3389 inline comp_t operator()() const { return call(); }
3390};
3391
3393 return alloc_handler_x(handler_in).call();
3394}
3395
3396
3408
3414 public:
3415 // args declaration
3420
3421 // constructor
3423
3424 // setter
3425 inline alloc_graph_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3426 inline alloc_graph_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3427 inline alloc_graph_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3428 inline alloc_graph_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3429
3431 comp_t call() const;
3432 inline comp_t operator()() const { return call(); }
3433};
3434
3436 return alloc_graph_x().call();
3437}
3438
3439
3452
3458 public:
3459 // args declaration
3465
3466 // constructor
3467 graph_add_node_x(comp_t comp_in, graph_node_run_cb_t fn_in) : m_comp(comp_in), m_fn(fn_in) {}
3468
3469 // setter
3470 inline graph_add_node_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3471 inline graph_add_node_x&& fn(graph_node_run_cb_t fn_in) { m_fn = fn_in; return std::move(*this); }
3472 inline graph_add_node_x&& value(void* value_in) { m_value = value_in; return std::move(*this); }
3473 inline graph_add_node_x&& free_cb(graph_node_free_cb_t free_cb_in) { m_free_cb = free_cb_in; return std::move(*this); }
3474 inline graph_add_node_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3475
3477 graph_node_t call() const;
3478 inline graph_node_t operator()() const { return call(); }
3479};
3480
3482 return graph_add_node_x(comp_in, fn_in).call();
3483}
3484
3485
3498
3504 public:
3505 // args declaration
3511
3512 // constructor
3513 graph_add_edge_x(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in) : m_comp(comp_in), m_src(src_in), m_dst(dst_in) {}
3514
3515 // setter
3516 inline graph_add_edge_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3517 inline graph_add_edge_x&& src(graph_node_t src_in) { m_src = src_in; return std::move(*this); }
3518 inline graph_add_edge_x&& dst(graph_node_t dst_in) { m_dst = dst_in; return std::move(*this); }
3519 inline graph_add_edge_x&& fn(graph_edge_run_cb_t fn_in) { m_fn = fn_in; return std::move(*this); }
3520 inline graph_add_edge_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3521
3523 void call() const;
3524 inline void operator()() const { return call(); }
3525};
3526
3527inline void graph_add_edge(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in) {
3528 return graph_add_edge_x(comp_in, src_in, dst_in).call();
3529}
3530
3531
3542
3548 public:
3549 // args declaration
3553
3554 // constructor
3556
3557 // setter
3558 inline graph_node_mark_complete_x&& node(graph_node_t node_in) { m_node = node_in; return std::move(*this); }
3559 inline graph_node_mark_complete_x&& status(status_t status_in) { m_status = status_in; return std::move(*this); }
3560 inline graph_node_mark_complete_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3561
3563 void call() const;
3564 inline void operator()() const { return call(); }
3565};
3566
3568 return graph_node_mark_complete_x(node_in).call();
3569}
3570
3571
3581
3587 public:
3588 // args declaration
3591
3592 // constructor
3593 graph_start_x(comp_t comp_in) : m_comp(comp_in) {}
3594
3595 // setter
3596 inline graph_start_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3597 inline graph_start_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3598
3600 void call() const;
3601 inline void operator()() const { return call(); }
3602};
3603
3604inline void graph_start(comp_t comp_in) {
3605 return graph_start_x(comp_in).call();
3606}
3607
3608
3618
3624 public:
3625 // args declaration
3628
3629 // constructor
3630 graph_test_x(comp_t comp_in) : m_comp(comp_in) {}
3631
3632 // setter
3633 inline graph_test_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3634 inline graph_test_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3635
3637 status_t call() const;
3638 inline status_t operator()() const { return call(); }
3639};
3640
3641inline status_t graph_test(comp_t comp_in) {
3642 return graph_test_x(comp_in).call();
3643}
3644
3645
3646} // namespace lci
3647
3648#endif // LCI_BINDING_POST_HPP_
The actual implementation for allgather.
Definition lci_binding_post.hpp:2737
allgather_x && size(size_t size_in)
Definition lci_binding_post.hpp:2754
allgather_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2753
void * m_recvbuf
Definition lci_binding_post.hpp:2741
size_t m_size
Definition lci_binding_post.hpp:2742
void call() const
Definition binding.cpp:804
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2743
const void * m_sendbuf
Definition lci_binding_post.hpp:2740
allgather_x && device(device_t device_in)
Definition lci_binding_post.hpp:2756
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2746
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2745
allgather_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2755
allgather_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2757
allgather_x(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:2749
allgather_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2758
void call_impl(const void *sendbuf, void *recvbuf, size_t size, runtime_t runtime, device_t device, endpoint_t endpoint, matching_engine_t matching_engine) const
option_t< device_t > m_device
Definition lci_binding_post.hpp:2744
void operator()() const
Definition lci_binding_post.hpp:2762
allgather_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2752
The actual implementation for alloc_counter.
Definition lci_binding_post.hpp:3163
alloc_counter_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3174
alloc_counter_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3176
option_t< const char * > m_name
Definition lci_binding_post.hpp:3167
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3166
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3168
comp_t operator()() const
Definition lci_binding_post.hpp:3180
comp_t call_impl(runtime_t runtime, const char *name, void *user_context) const
comp_t call() const
Definition binding.cpp:893
alloc_counter_x && name(const char *name_in)
Definition lci_binding_post.hpp:3175
alloc_counter_x()
Definition lci_binding_post.hpp:3171
The actual implementation for alloc_cq.
Definition lci_binding_post.hpp:3283
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3286
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:3288
alloc_cq_x && cq_type(attr_cq_type_t cq_type_in)
Definition lci_binding_post.hpp:3300
alloc_cq_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:3299
comp_t operator()() const
Definition lci_binding_post.hpp:3306
option_t< int > m_default_length
Definition lci_binding_post.hpp:3287
option_t< attr_cq_type_t > m_cq_type
Definition lci_binding_post.hpp:3289
alloc_cq_x && default_length(int default_length_in)
Definition lci_binding_post.hpp:3298
comp_t call_impl(runtime_t runtime, int default_length, bool zero_copy_am, attr_cq_type_t cq_type, const char *name, void *user_context) const
alloc_cq_x && name(const char *name_in)
Definition lci_binding_post.hpp:3301
alloc_cq_x()
Definition lci_binding_post.hpp:3294
comp_t call() const
Definition binding.cpp:913
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3291
alloc_cq_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3302
option_t< const char * > m_name
Definition lci_binding_post.hpp:3290
alloc_cq_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3297
The actual implementation for alloc_device.
Definition lci_binding_post.hpp:764
alloc_device_x && alloc_default_endpoint(bool alloc_default_endpoint_in)
Definition lci_binding_post.hpp:791
alloc_device_x()
Definition lci_binding_post.hpp:783
option_t< bool > m_use_reg_cache
Definition lci_binding_post.hpp:774
option_t< const char * > m_name
Definition lci_binding_post.hpp:776
option_t< bool > m_alloc_progress_endpoint
Definition lci_binding_post.hpp:773
option_t< net_context_t > m_net_context
Definition lci_binding_post.hpp:779
alloc_device_x && net_max_recvs(size_t net_max_recvs_in)
Definition lci_binding_post.hpp:787
option_t< attr_ibv_td_strategy_t > m_ibv_td_strategy
Definition lci_binding_post.hpp:775
alloc_device_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:796
option_t< size_t > m_net_max_recvs
Definition lci_binding_post.hpp:768
alloc_device_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:799
alloc_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:797
alloc_device_x && use_reg_cache(bool use_reg_cache_in)
Definition lci_binding_post.hpp:793
alloc_device_x && name(const char *name_in)
Definition lci_binding_post.hpp:795
option_t< double > m_net_send_reserved_pct
Definition lci_binding_post.hpp:770
alloc_device_x && ofi_lock_mode(uint64_t ofi_lock_mode_in)
Definition lci_binding_post.hpp:790
option_t< uint64_t > m_ofi_lock_mode
Definition lci_binding_post.hpp:771
option_t< void * > m_user_context
Definition lci_binding_post.hpp:777
option_t< size_t > m_net_max_sends
Definition lci_binding_post.hpp:767
alloc_device_x && net_send_reserved_pct(double net_send_reserved_pct_in)
Definition lci_binding_post.hpp:789
device_t call_impl(size_t net_max_sends, size_t net_max_recvs, size_t net_max_cqes, double net_send_reserved_pct, uint64_t ofi_lock_mode, bool alloc_default_endpoint, bool alloc_progress_endpoint, bool use_reg_cache, attr_ibv_td_strategy_t ibv_td_strategy, const char *name, void *user_context, runtime_t runtime, net_context_t net_context, packet_pool_t packet_pool) const
alloc_device_x && alloc_progress_endpoint(bool alloc_progress_endpoint_in)
Definition lci_binding_post.hpp:792
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:780
option_t< size_t > m_net_max_cqes
Definition lci_binding_post.hpp:769
alloc_device_x && net_context(net_context_t net_context_in)
Definition lci_binding_post.hpp:798
option_t< bool > m_alloc_default_endpoint
Definition lci_binding_post.hpp:772
device_t operator()() const
Definition lci_binding_post.hpp:803
device_t call() const
Definition binding.cpp:378
alloc_device_x && net_max_cqes(size_t net_max_cqes_in)
Definition lci_binding_post.hpp:788
alloc_device_x && ibv_td_strategy(attr_ibv_td_strategy_t ibv_td_strategy_in)
Definition lci_binding_post.hpp:794
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:778
alloc_device_x && net_max_sends(size_t net_max_sends_in)
Definition lci_binding_post.hpp:786
The actual implementation for alloc_endpoint.
Definition lci_binding_post.hpp:981
endpoint_t call() const
Definition binding.cpp:431
alloc_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:995
endpoint_t call_impl(const char *name, void *user_context, runtime_t runtime, device_t device) const
option_t< void * > m_user_context
Definition lci_binding_post.hpp:985
alloc_endpoint_x()
Definition lci_binding_post.hpp:990
option_t< device_t > m_device
Definition lci_binding_post.hpp:987
option_t< const char * > m_name
Definition lci_binding_post.hpp:984
alloc_endpoint_x && device(device_t device_in)
Definition lci_binding_post.hpp:996
endpoint_t operator()() const
Definition lci_binding_post.hpp:1000
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:986
alloc_endpoint_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:994
alloc_endpoint_x && name(const char *name_in)
Definition lci_binding_post.hpp:993
The actual implementation for alloc_graph.
Definition lci_binding_post.hpp:3413
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3419
alloc_graph_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3428
comp_t call() const
Definition binding.cpp:938
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3418
alloc_graph_x && name(const char *name_in)
Definition lci_binding_post.hpp:3426
alloc_graph_x()
Definition lci_binding_post.hpp:3422
comp_t call_impl(comp_t comp, const char *name, void *user_context, runtime_t runtime) const
alloc_graph_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3427
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:3416
alloc_graph_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3425
comp_t operator()() const
Definition lci_binding_post.hpp:3432
option_t< const char * > m_name
Definition lci_binding_post.hpp:3417
The actual implementation for alloc_handler.
Definition lci_binding_post.hpp:3368
comp_t call_impl(comp_handler_t handler, runtime_t runtime, bool zero_copy_am, const char *name, void *user_context) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3372
option_t< const char * > m_name
Definition lci_binding_post.hpp:3374
alloc_handler_x && handler(comp_handler_t handler_in)
Definition lci_binding_post.hpp:3381
alloc_handler_x(comp_handler_t handler_in)
Definition lci_binding_post.hpp:3378
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3375
comp_t call() const
Definition binding.cpp:929
comp_t operator()() const
Definition lci_binding_post.hpp:3389
alloc_handler_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:3383
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:3373
alloc_handler_x && name(const char *name_in)
Definition lci_binding_post.hpp:3384
alloc_handler_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3385
alloc_handler_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3382
comp_handler_t m_handler
Definition lci_binding_post.hpp:3371
The actual implementation for alloc_matching_engine.
Definition lci_binding_post.hpp:2022
matching_engine_t operator()() const
Definition lci_binding_post.hpp:2041
matching_engine_t call() const
Definition binding.cpp:668
alloc_matching_engine_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2036
option_t< attr_matching_engine_type_t > m_matching_engine_type
Definition lci_binding_post.hpp:2025
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2027
alloc_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2037
alloc_matching_engine_x && name(const char *name_in)
Definition lci_binding_post.hpp:2035
option_t< const char * > m_name
Definition lci_binding_post.hpp:2026
matching_engine_t call_impl(attr_matching_engine_type_t matching_engine_type, const char *name, void *user_context, runtime_t runtime) const
alloc_matching_engine_x && matching_engine_type(attr_matching_engine_type_t matching_engine_type_in)
Definition lci_binding_post.hpp:2034
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2028
alloc_matching_engine_x()
Definition lci_binding_post.hpp:2031
The actual implementation for alloc_net_context.
Definition lci_binding_post.hpp:658
alloc_net_context_x && ofi_provider_name(std::string ofi_provider_name_in)
Definition lci_binding_post.hpp:679
option_t< int > m_ibv_gid_idx
Definition lci_binding_post.hpp:665
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:672
alloc_net_context_x && ibv_prefetch_strategy(attr_ibv_prefetch_strategy_t ibv_prefetch_strategy_in)
Definition lci_binding_post.hpp:685
alloc_net_context_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:689
option_t< attr_ibv_odp_strategy_t > m_ibv_odp_strategy
Definition lci_binding_post.hpp:667
alloc_net_context_x && ibv_gid_idx(int ibv_gid_idx_in)
Definition lci_binding_post.hpp:682
alloc_net_context_x()
Definition lci_binding_post.hpp:675
alloc_net_context_x && max_inject_size(size_t max_inject_size_in)
Definition lci_binding_post.hpp:681
option_t< void * > m_user_context
Definition lci_binding_post.hpp:671
alloc_net_context_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:688
option_t< bool > m_use_dmabuf
Definition lci_binding_post.hpp:669
alloc_net_context_x && backend(attr_backend_t backend_in)
Definition lci_binding_post.hpp:678
option_t< const char * > m_name
Definition lci_binding_post.hpp:670
alloc_net_context_x && ibv_force_gid_auto_select(bool ibv_force_gid_auto_select_in)
Definition lci_binding_post.hpp:683
alloc_net_context_x && name(const char *name_in)
Definition lci_binding_post.hpp:687
alloc_net_context_x && ibv_odp_strategy(attr_ibv_odp_strategy_t ibv_odp_strategy_in)
Definition lci_binding_post.hpp:684
alloc_net_context_x && use_dmabuf(bool use_dmabuf_in)
Definition lci_binding_post.hpp:686
option_t< attr_backend_t > m_backend
Definition lci_binding_post.hpp:661
alloc_net_context_x && max_msg_size(size_t max_msg_size_in)
Definition lci_binding_post.hpp:680
net_context_t call() const
Definition binding.cpp:342
net_context_t call_impl(attr_backend_t backend, std::string ofi_provider_name, size_t max_msg_size, size_t max_inject_size, int ibv_gid_idx, bool ibv_force_gid_auto_select, attr_ibv_odp_strategy_t ibv_odp_strategy, attr_ibv_prefetch_strategy_t ibv_prefetch_strategy, bool use_dmabuf, const char *name, void *user_context, runtime_t runtime) const
option_t< std::string > m_ofi_provider_name
Definition lci_binding_post.hpp:662
option_t< bool > m_ibv_force_gid_auto_select
Definition lci_binding_post.hpp:666
option_t< size_t > m_max_inject_size
Definition lci_binding_post.hpp:664
net_context_t operator()() const
Definition lci_binding_post.hpp:693
option_t< size_t > m_max_msg_size
Definition lci_binding_post.hpp:663
option_t< attr_ibv_prefetch_strategy_t > m_ibv_prefetch_strategy
Definition lci_binding_post.hpp:668
The actual implementation for alloc_packet_pool.
Definition lci_binding_post.hpp:1786
packet_pool_t call() const
Definition binding.cpp:622
alloc_packet_pool_x()
Definition lci_binding_post.hpp:1796
packet_pool_t call_impl(size_t packet_size, size_t npackets, const char *name, void *user_context, runtime_t runtime) const
alloc_packet_pool_x && npackets(size_t npackets_in)
Definition lci_binding_post.hpp:1800
alloc_packet_pool_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1802
alloc_packet_pool_x && packet_size(size_t packet_size_in)
Definition lci_binding_post.hpp:1799
alloc_packet_pool_x && name(const char *name_in)
Definition lci_binding_post.hpp:1801
option_t< size_t > m_packet_size
Definition lci_binding_post.hpp:1789
alloc_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1803
option_t< const char * > m_name
Definition lci_binding_post.hpp:1791
packet_pool_t operator()() const
Definition lci_binding_post.hpp:1807
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1792
option_t< size_t > m_npackets
Definition lci_binding_post.hpp:1790
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1793
The actual implementation for alloc_runtime.
Definition lci_binding_post.hpp:1576
alloc_runtime_x && imm_nbits_tag(int imm_nbits_tag_in)
Definition lci_binding_post.hpp:1594
alloc_runtime_x && imm_nbits_rcomp(int imm_nbits_rcomp_in)
Definition lci_binding_post.hpp:1595
option_t< bool > m_alloc_default_packet_pool
Definition lci_binding_post.hpp:1584
alloc_runtime_x && name(const char *name_in)
Definition lci_binding_post.hpp:1600
runtime_t operator()() const
Definition lci_binding_post.hpp:1605
option_t< bool > m_alloc_default_matching_engine
Definition lci_binding_post.hpp:1585
runtime_t call() const
Definition binding.cpp:573
alloc_runtime_x && alloc_default_packet_pool(bool alloc_default_packet_pool_in)
Definition lci_binding_post.hpp:1598
alloc_runtime_x && rdv_protocol(attr_rdv_protocol_t rdv_protocol_in)
Definition lci_binding_post.hpp:1596
alloc_runtime_x()
Definition lci_binding_post.hpp:1590
runtime_t call_impl(size_t packet_return_threshold, int imm_nbits_tag, int imm_nbits_rcomp, attr_rdv_protocol_t rdv_protocol, bool alloc_default_device, bool alloc_default_packet_pool, bool alloc_default_matching_engine, const char *name, void *user_context) const
alloc_runtime_x && alloc_default_matching_engine(bool alloc_default_matching_engine_in)
Definition lci_binding_post.hpp:1599
alloc_runtime_x && alloc_default_device(bool alloc_default_device_in)
Definition lci_binding_post.hpp:1597
alloc_runtime_x && packet_return_threshold(size_t packet_return_threshold_in)
Definition lci_binding_post.hpp:1593
option_t< const char * > m_name
Definition lci_binding_post.hpp:1586
alloc_runtime_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1601
option_t< bool > m_alloc_default_device
Definition lci_binding_post.hpp:1583
option_t< attr_rdv_protocol_t > m_rdv_protocol
Definition lci_binding_post.hpp:1582
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1587
option_t< int > m_imm_nbits_rcomp
Definition lci_binding_post.hpp:1581
option_t< size_t > m_packet_return_threshold
Definition lci_binding_post.hpp:1579
option_t< int > m_imm_nbits_tag
Definition lci_binding_post.hpp:1580
The actual implementation for alloc_sync.
Definition lci_binding_post.hpp:3033
comp_t operator()() const
Definition lci_binding_post.hpp:3054
option_t< int > m_threshold
Definition lci_binding_post.hpp:3037
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3040
alloc_sync_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3050
alloc_sync_x && threshold(int threshold_in)
Definition lci_binding_post.hpp:3047
alloc_sync_x && name(const char *name_in)
Definition lci_binding_post.hpp:3049
comp_t call_impl(runtime_t runtime, int threshold, bool zero_copy_am, const char *name, void *user_context) const
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:3038
alloc_sync_x()
Definition lci_binding_post.hpp:3043
option_t< const char * > m_name
Definition lci_binding_post.hpp:3039
alloc_sync_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:3048
alloc_sync_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3046
comp_t call() const
Definition binding.cpp:868
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3036
The actual implementation for allreduce.
Definition lci_binding_post.hpp:2675
void call_impl(const void *sendbuf, void *recvbuf, size_t count, size_t item_size, reduce_op_t op, runtime_t runtime, device_t device, endpoint_t endpoint, matching_engine_t matching_engine, comp_t comp, allreduce_algorithm_t algorithm, int ring_nsteps) const
allreduce_x && item_size(size_t item_size_in)
Definition lci_binding_post.hpp:2698
void operator()() const
Definition lci_binding_post.hpp:2710
const void * m_sendbuf
Definition lci_binding_post.hpp:2678
option_t< device_t > m_device
Definition lci_binding_post.hpp:2684
allreduce_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2695
reduce_op_t m_op
Definition lci_binding_post.hpp:2682
void * m_recvbuf
Definition lci_binding_post.hpp:2679
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:2689
allreduce_x(const void *sendbuf_in, void *recvbuf_in, size_t count_in, size_t item_size_in, reduce_op_t op_in)
Definition lci_binding_post.hpp:2692
allreduce_x && device(device_t device_in)
Definition lci_binding_post.hpp:2701
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2686
size_t m_count
Definition lci_binding_post.hpp:2680
allreduce_x && count(size_t count_in)
Definition lci_binding_post.hpp:2697
allreduce_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2696
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2685
allreduce_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2702
option_t< allreduce_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:2688
allreduce_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:2699
allreduce_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2700
allreduce_x && algorithm(allreduce_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:2705
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2683
allreduce_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:2706
size_t m_item_size
Definition lci_binding_post.hpp:2681
allreduce_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2704
void call() const
Definition binding.cpp:788
allreduce_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2703
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2687
The actual implementation for alltoall.
Definition lci_binding_post.hpp:2790
const void * m_sendbuf
Definition lci_binding_post.hpp:2793
void call() const
Definition binding.cpp:815
alltoall_x && device(device_t device_in)
Definition lci_binding_post.hpp:2810
alltoall_x && size(size_t size_in)
Definition lci_binding_post.hpp:2808
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2799
alltoall_x(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:2803
void * m_recvbuf
Definition lci_binding_post.hpp:2794
alltoall_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2807
option_t< device_t > m_device
Definition lci_binding_post.hpp:2797
alltoall_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2812
alltoall_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2811
alltoall_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2809
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2796
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2798
alltoall_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2806
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:2800
alltoall_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:2813
size_t m_size
Definition lci_binding_post.hpp:2795
void operator()() const
Definition lci_binding_post.hpp:2817
void call_impl(const void *sendbuf, void *recvbuf, size_t size, runtime_t runtime, device_t device, endpoint_t endpoint, matching_engine_t matching_engine, comp_semantic_t comp_semantic) const
The actual implementation for barrier.
Definition lci_binding_post.hpp:2431
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2439
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2437
barrier_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2448
barrier_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2450
barrier_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:2449
void call_impl(runtime_t runtime, device_t device, endpoint_t endpoint, matching_engine_t matching_engine, comp_semantic_t comp_semantic, comp_t comp) const
option_t< device_t > m_device
Definition lci_binding_post.hpp:2435
void call() const
Definition binding.cpp:734
barrier_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2447
barrier_x()
Definition lci_binding_post.hpp:2442
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2436
barrier_x && device(device_t device_in)
Definition lci_binding_post.hpp:2446
void operator()() const
Definition lci_binding_post.hpp:2454
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:2438
barrier_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2445
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2434
The actual implementation for broadcast.
Definition lci_binding_post.hpp:2484
broadcast_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2508
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2492
void call() const
Definition binding.cpp:744
void operator()() const
Definition lci_binding_post.hpp:2515
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2493
int m_root
Definition lci_binding_post.hpp:2489
broadcast_x && root(int root_in)
Definition lci_binding_post.hpp:2504
broadcast_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2509
broadcast_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2505
broadcast_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:2511
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2490
broadcast_x && size(size_t size_in)
Definition lci_binding_post.hpp:2503
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:2496
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2494
void call_impl(void *buffer, size_t size, int root, runtime_t runtime, device_t device, endpoint_t endpoint, matching_engine_t matching_engine, comp_t comp, broadcast_algorithm_t algorithm, int ring_nsteps) const
broadcast_x(void *buffer_in, size_t size_in, int root_in)
Definition lci_binding_post.hpp:2499
broadcast_x && device(device_t device_in)
Definition lci_binding_post.hpp:2506
option_t< broadcast_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:2495
void * m_buffer
Definition lci_binding_post.hpp:2487
option_t< device_t > m_device
Definition lci_binding_post.hpp:2491
broadcast_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:2502
broadcast_x && algorithm(broadcast_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:2510
broadcast_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2507
size_t m_size
Definition lci_binding_post.hpp:2488
The actual implementation for comp_signal.
Definition lci_binding_post.hpp:2877
comp_signal_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2890
comp_signal_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2888
status_t m_status
Definition lci_binding_post.hpp:2881
comp_t m_comp
Definition lci_binding_post.hpp:2880
void call() const
Definition binding.cpp:842
comp_signal_x(comp_t comp_in, status_t status_in)
Definition lci_binding_post.hpp:2885
void call_impl(comp_t comp, status_t status, runtime_t runtime) const
void operator()() const
Definition lci_binding_post.hpp:2894
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2882
comp_signal_x && status(status_t status_in)
Definition lci_binding_post.hpp:2889
The actual implementation for RESOURCE comp.
Definition lci_binding_pre.hpp:512
The actual implementation for counter_get.
Definition lci_binding_post.hpp:3202
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3206
int64_t call_impl(comp_t comp, runtime_t runtime) const
int64_t operator()() const
Definition lci_binding_post.hpp:3217
counter_get_x(comp_t comp_in)
Definition lci_binding_post.hpp:3209
int64_t call() const
Definition binding.cpp:900
counter_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3213
comp_t m_comp
Definition lci_binding_post.hpp:3205
counter_get_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3212
The actual implementation for counter_set.
Definition lci_binding_post.hpp:3240
counter_set_x(comp_t comp_in, int64_t value_in)
Definition lci_binding_post.hpp:3248
int64_t m_value
Definition lci_binding_post.hpp:3244
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3245
comp_t m_comp
Definition lci_binding_post.hpp:3243
void call_impl(comp_t comp, int64_t value, runtime_t runtime) const
counter_set_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3253
counter_set_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3251
void operator()() const
Definition lci_binding_post.hpp:3257
counter_set_x && value(int64_t value_in)
Definition lci_binding_post.hpp:3252
void call() const
Definition binding.cpp:906
The actual implementation for cq_pop.
Definition lci_binding_post.hpp:3328
status_t operator()() const
Definition lci_binding_post.hpp:3343
comp_t m_comp
Definition lci_binding_post.hpp:3331
status_t call_impl(comp_t comp, runtime_t runtime) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3332
cq_pop_x(comp_t comp_in)
Definition lci_binding_post.hpp:3335
cq_pop_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3338
cq_pop_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3339
status_t call() const
Definition binding.cpp:923
The actual implementation for deregister_memory.
Definition lci_binding_post.hpp:905
void operator()() const
Definition lci_binding_post.hpp:920
void call() const
Definition binding.cpp:414
mr_t * m_mr
Definition lci_binding_post.hpp:908
deregister_memory_x && mr(mr_t *mr_in)
Definition lci_binding_post.hpp:915
deregister_memory_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:916
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:909
void call_impl(mr_t *mr, runtime_t runtime) const
deregister_memory_x(mr_t *mr_in)
Definition lci_binding_post.hpp:912
The actual implementation for deregister_packet_pool.
Definition lci_binding_post.hpp:1907
deregister_packet_pool_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1918
void call_impl(packet_pool_t packet_pool, device_t device, runtime_t runtime) const
packet_pool_t m_packet_pool
Definition lci_binding_post.hpp:1910
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1912
void operator()() const
Definition lci_binding_post.hpp:1924
void call() const
Definition binding.cpp:644
deregister_packet_pool_x && device(device_t device_in)
Definition lci_binding_post.hpp:1919
device_t m_device
Definition lci_binding_post.hpp:1911
deregister_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1920
deregister_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:1915
The actual implementation for deregister_rcomp.
Definition lci_binding_post.hpp:2993
deregister_rcomp_x(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:3000
void operator()() const
Definition lci_binding_post.hpp:3008
rcomp_t m_rcomp
Definition lci_binding_post.hpp:2996
void call_impl(rcomp_t rcomp, runtime_t runtime) const
void call() const
Definition binding.cpp:862
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2997
deregister_rcomp_x && rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:3003
deregister_rcomp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3004
The actual implementation for RESOURCE device.
Definition lci_binding_pre.hpp:269
The actual implementation for RESOURCE endpoint.
Definition lci_binding_pre.hpp:346
The actual implementation for free_comp.
Definition lci_binding_post.hpp:2839
free_comp_x(comp_t *comp_in)
Definition lci_binding_post.hpp:2846
free_comp_x && comp(comp_t *comp_in)
Definition lci_binding_post.hpp:2849
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2843
comp_t * m_comp
Definition lci_binding_post.hpp:2842
void call() const
Definition binding.cpp:836
free_comp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2850
void operator()() const
Definition lci_binding_post.hpp:2854
void call_impl(comp_t *comp, runtime_t runtime) const
The actual implementation for free_device.
Definition lci_binding_post.hpp:825
void call_impl(device_t *device, runtime_t runtime) const
free_device_x && device(device_t *device_in)
Definition lci_binding_post.hpp:835
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:829
device_t * m_device
Definition lci_binding_post.hpp:828
void operator()() const
Definition lci_binding_post.hpp:840
void call() const
Definition binding.cpp:396
free_device_x(device_t *device_in)
Definition lci_binding_post.hpp:832
free_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:836
The actual implementation for free_endpoint.
Definition lci_binding_post.hpp:1022
void operator()() const
Definition lci_binding_post.hpp:1037
endpoint_t * m_endpoint
Definition lci_binding_post.hpp:1025
free_endpoint_x && endpoint(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:1032
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1026
free_endpoint_x(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:1029
void call_impl(endpoint_t *endpoint, runtime_t runtime) const
void call() const
Definition binding.cpp:439
free_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1033
The actual implementation for free_matching_engine.
Definition lci_binding_post.hpp:2063
void call_impl(matching_engine_t *matching_engine, runtime_t runtime) const
free_matching_engine_x && matching_engine(matching_engine_t *matching_engine_in)
Definition lci_binding_post.hpp:2073
free_matching_engine_x(matching_engine_t *matching_engine_in)
Definition lci_binding_post.hpp:2070
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2067
matching_engine_t * m_matching_engine
Definition lci_binding_post.hpp:2066
void call() const
Definition binding.cpp:676
free_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2074
void operator()() const
Definition lci_binding_post.hpp:2078
The actual implementation for free_net_context.
Definition lci_binding_post.hpp:715
void operator()() const
Definition lci_binding_post.hpp:730
void call_impl(net_context_t *net_context, runtime_t runtime) const
free_net_context_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:726
free_net_context_x(net_context_t *net_context_in)
Definition lci_binding_post.hpp:722
void call() const
Definition binding.cpp:358
net_context_t * m_net_context
Definition lci_binding_post.hpp:718
free_net_context_x && net_context(net_context_t *net_context_in)
Definition lci_binding_post.hpp:725
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:719
The actual implementation for free_packet_pool.
Definition lci_binding_post.hpp:1829
void operator()() const
Definition lci_binding_post.hpp:1844
free_packet_pool_x(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:1836
void call() const
Definition binding.cpp:631
void call_impl(packet_pool_t *packet_pool, runtime_t runtime) const
packet_pool_t * m_packet_pool
Definition lci_binding_post.hpp:1832
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1833
free_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1840
free_packet_pool_x && packet_pool(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:1839
The actual implementation for free_runtime.
Definition lci_binding_post.hpp:1626
void call_impl(runtime_t *runtime) const
free_runtime_x(runtime_t *runtime_in)
Definition lci_binding_post.hpp:1632
runtime_t * m_runtime
Definition lci_binding_post.hpp:1629
free_runtime_x && runtime(runtime_t *runtime_in)
Definition lci_binding_post.hpp:1635
void operator()() const
Definition lci_binding_post.hpp:1639
void call() const
Definition binding.cpp:587
The actual implementation for g_runtime_fina.
Definition lci_binding_post.hpp:1718
g_runtime_fina_x()
Definition lci_binding_post.hpp:1723
void call() const
Definition binding.cpp:607
void operator()() const
Definition lci_binding_post.hpp:1729
void call_impl() const
The actual implementation for g_runtime_init.
Definition lci_binding_post.hpp:1668
g_runtime_init_x && imm_nbits_rcomp(int imm_nbits_rcomp_in)
Definition lci_binding_post.hpp:1687
g_runtime_init_x && alloc_default_packet_pool(bool alloc_default_packet_pool_in)
Definition lci_binding_post.hpp:1690
g_runtime_init_x && imm_nbits_tag(int imm_nbits_tag_in)
Definition lci_binding_post.hpp:1686
option_t< int > m_imm_nbits_tag
Definition lci_binding_post.hpp:1672
option_t< int > m_imm_nbits_rcomp
Definition lci_binding_post.hpp:1673
option_t< size_t > m_packet_return_threshold
Definition lci_binding_post.hpp:1671
g_runtime_init_x && name(const char *name_in)
Definition lci_binding_post.hpp:1692
option_t< attr_rdv_protocol_t > m_rdv_protocol
Definition lci_binding_post.hpp:1674
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1679
option_t< bool > m_alloc_default_device
Definition lci_binding_post.hpp:1675
g_runtime_init_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1693
g_runtime_init_x && alloc_default_matching_engine(bool alloc_default_matching_engine_in)
Definition lci_binding_post.hpp:1691
runtime_t call() const
Definition binding.cpp:593
option_t< bool > m_alloc_default_matching_engine
Definition lci_binding_post.hpp:1677
runtime_t call_impl(size_t packet_return_threshold, int imm_nbits_tag, int imm_nbits_rcomp, attr_rdv_protocol_t rdv_protocol, bool alloc_default_device, bool alloc_default_packet_pool, bool alloc_default_matching_engine, const char *name, void *user_context) const
option_t< bool > m_alloc_default_packet_pool
Definition lci_binding_post.hpp:1676
g_runtime_init_x()
Definition lci_binding_post.hpp:1682
g_runtime_init_x && alloc_default_device(bool alloc_default_device_in)
Definition lci_binding_post.hpp:1689
option_t< const char * > m_name
Definition lci_binding_post.hpp:1678
g_runtime_init_x && packet_return_threshold(size_t packet_return_threshold_in)
Definition lci_binding_post.hpp:1685
runtime_t operator()() const
Definition lci_binding_post.hpp:1697
g_runtime_init_x && rdv_protocol(attr_rdv_protocol_t rdv_protocol_in)
Definition lci_binding_post.hpp:1688
The actual implementation for get_allocator.
Definition lci_binding_post.hpp:2182
allocator_base_t * call_impl(runtime_t runtime) const
allocator_base_t * call() const
Definition binding.cpp:697
allocator_base_t * operator()() const
Definition lci_binding_post.hpp:2195
get_allocator_x()
Definition lci_binding_post.hpp:2188
get_allocator_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2191
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2185
The actual implementation for get_default_device.
Definition lci_binding_post.hpp:2250
device_t call_impl(runtime_t runtime) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2253
get_default_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2259
device_t call() const
Definition binding.cpp:707
get_default_device_x()
Definition lci_binding_post.hpp:2256
device_t operator()() const
Definition lci_binding_post.hpp:2263
The actual implementation for get_default_endpoint.
Definition lci_binding_post.hpp:2285
endpoint_t call_impl(runtime_t runtime, device_t device) const
get_default_endpoint_x && device(device_t device_in)
Definition lci_binding_post.hpp:2296
endpoint_t operator()() const
Definition lci_binding_post.hpp:2300
endpoint_t call() const
Definition binding.cpp:712
get_default_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2295
get_default_endpoint_x()
Definition lci_binding_post.hpp:2292
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2288
option_t< device_t > m_device
Definition lci_binding_post.hpp:2289
The actual implementation for get_default_matching_engine.
Definition lci_binding_post.hpp:2355
get_default_matching_engine_x()
Definition lci_binding_post.hpp:2361
matching_engine_t call() const
Definition binding.cpp:723
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2358
matching_engine_t call_impl(runtime_t runtime) const
matching_engine_t operator()() const
Definition lci_binding_post.hpp:2368
get_default_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2364
The actual implementation for get_default_net_context.
Definition lci_binding_post.hpp:2216
net_context_t operator()() const
Definition lci_binding_post.hpp:2229
get_default_net_context_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2225
get_default_net_context_x()
Definition lci_binding_post.hpp:2222
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2219
net_context_t call_impl(runtime_t runtime) const
net_context_t call() const
Definition binding.cpp:702
The actual implementation for get_default_packet_pool.
Definition lci_binding_post.hpp:2321
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2324
packet_pool_t operator()() const
Definition lci_binding_post.hpp:2334
packet_pool_t call_impl(runtime_t runtime) const
packet_pool_t call() const
Definition binding.cpp:718
get_default_packet_pool_x()
Definition lci_binding_post.hpp:2327
get_default_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2330
The actual implementation for get_g_runtime.
Definition lci_binding_post.hpp:1750
runtime_t operator()() const
Definition lci_binding_post.hpp:1761
get_g_runtime_x()
Definition lci_binding_post.hpp:1755
runtime_t call() const
Definition binding.cpp:612
runtime_t call_impl() const
The actual implementation for get_max_bcopy_size.
Definition lci_binding_post.hpp:2390
size_t operator()() const
Definition lci_binding_post.hpp:2405
get_max_bcopy_size_x()
Definition lci_binding_post.hpp:2397
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2393
size_t call_impl(runtime_t runtime, packet_pool_t packet_pool) const
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:2394
get_max_bcopy_size_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:2401
size_t call() const
Definition binding.cpp:728
get_max_bcopy_size_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2400
The actual implementation for get_rmr.
Definition lci_binding_post.hpp:942
get_rmr_x(mr_t mr_in)
Definition lci_binding_post.hpp:949
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:946
get_rmr_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:952
rmr_t operator()() const
Definition lci_binding_post.hpp:957
mr_t m_mr
Definition lci_binding_post.hpp:945
rmr_t call() const
Definition binding.cpp:420
get_rmr_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:953
rmr_t call_impl(mr_t mr, runtime_t runtime) const
The actual implementation for get_upacket.
Definition lci_binding_post.hpp:1946
get_upacket_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1957
void * call() const
Definition binding.cpp:651
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1949
get_upacket_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1956
void * operator()() const
Definition lci_binding_post.hpp:1961
void * call_impl(runtime_t runtime, packet_pool_t packet_pool) const
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:1950
get_upacket_x()
Definition lci_binding_post.hpp:1953
The actual implementation for graph_add_edge.
Definition lci_binding_post.hpp:3503
void call_impl(comp_t comp, graph_node_t src, graph_node_t dst, graph_edge_run_cb_t fn, runtime_t runtime) const
comp_t m_comp
Definition lci_binding_post.hpp:3506
void call() const
Definition binding.cpp:955
graph_add_edge_x(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in)
Definition lci_binding_post.hpp:3513
graph_add_edge_x && dst(graph_node_t dst_in)
Definition lci_binding_post.hpp:3518
graph_add_edge_x && fn(graph_edge_run_cb_t fn_in)
Definition lci_binding_post.hpp:3519
void operator()() const
Definition lci_binding_post.hpp:3524
option_t< graph_edge_run_cb_t > m_fn
Definition lci_binding_post.hpp:3509
graph_add_edge_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3516
graph_node_t m_dst
Definition lci_binding_post.hpp:3508
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3510
graph_add_edge_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3520
graph_add_edge_x && src(graph_node_t src_in)
Definition lci_binding_post.hpp:3517
graph_node_t m_src
Definition lci_binding_post.hpp:3507
The actual implementation for graph_add_node.
Definition lci_binding_post.hpp:3457
option_t< void * > m_value
Definition lci_binding_post.hpp:3462
graph_node_t operator()() const
Definition lci_binding_post.hpp:3478
graph_add_node_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3474
graph_node_t call() const
Definition binding.cpp:946
graph_add_node_x(comp_t comp_in, graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:3467
graph_node_t call_impl(comp_t comp, graph_node_run_cb_t fn, void *value, graph_node_free_cb_t free_cb, runtime_t runtime) const
graph_add_node_x && fn(graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:3471
graph_node_run_cb_t m_fn
Definition lci_binding_post.hpp:3461
comp_t m_comp
Definition lci_binding_post.hpp:3460
graph_add_node_x && free_cb(graph_node_free_cb_t free_cb_in)
Definition lci_binding_post.hpp:3473
graph_add_node_x && value(void *value_in)
Definition lci_binding_post.hpp:3472
option_t< graph_node_free_cb_t > m_free_cb
Definition lci_binding_post.hpp:3463
graph_add_node_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3470
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3464
The actual implementation for graph_node_mark_complete.
Definition lci_binding_post.hpp:3547
void operator()() const
Definition lci_binding_post.hpp:3564
void call() const
Definition binding.cpp:964
graph_node_t m_node
Definition lci_binding_post.hpp:3550
graph_node_mark_complete_x(graph_node_t node_in)
Definition lci_binding_post.hpp:3555
option_t< status_t > m_status
Definition lci_binding_post.hpp:3551
void call_impl(graph_node_t node, status_t status, runtime_t runtime) const
graph_node_mark_complete_x && node(graph_node_t node_in)
Definition lci_binding_post.hpp:3558
graph_node_mark_complete_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3560
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3552
graph_node_mark_complete_x && status(status_t status_in)
Definition lci_binding_post.hpp:3559
The actual implementation for graph_start.
Definition lci_binding_post.hpp:3586
graph_start_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3597
comp_t m_comp
Definition lci_binding_post.hpp:3589
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3590
graph_start_x(comp_t comp_in)
Definition lci_binding_post.hpp:3593
void call_impl(comp_t comp, runtime_t runtime) const
void call() const
Definition binding.cpp:971
void operator()() const
Definition lci_binding_post.hpp:3601
graph_start_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3596
The actual implementation for graph_test.
Definition lci_binding_post.hpp:3623
comp_t m_comp
Definition lci_binding_post.hpp:3626
status_t call_impl(comp_t comp, runtime_t runtime) const
graph_test_x(comp_t comp_in)
Definition lci_binding_post.hpp:3630
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3627
graph_test_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3634
status_t operator()() const
Definition lci_binding_post.hpp:3638
status_t call() const
Definition binding.cpp:977
graph_test_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3633
The actual implementation for matching_engine_insert.
Definition lci_binding_post.hpp:2103
matching_engine_insert_x && value(matching_entry_val_t value_in)
Definition lci_binding_post.hpp:2118
matching_engine_insert_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2120
matching_entry_val_t operator()() const
Definition lci_binding_post.hpp:2124
matching_entry_val_t call() const
Definition binding.cpp:682
matching_engine_insert_x && entry_type(matching_entry_type_t entry_type_in)
Definition lci_binding_post.hpp:2119
matching_engine_insert_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2116
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2110
matching_entry_type_t m_entry_type
Definition lci_binding_post.hpp:2109
matching_engine_t m_matching_engine
Definition lci_binding_post.hpp:2106
matching_entry_key_t m_key
Definition lci_binding_post.hpp:2107
matching_engine_insert_x && key(matching_entry_key_t key_in)
Definition lci_binding_post.hpp:2117
matching_engine_insert_x(matching_engine_t matching_engine_in, matching_entry_key_t key_in, matching_entry_val_t value_in, matching_entry_type_t entry_type_in)
Definition lci_binding_post.hpp:2113
matching_entry_val_t call_impl(matching_engine_t matching_engine, matching_entry_key_t key, matching_entry_val_t value, matching_entry_type_t entry_type, runtime_t runtime) const
matching_entry_val_t m_value
Definition lci_binding_post.hpp:2108
The actual implementation for RESOURCE matching_engine.
Definition lci_binding_pre.hpp:473
The actual implementation for RESOURCE mr.
Definition lci_binding_pre.hpp:312
The actual implementation for RESOURCE net_context.
Definition lci_binding_pre.hpp:216
The actual implementation for net_poll_cq.
Definition lci_binding_post.hpp:1061
net_poll_cq_x && device(device_t device_in)
Definition lci_binding_post.hpp:1076
net_poll_cq_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1075
option_t< device_t > m_device
Definition lci_binding_post.hpp:1067
net_poll_cq_x(size_t max_polls_in, net_status_t *statuses_in)
Definition lci_binding_post.hpp:1070
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1066
net_poll_cq_x && statuses(net_status_t *statuses_in)
Definition lci_binding_post.hpp:1074
size_t operator()() const
Definition lci_binding_post.hpp:1080
size_t call() const
Definition binding.cpp:445
net_poll_cq_x && max_polls(size_t max_polls_in)
Definition lci_binding_post.hpp:1073
size_t call_impl(size_t max_polls, net_status_t *statuses, runtime_t runtime, device_t device) const
size_t m_max_polls
Definition lci_binding_post.hpp:1064
net_status_t * m_statuses
Definition lci_binding_post.hpp:1065
The actual implementation for net_post_get.
Definition lci_binding_post.hpp:1516
net_post_get_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1535
net_post_get_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1542
net_post_get_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1539
option_t< device_t > m_device
Definition lci_binding_post.hpp:1526
int m_rank
Definition lci_binding_post.hpp:1519
net_post_get_x && device(device_t device_in)
Definition lci_binding_post.hpp:1541
net_post_get_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1537
error_t operator()() const
Definition lci_binding_post.hpp:1547
net_post_get_x && size(size_t size_in)
Definition lci_binding_post.hpp:1536
error_t call() const
Definition binding.cpp:544
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1525
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1527
mr_t m_mr
Definition lci_binding_post.hpp:1522
void * m_buffer
Definition lci_binding_post.hpp:1520
net_post_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1540
error_t call_impl(int rank, void *buffer, size_t size, mr_t mr, uint64_t offset, rmr_t rmr, runtime_t runtime, device_t device, endpoint_t endpoint, void *user_context) const
uint64_t m_offset
Definition lci_binding_post.hpp:1523
net_post_get_x && rank(int rank_in)
Definition lci_binding_post.hpp:1534
rmr_t m_rmr
Definition lci_binding_post.hpp:1524
size_t m_size
Definition lci_binding_post.hpp:1521
net_post_get_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1543
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1528
net_post_get_x(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in, uint64_t offset_in, rmr_t rmr_in)
Definition lci_binding_post.hpp:1531
net_post_get_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1538
The actual implementation for net_post_putImm.
Definition lci_binding_post.hpp:1453
net_post_putImm_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1480
net_post_putImm_x(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in, uint64_t offset_in, rmr_t rmr_in)
Definition lci_binding_post.hpp:1469
rmr_t m_rmr
Definition lci_binding_post.hpp:1461
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1462
net_post_putImm_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1475
net_post_putImm_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1477
error_t call() const
Definition binding.cpp:529
net_post_putImm_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1481
int m_rank
Definition lci_binding_post.hpp:1456
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1465
net_post_putImm_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1478
option_t< device_t > m_device
Definition lci_binding_post.hpp:1463
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1464
mr_t m_mr
Definition lci_binding_post.hpp:1459
net_post_putImm_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1473
void * m_buffer
Definition lci_binding_post.hpp:1457
net_post_putImm_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1482
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1466
error_t operator()() const
Definition lci_binding_post.hpp:1486
error_t call_impl(int rank, void *buffer, size_t size, mr_t mr, uint64_t offset, rmr_t rmr, runtime_t runtime, device_t device, endpoint_t endpoint, net_imm_data_t imm_data, void *user_context) const
size_t m_size
Definition lci_binding_post.hpp:1458
net_post_putImm_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1476
uint64_t m_offset
Definition lci_binding_post.hpp:1460
net_post_putImm_x && size(size_t size_in)
Definition lci_binding_post.hpp:1474
net_post_putImm_x && rank(int rank_in)
Definition lci_binding_post.hpp:1472
net_post_putImm_x && device(device_t device_in)
Definition lci_binding_post.hpp:1479
The actual implementation for net_post_putImms.
Definition lci_binding_post.hpp:1391
net_post_putImms_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1410
net_post_putImms_x && device(device_t device_in)
Definition lci_binding_post.hpp:1415
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1401
option_t< device_t > m_device
Definition lci_binding_post.hpp:1400
net_post_putImms_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1413
error_t call_impl(int rank, void *buffer, size_t size, uint64_t offset, rmr_t rmr, runtime_t runtime, device_t device, endpoint_t endpoint, net_imm_data_t imm_data, void *user_context) const
net_post_putImms_x && rank(int rank_in)
Definition lci_binding_post.hpp:1409
uint64_t m_offset
Definition lci_binding_post.hpp:1397
void * m_buffer
Definition lci_binding_post.hpp:1395
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1402
int m_rank
Definition lci_binding_post.hpp:1394
error_t operator()() const
Definition lci_binding_post.hpp:1422
net_post_putImms_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1412
error_t call() const
Definition binding.cpp:515
rmr_t m_rmr
Definition lci_binding_post.hpp:1398
net_post_putImms_x && size(size_t size_in)
Definition lci_binding_post.hpp:1411
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1403
net_post_putImms_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1416
net_post_putImms_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1417
size_t m_size
Definition lci_binding_post.hpp:1396
net_post_putImms_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1414
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1399
net_post_putImms_x(int rank_in, void *buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in)
Definition lci_binding_post.hpp:1406
net_post_putImms_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1418
The actual implementation for net_post_put.
Definition lci_binding_post.hpp:1330
rmr_t m_rmr
Definition lci_binding_post.hpp:1338
net_post_put_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1349
mr_t m_mr
Definition lci_binding_post.hpp:1336
net_post_put_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1353
int m_rank
Definition lci_binding_post.hpp:1333
net_post_put_x(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in, uint64_t offset_in, rmr_t rmr_in)
Definition lci_binding_post.hpp:1345
error_t call_impl(int rank, void *buffer, size_t size, mr_t mr, uint64_t offset, rmr_t rmr, runtime_t runtime, device_t device, endpoint_t endpoint, void *user_context) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1339
error_t call() const
Definition binding.cpp:501
net_post_put_x && rank(int rank_in)
Definition lci_binding_post.hpp:1348
option_t< device_t > m_device
Definition lci_binding_post.hpp:1340
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1341
net_post_put_x && device(device_t device_in)
Definition lci_binding_post.hpp:1355
net_post_put_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1357
net_post_put_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1356
net_post_put_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1351
net_post_put_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1352
net_post_put_x && size(size_t size_in)
Definition lci_binding_post.hpp:1350
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1342
size_t m_size
Definition lci_binding_post.hpp:1335
net_post_put_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1354
error_t operator()() const
Definition lci_binding_post.hpp:1361
uint64_t m_offset
Definition lci_binding_post.hpp:1337
void * m_buffer
Definition lci_binding_post.hpp:1334
The actual implementation for net_post_puts.
Definition lci_binding_post.hpp:1271
net_post_puts_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1292
net_post_puts_x && rank(int rank_in)
Definition lci_binding_post.hpp:1288
error_t operator()() const
Definition lci_binding_post.hpp:1300
net_post_puts_x && size(size_t size_in)
Definition lci_binding_post.hpp:1290
option_t< device_t > m_device
Definition lci_binding_post.hpp:1280
void * m_buffer
Definition lci_binding_post.hpp:1275
net_post_puts_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1291
net_post_puts_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1293
net_post_puts_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1289
net_post_puts_x && device(device_t device_in)
Definition lci_binding_post.hpp:1294
error_t call() const
Definition binding.cpp:488
int m_rank
Definition lci_binding_post.hpp:1274
net_post_puts_x(int rank_in, void *buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in)
Definition lci_binding_post.hpp:1285
rmr_t m_rmr
Definition lci_binding_post.hpp:1278
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1279
size_t m_size
Definition lci_binding_post.hpp:1276
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1282
error_t call_impl(int rank, void *buffer, size_t size, uint64_t offset, rmr_t rmr, runtime_t runtime, device_t device, endpoint_t endpoint, void *user_context) const
net_post_puts_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1296
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1281
net_post_puts_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1295
uint64_t m_offset
Definition lci_binding_post.hpp:1277
The actual implementation for net_post_recv.
Definition lci_binding_post.hpp:1106
net_post_recv_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1123
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1114
net_post_recv_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1120
error_t call() const
Definition binding.cpp:453
net_post_recv_x(void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1117
net_post_recv_x && size(size_t size_in)
Definition lci_binding_post.hpp:1121
net_post_recv_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1122
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1112
option_t< device_t > m_device
Definition lci_binding_post.hpp:1113
error_t call_impl(void *buffer, size_t size, mr_t mr, runtime_t runtime, device_t device, void *user_context) const
mr_t m_mr
Definition lci_binding_post.hpp:1111
size_t m_size
Definition lci_binding_post.hpp:1110
error_t operator()() const
Definition lci_binding_post.hpp:1129
net_post_recv_x && device(device_t device_in)
Definition lci_binding_post.hpp:1124
void * m_buffer
Definition lci_binding_post.hpp:1109
net_post_recv_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1125
The actual implementation for net_post_send.
Definition lci_binding_post.hpp:1213
net_post_send_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1237
net_post_send_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1234
net_post_send_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1231
void * m_buffer
Definition lci_binding_post.hpp:1217
int m_rank
Definition lci_binding_post.hpp:1216
mr_t m_mr
Definition lci_binding_post.hpp:1219
size_t m_size
Definition lci_binding_post.hpp:1218
net_post_send_x && size(size_t size_in)
Definition lci_binding_post.hpp:1232
error_t call() const
Definition binding.cpp:475
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1220
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1223
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1222
net_post_send_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1233
net_post_send_x && device(device_t device_in)
Definition lci_binding_post.hpp:1235
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1224
net_post_send_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1236
net_post_send_x(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1227
error_t call_impl(int rank, void *buffer, size_t size, mr_t mr, runtime_t runtime, device_t device, endpoint_t endpoint, net_imm_data_t imm_data, void *user_context) const
option_t< device_t > m_device
Definition lci_binding_post.hpp:1221
error_t operator()() const
Definition lci_binding_post.hpp:1242
net_post_send_x && rank(int rank_in)
Definition lci_binding_post.hpp:1230
net_post_send_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1238
The actual implementation for net_post_sends.
Definition lci_binding_post.hpp:1157
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1167
net_post_sends_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1179
net_post_sends_x && size(size_t size_in)
Definition lci_binding_post.hpp:1175
error_t call() const
Definition binding.cpp:463
option_t< device_t > m_device
Definition lci_binding_post.hpp:1164
net_post_sends_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1178
error_t call_impl(int rank, void *buffer, size_t size, runtime_t runtime, device_t device, endpoint_t endpoint, net_imm_data_t imm_data, void *user_context) const
int m_rank
Definition lci_binding_post.hpp:1160
net_post_sends_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1176
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1166
net_post_sends_x(int rank_in, void *buffer_in, size_t size_in)
Definition lci_binding_post.hpp:1170
net_post_sends_x && rank(int rank_in)
Definition lci_binding_post.hpp:1173
void * m_buffer
Definition lci_binding_post.hpp:1161
net_post_sends_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1180
error_t operator()() const
Definition lci_binding_post.hpp:1184
net_post_sends_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1174
size_t m_size
Definition lci_binding_post.hpp:1162
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1165
net_post_sends_x && device(device_t device_in)
Definition lci_binding_post.hpp:1177
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1163
The actual implementation for RESOURCE packet_pool.
Definition lci_binding_pre.hpp:437
The actual implementation for post_am.
Definition lci_binding_post.hpp:135
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:148
option_t< device_t > m_device
Definition lci_binding_post.hpp:144
post_am_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:167
rcomp_t m_remote_comp
Definition lci_binding_post.hpp:142
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:149
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:152
post_am_x(int rank_in, void *local_buffer_in, size_t size_in, comp_t local_comp_in, rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:156
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:145
post_am_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:172
post_am_x && size(size_t size_in)
Definition lci_binding_post.hpp:161
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:153
post_am_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:164
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:143
post_am_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:170
int m_rank
Definition lci_binding_post.hpp:138
post_am_x && rank(int rank_in)
Definition lci_binding_post.hpp:159
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:146
post_am_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:168
status_t call() const
Definition binding.cpp:203
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:147
status_t call_impl(int rank, void *local_buffer, size_t size, comp_t local_comp, rcomp_t remote_comp, runtime_t runtime, device_t device, endpoint_t endpoint, packet_pool_t packet_pool, comp_semantic_t comp_semantic, mr_t mr, tag_t tag, void *user_context, bool allow_done, bool allow_posted, bool allow_retry) const
post_am_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:169
comp_t m_local_comp
Definition lci_binding_post.hpp:141
post_am_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:174
post_am_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:173
post_am_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:160
size_t m_size
Definition lci_binding_post.hpp:140
post_am_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:166
post_am_x && device(device_t device_in)
Definition lci_binding_post.hpp:165
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:151
post_am_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:171
void * m_local_buffer
Definition lci_binding_post.hpp:139
post_am_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:162
status_t operator()() const
Definition lci_binding_post.hpp:178
option_t< void * > m_user_context
Definition lci_binding_post.hpp:150
post_am_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:163
The actual implementation for post_comm.
Definition lci_binding_post.hpp:46
status_t call() const
Definition binding.cpp:178
void * m_local_buffer
Definition lci_binding_post.hpp:51
option_t< void * > m_user_context
Definition lci_binding_post.hpp:65
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:66
post_comm_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:90
option_t< device_t > m_device
Definition lci_binding_post.hpp:55
post_comm_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:84
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:69
status_t call_impl(direction_t direction, int rank, void *local_buffer, size_t size, comp_t local_comp, runtime_t runtime, device_t device, endpoint_t endpoint, packet_pool_t packet_pool, matching_engine_t matching_engine, comp_semantic_t comp_semantic, mr_t mr, uintptr_t remote_disp, rmr_t rmr, tag_t tag, rcomp_t remote_comp, void *user_context, matching_policy_t matching_policy, bool allow_done, bool allow_posted, bool allow_retry) const
int m_rank
Definition lci_binding_post.hpp:50
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:58
post_comm_x && rank(int rank_in)
Definition lci_binding_post.hpp:76
post_comm_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:80
post_comm_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:77
size_t m_size
Definition lci_binding_post.hpp:52
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:54
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:60
comp_t m_local_comp
Definition lci_binding_post.hpp:53
status_t operator()() const
Definition lci_binding_post.hpp:99
option_t< rmr_t > m_rmr
Definition lci_binding_post.hpp:62
post_comm_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:91
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:68
post_comm_x(direction_t direction_in, int rank_in, void *local_buffer_in, size_t size_in, comp_t local_comp_in)
Definition lci_binding_post.hpp:72
option_t< uintptr_t > m_remote_disp
Definition lci_binding_post.hpp:61
post_comm_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:83
post_comm_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:93
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:56
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:64
post_comm_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:79
post_comm_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:89
post_comm_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:88
post_comm_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:86
post_comm_x && direction(direction_t direction_in)
Definition lci_binding_post.hpp:75
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:67
post_comm_x && size(size_t size_in)
Definition lci_binding_post.hpp:78
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:57
post_comm_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:82
post_comm_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:94
post_comm_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:85
post_comm_x && device(device_t device_in)
Definition lci_binding_post.hpp:81
post_comm_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:95
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:59
post_comm_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:92
direction_t m_direction
Definition lci_binding_post.hpp:49
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:63
post_comm_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:87
The actual implementation for post_get.
Definition lci_binding_post.hpp:465
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:481
option_t< void * > m_user_context
Definition lci_binding_post.hpp:482
post_get_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:506
post_get_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:503
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:478
comp_t m_local_comp
Definition lci_binding_post.hpp:471
post_get_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:501
post_get_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:495
post_get_x(int rank_in, void *local_buffer_in, size_t size_in, comp_t local_comp_in, uintptr_t remote_disp_in, rmr_t rmr_in)
Definition lci_binding_post.hpp:488
post_get_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:502
status_t operator()() const
Definition lci_binding_post.hpp:512
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:477
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:485
uintptr_t m_remote_disp
Definition lci_binding_post.hpp:472
status_t call_impl(int rank, void *local_buffer, size_t size, comp_t local_comp, uintptr_t remote_disp, rmr_t rmr, runtime_t runtime, device_t device, endpoint_t endpoint, packet_pool_t packet_pool, comp_semantic_t comp_semantic, mr_t mr, tag_t tag, rcomp_t remote_comp, void *user_context, bool allow_done, bool allow_posted, bool allow_retry) const
void * m_local_buffer
Definition lci_binding_post.hpp:469
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:483
option_t< device_t > m_device
Definition lci_binding_post.hpp:475
post_get_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:496
int m_rank
Definition lci_binding_post.hpp:468
post_get_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:492
post_get_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:504
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:474
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:484
post_get_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:507
post_get_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:500
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:476
post_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:497
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:479
post_get_x && size(size_t size_in)
Definition lci_binding_post.hpp:493
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:480
post_get_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:499
status_t call() const
Definition binding.cpp:287
post_get_x && rank(int rank_in)
Definition lci_binding_post.hpp:491
post_get_x && device(device_t device_in)
Definition lci_binding_post.hpp:498
post_get_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:494
post_get_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:505
size_t m_size
Definition lci_binding_post.hpp:470
rmr_t m_rmr
Definition lci_binding_post.hpp:473
post_get_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:508
The actual implementation for post_put.
Definition lci_binding_post.hpp:380
status_t call_impl(int rank, void *local_buffer, size_t size, comp_t local_comp, uintptr_t remote_disp, rmr_t rmr, runtime_t runtime, device_t device, endpoint_t endpoint, packet_pool_t packet_pool, comp_semantic_t comp_semantic, mr_t mr, tag_t tag, rcomp_t remote_comp, void *user_context, bool allow_done, bool allow_posted, bool allow_retry) const
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:398
post_put_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:420
post_put_x && device(device_t device_in)
Definition lci_binding_post.hpp:413
status_t operator()() const
Definition lci_binding_post.hpp:427
post_put_x && rank(int rank_in)
Definition lci_binding_post.hpp:406
post_put_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:412
post_put_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:414
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:399
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:391
comp_t m_local_comp
Definition lci_binding_post.hpp:386
uintptr_t m_remote_disp
Definition lci_binding_post.hpp:387
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:400
option_t< device_t > m_device
Definition lci_binding_post.hpp:390
option_t< void * > m_user_context
Definition lci_binding_post.hpp:397
post_put_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:407
int m_rank
Definition lci_binding_post.hpp:383
post_put_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:415
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:396
post_put_x(int rank_in, void *local_buffer_in, size_t size_in, comp_t local_comp_in, uintptr_t remote_disp_in, rmr_t rmr_in)
Definition lci_binding_post.hpp:403
post_put_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:418
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:394
post_put_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:421
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:395
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:393
post_put_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:416
status_t call() const
Definition binding.cpp:265
post_put_x && size(size_t size_in)
Definition lci_binding_post.hpp:408
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:389
post_put_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:423
post_put_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:411
post_put_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:409
post_put_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:410
rmr_t m_rmr
Definition lci_binding_post.hpp:388
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:392
size_t m_size
Definition lci_binding_post.hpp:385
post_put_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:419
post_put_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:417
void * m_local_buffer
Definition lci_binding_post.hpp:384
post_put_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:422
The actual implementation for post_recv.
Definition lci_binding_post.hpp:297
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:316
post_recv_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:337
size_t m_size
Definition lci_binding_post.hpp:302
post_recv_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:336
post_recv_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:325
option_t< void * > m_user_context
Definition lci_binding_post.hpp:312
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:309
tag_t m_tag
Definition lci_binding_post.hpp:303
post_recv_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:330
post_recv_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:327
option_t< device_t > m_device
Definition lci_binding_post.hpp:306
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:314
post_recv_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:332
post_recv_x && size(size_t size_in)
Definition lci_binding_post.hpp:324
status_t operator()() const
Definition lci_binding_post.hpp:342
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:308
post_recv_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:334
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:310
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:311
void * m_local_buffer
Definition lci_binding_post.hpp:301
post_recv_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:329
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:307
post_recv_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:331
comp_t m_local_comp
Definition lci_binding_post.hpp:304
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:315
post_recv_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:333
post_recv_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:338
post_recv_x && device(device_t device_in)
Definition lci_binding_post.hpp:328
int m_rank
Definition lci_binding_post.hpp:300
post_recv_x(int rank_in, void *local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in)
Definition lci_binding_post.hpp:319
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:305
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:313
post_recv_x && rank(int rank_in)
Definition lci_binding_post.hpp:322
status_t call_impl(int rank, void *local_buffer, size_t size, tag_t tag, comp_t local_comp, runtime_t runtime, device_t device, endpoint_t endpoint, packet_pool_t packet_pool, matching_engine_t matching_engine, comp_semantic_t comp_semantic, mr_t mr, void *user_context, matching_policy_t matching_policy, bool allow_done, bool allow_posted, bool allow_retry) const
post_recv_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:326
post_recv_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:335
post_recv_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:323
status_t call() const
Definition binding.cpp:244
The actual implementation for post_send.
Definition lci_binding_post.hpp:215
post_send_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:254
post_send_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:244
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:226
status_t call() const
Definition binding.cpp:223
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:227
post_send_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:247
void * m_local_buffer
Definition lci_binding_post.hpp:219
option_t< void * > m_user_context
Definition lci_binding_post.hpp:230
post_send_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:251
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:232
size_t m_size
Definition lci_binding_post.hpp:220
int m_rank
Definition lci_binding_post.hpp:218
post_send_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:241
tag_t m_tag
Definition lci_binding_post.hpp:221
post_send_x && size(size_t size_in)
Definition lci_binding_post.hpp:242
comp_t m_local_comp
Definition lci_binding_post.hpp:222
post_send_x(int rank_in, void *local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in)
Definition lci_binding_post.hpp:237
status_t operator()() const
Definition lci_binding_post.hpp:260
post_send_x && rank(int rank_in)
Definition lci_binding_post.hpp:240
post_send_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:245
post_send_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:256
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:229
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:225
post_send_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:249
status_t call_impl(int rank, void *local_buffer, size_t size, tag_t tag, comp_t local_comp, runtime_t runtime, device_t device, endpoint_t endpoint, packet_pool_t packet_pool, matching_engine_t matching_engine, comp_semantic_t comp_semantic, mr_t mr, void *user_context, matching_policy_t matching_policy, bool allow_done, bool allow_posted, bool allow_retry) const
post_send_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:250
post_send_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:255
option_t< device_t > m_device
Definition lci_binding_post.hpp:224
post_send_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:252
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:228
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:231
post_send_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:243
post_send_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:253
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:234
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:233
post_send_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:248
post_send_x && device(device_t device_in)
Definition lci_binding_post.hpp:246
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:223
The actual implementation for progress.
Definition lci_binding_post.hpp:535
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:538
error_t call() const
Definition binding.cpp:309
progress_x()
Definition lci_binding_post.hpp:543
progress_x && device(device_t device_in)
Definition lci_binding_post.hpp:547
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:540
option_t< device_t > m_device
Definition lci_binding_post.hpp:539
error_t operator()() const
Definition lci_binding_post.hpp:552
progress_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:546
error_t call_impl(runtime_t runtime, device_t device, endpoint_t endpoint) const
progress_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:548
The actual implementation for put_upacket.
Definition lci_binding_post.hpp:1983
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1987
void * m_packet
Definition lci_binding_post.hpp:1986
void call() const
Definition binding.cpp:657
void operator()() const
Definition lci_binding_post.hpp:1998
put_upacket_x && packet(void *packet_in)
Definition lci_binding_post.hpp:1993
put_upacket_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1994
put_upacket_x(void *packet_in)
Definition lci_binding_post.hpp:1990
void call_impl(void *packet, runtime_t runtime) const
The actual implementation for reduce_scatter.
Definition lci_binding_post.hpp:2608
reduce_scatter_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2629
reduce_scatter_x && item_size(size_t item_size_in)
Definition lci_binding_post.hpp:2631
reduce_scatter_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2636
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:2622
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2618
reduce_scatter_x && device(device_t device_in)
Definition lci_binding_post.hpp:2634
reduce_scatter_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2628
reduce_scatter_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2637
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2620
option_t< reduce_scatter_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:2621
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2616
void call_impl(const void *sendbuf, void *recvbuf, size_t recvcount, size_t item_size, reduce_op_t op, runtime_t runtime, device_t device, endpoint_t endpoint, matching_engine_t matching_engine, comp_t comp, reduce_scatter_algorithm_t algorithm, int ring_nsteps) const
void * m_recvbuf
Definition lci_binding_post.hpp:2612
size_t m_item_size
Definition lci_binding_post.hpp:2614
const void * m_sendbuf
Definition lci_binding_post.hpp:2611
size_t m_recvcount
Definition lci_binding_post.hpp:2613
reduce_scatter_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:2632
void operator()() const
Definition lci_binding_post.hpp:2643
reduce_scatter_x && algorithm(reduce_scatter_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:2638
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2619
reduce_op_t m_op
Definition lci_binding_post.hpp:2615
void call() const
Definition binding.cpp:772
reduce_scatter_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2633
option_t< device_t > m_device
Definition lci_binding_post.hpp:2617
reduce_scatter_x(const void *sendbuf_in, void *recvbuf_in, size_t recvcount_in, size_t item_size_in, reduce_op_t op_in)
Definition lci_binding_post.hpp:2625
reduce_scatter_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2635
reduce_scatter_x && recvcount(size_t recvcount_in)
Definition lci_binding_post.hpp:2630
reduce_scatter_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:2639
The actual implementation for reduce.
Definition lci_binding_post.hpp:2545
void operator()() const
Definition lci_binding_post.hpp:2576
reduce_x(const void *sendbuf_in, void *recvbuf_in, size_t count_in, size_t item_size_in, reduce_op_t op_in, int root_in)
Definition lci_binding_post.hpp:2560
reduce_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:2567
reduce_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2572
reduce_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2564
option_t< device_t > m_device
Definition lci_binding_post.hpp:2555
int m_root
Definition lci_binding_post.hpp:2553
size_t m_count
Definition lci_binding_post.hpp:2550
reduce_x && count(size_t count_in)
Definition lci_binding_post.hpp:2565
reduce_op_t m_op
Definition lci_binding_post.hpp:2552
reduce_x && device(device_t device_in)
Definition lci_binding_post.hpp:2570
size_t m_item_size
Definition lci_binding_post.hpp:2551
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2556
void call_impl(const void *sendbuf, void *recvbuf, size_t count, size_t item_size, reduce_op_t op, int root, runtime_t runtime, device_t device, endpoint_t endpoint, matching_engine_t matching_engine) const
void * m_recvbuf
Definition lci_binding_post.hpp:2549
reduce_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2563
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2557
reduce_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2569
reduce_x && item_size(size_t item_size_in)
Definition lci_binding_post.hpp:2566
reduce_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2571
reduce_x && root(int root_in)
Definition lci_binding_post.hpp:2568
const void * m_sendbuf
Definition lci_binding_post.hpp:2548
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2554
void call() const
Definition binding.cpp:758
The actual implementation for register_memory.
Definition lci_binding_post.hpp:864
register_memory_x && address(void *address_in)
Definition lci_binding_post.hpp:876
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:869
register_memory_x && device(device_t device_in)
Definition lci_binding_post.hpp:879
mr_t call_impl(void *address, size_t size, runtime_t runtime, device_t device) const
register_memory_x && size(size_t size_in)
Definition lci_binding_post.hpp:877
option_t< device_t > m_device
Definition lci_binding_post.hpp:870
void * m_address
Definition lci_binding_post.hpp:867
mr_t operator()() const
Definition lci_binding_post.hpp:883
register_memory_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:878
register_memory_x(void *address_in, size_t size_in)
Definition lci_binding_post.hpp:873
size_t m_size
Definition lci_binding_post.hpp:868
mr_t call() const
Definition binding.cpp:406
The actual implementation for register_packet_pool.
Definition lci_binding_post.hpp:1867
device_t m_device
Definition lci_binding_post.hpp:1871
void call_impl(packet_pool_t packet_pool, device_t device, runtime_t runtime) const
void operator()() const
Definition lci_binding_post.hpp:1884
register_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:1875
register_packet_pool_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1878
void call() const
Definition binding.cpp:637
register_packet_pool_x && device(device_t device_in)
Definition lci_binding_post.hpp:1879
packet_pool_t m_packet_pool
Definition lci_binding_post.hpp:1870
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1872
register_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1880
The actual implementation for register_rcomp.
Definition lci_binding_post.hpp:2954
rcomp_t call() const
Definition binding.cpp:855
rcomp_t operator()() const
Definition lci_binding_post.hpp:2971
comp_t m_comp
Definition lci_binding_post.hpp:2957
option_t< rcomp_t > m_rcomp
Definition lci_binding_post.hpp:2959
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2958
register_rcomp_x && rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:2967
register_rcomp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2966
register_rcomp_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2965
rcomp_t call_impl(comp_t comp, runtime_t runtime, rcomp_t rcomp) const
register_rcomp_x(comp_t comp_in)
Definition lci_binding_post.hpp:2962
The actual implementation for reserve_rcomps.
Definition lci_binding_post.hpp:2916
rcomp_t call_impl(rcomp_t n, runtime_t runtime) const
rcomp_t m_n
Definition lci_binding_post.hpp:2919
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2920
reserve_rcomps_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2927
rcomp_t call() const
Definition binding.cpp:849
reserve_rcomps_x(rcomp_t n_in)
Definition lci_binding_post.hpp:2923
rcomp_t operator()() const
Definition lci_binding_post.hpp:2931
reserve_rcomps_x && n(rcomp_t n_in)
Definition lci_binding_post.hpp:2926
The actual implementation for RESOURCE runtime.
Definition lci_binding_pre.hpp:391
The actual implementation for set_allocator.
Definition lci_binding_post.hpp:2146
set_allocator_x(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:2153
set_allocator_x && allocator(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:2156
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2150
void call_impl(allocator_base_t *allocator, runtime_t runtime) const
set_allocator_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2157
void call() const
Definition binding.cpp:691
allocator_base_t * m_allocator
Definition lci_binding_post.hpp:2149
void operator()() const
Definition lci_binding_post.hpp:2161
The actual implementation for sync_test.
Definition lci_binding_post.hpp:3077
comp_t m_comp
Definition lci_binding_post.hpp:3080
bool call_impl(comp_t comp, status_t *p_out, runtime_t runtime) const
sync_test_x && p_out(status_t *p_out_in)
Definition lci_binding_post.hpp:3089
status_t * m_p_out
Definition lci_binding_post.hpp:3081
sync_test_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3090
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3082
bool operator()() const
Definition lci_binding_post.hpp:3094
sync_test_x(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:3085
sync_test_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3088
bool call() const
Definition binding.cpp:877
The actual implementation for sync_wait.
Definition lci_binding_post.hpp:3119
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3124
sync_wait_x(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:3129
comp_t m_comp
Definition lci_binding_post.hpp:3122
sync_wait_x && p_out(status_t *p_out_in)
Definition lci_binding_post.hpp:3133
option_t< device_t > m_device
Definition lci_binding_post.hpp:3126
sync_wait_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3134
void call() const
Definition binding.cpp:884
status_t * m_p_out
Definition lci_binding_post.hpp:3123
option_t< bool > m_do_progress
Definition lci_binding_post.hpp:3125
sync_wait_x && device(device_t device_in)
Definition lci_binding_post.hpp:3136
sync_wait_x && do_progress(bool do_progress_in)
Definition lci_binding_post.hpp:3135
void call_impl(comp_t comp, status_t *p_out, runtime_t runtime, bool do_progress, device_t device) const
void operator()() const
Definition lci_binding_post.hpp:3140
sync_wait_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3132
The actual implementation for test_drained.
Definition lci_binding_post.hpp:574
option_t< device_t > m_device
Definition lci_binding_post.hpp:578
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:577
test_drained_x()
Definition lci_binding_post.hpp:581
error_t operator()() const
Definition lci_binding_post.hpp:589
test_drained_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:584
test_drained_x && device(device_t device_in)
Definition lci_binding_post.hpp:585
error_t call() const
Definition binding.cpp:316
error_t call_impl(runtime_t runtime, device_t device) const
The actual implementation for wait_drained.
Definition lci_binding_post.hpp:611
option_t< device_t > m_device
Definition lci_binding_post.hpp:615
void operator()() const
Definition lci_binding_post.hpp:626
wait_drained_x()
Definition lci_binding_post.hpp:618
void call() const
Definition binding.cpp:322
void call_impl(runtime_t runtime, device_t device) const
wait_drained_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:621
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:614
wait_drained_x && device(device_t device_in)
Definition lci_binding_post.hpp:622
broadcast_algorithm_t
The type of broadcast algorithm.
Definition lci.hpp:232
void(*)(status_t status, void *src_value, void *dst_value) graph_edge_run_cb_t
The function signature for a edge funciton in the completion graph.
Definition lci.hpp:580
uint64_t matching_entry_key_t
The type of matching engine entry key.
Definition lci.hpp:406
status_t(*)(void *value) graph_node_run_cb_t
The function signature for a node function in the completion graph.
Definition lci.hpp:559
direction_t
The enum class of comunication direction.
Definition lci.hpp:356
void(*)(void *value) graph_node_free_cb_t
The function signature for a callback that will be triggered when the node was freed.
Definition lci.hpp:574
void(*)(const void *left, const void *right, void *dst, size_t n) reduce_op_t
The user-defined reduction operation.
Definition lci.hpp:539
matching_policy_t
Enum class for matching policy.
Definition lci.hpp:395
void * graph_node_t
The node type for the completion graph.
Definition lci.hpp:545
allreduce_algorithm_t
The type of allreduce algorithm.
Definition lci.hpp:268
reduce_scatter_algorithm_t
The type of reduce scatter algorithm.
Definition lci.hpp:250
void * matching_entry_val_t
The type of matching engine entry value.
Definition lci.hpp:411
matching_entry_type_t
The type of matching entry.
Definition lci.hpp:386
uint32_t rcomp_t
The type of remote completion handler.
Definition lci.hpp:367
void(*)(status_t status) comp_handler_t
Function Signature for completion handler.
Definition lci.hpp:532
uint64_t tag_t
The type of tag.
Definition lci.hpp:350
comp_semantic_t
The enum class of completion semantic.
Definition lci.hpp:421
uint32_t net_imm_data_t
The type of network-layer immediate data field.
Definition lci.hpp:287
All LCI API functions and classes are defined in this namespace.
status_t post_comm(direction_t direction_in, int rank_in, void *local_buffer_in, size_t size_in, comp_t local_comp_in)
Definition lci_binding_post.hpp:102
error_t net_post_send(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1245
void graph_node_mark_complete(graph_node_t node_in)
Definition lci_binding_post.hpp:3567
size_t get_max_bcopy_size()
Definition lci_binding_post.hpp:2408
attr_matching_engine_type_t
Definition lci_binding_pre.hpp:53
void broadcast(void *buffer_in, size_t size_in, int root_in)
Definition lci_binding_post.hpp:2518
device_t alloc_device()
Definition lci_binding_post.hpp:806
net_context_t alloc_net_context()
Definition lci_binding_post.hpp:696
void free_net_context(net_context_t *net_context_in)
Definition lci_binding_post.hpp:733
error_t net_post_recv(void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1132
attr_backend_t
Definition lci.hpp:66
void deregister_rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:3011
void deregister_memory(mr_t *mr_in)
Definition lci_binding_post.hpp:923
comp_t alloc_counter()
Definition lci_binding_post.hpp:3183
status_t post_am(int rank_in, void *local_buffer_in, size_t size_in, comp_t local_comp_in, rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:181
matching_entry_val_t matching_engine_insert(matching_engine_t matching_engine_in, matching_entry_key_t key_in, matching_entry_val_t value_in, matching_entry_type_t entry_type_in)
Definition lci_binding_post.hpp:2127
void wait_drained()
Definition lci_binding_post.hpp:629
rcomp_t reserve_rcomps(rcomp_t n_in)
Definition lci_binding_post.hpp:2934
void sync_wait(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:3143
matching_engine_t alloc_matching_engine()
Definition lci_binding_post.hpp:2044
error_t net_post_putImms(int rank_in, void *buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in)
Definition lci_binding_post.hpp:1425
void alltoall(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:2820
status_t graph_test(comp_t comp_in)
Definition lci_binding_post.hpp:3641
void register_packet_pool(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:1887
matching_engine_t get_default_matching_engine()
Definition lci_binding_post.hpp:2371
status_t cq_pop(comp_t comp_in)
Definition lci_binding_post.hpp:3346
size_t net_poll_cq(size_t max_polls_in, net_status_t *statuses_in)
Definition lci_binding_post.hpp:1083
attr_rdv_protocol_t
Definition lci_binding_pre.hpp:47
void graph_start(comp_t comp_in)
Definition lci_binding_post.hpp:3604
void free_matching_engine(matching_engine_t *matching_engine_in)
Definition lci_binding_post.hpp:2081
void put_upacket(void *packet_in)
Definition lci_binding_post.hpp:2001
comp_t alloc_cq()
Definition lci_binding_post.hpp:3309
void g_runtime_fina()
Definition lci_binding_post.hpp:1732
error_t net_post_puts(int rank_in, void *buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in)
Definition lci_binding_post.hpp:1303
rcomp_t register_rcomp(comp_t comp_in)
Definition lci_binding_post.hpp:2974
error_t net_post_sends(int rank_in, void *buffer_in, size_t size_in)
Definition lci_binding_post.hpp:1187
void graph_add_edge(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in)
Definition lci_binding_post.hpp:3527
void set_allocator(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:2164
allocator_base_t * get_allocator()
Definition lci_binding_post.hpp:2198
net_context_t get_default_net_context()
Definition lci_binding_post.hpp:2232
void free_device(device_t *device_in)
Definition lci_binding_post.hpp:843
void free_comp(comp_t *comp_in)
Definition lci_binding_post.hpp:2857
packet_pool_t get_default_packet_pool()
Definition lci_binding_post.hpp:2337
void free_runtime(runtime_t *runtime_in)
Definition lci_binding_post.hpp:1642
comp_t alloc_handler(comp_handler_t handler_in)
Definition lci_binding_post.hpp:3392
error_t net_post_putImm(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in, uint64_t offset_in, rmr_t rmr_in)
Definition lci_binding_post.hpp:1489
runtime_t get_g_runtime()
Definition lci_binding_post.hpp:1764
void free_packet_pool(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:1847
void reduce(const void *sendbuf_in, void *recvbuf_in, size_t count_in, size_t item_size_in, reduce_op_t op_in, int root_in)
Definition lci_binding_post.hpp:2579
void deregister_packet_pool(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:1927
runtime_t g_runtime_init()
Definition lci_binding_post.hpp:1700
void counter_set(comp_t comp_in, int64_t value_in)
Definition lci_binding_post.hpp:3260
status_t post_send(int rank_in, void *local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in)
Definition lci_binding_post.hpp:263
void comp_signal(comp_t comp_in, status_t status_in)
Definition lci_binding_post.hpp:2897
mr_t register_memory(void *address_in, size_t size_in)
Definition lci_binding_post.hpp:886
rmr_t get_rmr(mr_t mr_in)
Definition lci_binding_post.hpp:960
endpoint_t alloc_endpoint()
Definition lci_binding_post.hpp:1003
status_t post_put(int rank_in, void *local_buffer_in, size_t size_in, comp_t local_comp_in, uintptr_t remote_disp_in, rmr_t rmr_in)
Definition lci_binding_post.hpp:430
endpoint_t get_default_endpoint()
Definition lci_binding_post.hpp:2303
void allreduce(const void *sendbuf_in, void *recvbuf_in, size_t count_in, size_t item_size_in, reduce_op_t op_in)
Definition lci_binding_post.hpp:2713
graph_node_t graph_add_node(comp_t comp_in, graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:3481
runtime_t alloc_runtime()
Definition lci_binding_post.hpp:1608
void allgather(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:2765
bool sync_test(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:3097
attr_ibv_td_strategy_t
Definition lci_binding_pre.hpp:41
error_t progress()
Definition lci_binding_post.hpp:555
attr_ibv_odp_strategy_t
Definition lci_binding_pre.hpp:28
error_t test_drained()
Definition lci_binding_post.hpp:592
device_t get_default_device()
Definition lci_binding_post.hpp:2266
int64_t counter_get(comp_t comp_in)
Definition lci_binding_post.hpp:3220
void reduce_scatter(const void *sendbuf_in, void *recvbuf_in, size_t recvcount_in, size_t item_size_in, reduce_op_t op_in)
Definition lci_binding_post.hpp:2646
packet_pool_t alloc_packet_pool()
Definition lci_binding_post.hpp:1810
attr_ibv_prefetch_strategy_t
Definition lci_binding_pre.hpp:34
void barrier()
Definition lci_binding_post.hpp:2457
error_t net_post_get(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in, uint64_t offset_in, rmr_t rmr_in)
Definition lci_binding_post.hpp:1550
attr_cq_type_t
Definition lci_binding_pre.hpp:67
comp_t alloc_graph()
Definition lci_binding_post.hpp:3435
status_t post_recv(int rank_in, void *local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in)
Definition lci_binding_post.hpp:345
void * get_upacket()
Definition lci_binding_post.hpp:1964
error_t net_post_put(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in, uint64_t offset_in, rmr_t rmr_in)
Definition lci_binding_post.hpp:1364
comp_t alloc_sync()
Definition lci_binding_post.hpp:3057
void free_endpoint(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:1040
status_t post_get(int rank_in, void *local_buffer_in, size_t size_in, comp_t local_comp_in, uintptr_t remote_disp_in, rmr_t rmr_in)
Definition lci_binding_post.hpp:515
The user-defined allocator type.
Definition lci.hpp:430
Wrapper class for error code.
Definition lci.hpp:163
The struct for network status.
Definition lci.hpp:295
Definition lci.hpp:82
The type of remote memory region.
Definition lci.hpp:333
The type of the completion desciptor for a posted communication.
Definition lci.hpp:446