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: MIT
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
22
28 public:
29 // args declaration
32
33 // constructor
34 free_comp_x(comp_t* comp_in) : m_comp(comp_in) {}
35
36 // setter
37 inline free_comp_x&& comp(comp_t* comp_in) { m_comp = comp_in; return std::move(*this); }
38 inline free_comp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
39
41 void call() const;
42 inline void operator()() const { return call(); }
43};
44
45inline void free_comp(comp_t* comp_in) {
46 return free_comp_x(comp_in).call();
47}
48
49
60
66 public:
67 // args declaration
71
72 // constructor
73 comp_signal_x(comp_t comp_in, status_t status_in) : m_comp(comp_in), m_status(status_in) {}
74
75 // setter
76 inline comp_signal_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
77 inline comp_signal_x&& status(status_t status_in) { m_status = status_in; return std::move(*this); }
78 inline comp_signal_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
79
81 void call() const;
82 inline void operator()() const { return call(); }
83};
84
85inline void comp_signal(comp_t comp_in, status_t status_in) {
86 return comp_signal_x(comp_in, status_in).call();
87}
88
89
99
105 public:
106 // args declaration
109
110 // constructor
111 reserve_rcomps_x(rcomp_t n_in) : m_n(n_in) {}
112
113 // setter
114 inline reserve_rcomps_x&& n(rcomp_t n_in) { m_n = n_in; return std::move(*this); }
115 inline reserve_rcomps_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
116
118 rcomp_t call() const;
119 inline rcomp_t operator()() const { return call(); }
120};
121
123 return reserve_rcomps_x(n_in).call();
124}
125
126
137
143 public:
144 // args declaration
148
149 // constructor
150 register_rcomp_x(comp_t comp_in) : m_comp(comp_in) {}
151
152 // setter
153 inline register_rcomp_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
154 inline register_rcomp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
155 inline register_rcomp_x&& rcomp(rcomp_t rcomp_in) { m_rcomp = rcomp_in; return std::move(*this); }
156
158 rcomp_t call() const;
159 inline rcomp_t operator()() const { return call(); }
160};
161
163 return register_rcomp_x(comp_in).call();
164}
165
166
176
182 public:
183 // args declaration
186
187 // constructor
188 deregister_rcomp_x(rcomp_t rcomp_in) : m_rcomp(rcomp_in) {}
189
190 // setter
191 inline deregister_rcomp_x&& rcomp(rcomp_t rcomp_in) { m_rcomp = rcomp_in; return std::move(*this); }
192 inline deregister_rcomp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
193
195 void call() const;
196 inline void operator()() const { return call(); }
197};
198
199inline void deregister_rcomp(rcomp_t rcomp_in) {
200 return deregister_rcomp_x(rcomp_in).call();
201}
202
203
215
221 public:
222 // args declaration
227
228 // constructor
230
231 // setter
232 inline alloc_sync_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
233 inline alloc_sync_x&& threshold(int threshold_in) { m_threshold = threshold_in; return std::move(*this); }
234 inline alloc_sync_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
235 inline alloc_sync_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
236
238 comp_t call() const;
239 inline comp_t operator()() const { return call(); }
240};
241
243 return alloc_sync_x().call();
244}
245
246
257
263 public:
264 // args declaration
268
269 // constructor
270 sync_test_x(comp_t comp_in, status_t* p_out_in) : m_comp(comp_in), m_p_out(p_out_in) {}
271
272 // setter
273 inline sync_test_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
274 inline sync_test_x&& p_out(status_t* p_out_in) { m_p_out = p_out_in; return std::move(*this); }
275 inline sync_test_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
276
278 bool call() const;
279 inline bool operator()() const { return call(); }
280};
281
282inline bool sync_test(comp_t comp_in, status_t* p_out_in) {
283 return sync_test_x(comp_in, p_out_in).call();
284}
285
286
299
305 public:
306 // args declaration
312
313 // constructor
314 sync_wait_x(comp_t comp_in, status_t* p_out_in) : m_comp(comp_in), m_p_out(p_out_in) {}
315
316 // setter
317 inline sync_wait_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
318 inline sync_wait_x&& p_out(status_t* p_out_in) { m_p_out = p_out_in; return std::move(*this); }
319 inline sync_wait_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
320 inline sync_wait_x&& do_progress(bool do_progress_in) { m_do_progress = do_progress_in; return std::move(*this); }
321 inline sync_wait_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
322
324 void call() const;
325 inline void operator()() const { return call(); }
326};
327
328inline void sync_wait(comp_t comp_in, status_t* p_out_in) {
329 return sync_wait_x(comp_in, p_out_in).call();
330}
331
332
345
351 public:
352 // args declaration
358
359 // constructor
361
362 // setter
363 inline alloc_cq_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
364 inline alloc_cq_x&& default_length(int default_length_in) { m_default_length = default_length_in; return std::move(*this); }
365 inline alloc_cq_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
366 inline alloc_cq_x&& cq_type(attr_cq_type_t cq_type_in) { m_cq_type = cq_type_in; return std::move(*this); }
367 inline alloc_cq_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
368
370 comp_t call() const;
371 inline comp_t operator()() const { return call(); }
372};
373
374inline comp_t alloc_cq() {
375 return alloc_cq_x().call();
376}
377
378
388
393class cq_pop_x {
394 public:
395 // args declaration
398
399 // constructor
400 cq_pop_x(comp_t comp_in) : m_comp(comp_in) {}
401
402 // setter
403 inline cq_pop_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
404 inline cq_pop_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
405
407 status_t call() const;
408 inline status_t operator()() const { return call(); }
409};
410
411inline status_t cq_pop(comp_t comp_in) {
412 return cq_pop_x(comp_in).call();
413}
414
415
427
433 public:
434 // args declaration
439
440 // constructor
441 alloc_handler_x(comp_handler_t handler_in) : m_handler(handler_in) {}
442
443 // setter
444 inline alloc_handler_x&& handler(comp_handler_t handler_in) { m_handler = handler_in; return std::move(*this); }
445 inline alloc_handler_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
446 inline alloc_handler_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
447 inline alloc_handler_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
448
450 comp_t call() const;
451 inline comp_t operator()() const { return call(); }
452};
453
455 return alloc_handler_x(handler_in).call();
456}
457
458
469
475 public:
476 // args declaration
480
481 // constructor
483
484 // setter
485 inline alloc_graph_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
486 inline alloc_graph_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
487 inline alloc_graph_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
488
490 comp_t call() const;
491 inline comp_t operator()() const { return call(); }
492};
493
495 return alloc_graph_x().call();
496}
497
498
511
517 public:
518 // args declaration
524
525 // constructor
526 graph_add_node_x(comp_t comp_in, graph_node_run_cb_t fn_in) : m_comp(comp_in), m_fn(fn_in) {}
527
528 // setter
529 inline graph_add_node_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
530 inline graph_add_node_x&& fn(graph_node_run_cb_t fn_in) { m_fn = fn_in; return std::move(*this); }
531 inline graph_add_node_x&& value(void* value_in) { m_value = value_in; return std::move(*this); }
532 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); }
533 inline graph_add_node_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
534
536 graph_node_t call() const;
537 inline graph_node_t operator()() const { return call(); }
538};
539
541 return graph_add_node_x(comp_in, fn_in).call();
542}
543
544
557
563 public:
564 // args declaration
570
571 // constructor
572 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) {}
573
574 // setter
575 inline graph_add_edge_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
576 inline graph_add_edge_x&& src(graph_node_t src_in) { m_src = src_in; return std::move(*this); }
577 inline graph_add_edge_x&& dst(graph_node_t dst_in) { m_dst = dst_in; return std::move(*this); }
578 inline graph_add_edge_x&& fn(graph_edge_run_cb_t fn_in) { m_fn = fn_in; return std::move(*this); }
579 inline graph_add_edge_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
580
582 void call() const;
583 inline void operator()() const { return call(); }
584};
585
586inline void graph_add_edge(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in) {
587 return graph_add_edge_x(comp_in, src_in, dst_in).call();
588}
589
590
601
607 public:
608 // args declaration
612
613 // constructor
615
616 // setter
617 inline graph_node_mark_complete_x&& node(graph_node_t node_in) { m_node = node_in; return std::move(*this); }
618 inline graph_node_mark_complete_x&& status(status_t status_in) { m_status = status_in; return std::move(*this); }
619 inline graph_node_mark_complete_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
620
622 void call() const;
623 inline void operator()() const { return call(); }
624};
625
627 return graph_node_mark_complete_x(node_in).call();
628}
629
630
640
646 public:
647 // args declaration
650
651 // constructor
652 graph_start_x(comp_t comp_in) : m_comp(comp_in) {}
653
654 // setter
655 inline graph_start_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
656 inline graph_start_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
657
659 void call() const;
660 inline void operator()() const { return call(); }
661};
662
663inline void graph_start(comp_t comp_in) {
664 return graph_start_x(comp_in).call();
665}
666
667
677
683 public:
684 // args declaration
687
688 // constructor
689 graph_test_x(comp_t comp_in) : m_comp(comp_in) {}
690
691 // setter
692 inline graph_test_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
693 inline graph_test_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
694
696 status_t call() const;
697 inline status_t operator()() const { return call(); }
698};
699
700inline status_t graph_test(comp_t comp_in) {
701 return graph_test_x(comp_in).call();
702}
703
704
722
728 public:
729 // args declaration
740
741 // constructor
743
744 // setter
745 inline alloc_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
746 inline alloc_net_context_x&& backend(attr_backend_t backend_in) { m_backend = backend_in; return std::move(*this); }
747 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); }
748 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); }
749 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); }
750 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); }
751 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); }
752 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); }
753 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); }
754 inline alloc_net_context_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
755
757 net_context_t call() const;
758 inline net_context_t operator()() const { return call(); }
759};
760
764
765
775
781 public:
782 // args declaration
785
786 // constructor
787 free_net_context_x(net_context_t* net_context_in) : m_net_context(net_context_in) {}
788
789 // setter
790 inline free_net_context_x&& net_context(net_context_t* net_context_in) { m_net_context = net_context_in; return std::move(*this); }
791 inline free_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
792
794 void call() const;
795 inline void operator()() const { return call(); }
796};
797
798inline void free_net_context(net_context_t* net_context_in) {
799 return free_net_context_x(net_context_in).call();
800}
801
802
820
826 public:
827 // args declaration
838
839 // constructor
841
842 // setter
843 inline alloc_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
844 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); }
845 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); }
846 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); }
847 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); }
848 inline alloc_device_x&& alloc_default_endpoint(bool alloc_default_endpoint_in) { m_alloc_default_endpoint = alloc_default_endpoint_in; return std::move(*this); }
849 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); }
850 inline alloc_device_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
851 inline alloc_device_x&& net_context(net_context_t net_context_in) { m_net_context = net_context_in; return std::move(*this); }
852 inline alloc_device_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
853
855 device_t call() const;
856 inline device_t operator()() const { return call(); }
857};
858
860 return alloc_device_x().call();
861}
862
863
873
879 public:
880 // args declaration
883
884 // constructor
885 free_device_x(device_t* device_in) : m_device(device_in) {}
886
887 // setter
888 inline free_device_x&& device(device_t* device_in) { m_device = device_in; return std::move(*this); }
889 inline free_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
890
892 void call() const;
893 inline void operator()() const { return call(); }
894};
895
896inline void free_device(device_t* device_in) {
897 return free_device_x(device_in).call();
898}
899
900
912
918 public:
919 // args declaration
921 size_t m_size;
924
925 // constructor
926 register_memory_x(void* address_in, size_t size_in) : m_address(address_in), m_size(size_in) {}
927
928 // setter
929 inline register_memory_x&& address(void* address_in) { m_address = address_in; return std::move(*this); }
930 inline register_memory_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
931 inline register_memory_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
932 inline register_memory_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
933
935 mr_t call() const;
936 inline mr_t operator()() const { return call(); }
937};
938
939inline mr_t register_memory(void* address_in, size_t size_in) {
940 return register_memory_x(address_in, size_in).call();
941}
942
943
953
959 public:
960 // args declaration
963
964 // constructor
965 deregister_memory_x(mr_t* mr_in) : m_mr(mr_in) {}
966
967 // setter
968 inline deregister_memory_x&& mr(mr_t* mr_in) { m_mr = mr_in; return std::move(*this); }
969 inline deregister_memory_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
970
972 void call() const;
973 inline void operator()() const { return call(); }
974};
975
976inline void deregister_memory(mr_t* mr_in) {
977 return deregister_memory_x(mr_in).call();
978}
979
980
990
996 public:
997 // args declaration
1000
1001 // constructor
1002 get_rmr_x(mr_t mr_in) : m_mr(mr_in) {}
1003
1004 // setter
1005 inline get_rmr_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1006 inline get_rmr_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1007
1009 rmr_t call() const;
1010 inline rmr_t operator()() const { return call(); }
1011};
1012
1013inline rmr_t get_rmr(mr_t mr_in) {
1014 return get_rmr_x(mr_in).call();
1015}
1016
1017
1028
1034 public:
1035 // args declaration
1039
1040 // constructor
1042
1043 // setter
1044 inline alloc_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1045 inline alloc_endpoint_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1046 inline alloc_endpoint_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1047
1049 endpoint_t call() const;
1050 inline endpoint_t operator()() const { return call(); }
1051};
1052
1054 return alloc_endpoint_x().call();
1055}
1056
1057
1067
1073 public:
1074 // args declaration
1077
1078 // constructor
1079 free_endpoint_x(endpoint_t* endpoint_in) : m_endpoint(endpoint_in) {}
1080
1081 // setter
1082 inline free_endpoint_x&& endpoint(endpoint_t* endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1083 inline free_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1084
1086 void call() const;
1087 inline void operator()() const { return call(); }
1088};
1089
1090inline void free_endpoint(endpoint_t* endpoint_in) {
1091 return free_endpoint_x(endpoint_in).call();
1092}
1093
1094
1106
1112 public:
1113 // args declaration
1118
1119 // constructor
1120 net_poll_cq_x(size_t max_polls_in, net_status_t* statuses_in) : m_max_polls(max_polls_in), m_statuses(statuses_in) {}
1121
1122 // setter
1123 inline net_poll_cq_x&& max_polls(size_t max_polls_in) { m_max_polls = max_polls_in; return std::move(*this); }
1124 inline net_poll_cq_x&& statuses(net_status_t* statuses_in) { m_statuses = statuses_in; return std::move(*this); }
1125 inline net_poll_cq_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1126 inline net_poll_cq_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1127
1129 size_t call() const;
1130 inline size_t operator()() const { return call(); }
1131};
1132
1133inline size_t net_poll_cq(size_t max_polls_in, net_status_t* statuses_in) {
1134 return net_poll_cq_x(max_polls_in, statuses_in).call();
1135}
1136
1137
1151
1157 public:
1158 // args declaration
1160 size_t m_size;
1165
1166 // constructor
1167 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) {}
1168
1169 // setter
1170 inline net_post_recv_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1171 inline net_post_recv_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1172 inline net_post_recv_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1173 inline net_post_recv_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1174 inline net_post_recv_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1175 inline net_post_recv_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1176
1178 error_t call() const;
1179 inline error_t operator()() const { return call(); }
1180};
1181
1182inline error_t net_post_recv(void* buffer_in, size_t size_in, mr_t mr_in) {
1183 return net_post_recv_x(buffer_in, size_in, mr_in).call();
1184}
1185
1186
1201
1207 public:
1208 // args declaration
1211 size_t m_size;
1216
1217 // constructor
1218 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) {}
1219
1220 // setter
1221 inline net_post_sends_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1222 inline net_post_sends_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1223 inline net_post_sends_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1224 inline net_post_sends_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1225 inline net_post_sends_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1226 inline net_post_sends_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1227 inline net_post_sends_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1228
1230 error_t call() const;
1231 inline error_t operator()() const { return call(); }
1232};
1233
1234inline error_t net_post_sends(int rank_in, void* buffer_in, size_t size_in) {
1235 return net_post_sends_x(rank_in, buffer_in, size_in).call();
1236}
1237
1238
1255
1261 public:
1262 // args declaration
1265 size_t m_size;
1272
1273 // constructor
1274 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) {}
1275
1276 // setter
1277 inline net_post_send_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1278 inline net_post_send_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1279 inline net_post_send_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1280 inline net_post_send_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1281 inline net_post_send_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1282 inline net_post_send_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1283 inline net_post_send_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1284 inline net_post_send_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1285 inline net_post_send_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1286
1288 error_t call() const;
1289 inline error_t operator()() const { return call(); }
1290};
1291
1292inline error_t net_post_send(int rank_in, void* buffer_in, size_t size_in, mr_t mr_in) {
1293 return net_post_send_x(rank_in, buffer_in, size_in, mr_in).call();
1294}
1295
1296
1312
1318 public:
1319 // args declaration
1322 size_t m_size;
1323 uint64_t m_offset;
1328
1329 // constructor
1330 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) {}
1331
1332 // setter
1333 inline net_post_puts_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1334 inline net_post_puts_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1335 inline net_post_puts_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1336 inline net_post_puts_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1337 inline net_post_puts_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1338 inline net_post_puts_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1339 inline net_post_puts_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1340 inline net_post_puts_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1341
1343 error_t call() const;
1344 inline error_t operator()() const { return call(); }
1345};
1346
1347inline error_t net_post_puts(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) {
1348 return net_post_puts_x(rank_in, buffer_in, size_in, offset_in, rmr_in).call();
1349}
1350
1351
1369
1375 public:
1376 // args declaration
1379 size_t m_size;
1381 uint64_t m_offset;
1387
1388 // constructor
1389 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) {}
1390
1391 // setter
1392 inline net_post_put_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1393 inline net_post_put_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1394 inline net_post_put_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1395 inline net_post_put_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1396 inline net_post_put_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1397 inline net_post_put_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1398 inline net_post_put_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1399 inline net_post_put_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1400 inline net_post_put_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1401 inline net_post_put_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1402
1404 error_t call() const;
1405 inline error_t operator()() const { return call(); }
1406};
1407
1408inline 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) {
1409 return net_post_put_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
1410}
1411
1412
1429
1435 public:
1436 // args declaration
1439 size_t m_size;
1440 uint64_t m_offset;
1446
1447 // constructor
1448 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) {}
1449
1450 // setter
1451 inline net_post_putImms_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1452 inline net_post_putImms_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1453 inline net_post_putImms_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1454 inline net_post_putImms_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1455 inline net_post_putImms_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1456 inline net_post_putImms_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1457 inline net_post_putImms_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1458 inline net_post_putImms_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1459 inline net_post_putImms_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1460
1462 error_t call() const;
1463 inline error_t operator()() const { return call(); }
1464};
1465
1466inline error_t net_post_putImms(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) {
1467 return net_post_putImms_x(rank_in, buffer_in, size_in, offset_in, rmr_in).call();
1468}
1469
1470
1489
1495 public:
1496 // args declaration
1499 size_t m_size;
1501 uint64_t m_offset;
1508
1509 // constructor
1510 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) {}
1511
1512 // setter
1513 inline net_post_putImm_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1514 inline net_post_putImm_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1515 inline net_post_putImm_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1516 inline net_post_putImm_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1517 inline net_post_putImm_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1518 inline net_post_putImm_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1519 inline net_post_putImm_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1520 inline net_post_putImm_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1521 inline net_post_putImm_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1522 inline net_post_putImm_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1523 inline net_post_putImm_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1524
1526 error_t call() const;
1527 inline error_t operator()() const { return call(); }
1528};
1529
1530inline 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) {
1531 return net_post_putImm_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
1532}
1533
1534
1552
1558 public:
1559 // args declaration
1562 size_t m_size;
1564 uint64_t m_offset;
1570
1571 // constructor
1572 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) {}
1573
1574 // setter
1575 inline net_post_get_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1576 inline net_post_get_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1577 inline net_post_get_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1578 inline net_post_get_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1579 inline net_post_get_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1580 inline net_post_get_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1581 inline net_post_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1582 inline net_post_get_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1583 inline net_post_get_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1584 inline net_post_get_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1585
1587 error_t call() const;
1588 inline error_t operator()() const { return call(); }
1589};
1590
1591inline 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) {
1592 return net_post_get_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
1593}
1594
1595
1627
1633 public:
1634 // args declaration
1638 size_t m_size;
1659
1660 // constructor
1661 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) {}
1662
1663 // setter
1664 inline post_comm_x&& direction(direction_t direction_in) { m_direction = direction_in; return std::move(*this); }
1665 inline post_comm_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1666 inline post_comm_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
1667 inline post_comm_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1668 inline post_comm_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
1669 inline post_comm_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1670 inline post_comm_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1671 inline post_comm_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1672 inline post_comm_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1673 inline post_comm_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1674 inline post_comm_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1675 inline post_comm_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1676 inline post_comm_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
1677 inline post_comm_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1678 inline post_comm_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
1679 inline post_comm_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
1680 inline post_comm_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1681 inline post_comm_x&& buffers(buffers_t buffers_in) { m_buffers = buffers_in; return std::move(*this); }
1682 inline post_comm_x&& rbuffers(rbuffers_t rbuffers_in) { m_rbuffers = rbuffers_in; return std::move(*this); }
1683 inline post_comm_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
1684 inline post_comm_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
1685 inline post_comm_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
1686 inline post_comm_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
1687 inline post_comm_x&& force_zcopy(bool force_zcopy_in) { m_force_zcopy = force_zcopy_in; return std::move(*this); }
1688
1690 status_t call() const;
1691 inline status_t operator()() const { return call(); }
1692};
1693
1694inline status_t post_comm(direction_t direction_in, int rank_in, void* local_buffer_in, size_t size_in, comp_t local_comp_in) {
1695 return post_comm_x(direction_in, rank_in, local_buffer_in, size_in, local_comp_in).call();
1696}
1697
1698
1724
1730 public:
1731 // args declaration
1734 size_t m_size;
1750
1751 // constructor
1752 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) {}
1753
1754 // setter
1755 inline post_am_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1756 inline post_am_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
1757 inline post_am_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1758 inline post_am_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
1759 inline post_am_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
1760 inline post_am_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1761 inline post_am_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1762 inline post_am_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1763 inline post_am_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1764 inline post_am_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1765 inline post_am_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1766 inline post_am_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
1767 inline post_am_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1768 inline post_am_x&& buffers(buffers_t buffers_in) { m_buffers = buffers_in; return std::move(*this); }
1769 inline post_am_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
1770 inline post_am_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
1771 inline post_am_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
1772 inline post_am_x&& force_zcopy(bool force_zcopy_in) { m_force_zcopy = force_zcopy_in; return std::move(*this); }
1773
1775 status_t call() const;
1776 inline status_t operator()() const { return call(); }
1777};
1778
1779inline 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) {
1780 return post_am_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_comp_in).call();
1781}
1782
1783
1810
1816 public:
1817 // args declaration
1820 size_t m_size;
1837
1838 // constructor
1839 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) {}
1840
1841 // setter
1842 inline post_send_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1843 inline post_send_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
1844 inline post_send_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1845 inline post_send_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
1846 inline post_send_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
1847 inline post_send_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1848 inline post_send_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1849 inline post_send_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1850 inline post_send_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1851 inline post_send_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1852 inline post_send_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1853 inline post_send_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1854 inline post_send_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1855 inline post_send_x&& buffers(buffers_t buffers_in) { m_buffers = buffers_in; return std::move(*this); }
1856 inline post_send_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
1857 inline post_send_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
1858 inline post_send_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
1859 inline post_send_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
1860 inline post_send_x&& force_zcopy(bool force_zcopy_in) { m_force_zcopy = force_zcopy_in; return std::move(*this); }
1861
1863 status_t call() const;
1864 inline status_t operator()() const { return call(); }
1865};
1866
1867inline status_t post_send(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) {
1868 return post_send_x(rank_in, local_buffer_in, size_in, tag_in, local_comp_in).call();
1869}
1870
1871
1897
1903 public:
1904 // args declaration
1907 size_t m_size;
1923
1924 // constructor
1925 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) {}
1926
1927 // setter
1928 inline post_recv_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1929 inline post_recv_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
1930 inline post_recv_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1931 inline post_recv_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
1932 inline post_recv_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
1933 inline post_recv_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1934 inline post_recv_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1935 inline post_recv_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1936 inline post_recv_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1937 inline post_recv_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1938 inline post_recv_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1939 inline post_recv_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1940 inline post_recv_x&& buffers(buffers_t buffers_in) { m_buffers = buffers_in; return std::move(*this); }
1941 inline post_recv_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
1942 inline post_recv_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
1943 inline post_recv_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
1944 inline post_recv_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
1945 inline post_recv_x&& force_zcopy(bool force_zcopy_in) { m_force_zcopy = force_zcopy_in; return std::move(*this); }
1946
1948 status_t call() const;
1949 inline status_t operator()() const { return call(); }
1950};
1951
1952inline status_t post_recv(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) {
1953 return post_recv_x(rank_in, local_buffer_in, size_in, tag_in, local_comp_in).call();
1954}
1955
1956
1985
1991 public:
1992 // args declaration
1995 size_t m_size;
1997 uintptr_t m_remote_disp;
2014
2015 // constructor
2016 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) {}
2017
2018 // setter
2019 inline post_put_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2020 inline post_put_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
2021 inline post_put_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2022 inline post_put_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
2023 inline post_put_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
2024 inline post_put_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
2025 inline post_put_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2026 inline post_put_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2027 inline post_put_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2028 inline post_put_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2029 inline post_put_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
2030 inline post_put_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
2031 inline post_put_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
2032 inline post_put_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
2033 inline post_put_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2034 inline post_put_x&& buffers(buffers_t buffers_in) { m_buffers = buffers_in; return std::move(*this); }
2035 inline post_put_x&& rbuffers(rbuffers_t rbuffers_in) { m_rbuffers = rbuffers_in; return std::move(*this); }
2036 inline post_put_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
2037 inline post_put_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
2038 inline post_put_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
2039 inline post_put_x&& force_zcopy(bool force_zcopy_in) { m_force_zcopy = force_zcopy_in; return std::move(*this); }
2040
2042 status_t call() const;
2043 inline status_t operator()() const { return call(); }
2044};
2045
2046inline 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) {
2047 return post_put_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_disp_in, rmr_in).call();
2048}
2049
2050
2078
2084 public:
2085 // args declaration
2088 size_t m_size;
2090 uintptr_t m_remote_disp;
2106
2107 // constructor
2108 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) {}
2109
2110 // setter
2111 inline post_get_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2112 inline post_get_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
2113 inline post_get_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2114 inline post_get_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
2115 inline post_get_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
2116 inline post_get_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
2117 inline post_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2118 inline post_get_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2119 inline post_get_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2120 inline post_get_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2121 inline post_get_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
2122 inline post_get_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
2123 inline post_get_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
2124 inline post_get_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2125 inline post_get_x&& buffers(buffers_t buffers_in) { m_buffers = buffers_in; return std::move(*this); }
2126 inline post_get_x&& rbuffers(rbuffers_t rbuffers_in) { m_rbuffers = rbuffers_in; return std::move(*this); }
2127 inline post_get_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
2128 inline post_get_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
2129 inline post_get_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
2130 inline post_get_x&& force_zcopy(bool force_zcopy_in) { m_force_zcopy = force_zcopy_in; return std::move(*this); }
2131
2133 status_t call() const;
2134 inline status_t operator()() const { return call(); }
2135};
2136
2137inline 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) {
2138 return post_get_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_disp_in, rmr_in).call();
2139}
2140
2141
2152
2158 public:
2159 // args declaration
2163
2164 // constructor
2166
2167 // setter
2168 inline progress_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2169 inline progress_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2170 inline progress_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2171
2173 error_t call() const;
2174 inline error_t operator()() const { return call(); }
2175};
2176
2178 return progress_x().call();
2179}
2180
2181
2190
2196 public:
2197 // args declaration
2198
2199 // constructor
2201
2202 // setter
2203
2204 int call_impl() const;
2205 int call() const;
2206 inline int operator()() const { return call(); }
2207};
2208
2209inline int get_rank_me() {
2210 return get_rank_me_x().call();
2211}
2212
2213
2222
2228 public:
2229 // args declaration
2230
2231 // constructor
2233
2234 // setter
2235
2236 int call_impl() const;
2237 int call() const;
2238 inline int operator()() const { return call(); }
2239};
2240
2241inline int get_rank_n() {
2242 return get_rank_n_x().call();
2243}
2244
2245
2261
2267 public:
2268 // args declaration
2277
2278 // constructor
2280
2281 // setter
2282 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); }
2283 inline alloc_runtime_x&& imm_nbits_tag(int imm_nbits_tag_in) { m_imm_nbits_tag = imm_nbits_tag_in; return std::move(*this); }
2284 inline alloc_runtime_x&& imm_nbits_rcomp(int imm_nbits_rcomp_in) { m_imm_nbits_rcomp = imm_nbits_rcomp_in; return std::move(*this); }
2285 inline alloc_runtime_x&& alloc_default_device(bool alloc_default_device_in) { m_alloc_default_device = alloc_default_device_in; return std::move(*this); }
2286 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); }
2287 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); }
2288 inline alloc_runtime_x&& rdv_protocol(attr_rdv_protocol_t rdv_protocol_in) { m_rdv_protocol = rdv_protocol_in; return std::move(*this); }
2289 inline alloc_runtime_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2290
2292 runtime_t call() const;
2293 inline runtime_t operator()() const { return call(); }
2294};
2295
2297 return alloc_runtime_x().call();
2298}
2299
2300
2309
2315 public:
2316 // args declaration
2318
2319 // constructor
2320 free_runtime_x(runtime_t* runtime_in) : m_runtime(runtime_in) {}
2321
2322 // setter
2323 inline free_runtime_x&& runtime(runtime_t* runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2324
2326 void call() const;
2327 inline void operator()() const { return call(); }
2328};
2329
2330inline void free_runtime(runtime_t* runtime_in) {
2331 return free_runtime_x(runtime_in).call();
2332}
2333
2334
2349
2355 public:
2356 // args declaration
2364
2365 // constructor
2367
2368 // setter
2369 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); }
2370 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); }
2371 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); }
2372 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); }
2373 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); }
2374 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); }
2375 inline g_runtime_init_x&& rdv_protocol(attr_rdv_protocol_t rdv_protocol_in) { m_rdv_protocol = rdv_protocol_in; return std::move(*this); }
2376
2378 void call() const;
2379 inline void operator()() const { return call(); }
2380};
2381
2382inline void g_runtime_init() {
2383 return g_runtime_init_x().call();
2384}
2385
2386
2395
2401 public:
2402 // args declaration
2403
2404 // constructor
2406
2407 // setter
2408
2409 void call_impl() const;
2410 void call() const;
2411 inline void operator()() const { return call(); }
2412};
2413
2414inline void g_runtime_fina() {
2415 return g_runtime_fina_x().call();
2416}
2417
2418
2427
2433 public:
2434 // args declaration
2435
2436 // constructor
2438
2439 // setter
2440
2442 runtime_t call() const;
2443 inline runtime_t operator()() const { return call(); }
2444};
2445
2447 return get_g_runtime_x().call();
2448}
2449
2450
2462
2468 public:
2469 // args declaration
2474
2475 // constructor
2477
2478 // setter
2479 inline alloc_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2480 inline alloc_packet_pool_x&& packet_size(size_t packet_size_in) { m_packet_size = packet_size_in; return std::move(*this); }
2481 inline alloc_packet_pool_x&& npackets(size_t npackets_in) { m_npackets = npackets_in; return std::move(*this); }
2482 inline alloc_packet_pool_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2483
2485 packet_pool_t call() const;
2486 inline packet_pool_t operator()() const { return call(); }
2487};
2488
2492
2493
2503
2509 public:
2510 // args declaration
2513
2514 // constructor
2515 free_packet_pool_x(packet_pool_t* packet_pool_in) : m_packet_pool(packet_pool_in) {}
2516
2517 // setter
2518 inline free_packet_pool_x&& packet_pool(packet_pool_t* packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2519 inline free_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2520
2522 void call() const;
2523 inline void operator()() const { return call(); }
2524};
2525
2526inline void free_packet_pool(packet_pool_t* packet_pool_in) {
2527 return free_packet_pool_x(packet_pool_in).call();
2528}
2529
2530
2541
2547 public:
2548 // args declaration
2552
2553 // constructor
2554 register_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in) : m_packet_pool(packet_pool_in), m_device(device_in) {}
2555
2556 // setter
2557 inline register_packet_pool_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2558 inline register_packet_pool_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2559 inline register_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2560
2562 void call() const;
2563 inline void operator()() const { return call(); }
2564};
2565
2566inline void register_packet_pool(packet_pool_t packet_pool_in, device_t device_in) {
2567 return register_packet_pool_x(packet_pool_in, device_in).call();
2568}
2569
2570
2581
2587 public:
2588 // args declaration
2592
2593 // constructor
2594 deregister_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in) : m_packet_pool(packet_pool_in), m_device(device_in) {}
2595
2596 // setter
2597 inline deregister_packet_pool_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2598 inline deregister_packet_pool_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2599 inline deregister_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2600
2602 void call() const;
2603 inline void operator()() const { return call(); }
2604};
2605
2606inline void deregister_packet_pool(packet_pool_t packet_pool_in, device_t device_in) {
2607 return deregister_packet_pool_x(packet_pool_in, device_in).call();
2608}
2609
2610
2620
2626 public:
2627 // args declaration
2630
2631 // constructor
2633
2634 // setter
2635 inline get_upacket_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2636 inline get_upacket_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2637
2639 void* call() const;
2640 inline void* operator()() const { return call(); }
2641};
2642
2643inline void* get_upacket() {
2644 return get_upacket_x().call();
2645}
2646
2647
2657
2663 public:
2664 // args declaration
2667
2668 // constructor
2669 put_upacket_x(void* packet_in) : m_packet(packet_in) {}
2670
2671 // setter
2672 inline put_upacket_x&& packet(void* packet_in) { m_packet = packet_in; return std::move(*this); }
2673 inline put_upacket_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2674
2675 void call_impl(void* packet, runtime_t runtime) const;
2676 void call() const;
2677 inline void operator()() const { return call(); }
2678};
2679
2680inline void put_upacket(void* packet_in) {
2681 return put_upacket_x(packet_in).call();
2682}
2683
2684
2695
2701 public:
2702 // args declaration
2706
2707 // constructor
2709
2710 // setter
2711 inline alloc_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2712 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); }
2713 inline alloc_matching_engine_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2714
2716 matching_engine_t call() const;
2717 inline matching_engine_t operator()() const { return call(); }
2718};
2719
2723
2724
2734
2740 public:
2741 // args declaration
2744
2745 // constructor
2746 free_matching_engine_x(matching_engine_t* matching_engine_in) : m_matching_engine(matching_engine_in) {}
2747
2748 // setter
2749 inline free_matching_engine_x&& matching_engine(matching_engine_t* matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2750 inline free_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2751
2753 void call() const;
2754 inline void operator()() const { return call(); }
2755};
2756
2757inline void free_matching_engine(matching_engine_t* matching_engine_in) {
2758 return free_matching_engine_x(matching_engine_in).call();
2759}
2760
2761
2774
2780 public:
2781 // args declaration
2787
2788 // constructor
2789 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) {}
2790
2791 // setter
2792 inline matching_engine_insert_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2793 inline matching_engine_insert_x&& key(matching_entry_key_t key_in) { m_key = key_in; return std::move(*this); }
2794 inline matching_engine_insert_x&& value(matching_entry_val_t value_in) { m_value = value_in; return std::move(*this); }
2795 inline matching_engine_insert_x&& entry_type(matching_entry_type_t entry_type_in) { m_entry_type = entry_type_in; return std::move(*this); }
2796 inline matching_engine_insert_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2797
2799 matching_entry_val_t call() const;
2800 inline matching_entry_val_t operator()() const { return call(); }
2801};
2802
2804 return matching_engine_insert_x(matching_engine_in, key_in, value_in, entry_type_in).call();
2805}
2806
2807
2817
2823 public:
2824 // args declaration
2827
2828 // constructor
2829 set_allocator_x(allocator_base_t* allocator_in) : m_allocator(allocator_in) {}
2830
2831 // setter
2832 inline set_allocator_x&& allocator(allocator_base_t* allocator_in) { m_allocator = allocator_in; return std::move(*this); }
2833 inline set_allocator_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2834
2836 void call() const;
2837 inline void operator()() const { return call(); }
2838};
2839
2840inline void set_allocator(allocator_base_t* allocator_in) {
2841 return set_allocator_x(allocator_in).call();
2842}
2843
2844
2853
2859 public:
2860 // args declaration
2862
2863 // constructor
2865
2866 // setter
2867 inline get_allocator_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2868
2870 allocator_base_t* call() const;
2871 inline allocator_base_t* operator()() const { return call(); }
2872};
2873
2875 return get_allocator_x().call();
2876}
2877
2878
2887
2893 public:
2894 // args declaration
2896
2897 // constructor
2899
2900 // setter
2901 inline get_default_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2902
2904 net_context_t call() const;
2905 inline net_context_t operator()() const { return call(); }
2906};
2907
2911
2912
2921
2927 public:
2928 // args declaration
2930
2931 // constructor
2933
2934 // setter
2935 inline get_default_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2936
2938 device_t call() const;
2939 inline device_t operator()() const { return call(); }
2940};
2941
2943 return get_default_device_x().call();
2944}
2945
2946
2956
2962 public:
2963 // args declaration
2966
2967 // constructor
2969
2970 // setter
2971 inline get_default_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2972 inline get_default_endpoint_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2973
2975 endpoint_t call() const;
2976 inline endpoint_t operator()() const { return call(); }
2977};
2978
2982
2983
2992
2998 public:
2999 // args declaration
3001
3002 // constructor
3004
3005 // setter
3006 inline get_default_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3007
3009 packet_pool_t call() const;
3010 inline packet_pool_t operator()() const { return call(); }
3011};
3012
3016
3017
3026
3032 public:
3033 // args declaration
3035
3036 // constructor
3038
3039 // setter
3040 inline get_default_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3041
3043 matching_engine_t call() const;
3044 inline matching_engine_t operator()() const { return call(); }
3045};
3046
3050
3051
3061
3067 public:
3068 // args declaration
3071
3072 // constructor
3074
3075 // setter
3076 inline get_max_bcopy_size_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3077 inline get_max_bcopy_size_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3078
3080 size_t call() const;
3081 inline size_t operator()() const { return call(); }
3082};
3083
3084inline size_t get_max_bcopy_size() {
3085 return get_max_bcopy_size_x().call();
3086}
3087
3088
3102
3108 public:
3109 // args declaration
3116
3117 // constructor
3119
3120 // setter
3121 inline barrier_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3122 inline barrier_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3123 inline barrier_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3124 inline barrier_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3125 inline barrier_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3126 inline barrier_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3127
3129 void call() const;
3130 inline void operator()() const { return call(); }
3131};
3132
3133inline void barrier() {
3134 return barrier_x().call();
3135}
3136
3137
3155
3161 public:
3162 // args declaration
3164 size_t m_size;
3173
3174 // constructor
3175 broadcast_x(void* buffer_in, size_t size_in, int root_in) : m_buffer(buffer_in), m_size(size_in), m_root(root_in) {}
3176
3177 // setter
3178 inline broadcast_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
3179 inline broadcast_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3180 inline broadcast_x&& root(int root_in) { m_root = root_in; return std::move(*this); }
3181 inline broadcast_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3182 inline broadcast_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3183 inline broadcast_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3184 inline broadcast_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3185 inline broadcast_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3186 inline broadcast_x&& algorithm(broadcast_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
3187 inline broadcast_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
3188
3190 void call() const;
3191 inline void operator()() const { return call(); }
3192};
3193
3194inline void broadcast(void* buffer_in, size_t size_in, int root_in) {
3195 return broadcast_x(buffer_in, size_in, root_in).call();
3196}
3197
3198
3216
3222 public:
3223 // args declaration
3224 const void* m_sendbuf;
3226 size_t m_count;
3234
3235 // constructor
3236 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) {}
3237
3238 // setter
3239 inline reduce_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
3240 inline reduce_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
3241 inline reduce_x&& count(size_t count_in) { m_count = count_in; return std::move(*this); }
3242 inline reduce_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
3243 inline reduce_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
3244 inline reduce_x&& root(int root_in) { m_root = root_in; return std::move(*this); }
3245 inline reduce_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3246 inline reduce_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3247 inline reduce_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3248 inline reduce_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3249
3251 void call() const;
3252 inline void operator()() const { return call(); }
3253};
3254
3255inline 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) {
3256 return reduce_x(sendbuf_in, recvbuf_in, count_in, item_size_in, op_in, root_in).call();
3257}
3258
3259
3279
3285 public:
3286 // args declaration
3287 const void* m_sendbuf;
3299
3300 // constructor
3301 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) {}
3302
3303 // setter
3304 inline reduce_scatter_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
3305 inline reduce_scatter_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
3306 inline reduce_scatter_x&& recvcount(size_t recvcount_in) { m_recvcount = recvcount_in; return std::move(*this); }
3307 inline reduce_scatter_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
3308 inline reduce_scatter_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
3309 inline reduce_scatter_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3310 inline reduce_scatter_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3311 inline reduce_scatter_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3312 inline reduce_scatter_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3313 inline reduce_scatter_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3314 inline reduce_scatter_x&& algorithm(reduce_scatter_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
3315 inline reduce_scatter_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
3316
3318 void call() const;
3319 inline void operator()() const { return call(); }
3320};
3321
3322inline void reduce_scatter(const void* sendbuf_in, void* recvbuf_in, size_t recvcount_in, size_t item_size_in, reduce_op_t op_in) {
3323 return reduce_scatter_x(sendbuf_in, recvbuf_in, recvcount_in, item_size_in, op_in).call();
3324}
3325
3326
3346
3352 public:
3353 // args declaration
3354 const void* m_sendbuf;
3356 size_t m_count;
3366
3367 // constructor
3368 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) {}
3369
3370 // setter
3371 inline allreduce_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
3372 inline allreduce_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
3373 inline allreduce_x&& count(size_t count_in) { m_count = count_in; return std::move(*this); }
3374 inline allreduce_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
3375 inline allreduce_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
3376 inline allreduce_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3377 inline allreduce_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3378 inline allreduce_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3379 inline allreduce_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3380 inline allreduce_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3381 inline allreduce_x&& algorithm(allreduce_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
3382 inline allreduce_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
3383
3385 void call() const;
3386 inline void operator()() const { return call(); }
3387};
3388
3389inline void allreduce(const void* sendbuf_in, void* recvbuf_in, size_t count_in, size_t item_size_in, reduce_op_t op_in) {
3390 return allreduce_x(sendbuf_in, recvbuf_in, count_in, item_size_in, op_in).call();
3391}
3392
3393
3408
3414 public:
3415 // args declaration
3416 const void* m_sendbuf;
3418 size_t m_size;
3423
3424 // constructor
3425 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) {}
3426
3427 // setter
3428 inline allgather_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
3429 inline allgather_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
3430 inline allgather_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3431 inline allgather_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3432 inline allgather_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3433 inline allgather_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3434 inline allgather_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3435
3437 void call() const;
3438 inline void operator()() const { return call(); }
3439};
3440
3441inline void allgather(const void* sendbuf_in, void* recvbuf_in, size_t size_in) {
3442 return allgather_x(sendbuf_in, recvbuf_in, size_in).call();
3443}
3444
3445
3460
3466 public:
3467 // args declaration
3468 const void* m_sendbuf;
3470 size_t m_size;
3475
3476 // constructor
3477 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) {}
3478
3479 // setter
3480 inline alltoall_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
3481 inline alltoall_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
3482 inline alltoall_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3483 inline alltoall_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3484 inline alltoall_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3485 inline alltoall_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3486 inline alltoall_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3487
3489 void call() const;
3490 inline void operator()() const { return call(); }
3491};
3492
3493inline void alltoall(const void* sendbuf_in, void* recvbuf_in, size_t size_in) {
3494 return alltoall_x(sendbuf_in, recvbuf_in, size_in).call();
3495}
3496
3497
3498} // namespace lci
3499
3500#endif // LCI_BINDING_POST_HPP_
The actual implementation for allgather.
Definition lci_binding_post.hpp:3413
allgather_x && size(size_t size_in)
Definition lci_binding_post.hpp:3430
allgather_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:3429
void * m_recvbuf
Definition lci_binding_post.hpp:3417
size_t m_size
Definition lci_binding_post.hpp:3418
void call() const
Definition binding.cpp:907
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3419
const void * m_sendbuf
Definition lci_binding_post.hpp:3416
allgather_x && device(device_t device_in)
Definition lci_binding_post.hpp:3432
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:3422
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3421
allgather_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3431
allgather_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3433
allgather_x(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:3425
allgather_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3434
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:3420
void operator()() const
Definition lci_binding_post.hpp:3438
allgather_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:3428
The actual implementation for alloc_cq.
Definition lci_binding_post.hpp:350
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:353
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:355
alloc_cq_x && cq_type(attr_cq_type_t cq_type_in)
Definition lci_binding_post.hpp:366
alloc_cq_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:365
comp_t operator()() const
Definition lci_binding_post.hpp:371
option_t< int > m_default_length
Definition lci_binding_post.hpp:354
option_t< attr_cq_type_t > m_cq_type
Definition lci_binding_post.hpp:356
alloc_cq_x && default_length(int default_length_in)
Definition lci_binding_post.hpp:364
alloc_cq_x()
Definition lci_binding_post.hpp:360
comp_t call() const
Definition binding.cpp:232
option_t< void * > m_user_context
Definition lci_binding_post.hpp:357
alloc_cq_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:367
alloc_cq_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:363
comp_t call_impl(runtime_t runtime, int default_length, bool zero_copy_am, attr_cq_type_t cq_type, void *user_context) const
The actual implementation for alloc_device.
Definition lci_binding_post.hpp:825
alloc_device_x && alloc_default_endpoint(bool alloc_default_endpoint_in)
Definition lci_binding_post.hpp:848
alloc_device_x()
Definition lci_binding_post.hpp:840
device_t call_impl(runtime_t runtime, size_t net_max_sends, size_t net_max_recvs, size_t net_max_cqes, uint64_t ofi_lock_mode, bool alloc_default_endpoint, attr_ibv_td_strategy_t ibv_td_strategy, void *user_context, net_context_t net_context, packet_pool_t packet_pool) const
option_t< net_context_t > m_net_context
Definition lci_binding_post.hpp:836
alloc_device_x && net_max_recvs(size_t net_max_recvs_in)
Definition lci_binding_post.hpp:845
option_t< attr_ibv_td_strategy_t > m_ibv_td_strategy
Definition lci_binding_post.hpp:834
alloc_device_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:850
option_t< size_t > m_net_max_recvs
Definition lci_binding_post.hpp:830
alloc_device_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:852
alloc_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:843
alloc_device_x && ofi_lock_mode(uint64_t ofi_lock_mode_in)
Definition lci_binding_post.hpp:847
option_t< uint64_t > m_ofi_lock_mode
Definition lci_binding_post.hpp:832
option_t< void * > m_user_context
Definition lci_binding_post.hpp:835
option_t< size_t > m_net_max_sends
Definition lci_binding_post.hpp:829
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:837
option_t< size_t > m_net_max_cqes
Definition lci_binding_post.hpp:831
alloc_device_x && net_context(net_context_t net_context_in)
Definition lci_binding_post.hpp:851
option_t< bool > m_alloc_default_endpoint
Definition lci_binding_post.hpp:833
device_t operator()() const
Definition lci_binding_post.hpp:856
device_t call() const
Definition binding.cpp:340
alloc_device_x && net_max_cqes(size_t net_max_cqes_in)
Definition lci_binding_post.hpp:846
alloc_device_x && ibv_td_strategy(attr_ibv_td_strategy_t ibv_td_strategy_in)
Definition lci_binding_post.hpp:849
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:828
alloc_device_x && net_max_sends(size_t net_max_sends_in)
Definition lci_binding_post.hpp:844
The actual implementation for alloc_endpoint.
Definition lci_binding_post.hpp:1033
endpoint_t call() const
Definition binding.cpp:387
endpoint_t call_impl(runtime_t runtime, void *user_context, device_t device) const
alloc_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1044
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1037
alloc_endpoint_x()
Definition lci_binding_post.hpp:1041
option_t< device_t > m_device
Definition lci_binding_post.hpp:1038
alloc_endpoint_x && device(device_t device_in)
Definition lci_binding_post.hpp:1046
endpoint_t operator()() const
Definition lci_binding_post.hpp:1050
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1036
alloc_endpoint_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1045
The actual implementation for alloc_graph.
Definition lci_binding_post.hpp:474
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:479
alloc_graph_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:487
comp_t call() const
Definition binding.cpp:255
option_t< void * > m_user_context
Definition lci_binding_post.hpp:478
alloc_graph_x()
Definition lci_binding_post.hpp:482
comp_t call_impl(comp_t comp, void *user_context, runtime_t runtime) const
alloc_graph_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:486
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:477
alloc_graph_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:485
comp_t operator()() const
Definition lci_binding_post.hpp:491
The actual implementation for alloc_handler.
Definition lci_binding_post.hpp:432
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:436
alloc_handler_x && handler(comp_handler_t handler_in)
Definition lci_binding_post.hpp:444
alloc_handler_x(comp_handler_t handler_in)
Definition lci_binding_post.hpp:441
option_t< void * > m_user_context
Definition lci_binding_post.hpp:438
comp_t call() const
Definition binding.cpp:247
comp_t operator()() const
Definition lci_binding_post.hpp:451
alloc_handler_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:446
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:437
comp_t call_impl(comp_handler_t handler, runtime_t runtime, bool zero_copy_am, void *user_context) const
alloc_handler_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:447
alloc_handler_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:445
comp_handler_t m_handler
Definition lci_binding_post.hpp:435
The actual implementation for alloc_matching_engine.
Definition lci_binding_post.hpp:2700
matching_engine_t operator()() const
Definition lci_binding_post.hpp:2717
matching_engine_t call() const
Definition binding.cpp:772
alloc_matching_engine_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2713
option_t< attr_matching_engine_type_t > m_matching_engine_type
Definition lci_binding_post.hpp:2704
matching_engine_t call_impl(runtime_t runtime, attr_matching_engine_type_t matching_engine_type, void *user_context) const
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2705
alloc_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2711
alloc_matching_engine_x && matching_engine_type(attr_matching_engine_type_t matching_engine_type_in)
Definition lci_binding_post.hpp:2712
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2703
alloc_matching_engine_x()
Definition lci_binding_post.hpp:2708
The actual implementation for alloc_net_context.
Definition lci_binding_post.hpp:727
net_context_t call_impl(runtime_t runtime, attr_backend_t backend, std::string ofi_provider_name, size_t max_msg_size, size_t max_inject_size, int ibv_gid_idx, bool ibv_force_gid_auto_select, attr_ibv_odp_strategy_t ibv_odp_strategy, attr_ibv_prefetch_strategy_t ibv_prefetch_strategy, void *user_context) const
alloc_net_context_x && ofi_provider_name(std::string ofi_provider_name_in)
Definition lci_binding_post.hpp:747
option_t< int > m_ibv_gid_idx
Definition lci_binding_post.hpp:735
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:730
alloc_net_context_x && ibv_prefetch_strategy(attr_ibv_prefetch_strategy_t ibv_prefetch_strategy_in)
Definition lci_binding_post.hpp:753
alloc_net_context_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:745
option_t< attr_ibv_odp_strategy_t > m_ibv_odp_strategy
Definition lci_binding_post.hpp:737
alloc_net_context_x && ibv_gid_idx(int ibv_gid_idx_in)
Definition lci_binding_post.hpp:750
alloc_net_context_x()
Definition lci_binding_post.hpp:742
alloc_net_context_x && max_inject_size(size_t max_inject_size_in)
Definition lci_binding_post.hpp:749
option_t< void * > m_user_context
Definition lci_binding_post.hpp:739
alloc_net_context_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:754
alloc_net_context_x && backend(attr_backend_t backend_in)
Definition lci_binding_post.hpp:746
alloc_net_context_x && ibv_force_gid_auto_select(bool ibv_force_gid_auto_select_in)
Definition lci_binding_post.hpp:751
alloc_net_context_x && ibv_odp_strategy(attr_ibv_odp_strategy_t ibv_odp_strategy_in)
Definition lci_binding_post.hpp:752
option_t< attr_backend_t > m_backend
Definition lci_binding_post.hpp:731
alloc_net_context_x && max_msg_size(size_t max_msg_size_in)
Definition lci_binding_post.hpp:748
net_context_t call() const
Definition binding.cpp:310
option_t< std::string > m_ofi_provider_name
Definition lci_binding_post.hpp:732
option_t< bool > m_ibv_force_gid_auto_select
Definition lci_binding_post.hpp:736
option_t< size_t > m_max_inject_size
Definition lci_binding_post.hpp:734
net_context_t operator()() const
Definition lci_binding_post.hpp:758
option_t< size_t > m_max_msg_size
Definition lci_binding_post.hpp:733
option_t< attr_ibv_prefetch_strategy_t > m_ibv_prefetch_strategy
Definition lci_binding_post.hpp:738
The actual implementation for alloc_packet_pool.
Definition lci_binding_post.hpp:2467
packet_pool_t call() const
Definition binding.cpp:728
alloc_packet_pool_x()
Definition lci_binding_post.hpp:2476
packet_pool_t call_impl(runtime_t runtime, size_t packet_size, size_t npackets, void *user_context) const
alloc_packet_pool_x && npackets(size_t npackets_in)
Definition lci_binding_post.hpp:2481
alloc_packet_pool_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2482
alloc_packet_pool_x && packet_size(size_t packet_size_in)
Definition lci_binding_post.hpp:2480
option_t< size_t > m_packet_size
Definition lci_binding_post.hpp:2471
alloc_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2479
packet_pool_t operator()() const
Definition lci_binding_post.hpp:2486
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2473
option_t< size_t > m_npackets
Definition lci_binding_post.hpp:2472
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2470
The actual implementation for alloc_runtime.
Definition lci_binding_post.hpp:2266
alloc_runtime_x && imm_nbits_tag(int imm_nbits_tag_in)
Definition lci_binding_post.hpp:2283
alloc_runtime_x && imm_nbits_rcomp(int imm_nbits_rcomp_in)
Definition lci_binding_post.hpp:2284
option_t< bool > m_alloc_default_packet_pool
Definition lci_binding_post.hpp:2273
runtime_t operator()() const
Definition lci_binding_post.hpp:2293
option_t< bool > m_alloc_default_matching_engine
Definition lci_binding_post.hpp:2274
runtime_t call() const
Definition binding.cpp:683
alloc_runtime_x && alloc_default_packet_pool(bool alloc_default_packet_pool_in)
Definition lci_binding_post.hpp:2286
alloc_runtime_x && rdv_protocol(attr_rdv_protocol_t rdv_protocol_in)
Definition lci_binding_post.hpp:2288
alloc_runtime_x()
Definition lci_binding_post.hpp:2279
alloc_runtime_x && alloc_default_matching_engine(bool alloc_default_matching_engine_in)
Definition lci_binding_post.hpp:2287
alloc_runtime_x && alloc_default_device(bool alloc_default_device_in)
Definition lci_binding_post.hpp:2285
runtime_t call_impl(size_t packet_return_threshold, int imm_nbits_tag, int imm_nbits_rcomp, bool alloc_default_device, bool alloc_default_packet_pool, bool alloc_default_matching_engine, attr_rdv_protocol_t rdv_protocol, void *user_context) const
alloc_runtime_x && packet_return_threshold(size_t packet_return_threshold_in)
Definition lci_binding_post.hpp:2282
alloc_runtime_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2289
option_t< bool > m_alloc_default_device
Definition lci_binding_post.hpp:2272
option_t< attr_rdv_protocol_t > m_rdv_protocol
Definition lci_binding_post.hpp:2275
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2276
option_t< int > m_imm_nbits_rcomp
Definition lci_binding_post.hpp:2271
option_t< size_t > m_packet_return_threshold
Definition lci_binding_post.hpp:2269
option_t< int > m_imm_nbits_tag
Definition lci_binding_post.hpp:2270
The actual implementation for alloc_sync.
Definition lci_binding_post.hpp:220
comp_t operator()() const
Definition lci_binding_post.hpp:239
option_t< int > m_threshold
Definition lci_binding_post.hpp:224
option_t< void * > m_user_context
Definition lci_binding_post.hpp:226
alloc_sync_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:235
alloc_sync_x && threshold(int threshold_in)
Definition lci_binding_post.hpp:233
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:225
alloc_sync_x()
Definition lci_binding_post.hpp:229
alloc_sync_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:234
alloc_sync_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:232
comp_t call_impl(runtime_t runtime, int threshold, bool zero_copy_am, void *user_context) const
comp_t call() const
Definition binding.cpp:208
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:223
The actual implementation for allreduce.
Definition lci_binding_post.hpp:3351
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:3374
void operator()() const
Definition lci_binding_post.hpp:3386
const void * m_sendbuf
Definition lci_binding_post.hpp:3354
option_t< device_t > m_device
Definition lci_binding_post.hpp:3360
allreduce_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:3371
reduce_op_t m_op
Definition lci_binding_post.hpp:3358
void * m_recvbuf
Definition lci_binding_post.hpp:3355
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:3365
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:3368
allreduce_x && device(device_t device_in)
Definition lci_binding_post.hpp:3377
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:3362
size_t m_count
Definition lci_binding_post.hpp:3356
allreduce_x && count(size_t count_in)
Definition lci_binding_post.hpp:3373
allreduce_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:3372
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3361
allreduce_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3378
option_t< allreduce_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:3364
allreduce_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:3375
allreduce_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3376
allreduce_x && algorithm(allreduce_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:3381
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3359
allreduce_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:3382
size_t m_item_size
Definition lci_binding_post.hpp:3357
allreduce_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3380
void call() const
Definition binding.cpp:891
allreduce_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3379
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:3363
The actual implementation for alltoall.
Definition lci_binding_post.hpp:3465
const void * m_sendbuf
Definition lci_binding_post.hpp:3468
void call() const
Definition binding.cpp:918
alltoall_x && device(device_t device_in)
Definition lci_binding_post.hpp:3484
alltoall_x && size(size_t size_in)
Definition lci_binding_post.hpp:3482
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< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:3474
alltoall_x(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:3477
void * m_recvbuf
Definition lci_binding_post.hpp:3469
alltoall_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:3481
option_t< device_t > m_device
Definition lci_binding_post.hpp:3472
alltoall_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3486
alltoall_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3485
alltoall_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3483
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3471
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3473
alltoall_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:3480
size_t m_size
Definition lci_binding_post.hpp:3470
void operator()() const
Definition lci_binding_post.hpp:3490
The actual implementation for barrier.
Definition lci_binding_post.hpp:3107
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:3115
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:3113
barrier_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3124
barrier_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3126
barrier_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3125
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:3111
void call() const
Definition binding.cpp:837
barrier_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3123
barrier_x()
Definition lci_binding_post.hpp:3118
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3112
barrier_x && device(device_t device_in)
Definition lci_binding_post.hpp:3122
void operator()() const
Definition lci_binding_post.hpp:3130
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3114
barrier_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3121
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3110
The actual implementation for broadcast.
Definition lci_binding_post.hpp:3160
broadcast_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3184
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3168
void call() const
Definition binding.cpp:847
void operator()() const
Definition lci_binding_post.hpp:3191
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:3169
int m_root
Definition lci_binding_post.hpp:3165
broadcast_x && root(int root_in)
Definition lci_binding_post.hpp:3180
broadcast_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3185
broadcast_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3181
broadcast_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:3187
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3166
broadcast_x && size(size_t size_in)
Definition lci_binding_post.hpp:3179
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:3172
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:3170
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:3175
broadcast_x && device(device_t device_in)
Definition lci_binding_post.hpp:3182
option_t< broadcast_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:3171
void * m_buffer
Definition lci_binding_post.hpp:3163
option_t< device_t > m_device
Definition lci_binding_post.hpp:3167
broadcast_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:3178
broadcast_x && algorithm(broadcast_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:3186
broadcast_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3183
size_t m_size
Definition lci_binding_post.hpp:3164
The actual implementation for comp_signal.
Definition lci_binding_post.hpp:65
comp_signal_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:78
comp_signal_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:76
status_t m_status
Definition lci_binding_post.hpp:69
comp_t m_comp
Definition lci_binding_post.hpp:68
void call() const
Definition binding.cpp:182
comp_signal_x(comp_t comp_in, status_t status_in)
Definition lci_binding_post.hpp:73
void call_impl(comp_t comp, status_t status, runtime_t runtime) const
void operator()() const
Definition lci_binding_post.hpp:82
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:70
comp_signal_x && status(status_t status_in)
Definition lci_binding_post.hpp:77
The actual implementation for RESOURCE comp.
Definition lci_binding_pre.hpp:128
The actual implementation for cq_pop.
Definition lci_binding_post.hpp:393
status_t operator()() const
Definition lci_binding_post.hpp:408
comp_t m_comp
Definition lci_binding_post.hpp:396
status_t call_impl(comp_t comp, runtime_t runtime) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:397
cq_pop_x(comp_t comp_in)
Definition lci_binding_post.hpp:400
cq_pop_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:403
cq_pop_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:404
status_t call() const
Definition binding.cpp:241
The actual implementation for deregister_memory.
Definition lci_binding_post.hpp:958
void operator()() const
Definition lci_binding_post.hpp:973
void call() const
Definition binding.cpp:371
mr_t * m_mr
Definition lci_binding_post.hpp:961
deregister_memory_x && mr(mr_t *mr_in)
Definition lci_binding_post.hpp:968
deregister_memory_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:969
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:962
void call_impl(mr_t *mr, runtime_t runtime) const
deregister_memory_x(mr_t *mr_in)
Definition lci_binding_post.hpp:965
The actual implementation for deregister_packet_pool.
Definition lci_binding_post.hpp:2586
deregister_packet_pool_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:2597
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:2589
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2591
void operator()() const
Definition lci_binding_post.hpp:2603
void call() const
Definition binding.cpp:749
deregister_packet_pool_x && device(device_t device_in)
Definition lci_binding_post.hpp:2598
device_t m_device
Definition lci_binding_post.hpp:2590
deregister_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2599
deregister_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:2594
The actual implementation for deregister_rcomp.
Definition lci_binding_post.hpp:181
deregister_rcomp_x(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:188
void operator()() const
Definition lci_binding_post.hpp:196
rcomp_t m_rcomp
Definition lci_binding_post.hpp:184
void call_impl(rcomp_t rcomp, runtime_t runtime) const
void call() const
Definition binding.cpp:202
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:185
deregister_rcomp_x && rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:191
deregister_rcomp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:192
The actual implementation for RESOURCE device.
Definition lci_binding_pre.hpp:241
The actual implementation for RESOURCE endpoint.
Definition lci_binding_pre.hpp:320
The actual implementation for free_comp.
Definition lci_binding_post.hpp:27
free_comp_x(comp_t *comp_in)
Definition lci_binding_post.hpp:34
free_comp_x && comp(comp_t *comp_in)
Definition lci_binding_post.hpp:37
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:31
comp_t * m_comp
Definition lci_binding_post.hpp:30
void call() const
Definition binding.cpp:176
free_comp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:38
void operator()() const
Definition lci_binding_post.hpp:42
void call_impl(comp_t *comp, runtime_t runtime) const
The actual implementation for free_device.
Definition lci_binding_post.hpp:878
void call_impl(device_t *device, runtime_t runtime) const
free_device_x && device(device_t *device_in)
Definition lci_binding_post.hpp:888
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:882
device_t * m_device
Definition lci_binding_post.hpp:881
void operator()() const
Definition lci_binding_post.hpp:893
void call() const
Definition binding.cpp:354
free_device_x(device_t *device_in)
Definition lci_binding_post.hpp:885
free_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:889
The actual implementation for free_endpoint.
Definition lci_binding_post.hpp:1072
void operator()() const
Definition lci_binding_post.hpp:1087
endpoint_t * m_endpoint
Definition lci_binding_post.hpp:1075
free_endpoint_x && endpoint(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:1082
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1076
free_endpoint_x(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:1079
void call_impl(endpoint_t *endpoint, runtime_t runtime) const
void call() const
Definition binding.cpp:394
free_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1083
The actual implementation for free_matching_engine.
Definition lci_binding_post.hpp:2739
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:2749
free_matching_engine_x(matching_engine_t *matching_engine_in)
Definition lci_binding_post.hpp:2746
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2743
matching_engine_t * m_matching_engine
Definition lci_binding_post.hpp:2742
void call() const
Definition binding.cpp:779
free_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2750
void operator()() const
Definition lci_binding_post.hpp:2754
The actual implementation for free_net_context.
Definition lci_binding_post.hpp:780
void operator()() const
Definition lci_binding_post.hpp:795
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:791
free_net_context_x(net_context_t *net_context_in)
Definition lci_binding_post.hpp:787
void call() const
Definition binding.cpp:324
net_context_t * m_net_context
Definition lci_binding_post.hpp:783
free_net_context_x && net_context(net_context_t *net_context_in)
Definition lci_binding_post.hpp:790
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:784
The actual implementation for free_packet_pool.
Definition lci_binding_post.hpp:2508
void operator()() const
Definition lci_binding_post.hpp:2523
free_packet_pool_x(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:2515
void call() const
Definition binding.cpp:736
void call_impl(packet_pool_t *packet_pool, runtime_t runtime) const
packet_pool_t * m_packet_pool
Definition lci_binding_post.hpp:2511
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2512
free_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2519
free_packet_pool_x && packet_pool(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:2518
The actual implementation for free_runtime.
Definition lci_binding_post.hpp:2314
void call_impl(runtime_t *runtime) const
free_runtime_x(runtime_t *runtime_in)
Definition lci_binding_post.hpp:2320
runtime_t * m_runtime
Definition lci_binding_post.hpp:2317
free_runtime_x && runtime(runtime_t *runtime_in)
Definition lci_binding_post.hpp:2323
void operator()() const
Definition lci_binding_post.hpp:2327
void call() const
Definition binding.cpp:696
The actual implementation for g_runtime_fina.
Definition lci_binding_post.hpp:2400
g_runtime_fina_x()
Definition lci_binding_post.hpp:2405
void call() const
Definition binding.cpp:714
void operator()() const
Definition lci_binding_post.hpp:2411
void call_impl() const
The actual implementation for g_runtime_init.
Definition lci_binding_post.hpp:2354
g_runtime_init_x && imm_nbits_rcomp(int imm_nbits_rcomp_in)
Definition lci_binding_post.hpp:2371
g_runtime_init_x && alloc_default_packet_pool(bool alloc_default_packet_pool_in)
Definition lci_binding_post.hpp:2373
g_runtime_init_x && imm_nbits_tag(int imm_nbits_tag_in)
Definition lci_binding_post.hpp:2370
option_t< int > m_imm_nbits_tag
Definition lci_binding_post.hpp:2358
void operator()() const
Definition lci_binding_post.hpp:2379
option_t< int > m_imm_nbits_rcomp
Definition lci_binding_post.hpp:2359
option_t< size_t > m_packet_return_threshold
Definition lci_binding_post.hpp:2357
option_t< attr_rdv_protocol_t > m_rdv_protocol
Definition lci_binding_post.hpp:2363
void call() const
Definition binding.cpp:702
option_t< bool > m_alloc_default_device
Definition lci_binding_post.hpp:2360
void call_impl(size_t packet_return_threshold, int imm_nbits_tag, int imm_nbits_rcomp, bool alloc_default_device, bool alloc_default_packet_pool, bool alloc_default_matching_engine, attr_rdv_protocol_t rdv_protocol) const
g_runtime_init_x && alloc_default_matching_engine(bool alloc_default_matching_engine_in)
Definition lci_binding_post.hpp:2374
option_t< bool > m_alloc_default_matching_engine
Definition lci_binding_post.hpp:2362
option_t< bool > m_alloc_default_packet_pool
Definition lci_binding_post.hpp:2361
g_runtime_init_x()
Definition lci_binding_post.hpp:2366
g_runtime_init_x && alloc_default_device(bool alloc_default_device_in)
Definition lci_binding_post.hpp:2372
g_runtime_init_x && packet_return_threshold(size_t packet_return_threshold_in)
Definition lci_binding_post.hpp:2369
g_runtime_init_x && rdv_protocol(attr_rdv_protocol_t rdv_protocol_in)
Definition lci_binding_post.hpp:2375
The actual implementation for get_allocator.
Definition lci_binding_post.hpp:2858
allocator_base_t * call_impl(runtime_t runtime) const
allocator_base_t * call() const
Definition binding.cpp:800
allocator_base_t * operator()() const
Definition lci_binding_post.hpp:2871
get_allocator_x()
Definition lci_binding_post.hpp:2864
get_allocator_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2867
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2861
The actual implementation for get_default_device.
Definition lci_binding_post.hpp:2926
device_t call_impl(runtime_t runtime) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2929
get_default_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2935
device_t call() const
Definition binding.cpp:810
get_default_device_x()
Definition lci_binding_post.hpp:2932
device_t operator()() const
Definition lci_binding_post.hpp:2939
The actual implementation for get_default_endpoint.
Definition lci_binding_post.hpp:2961
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:2972
endpoint_t operator()() const
Definition lci_binding_post.hpp:2976
endpoint_t call() const
Definition binding.cpp:815
get_default_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2971
get_default_endpoint_x()
Definition lci_binding_post.hpp:2968
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2964
option_t< device_t > m_device
Definition lci_binding_post.hpp:2965
The actual implementation for get_default_matching_engine.
Definition lci_binding_post.hpp:3031
get_default_matching_engine_x()
Definition lci_binding_post.hpp:3037
matching_engine_t call() const
Definition binding.cpp:826
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3034
matching_engine_t call_impl(runtime_t runtime) const
matching_engine_t operator()() const
Definition lci_binding_post.hpp:3044
get_default_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3040
The actual implementation for get_default_net_context.
Definition lci_binding_post.hpp:2892
net_context_t operator()() const
Definition lci_binding_post.hpp:2905
get_default_net_context_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2901
get_default_net_context_x()
Definition lci_binding_post.hpp:2898
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2895
net_context_t call_impl(runtime_t runtime) const
net_context_t call() const
Definition binding.cpp:805
The actual implementation for get_default_packet_pool.
Definition lci_binding_post.hpp:2997
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3000
packet_pool_t operator()() const
Definition lci_binding_post.hpp:3010
packet_pool_t call_impl(runtime_t runtime) const
packet_pool_t call() const
Definition binding.cpp:821
get_default_packet_pool_x()
Definition lci_binding_post.hpp:3003
get_default_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3006
The actual implementation for get_g_runtime.
Definition lci_binding_post.hpp:2432
runtime_t operator()() const
Definition lci_binding_post.hpp:2443
get_g_runtime_x()
Definition lci_binding_post.hpp:2437
runtime_t call() const
Definition binding.cpp:719
runtime_t call_impl() const
The actual implementation for get_max_bcopy_size.
Definition lci_binding_post.hpp:3066
size_t operator()() const
Definition lci_binding_post.hpp:3081
get_max_bcopy_size_x()
Definition lci_binding_post.hpp:3073
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3069
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:3070
get_max_bcopy_size_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3077
size_t call() const
Definition binding.cpp:831
get_max_bcopy_size_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3076
The actual implementation for get_rank_me.
Definition lci_binding_post.hpp:2195
int call_impl() const
int call() const
Definition binding.cpp:661
int operator()() const
Definition lci_binding_post.hpp:2206
get_rank_me_x()
Definition lci_binding_post.hpp:2200
The actual implementation for get_rank_n.
Definition lci_binding_post.hpp:2227
int call_impl() const
int call() const
Definition binding.cpp:665
int operator()() const
Definition lci_binding_post.hpp:2238
get_rank_n_x()
Definition lci_binding_post.hpp:2232
The actual implementation for get_rmr.
Definition lci_binding_post.hpp:995
get_rmr_x(mr_t mr_in)
Definition lci_binding_post.hpp:1002
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:999
get_rmr_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1005
rmr_t operator()() const
Definition lci_binding_post.hpp:1010
mr_t m_mr
Definition lci_binding_post.hpp:998
rmr_t call() const
Definition binding.cpp:377
get_rmr_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1006
rmr_t call_impl(mr_t mr, runtime_t runtime) const
The actual implementation for get_upacket.
Definition lci_binding_post.hpp:2625
get_upacket_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:2636
void * call() const
Definition binding.cpp:756
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2628
get_upacket_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2635
void * operator()() const
Definition lci_binding_post.hpp:2640
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:2629
get_upacket_x()
Definition lci_binding_post.hpp:2632
The actual implementation for graph_add_edge.
Definition lci_binding_post.hpp:562
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:565
void call() const
Definition binding.cpp:271
graph_add_edge_x(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in)
Definition lci_binding_post.hpp:572
graph_add_edge_x && dst(graph_node_t dst_in)
Definition lci_binding_post.hpp:577
graph_add_edge_x && fn(graph_edge_run_cb_t fn_in)
Definition lci_binding_post.hpp:578
void operator()() const
Definition lci_binding_post.hpp:583
option_t< graph_edge_run_cb_t > m_fn
Definition lci_binding_post.hpp:568
graph_add_edge_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:575
graph_node_t m_dst
Definition lci_binding_post.hpp:567
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:569
graph_add_edge_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:579
graph_add_edge_x && src(graph_node_t src_in)
Definition lci_binding_post.hpp:576
graph_node_t m_src
Definition lci_binding_post.hpp:566
The actual implementation for graph_add_node.
Definition lci_binding_post.hpp:516
option_t< void * > m_value
Definition lci_binding_post.hpp:521
graph_node_t operator()() const
Definition lci_binding_post.hpp:537
graph_add_node_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:533
graph_node_t call() const
Definition binding.cpp:262
graph_add_node_x(comp_t comp_in, graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:526
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:530
graph_node_run_cb_t m_fn
Definition lci_binding_post.hpp:520
comp_t m_comp
Definition lci_binding_post.hpp:519
graph_add_node_x && free_cb(graph_node_free_cb_t free_cb_in)
Definition lci_binding_post.hpp:532
graph_add_node_x && value(void *value_in)
Definition lci_binding_post.hpp:531
option_t< graph_node_free_cb_t > m_free_cb
Definition lci_binding_post.hpp:522
graph_add_node_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:529
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:523
The actual implementation for graph_node_mark_complete.
Definition lci_binding_post.hpp:606
void operator()() const
Definition lci_binding_post.hpp:623
void call() const
Definition binding.cpp:280
graph_node_t m_node
Definition lci_binding_post.hpp:609
graph_node_mark_complete_x(graph_node_t node_in)
Definition lci_binding_post.hpp:614
option_t< status_t > m_status
Definition lci_binding_post.hpp:610
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:617
graph_node_mark_complete_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:619
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:611
graph_node_mark_complete_x && status(status_t status_in)
Definition lci_binding_post.hpp:618
The actual implementation for graph_start.
Definition lci_binding_post.hpp:645
graph_start_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:656
comp_t m_comp
Definition lci_binding_post.hpp:648
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:649
graph_start_x(comp_t comp_in)
Definition lci_binding_post.hpp:652
void call_impl(comp_t comp, runtime_t runtime) const
void call() const
Definition binding.cpp:287
void operator()() const
Definition lci_binding_post.hpp:660
graph_start_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:655
The actual implementation for graph_test.
Definition lci_binding_post.hpp:682
comp_t m_comp
Definition lci_binding_post.hpp:685
status_t call_impl(comp_t comp, runtime_t runtime) const
graph_test_x(comp_t comp_in)
Definition lci_binding_post.hpp:689
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:686
graph_test_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:693
status_t operator()() const
Definition lci_binding_post.hpp:697
status_t call() const
Definition binding.cpp:293
graph_test_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:692
The actual implementation for matching_engine_insert.
Definition lci_binding_post.hpp:2779
matching_engine_insert_x && value(matching_entry_val_t value_in)
Definition lci_binding_post.hpp:2794
matching_engine_insert_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2796
matching_entry_val_t operator()() const
Definition lci_binding_post.hpp:2800
matching_entry_val_t call() const
Definition binding.cpp:785
matching_engine_insert_x && entry_type(matching_entry_type_t entry_type_in)
Definition lci_binding_post.hpp:2795
matching_engine_insert_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2792
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2786
matching_entry_type_t m_entry_type
Definition lci_binding_post.hpp:2785
matching_engine_t m_matching_engine
Definition lci_binding_post.hpp:2782
matching_entry_key_t m_key
Definition lci_binding_post.hpp:2783
matching_engine_insert_x && key(matching_entry_key_t key_in)
Definition lci_binding_post.hpp:2793
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:2789
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:2784
The actual implementation for RESOURCE matching_engine.
Definition lci_binding_pre.hpp:467
The actual implementation for RESOURCE mr.
Definition lci_binding_pre.hpp:283
The actual implementation for RESOURCE net_context.
Definition lci_binding_pre.hpp:184
The actual implementation for net_poll_cq.
Definition lci_binding_post.hpp:1111
net_poll_cq_x && device(device_t device_in)
Definition lci_binding_post.hpp:1126
net_poll_cq_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1125
option_t< device_t > m_device
Definition lci_binding_post.hpp:1117
net_poll_cq_x(size_t max_polls_in, net_status_t *statuses_in)
Definition lci_binding_post.hpp:1120
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1116
net_poll_cq_x && statuses(net_status_t *statuses_in)
Definition lci_binding_post.hpp:1124
size_t operator()() const
Definition lci_binding_post.hpp:1130
size_t call() const
Definition binding.cpp:400
net_poll_cq_x && max_polls(size_t max_polls_in)
Definition lci_binding_post.hpp:1123
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:1114
net_status_t * m_statuses
Definition lci_binding_post.hpp:1115
The actual implementation for net_post_get.
Definition lci_binding_post.hpp:1557
net_post_get_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1576
net_post_get_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1583
net_post_get_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1580
option_t< device_t > m_device
Definition lci_binding_post.hpp:1567
int m_rank
Definition lci_binding_post.hpp:1560
net_post_get_x && device(device_t device_in)
Definition lci_binding_post.hpp:1582
net_post_get_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1578
error_t operator()() const
Definition lci_binding_post.hpp:1588
net_post_get_x && size(size_t size_in)
Definition lci_binding_post.hpp:1577
error_t call() const
Definition binding.cpp:496
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1566
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1568
mr_t m_mr
Definition lci_binding_post.hpp:1563
void * m_buffer
Definition lci_binding_post.hpp:1561
net_post_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1581
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:1564
net_post_get_x && rank(int rank_in)
Definition lci_binding_post.hpp:1575
rmr_t m_rmr
Definition lci_binding_post.hpp:1565
size_t m_size
Definition lci_binding_post.hpp:1562
net_post_get_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1584
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1569
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:1572
net_post_get_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1579
The actual implementation for net_post_putImm.
Definition lci_binding_post.hpp:1494
net_post_putImm_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1521
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:1510
rmr_t m_rmr
Definition lci_binding_post.hpp:1502
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1503
net_post_putImm_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1516
net_post_putImm_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1518
error_t call() const
Definition binding.cpp:481
net_post_putImm_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1522
int m_rank
Definition lci_binding_post.hpp:1497
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1506
net_post_putImm_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1519
option_t< device_t > m_device
Definition lci_binding_post.hpp:1504
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1505
mr_t m_mr
Definition lci_binding_post.hpp:1500
net_post_putImm_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1514
void * m_buffer
Definition lci_binding_post.hpp:1498
net_post_putImm_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1523
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1507
error_t operator()() const
Definition lci_binding_post.hpp:1527
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:1499
net_post_putImm_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1517
uint64_t m_offset
Definition lci_binding_post.hpp:1501
net_post_putImm_x && size(size_t size_in)
Definition lci_binding_post.hpp:1515
net_post_putImm_x && rank(int rank_in)
Definition lci_binding_post.hpp:1513
net_post_putImm_x && device(device_t device_in)
Definition lci_binding_post.hpp:1520
The actual implementation for net_post_putImms.
Definition lci_binding_post.hpp:1434
net_post_putImms_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1452
net_post_putImms_x && device(device_t device_in)
Definition lci_binding_post.hpp:1457
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1444
option_t< device_t > m_device
Definition lci_binding_post.hpp:1443
net_post_putImms_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1455
net_post_putImms_x && rank(int rank_in)
Definition lci_binding_post.hpp:1451
uint64_t m_offset
Definition lci_binding_post.hpp:1440
void * m_buffer
Definition lci_binding_post.hpp:1438
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1445
int m_rank
Definition lci_binding_post.hpp:1437
error_t operator()() const
Definition lci_binding_post.hpp:1463
net_post_putImms_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1454
error_t call() const
Definition binding.cpp:468
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) const
rmr_t m_rmr
Definition lci_binding_post.hpp:1441
net_post_putImms_x && size(size_t size_in)
Definition lci_binding_post.hpp:1453
net_post_putImms_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1458
net_post_putImms_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1459
size_t m_size
Definition lci_binding_post.hpp:1439
net_post_putImms_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1456
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1442
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:1448
The actual implementation for net_post_put.
Definition lci_binding_post.hpp:1374
rmr_t m_rmr
Definition lci_binding_post.hpp:1382
net_post_put_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1393
mr_t m_mr
Definition lci_binding_post.hpp:1380
net_post_put_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1397
int m_rank
Definition lci_binding_post.hpp:1377
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:1389
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:1383
error_t call() const
Definition binding.cpp:454
net_post_put_x && rank(int rank_in)
Definition lci_binding_post.hpp:1392
option_t< device_t > m_device
Definition lci_binding_post.hpp:1384
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1385
net_post_put_x && device(device_t device_in)
Definition lci_binding_post.hpp:1399
net_post_put_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1401
net_post_put_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1400
net_post_put_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1395
net_post_put_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1396
net_post_put_x && size(size_t size_in)
Definition lci_binding_post.hpp:1394
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1386
size_t m_size
Definition lci_binding_post.hpp:1379
net_post_put_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1398
error_t operator()() const
Definition lci_binding_post.hpp:1405
uint64_t m_offset
Definition lci_binding_post.hpp:1381
void * m_buffer
Definition lci_binding_post.hpp:1378
The actual implementation for net_post_puts.
Definition lci_binding_post.hpp:1317
net_post_puts_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1337
net_post_puts_x && rank(int rank_in)
Definition lci_binding_post.hpp:1333
error_t operator()() const
Definition lci_binding_post.hpp:1344
net_post_puts_x && size(size_t size_in)
Definition lci_binding_post.hpp:1335
option_t< device_t > m_device
Definition lci_binding_post.hpp:1326
void * m_buffer
Definition lci_binding_post.hpp:1321
net_post_puts_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1336
net_post_puts_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1338
net_post_puts_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1334
net_post_puts_x && device(device_t device_in)
Definition lci_binding_post.hpp:1339
error_t call() const
Definition binding.cpp:442
int m_rank
Definition lci_binding_post.hpp:1320
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:1330
rmr_t m_rmr
Definition lci_binding_post.hpp:1324
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1325
size_t m_size
Definition lci_binding_post.hpp:1322
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) const
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1327
net_post_puts_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1340
uint64_t m_offset
Definition lci_binding_post.hpp:1323
The actual implementation for net_post_recv.
Definition lci_binding_post.hpp:1156
net_post_recv_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1173
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1164
net_post_recv_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1170
error_t call() const
Definition binding.cpp:408
net_post_recv_x(void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1167
net_post_recv_x && size(size_t size_in)
Definition lci_binding_post.hpp:1171
net_post_recv_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1172
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1162
option_t< device_t > m_device
Definition lci_binding_post.hpp:1163
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:1161
size_t m_size
Definition lci_binding_post.hpp:1160
error_t operator()() const
Definition lci_binding_post.hpp:1179
net_post_recv_x && device(device_t device_in)
Definition lci_binding_post.hpp:1174
void * m_buffer
Definition lci_binding_post.hpp:1159
net_post_recv_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1175
The actual implementation for net_post_send.
Definition lci_binding_post.hpp:1260
net_post_send_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1284
net_post_send_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1281
net_post_send_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1278
void * m_buffer
Definition lci_binding_post.hpp:1264
int m_rank
Definition lci_binding_post.hpp:1263
mr_t m_mr
Definition lci_binding_post.hpp:1266
size_t m_size
Definition lci_binding_post.hpp:1265
net_post_send_x && size(size_t size_in)
Definition lci_binding_post.hpp:1279
error_t call() const
Definition binding.cpp:429
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1267
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1270
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1269
net_post_send_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1280
net_post_send_x && device(device_t device_in)
Definition lci_binding_post.hpp:1282
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1271
net_post_send_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1283
net_post_send_x(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1274
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:1268
error_t operator()() const
Definition lci_binding_post.hpp:1289
net_post_send_x && rank(int rank_in)
Definition lci_binding_post.hpp:1277
net_post_send_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1285
The actual implementation for net_post_sends.
Definition lci_binding_post.hpp:1206
net_post_sends_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1227
net_post_sends_x && size(size_t size_in)
Definition lci_binding_post.hpp:1223
error_t call() const
Definition binding.cpp:418
option_t< device_t > m_device
Definition lci_binding_post.hpp:1213
net_post_sends_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1226
int m_rank
Definition lci_binding_post.hpp:1209
net_post_sends_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1224
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1215
net_post_sends_x(int rank_in, void *buffer_in, size_t size_in)
Definition lci_binding_post.hpp:1218
net_post_sends_x && rank(int rank_in)
Definition lci_binding_post.hpp:1221
void * m_buffer
Definition lci_binding_post.hpp:1210
error_t operator()() const
Definition lci_binding_post.hpp:1231
net_post_sends_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1222
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) const
size_t m_size
Definition lci_binding_post.hpp:1211
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1214
net_post_sends_x && device(device_t device_in)
Definition lci_binding_post.hpp:1225
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1212
The actual implementation for RESOURCE packet_pool.
Definition lci_binding_pre.hpp:428
The actual implementation for post_am.
Definition lci_binding_post.hpp:1729
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:1742
option_t< device_t > m_device
Definition lci_binding_post.hpp:1739
post_am_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1761
rcomp_t m_remote_comp
Definition lci_binding_post.hpp:1736
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:1743
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:1747
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:1752
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1740
post_am_x && buffers(buffers_t buffers_in)
Definition lci_binding_post.hpp:1768
post_am_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:1769
post_am_x && size(size_t size_in)
Definition lci_binding_post.hpp:1757
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:1748
post_am_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1760
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1737
post_am_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:1766
int m_rank
Definition lci_binding_post.hpp:1732
option_t< bool > m_force_zcopy
Definition lci_binding_post.hpp:1749
option_t< buffers_t > m_buffers
Definition lci_binding_post.hpp:1745
post_am_x && rank(int rank_in)
Definition lci_binding_post.hpp:1755
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:1738
post_am_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:1764
status_t call() const
Definition binding.cpp:538
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:1741
post_am_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1765
comp_t m_local_comp
Definition lci_binding_post.hpp:1735
post_am_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:1771
post_am_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:1770
post_am_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:1756
size_t m_size
Definition lci_binding_post.hpp:1734
post_am_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1763
post_am_x && device(device_t device_in)
Definition lci_binding_post.hpp:1762
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:1746
post_am_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1767
void * m_local_buffer
Definition lci_binding_post.hpp:1733
post_am_x && force_zcopy(bool force_zcopy_in)
Definition lci_binding_post.hpp:1772
post_am_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:1758
status_t call_impl(int rank, void *local_buffer, size_t size, comp_t local_comp, rcomp_t remote_comp, runtime_t runtime, packet_pool_t packet_pool, device_t device, endpoint_t endpoint, comp_semantic_t comp_semantic, mr_t mr, tag_t tag, void *user_context, buffers_t buffers, bool allow_done, bool allow_posted, bool allow_retry, bool force_zcopy) const
status_t operator()() const
Definition lci_binding_post.hpp:1776
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1744
post_am_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:1759
The actual implementation for post_comm.
Definition lci_binding_post.hpp:1632
status_t call() const
Definition binding.cpp:510
void * m_local_buffer
Definition lci_binding_post.hpp:1637
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1651
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:1654
post_comm_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:1679
option_t< bool > m_force_zcopy
Definition lci_binding_post.hpp:1658
option_t< device_t > m_device
Definition lci_binding_post.hpp:1642
post_comm_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1673
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:1657
int m_rank
Definition lci_binding_post.hpp:1636
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1644
post_comm_x && rank(int rank_in)
Definition lci_binding_post.hpp:1665
post_comm_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1669
post_comm_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:1666
size_t m_size
Definition lci_binding_post.hpp:1638
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1640
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:1646
comp_t m_local_comp
Definition lci_binding_post.hpp:1639
status_t operator()() const
Definition lci_binding_post.hpp:1691
option_t< buffers_t > m_buffers
Definition lci_binding_post.hpp:1652
option_t< rmr_t > m_rmr
Definition lci_binding_post.hpp:1648
post_comm_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1680
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:1656
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:1661
option_t< uintptr_t > m_remote_disp
Definition lci_binding_post.hpp:1647
post_comm_x && rbuffers(rbuffers_t rbuffers_in)
Definition lci_binding_post.hpp:1682
post_comm_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1670
post_comm_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:1684
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1643
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:1650
status_t call_impl(direction_t direction, int rank, void *local_buffer, size_t size, comp_t local_comp, runtime_t runtime, packet_pool_t packet_pool, device_t device, endpoint_t endpoint, 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, buffers_t buffers, rbuffers_t rbuffers, matching_policy_t matching_policy, bool allow_done, bool allow_posted, bool allow_retry, bool force_zcopy) const
post_comm_x && force_zcopy(bool force_zcopy_in)
Definition lci_binding_post.hpp:1687
option_t< rbuffers_t > m_rbuffers
Definition lci_binding_post.hpp:1653
post_comm_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:1668
post_comm_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:1678
post_comm_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1677
post_comm_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1675
post_comm_x && direction(direction_t direction_in)
Definition lci_binding_post.hpp:1664
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:1655
post_comm_x && size(size_t size_in)
Definition lci_binding_post.hpp:1667
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:1641
post_comm_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1672
post_comm_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:1685
post_comm_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:1674
post_comm_x && device(device_t device_in)
Definition lci_binding_post.hpp:1671
post_comm_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:1686
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:1645
post_comm_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:1683
direction_t m_direction
Definition lci_binding_post.hpp:1635
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:1649
post_comm_x && buffers(buffers_t buffers_in)
Definition lci_binding_post.hpp:1681
post_comm_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:1676
The actual implementation for post_get.
Definition lci_binding_post.hpp:2083
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:2098
option_t< buffers_t > m_buffers
Definition lci_binding_post.hpp:2100
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2099
option_t< rbuffers_t > m_rbuffers
Definition lci_binding_post.hpp:2101
post_get_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:2127
post_get_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:2122
comp_t m_local_comp
Definition lci_binding_post.hpp:2089
post_get_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:2115
post_get_x && rbuffers(rbuffers_t rbuffers_in)
Definition lci_binding_post.hpp:2126
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:2108
post_get_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:2121
status_t operator()() const
Definition lci_binding_post.hpp:2134
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:2093
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:2104
uintptr_t m_remote_disp
Definition lci_binding_post.hpp:2090
post_get_x && force_zcopy(bool force_zcopy_in)
Definition lci_binding_post.hpp:2130
void * m_local_buffer
Definition lci_binding_post.hpp:2087
post_get_x && buffers(buffers_t buffers_in)
Definition lci_binding_post.hpp:2125
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:2102
option_t< device_t > m_device
Definition lci_binding_post.hpp:2094
post_get_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:2116
int m_rank
Definition lci_binding_post.hpp:2086
post_get_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:2112
post_get_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:2123
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, packet_pool_t packet_pool, device_t device, endpoint_t endpoint, mr_t mr, tag_t tag, rcomp_t remote_comp, void *user_context, buffers_t buffers, rbuffers_t rbuffers, bool allow_done, bool allow_posted, bool allow_retry, bool force_zcopy) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2092
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:2103
post_get_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:2128
post_get_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:2118
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2095
post_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2117
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:2096
post_get_x && size(size_t size_in)
Definition lci_binding_post.hpp:2113
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:2097
post_get_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2120
status_t call() const
Definition binding.cpp:630
option_t< bool > m_force_zcopy
Definition lci_binding_post.hpp:2105
post_get_x && rank(int rank_in)
Definition lci_binding_post.hpp:2111
post_get_x && device(device_t device_in)
Definition lci_binding_post.hpp:2119
post_get_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:2114
post_get_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2124
size_t m_size
Definition lci_binding_post.hpp:2088
rmr_t m_rmr
Definition lci_binding_post.hpp:2091
post_get_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:2129
The actual implementation for post_put.
Definition lci_binding_post.hpp:1990
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:2010
post_put_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2033
post_put_x && device(device_t device_in)
Definition lci_binding_post.hpp:2027
status_t operator()() const
Definition lci_binding_post.hpp:2043
post_put_x && rank(int rank_in)
Definition lci_binding_post.hpp:2019
post_put_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2025
post_put_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2028
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:2011
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2002
comp_t m_local_comp
Definition lci_binding_post.hpp:1996
option_t< buffers_t > m_buffers
Definition lci_binding_post.hpp:2008
uintptr_t m_remote_disp
Definition lci_binding_post.hpp:1997
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:2012
option_t< device_t > m_device
Definition lci_binding_post.hpp:2001
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2007
post_put_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:2020
int m_rank
Definition lci_binding_post.hpp:1993
post_put_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:2026
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:2006
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:2016
post_put_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:2031
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:2004
post_put_x && buffers(buffers_t buffers_in)
Definition lci_binding_post.hpp:2034
post_put_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:2036
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:2005
option_t< rbuffers_t > m_rbuffers
Definition lci_binding_post.hpp:2009
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:2003
post_put_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:2029
post_put_x && force_zcopy(bool force_zcopy_in)
Definition lci_binding_post.hpp:2039
status_t call() const
Definition binding.cpp:605
post_put_x && size(size_t size_in)
Definition lci_binding_post.hpp:2021
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1999
post_put_x && rbuffers(rbuffers_t rbuffers_in)
Definition lci_binding_post.hpp:2035
post_put_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:2038
post_put_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:2024
post_put_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:2022
post_put_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:2023
option_t< bool > m_force_zcopy
Definition lci_binding_post.hpp:2013
rmr_t m_rmr
Definition lci_binding_post.hpp:1998
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:2000
size_t m_size
Definition lci_binding_post.hpp:1995
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, packet_pool_t packet_pool, device_t device, endpoint_t endpoint, comp_semantic_t comp_semantic, mr_t mr, tag_t tag, rcomp_t remote_comp, void *user_context, buffers_t buffers, rbuffers_t rbuffers, bool allow_done, bool allow_posted, bool allow_retry, bool force_zcopy) const
post_put_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:2032
post_put_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:2030
void * m_local_buffer
Definition lci_binding_post.hpp:1994
post_put_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:2037
The actual implementation for post_recv.
Definition lci_binding_post.hpp:1902
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:1921
post_recv_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:1943
size_t m_size
Definition lci_binding_post.hpp:1907
post_recv_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:1942
post_recv_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:1931
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1916
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1914
tag_t m_tag
Definition lci_binding_post.hpp:1908
post_recv_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1934
option_t< buffers_t > m_buffers
Definition lci_binding_post.hpp:1917
post_recv_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1933
option_t< device_t > m_device
Definition lci_binding_post.hpp:1912
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:1919
post_recv_x && size(size_t size_in)
Definition lci_binding_post.hpp:1930
status_t operator()() const
Definition lci_binding_post.hpp:1949
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:1911
post_recv_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1939
post_recv_x && force_zcopy(bool force_zcopy_in)
Definition lci_binding_post.hpp:1945
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:1915
void * m_local_buffer
Definition lci_binding_post.hpp:1906
post_recv_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1936
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1913
post_recv_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1937
comp_t m_local_comp
Definition lci_binding_post.hpp:1909
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:1920
post_recv_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1938
post_recv_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:1944
post_recv_x && device(device_t device_in)
Definition lci_binding_post.hpp:1935
int m_rank
Definition lci_binding_post.hpp:1905
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:1925
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1910
post_recv_x && buffers(buffers_t buffers_in)
Definition lci_binding_post.hpp:1940
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:1918
post_recv_x && rank(int rank_in)
Definition lci_binding_post.hpp:1928
option_t< bool > m_force_zcopy
Definition lci_binding_post.hpp:1922
post_recv_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:1932
post_recv_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:1941
post_recv_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:1929
status_t call() const
Definition binding.cpp:583
status_t call_impl(int rank, void *local_buffer, size_t size, tag_t tag, comp_t local_comp, runtime_t runtime, packet_pool_t packet_pool, device_t device, endpoint_t endpoint, matching_engine_t matching_engine, mr_t mr, void *user_context, buffers_t buffers, matching_policy_t matching_policy, bool allow_done, bool allow_posted, bool allow_retry, bool force_zcopy) const
The actual implementation for post_send.
Definition lci_binding_post.hpp:1815
post_send_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:1857
post_send_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:1846
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:1824
status_t call() const
Definition binding.cpp:560
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1827
post_send_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1850
option_t< bool > m_force_zcopy
Definition lci_binding_post.hpp:1836
void * m_local_buffer
Definition lci_binding_post.hpp:1819
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1830
post_send_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1853
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:1833
size_t m_size
Definition lci_binding_post.hpp:1820
int m_rank
Definition lci_binding_post.hpp:1818
post_send_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:1843
tag_t m_tag
Definition lci_binding_post.hpp:1821
post_send_x && size(size_t size_in)
Definition lci_binding_post.hpp:1844
comp_t m_local_comp
Definition lci_binding_post.hpp:1822
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:1839
status_t operator()() const
Definition lci_binding_post.hpp:1864
post_send_x && rank(int rank_in)
Definition lci_binding_post.hpp:1842
post_send_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1847
post_send_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:1859
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:1829
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1826
post_send_x && force_zcopy(bool force_zcopy_in)
Definition lci_binding_post.hpp:1860
post_send_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1851
option_t< buffers_t > m_buffers
Definition lci_binding_post.hpp:1831
post_send_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:1852
post_send_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:1858
option_t< device_t > m_device
Definition lci_binding_post.hpp:1825
post_send_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1854
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:1828
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:1832
post_send_x && buffers(buffers_t buffers_in)
Definition lci_binding_post.hpp:1855
post_send_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:1845
post_send_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:1856
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:1835
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:1834
status_t call_impl(int rank, void *local_buffer, size_t size, tag_t tag, comp_t local_comp, runtime_t runtime, packet_pool_t packet_pool, device_t device, endpoint_t endpoint, matching_engine_t matching_engine, comp_semantic_t comp_semantic, mr_t mr, void *user_context, buffers_t buffers, matching_policy_t matching_policy, bool allow_done, bool allow_posted, bool allow_retry, bool force_zcopy) const
post_send_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1848
post_send_x && device(device_t device_in)
Definition lci_binding_post.hpp:1849
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1823
The actual implementation for progress.
Definition lci_binding_post.hpp:2157
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2160
error_t call() const
Definition binding.cpp:654
progress_x()
Definition lci_binding_post.hpp:2165
progress_x && device(device_t device_in)
Definition lci_binding_post.hpp:2169
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2162
option_t< device_t > m_device
Definition lci_binding_post.hpp:2161
error_t operator()() const
Definition lci_binding_post.hpp:2174
progress_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2168
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:2170
The actual implementation for put_upacket.
Definition lci_binding_post.hpp:2662
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2666
void * m_packet
Definition lci_binding_post.hpp:2665
void call() const
Definition binding.cpp:762
void operator()() const
Definition lci_binding_post.hpp:2677
put_upacket_x && packet(void *packet_in)
Definition lci_binding_post.hpp:2672
put_upacket_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2673
put_upacket_x(void *packet_in)
Definition lci_binding_post.hpp:2669
void call_impl(void *packet, runtime_t runtime) const
The actual implementation for reduce_scatter.
Definition lci_binding_post.hpp:3284
reduce_scatter_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:3305
reduce_scatter_x && item_size(size_t item_size_in)
Definition lci_binding_post.hpp:3307
reduce_scatter_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3312
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:3298
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3294
reduce_scatter_x && device(device_t device_in)
Definition lci_binding_post.hpp:3310
reduce_scatter_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:3304
reduce_scatter_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3313
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:3296
option_t< reduce_scatter_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:3297
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3292
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:3288
size_t m_item_size
Definition lci_binding_post.hpp:3290
const void * m_sendbuf
Definition lci_binding_post.hpp:3287
size_t m_recvcount
Definition lci_binding_post.hpp:3289
reduce_scatter_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:3308
void operator()() const
Definition lci_binding_post.hpp:3319
reduce_scatter_x && algorithm(reduce_scatter_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:3314
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:3295
reduce_op_t m_op
Definition lci_binding_post.hpp:3291
void call() const
Definition binding.cpp:875
reduce_scatter_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3309
option_t< device_t > m_device
Definition lci_binding_post.hpp:3293
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:3301
reduce_scatter_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3311
reduce_scatter_x && recvcount(size_t recvcount_in)
Definition lci_binding_post.hpp:3306
reduce_scatter_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:3315
The actual implementation for reduce.
Definition lci_binding_post.hpp:3221
void operator()() const
Definition lci_binding_post.hpp:3252
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:3236
reduce_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:3243
reduce_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3248
reduce_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:3240
option_t< device_t > m_device
Definition lci_binding_post.hpp:3231
int m_root
Definition lci_binding_post.hpp:3229
size_t m_count
Definition lci_binding_post.hpp:3226
reduce_x && count(size_t count_in)
Definition lci_binding_post.hpp:3241
reduce_op_t m_op
Definition lci_binding_post.hpp:3228
reduce_x && device(device_t device_in)
Definition lci_binding_post.hpp:3246
size_t m_item_size
Definition lci_binding_post.hpp:3227
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3232
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:3225
reduce_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:3239
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:3233
reduce_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3245
reduce_x && item_size(size_t item_size_in)
Definition lci_binding_post.hpp:3242
reduce_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3247
reduce_x && root(int root_in)
Definition lci_binding_post.hpp:3244
const void * m_sendbuf
Definition lci_binding_post.hpp:3224
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3230
void call() const
Definition binding.cpp:861
The actual implementation for register_memory.
Definition lci_binding_post.hpp:917
register_memory_x && address(void *address_in)
Definition lci_binding_post.hpp:929
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:922
register_memory_x && device(device_t device_in)
Definition lci_binding_post.hpp:932
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:930
option_t< device_t > m_device
Definition lci_binding_post.hpp:923
void * m_address
Definition lci_binding_post.hpp:920
mr_t operator()() const
Definition lci_binding_post.hpp:936
register_memory_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:931
register_memory_x(void *address_in, size_t size_in)
Definition lci_binding_post.hpp:926
size_t m_size
Definition lci_binding_post.hpp:921
mr_t call() const
Definition binding.cpp:363
The actual implementation for register_packet_pool.
Definition lci_binding_post.hpp:2546
device_t m_device
Definition lci_binding_post.hpp:2550
void call_impl(packet_pool_t packet_pool, device_t device, runtime_t runtime) const
void operator()() const
Definition lci_binding_post.hpp:2563
register_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:2554
register_packet_pool_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:2557
void call() const
Definition binding.cpp:742
register_packet_pool_x && device(device_t device_in)
Definition lci_binding_post.hpp:2558
packet_pool_t m_packet_pool
Definition lci_binding_post.hpp:2549
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2551
register_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2559
The actual implementation for register_rcomp.
Definition lci_binding_post.hpp:142
rcomp_t call() const
Definition binding.cpp:195
rcomp_t operator()() const
Definition lci_binding_post.hpp:159
comp_t m_comp
Definition lci_binding_post.hpp:145
option_t< rcomp_t > m_rcomp
Definition lci_binding_post.hpp:147
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:146
register_rcomp_x && rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:155
register_rcomp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:154
register_rcomp_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:153
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:150
The actual implementation for reserve_rcomps.
Definition lci_binding_post.hpp:104
rcomp_t call_impl(rcomp_t n, runtime_t runtime) const
rcomp_t m_n
Definition lci_binding_post.hpp:107
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:108
reserve_rcomps_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:115
rcomp_t call() const
Definition binding.cpp:189
reserve_rcomps_x(rcomp_t n_in)
Definition lci_binding_post.hpp:111
rcomp_t operator()() const
Definition lci_binding_post.hpp:119
reserve_rcomps_x && n(rcomp_t n_in)
Definition lci_binding_post.hpp:114
The actual implementation for RESOURCE runtime.
Definition lci_binding_pre.hpp:378
The actual implementation for set_allocator.
Definition lci_binding_post.hpp:2822
set_allocator_x(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:2829
set_allocator_x && allocator(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:2832
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2826
void call_impl(allocator_base_t *allocator, runtime_t runtime) const
set_allocator_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2833
void call() const
Definition binding.cpp:794
allocator_base_t * m_allocator
Definition lci_binding_post.hpp:2825
void operator()() const
Definition lci_binding_post.hpp:2837
The actual implementation for sync_test.
Definition lci_binding_post.hpp:262
comp_t m_comp
Definition lci_binding_post.hpp:265
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:274
status_t * m_p_out
Definition lci_binding_post.hpp:266
sync_test_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:275
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:267
bool operator()() const
Definition lci_binding_post.hpp:279
sync_test_x(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:270
sync_test_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:273
bool call() const
Definition binding.cpp:216
The actual implementation for sync_wait.
Definition lci_binding_post.hpp:304
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:309
sync_wait_x(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:314
comp_t m_comp
Definition lci_binding_post.hpp:307
sync_wait_x && p_out(status_t *p_out_in)
Definition lci_binding_post.hpp:318
option_t< device_t > m_device
Definition lci_binding_post.hpp:311
sync_wait_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:319
void call() const
Definition binding.cpp:223
status_t * m_p_out
Definition lci_binding_post.hpp:308
option_t< bool > m_do_progress
Definition lci_binding_post.hpp:310
sync_wait_x && device(device_t device_in)
Definition lci_binding_post.hpp:321
sync_wait_x && do_progress(bool do_progress_in)
Definition lci_binding_post.hpp:320
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:325
sync_wait_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:317
broadcast_algorithm_t
The type of broadcast algorithm.
Definition lci.hpp:229
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:734
uint64_t matching_entry_key_t
The type of matching engine entry key.
Definition lci.hpp:403
status_t(*)(void *value) graph_node_run_cb_t
The function signature for a node function in the completion graph.
Definition lci.hpp:713
direction_t
The enum class of comunication direction.
Definition lci.hpp:353
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:728
void(*)(const void *left, const void *right, void *dst, size_t n) reduce_op_t
The user-defined reduction operation.
Definition lci.hpp:693
matching_policy_t
Enum class for matching policy.
Definition lci.hpp:392
void * graph_node_t
The node type for the completion graph.
Definition lci.hpp:699
allreduce_algorithm_t
The type of allreduce algorithm.
Definition lci.hpp:265
reduce_scatter_algorithm_t
The type of reduce scatter algorithm.
Definition lci.hpp:247
void * matching_entry_val_t
The type of matching engine entry value.
Definition lci.hpp:408
matching_entry_type_t
The type of matching entry.
Definition lci.hpp:383
uint32_t rcomp_t
The type of remote completion handler.
Definition lci.hpp:364
void(*)(status_t status) comp_handler_t
Function Signature for completion handler.
Definition lci.hpp:686
uint64_t tag_t
The type of tag.
Definition lci.hpp:347
comp_semantic_t
The enum class of completion semantic.
Definition lci.hpp:418
uint32_t net_imm_data_t
The type of network-layer immediate data field.
Definition lci.hpp:284
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:1694
error_t net_post_send(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1292
void graph_node_mark_complete(graph_node_t node_in)
Definition lci_binding_post.hpp:626
size_t get_max_bcopy_size()
Definition lci_binding_post.hpp:3084
attr_matching_engine_type_t
Definition lci_binding_pre.hpp:63
void broadcast(void *buffer_in, size_t size_in, int root_in)
Definition lci_binding_post.hpp:3194
device_t alloc_device()
Definition lci_binding_post.hpp:859
net_context_t alloc_net_context()
Definition lci_binding_post.hpp:761
void free_net_context(net_context_t *net_context_in)
Definition lci_binding_post.hpp:798
error_t net_post_recv(void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1182
attr_backend_t
Definition lci.hpp:63
void deregister_rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:199
void deregister_memory(mr_t *mr_in)
Definition lci_binding_post.hpp:976
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:1779
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:2803
rcomp_t reserve_rcomps(rcomp_t n_in)
Definition lci_binding_post.hpp:122
void sync_wait(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:328
matching_engine_t alloc_matching_engine()
Definition lci_binding_post.hpp:2720
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:1466
void alltoall(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:3493
status_t graph_test(comp_t comp_in)
Definition lci_binding_post.hpp:700
void register_packet_pool(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:2566
matching_engine_t get_default_matching_engine()
Definition lci_binding_post.hpp:3047
status_t cq_pop(comp_t comp_in)
Definition lci_binding_post.hpp:411
size_t net_poll_cq(size_t max_polls_in, net_status_t *statuses_in)
Definition lci_binding_post.hpp:1133
attr_rdv_protocol_t
Definition lci_binding_pre.hpp:59
void graph_start(comp_t comp_in)
Definition lci_binding_post.hpp:663
void free_matching_engine(matching_engine_t *matching_engine_in)
Definition lci_binding_post.hpp:2757
int get_rank_n()
Definition lci_binding_post.hpp:2241
void put_upacket(void *packet_in)
Definition lci_binding_post.hpp:2680
comp_t alloc_cq()
Definition lci_binding_post.hpp:374
void g_runtime_fina()
Definition lci_binding_post.hpp:2414
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:1347
rcomp_t register_rcomp(comp_t comp_in)
Definition lci_binding_post.hpp:162
error_t net_post_sends(int rank_in, void *buffer_in, size_t size_in)
Definition lci_binding_post.hpp:1234
void graph_add_edge(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in)
Definition lci_binding_post.hpp:586
void set_allocator(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:2840
allocator_base_t * get_allocator()
Definition lci_binding_post.hpp:2874
net_context_t get_default_net_context()
Definition lci_binding_post.hpp:2908
void free_device(device_t *device_in)
Definition lci_binding_post.hpp:896
void free_comp(comp_t *comp_in)
Definition lci_binding_post.hpp:45
packet_pool_t get_default_packet_pool()
Definition lci_binding_post.hpp:3013
void free_runtime(runtime_t *runtime_in)
Definition lci_binding_post.hpp:2330
std::vector< rbuffer_t > rbuffers_t
Definition lci.hpp:455
int get_rank_me()
Definition lci_binding_post.hpp:2209
comp_t alloc_handler(comp_handler_t handler_in)
Definition lci_binding_post.hpp:454
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:1530
runtime_t get_g_runtime()
Definition lci_binding_post.hpp:2446
void free_packet_pool(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:2526
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:3255
void deregister_packet_pool(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:2606
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:1867
void comp_signal(comp_t comp_in, status_t status_in)
Definition lci_binding_post.hpp:85
mr_t register_memory(void *address_in, size_t size_in)
Definition lci_binding_post.hpp:939
rmr_t get_rmr(mr_t mr_in)
Definition lci_binding_post.hpp:1013
endpoint_t alloc_endpoint()
Definition lci_binding_post.hpp:1053
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:2046
endpoint_t get_default_endpoint()
Definition lci_binding_post.hpp:2979
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:3389
graph_node_t graph_add_node(comp_t comp_in, graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:540
runtime_t alloc_runtime()
Definition lci_binding_post.hpp:2296
void allgather(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:3441
bool sync_test(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:282
attr_ibv_td_strategy_t
Definition lci_binding_pre.hpp:53
error_t progress()
Definition lci_binding_post.hpp:2177
attr_ibv_odp_strategy_t
Definition lci_binding_pre.hpp:40
device_t get_default_device()
Definition lci_binding_post.hpp:2942
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:3322
packet_pool_t alloc_packet_pool()
Definition lci_binding_post.hpp:2489
attr_ibv_prefetch_strategy_t
Definition lci_binding_pre.hpp:46
void barrier()
Definition lci_binding_post.hpp:3133
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:1591
attr_cq_type_t
Definition lci_binding_pre.hpp:35
comp_t alloc_graph()
Definition lci_binding_post.hpp:494
void g_runtime_init()
Definition lci_binding_post.hpp:2382
std::vector< buffer_t > buffers_t
Definition lci.hpp:454
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:1952
void * get_upacket()
Definition lci_binding_post.hpp:2643
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:1408
comp_t alloc_sync()
Definition lci_binding_post.hpp:242
void free_endpoint(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:1090
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:2137
The user-defined allocator type.
Definition lci.hpp:461
Wrapper class for error code.
Definition lci.hpp:160
The struct for network status.
Definition lci.hpp:292
Definition lci.hpp:79
The type of remote memory region.
Definition lci.hpp:330
The type of the completion desciptor for a posted communication.
Definition lci.hpp:604