LCI v2.0.0-dev
For Asynchronous Multithreaded Communication
Loading...
Searching...
No Matches
lci_binding_post.hpp
Go to the documentation of this file.
1
2// Copyright (c) 2025 The LCI Project Authors
3// SPDX-License-Identifier: NCSA
4
5// clang-format off
6// This file is generated by generate_binding.py
7#ifndef LCI_BINDING_POST_HPP_
8#define LCI_BINDING_POST_HPP_
9
10namespace lci {
11
12
30
36 public:
37 // args declaration
48
49 // constructor
51
52 // setter
53 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); }
54 inline alloc_runtime_x&& imm_nbits_tag(int imm_nbits_tag_in) { m_imm_nbits_tag = imm_nbits_tag_in; return std::move(*this); }
55 inline alloc_runtime_x&& imm_nbits_rcomp(int imm_nbits_rcomp_in) { m_imm_nbits_rcomp = imm_nbits_rcomp_in; return std::move(*this); }
56 inline alloc_runtime_x&& rdv_protocol(attr_rdv_protocol_t rdv_protocol_in) { m_rdv_protocol = rdv_protocol_in; return std::move(*this); }
57 inline alloc_runtime_x&& alloc_default_device(bool alloc_default_device_in) { m_alloc_default_device = alloc_default_device_in; return std::move(*this); }
58 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); }
59 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); }
60 inline alloc_runtime_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
61 inline alloc_runtime_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
62 inline alloc_runtime_x&& device_name(std::string device_name_in) { m_device_name = device_name_in; return std::move(*this); }
63
65 runtime_t call() const;
66 inline runtime_t operator()() const { return call(); }
67};
68
70 return alloc_runtime_x().call();
71}
72
73
82
88 public:
89 // args declaration
91
92 // constructor
93 free_runtime_x(runtime_t* runtime_in) : m_runtime(runtime_in) {}
94
95 // setter
96 inline free_runtime_x&& runtime(runtime_t* runtime_in) { m_runtime = runtime_in; return std::move(*this); }
97
99 void call() const;
100 inline void operator()() const { return call(); }
101};
102
103inline void free_runtime(runtime_t* runtime_in) {
104 return free_runtime_x(runtime_in).call();
105}
106
107
125
131 public:
132 // args declaration
143
144 // constructor
146
147 // setter
148 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); }
149 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); }
150 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); }
151 inline g_runtime_init_x&& rdv_protocol(attr_rdv_protocol_t rdv_protocol_in) { m_rdv_protocol = rdv_protocol_in; return std::move(*this); }
152 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); }
153 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); }
154 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); }
155 inline g_runtime_init_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
156 inline g_runtime_init_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
157 inline g_runtime_init_x&& device_name(std::string device_name_in) { m_device_name = device_name_in; return std::move(*this); }
158
160 runtime_t call() const;
161 inline runtime_t operator()() const { return call(); }
162};
163
165 return g_runtime_init_x().call();
166}
167
168
177
183 public:
184 // args declaration
185
186 // constructor
188
189 // setter
190
191 void call_impl() const;
192 void call() const;
193 inline void operator()() const { return call(); }
194};
195
196inline void g_runtime_fina() {
197 return g_runtime_fina_x().call();
198}
199
200
209
215 public:
216 // args declaration
217
218 // constructor
220
221 // setter
222
224 runtime_t call() const;
225 inline runtime_t operator()() const { return call(); }
226};
227
229 return get_g_runtime_x().call();
230}
231
232
245
251 public:
252 // args declaration
258
259 // constructor
261
262 // setter
263 inline alloc_packet_pool_x&& packet_size(size_t packet_size_in) { m_packet_size = packet_size_in; return std::move(*this); }
264 inline alloc_packet_pool_x&& npackets(size_t npackets_in) { m_npackets = npackets_in; return std::move(*this); }
265 inline alloc_packet_pool_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
266 inline alloc_packet_pool_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
267 inline alloc_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
268
269 packet_pool_t call_impl(size_t packet_size, size_t npackets, const char* name, void* user_context, runtime_t runtime) const;
270 packet_pool_t call() const;
271 inline packet_pool_t operator()() const { return call(); }
272};
273
277
278
288
294 public:
295 // args declaration
298
299 // constructor
300 free_packet_pool_x(packet_pool_t* packet_pool_in) : m_packet_pool(packet_pool_in) {}
301
302 // setter
303 inline free_packet_pool_x&& packet_pool(packet_pool_t* packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
304 inline free_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
305
307 void call() const;
308 inline void operator()() const { return call(); }
309};
310
311inline void free_packet_pool(packet_pool_t* packet_pool_in) {
312 return free_packet_pool_x(packet_pool_in).call();
313}
314
315
326
332 public:
333 // args declaration
337
338 // constructor
339 register_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in) : m_packet_pool(packet_pool_in), m_device(device_in) {}
340
341 // setter
342 inline register_packet_pool_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
343 inline register_packet_pool_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
344 inline register_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
345
347 void call() const;
348 inline void operator()() const { return call(); }
349};
350
351inline void register_packet_pool(packet_pool_t packet_pool_in, device_t device_in) {
352 return register_packet_pool_x(packet_pool_in, device_in).call();
353}
354
355
366
372 public:
373 // args declaration
377
378 // constructor
379 deregister_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in) : m_packet_pool(packet_pool_in), m_device(device_in) {}
380
381 // setter
382 inline deregister_packet_pool_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
383 inline deregister_packet_pool_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
384 inline deregister_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
385
387 void call() const;
388 inline void operator()() const { return call(); }
389};
390
391inline void deregister_packet_pool(packet_pool_t packet_pool_in, device_t device_in) {
392 return deregister_packet_pool_x(packet_pool_in, device_in).call();
393}
394
395
405
411 public:
412 // args declaration
415
416 // constructor
418
419 // setter
420 inline get_upacket_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
421 inline get_upacket_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
422
424 void* call() const;
425 inline void* operator()() const { return call(); }
426};
427
428inline void* get_upacket() {
429 return get_upacket_x().call();
430}
431
432
442
448 public:
449 // args declaration
450 void* m_packet;
452
453 // constructor
454 put_upacket_x(void* packet_in) : m_packet(packet_in) {}
455
456 // setter
457 inline put_upacket_x&& packet(void* packet_in) { m_packet = packet_in; return std::move(*this); }
458 inline put_upacket_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
459
460 void call_impl(void* packet, runtime_t runtime) const;
461 void call() const;
462 inline void operator()() const { return call(); }
463};
464
465inline void put_upacket(void* packet_in) {
466 return put_upacket_x(packet_in).call();
467}
468
469
481
487 public:
488 // args declaration
493
494 // constructor
496
497 // setter
498 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); }
499 inline alloc_matching_engine_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
500 inline alloc_matching_engine_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
501 inline alloc_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
502
504 matching_engine_t call() const;
505 inline matching_engine_t operator()() const { return call(); }
506};
507
511
512
522
528 public:
529 // args declaration
532
533 // constructor
534 free_matching_engine_x(matching_engine_t* matching_engine_in) : m_matching_engine(matching_engine_in) {}
535
536 // setter
537 inline free_matching_engine_x&& matching_engine(matching_engine_t* matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
538 inline free_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
539
541 void call() const;
542 inline void operator()() const { return call(); }
543};
544
545inline void free_matching_engine(matching_engine_t* matching_engine_in) {
546 return free_matching_engine_x(matching_engine_in).call();
547}
548
549
562
568 public:
569 // args declaration
575
576 // constructor
577 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) {}
578
579 // setter
580 inline matching_engine_insert_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
581 inline matching_engine_insert_x&& key(matching_entry_key_t key_in) { m_key = key_in; return std::move(*this); }
582 inline matching_engine_insert_x&& value(matching_entry_val_t value_in) { m_value = value_in; return std::move(*this); }
583 inline matching_engine_insert_x&& entry_type(matching_entry_type_t entry_type_in) { m_entry_type = entry_type_in; return std::move(*this); }
584 inline matching_engine_insert_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
585
588 inline matching_entry_val_t operator()() const { return call(); }
589};
590
592 return matching_engine_insert_x(matching_engine_in, key_in, value_in, entry_type_in).call();
593}
594
595
605
611 public:
612 // args declaration
615
616 // constructor
617 set_allocator_x(allocator_base_t* allocator_in) : m_allocator(allocator_in) {}
618
619 // setter
620 inline set_allocator_x&& allocator(allocator_base_t* allocator_in) { m_allocator = allocator_in; return std::move(*this); }
621 inline set_allocator_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
622
624 void call() const;
625 inline void operator()() const { return call(); }
626};
627
628inline void set_allocator(allocator_base_t* allocator_in) {
629 return set_allocator_x(allocator_in).call();
630}
631
632
641
647 public:
648 // args declaration
650
651 // constructor
653
654 // setter
655 inline get_allocator_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
656
658 allocator_base_t* call() const;
659 inline allocator_base_t* operator()() const { return call(); }
660};
661
663 return get_allocator_x().call();
664}
665
666
675
681 public:
682 // args declaration
684
685 // constructor
687
688 // setter
689 inline get_default_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
690
692 net_context_t call() const;
693 inline net_context_t operator()() const { return call(); }
694};
695
699
700
709
715 public:
716 // args declaration
718
719 // constructor
721
722 // setter
723 inline get_default_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
724
726 device_t call() const;
727 inline device_t operator()() const { return call(); }
728};
729
731 return get_default_device_x().call();
732}
733
734
744
750 public:
751 // args declaration
754
755 // constructor
757
758 // setter
759 inline get_default_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
760 inline get_default_endpoint_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
761
763 endpoint_t call() const;
764 inline endpoint_t operator()() const { return call(); }
765};
766
770
771
780
786 public:
787 // args declaration
789
790 // constructor
792
793 // setter
794 inline get_default_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
795
797 packet_pool_t call() const;
798 inline packet_pool_t operator()() const { return call(); }
799};
800
804
805
814
820 public:
821 // args declaration
823
824 // constructor
826
827 // setter
828 inline get_default_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
829
831 matching_engine_t call() const;
832 inline matching_engine_t operator()() const { return call(); }
833};
834
838
839
849
855 public:
856 // args declaration
859
860 // constructor
862
863 // setter
864 inline get_max_bcopy_size_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
865 inline get_max_bcopy_size_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
866
868 size_t call() const;
869 inline size_t operator()() const { return call(); }
870};
871
872inline size_t get_max_bcopy_size() {
873 return get_max_bcopy_size_x().call();
874}
875
876
897
903 public:
904 // args declaration
918
919 // constructor
921
922 // setter
923 inline alloc_net_context_x&& backend(attr_backend_t backend_in) { m_backend = backend_in; return std::move(*this); }
924 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); }
925 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); }
926 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); }
927 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); }
928 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); }
929 inline alloc_net_context_x&& device_name(std::string device_name_in) { m_device_name = device_name_in; return std::move(*this); }
930 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); }
931 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); }
932 inline alloc_net_context_x&& use_dmabuf(bool use_dmabuf_in) { m_use_dmabuf = use_dmabuf_in; return std::move(*this); }
933 inline alloc_net_context_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
934 inline alloc_net_context_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
935 inline alloc_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
936
938 net_context_t call() const;
939 inline net_context_t operator()() const { return call(); }
940};
941
945
946
956
962 public:
963 // args declaration
966
967 // constructor
968 free_net_context_x(net_context_t* net_context_in) : m_net_context(net_context_in) {}
969
970 // setter
971 inline free_net_context_x&& net_context(net_context_t* net_context_in) { m_net_context = net_context_in; return std::move(*this); }
972 inline free_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
973
975 void call() const;
976 inline void operator()() const { return call(); }
977};
978
979inline void free_net_context(net_context_t* net_context_in) {
980 return free_net_context_x(net_context_in).call();
981}
982
983
1005
1011 public:
1012 // args declaration
1027
1028 // constructor
1030
1031 // setter
1032 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); }
1033 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); }
1034 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); }
1035 inline alloc_device_x&& net_send_reserved_pct(double net_send_reserved_pct_in) { m_net_send_reserved_pct = net_send_reserved_pct_in; return std::move(*this); }
1036 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); }
1037 inline alloc_device_x&& alloc_default_endpoint(bool alloc_default_endpoint_in) { m_alloc_default_endpoint = alloc_default_endpoint_in; return std::move(*this); }
1038 inline alloc_device_x&& alloc_progress_endpoint(bool alloc_progress_endpoint_in) { m_alloc_progress_endpoint = alloc_progress_endpoint_in; return std::move(*this); }
1039 inline alloc_device_x&& use_reg_cache(bool use_reg_cache_in) { m_use_reg_cache = use_reg_cache_in; return std::move(*this); }
1040 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); }
1041 inline alloc_device_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
1042 inline alloc_device_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1043 inline alloc_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1044 inline alloc_device_x&& net_context(net_context_t net_context_in) { m_net_context = net_context_in; return std::move(*this); }
1045 inline alloc_device_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1046
1048 device_t call() const;
1049 inline device_t operator()() const { return call(); }
1050};
1051
1053 return alloc_device_x().call();
1054}
1055
1056
1066
1072 public:
1073 // args declaration
1076
1077 // constructor
1078 free_device_x(device_t* device_in) : m_device(device_in) {}
1079
1080 // setter
1081 inline free_device_x&& device(device_t* device_in) { m_device = device_in; return std::move(*this); }
1082 inline free_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1083
1085 void call() const;
1086 inline void operator()() const { return call(); }
1087};
1088
1089inline void free_device(device_t* device_in) {
1090 return free_device_x(device_in).call();
1091}
1092
1093
1105
1111 public:
1112 // args declaration
1114 size_t m_size;
1117
1118 // constructor
1119 register_memory_x(void* address_in, size_t size_in) : m_address(address_in), m_size(size_in) {}
1120
1121 // setter
1122 inline register_memory_x&& address(void* address_in) { m_address = address_in; return std::move(*this); }
1123 inline register_memory_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1124 inline register_memory_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1125 inline register_memory_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1126
1128 mr_t call() const;
1129 inline mr_t operator()() const { return call(); }
1130};
1131
1132inline mr_t register_memory(void* address_in, size_t size_in) {
1133 return register_memory_x(address_in, size_in).call();
1134}
1135
1136
1146
1152 public:
1153 // args declaration
1156
1157 // constructor
1158 deregister_memory_x(mr_t* mr_in) : m_mr(mr_in) {}
1159
1160 // setter
1161 inline deregister_memory_x&& mr(mr_t* mr_in) { m_mr = mr_in; return std::move(*this); }
1162 inline deregister_memory_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1163
1165 void call() const;
1166 inline void operator()() const { return call(); }
1167};
1168
1169inline void deregister_memory(mr_t* mr_in) {
1170 return deregister_memory_x(mr_in).call();
1171}
1172
1173
1183
1189 public:
1190 // args declaration
1193
1194 // constructor
1195 get_rmr_x(mr_t mr_in) : m_mr(mr_in) {}
1196
1197 // setter
1198 inline get_rmr_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1199 inline get_rmr_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1200
1202 rmr_t call() const;
1203 inline rmr_t operator()() const { return call(); }
1204};
1205
1206inline rmr_t get_rmr(mr_t mr_in) {
1207 return get_rmr_x(mr_in).call();
1208}
1209
1210
1222
1228 public:
1229 // args declaration
1234
1235 // constructor
1237
1238 // setter
1239 inline alloc_endpoint_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
1240 inline alloc_endpoint_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1241 inline alloc_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1242 inline alloc_endpoint_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1243
1245 endpoint_t call() const;
1246 inline endpoint_t operator()() const { return call(); }
1247};
1248
1250 return alloc_endpoint_x().call();
1251}
1252
1253
1263
1269 public:
1270 // args declaration
1273
1274 // constructor
1275 free_endpoint_x(endpoint_t* endpoint_in) : m_endpoint(endpoint_in) {}
1276
1277 // setter
1278 inline free_endpoint_x&& endpoint(endpoint_t* endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1279 inline free_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1280
1282 void call() const;
1283 inline void operator()() const { return call(); }
1284};
1285
1286inline void free_endpoint(endpoint_t* endpoint_in) {
1287 return free_endpoint_x(endpoint_in).call();
1288}
1289
1290
1302
1308 public:
1309 // args declaration
1314
1315 // constructor
1316 net_poll_cq_x(size_t max_polls_in, net_status_t* statuses_in) : m_max_polls(max_polls_in), m_statuses(statuses_in) {}
1317
1318 // setter
1319 inline net_poll_cq_x&& max_polls(size_t max_polls_in) { m_max_polls = max_polls_in; return std::move(*this); }
1320 inline net_poll_cq_x&& statuses(net_status_t* statuses_in) { m_statuses = statuses_in; return std::move(*this); }
1321 inline net_poll_cq_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1322 inline net_poll_cq_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1323
1325 size_t call() const;
1326 inline size_t operator()() const { return call(); }
1327};
1328
1329inline size_t net_poll_cq(size_t max_polls_in, net_status_t* statuses_in) {
1330 return net_poll_cq_x(max_polls_in, statuses_in).call();
1331}
1332
1333
1347
1353 public:
1354 // args declaration
1356 size_t m_size;
1361
1362 // constructor
1363 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) {}
1364
1365 // setter
1366 inline net_post_recv_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1367 inline net_post_recv_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1368 inline net_post_recv_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1369 inline net_post_recv_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1370 inline net_post_recv_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1371 inline net_post_recv_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1372
1374 error_t call() const;
1375 inline error_t operator()() const { return call(); }
1376};
1377
1378inline error_t net_post_recv(void* buffer_in, size_t size_in, mr_t mr_in) {
1379 return net_post_recv_x(buffer_in, size_in, mr_in).call();
1380}
1381
1382
1398
1404 public:
1405 // args declaration
1408 size_t m_size;
1414
1415 // constructor
1416 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) {}
1417
1418 // setter
1419 inline net_post_sends_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1420 inline net_post_sends_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1421 inline net_post_sends_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1422 inline net_post_sends_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1423 inline net_post_sends_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1424 inline net_post_sends_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1425 inline net_post_sends_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1426 inline net_post_sends_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1427
1429 error_t call() const;
1430 inline error_t operator()() const { return call(); }
1431};
1432
1433inline error_t net_post_sends(int rank_in, void* buffer_in, size_t size_in) {
1434 return net_post_sends_x(rank_in, buffer_in, size_in).call();
1435}
1436
1437
1454
1460 public:
1461 // args declaration
1464 size_t m_size;
1471
1472 // constructor
1473 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) {}
1474
1475 // setter
1476 inline net_post_send_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1477 inline net_post_send_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1478 inline net_post_send_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1479 inline net_post_send_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1480 inline net_post_send_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1481 inline net_post_send_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1482 inline net_post_send_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1483 inline net_post_send_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1484 inline net_post_send_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1485
1487 error_t call() const;
1488 inline error_t operator()() const { return call(); }
1489};
1490
1491inline error_t net_post_send(int rank_in, void* buffer_in, size_t size_in, mr_t mr_in) {
1492 return net_post_send_x(rank_in, buffer_in, size_in, mr_in).call();
1493}
1494
1495
1512
1518 public:
1519 // args declaration
1522 size_t m_size;
1523 uint64_t m_offset;
1529
1530 // constructor
1531 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) {}
1532
1533 // setter
1534 inline net_post_puts_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1535 inline net_post_puts_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1536 inline net_post_puts_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1537 inline net_post_puts_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1538 inline net_post_puts_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1539 inline net_post_puts_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1540 inline net_post_puts_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1541 inline net_post_puts_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1542 inline net_post_puts_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1543
1545 error_t call() const;
1546 inline error_t operator()() const { return call(); }
1547};
1548
1549inline error_t net_post_puts(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) {
1550 return net_post_puts_x(rank_in, buffer_in, size_in, offset_in, rmr_in).call();
1551}
1552
1553
1571
1577 public:
1578 // args declaration
1581 size_t m_size;
1583 uint64_t m_offset;
1589
1590 // constructor
1591 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) {}
1592
1593 // setter
1594 inline net_post_put_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1595 inline net_post_put_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1596 inline net_post_put_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1597 inline net_post_put_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1598 inline net_post_put_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1599 inline net_post_put_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1600 inline net_post_put_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1601 inline net_post_put_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1602 inline net_post_put_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1603 inline net_post_put_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1604
1606 error_t call() const;
1607 inline error_t operator()() const { return call(); }
1608};
1609
1610inline 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) {
1611 return net_post_put_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
1612}
1613
1614
1632
1638 public:
1639 // args declaration
1642 size_t m_size;
1643 uint64_t m_offset;
1650
1651 // constructor
1652 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) {}
1653
1654 // setter
1655 inline net_post_putImms_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1656 inline net_post_putImms_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1657 inline net_post_putImms_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1658 inline net_post_putImms_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1659 inline net_post_putImms_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1660 inline net_post_putImms_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1661 inline net_post_putImms_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1662 inline net_post_putImms_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1663 inline net_post_putImms_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1664 inline net_post_putImms_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1665
1667 error_t call() const;
1668 inline error_t operator()() const { return call(); }
1669};
1670
1671inline error_t net_post_putImms(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) {
1672 return net_post_putImms_x(rank_in, buffer_in, size_in, offset_in, rmr_in).call();
1673}
1674
1675
1694
1700 public:
1701 // args declaration
1704 size_t m_size;
1706 uint64_t m_offset;
1713
1714 // constructor
1715 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) {}
1716
1717 // setter
1718 inline net_post_putImm_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1719 inline net_post_putImm_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1720 inline net_post_putImm_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1721 inline net_post_putImm_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1722 inline net_post_putImm_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1723 inline net_post_putImm_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1724 inline net_post_putImm_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1725 inline net_post_putImm_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1726 inline net_post_putImm_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1727 inline net_post_putImm_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1728 inline net_post_putImm_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1729
1731 error_t call() const;
1732 inline error_t operator()() const { return call(); }
1733};
1734
1735inline 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) {
1736 return net_post_putImm_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
1737}
1738
1739
1757
1763 public:
1764 // args declaration
1767 size_t m_size;
1769 uint64_t m_offset;
1775
1776 // constructor
1777 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) {}
1778
1779 // setter
1780 inline net_post_get_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1781 inline net_post_get_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1782 inline net_post_get_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1783 inline net_post_get_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1784 inline net_post_get_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1785 inline net_post_get_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1786 inline net_post_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1787 inline net_post_get_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1788 inline net_post_get_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1789 inline net_post_get_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1790
1792 error_t call() const;
1793 inline error_t operator()() const { return call(); }
1794};
1795
1796inline 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) {
1797 return net_post_get_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
1798}
1799
1800
1814
1820 public:
1821 // args declaration
1828
1829 // constructor
1831
1832 // setter
1833 inline barrier_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1834 inline barrier_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1835 inline barrier_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1836 inline barrier_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1837 inline barrier_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1838 inline barrier_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1839
1841 void call() const;
1842 inline void operator()() const { return call(); }
1843};
1844
1845inline void barrier() {
1846 return barrier_x().call();
1847}
1848
1849
1867
1873 public:
1874 // args declaration
1876 size_t m_size;
1885
1886 // constructor
1887 broadcast_x(void* buffer_in, size_t size_in, int root_in) : m_buffer(buffer_in), m_size(size_in), m_root(root_in) {}
1888
1889 // setter
1890 inline broadcast_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1891 inline broadcast_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1892 inline broadcast_x&& root(int root_in) { m_root = root_in; return std::move(*this); }
1893 inline broadcast_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1894 inline broadcast_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1895 inline broadcast_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1896 inline broadcast_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1897 inline broadcast_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1898 inline broadcast_x&& algorithm(broadcast_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
1899 inline broadcast_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
1900
1902 void call() const;
1903 inline void operator()() const { return call(); }
1904};
1905
1906inline void broadcast(void* buffer_in, size_t size_in, int root_in) {
1907 return broadcast_x(buffer_in, size_in, root_in).call();
1908}
1909
1910
1928
1934 public:
1935 // args declaration
1936 const void* m_sendbuf;
1938 size_t m_count;
1946
1947 // constructor
1948 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) {}
1949
1950 // setter
1951 inline reduce_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
1952 inline reduce_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
1953 inline reduce_x&& count(size_t count_in) { m_count = count_in; return std::move(*this); }
1954 inline reduce_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
1955 inline reduce_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
1956 inline reduce_x&& root(int root_in) { m_root = root_in; return std::move(*this); }
1957 inline reduce_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1958 inline reduce_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1959 inline reduce_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1960 inline reduce_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1961
1963 void call() const;
1964 inline void operator()() const { return call(); }
1965};
1966
1967inline 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) {
1968 return reduce_x(sendbuf_in, recvbuf_in, count_in, item_size_in, op_in, root_in).call();
1969}
1970
1971
1991
1997 public:
1998 // args declaration
1999 const void* m_sendbuf;
2011
2012 // constructor
2013 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) {}
2014
2015 // setter
2016 inline reduce_scatter_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2017 inline reduce_scatter_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2018 inline reduce_scatter_x&& recvcount(size_t recvcount_in) { m_recvcount = recvcount_in; return std::move(*this); }
2019 inline reduce_scatter_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
2020 inline reduce_scatter_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
2021 inline reduce_scatter_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2022 inline reduce_scatter_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2023 inline reduce_scatter_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2024 inline reduce_scatter_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2025 inline reduce_scatter_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2026 inline reduce_scatter_x&& algorithm(reduce_scatter_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
2027 inline reduce_scatter_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
2028
2030 void call() const;
2031 inline void operator()() const { return call(); }
2032};
2033
2034inline void reduce_scatter(const void* sendbuf_in, void* recvbuf_in, size_t recvcount_in, size_t item_size_in, reduce_op_t op_in) {
2035 return reduce_scatter_x(sendbuf_in, recvbuf_in, recvcount_in, item_size_in, op_in).call();
2036}
2037
2038
2058
2064 public:
2065 // args declaration
2066 const void* m_sendbuf;
2068 size_t m_count;
2078
2079 // constructor
2080 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) {}
2081
2082 // setter
2083 inline allreduce_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2084 inline allreduce_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2085 inline allreduce_x&& count(size_t count_in) { m_count = count_in; return std::move(*this); }
2086 inline allreduce_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
2087 inline allreduce_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
2088 inline allreduce_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2089 inline allreduce_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2090 inline allreduce_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2091 inline allreduce_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2092 inline allreduce_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2093 inline allreduce_x&& algorithm(allreduce_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
2094 inline allreduce_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
2095
2097 void call() const;
2098 inline void operator()() const { return call(); }
2099};
2100
2101inline void allreduce(const void* sendbuf_in, void* recvbuf_in, size_t count_in, size_t item_size_in, reduce_op_t op_in) {
2102 return allreduce_x(sendbuf_in, recvbuf_in, count_in, item_size_in, op_in).call();
2103}
2104
2105
2120
2126 public:
2127 // args declaration
2128 const void* m_sendbuf;
2130 size_t m_size;
2135
2136 // constructor
2137 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) {}
2138
2139 // setter
2140 inline allgather_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2141 inline allgather_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2142 inline allgather_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2143 inline allgather_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2144 inline allgather_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2145 inline allgather_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2146 inline allgather_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2147
2149 void call() const;
2150 inline void operator()() const { return call(); }
2151};
2152
2153inline void allgather(const void* sendbuf_in, void* recvbuf_in, size_t size_in) {
2154 return allgather_x(sendbuf_in, recvbuf_in, size_in).call();
2155}
2156
2157
2173
2179 public:
2180 // args declaration
2181 const void* m_sendbuf;
2183 size_t m_size;
2189
2190 // constructor
2191 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) {}
2192
2193 // setter
2194 inline alltoall_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2195 inline alltoall_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2196 inline alltoall_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2197 inline alltoall_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2198 inline alltoall_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2199 inline alltoall_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2200 inline alltoall_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2201 inline alltoall_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
2202
2204 void call() const;
2205 inline void operator()() const { return call(); }
2206};
2207
2208inline void alltoall(const void* sendbuf_in, void* recvbuf_in, size_t size_in) {
2209 return alltoall_x(sendbuf_in, recvbuf_in, size_in).call();
2210}
2211
2212
2241
2247 public:
2248 // args declaration
2252 size_t m_size;
2270
2271 // constructor
2272 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) {}
2273
2274 // setter
2275 inline post_comm_x&& direction(direction_t direction_in) { m_direction = direction_in; return std::move(*this); }
2276 inline post_comm_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2277 inline post_comm_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
2278 inline post_comm_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2279 inline post_comm_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
2280 inline post_comm_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2281 inline post_comm_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2282 inline post_comm_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2283 inline post_comm_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2284 inline post_comm_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2285 inline post_comm_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
2286 inline post_comm_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
2287 inline post_comm_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
2288 inline post_comm_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
2289 inline post_comm_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
2290 inline post_comm_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
2291 inline post_comm_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2292 inline post_comm_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
2293 inline post_comm_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
2294 inline post_comm_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
2295 inline post_comm_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
2296
2298 status_t call() const;
2299 inline status_t operator()() const { return call(); }
2300};
2301
2302inline status_t post_comm(direction_t direction_in, int rank_in, void* local_buffer_in, size_t size_in, comp_t local_comp_in) {
2303 return post_comm_x(direction_in, rank_in, local_buffer_in, size_in, local_comp_in).call();
2304}
2305
2306
2330
2336 public:
2337 // args declaration
2340 size_t m_size;
2354
2355 // constructor
2356 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) {}
2357
2358 // setter
2359 inline post_am_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2360 inline post_am_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
2361 inline post_am_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2362 inline post_am_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
2363 inline post_am_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
2364 inline post_am_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2365 inline post_am_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2366 inline post_am_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2367 inline post_am_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2368 inline post_am_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
2369 inline post_am_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
2370 inline post_am_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
2371 inline post_am_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2372 inline post_am_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
2373 inline post_am_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
2374 inline post_am_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
2375
2377 status_t call() const;
2378 inline status_t operator()() const { return call(); }
2379};
2380
2381inline 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) {
2382 return post_am_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_comp_in).call();
2383}
2384
2385
2410
2416 public:
2417 // args declaration
2420 size_t m_size;
2435
2436 // constructor
2437 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) {}
2438
2439 // setter
2440 inline post_send_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2441 inline post_send_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
2442 inline post_send_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2443 inline post_send_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
2444 inline post_send_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
2445 inline post_send_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2446 inline post_send_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2447 inline post_send_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2448 inline post_send_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2449 inline post_send_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2450 inline post_send_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
2451 inline post_send_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
2452 inline post_send_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2453 inline post_send_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
2454 inline post_send_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
2455 inline post_send_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
2456 inline post_send_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
2457
2459 status_t call() const;
2460 inline status_t operator()() const { return call(); }
2461};
2462
2463inline status_t post_send(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) {
2464 return post_send_x(rank_in, local_buffer_in, size_in, tag_in, local_comp_in).call();
2465}
2466
2467
2492
2498 public:
2499 // args declaration
2502 size_t m_size;
2517
2518 // constructor
2519 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) {}
2520
2521 // setter
2522 inline post_recv_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2523 inline post_recv_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
2524 inline post_recv_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2525 inline post_recv_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
2526 inline post_recv_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
2527 inline post_recv_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2528 inline post_recv_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2529 inline post_recv_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2530 inline post_recv_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2531 inline post_recv_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2532 inline post_recv_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
2533 inline post_recv_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
2534 inline post_recv_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2535 inline post_recv_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
2536 inline post_recv_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
2537 inline post_recv_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
2538 inline post_recv_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
2539
2541 status_t call() const;
2542 inline status_t operator()() const { return call(); }
2543};
2544
2545inline status_t post_recv(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) {
2546 return post_recv_x(rank_in, local_buffer_in, size_in, tag_in, local_comp_in).call();
2547}
2548
2549
2575
2581 public:
2582 // args declaration
2585 size_t m_size;
2587 uintptr_t m_remote_disp;
2601
2602 // constructor
2603 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) {}
2604
2605 // setter
2606 inline post_put_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2607 inline post_put_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
2608 inline post_put_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2609 inline post_put_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
2610 inline post_put_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
2611 inline post_put_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
2612 inline post_put_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2613 inline post_put_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2614 inline post_put_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2615 inline post_put_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2616 inline post_put_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
2617 inline post_put_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
2618 inline post_put_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
2619 inline post_put_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
2620 inline post_put_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2621 inline post_put_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
2622 inline post_put_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
2623 inline post_put_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
2624
2626 status_t call() const;
2627 inline status_t operator()() const { return call(); }
2628};
2629
2630inline 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) {
2631 return post_put_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_disp_in, rmr_in).call();
2632}
2633
2634
2660
2666 public:
2667 // args declaration
2670 size_t m_size;
2672 uintptr_t m_remote_disp;
2686
2687 // constructor
2688 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) {}
2689
2690 // setter
2691 inline post_get_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2692 inline post_get_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
2693 inline post_get_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2694 inline post_get_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
2695 inline post_get_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
2696 inline post_get_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
2697 inline post_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2698 inline post_get_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2699 inline post_get_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2700 inline post_get_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2701 inline post_get_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
2702 inline post_get_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
2703 inline post_get_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
2704 inline post_get_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
2705 inline post_get_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2706 inline post_get_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
2707 inline post_get_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
2708 inline post_get_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
2709
2711 status_t call() const;
2712 inline status_t operator()() const { return call(); }
2713};
2714
2715inline 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) {
2716 return post_get_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_disp_in, rmr_in).call();
2717}
2718
2719
2730
2736 public:
2737 // args declaration
2741
2742 // constructor
2744
2745 // setter
2746 inline progress_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2747 inline progress_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2748 inline progress_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2749
2751 error_t call() const;
2752 inline error_t operator()() const { return call(); }
2753};
2754
2756 return progress_x().call();
2757}
2758
2759
2769
2775 public:
2776 // args declaration
2779
2780 // constructor
2782
2783 // setter
2784 inline test_drained_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2785 inline test_drained_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2786
2788 error_t call() const;
2789 inline error_t operator()() const { return call(); }
2790};
2791
2793 return test_drained_x().call();
2794}
2795
2796
2806
2812 public:
2813 // args declaration
2816
2817 // constructor
2819
2820 // setter
2821 inline wait_drained_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2822 inline wait_drained_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2823
2825 void call() const;
2826 inline void operator()() const { return call(); }
2827};
2828
2829inline void wait_drained() {
2830 return wait_drained_x().call();
2831}
2832
2833
2843
2849 public:
2850 // args declaration
2853
2854 // constructor
2855 free_comp_x(comp_t* comp_in) : m_comp(comp_in) {}
2856
2857 // setter
2858 inline free_comp_x&& comp(comp_t* comp_in) { m_comp = comp_in; return std::move(*this); }
2859 inline free_comp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2860
2862 void call() const;
2863 inline void operator()() const { return call(); }
2864};
2865
2866inline void free_comp(comp_t* comp_in) {
2867 return free_comp_x(comp_in).call();
2868}
2869
2870
2881
2887 public:
2888 // args declaration
2892
2893 // constructor
2894 comp_signal_x(comp_t comp_in, status_t status_in) : m_comp(comp_in), m_status(status_in) {}
2895
2896 // setter
2897 inline comp_signal_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2898 inline comp_signal_x&& status(status_t status_in) { m_status = status_in; return std::move(*this); }
2899 inline comp_signal_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2900
2902 void call() const;
2903 inline void operator()() const { return call(); }
2904};
2905
2906inline void comp_signal(comp_t comp_in, status_t status_in) {
2907 return comp_signal_x(comp_in, status_in).call();
2908}
2909
2910
2920
2926 public:
2927 // args declaration
2930
2931 // constructor
2933
2934 // setter
2935 inline reserve_rcomps_x&& n(rcomp_t n_in) { m_n = n_in; return std::move(*this); }
2936 inline reserve_rcomps_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2937
2939 rcomp_t call() const;
2940 inline rcomp_t operator()() const { return call(); }
2941};
2942
2944 return reserve_rcomps_x(n_in).call();
2945}
2946
2947
2958
2964 public:
2965 // args declaration
2969
2970 // constructor
2971 register_rcomp_x(comp_t comp_in) : m_comp(comp_in) {}
2972
2973 // setter
2974 inline register_rcomp_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2975 inline register_rcomp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2976 inline register_rcomp_x&& rcomp(rcomp_t rcomp_in) { m_rcomp = rcomp_in; return std::move(*this); }
2977
2979 rcomp_t call() const;
2980 inline rcomp_t operator()() const { return call(); }
2981};
2982
2984 return register_rcomp_x(comp_in).call();
2985}
2986
2987
2997
3003 public:
3004 // args declaration
3007
3008 // constructor
3009 deregister_rcomp_x(rcomp_t rcomp_in) : m_rcomp(rcomp_in) {}
3010
3011 // setter
3012 inline deregister_rcomp_x&& rcomp(rcomp_t rcomp_in) { m_rcomp = rcomp_in; return std::move(*this); }
3013 inline deregister_rcomp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3014
3016 void call() const;
3017 inline void operator()() const { return call(); }
3018};
3019
3020inline void deregister_rcomp(rcomp_t rcomp_in) {
3021 return deregister_rcomp_x(rcomp_in).call();
3022}
3023
3024
3037
3043 public:
3044 // args declaration
3050
3051 // constructor
3053
3054 // setter
3055 inline alloc_sync_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3056 inline alloc_sync_x&& threshold(int threshold_in) { m_threshold = threshold_in; return std::move(*this); }
3057 inline alloc_sync_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
3058 inline alloc_sync_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3059 inline alloc_sync_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3060
3062 comp_t call() const;
3063 inline comp_t operator()() const { return call(); }
3064};
3065
3067 return alloc_sync_x().call();
3068}
3069
3070
3081
3087 public:
3088 // args declaration
3092
3093 // constructor
3094 sync_test_x(comp_t comp_in, status_t* p_out_in) : m_comp(comp_in), m_p_out(p_out_in) {}
3095
3096 // setter
3097 inline sync_test_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3098 inline sync_test_x&& p_out(status_t* p_out_in) { m_p_out = p_out_in; return std::move(*this); }
3099 inline sync_test_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3100
3102 bool call() const;
3103 inline bool operator()() const { return call(); }
3104};
3105
3106inline bool sync_test(comp_t comp_in, status_t* p_out_in) {
3107 return sync_test_x(comp_in, p_out_in).call();
3108}
3109
3110
3123
3129 public:
3130 // args declaration
3136
3137 // constructor
3138 sync_wait_x(comp_t comp_in, status_t* p_out_in) : m_comp(comp_in), m_p_out(p_out_in) {}
3139
3140 // setter
3141 inline sync_wait_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3142 inline sync_wait_x&& p_out(status_t* p_out_in) { m_p_out = p_out_in; return std::move(*this); }
3143 inline sync_wait_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3144 inline sync_wait_x&& do_progress(bool do_progress_in) { m_do_progress = do_progress_in; return std::move(*this); }
3145 inline sync_wait_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3146
3148 void call() const;
3149 inline void operator()() const { return call(); }
3150};
3151
3152inline void sync_wait(comp_t comp_in, status_t* p_out_in) {
3153 return sync_wait_x(comp_in, p_out_in).call();
3154}
3155
3156
3167
3173 public:
3174 // args declaration
3178
3179 // constructor
3181
3182 // setter
3183 inline alloc_counter_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3184 inline alloc_counter_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3185 inline alloc_counter_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3186
3188 comp_t call() const;
3189 inline comp_t operator()() const { return call(); }
3190};
3191
3193 return alloc_counter_x().call();
3194}
3195
3196
3206
3212 public:
3213 // args declaration
3216
3217 // constructor
3218 counter_get_x(comp_t comp_in) : m_comp(comp_in) {}
3219
3220 // setter
3221 inline counter_get_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3222 inline counter_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3223
3225 int64_t call() const;
3226 inline int64_t operator()() const { return call(); }
3227};
3228
3229inline int64_t counter_get(comp_t comp_in) {
3230 return counter_get_x(comp_in).call();
3231}
3232
3233
3244
3250 public:
3251 // args declaration
3253 int64_t m_value;
3255
3256 // constructor
3257 counter_set_x(comp_t comp_in, int64_t value_in) : m_comp(comp_in), m_value(value_in) {}
3258
3259 // setter
3260 inline counter_set_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3261 inline counter_set_x&& value(int64_t value_in) { m_value = value_in; return std::move(*this); }
3262 inline counter_set_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3263
3265 void call() const;
3266 inline void operator()() const { return call(); }
3267};
3268
3269inline void counter_set(comp_t comp_in, int64_t value_in) {
3270 return counter_set_x(comp_in, value_in).call();
3271}
3272
3273
3287
3293 public:
3294 // args declaration
3301
3302 // constructor
3304
3305 // setter
3306 inline alloc_cq_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3307 inline alloc_cq_x&& default_length(int default_length_in) { m_default_length = default_length_in; return std::move(*this); }
3308 inline alloc_cq_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
3309 inline alloc_cq_x&& cq_type(attr_cq_type_t cq_type_in) { m_cq_type = cq_type_in; return std::move(*this); }
3310 inline alloc_cq_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3311 inline alloc_cq_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3312
3314 comp_t call() const;
3315 inline comp_t operator()() const { return call(); }
3316};
3317
3319 return alloc_cq_x().call();
3320}
3321
3322
3332
3338 public:
3339 // args declaration
3342
3343 // constructor
3344 cq_pop_x(comp_t comp_in) : m_comp(comp_in) {}
3345
3346 // setter
3347 inline cq_pop_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3348 inline cq_pop_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3349
3351 status_t call() const;
3352 inline status_t operator()() const { return call(); }
3353};
3354
3355inline status_t cq_pop(comp_t comp_in) {
3356 return cq_pop_x(comp_in).call();
3357}
3358
3359
3372
3378 public:
3379 // args declaration
3385
3386 // constructor
3387 alloc_handler_x(comp_handler_t handler_in) : m_handler(handler_in) {}
3388
3389 // setter
3390 inline alloc_handler_x&& handler(comp_handler_t handler_in) { m_handler = handler_in; return std::move(*this); }
3391 inline alloc_handler_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3392 inline alloc_handler_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
3393 inline alloc_handler_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3394 inline alloc_handler_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3395
3397 comp_t call() const;
3398 inline comp_t operator()() const { return call(); }
3399};
3400
3402 return alloc_handler_x(handler_in).call();
3403}
3404
3405
3417
3423 public:
3424 // args declaration
3429
3430 // constructor
3432
3433 // setter
3434 inline alloc_graph_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3435 inline alloc_graph_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3436 inline alloc_graph_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3437 inline alloc_graph_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3438
3440 comp_t call() const;
3441 inline comp_t operator()() const { return call(); }
3442};
3443
3445 return alloc_graph_x().call();
3446}
3447
3448
3461
3467 public:
3468 // args declaration
3474
3475 // constructor
3476 graph_add_node_x(comp_t comp_in, graph_node_run_cb_t fn_in) : m_comp(comp_in), m_fn(fn_in) {}
3477
3478 // setter
3479 inline graph_add_node_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3480 inline graph_add_node_x&& fn(graph_node_run_cb_t fn_in) { m_fn = fn_in; return std::move(*this); }
3481 inline graph_add_node_x&& value(void* value_in) { m_value = value_in; return std::move(*this); }
3482 inline graph_add_node_x&& free_cb(graph_node_free_cb_t free_cb_in) { m_free_cb = free_cb_in; return std::move(*this); }
3483 inline graph_add_node_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3484
3486 graph_node_t call() const;
3487 inline graph_node_t operator()() const { return call(); }
3488};
3489
3491 return graph_add_node_x(comp_in, fn_in).call();
3492}
3493
3494
3507
3513 public:
3514 // args declaration
3520
3521 // constructor
3522 graph_add_edge_x(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in) : m_comp(comp_in), m_src(src_in), m_dst(dst_in) {}
3523
3524 // setter
3525 inline graph_add_edge_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3526 inline graph_add_edge_x&& src(graph_node_t src_in) { m_src = src_in; return std::move(*this); }
3527 inline graph_add_edge_x&& dst(graph_node_t dst_in) { m_dst = dst_in; return std::move(*this); }
3528 inline graph_add_edge_x&& fn(graph_edge_run_cb_t fn_in) { m_fn = fn_in; return std::move(*this); }
3529 inline graph_add_edge_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3530
3532 void call() const;
3533 inline void operator()() const { return call(); }
3534};
3535
3536inline void graph_add_edge(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in) {
3537 return graph_add_edge_x(comp_in, src_in, dst_in).call();
3538}
3539
3540
3551
3557 public:
3558 // args declaration
3562
3563 // constructor
3565
3566 // setter
3567 inline graph_node_mark_complete_x&& node(graph_node_t node_in) { m_node = node_in; return std::move(*this); }
3568 inline graph_node_mark_complete_x&& status(status_t status_in) { m_status = status_in; return std::move(*this); }
3569 inline graph_node_mark_complete_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3570
3572 void call() const;
3573 inline void operator()() const { return call(); }
3574};
3575
3577 return graph_node_mark_complete_x(node_in).call();
3578}
3579
3580
3590
3596 public:
3597 // args declaration
3600
3601 // constructor
3602 graph_start_x(comp_t comp_in) : m_comp(comp_in) {}
3603
3604 // setter
3605 inline graph_start_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3606 inline graph_start_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3607
3609 void call() const;
3610 inline void operator()() const { return call(); }
3611};
3612
3613inline void graph_start(comp_t comp_in) {
3614 return graph_start_x(comp_in).call();
3615}
3616
3617
3627
3633 public:
3634 // args declaration
3637
3638 // constructor
3639 graph_test_x(comp_t comp_in) : m_comp(comp_in) {}
3640
3641 // setter
3642 inline graph_test_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3643 inline graph_test_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3644
3646 status_t call() const;
3647 inline status_t operator()() const { return call(); }
3648};
3649
3650inline status_t graph_test(comp_t comp_in) {
3651 return graph_test_x(comp_in).call();
3652}
3653
3654
3655} // namespace lci
3656
3657#endif // LCI_BINDING_POST_HPP_
The actual implementation for allgather.
Definition lci_binding_post.hpp:2125
allgather_x && size(size_t size_in)
Definition lci_binding_post.hpp:2142
allgather_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2141
void * m_recvbuf
Definition lci_binding_post.hpp:2129
size_t m_size
Definition lci_binding_post.hpp:2130
void call() const
Definition binding.cpp:660
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2131
const void * m_sendbuf
Definition lci_binding_post.hpp:2128
allgather_x && device(device_t device_in)
Definition lci_binding_post.hpp:2144
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2134
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2133
allgather_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2143
allgather_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2145
allgather_x(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:2137
allgather_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2146
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:2132
void operator()() const
Definition lci_binding_post.hpp:2150
allgather_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2140
The actual implementation for alloc_counter.
Definition lci_binding_post.hpp:3172
alloc_counter_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3183
alloc_counter_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3185
option_t< const char * > m_name
Definition lci_binding_post.hpp:3176
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3175
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3177
comp_t operator()() const
Definition lci_binding_post.hpp:3189
comp_t call_impl(runtime_t runtime, const char *name, void *user_context) const
comp_t call() const
Definition binding.cpp:899
alloc_counter_x && name(const char *name_in)
Definition lci_binding_post.hpp:3184
alloc_counter_x()
Definition lci_binding_post.hpp:3180
The actual implementation for alloc_cq.
Definition lci_binding_post.hpp:3292
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3295
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:3297
alloc_cq_x && cq_type(attr_cq_type_t cq_type_in)
Definition lci_binding_post.hpp:3309
alloc_cq_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:3308
comp_t operator()() const
Definition lci_binding_post.hpp:3315
option_t< int > m_default_length
Definition lci_binding_post.hpp:3296
option_t< attr_cq_type_t > m_cq_type
Definition lci_binding_post.hpp:3298
alloc_cq_x && default_length(int default_length_in)
Definition lci_binding_post.hpp:3307
comp_t call_impl(runtime_t runtime, int default_length, bool zero_copy_am, attr_cq_type_t cq_type, const char *name, void *user_context) const
alloc_cq_x && name(const char *name_in)
Definition lci_binding_post.hpp:3310
alloc_cq_x()
Definition lci_binding_post.hpp:3303
comp_t call() const
Definition binding.cpp:919
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3300
alloc_cq_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3311
option_t< const char * > m_name
Definition lci_binding_post.hpp:3299
alloc_cq_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3306
The actual implementation for alloc_device.
Definition lci_binding_post.hpp:1010
alloc_device_x && alloc_default_endpoint(bool alloc_default_endpoint_in)
Definition lci_binding_post.hpp:1037
alloc_device_x()
Definition lci_binding_post.hpp:1029
option_t< bool > m_use_reg_cache
Definition lci_binding_post.hpp:1020
option_t< const char * > m_name
Definition lci_binding_post.hpp:1022
option_t< bool > m_alloc_progress_endpoint
Definition lci_binding_post.hpp:1019
option_t< net_context_t > m_net_context
Definition lci_binding_post.hpp:1025
alloc_device_x && net_max_recvs(size_t net_max_recvs_in)
Definition lci_binding_post.hpp:1033
option_t< attr_ibv_td_strategy_t > m_ibv_td_strategy
Definition lci_binding_post.hpp:1021
alloc_device_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1042
option_t< size_t > m_net_max_recvs
Definition lci_binding_post.hpp:1014
alloc_device_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1045
alloc_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1043
alloc_device_x && use_reg_cache(bool use_reg_cache_in)
Definition lci_binding_post.hpp:1039
alloc_device_x && name(const char *name_in)
Definition lci_binding_post.hpp:1041
option_t< double > m_net_send_reserved_pct
Definition lci_binding_post.hpp:1016
alloc_device_x && ofi_lock_mode(uint64_t ofi_lock_mode_in)
Definition lci_binding_post.hpp:1036
option_t< uint64_t > m_ofi_lock_mode
Definition lci_binding_post.hpp:1017
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1023
option_t< size_t > m_net_max_sends
Definition lci_binding_post.hpp:1013
alloc_device_x && net_send_reserved_pct(double net_send_reserved_pct_in)
Definition lci_binding_post.hpp:1035
device_t call_impl(size_t net_max_sends, size_t net_max_recvs, size_t net_max_cqes, double net_send_reserved_pct, uint64_t ofi_lock_mode, bool alloc_default_endpoint, bool alloc_progress_endpoint, bool use_reg_cache, attr_ibv_td_strategy_t ibv_td_strategy, const char *name, void *user_context, runtime_t runtime, net_context_t net_context, packet_pool_t packet_pool) const
alloc_device_x && alloc_progress_endpoint(bool alloc_progress_endpoint_in)
Definition lci_binding_post.hpp:1038
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:1026
option_t< size_t > m_net_max_cqes
Definition lci_binding_post.hpp:1015
alloc_device_x && net_context(net_context_t net_context_in)
Definition lci_binding_post.hpp:1044
option_t< bool > m_alloc_default_endpoint
Definition lci_binding_post.hpp:1018
device_t operator()() const
Definition lci_binding_post.hpp:1049
device_t call() const
Definition binding.cpp:410
alloc_device_x && net_max_cqes(size_t net_max_cqes_in)
Definition lci_binding_post.hpp:1034
alloc_device_x && ibv_td_strategy(attr_ibv_td_strategy_t ibv_td_strategy_in)
Definition lci_binding_post.hpp:1040
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1024
alloc_device_x && net_max_sends(size_t net_max_sends_in)
Definition lci_binding_post.hpp:1032
The actual implementation for alloc_endpoint.
Definition lci_binding_post.hpp:1227
endpoint_t call() const
Definition binding.cpp:463
alloc_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1241
endpoint_t call_impl(const char *name, void *user_context, runtime_t runtime, device_t device) const
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1231
alloc_endpoint_x()
Definition lci_binding_post.hpp:1236
option_t< device_t > m_device
Definition lci_binding_post.hpp:1233
option_t< const char * > m_name
Definition lci_binding_post.hpp:1230
alloc_endpoint_x && device(device_t device_in)
Definition lci_binding_post.hpp:1242
endpoint_t operator()() const
Definition lci_binding_post.hpp:1246
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1232
alloc_endpoint_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1240
alloc_endpoint_x && name(const char *name_in)
Definition lci_binding_post.hpp:1239
The actual implementation for alloc_graph.
Definition lci_binding_post.hpp:3422
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3428
alloc_graph_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3437
comp_t call() const
Definition binding.cpp:944
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3427
alloc_graph_x && name(const char *name_in)
Definition lci_binding_post.hpp:3435
alloc_graph_x()
Definition lci_binding_post.hpp:3431
comp_t call_impl(comp_t comp, const char *name, void *user_context, runtime_t runtime) const
alloc_graph_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3436
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:3425
alloc_graph_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3434
comp_t operator()() const
Definition lci_binding_post.hpp:3441
option_t< const char * > m_name
Definition lci_binding_post.hpp:3426
The actual implementation for alloc_handler.
Definition lci_binding_post.hpp:3377
comp_t call_impl(comp_handler_t handler, runtime_t runtime, bool zero_copy_am, const char *name, void *user_context) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3381
option_t< const char * > m_name
Definition lci_binding_post.hpp:3383
alloc_handler_x && handler(comp_handler_t handler_in)
Definition lci_binding_post.hpp:3390
alloc_handler_x(comp_handler_t handler_in)
Definition lci_binding_post.hpp:3387
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3384
comp_t call() const
Definition binding.cpp:935
comp_t operator()() const
Definition lci_binding_post.hpp:3398
alloc_handler_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:3392
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:3382
alloc_handler_x && name(const char *name_in)
Definition lci_binding_post.hpp:3393
alloc_handler_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3394
alloc_handler_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3391
comp_handler_t m_handler
Definition lci_binding_post.hpp:3380
The actual implementation for alloc_matching_engine.
Definition lci_binding_post.hpp:486
matching_engine_t operator()() const
Definition lci_binding_post.hpp:505
matching_engine_t call() const
Definition binding.cpp:292
alloc_matching_engine_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:500
option_t< attr_matching_engine_type_t > m_matching_engine_type
Definition lci_binding_post.hpp:489
option_t< void * > m_user_context
Definition lci_binding_post.hpp:491
alloc_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:501
alloc_matching_engine_x && name(const char *name_in)
Definition lci_binding_post.hpp:499
option_t< const char * > m_name
Definition lci_binding_post.hpp:490
matching_engine_t call_impl(attr_matching_engine_type_t matching_engine_type, const char *name, void *user_context, runtime_t runtime) const
alloc_matching_engine_x && matching_engine_type(attr_matching_engine_type_t matching_engine_type_in)
Definition lci_binding_post.hpp:498
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:492
alloc_matching_engine_x()
Definition lci_binding_post.hpp:495
The actual implementation for alloc_net_context.
Definition lci_binding_post.hpp:902
alloc_net_context_x && ofi_provider_name(std::string ofi_provider_name_in)
Definition lci_binding_post.hpp:924
option_t< int > m_ibv_gid_idx
Definition lci_binding_post.hpp:909
alloc_net_context_x && device_name(std::string device_name_in)
Definition lci_binding_post.hpp:929
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:917
alloc_net_context_x && ibv_prefetch_strategy(attr_ibv_prefetch_strategy_t ibv_prefetch_strategy_in)
Definition lci_binding_post.hpp:931
alloc_net_context_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:935
option_t< attr_ibv_odp_strategy_t > m_ibv_odp_strategy
Definition lci_binding_post.hpp:912
alloc_net_context_x && ibv_gid_idx(int ibv_gid_idx_in)
Definition lci_binding_post.hpp:927
alloc_net_context_x()
Definition lci_binding_post.hpp:920
net_context_t call_impl(attr_backend_t backend, std::string ofi_provider_name, size_t max_msg_size, size_t max_inject_size, int ibv_gid_idx, bool ibv_force_gid_auto_select, std::string device_name, attr_ibv_odp_strategy_t ibv_odp_strategy, attr_ibv_prefetch_strategy_t ibv_prefetch_strategy, bool use_dmabuf, const char *name, void *user_context, runtime_t runtime) const
alloc_net_context_x && max_inject_size(size_t max_inject_size_in)
Definition lci_binding_post.hpp:926
option_t< void * > m_user_context
Definition lci_binding_post.hpp:916
alloc_net_context_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:934
option_t< bool > m_use_dmabuf
Definition lci_binding_post.hpp:914
alloc_net_context_x && backend(attr_backend_t backend_in)
Definition lci_binding_post.hpp:923
option_t< std::string > m_device_name
Definition lci_binding_post.hpp:911
option_t< const char * > m_name
Definition lci_binding_post.hpp:915
alloc_net_context_x && ibv_force_gid_auto_select(bool ibv_force_gid_auto_select_in)
Definition lci_binding_post.hpp:928
alloc_net_context_x && name(const char *name_in)
Definition lci_binding_post.hpp:933
alloc_net_context_x && ibv_odp_strategy(attr_ibv_odp_strategy_t ibv_odp_strategy_in)
Definition lci_binding_post.hpp:930
alloc_net_context_x && use_dmabuf(bool use_dmabuf_in)
Definition lci_binding_post.hpp:932
option_t< attr_backend_t > m_backend
Definition lci_binding_post.hpp:905
alloc_net_context_x && max_msg_size(size_t max_msg_size_in)
Definition lci_binding_post.hpp:925
net_context_t call() const
Definition binding.cpp:373
option_t< std::string > m_ofi_provider_name
Definition lci_binding_post.hpp:906
option_t< bool > m_ibv_force_gid_auto_select
Definition lci_binding_post.hpp:910
option_t< size_t > m_max_inject_size
Definition lci_binding_post.hpp:908
net_context_t operator()() const
Definition lci_binding_post.hpp:939
option_t< size_t > m_max_msg_size
Definition lci_binding_post.hpp:907
option_t< attr_ibv_prefetch_strategy_t > m_ibv_prefetch_strategy
Definition lci_binding_post.hpp:913
The actual implementation for alloc_packet_pool.
Definition lci_binding_post.hpp:250
packet_pool_t call() const
Definition binding.cpp:246
alloc_packet_pool_x()
Definition lci_binding_post.hpp:260
packet_pool_t call_impl(size_t packet_size, size_t npackets, const char *name, void *user_context, runtime_t runtime) const
alloc_packet_pool_x && npackets(size_t npackets_in)
Definition lci_binding_post.hpp:264
alloc_packet_pool_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:266
alloc_packet_pool_x && packet_size(size_t packet_size_in)
Definition lci_binding_post.hpp:263
alloc_packet_pool_x && name(const char *name_in)
Definition lci_binding_post.hpp:265
option_t< size_t > m_packet_size
Definition lci_binding_post.hpp:253
alloc_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:267
option_t< const char * > m_name
Definition lci_binding_post.hpp:255
packet_pool_t operator()() const
Definition lci_binding_post.hpp:271
option_t< void * > m_user_context
Definition lci_binding_post.hpp:256
option_t< size_t > m_npackets
Definition lci_binding_post.hpp:254
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:257
The actual implementation for alloc_runtime.
Definition lci_binding_post.hpp:35
alloc_runtime_x && imm_nbits_tag(int imm_nbits_tag_in)
Definition lci_binding_post.hpp:54
alloc_runtime_x && imm_nbits_rcomp(int imm_nbits_rcomp_in)
Definition lci_binding_post.hpp:55
option_t< bool > m_alloc_default_packet_pool
Definition lci_binding_post.hpp:43
alloc_runtime_x && name(const char *name_in)
Definition lci_binding_post.hpp:60
runtime_t operator()() const
Definition lci_binding_post.hpp:66
option_t< bool > m_alloc_default_matching_engine
Definition lci_binding_post.hpp:44
runtime_t call() const
Definition binding.cpp:195
alloc_runtime_x && alloc_default_packet_pool(bool alloc_default_packet_pool_in)
Definition lci_binding_post.hpp:58
alloc_runtime_x && rdv_protocol(attr_rdv_protocol_t rdv_protocol_in)
Definition lci_binding_post.hpp:56
alloc_runtime_x()
Definition lci_binding_post.hpp:50
option_t< std::string > m_device_name
Definition lci_binding_post.hpp:47
alloc_runtime_x && alloc_default_matching_engine(bool alloc_default_matching_engine_in)
Definition lci_binding_post.hpp:59
alloc_runtime_x && alloc_default_device(bool alloc_default_device_in)
Definition lci_binding_post.hpp:57
alloc_runtime_x && packet_return_threshold(size_t packet_return_threshold_in)
Definition lci_binding_post.hpp:53
option_t< const char * > m_name
Definition lci_binding_post.hpp:45
alloc_runtime_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:61
alloc_runtime_x && device_name(std::string device_name_in)
Definition lci_binding_post.hpp:62
option_t< bool > m_alloc_default_device
Definition lci_binding_post.hpp:42
runtime_t call_impl(size_t packet_return_threshold, int imm_nbits_tag, int imm_nbits_rcomp, attr_rdv_protocol_t rdv_protocol, bool alloc_default_device, bool alloc_default_packet_pool, bool alloc_default_matching_engine, const char *name, void *user_context, std::string device_name) const
option_t< attr_rdv_protocol_t > m_rdv_protocol
Definition lci_binding_post.hpp:41
option_t< void * > m_user_context
Definition lci_binding_post.hpp:46
option_t< int > m_imm_nbits_rcomp
Definition lci_binding_post.hpp:40
option_t< size_t > m_packet_return_threshold
Definition lci_binding_post.hpp:38
option_t< int > m_imm_nbits_tag
Definition lci_binding_post.hpp:39
The actual implementation for alloc_sync.
Definition lci_binding_post.hpp:3042
comp_t operator()() const
Definition lci_binding_post.hpp:3063
option_t< int > m_threshold
Definition lci_binding_post.hpp:3046
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3049
alloc_sync_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3059
alloc_sync_x && threshold(int threshold_in)
Definition lci_binding_post.hpp:3056
alloc_sync_x && name(const char *name_in)
Definition lci_binding_post.hpp:3058
comp_t call_impl(runtime_t runtime, int threshold, bool zero_copy_am, const char *name, void *user_context) const
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:3047
alloc_sync_x()
Definition lci_binding_post.hpp:3052
option_t< const char * > m_name
Definition lci_binding_post.hpp:3048
alloc_sync_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:3057
alloc_sync_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3055
comp_t call() const
Definition binding.cpp:874
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3045
The actual implementation for allreduce.
Definition lci_binding_post.hpp:2063
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:2086
void operator()() const
Definition lci_binding_post.hpp:2098
const void * m_sendbuf
Definition lci_binding_post.hpp:2066
option_t< device_t > m_device
Definition lci_binding_post.hpp:2072
allreduce_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2083
reduce_op_t m_op
Definition lci_binding_post.hpp:2070
void * m_recvbuf
Definition lci_binding_post.hpp:2067
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:2077
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:2080
allreduce_x && device(device_t device_in)
Definition lci_binding_post.hpp:2089
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2074
size_t m_count
Definition lci_binding_post.hpp:2068
allreduce_x && count(size_t count_in)
Definition lci_binding_post.hpp:2085
allreduce_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2084
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2073
allreduce_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2090
option_t< allreduce_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:2076
allreduce_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:2087
allreduce_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2088
allreduce_x && algorithm(allreduce_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:2093
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2071
allreduce_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:2094
size_t m_item_size
Definition lci_binding_post.hpp:2069
allreduce_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2092
void call() const
Definition binding.cpp:644
allreduce_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2091
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2075
The actual implementation for alltoall.
Definition lci_binding_post.hpp:2178
const void * m_sendbuf
Definition lci_binding_post.hpp:2181
void call() const
Definition binding.cpp:671
alltoall_x && device(device_t device_in)
Definition lci_binding_post.hpp:2198
alltoall_x && size(size_t size_in)
Definition lci_binding_post.hpp:2196
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2187
alltoall_x(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:2191
void * m_recvbuf
Definition lci_binding_post.hpp:2182
alltoall_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2195
option_t< device_t > m_device
Definition lci_binding_post.hpp:2185
alltoall_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2200
alltoall_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2199
alltoall_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2197
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2184
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2186
alltoall_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2194
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:2188
alltoall_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:2201
size_t m_size
Definition lci_binding_post.hpp:2183
void operator()() const
Definition lci_binding_post.hpp:2205
void call_impl(const void *sendbuf, void *recvbuf, size_t size, runtime_t runtime, device_t device, endpoint_t endpoint, matching_engine_t matching_engine, comp_semantic_t comp_semantic) const
The actual implementation for barrier.
Definition lci_binding_post.hpp:1819
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:1827
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1825
barrier_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1836
barrier_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1838
barrier_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:1837
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:1823
void call() const
Definition binding.cpp:590
barrier_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1835
barrier_x()
Definition lci_binding_post.hpp:1830
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1824
barrier_x && device(device_t device_in)
Definition lci_binding_post.hpp:1834
void operator()() const
Definition lci_binding_post.hpp:1842
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:1826
barrier_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1833
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1822
The actual implementation for broadcast.
Definition lci_binding_post.hpp:1872
broadcast_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1896
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1880
void call() const
Definition binding.cpp:600
void operator()() const
Definition lci_binding_post.hpp:1903
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1881
int m_root
Definition lci_binding_post.hpp:1877
broadcast_x && root(int root_in)
Definition lci_binding_post.hpp:1892
broadcast_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1897
broadcast_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1893
broadcast_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:1899
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1878
broadcast_x && size(size_t size_in)
Definition lci_binding_post.hpp:1891
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:1884
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:1882
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:1887
broadcast_x && device(device_t device_in)
Definition lci_binding_post.hpp:1894
option_t< broadcast_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:1883
void * m_buffer
Definition lci_binding_post.hpp:1875
option_t< device_t > m_device
Definition lci_binding_post.hpp:1879
broadcast_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1890
broadcast_x && algorithm(broadcast_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:1898
broadcast_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1895
size_t m_size
Definition lci_binding_post.hpp:1876
The actual implementation for comp_signal.
Definition lci_binding_post.hpp:2886
comp_signal_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2899
comp_signal_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2897
status_t m_status
Definition lci_binding_post.hpp:2890
comp_t m_comp
Definition lci_binding_post.hpp:2889
void call() const
Definition binding.cpp:848
comp_signal_x(comp_t comp_in, status_t status_in)
Definition lci_binding_post.hpp:2894
void call_impl(comp_t comp, status_t status, runtime_t runtime) const
void operator()() const
Definition lci_binding_post.hpp:2903
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2891
comp_signal_x && status(status_t status_in)
Definition lci_binding_post.hpp:2898
The actual implementation for RESOURCE comp.
Definition lci_binding_pre.hpp:516
The actual implementation for counter_get.
Definition lci_binding_post.hpp:3211
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3215
int64_t call_impl(comp_t comp, runtime_t runtime) const
int64_t operator()() const
Definition lci_binding_post.hpp:3226
counter_get_x(comp_t comp_in)
Definition lci_binding_post.hpp:3218
int64_t call() const
Definition binding.cpp:906
counter_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3222
comp_t m_comp
Definition lci_binding_post.hpp:3214
counter_get_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3221
The actual implementation for counter_set.
Definition lci_binding_post.hpp:3249
counter_set_x(comp_t comp_in, int64_t value_in)
Definition lci_binding_post.hpp:3257
int64_t m_value
Definition lci_binding_post.hpp:3253
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3254
comp_t m_comp
Definition lci_binding_post.hpp:3252
void call_impl(comp_t comp, int64_t value, runtime_t runtime) const
counter_set_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3262
counter_set_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3260
void operator()() const
Definition lci_binding_post.hpp:3266
counter_set_x && value(int64_t value_in)
Definition lci_binding_post.hpp:3261
void call() const
Definition binding.cpp:912
The actual implementation for cq_pop.
Definition lci_binding_post.hpp:3337
status_t operator()() const
Definition lci_binding_post.hpp:3352
comp_t m_comp
Definition lci_binding_post.hpp:3340
status_t call_impl(comp_t comp, runtime_t runtime) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3341
cq_pop_x(comp_t comp_in)
Definition lci_binding_post.hpp:3344
cq_pop_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3347
cq_pop_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3348
status_t call() const
Definition binding.cpp:929
The actual implementation for deregister_memory.
Definition lci_binding_post.hpp:1151
void operator()() const
Definition lci_binding_post.hpp:1166
void call() const
Definition binding.cpp:446
mr_t * m_mr
Definition lci_binding_post.hpp:1154
deregister_memory_x && mr(mr_t *mr_in)
Definition lci_binding_post.hpp:1161
deregister_memory_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1162
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1155
void call_impl(mr_t *mr, runtime_t runtime) const
deregister_memory_x(mr_t *mr_in)
Definition lci_binding_post.hpp:1158
The actual implementation for deregister_packet_pool.
Definition lci_binding_post.hpp:371
deregister_packet_pool_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:382
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:374
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:376
void operator()() const
Definition lci_binding_post.hpp:388
void call() const
Definition binding.cpp:268
deregister_packet_pool_x && device(device_t device_in)
Definition lci_binding_post.hpp:383
device_t m_device
Definition lci_binding_post.hpp:375
deregister_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:384
deregister_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:379
The actual implementation for deregister_rcomp.
Definition lci_binding_post.hpp:3002
deregister_rcomp_x(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:3009
void operator()() const
Definition lci_binding_post.hpp:3017
rcomp_t m_rcomp
Definition lci_binding_post.hpp:3005
void call_impl(rcomp_t rcomp, runtime_t runtime) const
void call() const
Definition binding.cpp:868
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3006
deregister_rcomp_x && rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:3012
deregister_rcomp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3013
The actual implementation for RESOURCE device.
Definition lci_binding_pre.hpp:400
The actual implementation for RESOURCE endpoint.
Definition lci_binding_pre.hpp:477
The actual implementation for free_comp.
Definition lci_binding_post.hpp:2848
free_comp_x(comp_t *comp_in)
Definition lci_binding_post.hpp:2855
free_comp_x && comp(comp_t *comp_in)
Definition lci_binding_post.hpp:2858
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2852
comp_t * m_comp
Definition lci_binding_post.hpp:2851
void call() const
Definition binding.cpp:842
free_comp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2859
void operator()() const
Definition lci_binding_post.hpp:2863
void call_impl(comp_t *comp, runtime_t runtime) const
The actual implementation for free_device.
Definition lci_binding_post.hpp:1071
void call_impl(device_t *device, runtime_t runtime) const
free_device_x && device(device_t *device_in)
Definition lci_binding_post.hpp:1081
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1075
device_t * m_device
Definition lci_binding_post.hpp:1074
void operator()() const
Definition lci_binding_post.hpp:1086
void call() const
Definition binding.cpp:428
free_device_x(device_t *device_in)
Definition lci_binding_post.hpp:1078
free_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1082
The actual implementation for free_endpoint.
Definition lci_binding_post.hpp:1268
void operator()() const
Definition lci_binding_post.hpp:1283
endpoint_t * m_endpoint
Definition lci_binding_post.hpp:1271
free_endpoint_x && endpoint(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:1278
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1272
free_endpoint_x(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:1275
void call_impl(endpoint_t *endpoint, runtime_t runtime) const
void call() const
Definition binding.cpp:471
free_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1279
The actual implementation for free_matching_engine.
Definition lci_binding_post.hpp:527
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:537
free_matching_engine_x(matching_engine_t *matching_engine_in)
Definition lci_binding_post.hpp:534
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:531
matching_engine_t * m_matching_engine
Definition lci_binding_post.hpp:530
void call() const
Definition binding.cpp:300
free_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:538
void operator()() const
Definition lci_binding_post.hpp:542
The actual implementation for free_net_context.
Definition lci_binding_post.hpp:961
void operator()() const
Definition lci_binding_post.hpp:976
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:972
free_net_context_x(net_context_t *net_context_in)
Definition lci_binding_post.hpp:968
void call() const
Definition binding.cpp:390
net_context_t * m_net_context
Definition lci_binding_post.hpp:964
free_net_context_x && net_context(net_context_t *net_context_in)
Definition lci_binding_post.hpp:971
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:965
The actual implementation for free_packet_pool.
Definition lci_binding_post.hpp:293
void operator()() const
Definition lci_binding_post.hpp:308
free_packet_pool_x(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:300
void call() const
Definition binding.cpp:255
void call_impl(packet_pool_t *packet_pool, runtime_t runtime) const
packet_pool_t * m_packet_pool
Definition lci_binding_post.hpp:296
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:297
free_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:304
free_packet_pool_x && packet_pool(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:303
The actual implementation for free_runtime.
Definition lci_binding_post.hpp:87
void call_impl(runtime_t *runtime) const
free_runtime_x(runtime_t *runtime_in)
Definition lci_binding_post.hpp:93
runtime_t * m_runtime
Definition lci_binding_post.hpp:90
free_runtime_x && runtime(runtime_t *runtime_in)
Definition lci_binding_post.hpp:96
void operator()() const
Definition lci_binding_post.hpp:100
void call() const
Definition binding.cpp:210
The actual implementation for g_runtime_fina.
Definition lci_binding_post.hpp:182
g_runtime_fina_x()
Definition lci_binding_post.hpp:187
void call() const
Definition binding.cpp:231
void operator()() const
Definition lci_binding_post.hpp:193
void call_impl() const
The actual implementation for g_runtime_init.
Definition lci_binding_post.hpp:130
g_runtime_init_x && imm_nbits_rcomp(int imm_nbits_rcomp_in)
Definition lci_binding_post.hpp:150
g_runtime_init_x && alloc_default_packet_pool(bool alloc_default_packet_pool_in)
Definition lci_binding_post.hpp:153
g_runtime_init_x && imm_nbits_tag(int imm_nbits_tag_in)
Definition lci_binding_post.hpp:149
runtime_t call_impl(size_t packet_return_threshold, int imm_nbits_tag, int imm_nbits_rcomp, attr_rdv_protocol_t rdv_protocol, bool alloc_default_device, bool alloc_default_packet_pool, bool alloc_default_matching_engine, const char *name, void *user_context, std::string device_name) const
option_t< int > m_imm_nbits_tag
Definition lci_binding_post.hpp:134
option_t< int > m_imm_nbits_rcomp
Definition lci_binding_post.hpp:135
option_t< size_t > m_packet_return_threshold
Definition lci_binding_post.hpp:133
g_runtime_init_x && name(const char *name_in)
Definition lci_binding_post.hpp:155
option_t< attr_rdv_protocol_t > m_rdv_protocol
Definition lci_binding_post.hpp:136
option_t< void * > m_user_context
Definition lci_binding_post.hpp:141
option_t< std::string > m_device_name
Definition lci_binding_post.hpp:142
option_t< bool > m_alloc_default_device
Definition lci_binding_post.hpp:137
g_runtime_init_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:156
g_runtime_init_x && alloc_default_matching_engine(bool alloc_default_matching_engine_in)
Definition lci_binding_post.hpp:154
runtime_t call() const
Definition binding.cpp:216
option_t< bool > m_alloc_default_matching_engine
Definition lci_binding_post.hpp:139
g_runtime_init_x && device_name(std::string device_name_in)
Definition lci_binding_post.hpp:157
option_t< bool > m_alloc_default_packet_pool
Definition lci_binding_post.hpp:138
g_runtime_init_x()
Definition lci_binding_post.hpp:145
g_runtime_init_x && alloc_default_device(bool alloc_default_device_in)
Definition lci_binding_post.hpp:152
option_t< const char * > m_name
Definition lci_binding_post.hpp:140
g_runtime_init_x && packet_return_threshold(size_t packet_return_threshold_in)
Definition lci_binding_post.hpp:148
runtime_t operator()() const
Definition lci_binding_post.hpp:161
g_runtime_init_x && rdv_protocol(attr_rdv_protocol_t rdv_protocol_in)
Definition lci_binding_post.hpp:151
The actual implementation for get_allocator.
Definition lci_binding_post.hpp:646
allocator_base_t * call_impl(runtime_t runtime) const
allocator_base_t * call() const
Definition binding.cpp:321
allocator_base_t * operator()() const
Definition lci_binding_post.hpp:659
get_allocator_x()
Definition lci_binding_post.hpp:652
get_allocator_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:655
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:649
The actual implementation for get_default_device.
Definition lci_binding_post.hpp:714
device_t call_impl(runtime_t runtime) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:717
get_default_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:723
device_t call() const
Definition binding.cpp:331
get_default_device_x()
Definition lci_binding_post.hpp:720
device_t operator()() const
Definition lci_binding_post.hpp:727
The actual implementation for get_default_endpoint.
Definition lci_binding_post.hpp:749
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:760
endpoint_t operator()() const
Definition lci_binding_post.hpp:764
endpoint_t call() const
Definition binding.cpp:336
get_default_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:759
get_default_endpoint_x()
Definition lci_binding_post.hpp:756
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:752
option_t< device_t > m_device
Definition lci_binding_post.hpp:753
The actual implementation for get_default_matching_engine.
Definition lci_binding_post.hpp:819
get_default_matching_engine_x()
Definition lci_binding_post.hpp:825
matching_engine_t call() const
Definition binding.cpp:347
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:822
matching_engine_t call_impl(runtime_t runtime) const
matching_engine_t operator()() const
Definition lci_binding_post.hpp:832
get_default_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:828
The actual implementation for get_default_net_context.
Definition lci_binding_post.hpp:680
net_context_t operator()() const
Definition lci_binding_post.hpp:693
get_default_net_context_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:689
get_default_net_context_x()
Definition lci_binding_post.hpp:686
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:683
net_context_t call_impl(runtime_t runtime) const
net_context_t call() const
Definition binding.cpp:326
The actual implementation for get_default_packet_pool.
Definition lci_binding_post.hpp:785
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:788
packet_pool_t operator()() const
Definition lci_binding_post.hpp:798
packet_pool_t call_impl(runtime_t runtime) const
packet_pool_t call() const
Definition binding.cpp:342
get_default_packet_pool_x()
Definition lci_binding_post.hpp:791
get_default_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:794
The actual implementation for get_g_runtime.
Definition lci_binding_post.hpp:214
runtime_t operator()() const
Definition lci_binding_post.hpp:225
get_g_runtime_x()
Definition lci_binding_post.hpp:219
runtime_t call() const
Definition binding.cpp:236
runtime_t call_impl() const
The actual implementation for get_max_bcopy_size.
Definition lci_binding_post.hpp:854
size_t operator()() const
Definition lci_binding_post.hpp:869
get_max_bcopy_size_x()
Definition lci_binding_post.hpp:861
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:857
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:858
get_max_bcopy_size_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:865
size_t call() const
Definition binding.cpp:352
get_max_bcopy_size_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:864
The actual implementation for get_rmr.
Definition lci_binding_post.hpp:1188
get_rmr_x(mr_t mr_in)
Definition lci_binding_post.hpp:1195
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1192
get_rmr_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1198
rmr_t operator()() const
Definition lci_binding_post.hpp:1203
mr_t m_mr
Definition lci_binding_post.hpp:1191
rmr_t call() const
Definition binding.cpp:452
get_rmr_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1199
rmr_t call_impl(mr_t mr, runtime_t runtime) const
The actual implementation for get_upacket.
Definition lci_binding_post.hpp:410
get_upacket_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:421
void * call() const
Definition binding.cpp:275
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:413
get_upacket_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:420
void * operator()() const
Definition lci_binding_post.hpp:425
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:414
get_upacket_x()
Definition lci_binding_post.hpp:417
The actual implementation for graph_add_edge.
Definition lci_binding_post.hpp:3512
void call_impl(comp_t comp, graph_node_t src, graph_node_t dst, graph_edge_run_cb_t fn, runtime_t runtime) const
comp_t m_comp
Definition lci_binding_post.hpp:3515
void call() const
Definition binding.cpp:961
graph_add_edge_x(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in)
Definition lci_binding_post.hpp:3522
graph_add_edge_x && dst(graph_node_t dst_in)
Definition lci_binding_post.hpp:3527
graph_add_edge_x && fn(graph_edge_run_cb_t fn_in)
Definition lci_binding_post.hpp:3528
void operator()() const
Definition lci_binding_post.hpp:3533
option_t< graph_edge_run_cb_t > m_fn
Definition lci_binding_post.hpp:3518
graph_add_edge_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3525
graph_node_t m_dst
Definition lci_binding_post.hpp:3517
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3519
graph_add_edge_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3529
graph_add_edge_x && src(graph_node_t src_in)
Definition lci_binding_post.hpp:3526
graph_node_t m_src
Definition lci_binding_post.hpp:3516
The actual implementation for graph_add_node.
Definition lci_binding_post.hpp:3466
option_t< void * > m_value
Definition lci_binding_post.hpp:3471
graph_node_t operator()() const
Definition lci_binding_post.hpp:3487
graph_add_node_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3483
graph_node_t call() const
Definition binding.cpp:952
graph_add_node_x(comp_t comp_in, graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:3476
graph_node_t call_impl(comp_t comp, graph_node_run_cb_t fn, void *value, graph_node_free_cb_t free_cb, runtime_t runtime) const
graph_add_node_x && fn(graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:3480
graph_node_run_cb_t m_fn
Definition lci_binding_post.hpp:3470
comp_t m_comp
Definition lci_binding_post.hpp:3469
graph_add_node_x && free_cb(graph_node_free_cb_t free_cb_in)
Definition lci_binding_post.hpp:3482
graph_add_node_x && value(void *value_in)
Definition lci_binding_post.hpp:3481
option_t< graph_node_free_cb_t > m_free_cb
Definition lci_binding_post.hpp:3472
graph_add_node_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3479
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3473
The actual implementation for graph_node_mark_complete.
Definition lci_binding_post.hpp:3556
void operator()() const
Definition lci_binding_post.hpp:3573
void call() const
Definition binding.cpp:970
graph_node_t m_node
Definition lci_binding_post.hpp:3559
graph_node_mark_complete_x(graph_node_t node_in)
Definition lci_binding_post.hpp:3564
option_t< status_t > m_status
Definition lci_binding_post.hpp:3560
void call_impl(graph_node_t node, status_t status, runtime_t runtime) const
graph_node_mark_complete_x && node(graph_node_t node_in)
Definition lci_binding_post.hpp:3567
graph_node_mark_complete_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3569
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3561
graph_node_mark_complete_x && status(status_t status_in)
Definition lci_binding_post.hpp:3568
The actual implementation for graph_start.
Definition lci_binding_post.hpp:3595
graph_start_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3606
comp_t m_comp
Definition lci_binding_post.hpp:3598
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3599
graph_start_x(comp_t comp_in)
Definition lci_binding_post.hpp:3602
void call_impl(comp_t comp, runtime_t runtime) const
void call() const
Definition binding.cpp:977
void operator()() const
Definition lci_binding_post.hpp:3610
graph_start_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3605
The actual implementation for graph_test.
Definition lci_binding_post.hpp:3632
comp_t m_comp
Definition lci_binding_post.hpp:3635
status_t call_impl(comp_t comp, runtime_t runtime) const
graph_test_x(comp_t comp_in)
Definition lci_binding_post.hpp:3639
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3636
graph_test_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3643
status_t operator()() const
Definition lci_binding_post.hpp:3647
status_t call() const
Definition binding.cpp:983
graph_test_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3642
The actual implementation for matching_engine_insert.
Definition lci_binding_post.hpp:567
matching_engine_insert_x && value(matching_entry_val_t value_in)
Definition lci_binding_post.hpp:582
matching_engine_insert_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:584
matching_entry_val_t operator()() const
Definition lci_binding_post.hpp:588
matching_entry_val_t call() const
Definition binding.cpp:306
matching_engine_insert_x && entry_type(matching_entry_type_t entry_type_in)
Definition lci_binding_post.hpp:583
matching_engine_insert_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:580
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:574
matching_entry_type_t m_entry_type
Definition lci_binding_post.hpp:573
matching_engine_t m_matching_engine
Definition lci_binding_post.hpp:570
matching_entry_key_t m_key
Definition lci_binding_post.hpp:571
matching_engine_insert_x && key(matching_entry_key_t key_in)
Definition lci_binding_post.hpp:581
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:577
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:572
The actual implementation for RESOURCE matching_engine.
Definition lci_binding_pre.hpp:301
The actual implementation for RESOURCE mr.
Definition lci_binding_pre.hpp:443
The actual implementation for RESOURCE net_context.
Definition lci_binding_pre.hpp:346
The actual implementation for net_poll_cq.
Definition lci_binding_post.hpp:1307
net_poll_cq_x && device(device_t device_in)
Definition lci_binding_post.hpp:1322
net_poll_cq_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1321
option_t< device_t > m_device
Definition lci_binding_post.hpp:1313
net_poll_cq_x(size_t max_polls_in, net_status_t *statuses_in)
Definition lci_binding_post.hpp:1316
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1312
net_poll_cq_x && statuses(net_status_t *statuses_in)
Definition lci_binding_post.hpp:1320
size_t operator()() const
Definition lci_binding_post.hpp:1326
size_t call() const
Definition binding.cpp:477
net_poll_cq_x && max_polls(size_t max_polls_in)
Definition lci_binding_post.hpp:1319
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:1310
net_status_t * m_statuses
Definition lci_binding_post.hpp:1311
The actual implementation for net_post_get.
Definition lci_binding_post.hpp:1762
net_post_get_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1781
net_post_get_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1788
net_post_get_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1785
option_t< device_t > m_device
Definition lci_binding_post.hpp:1772
int m_rank
Definition lci_binding_post.hpp:1765
net_post_get_x && device(device_t device_in)
Definition lci_binding_post.hpp:1787
net_post_get_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1783
error_t operator()() const
Definition lci_binding_post.hpp:1793
net_post_get_x && size(size_t size_in)
Definition lci_binding_post.hpp:1782
error_t call() const
Definition binding.cpp:576
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1771
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1773
mr_t m_mr
Definition lci_binding_post.hpp:1768
void * m_buffer
Definition lci_binding_post.hpp:1766
net_post_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1786
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:1769
net_post_get_x && rank(int rank_in)
Definition lci_binding_post.hpp:1780
rmr_t m_rmr
Definition lci_binding_post.hpp:1770
size_t m_size
Definition lci_binding_post.hpp:1767
net_post_get_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1789
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1774
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:1777
net_post_get_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1784
The actual implementation for net_post_putImm.
Definition lci_binding_post.hpp:1699
net_post_putImm_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1726
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:1715
rmr_t m_rmr
Definition lci_binding_post.hpp:1707
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1708
net_post_putImm_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1721
net_post_putImm_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1723
error_t call() const
Definition binding.cpp:561
net_post_putImm_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1727
int m_rank
Definition lci_binding_post.hpp:1702
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1711
net_post_putImm_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1724
option_t< device_t > m_device
Definition lci_binding_post.hpp:1709
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1710
mr_t m_mr
Definition lci_binding_post.hpp:1705
net_post_putImm_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1719
void * m_buffer
Definition lci_binding_post.hpp:1703
net_post_putImm_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1728
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1712
error_t operator()() const
Definition lci_binding_post.hpp:1732
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:1704
net_post_putImm_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1722
uint64_t m_offset
Definition lci_binding_post.hpp:1706
net_post_putImm_x && size(size_t size_in)
Definition lci_binding_post.hpp:1720
net_post_putImm_x && rank(int rank_in)
Definition lci_binding_post.hpp:1718
net_post_putImm_x && device(device_t device_in)
Definition lci_binding_post.hpp:1725
The actual implementation for net_post_putImms.
Definition lci_binding_post.hpp:1637
net_post_putImms_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1656
net_post_putImms_x && device(device_t device_in)
Definition lci_binding_post.hpp:1661
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1647
option_t< device_t > m_device
Definition lci_binding_post.hpp:1646
net_post_putImms_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1659
error_t call_impl(int rank, void *buffer, size_t size, uint64_t offset, rmr_t rmr, runtime_t runtime, device_t device, endpoint_t endpoint, net_imm_data_t imm_data, void *user_context) const
net_post_putImms_x && rank(int rank_in)
Definition lci_binding_post.hpp:1655
uint64_t m_offset
Definition lci_binding_post.hpp:1643
void * m_buffer
Definition lci_binding_post.hpp:1641
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1648
int m_rank
Definition lci_binding_post.hpp:1640
error_t operator()() const
Definition lci_binding_post.hpp:1668
net_post_putImms_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1658
error_t call() const
Definition binding.cpp:547
rmr_t m_rmr
Definition lci_binding_post.hpp:1644
net_post_putImms_x && size(size_t size_in)
Definition lci_binding_post.hpp:1657
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1649
net_post_putImms_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1662
net_post_putImms_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1663
size_t m_size
Definition lci_binding_post.hpp:1642
net_post_putImms_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1660
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1645
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:1652
net_post_putImms_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1664
The actual implementation for net_post_put.
Definition lci_binding_post.hpp:1576
rmr_t m_rmr
Definition lci_binding_post.hpp:1584
net_post_put_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1595
mr_t m_mr
Definition lci_binding_post.hpp:1582
net_post_put_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1599
int m_rank
Definition lci_binding_post.hpp:1579
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:1591
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:1585
error_t call() const
Definition binding.cpp:533
net_post_put_x && rank(int rank_in)
Definition lci_binding_post.hpp:1594
option_t< device_t > m_device
Definition lci_binding_post.hpp:1586
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1587
net_post_put_x && device(device_t device_in)
Definition lci_binding_post.hpp:1601
net_post_put_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1603
net_post_put_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1602
net_post_put_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1597
net_post_put_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1598
net_post_put_x && size(size_t size_in)
Definition lci_binding_post.hpp:1596
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1588
size_t m_size
Definition lci_binding_post.hpp:1581
net_post_put_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1600
error_t operator()() const
Definition lci_binding_post.hpp:1607
uint64_t m_offset
Definition lci_binding_post.hpp:1583
void * m_buffer
Definition lci_binding_post.hpp:1580
The actual implementation for net_post_puts.
Definition lci_binding_post.hpp:1517
net_post_puts_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1538
net_post_puts_x && rank(int rank_in)
Definition lci_binding_post.hpp:1534
error_t operator()() const
Definition lci_binding_post.hpp:1546
net_post_puts_x && size(size_t size_in)
Definition lci_binding_post.hpp:1536
option_t< device_t > m_device
Definition lci_binding_post.hpp:1526
void * m_buffer
Definition lci_binding_post.hpp:1521
net_post_puts_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1537
net_post_puts_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1539
net_post_puts_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1535
net_post_puts_x && device(device_t device_in)
Definition lci_binding_post.hpp:1540
error_t call() const
Definition binding.cpp:520
int m_rank
Definition lci_binding_post.hpp:1520
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:1531
rmr_t m_rmr
Definition lci_binding_post.hpp:1524
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1525
size_t m_size
Definition lci_binding_post.hpp:1522
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1528
error_t call_impl(int rank, void *buffer, size_t size, uint64_t offset, rmr_t rmr, runtime_t runtime, device_t device, endpoint_t endpoint, void *user_context) const
net_post_puts_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1542
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1527
net_post_puts_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1541
uint64_t m_offset
Definition lci_binding_post.hpp:1523
The actual implementation for net_post_recv.
Definition lci_binding_post.hpp:1352
net_post_recv_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1369
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1360
net_post_recv_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1366
error_t call() const
Definition binding.cpp:485
net_post_recv_x(void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1363
net_post_recv_x && size(size_t size_in)
Definition lci_binding_post.hpp:1367
net_post_recv_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1368
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1358
option_t< device_t > m_device
Definition lci_binding_post.hpp:1359
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:1357
size_t m_size
Definition lci_binding_post.hpp:1356
error_t operator()() const
Definition lci_binding_post.hpp:1375
net_post_recv_x && device(device_t device_in)
Definition lci_binding_post.hpp:1370
void * m_buffer
Definition lci_binding_post.hpp:1355
net_post_recv_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1371
The actual implementation for net_post_send.
Definition lci_binding_post.hpp:1459
net_post_send_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1483
net_post_send_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1480
net_post_send_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1477
void * m_buffer
Definition lci_binding_post.hpp:1463
int m_rank
Definition lci_binding_post.hpp:1462
mr_t m_mr
Definition lci_binding_post.hpp:1465
size_t m_size
Definition lci_binding_post.hpp:1464
net_post_send_x && size(size_t size_in)
Definition lci_binding_post.hpp:1478
error_t call() const
Definition binding.cpp:507
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1466
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1469
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1468
net_post_send_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1479
net_post_send_x && device(device_t device_in)
Definition lci_binding_post.hpp:1481
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1470
net_post_send_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1482
net_post_send_x(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1473
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:1467
error_t operator()() const
Definition lci_binding_post.hpp:1488
net_post_send_x && rank(int rank_in)
Definition lci_binding_post.hpp:1476
net_post_send_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1484
The actual implementation for net_post_sends.
Definition lci_binding_post.hpp:1403
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1413
net_post_sends_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1425
net_post_sends_x && size(size_t size_in)
Definition lci_binding_post.hpp:1421
error_t call() const
Definition binding.cpp:495
option_t< device_t > m_device
Definition lci_binding_post.hpp:1410
net_post_sends_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1424
error_t call_impl(int rank, void *buffer, size_t size, runtime_t runtime, device_t device, endpoint_t endpoint, net_imm_data_t imm_data, void *user_context) const
int m_rank
Definition lci_binding_post.hpp:1406
net_post_sends_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1422
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1412
net_post_sends_x(int rank_in, void *buffer_in, size_t size_in)
Definition lci_binding_post.hpp:1416
net_post_sends_x && rank(int rank_in)
Definition lci_binding_post.hpp:1419
void * m_buffer
Definition lci_binding_post.hpp:1407
net_post_sends_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1426
error_t operator()() const
Definition lci_binding_post.hpp:1430
net_post_sends_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1420
size_t m_size
Definition lci_binding_post.hpp:1408
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1411
net_post_sends_x && device(device_t device_in)
Definition lci_binding_post.hpp:1423
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1409
The actual implementation for RESOURCE packet_pool.
Definition lci_binding_pre.hpp:265
The actual implementation for post_am.
Definition lci_binding_post.hpp:2335
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:2348
option_t< device_t > m_device
Definition lci_binding_post.hpp:2344
post_am_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:2367
rcomp_t m_remote_comp
Definition lci_binding_post.hpp:2342
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:2349
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:2352
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:2356
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2345
post_am_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:2372
post_am_x && size(size_t size_in)
Definition lci_binding_post.hpp:2361
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:2353
post_am_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2364
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2343
post_am_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:2370
int m_rank
Definition lci_binding_post.hpp:2338
post_am_x && rank(int rank_in)
Definition lci_binding_post.hpp:2359
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:2346
post_am_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:2368
status_t call() const
Definition binding.cpp:708
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:2347
status_t call_impl(int rank, void *local_buffer, size_t size, comp_t local_comp, rcomp_t remote_comp, runtime_t runtime, device_t device, endpoint_t endpoint, packet_pool_t packet_pool, comp_semantic_t comp_semantic, mr_t mr, tag_t tag, void *user_context, bool allow_done, bool allow_posted, bool allow_retry) const
post_am_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:2369
comp_t m_local_comp
Definition lci_binding_post.hpp:2341
post_am_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:2374
post_am_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:2373
post_am_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:2360
size_t m_size
Definition lci_binding_post.hpp:2340
post_am_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2366
post_am_x && device(device_t device_in)
Definition lci_binding_post.hpp:2365
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:2351
post_am_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2371
void * m_local_buffer
Definition lci_binding_post.hpp:2339
post_am_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:2362
status_t operator()() const
Definition lci_binding_post.hpp:2378
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2350
post_am_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:2363
The actual implementation for post_comm.
Definition lci_binding_post.hpp:2246
status_t call() const
Definition binding.cpp:683
void * m_local_buffer
Definition lci_binding_post.hpp:2251
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2265
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:2266
post_comm_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:2290
option_t< device_t > m_device
Definition lci_binding_post.hpp:2255
post_comm_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2284
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:2269
status_t call_impl(direction_t direction, int rank, void *local_buffer, size_t size, comp_t local_comp, runtime_t runtime, device_t device, endpoint_t endpoint, packet_pool_t packet_pool, matching_engine_t matching_engine, comp_semantic_t comp_semantic, mr_t mr, uintptr_t remote_disp, rmr_t rmr, tag_t tag, rcomp_t remote_comp, void *user_context, matching_policy_t matching_policy, bool allow_done, bool allow_posted, bool allow_retry) const
int m_rank
Definition lci_binding_post.hpp:2250
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2258
post_comm_x && rank(int rank_in)
Definition lci_binding_post.hpp:2276
post_comm_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2280
post_comm_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:2277
size_t m_size
Definition lci_binding_post.hpp:2252
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2254
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:2260
comp_t m_local_comp
Definition lci_binding_post.hpp:2253
status_t operator()() const
Definition lci_binding_post.hpp:2299
option_t< rmr_t > m_rmr
Definition lci_binding_post.hpp:2262
post_comm_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2291
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:2268
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:2272
option_t< uintptr_t > m_remote_disp
Definition lci_binding_post.hpp:2261
post_comm_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:2283
post_comm_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:2293
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2256
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:2264
post_comm_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:2279
post_comm_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:2289
post_comm_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:2288
post_comm_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:2286
post_comm_x && direction(direction_t direction_in)
Definition lci_binding_post.hpp:2275
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:2267
post_comm_x && size(size_t size_in)
Definition lci_binding_post.hpp:2278
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:2257
post_comm_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2282
post_comm_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:2294
post_comm_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:2285
post_comm_x && device(device_t device_in)
Definition lci_binding_post.hpp:2281
post_comm_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:2295
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:2259
post_comm_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:2292
direction_t m_direction
Definition lci_binding_post.hpp:2249
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:2263
post_comm_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:2287
The actual implementation for post_get.
Definition lci_binding_post.hpp:2665
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:2681
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2682
post_get_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:2706
post_get_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:2703
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:2678
comp_t m_local_comp
Definition lci_binding_post.hpp:2671
post_get_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:2701
post_get_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:2695
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:2688
post_get_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:2702
status_t operator()() const
Definition lci_binding_post.hpp:2712
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:2677
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:2685
uintptr_t m_remote_disp
Definition lci_binding_post.hpp:2672
status_t call_impl(int rank, void *local_buffer, size_t size, comp_t local_comp, uintptr_t remote_disp, rmr_t rmr, runtime_t runtime, device_t device, endpoint_t endpoint, packet_pool_t packet_pool, comp_semantic_t comp_semantic, mr_t mr, tag_t tag, rcomp_t remote_comp, void *user_context, bool allow_done, bool allow_posted, bool allow_retry) const
void * m_local_buffer
Definition lci_binding_post.hpp:2669
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:2683
option_t< device_t > m_device
Definition lci_binding_post.hpp:2675
post_get_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:2696
int m_rank
Definition lci_binding_post.hpp:2668
post_get_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:2692
post_get_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:2704
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2674
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:2684
post_get_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:2707
post_get_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:2700
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2676
post_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2697
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:2679
post_get_x && size(size_t size_in)
Definition lci_binding_post.hpp:2693
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:2680
post_get_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2699
status_t call() const
Definition binding.cpp:792
post_get_x && rank(int rank_in)
Definition lci_binding_post.hpp:2691
post_get_x && device(device_t device_in)
Definition lci_binding_post.hpp:2698
post_get_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:2694
post_get_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2705
size_t m_size
Definition lci_binding_post.hpp:2670
rmr_t m_rmr
Definition lci_binding_post.hpp:2673
post_get_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:2708
The actual implementation for post_put.
Definition lci_binding_post.hpp:2580
status_t call_impl(int rank, void *local_buffer, size_t size, comp_t local_comp, uintptr_t remote_disp, rmr_t rmr, runtime_t runtime, device_t device, endpoint_t endpoint, packet_pool_t packet_pool, comp_semantic_t comp_semantic, mr_t mr, tag_t tag, rcomp_t remote_comp, void *user_context, bool allow_done, bool allow_posted, bool allow_retry) const
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:2598
post_put_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2620
post_put_x && device(device_t device_in)
Definition lci_binding_post.hpp:2613
status_t operator()() const
Definition lci_binding_post.hpp:2627
post_put_x && rank(int rank_in)
Definition lci_binding_post.hpp:2606
post_put_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2612
post_put_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2614
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:2599
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2591
comp_t m_local_comp
Definition lci_binding_post.hpp:2586
uintptr_t m_remote_disp
Definition lci_binding_post.hpp:2587
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:2600
option_t< device_t > m_device
Definition lci_binding_post.hpp:2590
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2597
post_put_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:2607
int m_rank
Definition lci_binding_post.hpp:2583
post_put_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:2615
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:2596
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:2603
post_put_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:2618
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:2594
post_put_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:2621
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:2595
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:2593
post_put_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:2616
status_t call() const
Definition binding.cpp:770
post_put_x && size(size_t size_in)
Definition lci_binding_post.hpp:2608
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2589
post_put_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:2623
post_put_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:2611
post_put_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:2609
post_put_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:2610
rmr_t m_rmr
Definition lci_binding_post.hpp:2588
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:2592
size_t m_size
Definition lci_binding_post.hpp:2585
post_put_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:2619
post_put_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:2617
void * m_local_buffer
Definition lci_binding_post.hpp:2584
post_put_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:2622
The actual implementation for post_recv.
Definition lci_binding_post.hpp:2497
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:2516
post_recv_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:2537
size_t m_size
Definition lci_binding_post.hpp:2502
post_recv_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:2536
post_recv_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:2525
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2512
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2509
tag_t m_tag
Definition lci_binding_post.hpp:2503
post_recv_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:2530
post_recv_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2527
option_t< device_t > m_device
Definition lci_binding_post.hpp:2506
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:2514
post_recv_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:2532
post_recv_x && size(size_t size_in)
Definition lci_binding_post.hpp:2524
status_t operator()() const
Definition lci_binding_post.hpp:2542
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:2508
post_recv_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2534
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:2510
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:2511
void * m_local_buffer
Definition lci_binding_post.hpp:2501
post_recv_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2529
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2507
post_recv_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2531
comp_t m_local_comp
Definition lci_binding_post.hpp:2504
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:2515
post_recv_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:2533
post_recv_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:2538
post_recv_x && device(device_t device_in)
Definition lci_binding_post.hpp:2528
int m_rank
Definition lci_binding_post.hpp:2500
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:2519
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2505
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:2513
post_recv_x && rank(int rank_in)
Definition lci_binding_post.hpp:2522
status_t call_impl(int rank, void *local_buffer, size_t size, tag_t tag, comp_t local_comp, runtime_t runtime, device_t device, endpoint_t endpoint, packet_pool_t packet_pool, matching_engine_t matching_engine, comp_semantic_t comp_semantic, mr_t mr, void *user_context, matching_policy_t matching_policy, bool allow_done, bool allow_posted, bool allow_retry) const
post_recv_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:2526
post_recv_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:2535
post_recv_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:2523
status_t call() const
Definition binding.cpp:749
The actual implementation for post_send.
Definition lci_binding_post.hpp:2415
post_send_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:2454
post_send_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:2444
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:2426
status_t call() const
Definition binding.cpp:728
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2427
post_send_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2447
void * m_local_buffer
Definition lci_binding_post.hpp:2419
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2430
post_send_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:2451
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:2432
size_t m_size
Definition lci_binding_post.hpp:2420
int m_rank
Definition lci_binding_post.hpp:2418
post_send_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:2441
tag_t m_tag
Definition lci_binding_post.hpp:2421
post_send_x && size(size_t size_in)
Definition lci_binding_post.hpp:2442
comp_t m_local_comp
Definition lci_binding_post.hpp:2422
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:2437
status_t operator()() const
Definition lci_binding_post.hpp:2460
post_send_x && rank(int rank_in)
Definition lci_binding_post.hpp:2440
post_send_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2445
post_send_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:2456
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:2429
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2425
post_send_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2449
status_t call_impl(int rank, void *local_buffer, size_t size, tag_t tag, comp_t local_comp, runtime_t runtime, device_t device, endpoint_t endpoint, packet_pool_t packet_pool, matching_engine_t matching_engine, comp_semantic_t comp_semantic, mr_t mr, void *user_context, matching_policy_t matching_policy, bool allow_done, bool allow_posted, bool allow_retry) const
post_send_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:2450
post_send_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:2455
option_t< device_t > m_device
Definition lci_binding_post.hpp:2424
post_send_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2452
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:2428
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:2431
post_send_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:2443
post_send_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:2453
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:2434
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:2433
post_send_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:2448
post_send_x && device(device_t device_in)
Definition lci_binding_post.hpp:2446
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2423
The actual implementation for progress.
Definition lci_binding_post.hpp:2735
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2738
error_t call() const
Definition binding.cpp:814
progress_x()
Definition lci_binding_post.hpp:2743
progress_x && device(device_t device_in)
Definition lci_binding_post.hpp:2747
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2740
option_t< device_t > m_device
Definition lci_binding_post.hpp:2739
error_t operator()() const
Definition lci_binding_post.hpp:2752
progress_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2746
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:2748
The actual implementation for put_upacket.
Definition lci_binding_post.hpp:447
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:451
void * m_packet
Definition lci_binding_post.hpp:450
void call() const
Definition binding.cpp:281
void operator()() const
Definition lci_binding_post.hpp:462
put_upacket_x && packet(void *packet_in)
Definition lci_binding_post.hpp:457
put_upacket_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:458
put_upacket_x(void *packet_in)
Definition lci_binding_post.hpp:454
void call_impl(void *packet, runtime_t runtime) const
The actual implementation for reduce_scatter.
Definition lci_binding_post.hpp:1996
reduce_scatter_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2017
reduce_scatter_x && item_size(size_t item_size_in)
Definition lci_binding_post.hpp:2019
reduce_scatter_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2024
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:2010
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2006
reduce_scatter_x && device(device_t device_in)
Definition lci_binding_post.hpp:2022
reduce_scatter_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2016
reduce_scatter_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2025
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2008
option_t< reduce_scatter_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:2009
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2004
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:2000
size_t m_item_size
Definition lci_binding_post.hpp:2002
const void * m_sendbuf
Definition lci_binding_post.hpp:1999
size_t m_recvcount
Definition lci_binding_post.hpp:2001
reduce_scatter_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:2020
void operator()() const
Definition lci_binding_post.hpp:2031
reduce_scatter_x && algorithm(reduce_scatter_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:2026
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2007
reduce_op_t m_op
Definition lci_binding_post.hpp:2003
void call() const
Definition binding.cpp:628
reduce_scatter_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2021
option_t< device_t > m_device
Definition lci_binding_post.hpp:2005
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:2013
reduce_scatter_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2023
reduce_scatter_x && recvcount(size_t recvcount_in)
Definition lci_binding_post.hpp:2018
reduce_scatter_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:2027
The actual implementation for reduce.
Definition lci_binding_post.hpp:1933
void operator()() const
Definition lci_binding_post.hpp:1964
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:1948
reduce_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:1955
reduce_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1960
reduce_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:1952
option_t< device_t > m_device
Definition lci_binding_post.hpp:1943
int m_root
Definition lci_binding_post.hpp:1941
size_t m_count
Definition lci_binding_post.hpp:1938
reduce_x && count(size_t count_in)
Definition lci_binding_post.hpp:1953
reduce_op_t m_op
Definition lci_binding_post.hpp:1940
reduce_x && device(device_t device_in)
Definition lci_binding_post.hpp:1958
size_t m_item_size
Definition lci_binding_post.hpp:1939
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1944
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:1937
reduce_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:1951
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1945
reduce_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1957
reduce_x && item_size(size_t item_size_in)
Definition lci_binding_post.hpp:1954
reduce_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1959
reduce_x && root(int root_in)
Definition lci_binding_post.hpp:1956
const void * m_sendbuf
Definition lci_binding_post.hpp:1936
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1942
void call() const
Definition binding.cpp:614
The actual implementation for register_memory.
Definition lci_binding_post.hpp:1110
register_memory_x && address(void *address_in)
Definition lci_binding_post.hpp:1122
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1115
register_memory_x && device(device_t device_in)
Definition lci_binding_post.hpp:1125
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:1123
option_t< device_t > m_device
Definition lci_binding_post.hpp:1116
void * m_address
Definition lci_binding_post.hpp:1113
mr_t operator()() const
Definition lci_binding_post.hpp:1129
register_memory_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1124
register_memory_x(void *address_in, size_t size_in)
Definition lci_binding_post.hpp:1119
size_t m_size
Definition lci_binding_post.hpp:1114
mr_t call() const
Definition binding.cpp:438
The actual implementation for register_packet_pool.
Definition lci_binding_post.hpp:331
device_t m_device
Definition lci_binding_post.hpp:335
void call_impl(packet_pool_t packet_pool, device_t device, runtime_t runtime) const
void operator()() const
Definition lci_binding_post.hpp:348
register_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:339
register_packet_pool_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:342
void call() const
Definition binding.cpp:261
register_packet_pool_x && device(device_t device_in)
Definition lci_binding_post.hpp:343
packet_pool_t m_packet_pool
Definition lci_binding_post.hpp:334
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:336
register_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:344
The actual implementation for register_rcomp.
Definition lci_binding_post.hpp:2963
rcomp_t call() const
Definition binding.cpp:861
rcomp_t operator()() const
Definition lci_binding_post.hpp:2980
comp_t m_comp
Definition lci_binding_post.hpp:2966
option_t< rcomp_t > m_rcomp
Definition lci_binding_post.hpp:2968
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2967
register_rcomp_x && rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:2976
register_rcomp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2975
register_rcomp_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2974
rcomp_t call_impl(comp_t comp, runtime_t runtime, rcomp_t rcomp) const
register_rcomp_x(comp_t comp_in)
Definition lci_binding_post.hpp:2971
The actual implementation for reserve_rcomps.
Definition lci_binding_post.hpp:2925
rcomp_t call_impl(rcomp_t n, runtime_t runtime) const
rcomp_t m_n
Definition lci_binding_post.hpp:2928
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2929
reserve_rcomps_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2936
rcomp_t call() const
Definition binding.cpp:855
reserve_rcomps_x(rcomp_t n_in)
Definition lci_binding_post.hpp:2932
rcomp_t operator()() const
Definition lci_binding_post.hpp:2940
reserve_rcomps_x && n(rcomp_t n_in)
Definition lci_binding_post.hpp:2935
The actual implementation for RESOURCE runtime.
Definition lci_binding_pre.hpp:219
The actual implementation for set_allocator.
Definition lci_binding_post.hpp:610
set_allocator_x(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:617
set_allocator_x && allocator(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:620
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:614
void call_impl(allocator_base_t *allocator, runtime_t runtime) const
set_allocator_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:621
void call() const
Definition binding.cpp:315
allocator_base_t * m_allocator
Definition lci_binding_post.hpp:613
void operator()() const
Definition lci_binding_post.hpp:625
The actual implementation for sync_test.
Definition lci_binding_post.hpp:3086
comp_t m_comp
Definition lci_binding_post.hpp:3089
bool call_impl(comp_t comp, status_t *p_out, runtime_t runtime) const
sync_test_x && p_out(status_t *p_out_in)
Definition lci_binding_post.hpp:3098
status_t * m_p_out
Definition lci_binding_post.hpp:3090
sync_test_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3099
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3091
bool operator()() const
Definition lci_binding_post.hpp:3103
sync_test_x(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:3094
sync_test_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3097
bool call() const
Definition binding.cpp:883
The actual implementation for sync_wait.
Definition lci_binding_post.hpp:3128
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3133
sync_wait_x(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:3138
comp_t m_comp
Definition lci_binding_post.hpp:3131
sync_wait_x && p_out(status_t *p_out_in)
Definition lci_binding_post.hpp:3142
option_t< device_t > m_device
Definition lci_binding_post.hpp:3135
sync_wait_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3143
void call() const
Definition binding.cpp:890
status_t * m_p_out
Definition lci_binding_post.hpp:3132
option_t< bool > m_do_progress
Definition lci_binding_post.hpp:3134
sync_wait_x && device(device_t device_in)
Definition lci_binding_post.hpp:3145
sync_wait_x && do_progress(bool do_progress_in)
Definition lci_binding_post.hpp:3144
void call_impl(comp_t comp, status_t *p_out, runtime_t runtime, bool do_progress, device_t device) const
void operator()() const
Definition lci_binding_post.hpp:3149
sync_wait_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3141
The actual implementation for test_drained.
Definition lci_binding_post.hpp:2774
option_t< device_t > m_device
Definition lci_binding_post.hpp:2778
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2777
test_drained_x()
Definition lci_binding_post.hpp:2781
error_t operator()() const
Definition lci_binding_post.hpp:2789
test_drained_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2784
test_drained_x && device(device_t device_in)
Definition lci_binding_post.hpp:2785
error_t call() const
Definition binding.cpp:821
error_t call_impl(runtime_t runtime, device_t device) const
The actual implementation for wait_drained.
Definition lci_binding_post.hpp:2811
option_t< device_t > m_device
Definition lci_binding_post.hpp:2815
void operator()() const
Definition lci_binding_post.hpp:2826
wait_drained_x()
Definition lci_binding_post.hpp:2818
void call() const
Definition binding.cpp:827
void call_impl(runtime_t runtime, device_t device) const
wait_drained_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2821
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2814
wait_drained_x && device(device_t device_in)
Definition lci_binding_post.hpp:2822
broadcast_algorithm_t
The type of broadcast algorithm.
Definition lci.hpp:232
void(*)(status_t status, void *src_value, void *dst_value) graph_edge_run_cb_t
The function signature for a edge funciton in the completion graph.
Definition lci.hpp:580
uint64_t matching_entry_key_t
The type of matching engine entry key.
Definition lci.hpp:406
status_t(*)(void *value) graph_node_run_cb_t
The function signature for a node function in the completion graph.
Definition lci.hpp:559
direction_t
The enum class of comunication direction.
Definition lci.hpp:356
void(*)(void *value) graph_node_free_cb_t
The function signature for a callback that will be triggered when the node was freed.
Definition lci.hpp:574
void(*)(const void *left, const void *right, void *dst, size_t n) reduce_op_t
The user-defined reduction operation.
Definition lci.hpp:539
matching_policy_t
Enum class for matching policy.
Definition lci.hpp:395
void * graph_node_t
The node type for the completion graph.
Definition lci.hpp:545
allreduce_algorithm_t
The type of allreduce algorithm.
Definition lci.hpp:268
reduce_scatter_algorithm_t
The type of reduce scatter algorithm.
Definition lci.hpp:250
void * matching_entry_val_t
The type of matching engine entry value.
Definition lci.hpp:411
matching_entry_type_t
The type of matching entry.
Definition lci.hpp:386
uint32_t rcomp_t
The type of remote completion handler.
Definition lci.hpp:367
void(*)(status_t status) comp_handler_t
Function Signature for completion handler.
Definition lci.hpp:532
uint64_t tag_t
The type of tag.
Definition lci.hpp:350
comp_semantic_t
The enum class of completion semantic.
Definition lci.hpp:421
uint32_t net_imm_data_t
The type of network-layer immediate data field.
Definition lci.hpp:287
All LCI API functions and classes are defined in this namespace.
status_t post_comm(direction_t direction_in, int rank_in, void *local_buffer_in, size_t size_in, comp_t local_comp_in)
Definition lci_binding_post.hpp:2302
error_t net_post_send(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1491
void graph_node_mark_complete(graph_node_t node_in)
Definition lci_binding_post.hpp:3576
size_t get_max_bcopy_size()
Definition lci_binding_post.hpp:872
attr_matching_engine_type_t
Definition lci_binding_pre.hpp:34
void broadcast(void *buffer_in, size_t size_in, int root_in)
Definition lci_binding_post.hpp:1906
device_t alloc_device()
Definition lci_binding_post.hpp:1052
net_context_t alloc_net_context()
Definition lci_binding_post.hpp:942
void free_net_context(net_context_t *net_context_in)
Definition lci_binding_post.hpp:979
error_t net_post_recv(void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1378
attr_backend_t
Definition lci.hpp:66
void deregister_rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:3020
void deregister_memory(mr_t *mr_in)
Definition lci_binding_post.hpp:1169
comp_t alloc_counter()
Definition lci_binding_post.hpp:3192
status_t post_am(int rank_in, void *local_buffer_in, size_t size_in, comp_t local_comp_in, rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:2381
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:591
void wait_drained()
Definition lci_binding_post.hpp:2829
rcomp_t reserve_rcomps(rcomp_t n_in)
Definition lci_binding_post.hpp:2943
void sync_wait(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:3152
matching_engine_t alloc_matching_engine()
Definition lci_binding_post.hpp:508
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:1671
void alltoall(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:2208
status_t graph_test(comp_t comp_in)
Definition lci_binding_post.hpp:3650
void register_packet_pool(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:351
matching_engine_t get_default_matching_engine()
Definition lci_binding_post.hpp:835
status_t cq_pop(comp_t comp_in)
Definition lci_binding_post.hpp:3355
size_t net_poll_cq(size_t max_polls_in, net_status_t *statuses_in)
Definition lci_binding_post.hpp:1329
attr_rdv_protocol_t
Definition lci_binding_pre.hpp:28
void graph_start(comp_t comp_in)
Definition lci_binding_post.hpp:3613
void free_matching_engine(matching_engine_t *matching_engine_in)
Definition lci_binding_post.hpp:545
void put_upacket(void *packet_in)
Definition lci_binding_post.hpp:465
comp_t alloc_cq()
Definition lci_binding_post.hpp:3318
void g_runtime_fina()
Definition lci_binding_post.hpp:196
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:1549
rcomp_t register_rcomp(comp_t comp_in)
Definition lci_binding_post.hpp:2983
error_t net_post_sends(int rank_in, void *buffer_in, size_t size_in)
Definition lci_binding_post.hpp:1433
void graph_add_edge(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in)
Definition lci_binding_post.hpp:3536
void set_allocator(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:628
allocator_base_t * get_allocator()
Definition lci_binding_post.hpp:662
net_context_t get_default_net_context()
Definition lci_binding_post.hpp:696
void free_device(device_t *device_in)
Definition lci_binding_post.hpp:1089
void free_comp(comp_t *comp_in)
Definition lci_binding_post.hpp:2866
packet_pool_t get_default_packet_pool()
Definition lci_binding_post.hpp:801
void free_runtime(runtime_t *runtime_in)
Definition lci_binding_post.hpp:103
comp_t alloc_handler(comp_handler_t handler_in)
Definition lci_binding_post.hpp:3401
error_t net_post_putImm(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in, uint64_t offset_in, rmr_t rmr_in)
Definition lci_binding_post.hpp:1735
runtime_t get_g_runtime()
Definition lci_binding_post.hpp:228
void free_packet_pool(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:311
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:1967
void deregister_packet_pool(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:391
runtime_t g_runtime_init()
Definition lci_binding_post.hpp:164
void counter_set(comp_t comp_in, int64_t value_in)
Definition lci_binding_post.hpp:3269
status_t post_send(int rank_in, void *local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in)
Definition lci_binding_post.hpp:2463
void comp_signal(comp_t comp_in, status_t status_in)
Definition lci_binding_post.hpp:2906
mr_t register_memory(void *address_in, size_t size_in)
Definition lci_binding_post.hpp:1132
rmr_t get_rmr(mr_t mr_in)
Definition lci_binding_post.hpp:1206
endpoint_t alloc_endpoint()
Definition lci_binding_post.hpp:1249
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:2630
endpoint_t get_default_endpoint()
Definition lci_binding_post.hpp:767
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:2101
graph_node_t graph_add_node(comp_t comp_in, graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:3490
runtime_t alloc_runtime()
Definition lci_binding_post.hpp:69
void allgather(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:2153
bool sync_test(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:3106
attr_ibv_td_strategy_t
Definition lci_binding_pre.hpp:52
error_t progress()
Definition lci_binding_post.hpp:2755
attr_ibv_odp_strategy_t
Definition lci_binding_pre.hpp:39
error_t test_drained()
Definition lci_binding_post.hpp:2792
device_t get_default_device()
Definition lci_binding_post.hpp:730
int64_t counter_get(comp_t comp_in)
Definition lci_binding_post.hpp:3229
void reduce_scatter(const void *sendbuf_in, void *recvbuf_in, size_t recvcount_in, size_t item_size_in, reduce_op_t op_in)
Definition lci_binding_post.hpp:2034
packet_pool_t alloc_packet_pool()
Definition lci_binding_post.hpp:274
attr_ibv_prefetch_strategy_t
Definition lci_binding_pre.hpp:45
void barrier()
Definition lci_binding_post.hpp:1845
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:1796
attr_cq_type_t
Definition lci_binding_pre.hpp:67
comp_t alloc_graph()
Definition lci_binding_post.hpp:3444
status_t post_recv(int rank_in, void *local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in)
Definition lci_binding_post.hpp:2545
void * get_upacket()
Definition lci_binding_post.hpp:428
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:1610
comp_t alloc_sync()
Definition lci_binding_post.hpp:3066
void free_endpoint(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:1286
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:2715
The user-defined allocator type.
Definition lci.hpp:430
Wrapper class for error code.
Definition lci.hpp:163
The struct for network status.
Definition lci.hpp:295
Definition lci.hpp:82
The type of remote memory region.
Definition lci.hpp:333
The type of the completion desciptor for a posted communication.
Definition lci.hpp:446