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
33
39 public:
40 // args declaration
54
55 // constructor
57
58 // setter
59 inline alloc_net_context_x&& backend(attr_backend_t backend_in) { m_backend = backend_in; return std::move(*this); }
60 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); }
61 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); }
62 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); }
63 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); }
64 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); }
65 inline alloc_net_context_x&& device_name(std::string device_name_in) { m_device_name = device_name_in; return std::move(*this); }
66 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); }
67 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); }
68 inline alloc_net_context_x&& use_dmabuf(bool use_dmabuf_in) { m_use_dmabuf = use_dmabuf_in; return std::move(*this); }
69 inline alloc_net_context_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
70 inline alloc_net_context_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
71 inline alloc_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
72
74 net_context_t call() const;
75 inline net_context_t operator()() const { return call(); }
76};
77
81
82
92
98 public:
99 // args declaration
102
103 // constructor
104 free_net_context_x(net_context_t* net_context_in) : m_net_context(net_context_in) {}
105
106 // setter
107 inline free_net_context_x&& net_context(net_context_t* net_context_in) { m_net_context = net_context_in; return std::move(*this); }
108 inline free_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
109
111 void call() const;
112 inline void operator()() const { return call(); }
113};
114
115inline void free_net_context(net_context_t* net_context_in) {
116 return free_net_context_x(net_context_in).call();
117}
118
119
141
147 public:
148 // args declaration
163
164 // constructor
166
167 // setter
168 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); }
169 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); }
170 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); }
171 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); }
172 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); }
173 inline alloc_device_x&& alloc_default_endpoint(bool alloc_default_endpoint_in) { m_alloc_default_endpoint = alloc_default_endpoint_in; return std::move(*this); }
174 inline alloc_device_x&& alloc_progress_endpoint(bool alloc_progress_endpoint_in) { m_alloc_progress_endpoint = alloc_progress_endpoint_in; return std::move(*this); }
175 inline alloc_device_x&& use_reg_cache(bool use_reg_cache_in) { m_use_reg_cache = use_reg_cache_in; return std::move(*this); }
176 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); }
177 inline alloc_device_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
178 inline alloc_device_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
179 inline alloc_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
180 inline alloc_device_x&& net_context(net_context_t net_context_in) { m_net_context = net_context_in; return std::move(*this); }
181 inline alloc_device_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
182
184 device_t call() const;
185 inline device_t operator()() const { return call(); }
186};
187
189 return alloc_device_x().call();
190}
191
192
202
208 public:
209 // args declaration
212
213 // constructor
214 free_device_x(device_t* device_in) : m_device(device_in) {}
215
216 // setter
217 inline free_device_x&& device(device_t* device_in) { m_device = device_in; return std::move(*this); }
218 inline free_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
219
221 void call() const;
222 inline void operator()() const { return call(); }
223};
224
225inline void free_device(device_t* device_in) {
226 return free_device_x(device_in).call();
227}
228
229
241
247 public:
248 // args declaration
250 size_t m_size;
253
254 // constructor
255 register_memory_x(void* address_in, size_t size_in) : m_address(address_in), m_size(size_in) {}
256
257 // setter
258 inline register_memory_x&& address(void* address_in) { m_address = address_in; return std::move(*this); }
259 inline register_memory_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
260 inline register_memory_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
261 inline register_memory_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
262
264 mr_t call() const;
265 inline mr_t operator()() const { return call(); }
266};
267
268inline mr_t register_memory(void* address_in, size_t size_in) {
269 return register_memory_x(address_in, size_in).call();
270}
271
272
282
288 public:
289 // args declaration
292
293 // constructor
294 deregister_memory_x(mr_t* mr_in) : m_mr(mr_in) {}
295
296 // setter
297 inline deregister_memory_x&& mr(mr_t* mr_in) { m_mr = mr_in; return std::move(*this); }
298 inline deregister_memory_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
299
301 void call() const;
302 inline void operator()() const { return call(); }
303};
304
305inline void deregister_memory(mr_t* mr_in) {
306 return deregister_memory_x(mr_in).call();
307}
308
309
319
325 public:
326 // args declaration
329
330 // constructor
331 get_rmr_x(mr_t mr_in) : m_mr(mr_in) {}
332
333 // setter
334 inline get_rmr_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
335 inline get_rmr_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
336
338 rmr_t call() const;
339 inline rmr_t operator()() const { return call(); }
340};
341
342inline rmr_t get_rmr(mr_t mr_in) {
343 return get_rmr_x(mr_in).call();
344}
345
346
358
364 public:
365 // args declaration
370
371 // constructor
373
374 // setter
375 inline alloc_endpoint_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
376 inline alloc_endpoint_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
377 inline alloc_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
378 inline alloc_endpoint_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
379
381 endpoint_t call() const;
382 inline endpoint_t operator()() const { return call(); }
383};
384
386 return alloc_endpoint_x().call();
387}
388
389
399
405 public:
406 // args declaration
409
410 // constructor
411 free_endpoint_x(endpoint_t* endpoint_in) : m_endpoint(endpoint_in) {}
412
413 // setter
414 inline free_endpoint_x&& endpoint(endpoint_t* endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
415 inline free_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
416
418 void call() const;
419 inline void operator()() const { return call(); }
420};
421
422inline void free_endpoint(endpoint_t* endpoint_in) {
423 return free_endpoint_x(endpoint_in).call();
424}
425
426
438
444 public:
445 // args declaration
450
451 // constructor
452 net_poll_cq_x(size_t max_polls_in, net_status_t* statuses_in) : m_max_polls(max_polls_in), m_statuses(statuses_in) {}
453
454 // setter
455 inline net_poll_cq_x&& max_polls(size_t max_polls_in) { m_max_polls = max_polls_in; return std::move(*this); }
456 inline net_poll_cq_x&& statuses(net_status_t* statuses_in) { m_statuses = statuses_in; return std::move(*this); }
457 inline net_poll_cq_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
458 inline net_poll_cq_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
459
461 size_t call() const;
462 inline size_t operator()() const { return call(); }
463};
464
465inline size_t net_poll_cq(size_t max_polls_in, net_status_t* statuses_in) {
466 return net_poll_cq_x(max_polls_in, statuses_in).call();
467}
468
469
483
489 public:
490 // args declaration
491 void* m_buffer;
492 size_t m_size;
497
498 // constructor
499 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) {}
500
501 // setter
502 inline net_post_recv_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
503 inline net_post_recv_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
504 inline net_post_recv_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
505 inline net_post_recv_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
506 inline net_post_recv_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
507 inline net_post_recv_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
508
510 error_t call() const;
511 inline error_t operator()() const { return call(); }
512};
513
514inline error_t net_post_recv(void* buffer_in, size_t size_in, mr_t mr_in) {
515 return net_post_recv_x(buffer_in, size_in, mr_in).call();
516}
517
518
534
540 public:
541 // args declaration
543 void* m_buffer;
544 size_t m_size;
550
551 // constructor
552 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) {}
553
554 // setter
555 inline net_post_sends_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
556 inline net_post_sends_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
557 inline net_post_sends_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
558 inline net_post_sends_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
559 inline net_post_sends_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
560 inline net_post_sends_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
561 inline net_post_sends_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
562 inline net_post_sends_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
563
565 error_t call() const;
566 inline error_t operator()() const { return call(); }
567};
568
569inline error_t net_post_sends(int rank_in, void* buffer_in, size_t size_in) {
570 return net_post_sends_x(rank_in, buffer_in, size_in).call();
571}
572
573
590
596 public:
597 // args declaration
599 void* m_buffer;
600 size_t m_size;
607
608 // constructor
609 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) {}
610
611 // setter
612 inline net_post_send_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
613 inline net_post_send_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
614 inline net_post_send_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
615 inline net_post_send_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
616 inline net_post_send_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
617 inline net_post_send_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
618 inline net_post_send_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
619 inline net_post_send_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
620 inline net_post_send_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
621
623 error_t call() const;
624 inline error_t operator()() const { return call(); }
625};
626
627inline error_t net_post_send(int rank_in, void* buffer_in, size_t size_in, mr_t mr_in) {
628 return net_post_send_x(rank_in, buffer_in, size_in, mr_in).call();
629}
630
631
648
654 public:
655 // args declaration
657 void* m_buffer;
658 size_t m_size;
659 uint64_t m_offset;
665
666 // constructor
667 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) {}
668
669 // setter
670 inline net_post_puts_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
671 inline net_post_puts_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
672 inline net_post_puts_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
673 inline net_post_puts_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
674 inline net_post_puts_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
675 inline net_post_puts_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
676 inline net_post_puts_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
677 inline net_post_puts_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
678 inline net_post_puts_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
679
681 error_t call() const;
682 inline error_t operator()() const { return call(); }
683};
684
685inline error_t net_post_puts(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) {
686 return net_post_puts_x(rank_in, buffer_in, size_in, offset_in, rmr_in).call();
687}
688
689
707
713 public:
714 // args declaration
716 void* m_buffer;
717 size_t m_size;
719 uint64_t m_offset;
725
726 // constructor
727 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) {}
728
729 // setter
730 inline net_post_put_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
731 inline net_post_put_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
732 inline net_post_put_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
733 inline net_post_put_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
734 inline net_post_put_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
735 inline net_post_put_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
736 inline net_post_put_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
737 inline net_post_put_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
738 inline net_post_put_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
739 inline net_post_put_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
740
742 error_t call() const;
743 inline error_t operator()() const { return call(); }
744};
745
746inline 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) {
747 return net_post_put_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
748}
749
750
768
774 public:
775 // args declaration
777 void* m_buffer;
778 size_t m_size;
779 uint64_t m_offset;
786
787 // constructor
788 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) {}
789
790 // setter
791 inline net_post_putImms_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
792 inline net_post_putImms_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
793 inline net_post_putImms_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
794 inline net_post_putImms_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
795 inline net_post_putImms_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
796 inline net_post_putImms_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
797 inline net_post_putImms_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
798 inline net_post_putImms_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
799 inline net_post_putImms_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
800 inline net_post_putImms_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
801
803 error_t call() const;
804 inline error_t operator()() const { return call(); }
805};
806
807inline error_t net_post_putImms(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) {
808 return net_post_putImms_x(rank_in, buffer_in, size_in, offset_in, rmr_in).call();
809}
810
811
830
836 public:
837 // args declaration
839 void* m_buffer;
840 size_t m_size;
842 uint64_t m_offset;
849
850 // constructor
851 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) {}
852
853 // setter
854 inline net_post_putImm_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
855 inline net_post_putImm_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
856 inline net_post_putImm_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
857 inline net_post_putImm_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
858 inline net_post_putImm_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
859 inline net_post_putImm_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
860 inline net_post_putImm_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
861 inline net_post_putImm_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
862 inline net_post_putImm_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
863 inline net_post_putImm_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
864 inline net_post_putImm_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
865
867 error_t call() const;
868 inline error_t operator()() const { return call(); }
869};
870
871inline 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) {
872 return net_post_putImm_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
873}
874
875
893
899 public:
900 // args declaration
902 void* m_buffer;
903 size_t m_size;
905 uint64_t m_offset;
911
912 // constructor
913 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) {}
914
915 // setter
916 inline net_post_get_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
917 inline net_post_get_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
918 inline net_post_get_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
919 inline net_post_get_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
920 inline net_post_get_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
921 inline net_post_get_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
922 inline net_post_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
923 inline net_post_get_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
924 inline net_post_get_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
925 inline net_post_get_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
926
928 error_t call() const;
929 inline error_t operator()() const { return call(); }
930};
931
932inline 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) {
933 return net_post_get_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
934}
935
936
965
971 public:
972 // args declaration
976 size_t m_size;
994
995 // constructor
996 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) {}
997
998 // setter
999 inline post_comm_x&& direction(direction_t direction_in) { m_direction = direction_in; return std::move(*this); }
1000 inline post_comm_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1001 inline post_comm_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
1002 inline post_comm_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1003 inline post_comm_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
1004 inline post_comm_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1005 inline post_comm_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1006 inline post_comm_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1007 inline post_comm_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1008 inline post_comm_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1009 inline post_comm_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1010 inline post_comm_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1011 inline post_comm_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
1012 inline post_comm_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1013 inline post_comm_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
1014 inline post_comm_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
1015 inline post_comm_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1016 inline post_comm_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
1017 inline post_comm_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
1018 inline post_comm_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
1019 inline post_comm_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
1020
1022 status_t call() const;
1023 inline status_t operator()() const { return call(); }
1024};
1025
1026inline status_t post_comm(direction_t direction_in, int rank_in, void* local_buffer_in, size_t size_in, comp_t local_comp_in) {
1027 return post_comm_x(direction_in, rank_in, local_buffer_in, size_in, local_comp_in).call();
1028}
1029
1030
1054
1060 public:
1061 // args declaration
1064 size_t m_size;
1078
1079 // constructor
1080 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) {}
1081
1082 // setter
1083 inline post_am_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1084 inline post_am_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
1085 inline post_am_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1086 inline post_am_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
1087 inline post_am_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
1088 inline post_am_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1089 inline post_am_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1090 inline post_am_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1091 inline post_am_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1092 inline post_am_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1093 inline post_am_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1094 inline post_am_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
1095 inline post_am_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1096 inline post_am_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
1097 inline post_am_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
1098 inline post_am_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
1099
1101 status_t call() const;
1102 inline status_t operator()() const { return call(); }
1103};
1104
1105inline 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) {
1106 return post_am_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_comp_in).call();
1107}
1108
1109
1134
1140 public:
1141 // args declaration
1144 size_t m_size;
1159
1160 // constructor
1161 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) {}
1162
1163 // setter
1164 inline post_send_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1165 inline post_send_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
1166 inline post_send_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1167 inline post_send_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
1168 inline post_send_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
1169 inline post_send_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1170 inline post_send_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1171 inline post_send_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1172 inline post_send_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1173 inline post_send_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1174 inline post_send_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1175 inline post_send_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1176 inline post_send_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1177 inline post_send_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
1178 inline post_send_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
1179 inline post_send_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
1180 inline post_send_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
1181
1183 status_t call() const;
1184 inline status_t operator()() const { return call(); }
1185};
1186
1187inline status_t post_send(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) {
1188 return post_send_x(rank_in, local_buffer_in, size_in, tag_in, local_comp_in).call();
1189}
1190
1191
1216
1222 public:
1223 // args declaration
1226 size_t m_size;
1241
1242 // constructor
1243 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) {}
1244
1245 // setter
1246 inline post_recv_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1247 inline post_recv_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
1248 inline post_recv_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1249 inline post_recv_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
1250 inline post_recv_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
1251 inline post_recv_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1252 inline post_recv_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1253 inline post_recv_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1254 inline post_recv_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1255 inline post_recv_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1256 inline post_recv_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1257 inline post_recv_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1258 inline post_recv_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1259 inline post_recv_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
1260 inline post_recv_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
1261 inline post_recv_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
1262 inline post_recv_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
1263
1265 status_t call() const;
1266 inline status_t operator()() const { return call(); }
1267};
1268
1269inline status_t post_recv(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) {
1270 return post_recv_x(rank_in, local_buffer_in, size_in, tag_in, local_comp_in).call();
1271}
1272
1273
1299
1305 public:
1306 // args declaration
1309 size_t m_size;
1311 uintptr_t m_remote_disp;
1325
1326 // constructor
1327 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) {}
1328
1329 // setter
1330 inline post_put_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1331 inline post_put_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
1332 inline post_put_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1333 inline post_put_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
1334 inline post_put_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
1335 inline post_put_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1336 inline post_put_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1337 inline post_put_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1338 inline post_put_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1339 inline post_put_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1340 inline post_put_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1341 inline post_put_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1342 inline post_put_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
1343 inline post_put_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
1344 inline post_put_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1345 inline post_put_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
1346 inline post_put_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
1347 inline post_put_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
1348
1350 status_t call() const;
1351 inline status_t operator()() const { return call(); }
1352};
1353
1354inline 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) {
1355 return post_put_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_disp_in, rmr_in).call();
1356}
1357
1358
1384
1390 public:
1391 // args declaration
1394 size_t m_size;
1396 uintptr_t m_remote_disp;
1410
1411 // constructor
1412 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) {}
1413
1414 // setter
1415 inline post_get_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1416 inline post_get_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
1417 inline post_get_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1418 inline post_get_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
1419 inline post_get_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
1420 inline post_get_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1421 inline post_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1422 inline post_get_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1423 inline post_get_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1424 inline post_get_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1425 inline post_get_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1426 inline post_get_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1427 inline post_get_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
1428 inline post_get_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
1429 inline post_get_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1430 inline post_get_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
1431 inline post_get_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
1432 inline post_get_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
1433
1435 status_t call() const;
1436 inline status_t operator()() const { return call(); }
1437};
1438
1439inline 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) {
1440 return post_get_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_disp_in, rmr_in).call();
1441}
1442
1443
1454
1460 public:
1461 // args declaration
1465
1466 // constructor
1468
1469 // setter
1470 inline progress_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1471 inline progress_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1472 inline progress_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1473
1475 error_t call() const;
1476 inline error_t operator()() const { return call(); }
1477};
1478
1480 return progress_x().call();
1481}
1482
1483
1493
1499 public:
1500 // args declaration
1503
1504 // constructor
1506
1507 // setter
1508 inline test_drained_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1509 inline test_drained_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1510
1512 error_t call() const;
1513 inline error_t operator()() const { return call(); }
1514};
1515
1517 return test_drained_x().call();
1518}
1519
1520
1530
1536 public:
1537 // args declaration
1540
1541 // constructor
1543
1544 // setter
1545 inline wait_drained_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1546 inline wait_drained_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1547
1549 void call() const;
1550 inline void operator()() const { return call(); }
1551};
1552
1553inline void wait_drained() {
1554 return wait_drained_x().call();
1555}
1556
1557
1571
1577 public:
1578 // args declaration
1585
1586 // constructor
1588
1589 // setter
1590 inline barrier_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1591 inline barrier_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1592 inline barrier_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1593 inline barrier_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1594 inline barrier_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1595 inline barrier_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1596
1598 void call() const;
1599 inline void operator()() const { return call(); }
1600};
1601
1602inline void barrier() {
1603 return barrier_x().call();
1604}
1605
1606
1624
1630 public:
1631 // args declaration
1633 size_t m_size;
1642
1643 // constructor
1644 broadcast_x(void* buffer_in, size_t size_in, int root_in) : m_buffer(buffer_in), m_size(size_in), m_root(root_in) {}
1645
1646 // setter
1647 inline broadcast_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1648 inline broadcast_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1649 inline broadcast_x&& root(int root_in) { m_root = root_in; return std::move(*this); }
1650 inline broadcast_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1651 inline broadcast_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1652 inline broadcast_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1653 inline broadcast_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1654 inline broadcast_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1655 inline broadcast_x&& algorithm(broadcast_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
1656 inline broadcast_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
1657
1659 void call() const;
1660 inline void operator()() const { return call(); }
1661};
1662
1663inline void broadcast(void* buffer_in, size_t size_in, int root_in) {
1664 return broadcast_x(buffer_in, size_in, root_in).call();
1665}
1666
1667
1685
1691 public:
1692 // args declaration
1693 const void* m_sendbuf;
1695 size_t m_count;
1703
1704 // constructor
1705 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) {}
1706
1707 // setter
1708 inline reduce_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
1709 inline reduce_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
1710 inline reduce_x&& count(size_t count_in) { m_count = count_in; return std::move(*this); }
1711 inline reduce_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
1712 inline reduce_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
1713 inline reduce_x&& root(int root_in) { m_root = root_in; return std::move(*this); }
1714 inline reduce_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1715 inline reduce_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1716 inline reduce_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1717 inline reduce_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1718
1720 void call() const;
1721 inline void operator()() const { return call(); }
1722};
1723
1724inline 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) {
1725 return reduce_x(sendbuf_in, recvbuf_in, count_in, item_size_in, op_in, root_in).call();
1726}
1727
1728
1748
1754 public:
1755 // args declaration
1756 const void* m_sendbuf;
1768
1769 // constructor
1770 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) {}
1771
1772 // setter
1773 inline reduce_scatter_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
1774 inline reduce_scatter_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
1775 inline reduce_scatter_x&& recvcount(size_t recvcount_in) { m_recvcount = recvcount_in; return std::move(*this); }
1776 inline reduce_scatter_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
1777 inline reduce_scatter_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
1778 inline reduce_scatter_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1779 inline reduce_scatter_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1780 inline reduce_scatter_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1781 inline reduce_scatter_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1782 inline reduce_scatter_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1783 inline reduce_scatter_x&& algorithm(reduce_scatter_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
1784 inline reduce_scatter_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
1785
1787 void call() const;
1788 inline void operator()() const { return call(); }
1789};
1790
1791inline void reduce_scatter(const void* sendbuf_in, void* recvbuf_in, size_t recvcount_in, size_t item_size_in, reduce_op_t op_in) {
1792 return reduce_scatter_x(sendbuf_in, recvbuf_in, recvcount_in, item_size_in, op_in).call();
1793}
1794
1795
1815
1821 public:
1822 // args declaration
1823 const void* m_sendbuf;
1825 size_t m_count;
1835
1836 // constructor
1837 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) {}
1838
1839 // setter
1840 inline allreduce_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
1841 inline allreduce_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
1842 inline allreduce_x&& count(size_t count_in) { m_count = count_in; return std::move(*this); }
1843 inline allreduce_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
1844 inline allreduce_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
1845 inline allreduce_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1846 inline allreduce_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1847 inline allreduce_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1848 inline allreduce_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1849 inline allreduce_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1850 inline allreduce_x&& algorithm(allreduce_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
1851 inline allreduce_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
1852
1854 void call() const;
1855 inline void operator()() const { return call(); }
1856};
1857
1858inline void allreduce(const void* sendbuf_in, void* recvbuf_in, size_t count_in, size_t item_size_in, reduce_op_t op_in) {
1859 return allreduce_x(sendbuf_in, recvbuf_in, count_in, item_size_in, op_in).call();
1860}
1861
1862
1877
1883 public:
1884 // args declaration
1885 const void* m_sendbuf;
1887 size_t m_size;
1892
1893 // constructor
1894 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) {}
1895
1896 // setter
1897 inline allgather_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
1898 inline allgather_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
1899 inline allgather_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1900 inline allgather_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1901 inline allgather_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1902 inline allgather_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1903 inline allgather_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1904
1906 void call() const;
1907 inline void operator()() const { return call(); }
1908};
1909
1910inline void allgather(const void* sendbuf_in, void* recvbuf_in, size_t size_in) {
1911 return allgather_x(sendbuf_in, recvbuf_in, size_in).call();
1912}
1913
1914
1930
1936 public:
1937 // args declaration
1938 const void* m_sendbuf;
1940 size_t m_size;
1946
1947 // constructor
1948 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) {}
1949
1950 // setter
1951 inline alltoall_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
1952 inline alltoall_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
1953 inline alltoall_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1954 inline alltoall_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1955 inline alltoall_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1956 inline alltoall_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1957 inline alltoall_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1958 inline alltoall_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1959
1961 void call() const;
1962 inline void operator()() const { return call(); }
1963};
1964
1965inline void alltoall(const void* sendbuf_in, void* recvbuf_in, size_t size_in) {
1966 return alltoall_x(sendbuf_in, recvbuf_in, size_in).call();
1967}
1968
1969
1987
1993 public:
1994 // args declaration
2005
2006 // constructor
2008
2009 // setter
2010 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); }
2011 inline alloc_runtime_x&& imm_nbits_tag(int imm_nbits_tag_in) { m_imm_nbits_tag = imm_nbits_tag_in; return std::move(*this); }
2012 inline alloc_runtime_x&& imm_nbits_rcomp(int imm_nbits_rcomp_in) { m_imm_nbits_rcomp = imm_nbits_rcomp_in; return std::move(*this); }
2013 inline alloc_runtime_x&& rdv_protocol(attr_rdv_protocol_t rdv_protocol_in) { m_rdv_protocol = rdv_protocol_in; return std::move(*this); }
2014 inline alloc_runtime_x&& alloc_default_device(bool alloc_default_device_in) { m_alloc_default_device = alloc_default_device_in; return std::move(*this); }
2015 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); }
2016 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); }
2017 inline alloc_runtime_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2018 inline alloc_runtime_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2019 inline alloc_runtime_x&& device_name(std::string device_name_in) { m_device_name = device_name_in; return std::move(*this); }
2020
2022 runtime_t call() const;
2023 inline runtime_t operator()() const { return call(); }
2024};
2025
2027 return alloc_runtime_x().call();
2028}
2029
2030
2039
2045 public:
2046 // args declaration
2048
2049 // constructor
2050 free_runtime_x(runtime_t* runtime_in) : m_runtime(runtime_in) {}
2051
2052 // setter
2053 inline free_runtime_x&& runtime(runtime_t* runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2054
2056 void call() const;
2057 inline void operator()() const { return call(); }
2058};
2059
2060inline void free_runtime(runtime_t* runtime_in) {
2061 return free_runtime_x(runtime_in).call();
2062}
2063
2064
2082
2088 public:
2089 // args declaration
2100
2101 // constructor
2103
2104 // setter
2105 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); }
2106 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); }
2107 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); }
2108 inline g_runtime_init_x&& rdv_protocol(attr_rdv_protocol_t rdv_protocol_in) { m_rdv_protocol = rdv_protocol_in; return std::move(*this); }
2109 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); }
2110 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); }
2111 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); }
2112 inline g_runtime_init_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2113 inline g_runtime_init_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2114 inline g_runtime_init_x&& device_name(std::string device_name_in) { m_device_name = device_name_in; return std::move(*this); }
2115
2117 runtime_t call() const;
2118 inline runtime_t operator()() const { return call(); }
2119};
2120
2122 return g_runtime_init_x().call();
2123}
2124
2125
2134
2140 public:
2141 // args declaration
2142
2143 // constructor
2145
2146 // setter
2147
2148 void call_impl() const;
2149 void call() const;
2150 inline void operator()() const { return call(); }
2151};
2152
2153inline void g_runtime_fina() {
2154 return g_runtime_fina_x().call();
2155}
2156
2157
2166
2172 public:
2173 // args declaration
2174
2175 // constructor
2177
2178 // setter
2179
2181 runtime_t call() const;
2182 inline runtime_t operator()() const { return call(); }
2183};
2184
2186 return get_g_runtime_x().call();
2187}
2188
2189
2202
2208 public:
2209 // args declaration
2215
2216 // constructor
2218
2219 // setter
2220 inline alloc_packet_pool_x&& packet_size(size_t packet_size_in) { m_packet_size = packet_size_in; return std::move(*this); }
2221 inline alloc_packet_pool_x&& npackets(size_t npackets_in) { m_npackets = npackets_in; return std::move(*this); }
2222 inline alloc_packet_pool_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2223 inline alloc_packet_pool_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2224 inline alloc_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2225
2226 packet_pool_t call_impl(size_t packet_size, size_t npackets, const char* name, void* user_context, runtime_t runtime) const;
2227 packet_pool_t call() const;
2228 inline packet_pool_t operator()() const { return call(); }
2229};
2230
2234
2235
2245
2251 public:
2252 // args declaration
2255
2256 // constructor
2257 free_packet_pool_x(packet_pool_t* packet_pool_in) : m_packet_pool(packet_pool_in) {}
2258
2259 // setter
2260 inline free_packet_pool_x&& packet_pool(packet_pool_t* packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2261 inline free_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2262
2264 void call() const;
2265 inline void operator()() const { return call(); }
2266};
2267
2268inline void free_packet_pool(packet_pool_t* packet_pool_in) {
2269 return free_packet_pool_x(packet_pool_in).call();
2270}
2271
2272
2283
2289 public:
2290 // args declaration
2294
2295 // constructor
2296 register_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in) : m_packet_pool(packet_pool_in), m_device(device_in) {}
2297
2298 // setter
2299 inline register_packet_pool_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2300 inline register_packet_pool_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2301 inline register_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2302
2304 void call() const;
2305 inline void operator()() const { return call(); }
2306};
2307
2308inline void register_packet_pool(packet_pool_t packet_pool_in, device_t device_in) {
2309 return register_packet_pool_x(packet_pool_in, device_in).call();
2310}
2311
2312
2323
2329 public:
2330 // args declaration
2334
2335 // constructor
2336 deregister_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in) : m_packet_pool(packet_pool_in), m_device(device_in) {}
2337
2338 // setter
2339 inline deregister_packet_pool_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2340 inline deregister_packet_pool_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2341 inline deregister_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2342
2344 void call() const;
2345 inline void operator()() const { return call(); }
2346};
2347
2348inline void deregister_packet_pool(packet_pool_t packet_pool_in, device_t device_in) {
2349 return deregister_packet_pool_x(packet_pool_in, device_in).call();
2350}
2351
2352
2362
2368 public:
2369 // args declaration
2372
2373 // constructor
2375
2376 // setter
2377 inline get_upacket_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2378 inline get_upacket_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2379
2381 void* call() const;
2382 inline void* operator()() const { return call(); }
2383};
2384
2385inline void* get_upacket() {
2386 return get_upacket_x().call();
2387}
2388
2389
2399
2405 public:
2406 // args declaration
2409
2410 // constructor
2411 put_upacket_x(void* packet_in) : m_packet(packet_in) {}
2412
2413 // setter
2414 inline put_upacket_x&& packet(void* packet_in) { m_packet = packet_in; return std::move(*this); }
2415 inline put_upacket_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2416
2417 void call_impl(void* packet, runtime_t runtime) const;
2418 void call() const;
2419 inline void operator()() const { return call(); }
2420};
2421
2422inline void put_upacket(void* packet_in) {
2423 return put_upacket_x(packet_in).call();
2424}
2425
2426
2438
2444 public:
2445 // args declaration
2450
2451 // constructor
2453
2454 // setter
2455 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); }
2456 inline alloc_matching_engine_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2457 inline alloc_matching_engine_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2458 inline alloc_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2459
2461 matching_engine_t call() const;
2462 inline matching_engine_t operator()() const { return call(); }
2463};
2464
2468
2469
2479
2485 public:
2486 // args declaration
2489
2490 // constructor
2491 free_matching_engine_x(matching_engine_t* matching_engine_in) : m_matching_engine(matching_engine_in) {}
2492
2493 // setter
2494 inline free_matching_engine_x&& matching_engine(matching_engine_t* matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2495 inline free_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2496
2498 void call() const;
2499 inline void operator()() const { return call(); }
2500};
2501
2502inline void free_matching_engine(matching_engine_t* matching_engine_in) {
2503 return free_matching_engine_x(matching_engine_in).call();
2504}
2505
2506
2519
2525 public:
2526 // args declaration
2532
2533 // constructor
2534 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) {}
2535
2536 // setter
2537 inline matching_engine_insert_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2538 inline matching_engine_insert_x&& key(matching_entry_key_t key_in) { m_key = key_in; return std::move(*this); }
2539 inline matching_engine_insert_x&& value(matching_entry_val_t value_in) { m_value = value_in; return std::move(*this); }
2540 inline matching_engine_insert_x&& entry_type(matching_entry_type_t entry_type_in) { m_entry_type = entry_type_in; return std::move(*this); }
2541 inline matching_engine_insert_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2542
2544 matching_entry_val_t call() const;
2545 inline matching_entry_val_t operator()() const { return call(); }
2546};
2547
2549 return matching_engine_insert_x(matching_engine_in, key_in, value_in, entry_type_in).call();
2550}
2551
2552
2562
2568 public:
2569 // args declaration
2572
2573 // constructor
2574 set_allocator_x(allocator_base_t* allocator_in) : m_allocator(allocator_in) {}
2575
2576 // setter
2577 inline set_allocator_x&& allocator(allocator_base_t* allocator_in) { m_allocator = allocator_in; return std::move(*this); }
2578 inline set_allocator_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2579
2581 void call() const;
2582 inline void operator()() const { return call(); }
2583};
2584
2585inline void set_allocator(allocator_base_t* allocator_in) {
2586 return set_allocator_x(allocator_in).call();
2587}
2588
2589
2598
2604 public:
2605 // args declaration
2607
2608 // constructor
2610
2611 // setter
2612 inline get_allocator_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2613
2615 allocator_base_t* call() const;
2616 inline allocator_base_t* operator()() const { return call(); }
2617};
2618
2620 return get_allocator_x().call();
2621}
2622
2623
2632
2638 public:
2639 // args declaration
2641
2642 // constructor
2644
2645 // setter
2646 inline get_default_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2647
2649 net_context_t call() const;
2650 inline net_context_t operator()() const { return call(); }
2651};
2652
2656
2657
2666
2672 public:
2673 // args declaration
2675
2676 // constructor
2678
2679 // setter
2680 inline get_default_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2681
2683 device_t call() const;
2684 inline device_t operator()() const { return call(); }
2685};
2686
2688 return get_default_device_x().call();
2689}
2690
2691
2701
2707 public:
2708 // args declaration
2711
2712 // constructor
2714
2715 // setter
2716 inline get_default_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2717 inline get_default_endpoint_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2718
2720 endpoint_t call() const;
2721 inline endpoint_t operator()() const { return call(); }
2722};
2723
2727
2728
2737
2743 public:
2744 // args declaration
2746
2747 // constructor
2749
2750 // setter
2751 inline get_default_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2752
2754 packet_pool_t call() const;
2755 inline packet_pool_t operator()() const { return call(); }
2756};
2757
2761
2762
2771
2777 public:
2778 // args declaration
2780
2781 // constructor
2783
2784 // setter
2785 inline get_default_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2786
2788 matching_engine_t call() const;
2789 inline matching_engine_t operator()() const { return call(); }
2790};
2791
2795
2796
2806
2812 public:
2813 // args declaration
2816
2817 // constructor
2819
2820 // setter
2821 inline get_max_bcopy_size_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2822 inline get_max_bcopy_size_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2823
2825 size_t call() const;
2826 inline size_t operator()() const { return call(); }
2827};
2828
2829inline size_t get_max_bcopy_size() {
2830 return get_max_bcopy_size_x().call();
2831}
2832
2833
2843
2849 public:
2850 // args declaration
2853
2854 // constructor
2855 free_comp_x(comp_t* comp_in) : m_comp(comp_in) {}
2856
2857 // setter
2858 inline free_comp_x&& comp(comp_t* comp_in) { m_comp = comp_in; return std::move(*this); }
2859 inline free_comp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2860
2862 void call() const;
2863 inline void operator()() const { return call(); }
2864};
2865
2866inline void free_comp(comp_t* comp_in) {
2867 return free_comp_x(comp_in).call();
2868}
2869
2870
2881
2887 public:
2888 // args declaration
2892
2893 // constructor
2894 comp_signal_x(comp_t comp_in, status_t status_in) : m_comp(comp_in), m_status(status_in) {}
2895
2896 // setter
2897 inline comp_signal_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2898 inline comp_signal_x&& status(status_t status_in) { m_status = status_in; return std::move(*this); }
2899 inline comp_signal_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2900
2902 void call() const;
2903 inline void operator()() const { return call(); }
2904};
2905
2906inline void comp_signal(comp_t comp_in, status_t status_in) {
2907 return comp_signal_x(comp_in, status_in).call();
2908}
2909
2910
2920
2926 public:
2927 // args declaration
2930
2931 // constructor
2933
2934 // setter
2935 inline reserve_rcomps_x&& n(rcomp_t n_in) { m_n = n_in; return std::move(*this); }
2936 inline reserve_rcomps_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2937
2939 rcomp_t call() const;
2940 inline rcomp_t operator()() const { return call(); }
2941};
2942
2944 return reserve_rcomps_x(n_in).call();
2945}
2946
2947
2958
2964 public:
2965 // args declaration
2969
2970 // constructor
2971 register_rcomp_x(comp_t comp_in) : m_comp(comp_in) {}
2972
2973 // setter
2974 inline register_rcomp_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2975 inline register_rcomp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2976 inline register_rcomp_x&& rcomp(rcomp_t rcomp_in) { m_rcomp = rcomp_in; return std::move(*this); }
2977
2979 rcomp_t call() const;
2980 inline rcomp_t operator()() const { return call(); }
2981};
2982
2984 return register_rcomp_x(comp_in).call();
2985}
2986
2987
2997
3003 public:
3004 // args declaration
3007
3008 // constructor
3009 deregister_rcomp_x(rcomp_t rcomp_in) : m_rcomp(rcomp_in) {}
3010
3011 // setter
3012 inline deregister_rcomp_x&& rcomp(rcomp_t rcomp_in) { m_rcomp = rcomp_in; return std::move(*this); }
3013 inline deregister_rcomp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3014
3016 void call() const;
3017 inline void operator()() const { return call(); }
3018};
3019
3020inline void deregister_rcomp(rcomp_t rcomp_in) {
3021 return deregister_rcomp_x(rcomp_in).call();
3022}
3023
3024
3037
3043 public:
3044 // args declaration
3050
3051 // constructor
3053
3054 // setter
3055 inline alloc_sync_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3056 inline alloc_sync_x&& threshold(int threshold_in) { m_threshold = threshold_in; return std::move(*this); }
3057 inline alloc_sync_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
3058 inline alloc_sync_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3059 inline alloc_sync_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3060
3062 comp_t call() const;
3063 inline comp_t operator()() const { return call(); }
3064};
3065
3067 return alloc_sync_x().call();
3068}
3069
3070
3081
3087 public:
3088 // args declaration
3092
3093 // constructor
3094 sync_test_x(comp_t comp_in, status_t* p_out_in) : m_comp(comp_in), m_p_out(p_out_in) {}
3095
3096 // setter
3097 inline sync_test_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3098 inline sync_test_x&& p_out(status_t* p_out_in) { m_p_out = p_out_in; return std::move(*this); }
3099 inline sync_test_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3100
3102 bool call() const;
3103 inline bool operator()() const { return call(); }
3104};
3105
3106inline bool sync_test(comp_t comp_in, status_t* p_out_in) {
3107 return sync_test_x(comp_in, p_out_in).call();
3108}
3109
3110
3123
3129 public:
3130 // args declaration
3136
3137 // constructor
3138 sync_wait_x(comp_t comp_in, status_t* p_out_in) : m_comp(comp_in), m_p_out(p_out_in) {}
3139
3140 // setter
3141 inline sync_wait_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3142 inline sync_wait_x&& p_out(status_t* p_out_in) { m_p_out = p_out_in; return std::move(*this); }
3143 inline sync_wait_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3144 inline sync_wait_x&& do_progress(bool do_progress_in) { m_do_progress = do_progress_in; return std::move(*this); }
3145 inline sync_wait_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3146
3148 void call() const;
3149 inline void operator()() const { return call(); }
3150};
3151
3152inline void sync_wait(comp_t comp_in, status_t* p_out_in) {
3153 return sync_wait_x(comp_in, p_out_in).call();
3154}
3155
3156
3167
3173 public:
3174 // args declaration
3178
3179 // constructor
3181
3182 // setter
3183 inline alloc_counter_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3184 inline alloc_counter_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3185 inline alloc_counter_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3186
3188 comp_t call() const;
3189 inline comp_t operator()() const { return call(); }
3190};
3191
3193 return alloc_counter_x().call();
3194}
3195
3196
3206
3212 public:
3213 // args declaration
3216
3217 // constructor
3218 counter_get_x(comp_t comp_in) : m_comp(comp_in) {}
3219
3220 // setter
3221 inline counter_get_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3222 inline counter_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3223
3225 int64_t call() const;
3226 inline int64_t operator()() const { return call(); }
3227};
3228
3229inline int64_t counter_get(comp_t comp_in) {
3230 return counter_get_x(comp_in).call();
3231}
3232
3233
3244
3250 public:
3251 // args declaration
3253 int64_t m_value;
3255
3256 // constructor
3257 counter_set_x(comp_t comp_in, int64_t value_in) : m_comp(comp_in), m_value(value_in) {}
3258
3259 // setter
3260 inline counter_set_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3261 inline counter_set_x&& value(int64_t value_in) { m_value = value_in; return std::move(*this); }
3262 inline counter_set_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3263
3265 void call() const;
3266 inline void operator()() const { return call(); }
3267};
3268
3269inline void counter_set(comp_t comp_in, int64_t value_in) {
3270 return counter_set_x(comp_in, value_in).call();
3271}
3272
3273
3287
3293 public:
3294 // args declaration
3301
3302 // constructor
3304
3305 // setter
3306 inline alloc_cq_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3307 inline alloc_cq_x&& default_length(int default_length_in) { m_default_length = default_length_in; return std::move(*this); }
3308 inline alloc_cq_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
3309 inline alloc_cq_x&& cq_type(attr_cq_type_t cq_type_in) { m_cq_type = cq_type_in; return std::move(*this); }
3310 inline alloc_cq_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3311 inline alloc_cq_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3312
3314 comp_t call() const;
3315 inline comp_t operator()() const { return call(); }
3316};
3317
3319 return alloc_cq_x().call();
3320}
3321
3322
3332
3338 public:
3339 // args declaration
3342
3343 // constructor
3344 cq_pop_x(comp_t comp_in) : m_comp(comp_in) {}
3345
3346 // setter
3347 inline cq_pop_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3348 inline cq_pop_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3349
3351 status_t call() const;
3352 inline status_t operator()() const { return call(); }
3353};
3354
3355inline status_t cq_pop(comp_t comp_in) {
3356 return cq_pop_x(comp_in).call();
3357}
3358
3359
3372
3378 public:
3379 // args declaration
3385
3386 // constructor
3387 alloc_handler_x(comp_handler_t handler_in) : m_handler(handler_in) {}
3388
3389 // setter
3390 inline alloc_handler_x&& handler(comp_handler_t handler_in) { m_handler = handler_in; return std::move(*this); }
3391 inline alloc_handler_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3392 inline alloc_handler_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
3393 inline alloc_handler_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3394 inline alloc_handler_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3395
3397 comp_t call() const;
3398 inline comp_t operator()() const { return call(); }
3399};
3400
3402 return alloc_handler_x(handler_in).call();
3403}
3404
3405
3417
3423 public:
3424 // args declaration
3429
3430 // constructor
3432
3433 // setter
3434 inline alloc_graph_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3435 inline alloc_graph_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3436 inline alloc_graph_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3437 inline alloc_graph_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3438
3440 comp_t call() const;
3441 inline comp_t operator()() const { return call(); }
3442};
3443
3445 return alloc_graph_x().call();
3446}
3447
3448
3461
3467 public:
3468 // args declaration
3474
3475 // constructor
3476 graph_add_node_x(comp_t comp_in, graph_node_run_cb_t fn_in) : m_comp(comp_in), m_fn(fn_in) {}
3477
3478 // setter
3479 inline graph_add_node_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3480 inline graph_add_node_x&& fn(graph_node_run_cb_t fn_in) { m_fn = fn_in; return std::move(*this); }
3481 inline graph_add_node_x&& value(void* value_in) { m_value = value_in; return std::move(*this); }
3482 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); }
3483 inline graph_add_node_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3484
3486 graph_node_t call() const;
3487 inline graph_node_t operator()() const { return call(); }
3488};
3489
3491 return graph_add_node_x(comp_in, fn_in).call();
3492}
3493
3494
3507
3513 public:
3514 // args declaration
3520
3521 // constructor
3522 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) {}
3523
3524 // setter
3525 inline graph_add_edge_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3526 inline graph_add_edge_x&& src(graph_node_t src_in) { m_src = src_in; return std::move(*this); }
3527 inline graph_add_edge_x&& dst(graph_node_t dst_in) { m_dst = dst_in; return std::move(*this); }
3528 inline graph_add_edge_x&& fn(graph_edge_run_cb_t fn_in) { m_fn = fn_in; return std::move(*this); }
3529 inline graph_add_edge_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3530
3532 void call() const;
3533 inline void operator()() const { return call(); }
3534};
3535
3536inline void graph_add_edge(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in) {
3537 return graph_add_edge_x(comp_in, src_in, dst_in).call();
3538}
3539
3540
3551
3557 public:
3558 // args declaration
3562
3563 // constructor
3565
3566 // setter
3567 inline graph_node_mark_complete_x&& node(graph_node_t node_in) { m_node = node_in; return std::move(*this); }
3568 inline graph_node_mark_complete_x&& status(status_t status_in) { m_status = status_in; return std::move(*this); }
3569 inline graph_node_mark_complete_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3570
3572 void call() const;
3573 inline void operator()() const { return call(); }
3574};
3575
3577 return graph_node_mark_complete_x(node_in).call();
3578}
3579
3580
3590
3596 public:
3597 // args declaration
3600
3601 // constructor
3602 graph_start_x(comp_t comp_in) : m_comp(comp_in) {}
3603
3604 // setter
3605 inline graph_start_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3606 inline graph_start_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3607
3609 void call() const;
3610 inline void operator()() const { return call(); }
3611};
3612
3613inline void graph_start(comp_t comp_in) {
3614 return graph_start_x(comp_in).call();
3615}
3616
3617
3627
3633 public:
3634 // args declaration
3637
3638 // constructor
3639 graph_test_x(comp_t comp_in) : m_comp(comp_in) {}
3640
3641 // setter
3642 inline graph_test_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3643 inline graph_test_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3644
3646 status_t call() const;
3647 inline status_t operator()() const { return call(); }
3648};
3649
3650inline status_t graph_test(comp_t comp_in) {
3651 return graph_test_x(comp_in).call();
3652}
3653
3654
3655} // namespace lci
3656
3657#endif // LCI_BINDING_POST_HPP_
The actual implementation for allgather.
Definition lci_binding_post.hpp:1882
allgather_x && size(size_t size_in)
Definition lci_binding_post.hpp:1899
allgather_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:1898
void * m_recvbuf
Definition lci_binding_post.hpp:1886
size_t m_size
Definition lci_binding_post.hpp:1887
void call() const
Definition binding.cpp:632
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1888
const void * m_sendbuf
Definition lci_binding_post.hpp:1885
allgather_x && device(device_t device_in)
Definition lci_binding_post.hpp:1901
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1891
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1890
allgather_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1900
allgather_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1902
allgather_x(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:1894
allgather_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1903
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:1889
void operator()() const
Definition lci_binding_post.hpp:1907
allgather_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:1897
The actual implementation for alloc_counter.
Definition lci_binding_post.hpp:3172
alloc_counter_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3183
alloc_counter_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3185
option_t< const char * > m_name
Definition lci_binding_post.hpp:3176
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3175
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3177
comp_t operator()() const
Definition lci_binding_post.hpp:3189
comp_t call_impl(runtime_t runtime, const char *name, void *user_context) const
comp_t call() const
Definition binding.cpp:899
alloc_counter_x && name(const char *name_in)
Definition lci_binding_post.hpp:3184
alloc_counter_x()
Definition lci_binding_post.hpp:3180
The actual implementation for alloc_cq.
Definition lci_binding_post.hpp:3292
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3295
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:3297
alloc_cq_x && cq_type(attr_cq_type_t cq_type_in)
Definition lci_binding_post.hpp:3309
alloc_cq_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:3308
comp_t operator()() const
Definition lci_binding_post.hpp:3315
option_t< int > m_default_length
Definition lci_binding_post.hpp:3296
option_t< attr_cq_type_t > m_cq_type
Definition lci_binding_post.hpp:3298
alloc_cq_x && default_length(int default_length_in)
Definition lci_binding_post.hpp:3307
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:3310
alloc_cq_x()
Definition lci_binding_post.hpp:3303
comp_t call() const
Definition binding.cpp:919
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3300
alloc_cq_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3311
option_t< const char * > m_name
Definition lci_binding_post.hpp:3299
alloc_cq_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3306
The actual implementation for alloc_device.
Definition lci_binding_post.hpp:146
alloc_device_x && alloc_default_endpoint(bool alloc_default_endpoint_in)
Definition lci_binding_post.hpp:173
alloc_device_x()
Definition lci_binding_post.hpp:165
option_t< bool > m_use_reg_cache
Definition lci_binding_post.hpp:156
option_t< const char * > m_name
Definition lci_binding_post.hpp:158
option_t< bool > m_alloc_progress_endpoint
Definition lci_binding_post.hpp:155
option_t< net_context_t > m_net_context
Definition lci_binding_post.hpp:161
alloc_device_x && net_max_recvs(size_t net_max_recvs_in)
Definition lci_binding_post.hpp:169
option_t< attr_ibv_td_strategy_t > m_ibv_td_strategy
Definition lci_binding_post.hpp:157
alloc_device_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:178
option_t< size_t > m_net_max_recvs
Definition lci_binding_post.hpp:150
alloc_device_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:181
alloc_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:179
alloc_device_x && use_reg_cache(bool use_reg_cache_in)
Definition lci_binding_post.hpp:175
alloc_device_x && name(const char *name_in)
Definition lci_binding_post.hpp:177
option_t< double > m_net_send_reserved_pct
Definition lci_binding_post.hpp:152
alloc_device_x && ofi_lock_mode(uint64_t ofi_lock_mode_in)
Definition lci_binding_post.hpp:172
option_t< uint64_t > m_ofi_lock_mode
Definition lci_binding_post.hpp:153
option_t< void * > m_user_context
Definition lci_binding_post.hpp:159
option_t< size_t > m_net_max_sends
Definition lci_binding_post.hpp:149
alloc_device_x && net_send_reserved_pct(double net_send_reserved_pct_in)
Definition lci_binding_post.hpp:171
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:174
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:162
option_t< size_t > m_net_max_cqes
Definition lci_binding_post.hpp:151
alloc_device_x && net_context(net_context_t net_context_in)
Definition lci_binding_post.hpp:180
option_t< bool > m_alloc_default_endpoint
Definition lci_binding_post.hpp:154
device_t operator()() const
Definition lci_binding_post.hpp:185
device_t call() const
Definition binding.cpp:232
alloc_device_x && net_max_cqes(size_t net_max_cqes_in)
Definition lci_binding_post.hpp:170
alloc_device_x && ibv_td_strategy(attr_ibv_td_strategy_t ibv_td_strategy_in)
Definition lci_binding_post.hpp:176
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:160
alloc_device_x && net_max_sends(size_t net_max_sends_in)
Definition lci_binding_post.hpp:168
The actual implementation for alloc_endpoint.
Definition lci_binding_post.hpp:363
endpoint_t call() const
Definition binding.cpp:285
alloc_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:377
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:367
alloc_endpoint_x()
Definition lci_binding_post.hpp:372
option_t< device_t > m_device
Definition lci_binding_post.hpp:369
option_t< const char * > m_name
Definition lci_binding_post.hpp:366
alloc_endpoint_x && device(device_t device_in)
Definition lci_binding_post.hpp:378
endpoint_t operator()() const
Definition lci_binding_post.hpp:382
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:368
alloc_endpoint_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:376
alloc_endpoint_x && name(const char *name_in)
Definition lci_binding_post.hpp:375
The actual implementation for alloc_graph.
Definition lci_binding_post.hpp:3422
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3428
alloc_graph_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3437
comp_t call() const
Definition binding.cpp:944
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3427
alloc_graph_x && name(const char *name_in)
Definition lci_binding_post.hpp:3435
alloc_graph_x()
Definition lci_binding_post.hpp:3431
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:3436
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:3425
alloc_graph_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3434
comp_t operator()() const
Definition lci_binding_post.hpp:3441
option_t< const char * > m_name
Definition lci_binding_post.hpp:3426
The actual implementation for alloc_handler.
Definition lci_binding_post.hpp:3377
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:3381
option_t< const char * > m_name
Definition lci_binding_post.hpp:3383
alloc_handler_x && handler(comp_handler_t handler_in)
Definition lci_binding_post.hpp:3390
alloc_handler_x(comp_handler_t handler_in)
Definition lci_binding_post.hpp:3387
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3384
comp_t call() const
Definition binding.cpp:935
comp_t operator()() const
Definition lci_binding_post.hpp:3398
alloc_handler_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:3392
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:3382
alloc_handler_x && name(const char *name_in)
Definition lci_binding_post.hpp:3393
alloc_handler_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3394
alloc_handler_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3391
comp_handler_t m_handler
Definition lci_binding_post.hpp:3380
The actual implementation for alloc_matching_engine.
Definition lci_binding_post.hpp:2443
matching_engine_t operator()() const
Definition lci_binding_post.hpp:2462
matching_engine_t call() const
Definition binding.cpp:767
alloc_matching_engine_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2457
option_t< attr_matching_engine_type_t > m_matching_engine_type
Definition lci_binding_post.hpp:2446
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2448
alloc_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2458
alloc_matching_engine_x && name(const char *name_in)
Definition lci_binding_post.hpp:2456
option_t< const char * > m_name
Definition lci_binding_post.hpp:2447
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:2455
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2449
alloc_matching_engine_x()
Definition lci_binding_post.hpp:2452
The actual implementation for alloc_net_context.
Definition lci_binding_post.hpp:38
alloc_net_context_x && ofi_provider_name(std::string ofi_provider_name_in)
Definition lci_binding_post.hpp:60
option_t< int > m_ibv_gid_idx
Definition lci_binding_post.hpp:45
alloc_net_context_x && device_name(std::string device_name_in)
Definition lci_binding_post.hpp:65
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:53
alloc_net_context_x && ibv_prefetch_strategy(attr_ibv_prefetch_strategy_t ibv_prefetch_strategy_in)
Definition lci_binding_post.hpp:67
alloc_net_context_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:71
option_t< attr_ibv_odp_strategy_t > m_ibv_odp_strategy
Definition lci_binding_post.hpp:48
alloc_net_context_x && ibv_gid_idx(int ibv_gid_idx_in)
Definition lci_binding_post.hpp:63
alloc_net_context_x()
Definition lci_binding_post.hpp:56
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, std::string device_name, 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
alloc_net_context_x && max_inject_size(size_t max_inject_size_in)
Definition lci_binding_post.hpp:62
option_t< void * > m_user_context
Definition lci_binding_post.hpp:52
alloc_net_context_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:70
option_t< bool > m_use_dmabuf
Definition lci_binding_post.hpp:50
alloc_net_context_x && backend(attr_backend_t backend_in)
Definition lci_binding_post.hpp:59
option_t< std::string > m_device_name
Definition lci_binding_post.hpp:47
option_t< const char * > m_name
Definition lci_binding_post.hpp:51
alloc_net_context_x && ibv_force_gid_auto_select(bool ibv_force_gid_auto_select_in)
Definition lci_binding_post.hpp:64
alloc_net_context_x && name(const char *name_in)
Definition lci_binding_post.hpp:69
alloc_net_context_x && ibv_odp_strategy(attr_ibv_odp_strategy_t ibv_odp_strategy_in)
Definition lci_binding_post.hpp:66
alloc_net_context_x && use_dmabuf(bool use_dmabuf_in)
Definition lci_binding_post.hpp:68
option_t< attr_backend_t > m_backend
Definition lci_binding_post.hpp:41
alloc_net_context_x && max_msg_size(size_t max_msg_size_in)
Definition lci_binding_post.hpp:61
net_context_t call() const
Definition binding.cpp:195
option_t< std::string > m_ofi_provider_name
Definition lci_binding_post.hpp:42
option_t< bool > m_ibv_force_gid_auto_select
Definition lci_binding_post.hpp:46
option_t< size_t > m_max_inject_size
Definition lci_binding_post.hpp:44
net_context_t operator()() const
Definition lci_binding_post.hpp:75
option_t< size_t > m_max_msg_size
Definition lci_binding_post.hpp:43
option_t< attr_ibv_prefetch_strategy_t > m_ibv_prefetch_strategy
Definition lci_binding_post.hpp:49
The actual implementation for alloc_packet_pool.
Definition lci_binding_post.hpp:2207
packet_pool_t call() const
Definition binding.cpp:721
alloc_packet_pool_x()
Definition lci_binding_post.hpp:2217
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:2221
alloc_packet_pool_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2223
alloc_packet_pool_x && packet_size(size_t packet_size_in)
Definition lci_binding_post.hpp:2220
alloc_packet_pool_x && name(const char *name_in)
Definition lci_binding_post.hpp:2222
option_t< size_t > m_packet_size
Definition lci_binding_post.hpp:2210
alloc_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2224
option_t< const char * > m_name
Definition lci_binding_post.hpp:2212
packet_pool_t operator()() const
Definition lci_binding_post.hpp:2228
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2213
option_t< size_t > m_npackets
Definition lci_binding_post.hpp:2211
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2214
The actual implementation for alloc_runtime.
Definition lci_binding_post.hpp:1992
alloc_runtime_x && imm_nbits_tag(int imm_nbits_tag_in)
Definition lci_binding_post.hpp:2011
alloc_runtime_x && imm_nbits_rcomp(int imm_nbits_rcomp_in)
Definition lci_binding_post.hpp:2012
option_t< bool > m_alloc_default_packet_pool
Definition lci_binding_post.hpp:2000
alloc_runtime_x && name(const char *name_in)
Definition lci_binding_post.hpp:2017
runtime_t operator()() const
Definition lci_binding_post.hpp:2023
option_t< bool > m_alloc_default_matching_engine
Definition lci_binding_post.hpp:2001
runtime_t call() const
Definition binding.cpp:670
alloc_runtime_x && alloc_default_packet_pool(bool alloc_default_packet_pool_in)
Definition lci_binding_post.hpp:2015
alloc_runtime_x && rdv_protocol(attr_rdv_protocol_t rdv_protocol_in)
Definition lci_binding_post.hpp:2013
alloc_runtime_x()
Definition lci_binding_post.hpp:2007
option_t< std::string > m_device_name
Definition lci_binding_post.hpp:2004
alloc_runtime_x && alloc_default_matching_engine(bool alloc_default_matching_engine_in)
Definition lci_binding_post.hpp:2016
alloc_runtime_x && alloc_default_device(bool alloc_default_device_in)
Definition lci_binding_post.hpp:2014
alloc_runtime_x && packet_return_threshold(size_t packet_return_threshold_in)
Definition lci_binding_post.hpp:2010
option_t< const char * > m_name
Definition lci_binding_post.hpp:2002
alloc_runtime_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2018
alloc_runtime_x && device_name(std::string device_name_in)
Definition lci_binding_post.hpp:2019
option_t< bool > m_alloc_default_device
Definition lci_binding_post.hpp:1999
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, std::string device_name) const
option_t< attr_rdv_protocol_t > m_rdv_protocol
Definition lci_binding_post.hpp:1998
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2003
option_t< int > m_imm_nbits_rcomp
Definition lci_binding_post.hpp:1997
option_t< size_t > m_packet_return_threshold
Definition lci_binding_post.hpp:1995
option_t< int > m_imm_nbits_tag
Definition lci_binding_post.hpp:1996
The actual implementation for alloc_sync.
Definition lci_binding_post.hpp:3042
comp_t operator()() const
Definition lci_binding_post.hpp:3063
option_t< int > m_threshold
Definition lci_binding_post.hpp:3046
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3049
alloc_sync_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3059
alloc_sync_x && threshold(int threshold_in)
Definition lci_binding_post.hpp:3056
alloc_sync_x && name(const char *name_in)
Definition lci_binding_post.hpp:3058
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:3047
alloc_sync_x()
Definition lci_binding_post.hpp:3052
option_t< const char * > m_name
Definition lci_binding_post.hpp:3048
alloc_sync_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:3057
alloc_sync_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3055
comp_t call() const
Definition binding.cpp:874
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3045
The actual implementation for allreduce.
Definition lci_binding_post.hpp:1820
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:1843
void operator()() const
Definition lci_binding_post.hpp:1855
const void * m_sendbuf
Definition lci_binding_post.hpp:1823
option_t< device_t > m_device
Definition lci_binding_post.hpp:1829
allreduce_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:1840
reduce_op_t m_op
Definition lci_binding_post.hpp:1827
void * m_recvbuf
Definition lci_binding_post.hpp:1824
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:1834
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:1837
allreduce_x && device(device_t device_in)
Definition lci_binding_post.hpp:1846
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1831
size_t m_count
Definition lci_binding_post.hpp:1825
allreduce_x && count(size_t count_in)
Definition lci_binding_post.hpp:1842
allreduce_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:1841
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1830
allreduce_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1847
option_t< allreduce_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:1833
allreduce_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:1844
allreduce_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1845
allreduce_x && algorithm(allreduce_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:1850
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1828
allreduce_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:1851
size_t m_item_size
Definition lci_binding_post.hpp:1826
allreduce_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1849
void call() const
Definition binding.cpp:616
allreduce_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1848
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:1832
The actual implementation for alltoall.
Definition lci_binding_post.hpp:1935
const void * m_sendbuf
Definition lci_binding_post.hpp:1938
void call() const
Definition binding.cpp:643
alltoall_x && device(device_t device_in)
Definition lci_binding_post.hpp:1955
alltoall_x && size(size_t size_in)
Definition lci_binding_post.hpp:1953
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1944
alltoall_x(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:1948
void * m_recvbuf
Definition lci_binding_post.hpp:1939
alltoall_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:1952
option_t< device_t > m_device
Definition lci_binding_post.hpp:1942
alltoall_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1957
alltoall_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1956
alltoall_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1954
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1941
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1943
alltoall_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:1951
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:1945
alltoall_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:1958
size_t m_size
Definition lci_binding_post.hpp:1940
void operator()() const
Definition lci_binding_post.hpp:1962
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:1576
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:1584
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1582
barrier_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1593
barrier_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1595
barrier_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:1594
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:1580
void call() const
Definition binding.cpp:562
barrier_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1592
barrier_x()
Definition lci_binding_post.hpp:1587
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1581
barrier_x && device(device_t device_in)
Definition lci_binding_post.hpp:1591
void operator()() const
Definition lci_binding_post.hpp:1599
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:1583
barrier_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1590
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1579
The actual implementation for broadcast.
Definition lci_binding_post.hpp:1629
broadcast_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1653
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1637
void call() const
Definition binding.cpp:572
void operator()() const
Definition lci_binding_post.hpp:1660
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1638
int m_root
Definition lci_binding_post.hpp:1634
broadcast_x && root(int root_in)
Definition lci_binding_post.hpp:1649
broadcast_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1654
broadcast_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1650
broadcast_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:1656
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1635
broadcast_x && size(size_t size_in)
Definition lci_binding_post.hpp:1648
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:1641
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:1639
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:1644
broadcast_x && device(device_t device_in)
Definition lci_binding_post.hpp:1651
option_t< broadcast_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:1640
void * m_buffer
Definition lci_binding_post.hpp:1632
option_t< device_t > m_device
Definition lci_binding_post.hpp:1636
broadcast_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1647
broadcast_x && algorithm(broadcast_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:1655
broadcast_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1652
size_t m_size
Definition lci_binding_post.hpp:1633
The actual implementation for comp_signal.
Definition lci_binding_post.hpp:2886
comp_signal_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2899
comp_signal_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2897
status_t m_status
Definition lci_binding_post.hpp:2890
comp_t m_comp
Definition lci_binding_post.hpp:2889
void call() const
Definition binding.cpp:848
comp_signal_x(comp_t comp_in, status_t status_in)
Definition lci_binding_post.hpp:2894
void call_impl(comp_t comp, status_t status, runtime_t runtime) const
void operator()() const
Definition lci_binding_post.hpp:2903
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2891
comp_signal_x && status(status_t status_in)
Definition lci_binding_post.hpp:2898
The actual implementation for RESOURCE comp.
Definition lci_binding_pre.hpp:516
The actual implementation for counter_get.
Definition lci_binding_post.hpp:3211
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3215
int64_t call_impl(comp_t comp, runtime_t runtime) const
int64_t operator()() const
Definition lci_binding_post.hpp:3226
counter_get_x(comp_t comp_in)
Definition lci_binding_post.hpp:3218
int64_t call() const
Definition binding.cpp:906
counter_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3222
comp_t m_comp
Definition lci_binding_post.hpp:3214
counter_get_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3221
The actual implementation for counter_set.
Definition lci_binding_post.hpp:3249
counter_set_x(comp_t comp_in, int64_t value_in)
Definition lci_binding_post.hpp:3257
int64_t m_value
Definition lci_binding_post.hpp:3253
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3254
comp_t m_comp
Definition lci_binding_post.hpp:3252
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:3262
counter_set_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3260
void operator()() const
Definition lci_binding_post.hpp:3266
counter_set_x && value(int64_t value_in)
Definition lci_binding_post.hpp:3261
void call() const
Definition binding.cpp:912
The actual implementation for cq_pop.
Definition lci_binding_post.hpp:3337
status_t operator()() const
Definition lci_binding_post.hpp:3352
comp_t m_comp
Definition lci_binding_post.hpp:3340
status_t call_impl(comp_t comp, runtime_t runtime) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3341
cq_pop_x(comp_t comp_in)
Definition lci_binding_post.hpp:3344
cq_pop_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3347
cq_pop_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3348
status_t call() const
Definition binding.cpp:929
The actual implementation for deregister_memory.
Definition lci_binding_post.hpp:287
void operator()() const
Definition lci_binding_post.hpp:302
void call() const
Definition binding.cpp:268
mr_t * m_mr
Definition lci_binding_post.hpp:290
deregister_memory_x && mr(mr_t *mr_in)
Definition lci_binding_post.hpp:297
deregister_memory_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:298
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:291
void call_impl(mr_t *mr, runtime_t runtime) const
deregister_memory_x(mr_t *mr_in)
Definition lci_binding_post.hpp:294
The actual implementation for deregister_packet_pool.
Definition lci_binding_post.hpp:2328
deregister_packet_pool_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:2339
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:2331
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2333
void operator()() const
Definition lci_binding_post.hpp:2345
void call() const
Definition binding.cpp:743
deregister_packet_pool_x && device(device_t device_in)
Definition lci_binding_post.hpp:2340
device_t m_device
Definition lci_binding_post.hpp:2332
deregister_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2341
deregister_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:2336
The actual implementation for deregister_rcomp.
Definition lci_binding_post.hpp:3002
deregister_rcomp_x(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:3009
void operator()() const
Definition lci_binding_post.hpp:3017
rcomp_t m_rcomp
Definition lci_binding_post.hpp:3005
void call_impl(rcomp_t rcomp, runtime_t runtime) const
void call() const
Definition binding.cpp:868
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3006
deregister_rcomp_x && rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:3012
deregister_rcomp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3013
The actual implementation for RESOURCE device.
Definition lci_binding_pre.hpp:273
The actual implementation for RESOURCE endpoint.
Definition lci_binding_pre.hpp:350
The actual implementation for free_comp.
Definition lci_binding_post.hpp:2848
free_comp_x(comp_t *comp_in)
Definition lci_binding_post.hpp:2855
free_comp_x && comp(comp_t *comp_in)
Definition lci_binding_post.hpp:2858
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2852
comp_t * m_comp
Definition lci_binding_post.hpp:2851
void call() const
Definition binding.cpp:842
free_comp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2859
void operator()() const
Definition lci_binding_post.hpp:2863
void call_impl(comp_t *comp, runtime_t runtime) const
The actual implementation for free_device.
Definition lci_binding_post.hpp:207
void call_impl(device_t *device, runtime_t runtime) const
free_device_x && device(device_t *device_in)
Definition lci_binding_post.hpp:217
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:211
device_t * m_device
Definition lci_binding_post.hpp:210
void operator()() const
Definition lci_binding_post.hpp:222
void call() const
Definition binding.cpp:250
free_device_x(device_t *device_in)
Definition lci_binding_post.hpp:214
free_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:218
The actual implementation for free_endpoint.
Definition lci_binding_post.hpp:404
void operator()() const
Definition lci_binding_post.hpp:419
endpoint_t * m_endpoint
Definition lci_binding_post.hpp:407
free_endpoint_x && endpoint(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:414
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:408
free_endpoint_x(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:411
void call_impl(endpoint_t *endpoint, runtime_t runtime) const
void call() const
Definition binding.cpp:293
free_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:415
The actual implementation for free_matching_engine.
Definition lci_binding_post.hpp:2484
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:2494
free_matching_engine_x(matching_engine_t *matching_engine_in)
Definition lci_binding_post.hpp:2491
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2488
matching_engine_t * m_matching_engine
Definition lci_binding_post.hpp:2487
void call() const
Definition binding.cpp:775
free_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2495
void operator()() const
Definition lci_binding_post.hpp:2499
The actual implementation for free_net_context.
Definition lci_binding_post.hpp:97
void operator()() const
Definition lci_binding_post.hpp:112
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:108
free_net_context_x(net_context_t *net_context_in)
Definition lci_binding_post.hpp:104
void call() const
Definition binding.cpp:212
net_context_t * m_net_context
Definition lci_binding_post.hpp:100
free_net_context_x && net_context(net_context_t *net_context_in)
Definition lci_binding_post.hpp:107
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:101
The actual implementation for free_packet_pool.
Definition lci_binding_post.hpp:2250
void operator()() const
Definition lci_binding_post.hpp:2265
free_packet_pool_x(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:2257
void call() const
Definition binding.cpp:730
void call_impl(packet_pool_t *packet_pool, runtime_t runtime) const
packet_pool_t * m_packet_pool
Definition lci_binding_post.hpp:2253
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2254
free_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2261
free_packet_pool_x && packet_pool(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:2260
The actual implementation for free_runtime.
Definition lci_binding_post.hpp:2044
void call_impl(runtime_t *runtime) const
free_runtime_x(runtime_t *runtime_in)
Definition lci_binding_post.hpp:2050
runtime_t * m_runtime
Definition lci_binding_post.hpp:2047
free_runtime_x && runtime(runtime_t *runtime_in)
Definition lci_binding_post.hpp:2053
void operator()() const
Definition lci_binding_post.hpp:2057
void call() const
Definition binding.cpp:685
The actual implementation for g_runtime_fina.
Definition lci_binding_post.hpp:2139
g_runtime_fina_x()
Definition lci_binding_post.hpp:2144
void call() const
Definition binding.cpp:706
void operator()() const
Definition lci_binding_post.hpp:2150
void call_impl() const
The actual implementation for g_runtime_init.
Definition lci_binding_post.hpp:2087
g_runtime_init_x && imm_nbits_rcomp(int imm_nbits_rcomp_in)
Definition lci_binding_post.hpp:2107
g_runtime_init_x && alloc_default_packet_pool(bool alloc_default_packet_pool_in)
Definition lci_binding_post.hpp:2110
g_runtime_init_x && imm_nbits_tag(int imm_nbits_tag_in)
Definition lci_binding_post.hpp:2106
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, std::string device_name) const
option_t< int > m_imm_nbits_tag
Definition lci_binding_post.hpp:2091
option_t< int > m_imm_nbits_rcomp
Definition lci_binding_post.hpp:2092
option_t< size_t > m_packet_return_threshold
Definition lci_binding_post.hpp:2090
g_runtime_init_x && name(const char *name_in)
Definition lci_binding_post.hpp:2112
option_t< attr_rdv_protocol_t > m_rdv_protocol
Definition lci_binding_post.hpp:2093
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2098
option_t< std::string > m_device_name
Definition lci_binding_post.hpp:2099
option_t< bool > m_alloc_default_device
Definition lci_binding_post.hpp:2094
g_runtime_init_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2113
g_runtime_init_x && alloc_default_matching_engine(bool alloc_default_matching_engine_in)
Definition lci_binding_post.hpp:2111
runtime_t call() const
Definition binding.cpp:691
option_t< bool > m_alloc_default_matching_engine
Definition lci_binding_post.hpp:2096
g_runtime_init_x && device_name(std::string device_name_in)
Definition lci_binding_post.hpp:2114
option_t< bool > m_alloc_default_packet_pool
Definition lci_binding_post.hpp:2095
g_runtime_init_x()
Definition lci_binding_post.hpp:2102
g_runtime_init_x && alloc_default_device(bool alloc_default_device_in)
Definition lci_binding_post.hpp:2109
option_t< const char * > m_name
Definition lci_binding_post.hpp:2097
g_runtime_init_x && packet_return_threshold(size_t packet_return_threshold_in)
Definition lci_binding_post.hpp:2105
runtime_t operator()() const
Definition lci_binding_post.hpp:2118
g_runtime_init_x && rdv_protocol(attr_rdv_protocol_t rdv_protocol_in)
Definition lci_binding_post.hpp:2108
The actual implementation for get_allocator.
Definition lci_binding_post.hpp:2603
allocator_base_t * call_impl(runtime_t runtime) const
allocator_base_t * call() const
Definition binding.cpp:796
allocator_base_t * operator()() const
Definition lci_binding_post.hpp:2616
get_allocator_x()
Definition lci_binding_post.hpp:2609
get_allocator_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2612
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2606
The actual implementation for get_default_device.
Definition lci_binding_post.hpp:2671
device_t call_impl(runtime_t runtime) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2674
get_default_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2680
device_t call() const
Definition binding.cpp:806
get_default_device_x()
Definition lci_binding_post.hpp:2677
device_t operator()() const
Definition lci_binding_post.hpp:2684
The actual implementation for get_default_endpoint.
Definition lci_binding_post.hpp:2706
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:2717
endpoint_t operator()() const
Definition lci_binding_post.hpp:2721
endpoint_t call() const
Definition binding.cpp:811
get_default_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2716
get_default_endpoint_x()
Definition lci_binding_post.hpp:2713
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2709
option_t< device_t > m_device
Definition lci_binding_post.hpp:2710
The actual implementation for get_default_matching_engine.
Definition lci_binding_post.hpp:2776
get_default_matching_engine_x()
Definition lci_binding_post.hpp:2782
matching_engine_t call() const
Definition binding.cpp:822
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2779
matching_engine_t call_impl(runtime_t runtime) const
matching_engine_t operator()() const
Definition lci_binding_post.hpp:2789
get_default_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2785
The actual implementation for get_default_net_context.
Definition lci_binding_post.hpp:2637
net_context_t operator()() const
Definition lci_binding_post.hpp:2650
get_default_net_context_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2646
get_default_net_context_x()
Definition lci_binding_post.hpp:2643
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2640
net_context_t call_impl(runtime_t runtime) const
net_context_t call() const
Definition binding.cpp:801
The actual implementation for get_default_packet_pool.
Definition lci_binding_post.hpp:2742
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2745
packet_pool_t operator()() const
Definition lci_binding_post.hpp:2755
packet_pool_t call_impl(runtime_t runtime) const
packet_pool_t call() const
Definition binding.cpp:817
get_default_packet_pool_x()
Definition lci_binding_post.hpp:2748
get_default_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2751
The actual implementation for get_g_runtime.
Definition lci_binding_post.hpp:2171
runtime_t operator()() const
Definition lci_binding_post.hpp:2182
get_g_runtime_x()
Definition lci_binding_post.hpp:2176
runtime_t call() const
Definition binding.cpp:711
runtime_t call_impl() const
The actual implementation for get_max_bcopy_size.
Definition lci_binding_post.hpp:2811
size_t operator()() const
Definition lci_binding_post.hpp:2826
get_max_bcopy_size_x()
Definition lci_binding_post.hpp:2818
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2814
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:2815
get_max_bcopy_size_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:2822
size_t call() const
Definition binding.cpp:827
get_max_bcopy_size_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2821
The actual implementation for get_rmr.
Definition lci_binding_post.hpp:324
get_rmr_x(mr_t mr_in)
Definition lci_binding_post.hpp:331
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:328
get_rmr_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:334
rmr_t operator()() const
Definition lci_binding_post.hpp:339
mr_t m_mr
Definition lci_binding_post.hpp:327
rmr_t call() const
Definition binding.cpp:274
get_rmr_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:335
rmr_t call_impl(mr_t mr, runtime_t runtime) const
The actual implementation for get_upacket.
Definition lci_binding_post.hpp:2367
get_upacket_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:2378
void * call() const
Definition binding.cpp:750
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2370
get_upacket_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2377
void * operator()() const
Definition lci_binding_post.hpp:2382
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:2371
get_upacket_x()
Definition lci_binding_post.hpp:2374
The actual implementation for graph_add_edge.
Definition lci_binding_post.hpp:3512
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:3515
void call() const
Definition binding.cpp:961
graph_add_edge_x(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in)
Definition lci_binding_post.hpp:3522
graph_add_edge_x && dst(graph_node_t dst_in)
Definition lci_binding_post.hpp:3527
graph_add_edge_x && fn(graph_edge_run_cb_t fn_in)
Definition lci_binding_post.hpp:3528
void operator()() const
Definition lci_binding_post.hpp:3533
option_t< graph_edge_run_cb_t > m_fn
Definition lci_binding_post.hpp:3518
graph_add_edge_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3525
graph_node_t m_dst
Definition lci_binding_post.hpp:3517
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3519
graph_add_edge_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3529
graph_add_edge_x && src(graph_node_t src_in)
Definition lci_binding_post.hpp:3526
graph_node_t m_src
Definition lci_binding_post.hpp:3516
The actual implementation for graph_add_node.
Definition lci_binding_post.hpp:3466
option_t< void * > m_value
Definition lci_binding_post.hpp:3471
graph_node_t operator()() const
Definition lci_binding_post.hpp:3487
graph_add_node_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3483
graph_node_t call() const
Definition binding.cpp:952
graph_add_node_x(comp_t comp_in, graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:3476
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:3480
graph_node_run_cb_t m_fn
Definition lci_binding_post.hpp:3470
comp_t m_comp
Definition lci_binding_post.hpp:3469
graph_add_node_x && free_cb(graph_node_free_cb_t free_cb_in)
Definition lci_binding_post.hpp:3482
graph_add_node_x && value(void *value_in)
Definition lci_binding_post.hpp:3481
option_t< graph_node_free_cb_t > m_free_cb
Definition lci_binding_post.hpp:3472
graph_add_node_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3479
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3473
The actual implementation for graph_node_mark_complete.
Definition lci_binding_post.hpp:3556
void operator()() const
Definition lci_binding_post.hpp:3573
void call() const
Definition binding.cpp:970
graph_node_t m_node
Definition lci_binding_post.hpp:3559
graph_node_mark_complete_x(graph_node_t node_in)
Definition lci_binding_post.hpp:3564
option_t< status_t > m_status
Definition lci_binding_post.hpp:3560
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:3567
graph_node_mark_complete_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3569
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3561
graph_node_mark_complete_x && status(status_t status_in)
Definition lci_binding_post.hpp:3568
The actual implementation for graph_start.
Definition lci_binding_post.hpp:3595
graph_start_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3606
comp_t m_comp
Definition lci_binding_post.hpp:3598
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3599
graph_start_x(comp_t comp_in)
Definition lci_binding_post.hpp:3602
void call_impl(comp_t comp, runtime_t runtime) const
void call() const
Definition binding.cpp:977
void operator()() const
Definition lci_binding_post.hpp:3610
graph_start_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3605
The actual implementation for graph_test.
Definition lci_binding_post.hpp:3632
comp_t m_comp
Definition lci_binding_post.hpp:3635
status_t call_impl(comp_t comp, runtime_t runtime) const
graph_test_x(comp_t comp_in)
Definition lci_binding_post.hpp:3639
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3636
graph_test_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3643
status_t operator()() const
Definition lci_binding_post.hpp:3647
status_t call() const
Definition binding.cpp:983
graph_test_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3642
The actual implementation for matching_engine_insert.
Definition lci_binding_post.hpp:2524
matching_engine_insert_x && value(matching_entry_val_t value_in)
Definition lci_binding_post.hpp:2539
matching_engine_insert_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2541
matching_entry_val_t operator()() const
Definition lci_binding_post.hpp:2545
matching_entry_val_t call() const
Definition binding.cpp:781
matching_engine_insert_x && entry_type(matching_entry_type_t entry_type_in)
Definition lci_binding_post.hpp:2540
matching_engine_insert_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2537
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2531
matching_entry_type_t m_entry_type
Definition lci_binding_post.hpp:2530
matching_engine_t m_matching_engine
Definition lci_binding_post.hpp:2527
matching_entry_key_t m_key
Definition lci_binding_post.hpp:2528
matching_engine_insert_x && key(matching_entry_key_t key_in)
Definition lci_binding_post.hpp:2538
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:2534
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:2529
The actual implementation for RESOURCE matching_engine.
Definition lci_binding_pre.hpp:477
The actual implementation for RESOURCE mr.
Definition lci_binding_pre.hpp:316
The actual implementation for RESOURCE net_context.
Definition lci_binding_pre.hpp:219
The actual implementation for net_poll_cq.
Definition lci_binding_post.hpp:443
net_poll_cq_x && device(device_t device_in)
Definition lci_binding_post.hpp:458
net_poll_cq_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:457
option_t< device_t > m_device
Definition lci_binding_post.hpp:449
net_poll_cq_x(size_t max_polls_in, net_status_t *statuses_in)
Definition lci_binding_post.hpp:452
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:448
net_poll_cq_x && statuses(net_status_t *statuses_in)
Definition lci_binding_post.hpp:456
size_t operator()() const
Definition lci_binding_post.hpp:462
size_t call() const
Definition binding.cpp:299
net_poll_cq_x && max_polls(size_t max_polls_in)
Definition lci_binding_post.hpp:455
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:446
net_status_t * m_statuses
Definition lci_binding_post.hpp:447
The actual implementation for net_post_get.
Definition lci_binding_post.hpp:898
net_post_get_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:917
net_post_get_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:924
net_post_get_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:921
option_t< device_t > m_device
Definition lci_binding_post.hpp:908
int m_rank
Definition lci_binding_post.hpp:901
net_post_get_x && device(device_t device_in)
Definition lci_binding_post.hpp:923
net_post_get_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:919
error_t operator()() const
Definition lci_binding_post.hpp:929
net_post_get_x && size(size_t size_in)
Definition lci_binding_post.hpp:918
error_t call() const
Definition binding.cpp:398
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:907
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:909
mr_t m_mr
Definition lci_binding_post.hpp:904
void * m_buffer
Definition lci_binding_post.hpp:902
net_post_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:922
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:905
net_post_get_x && rank(int rank_in)
Definition lci_binding_post.hpp:916
rmr_t m_rmr
Definition lci_binding_post.hpp:906
size_t m_size
Definition lci_binding_post.hpp:903
net_post_get_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:925
option_t< void * > m_user_context
Definition lci_binding_post.hpp:910
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:913
net_post_get_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:920
The actual implementation for net_post_putImm.
Definition lci_binding_post.hpp:835
net_post_putImm_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:862
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:851
rmr_t m_rmr
Definition lci_binding_post.hpp:843
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:844
net_post_putImm_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:857
net_post_putImm_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:859
error_t call() const
Definition binding.cpp:383
net_post_putImm_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:863
int m_rank
Definition lci_binding_post.hpp:838
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:847
net_post_putImm_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:860
option_t< device_t > m_device
Definition lci_binding_post.hpp:845
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:846
mr_t m_mr
Definition lci_binding_post.hpp:841
net_post_putImm_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:855
void * m_buffer
Definition lci_binding_post.hpp:839
net_post_putImm_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:864
option_t< void * > m_user_context
Definition lci_binding_post.hpp:848
error_t operator()() const
Definition lci_binding_post.hpp:868
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:840
net_post_putImm_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:858
uint64_t m_offset
Definition lci_binding_post.hpp:842
net_post_putImm_x && size(size_t size_in)
Definition lci_binding_post.hpp:856
net_post_putImm_x && rank(int rank_in)
Definition lci_binding_post.hpp:854
net_post_putImm_x && device(device_t device_in)
Definition lci_binding_post.hpp:861
The actual implementation for net_post_putImms.
Definition lci_binding_post.hpp:773
net_post_putImms_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:792
net_post_putImms_x && device(device_t device_in)
Definition lci_binding_post.hpp:797
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:783
option_t< device_t > m_device
Definition lci_binding_post.hpp:782
net_post_putImms_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:795
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:791
uint64_t m_offset
Definition lci_binding_post.hpp:779
void * m_buffer
Definition lci_binding_post.hpp:777
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:784
int m_rank
Definition lci_binding_post.hpp:776
error_t operator()() const
Definition lci_binding_post.hpp:804
net_post_putImms_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:794
error_t call() const
Definition binding.cpp:369
rmr_t m_rmr
Definition lci_binding_post.hpp:780
net_post_putImms_x && size(size_t size_in)
Definition lci_binding_post.hpp:793
option_t< void * > m_user_context
Definition lci_binding_post.hpp:785
net_post_putImms_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:798
net_post_putImms_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:799
size_t m_size
Definition lci_binding_post.hpp:778
net_post_putImms_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:796
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:781
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:788
net_post_putImms_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:800
The actual implementation for net_post_put.
Definition lci_binding_post.hpp:712
rmr_t m_rmr
Definition lci_binding_post.hpp:720
net_post_put_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:731
mr_t m_mr
Definition lci_binding_post.hpp:718
net_post_put_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:735
int m_rank
Definition lci_binding_post.hpp:715
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:727
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:721
error_t call() const
Definition binding.cpp:355
net_post_put_x && rank(int rank_in)
Definition lci_binding_post.hpp:730
option_t< device_t > m_device
Definition lci_binding_post.hpp:722
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:723
net_post_put_x && device(device_t device_in)
Definition lci_binding_post.hpp:737
net_post_put_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:739
net_post_put_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:738
net_post_put_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:733
net_post_put_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:734
net_post_put_x && size(size_t size_in)
Definition lci_binding_post.hpp:732
option_t< void * > m_user_context
Definition lci_binding_post.hpp:724
size_t m_size
Definition lci_binding_post.hpp:717
net_post_put_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:736
error_t operator()() const
Definition lci_binding_post.hpp:743
uint64_t m_offset
Definition lci_binding_post.hpp:719
void * m_buffer
Definition lci_binding_post.hpp:716
The actual implementation for net_post_puts.
Definition lci_binding_post.hpp:653
net_post_puts_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:674
net_post_puts_x && rank(int rank_in)
Definition lci_binding_post.hpp:670
error_t operator()() const
Definition lci_binding_post.hpp:682
net_post_puts_x && size(size_t size_in)
Definition lci_binding_post.hpp:672
option_t< device_t > m_device
Definition lci_binding_post.hpp:662
void * m_buffer
Definition lci_binding_post.hpp:657
net_post_puts_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:673
net_post_puts_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:675
net_post_puts_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:671
net_post_puts_x && device(device_t device_in)
Definition lci_binding_post.hpp:676
error_t call() const
Definition binding.cpp:342
int m_rank
Definition lci_binding_post.hpp:656
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:667
rmr_t m_rmr
Definition lci_binding_post.hpp:660
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:661
size_t m_size
Definition lci_binding_post.hpp:658
option_t< void * > m_user_context
Definition lci_binding_post.hpp:664
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:678
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:663
net_post_puts_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:677
uint64_t m_offset
Definition lci_binding_post.hpp:659
The actual implementation for net_post_recv.
Definition lci_binding_post.hpp:488
net_post_recv_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:505
option_t< void * > m_user_context
Definition lci_binding_post.hpp:496
net_post_recv_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:502
error_t call() const
Definition binding.cpp:307
net_post_recv_x(void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:499
net_post_recv_x && size(size_t size_in)
Definition lci_binding_post.hpp:503
net_post_recv_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:504
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:494
option_t< device_t > m_device
Definition lci_binding_post.hpp:495
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:493
size_t m_size
Definition lci_binding_post.hpp:492
error_t operator()() const
Definition lci_binding_post.hpp:511
net_post_recv_x && device(device_t device_in)
Definition lci_binding_post.hpp:506
void * m_buffer
Definition lci_binding_post.hpp:491
net_post_recv_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:507
The actual implementation for net_post_send.
Definition lci_binding_post.hpp:595
net_post_send_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:619
net_post_send_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:616
net_post_send_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:613
void * m_buffer
Definition lci_binding_post.hpp:599
int m_rank
Definition lci_binding_post.hpp:598
mr_t m_mr
Definition lci_binding_post.hpp:601
size_t m_size
Definition lci_binding_post.hpp:600
net_post_send_x && size(size_t size_in)
Definition lci_binding_post.hpp:614
error_t call() const
Definition binding.cpp:329
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:602
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:605
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:604
net_post_send_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:615
net_post_send_x && device(device_t device_in)
Definition lci_binding_post.hpp:617
option_t< void * > m_user_context
Definition lci_binding_post.hpp:606
net_post_send_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:618
net_post_send_x(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:609
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:603
error_t operator()() const
Definition lci_binding_post.hpp:624
net_post_send_x && rank(int rank_in)
Definition lci_binding_post.hpp:612
net_post_send_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:620
The actual implementation for net_post_sends.
Definition lci_binding_post.hpp:539
option_t< void * > m_user_context
Definition lci_binding_post.hpp:549
net_post_sends_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:561
net_post_sends_x && size(size_t size_in)
Definition lci_binding_post.hpp:557
error_t call() const
Definition binding.cpp:317
option_t< device_t > m_device
Definition lci_binding_post.hpp:546
net_post_sends_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:560
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:542
net_post_sends_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:558
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:548
net_post_sends_x(int rank_in, void *buffer_in, size_t size_in)
Definition lci_binding_post.hpp:552
net_post_sends_x && rank(int rank_in)
Definition lci_binding_post.hpp:555
void * m_buffer
Definition lci_binding_post.hpp:543
net_post_sends_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:562
error_t operator()() const
Definition lci_binding_post.hpp:566
net_post_sends_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:556
size_t m_size
Definition lci_binding_post.hpp:544
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:547
net_post_sends_x && device(device_t device_in)
Definition lci_binding_post.hpp:559
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:545
The actual implementation for RESOURCE packet_pool.
Definition lci_binding_pre.hpp:441
The actual implementation for post_am.
Definition lci_binding_post.hpp:1059
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:1072
option_t< device_t > m_device
Definition lci_binding_post.hpp:1068
post_am_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1091
rcomp_t m_remote_comp
Definition lci_binding_post.hpp:1066
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:1073
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:1076
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:1080
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1069
post_am_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:1096
post_am_x && size(size_t size_in)
Definition lci_binding_post.hpp:1085
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:1077
post_am_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1088
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1067
post_am_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:1094
int m_rank
Definition lci_binding_post.hpp:1062
post_am_x && rank(int rank_in)
Definition lci_binding_post.hpp:1083
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:1070
post_am_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:1092
status_t call() const
Definition binding.cpp:437
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:1071
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:1093
comp_t m_local_comp
Definition lci_binding_post.hpp:1065
post_am_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:1098
post_am_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:1097
post_am_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:1084
size_t m_size
Definition lci_binding_post.hpp:1064
post_am_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1090
post_am_x && device(device_t device_in)
Definition lci_binding_post.hpp:1089
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:1075
post_am_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1095
void * m_local_buffer
Definition lci_binding_post.hpp:1063
post_am_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:1086
status_t operator()() const
Definition lci_binding_post.hpp:1102
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1074
post_am_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:1087
The actual implementation for post_comm.
Definition lci_binding_post.hpp:970
status_t call() const
Definition binding.cpp:412
void * m_local_buffer
Definition lci_binding_post.hpp:975
option_t< void * > m_user_context
Definition lci_binding_post.hpp:989
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:990
post_comm_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:1014
option_t< device_t > m_device
Definition lci_binding_post.hpp:979
post_comm_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1008
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:993
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:974
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:982
post_comm_x && rank(int rank_in)
Definition lci_binding_post.hpp:1000
post_comm_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1004
post_comm_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:1001
size_t m_size
Definition lci_binding_post.hpp:976
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:978
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:984
comp_t m_local_comp
Definition lci_binding_post.hpp:977
status_t operator()() const
Definition lci_binding_post.hpp:1023
option_t< rmr_t > m_rmr
Definition lci_binding_post.hpp:986
post_comm_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1015
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:992
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:996
option_t< uintptr_t > m_remote_disp
Definition lci_binding_post.hpp:985
post_comm_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1007
post_comm_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:1017
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:980
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:988
post_comm_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:1003
post_comm_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:1013
post_comm_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1012
post_comm_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1010
post_comm_x && direction(direction_t direction_in)
Definition lci_binding_post.hpp:999
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:991
post_comm_x && size(size_t size_in)
Definition lci_binding_post.hpp:1002
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:981
post_comm_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1006
post_comm_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:1018
post_comm_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:1009
post_comm_x && device(device_t device_in)
Definition lci_binding_post.hpp:1005
post_comm_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:1019
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:983
post_comm_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:1016
direction_t m_direction
Definition lci_binding_post.hpp:973
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:987
post_comm_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:1011
The actual implementation for post_get.
Definition lci_binding_post.hpp:1389
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:1405
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1406
post_get_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:1430
post_get_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:1427
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:1402
comp_t m_local_comp
Definition lci_binding_post.hpp:1395
post_get_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:1425
post_get_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:1419
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:1412
post_get_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1426
status_t operator()() const
Definition lci_binding_post.hpp:1436
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:1401
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:1409
uintptr_t m_remote_disp
Definition lci_binding_post.hpp:1396
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:1393
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:1407
option_t< device_t > m_device
Definition lci_binding_post.hpp:1399
post_get_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1420
int m_rank
Definition lci_binding_post.hpp:1392
post_get_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:1416
post_get_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:1428
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1398
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:1408
post_get_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:1431
post_get_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1424
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1400
post_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1421
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:1403
post_get_x && size(size_t size_in)
Definition lci_binding_post.hpp:1417
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:1404
post_get_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1423
status_t call() const
Definition binding.cpp:521
post_get_x && rank(int rank_in)
Definition lci_binding_post.hpp:1415
post_get_x && device(device_t device_in)
Definition lci_binding_post.hpp:1422
post_get_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:1418
post_get_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1429
size_t m_size
Definition lci_binding_post.hpp:1394
rmr_t m_rmr
Definition lci_binding_post.hpp:1397
post_get_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:1432
The actual implementation for post_put.
Definition lci_binding_post.hpp:1304
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:1322
post_put_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1344
post_put_x && device(device_t device_in)
Definition lci_binding_post.hpp:1337
status_t operator()() const
Definition lci_binding_post.hpp:1351
post_put_x && rank(int rank_in)
Definition lci_binding_post.hpp:1330
post_put_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1336
post_put_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1338
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:1323
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1315
comp_t m_local_comp
Definition lci_binding_post.hpp:1310
uintptr_t m_remote_disp
Definition lci_binding_post.hpp:1311
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:1324
option_t< device_t > m_device
Definition lci_binding_post.hpp:1314
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1321
post_put_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:1331
int m_rank
Definition lci_binding_post.hpp:1307
post_put_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1339
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:1320
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:1327
post_put_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:1342
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:1318
post_put_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:1345
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:1319
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:1317
post_put_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:1340
status_t call() const
Definition binding.cpp:499
post_put_x && size(size_t size_in)
Definition lci_binding_post.hpp:1332
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1313
post_put_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:1347
post_put_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1335
post_put_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:1333
post_put_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:1334
rmr_t m_rmr
Definition lci_binding_post.hpp:1312
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:1316
size_t m_size
Definition lci_binding_post.hpp:1309
post_put_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:1343
post_put_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1341
void * m_local_buffer
Definition lci_binding_post.hpp:1308
post_put_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:1346
The actual implementation for post_recv.
Definition lci_binding_post.hpp:1221
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:1240
post_recv_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:1261
size_t m_size
Definition lci_binding_post.hpp:1226
post_recv_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:1260
post_recv_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:1249
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1236
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1233
tag_t m_tag
Definition lci_binding_post.hpp:1227
post_recv_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1254
post_recv_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1251
option_t< device_t > m_device
Definition lci_binding_post.hpp:1230
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:1238
post_recv_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:1256
post_recv_x && size(size_t size_in)
Definition lci_binding_post.hpp:1248
status_t operator()() const
Definition lci_binding_post.hpp:1266
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:1232
post_recv_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1258
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:1234
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:1235
void * m_local_buffer
Definition lci_binding_post.hpp:1225
post_recv_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1253
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1231
post_recv_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1255
comp_t m_local_comp
Definition lci_binding_post.hpp:1228
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:1239
post_recv_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1257
post_recv_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:1262
post_recv_x && device(device_t device_in)
Definition lci_binding_post.hpp:1252
int m_rank
Definition lci_binding_post.hpp:1224
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:1243
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1229
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:1237
post_recv_x && rank(int rank_in)
Definition lci_binding_post.hpp:1246
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:1250
post_recv_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:1259
post_recv_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:1247
status_t call() const
Definition binding.cpp:478
The actual implementation for post_send.
Definition lci_binding_post.hpp:1139
post_send_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:1178
post_send_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:1168
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:1150
status_t call() const
Definition binding.cpp:457
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1151
post_send_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1171
void * m_local_buffer
Definition lci_binding_post.hpp:1143
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1154
post_send_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1175
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:1156
size_t m_size
Definition lci_binding_post.hpp:1144
int m_rank
Definition lci_binding_post.hpp:1142
post_send_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:1165
tag_t m_tag
Definition lci_binding_post.hpp:1145
post_send_x && size(size_t size_in)
Definition lci_binding_post.hpp:1166
comp_t m_local_comp
Definition lci_binding_post.hpp:1146
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:1161
status_t operator()() const
Definition lci_binding_post.hpp:1184
post_send_x && rank(int rank_in)
Definition lci_binding_post.hpp:1164
post_send_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1169
post_send_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:1180
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:1153
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1149
post_send_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1173
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:1174
post_send_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:1179
option_t< device_t > m_device
Definition lci_binding_post.hpp:1148
post_send_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1176
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:1152
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:1155
post_send_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:1167
post_send_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:1177
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:1158
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:1157
post_send_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1172
post_send_x && device(device_t device_in)
Definition lci_binding_post.hpp:1170
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1147
The actual implementation for progress.
Definition lci_binding_post.hpp:1459
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1462
error_t call() const
Definition binding.cpp:543
progress_x()
Definition lci_binding_post.hpp:1467
progress_x && device(device_t device_in)
Definition lci_binding_post.hpp:1471
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1464
option_t< device_t > m_device
Definition lci_binding_post.hpp:1463
error_t operator()() const
Definition lci_binding_post.hpp:1476
progress_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1470
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:1472
The actual implementation for put_upacket.
Definition lci_binding_post.hpp:2404
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2408
void * m_packet
Definition lci_binding_post.hpp:2407
void call() const
Definition binding.cpp:756
void operator()() const
Definition lci_binding_post.hpp:2419
put_upacket_x && packet(void *packet_in)
Definition lci_binding_post.hpp:2414
put_upacket_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2415
put_upacket_x(void *packet_in)
Definition lci_binding_post.hpp:2411
void call_impl(void *packet, runtime_t runtime) const
The actual implementation for reduce_scatter.
Definition lci_binding_post.hpp:1753
reduce_scatter_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:1774
reduce_scatter_x && item_size(size_t item_size_in)
Definition lci_binding_post.hpp:1776
reduce_scatter_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1781
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:1767
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1763
reduce_scatter_x && device(device_t device_in)
Definition lci_binding_post.hpp:1779
reduce_scatter_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:1773
reduce_scatter_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1782
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:1765
option_t< reduce_scatter_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:1766
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1761
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:1757
size_t m_item_size
Definition lci_binding_post.hpp:1759
const void * m_sendbuf
Definition lci_binding_post.hpp:1756
size_t m_recvcount
Definition lci_binding_post.hpp:1758
reduce_scatter_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:1777
void operator()() const
Definition lci_binding_post.hpp:1788
reduce_scatter_x && algorithm(reduce_scatter_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:1783
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1764
reduce_op_t m_op
Definition lci_binding_post.hpp:1760
void call() const
Definition binding.cpp:600
reduce_scatter_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1778
option_t< device_t > m_device
Definition lci_binding_post.hpp:1762
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:1770
reduce_scatter_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1780
reduce_scatter_x && recvcount(size_t recvcount_in)
Definition lci_binding_post.hpp:1775
reduce_scatter_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:1784
The actual implementation for reduce.
Definition lci_binding_post.hpp:1690
void operator()() const
Definition lci_binding_post.hpp:1721
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:1705
reduce_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:1712
reduce_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1717
reduce_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:1709
option_t< device_t > m_device
Definition lci_binding_post.hpp:1700
int m_root
Definition lci_binding_post.hpp:1698
size_t m_count
Definition lci_binding_post.hpp:1695
reduce_x && count(size_t count_in)
Definition lci_binding_post.hpp:1710
reduce_op_t m_op
Definition lci_binding_post.hpp:1697
reduce_x && device(device_t device_in)
Definition lci_binding_post.hpp:1715
size_t m_item_size
Definition lci_binding_post.hpp:1696
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1701
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:1694
reduce_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:1708
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1702
reduce_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1714
reduce_x && item_size(size_t item_size_in)
Definition lci_binding_post.hpp:1711
reduce_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1716
reduce_x && root(int root_in)
Definition lci_binding_post.hpp:1713
const void * m_sendbuf
Definition lci_binding_post.hpp:1693
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1699
void call() const
Definition binding.cpp:586
The actual implementation for register_memory.
Definition lci_binding_post.hpp:246
register_memory_x && address(void *address_in)
Definition lci_binding_post.hpp:258
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:251
register_memory_x && device(device_t device_in)
Definition lci_binding_post.hpp:261
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:259
option_t< device_t > m_device
Definition lci_binding_post.hpp:252
void * m_address
Definition lci_binding_post.hpp:249
mr_t operator()() const
Definition lci_binding_post.hpp:265
register_memory_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:260
register_memory_x(void *address_in, size_t size_in)
Definition lci_binding_post.hpp:255
size_t m_size
Definition lci_binding_post.hpp:250
mr_t call() const
Definition binding.cpp:260
The actual implementation for register_packet_pool.
Definition lci_binding_post.hpp:2288
device_t m_device
Definition lci_binding_post.hpp:2292
void call_impl(packet_pool_t packet_pool, device_t device, runtime_t runtime) const
void operator()() const
Definition lci_binding_post.hpp:2305
register_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:2296
register_packet_pool_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:2299
void call() const
Definition binding.cpp:736
register_packet_pool_x && device(device_t device_in)
Definition lci_binding_post.hpp:2300
packet_pool_t m_packet_pool
Definition lci_binding_post.hpp:2291
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2293
register_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2301
The actual implementation for register_rcomp.
Definition lci_binding_post.hpp:2963
rcomp_t call() const
Definition binding.cpp:861
rcomp_t operator()() const
Definition lci_binding_post.hpp:2980
comp_t m_comp
Definition lci_binding_post.hpp:2966
option_t< rcomp_t > m_rcomp
Definition lci_binding_post.hpp:2968
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2967
register_rcomp_x && rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:2976
register_rcomp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2975
register_rcomp_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2974
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:2971
The actual implementation for reserve_rcomps.
Definition lci_binding_post.hpp:2925
rcomp_t call_impl(rcomp_t n, runtime_t runtime) const
rcomp_t m_n
Definition lci_binding_post.hpp:2928
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2929
reserve_rcomps_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2936
rcomp_t call() const
Definition binding.cpp:855
reserve_rcomps_x(rcomp_t n_in)
Definition lci_binding_post.hpp:2932
rcomp_t operator()() const
Definition lci_binding_post.hpp:2940
reserve_rcomps_x && n(rcomp_t n_in)
Definition lci_binding_post.hpp:2935
The actual implementation for RESOURCE runtime.
Definition lci_binding_pre.hpp:395
The actual implementation for set_allocator.
Definition lci_binding_post.hpp:2567
set_allocator_x(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:2574
set_allocator_x && allocator(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:2577
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2571
void call_impl(allocator_base_t *allocator, runtime_t runtime) const
set_allocator_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2578
void call() const
Definition binding.cpp:790
allocator_base_t * m_allocator
Definition lci_binding_post.hpp:2570
void operator()() const
Definition lci_binding_post.hpp:2582
The actual implementation for sync_test.
Definition lci_binding_post.hpp:3086
comp_t m_comp
Definition lci_binding_post.hpp:3089
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:3098
status_t * m_p_out
Definition lci_binding_post.hpp:3090
sync_test_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3099
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3091
bool operator()() const
Definition lci_binding_post.hpp:3103
sync_test_x(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:3094
sync_test_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3097
bool call() const
Definition binding.cpp:883
The actual implementation for sync_wait.
Definition lci_binding_post.hpp:3128
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3133
sync_wait_x(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:3138
comp_t m_comp
Definition lci_binding_post.hpp:3131
sync_wait_x && p_out(status_t *p_out_in)
Definition lci_binding_post.hpp:3142
option_t< device_t > m_device
Definition lci_binding_post.hpp:3135
sync_wait_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3143
void call() const
Definition binding.cpp:890
status_t * m_p_out
Definition lci_binding_post.hpp:3132
option_t< bool > m_do_progress
Definition lci_binding_post.hpp:3134
sync_wait_x && device(device_t device_in)
Definition lci_binding_post.hpp:3145
sync_wait_x && do_progress(bool do_progress_in)
Definition lci_binding_post.hpp:3144
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:3149
sync_wait_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3141
The actual implementation for test_drained.
Definition lci_binding_post.hpp:1498
option_t< device_t > m_device
Definition lci_binding_post.hpp:1502
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1501
test_drained_x()
Definition lci_binding_post.hpp:1505
error_t operator()() const
Definition lci_binding_post.hpp:1513
test_drained_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1508
test_drained_x && device(device_t device_in)
Definition lci_binding_post.hpp:1509
error_t call() const
Definition binding.cpp:550
error_t call_impl(runtime_t runtime, device_t device) const
The actual implementation for wait_drained.
Definition lci_binding_post.hpp:1535
option_t< device_t > m_device
Definition lci_binding_post.hpp:1539
void operator()() const
Definition lci_binding_post.hpp:1550
wait_drained_x()
Definition lci_binding_post.hpp:1542
void call() const
Definition binding.cpp:556
void call_impl(runtime_t runtime, device_t device) const
wait_drained_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1545
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1538
wait_drained_x && device(device_t device_in)
Definition lci_binding_post.hpp:1546
broadcast_algorithm_t
The type of broadcast algorithm.
Definition lci.hpp:235
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:587
uint64_t matching_entry_key_t
The type of matching engine entry key.
Definition lci.hpp:413
status_t(*)(void *value) graph_node_run_cb_t
The function signature for a node function in the completion graph.
Definition lci.hpp:566
direction_t
The enum class of comunication direction.
Definition lci.hpp:363
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:581
void(*)(const void *left, const void *right, void *dst, size_t n) reduce_op_t
The user-defined reduction operation.
Definition lci.hpp:546
matching_policy_t
Enum class for matching policy.
Definition lci.hpp:402
void * graph_node_t
The node type for the completion graph.
Definition lci.hpp:552
allreduce_algorithm_t
The type of allreduce algorithm.
Definition lci.hpp:271
reduce_scatter_algorithm_t
The type of reduce scatter algorithm.
Definition lci.hpp:253
void * matching_entry_val_t
The type of matching engine entry value.
Definition lci.hpp:418
matching_entry_type_t
The type of matching entry.
Definition lci.hpp:393
uint32_t rcomp_t
The type of remote completion handler.
Definition lci.hpp:374
void(*)(status_t status) comp_handler_t
Function Signature for completion handler.
Definition lci.hpp:539
uint64_t tag_t
The type of tag.
Definition lci.hpp:357
comp_semantic_t
The enum class of completion semantic.
Definition lci.hpp:428
uint32_t net_imm_data_t
The type of network-layer immediate data field.
Definition lci.hpp:290
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:1026
error_t net_post_send(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:627
void graph_node_mark_complete(graph_node_t node_in)
Definition lci_binding_post.hpp:3576
size_t get_max_bcopy_size()
Definition lci_binding_post.hpp:2829
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:1663
device_t alloc_device()
Definition lci_binding_post.hpp:188
net_context_t alloc_net_context()
Definition lci_binding_post.hpp:78
void free_net_context(net_context_t *net_context_in)
Definition lci_binding_post.hpp:115
error_t net_post_recv(void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:514
attr_backend_t
Definition lci.hpp:66
void deregister_rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:3020
void deregister_memory(mr_t *mr_in)
Definition lci_binding_post.hpp:305
comp_t alloc_counter()
Definition lci_binding_post.hpp:3192
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:1105
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:2548
void wait_drained()
Definition lci_binding_post.hpp:1553
rcomp_t reserve_rcomps(rcomp_t n_in)
Definition lci_binding_post.hpp:2943
void sync_wait(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:3152
matching_engine_t alloc_matching_engine()
Definition lci_binding_post.hpp:2465
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:807
void alltoall(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:1965
status_t graph_test(comp_t comp_in)
Definition lci_binding_post.hpp:3650
void register_packet_pool(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:2308
matching_engine_t get_default_matching_engine()
Definition lci_binding_post.hpp:2792
status_t cq_pop(comp_t comp_in)
Definition lci_binding_post.hpp:3355
size_t net_poll_cq(size_t max_polls_in, net_status_t *statuses_in)
Definition lci_binding_post.hpp:465
attr_rdv_protocol_t
Definition lci_binding_pre.hpp:47
void graph_start(comp_t comp_in)
Definition lci_binding_post.hpp:3613
void free_matching_engine(matching_engine_t *matching_engine_in)
Definition lci_binding_post.hpp:2502
void put_upacket(void *packet_in)
Definition lci_binding_post.hpp:2422
comp_t alloc_cq()
Definition lci_binding_post.hpp:3318
void g_runtime_fina()
Definition lci_binding_post.hpp:2153
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:685
rcomp_t register_rcomp(comp_t comp_in)
Definition lci_binding_post.hpp:2983
error_t net_post_sends(int rank_in, void *buffer_in, size_t size_in)
Definition lci_binding_post.hpp:569
void graph_add_edge(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in)
Definition lci_binding_post.hpp:3536
void set_allocator(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:2585
allocator_base_t * get_allocator()
Definition lci_binding_post.hpp:2619
net_context_t get_default_net_context()
Definition lci_binding_post.hpp:2653
void free_device(device_t *device_in)
Definition lci_binding_post.hpp:225
void free_comp(comp_t *comp_in)
Definition lci_binding_post.hpp:2866
packet_pool_t get_default_packet_pool()
Definition lci_binding_post.hpp:2758
void free_runtime(runtime_t *runtime_in)
Definition lci_binding_post.hpp:2060
comp_t alloc_handler(comp_handler_t handler_in)
Definition lci_binding_post.hpp:3401
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:871
runtime_t get_g_runtime()
Definition lci_binding_post.hpp:2185
void free_packet_pool(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:2268
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:1724
void deregister_packet_pool(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:2348
runtime_t g_runtime_init()
Definition lci_binding_post.hpp:2121
void counter_set(comp_t comp_in, int64_t value_in)
Definition lci_binding_post.hpp:3269
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:1187
void comp_signal(comp_t comp_in, status_t status_in)
Definition lci_binding_post.hpp:2906
mr_t register_memory(void *address_in, size_t size_in)
Definition lci_binding_post.hpp:268
rmr_t get_rmr(mr_t mr_in)
Definition lci_binding_post.hpp:342
endpoint_t alloc_endpoint()
Definition lci_binding_post.hpp:385
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:1354
endpoint_t get_default_endpoint()
Definition lci_binding_post.hpp:2724
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:1858
graph_node_t graph_add_node(comp_t comp_in, graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:3490
runtime_t alloc_runtime()
Definition lci_binding_post.hpp:2026
void allgather(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:1910
bool sync_test(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:3106
attr_ibv_td_strategy_t
Definition lci_binding_pre.hpp:41
error_t progress()
Definition lci_binding_post.hpp:1479
attr_ibv_odp_strategy_t
Definition lci_binding_pre.hpp:28
error_t test_drained()
Definition lci_binding_post.hpp:1516
device_t get_default_device()
Definition lci_binding_post.hpp:2687
int64_t counter_get(comp_t comp_in)
Definition lci_binding_post.hpp:3229
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:1791
packet_pool_t alloc_packet_pool()
Definition lci_binding_post.hpp:2231
attr_ibv_prefetch_strategy_t
Definition lci_binding_pre.hpp:34
void barrier()
Definition lci_binding_post.hpp:1602
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:932
attr_cq_type_t
Definition lci_binding_pre.hpp:67
comp_t alloc_graph()
Definition lci_binding_post.hpp:3444
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:1269
void * get_upacket()
Definition lci_binding_post.hpp:2385
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:746
comp_t alloc_sync()
Definition lci_binding_post.hpp:3066
void free_endpoint(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:422
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:1439
The user-defined allocator type.
Definition lci.hpp:437
Wrapper class for error code.
Definition lci.hpp:166
The struct for network status.
Definition lci.hpp:298
Definition lci.hpp:85
The type of remote memory region.
Definition lci.hpp:336
The type of the completion desciptor for a posted communication.
Definition lci.hpp:453