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
886
892 public:
893 // args declaration
896
897 // constructor
898 free_comp_x(comp_t* comp_in) : m_comp(comp_in) {}
899
900 // setter
901 inline free_comp_x&& comp(comp_t* comp_in) { m_comp = comp_in; return std::move(*this); }
902 inline free_comp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
903
905 void call() const;
906 inline void operator()() const { return call(); }
907};
908
909inline void free_comp(comp_t* comp_in) {
910 return free_comp_x(comp_in).call();
911}
912
913
924
930 public:
931 // args declaration
935
936 // constructor
937 comp_signal_x(comp_t comp_in, status_t status_in) : m_comp(comp_in), m_status(status_in) {}
938
939 // setter
940 inline comp_signal_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
941 inline comp_signal_x&& status(status_t status_in) { m_status = status_in; return std::move(*this); }
942 inline comp_signal_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
943
945 void call() const;
946 inline void operator()() const { return call(); }
947};
948
949inline void comp_signal(comp_t comp_in, status_t status_in) {
950 return comp_signal_x(comp_in, status_in).call();
951}
952
953
963
969 public:
970 // args declaration
973
974 // constructor
975 reserve_rcomps_x(rcomp_t n_in) : m_n(n_in) {}
976
977 // setter
978 inline reserve_rcomps_x&& n(rcomp_t n_in) { m_n = n_in; return std::move(*this); }
979 inline reserve_rcomps_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
980
982 rcomp_t call() const;
983 inline rcomp_t operator()() const { return call(); }
984};
985
987 return reserve_rcomps_x(n_in).call();
988}
989
990
1001
1007 public:
1008 // args declaration
1012
1013 // constructor
1014 register_rcomp_x(comp_t comp_in) : m_comp(comp_in) {}
1015
1016 // setter
1017 inline register_rcomp_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1018 inline register_rcomp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1019 inline register_rcomp_x&& rcomp(rcomp_t rcomp_in) { m_rcomp = rcomp_in; return std::move(*this); }
1020
1022 rcomp_t call() const;
1023 inline rcomp_t operator()() const { return call(); }
1024};
1025
1027 return register_rcomp_x(comp_in).call();
1028}
1029
1030
1040
1046 public:
1047 // args declaration
1050
1051 // constructor
1052 deregister_rcomp_x(rcomp_t rcomp_in) : m_rcomp(rcomp_in) {}
1053
1054 // setter
1055 inline deregister_rcomp_x&& rcomp(rcomp_t rcomp_in) { m_rcomp = rcomp_in; return std::move(*this); }
1056 inline deregister_rcomp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1057
1059 void call() const;
1060 inline void operator()() const { return call(); }
1061};
1062
1063inline void deregister_rcomp(rcomp_t rcomp_in) {
1064 return deregister_rcomp_x(rcomp_in).call();
1065}
1066
1067
1080
1086 public:
1087 // args declaration
1093
1094 // constructor
1096
1097 // setter
1098 inline alloc_sync_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1099 inline alloc_sync_x&& threshold(int threshold_in) { m_threshold = threshold_in; return std::move(*this); }
1100 inline alloc_sync_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
1101 inline alloc_sync_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
1102 inline alloc_sync_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1103
1105 comp_t call() const;
1106 inline comp_t operator()() const { return call(); }
1107};
1108
1110 return alloc_sync_x().call();
1111}
1112
1113
1124
1130 public:
1131 // args declaration
1135
1136 // constructor
1137 sync_test_x(comp_t comp_in, status_t* p_out_in) : m_comp(comp_in), m_p_out(p_out_in) {}
1138
1139 // setter
1140 inline sync_test_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1141 inline sync_test_x&& p_out(status_t* p_out_in) { m_p_out = p_out_in; return std::move(*this); }
1142 inline sync_test_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1143
1145 bool call() const;
1146 inline bool operator()() const { return call(); }
1147};
1148
1149inline bool sync_test(comp_t comp_in, status_t* p_out_in) {
1150 return sync_test_x(comp_in, p_out_in).call();
1151}
1152
1153
1166
1172 public:
1173 // args declaration
1179
1180 // constructor
1181 sync_wait_x(comp_t comp_in, status_t* p_out_in) : m_comp(comp_in), m_p_out(p_out_in) {}
1182
1183 // setter
1184 inline sync_wait_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1185 inline sync_wait_x&& p_out(status_t* p_out_in) { m_p_out = p_out_in; return std::move(*this); }
1186 inline sync_wait_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1187 inline sync_wait_x&& do_progress(bool do_progress_in) { m_do_progress = do_progress_in; return std::move(*this); }
1188 inline sync_wait_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1189
1191 void call() const;
1192 inline void operator()() const { return call(); }
1193};
1194
1195inline void sync_wait(comp_t comp_in, status_t* p_out_in) {
1196 return sync_wait_x(comp_in, p_out_in).call();
1197}
1198
1199
1210
1216 public:
1217 // args declaration
1221
1222 // constructor
1224
1225 // setter
1226 inline alloc_counter_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1227 inline alloc_counter_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
1228 inline alloc_counter_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1229
1231 comp_t call() const;
1232 inline comp_t operator()() const { return call(); }
1233};
1234
1236 return alloc_counter_x().call();
1237}
1238
1239
1249
1255 public:
1256 // args declaration
1259
1260 // constructor
1261 counter_get_x(comp_t comp_in) : m_comp(comp_in) {}
1262
1263 // setter
1264 inline counter_get_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1265 inline counter_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1266
1268 int64_t call() const;
1269 inline int64_t operator()() const { return call(); }
1270};
1271
1272inline int64_t counter_get(comp_t comp_in) {
1273 return counter_get_x(comp_in).call();
1274}
1275
1276
1287
1293 public:
1294 // args declaration
1296 int64_t m_value;
1298
1299 // constructor
1300 counter_set_x(comp_t comp_in, int64_t value_in) : m_comp(comp_in), m_value(value_in) {}
1301
1302 // setter
1303 inline counter_set_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1304 inline counter_set_x&& value(int64_t value_in) { m_value = value_in; return std::move(*this); }
1305 inline counter_set_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1306
1308 void call() const;
1309 inline void operator()() const { return call(); }
1310};
1311
1312inline void counter_set(comp_t comp_in, int64_t value_in) {
1313 return counter_set_x(comp_in, value_in).call();
1314}
1315
1316
1330
1336 public:
1337 // args declaration
1344
1345 // constructor
1347
1348 // setter
1349 inline alloc_cq_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1350 inline alloc_cq_x&& default_length(int default_length_in) { m_default_length = default_length_in; return std::move(*this); }
1351 inline alloc_cq_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
1352 inline alloc_cq_x&& cq_type(attr_cq_type_t cq_type_in) { m_cq_type = cq_type_in; return std::move(*this); }
1353 inline alloc_cq_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
1354 inline alloc_cq_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1355
1357 comp_t call() const;
1358 inline comp_t operator()() const { return call(); }
1359};
1360
1362 return alloc_cq_x().call();
1363}
1364
1365
1375
1381 public:
1382 // args declaration
1385
1386 // constructor
1387 cq_pop_x(comp_t comp_in) : m_comp(comp_in) {}
1388
1389 // setter
1390 inline cq_pop_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1391 inline cq_pop_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1392
1394 status_t call() const;
1395 inline status_t operator()() const { return call(); }
1396};
1397
1398inline status_t cq_pop(comp_t comp_in) {
1399 return cq_pop_x(comp_in).call();
1400}
1401
1402
1415
1421 public:
1422 // args declaration
1428
1429 // constructor
1430 alloc_handler_x(comp_handler_t handler_in) : m_handler(handler_in) {}
1431
1432 // setter
1433 inline alloc_handler_x&& handler(comp_handler_t handler_in) { m_handler = handler_in; return std::move(*this); }
1434 inline alloc_handler_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1435 inline alloc_handler_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
1436 inline alloc_handler_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
1437 inline alloc_handler_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1438
1440 comp_t call() const;
1441 inline comp_t operator()() const { return call(); }
1442};
1443
1445 return alloc_handler_x(handler_in).call();
1446}
1447
1448
1460
1466 public:
1467 // args declaration
1472
1473 // constructor
1475
1476 // setter
1477 inline alloc_graph_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1478 inline alloc_graph_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
1479 inline alloc_graph_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1480 inline alloc_graph_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1481
1483 comp_t call() const;
1484 inline comp_t operator()() const { return call(); }
1485};
1486
1488 return alloc_graph_x().call();
1489}
1490
1491
1504
1510 public:
1511 // args declaration
1517
1518 // constructor
1519 graph_add_node_x(comp_t comp_in, graph_node_run_cb_t fn_in) : m_comp(comp_in), m_fn(fn_in) {}
1520
1521 // setter
1522 inline graph_add_node_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1523 inline graph_add_node_x&& fn(graph_node_run_cb_t fn_in) { m_fn = fn_in; return std::move(*this); }
1524 inline graph_add_node_x&& value(void* value_in) { m_value = value_in; return std::move(*this); }
1525 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); }
1526 inline graph_add_node_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1527
1529 graph_node_t call() const;
1530 inline graph_node_t operator()() const { return call(); }
1531};
1532
1534 return graph_add_node_x(comp_in, fn_in).call();
1535}
1536
1537
1550
1556 public:
1557 // args declaration
1563
1564 // constructor
1565 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) {}
1566
1567 // setter
1568 inline graph_add_edge_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1569 inline graph_add_edge_x&& src(graph_node_t src_in) { m_src = src_in; return std::move(*this); }
1570 inline graph_add_edge_x&& dst(graph_node_t dst_in) { m_dst = dst_in; return std::move(*this); }
1571 inline graph_add_edge_x&& fn(graph_edge_run_cb_t fn_in) { m_fn = fn_in; return std::move(*this); }
1572 inline graph_add_edge_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1573
1575 void call() const;
1576 inline void operator()() const { return call(); }
1577};
1578
1579inline void graph_add_edge(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in) {
1580 return graph_add_edge_x(comp_in, src_in, dst_in).call();
1581}
1582
1583
1594
1600 public:
1601 // args declaration
1605
1606 // constructor
1608
1609 // setter
1610 inline graph_node_mark_complete_x&& node(graph_node_t node_in) { m_node = node_in; return std::move(*this); }
1611 inline graph_node_mark_complete_x&& status(status_t status_in) { m_status = status_in; return std::move(*this); }
1612 inline graph_node_mark_complete_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1613
1615 void call() const;
1616 inline void operator()() const { return call(); }
1617};
1618
1620 return graph_node_mark_complete_x(node_in).call();
1621}
1622
1623
1633
1639 public:
1640 // args declaration
1643
1644 // constructor
1645 graph_start_x(comp_t comp_in) : m_comp(comp_in) {}
1646
1647 // setter
1648 inline graph_start_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1649 inline graph_start_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1650
1652 void call() const;
1653 inline void operator()() const { return call(); }
1654};
1655
1656inline void graph_start(comp_t comp_in) {
1657 return graph_start_x(comp_in).call();
1658}
1659
1660
1670
1676 public:
1677 // args declaration
1680
1681 // constructor
1682 graph_test_x(comp_t comp_in) : m_comp(comp_in) {}
1683
1684 // setter
1685 inline graph_test_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1686 inline graph_test_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1687
1689 status_t call() const;
1690 inline status_t operator()() const { return call(); }
1691};
1692
1693inline status_t graph_test(comp_t comp_in) {
1694 return graph_test_x(comp_in).call();
1695}
1696
1697
1711
1717 public:
1718 // args declaration
1725
1726 // constructor
1728
1729 // setter
1730 inline barrier_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1731 inline barrier_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1732 inline barrier_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1733 inline barrier_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1734 inline barrier_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1735 inline barrier_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1736
1738 void call() const;
1739 inline void operator()() const { return call(); }
1740};
1741
1742inline void barrier() {
1743 return barrier_x().call();
1744}
1745
1746
1764
1770 public:
1771 // args declaration
1773 size_t m_size;
1782
1783 // constructor
1784 broadcast_x(void* buffer_in, size_t size_in, int root_in) : m_buffer(buffer_in), m_size(size_in), m_root(root_in) {}
1785
1786 // setter
1787 inline broadcast_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1788 inline broadcast_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1789 inline broadcast_x&& root(int root_in) { m_root = root_in; return std::move(*this); }
1790 inline broadcast_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1791 inline broadcast_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1792 inline broadcast_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1793 inline broadcast_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1794 inline broadcast_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1795 inline broadcast_x&& algorithm(broadcast_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
1796 inline broadcast_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
1797
1799 void call() const;
1800 inline void operator()() const { return call(); }
1801};
1802
1803inline void broadcast(void* buffer_in, size_t size_in, int root_in) {
1804 return broadcast_x(buffer_in, size_in, root_in).call();
1805}
1806
1807
1825
1831 public:
1832 // args declaration
1833 const void* m_sendbuf;
1835 size_t m_count;
1843
1844 // constructor
1845 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) {}
1846
1847 // setter
1848 inline reduce_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
1849 inline reduce_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
1850 inline reduce_x&& count(size_t count_in) { m_count = count_in; return std::move(*this); }
1851 inline reduce_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
1852 inline reduce_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
1853 inline reduce_x&& root(int root_in) { m_root = root_in; return std::move(*this); }
1854 inline reduce_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1855 inline reduce_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1856 inline reduce_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1857 inline reduce_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1858
1860 void call() const;
1861 inline void operator()() const { return call(); }
1862};
1863
1864inline 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) {
1865 return reduce_x(sendbuf_in, recvbuf_in, count_in, item_size_in, op_in, root_in).call();
1866}
1867
1868
1888
1894 public:
1895 // args declaration
1896 const void* m_sendbuf;
1908
1909 // constructor
1910 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) {}
1911
1912 // setter
1913 inline reduce_scatter_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
1914 inline reduce_scatter_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
1915 inline reduce_scatter_x&& recvcount(size_t recvcount_in) { m_recvcount = recvcount_in; return std::move(*this); }
1916 inline reduce_scatter_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
1917 inline reduce_scatter_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
1918 inline reduce_scatter_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1919 inline reduce_scatter_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1920 inline reduce_scatter_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1921 inline reduce_scatter_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1922 inline reduce_scatter_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1923 inline reduce_scatter_x&& algorithm(reduce_scatter_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
1924 inline reduce_scatter_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
1925
1927 void call() const;
1928 inline void operator()() const { return call(); }
1929};
1930
1931inline void reduce_scatter(const void* sendbuf_in, void* recvbuf_in, size_t recvcount_in, size_t item_size_in, reduce_op_t op_in) {
1932 return reduce_scatter_x(sendbuf_in, recvbuf_in, recvcount_in, item_size_in, op_in).call();
1933}
1934
1935
1955
1961 public:
1962 // args declaration
1963 const void* m_sendbuf;
1965 size_t m_count;
1975
1976 // constructor
1977 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) {}
1978
1979 // setter
1980 inline allreduce_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
1981 inline allreduce_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
1982 inline allreduce_x&& count(size_t count_in) { m_count = count_in; return std::move(*this); }
1983 inline allreduce_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
1984 inline allreduce_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
1985 inline allreduce_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1986 inline allreduce_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1987 inline allreduce_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1988 inline allreduce_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1989 inline allreduce_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1990 inline allreduce_x&& algorithm(allreduce_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
1991 inline allreduce_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
1992
1994 void call() const;
1995 inline void operator()() const { return call(); }
1996};
1997
1998inline void allreduce(const void* sendbuf_in, void* recvbuf_in, size_t count_in, size_t item_size_in, reduce_op_t op_in) {
1999 return allreduce_x(sendbuf_in, recvbuf_in, count_in, item_size_in, op_in).call();
2000}
2001
2002
2017
2023 public:
2024 // args declaration
2025 const void* m_sendbuf;
2027 size_t m_size;
2032
2033 // constructor
2034 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) {}
2035
2036 // setter
2037 inline allgather_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2038 inline allgather_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2039 inline allgather_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2040 inline allgather_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2041 inline allgather_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2042 inline allgather_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2043 inline allgather_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2044
2046 void call() const;
2047 inline void operator()() const { return call(); }
2048};
2049
2050inline void allgather(const void* sendbuf_in, void* recvbuf_in, size_t size_in) {
2051 return allgather_x(sendbuf_in, recvbuf_in, size_in).call();
2052}
2053
2054
2071
2077 public:
2078 // args declaration
2079 const void* m_sendbuf;
2081 size_t m_size;
2088
2089 // constructor
2090 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) {}
2091
2092 // setter
2093 inline alltoall_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2094 inline alltoall_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2095 inline alltoall_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2096 inline alltoall_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2097 inline alltoall_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2098 inline alltoall_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2099 inline alltoall_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2100 inline alltoall_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2101 inline alltoall_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
2102
2104 void call() const;
2105 inline void operator()() const { return call(); }
2106};
2107
2108inline void alltoall(const void* sendbuf_in, void* recvbuf_in, size_t size_in) {
2109 return alltoall_x(sendbuf_in, recvbuf_in, size_in).call();
2110}
2111
2112
2133
2139 public:
2140 // args declaration
2154
2155 // constructor
2157
2158 // setter
2159 inline alloc_net_context_x&& backend(attr_backend_t backend_in) { m_backend = backend_in; return std::move(*this); }
2160 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); }
2161 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); }
2162 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); }
2163 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); }
2164 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); }
2165 inline alloc_net_context_x&& device_name(std::string device_name_in) { m_device_name = device_name_in; return std::move(*this); }
2166 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); }
2167 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); }
2168 inline alloc_net_context_x&& use_dmabuf(bool use_dmabuf_in) { m_use_dmabuf = use_dmabuf_in; return std::move(*this); }
2169 inline alloc_net_context_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2170 inline alloc_net_context_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2171 inline alloc_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2172
2174 net_context_t call() const;
2175 inline net_context_t operator()() const { return call(); }
2176};
2177
2181
2182
2192
2198 public:
2199 // args declaration
2202
2203 // constructor
2204 free_net_context_x(net_context_t* net_context_in) : m_net_context(net_context_in) {}
2205
2206 // setter
2207 inline free_net_context_x&& net_context(net_context_t* net_context_in) { m_net_context = net_context_in; return std::move(*this); }
2208 inline free_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2209
2211 void call() const;
2212 inline void operator()() const { return call(); }
2213};
2214
2215inline void free_net_context(net_context_t* net_context_in) {
2216 return free_net_context_x(net_context_in).call();
2217}
2218
2219
2247
2253 public:
2254 // args declaration
2275
2276 // constructor
2278
2279 // setter
2280 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); }
2281 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); }
2282 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); }
2283 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); }
2284 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); }
2285 inline alloc_device_x&& alloc_default_endpoint(bool alloc_default_endpoint_in) { m_alloc_default_endpoint = alloc_default_endpoint_in; return std::move(*this); }
2286 inline alloc_device_x&& alloc_progress_endpoint(bool alloc_progress_endpoint_in) { m_alloc_progress_endpoint = alloc_progress_endpoint_in; return std::move(*this); }
2287 inline alloc_device_x&& use_reg_cache(bool use_reg_cache_in) { m_use_reg_cache = use_reg_cache_in; return std::move(*this); }
2288 inline alloc_device_x&& shm_enable(bool shm_enable_in) { m_shm_enable = shm_enable_in; return std::move(*this); }
2289 inline alloc_device_x&& shm_ring_size(size_t shm_ring_size_in) { m_shm_ring_size = shm_ring_size_in; return std::move(*this); }
2290 inline alloc_device_x&& shm_slot_size(size_t shm_slot_size_in) { m_shm_slot_size = shm_slot_size_in; return std::move(*this); }
2291 inline alloc_device_x&& shm_producer_cas_attempts(size_t shm_producer_cas_attempts_in) { m_shm_producer_cas_attempts = shm_producer_cas_attempts_in; return std::move(*this); }
2292 inline alloc_device_x&& shm_consumer_cas_attempts(size_t shm_consumer_cas_attempts_in) { m_shm_consumer_cas_attempts = shm_consumer_cas_attempts_in; return std::move(*this); }
2293 inline alloc_device_x&& shm_max_polls(size_t shm_max_polls_in) { m_shm_max_polls = shm_max_polls_in; return std::move(*this); }
2294 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); }
2295 inline alloc_device_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2296 inline alloc_device_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2297 inline alloc_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2298 inline alloc_device_x&& net_context(net_context_t net_context_in) { m_net_context = net_context_in; return std::move(*this); }
2299 inline alloc_device_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2300
2302 device_t call() const;
2303 inline device_t operator()() const { return call(); }
2304};
2305
2307 return alloc_device_x().call();
2308}
2309
2310
2320
2326 public:
2327 // args declaration
2330
2331 // constructor
2332 free_device_x(device_t* device_in) : m_device(device_in) {}
2333
2334 // setter
2335 inline free_device_x&& device(device_t* device_in) { m_device = device_in; return std::move(*this); }
2336 inline free_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2337
2339 void call() const;
2340 inline void operator()() const { return call(); }
2341};
2342
2343inline void free_device(device_t* device_in) {
2344 return free_device_x(device_in).call();
2345}
2346
2347
2359
2365 public:
2366 // args declaration
2368 size_t m_size;
2371
2372 // constructor
2373 register_memory_x(void* address_in, size_t size_in) : m_address(address_in), m_size(size_in) {}
2374
2375 // setter
2376 inline register_memory_x&& address(void* address_in) { m_address = address_in; return std::move(*this); }
2377 inline register_memory_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2378 inline register_memory_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2379 inline register_memory_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2380
2382 mr_t call() const;
2383 inline mr_t operator()() const { return call(); }
2384};
2385
2386inline mr_t register_memory(void* address_in, size_t size_in) {
2387 return register_memory_x(address_in, size_in).call();
2388}
2389
2390
2400
2406 public:
2407 // args declaration
2410
2411 // constructor
2412 deregister_memory_x(mr_t* mr_in) : m_mr(mr_in) {}
2413
2414 // setter
2415 inline deregister_memory_x&& mr(mr_t* mr_in) { m_mr = mr_in; return std::move(*this); }
2416 inline deregister_memory_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2417
2419 void call() const;
2420 inline void operator()() const { return call(); }
2421};
2422
2423inline void deregister_memory(mr_t* mr_in) {
2424 return deregister_memory_x(mr_in).call();
2425}
2426
2427
2437
2443 public:
2444 // args declaration
2447
2448 // constructor
2449 get_rmr_x(mr_t mr_in) : m_mr(mr_in) {}
2450
2451 // setter
2452 inline get_rmr_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
2453 inline get_rmr_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2454
2456 rmr_t call() const;
2457 inline rmr_t operator()() const { return call(); }
2458};
2459
2460inline rmr_t get_rmr(mr_t mr_in) {
2461 return get_rmr_x(mr_in).call();
2462}
2463
2464
2476
2482 public:
2483 // args declaration
2488
2489 // constructor
2491
2492 // setter
2493 inline alloc_endpoint_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2494 inline alloc_endpoint_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2495 inline alloc_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2496 inline alloc_endpoint_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2497
2499 endpoint_t call() const;
2500 inline endpoint_t operator()() const { return call(); }
2501};
2502
2504 return alloc_endpoint_x().call();
2505}
2506
2507
2517
2523 public:
2524 // args declaration
2527
2528 // constructor
2529 free_endpoint_x(endpoint_t* endpoint_in) : m_endpoint(endpoint_in) {}
2530
2531 // setter
2532 inline free_endpoint_x&& endpoint(endpoint_t* endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2533 inline free_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2534
2536 void call() const;
2537 inline void operator()() const { return call(); }
2538};
2539
2540inline void free_endpoint(endpoint_t* endpoint_in) {
2541 return free_endpoint_x(endpoint_in).call();
2542}
2543
2544
2556
2562 public:
2563 // args declaration
2568
2569 // constructor
2570 net_poll_cq_x(size_t max_polls_in, net_status_t* statuses_in) : m_max_polls(max_polls_in), m_statuses(statuses_in) {}
2571
2572 // setter
2573 inline net_poll_cq_x&& max_polls(size_t max_polls_in) { m_max_polls = max_polls_in; return std::move(*this); }
2574 inline net_poll_cq_x&& statuses(net_status_t* statuses_in) { m_statuses = statuses_in; return std::move(*this); }
2575 inline net_poll_cq_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2576 inline net_poll_cq_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2577
2579 size_t call() const;
2580 inline size_t operator()() const { return call(); }
2581};
2582
2583inline size_t net_poll_cq(size_t max_polls_in, net_status_t* statuses_in) {
2584 return net_poll_cq_x(max_polls_in, statuses_in).call();
2585}
2586
2587
2601
2607 public:
2608 // args declaration
2610 size_t m_size;
2615
2616 // constructor
2617 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) {}
2618
2619 // setter
2620 inline net_post_recv_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
2621 inline net_post_recv_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2622 inline net_post_recv_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
2623 inline net_post_recv_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2624 inline net_post_recv_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2625 inline net_post_recv_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2626
2628 error_t call() const;
2629 inline error_t operator()() const { return call(); }
2630};
2631
2632inline error_t net_post_recv(void* buffer_in, size_t size_in, mr_t mr_in) {
2633 return net_post_recv_x(buffer_in, size_in, mr_in).call();
2634}
2635
2636
2652
2658 public:
2659 // args declaration
2662 size_t m_size;
2668
2669 // constructor
2670 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) {}
2671
2672 // setter
2673 inline net_post_sends_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2674 inline net_post_sends_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
2675 inline net_post_sends_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2676 inline net_post_sends_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2677 inline net_post_sends_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2678 inline net_post_sends_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2679 inline net_post_sends_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
2680 inline net_post_sends_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2681
2683 error_t call() const;
2684 inline error_t operator()() const { return call(); }
2685};
2686
2687inline error_t net_post_sends(int rank_in, void* buffer_in, size_t size_in) {
2688 return net_post_sends_x(rank_in, buffer_in, size_in).call();
2689}
2690
2691
2708
2714 public:
2715 // args declaration
2718 size_t m_size;
2725
2726 // constructor
2727 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) {}
2728
2729 // setter
2730 inline net_post_send_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2731 inline net_post_send_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
2732 inline net_post_send_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2733 inline net_post_send_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
2734 inline net_post_send_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2735 inline net_post_send_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2736 inline net_post_send_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2737 inline net_post_send_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
2738 inline net_post_send_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2739
2741 error_t call() const;
2742 inline error_t operator()() const { return call(); }
2743};
2744
2745inline error_t net_post_send(int rank_in, void* buffer_in, size_t size_in, mr_t mr_in) {
2746 return net_post_send_x(rank_in, buffer_in, size_in, mr_in).call();
2747}
2748
2749
2766
2772 public:
2773 // args declaration
2776 size_t m_size;
2777 uint64_t m_offset;
2783
2784 // constructor
2785 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) {}
2786
2787 // setter
2788 inline net_post_puts_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2789 inline net_post_puts_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
2790 inline net_post_puts_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2791 inline net_post_puts_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
2792 inline net_post_puts_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
2793 inline net_post_puts_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2794 inline net_post_puts_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2795 inline net_post_puts_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2796 inline net_post_puts_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2797
2799 error_t call() const;
2800 inline error_t operator()() const { return call(); }
2801};
2802
2803inline error_t net_post_puts(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) {
2804 return net_post_puts_x(rank_in, buffer_in, size_in, offset_in, rmr_in).call();
2805}
2806
2807
2825
2831 public:
2832 // args declaration
2835 size_t m_size;
2837 uint64_t m_offset;
2843
2844 // constructor
2845 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) {}
2846
2847 // setter
2848 inline net_post_put_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2849 inline net_post_put_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
2850 inline net_post_put_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2851 inline net_post_put_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
2852 inline net_post_put_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
2853 inline net_post_put_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
2854 inline net_post_put_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2855 inline net_post_put_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2856 inline net_post_put_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2857 inline net_post_put_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2858
2860 error_t call() const;
2861 inline error_t operator()() const { return call(); }
2862};
2863
2864inline 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) {
2865 return net_post_put_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
2866}
2867
2868
2886
2892 public:
2893 // args declaration
2896 size_t m_size;
2897 uint64_t m_offset;
2904
2905 // constructor
2906 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) {}
2907
2908 // setter
2909 inline net_post_putImms_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2910 inline net_post_putImms_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
2911 inline net_post_putImms_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2912 inline net_post_putImms_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
2913 inline net_post_putImms_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
2914 inline net_post_putImms_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2915 inline net_post_putImms_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2916 inline net_post_putImms_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2917 inline net_post_putImms_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
2918 inline net_post_putImms_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2919
2921 error_t call() const;
2922 inline error_t operator()() const { return call(); }
2923};
2924
2925inline error_t net_post_putImms(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) {
2926 return net_post_putImms_x(rank_in, buffer_in, size_in, offset_in, rmr_in).call();
2927}
2928
2929
2948
2954 public:
2955 // args declaration
2958 size_t m_size;
2960 uint64_t m_offset;
2967
2968 // constructor
2969 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) {}
2970
2971 // setter
2972 inline net_post_putImm_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2973 inline net_post_putImm_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
2974 inline net_post_putImm_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2975 inline net_post_putImm_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
2976 inline net_post_putImm_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
2977 inline net_post_putImm_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
2978 inline net_post_putImm_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2979 inline net_post_putImm_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2980 inline net_post_putImm_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2981 inline net_post_putImm_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
2982 inline net_post_putImm_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2983
2985 error_t call() const;
2986 inline error_t operator()() const { return call(); }
2987};
2988
2989inline 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) {
2990 return net_post_putImm_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
2991}
2992
2993
3011
3017 public:
3018 // args declaration
3021 size_t m_size;
3023 uint64_t m_offset;
3029
3030 // constructor
3031 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) {}
3032
3033 // setter
3034 inline net_post_get_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3035 inline net_post_get_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
3036 inline net_post_get_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3037 inline net_post_get_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3038 inline net_post_get_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
3039 inline net_post_get_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
3040 inline net_post_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3041 inline net_post_get_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3042 inline net_post_get_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3043 inline net_post_get_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3044
3046 error_t call() const;
3047 inline error_t operator()() const { return call(); }
3048};
3049
3050inline 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) {
3051 return net_post_get_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
3052}
3053
3054
3083
3089 public:
3090 // args declaration
3094 size_t m_size;
3112
3113 // constructor
3114 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) {}
3115
3116 // setter
3117 inline post_comm_x&& direction(direction_t direction_in) { m_direction = direction_in; return std::move(*this); }
3118 inline post_comm_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3119 inline post_comm_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3120 inline post_comm_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3121 inline post_comm_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3122 inline post_comm_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3123 inline post_comm_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3124 inline post_comm_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3125 inline post_comm_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3126 inline post_comm_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3127 inline post_comm_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3128 inline post_comm_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3129 inline post_comm_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
3130 inline post_comm_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
3131 inline post_comm_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3132 inline post_comm_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
3133 inline post_comm_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3134 inline post_comm_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
3135 inline post_comm_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3136 inline post_comm_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3137 inline post_comm_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3138
3140 status_t call() const;
3141 inline status_t operator()() const { return call(); }
3142};
3143
3144inline status_t post_comm(direction_t direction_in, int rank_in, void* local_buffer_in, size_t size_in, comp_t local_comp_in) {
3145 return post_comm_x(direction_in, rank_in, local_buffer_in, size_in, local_comp_in).call();
3146}
3147
3148
3172
3178 public:
3179 // args declaration
3182 size_t m_size;
3196
3197 // constructor
3198 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) {}
3199
3200 // setter
3201 inline post_am_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3202 inline post_am_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3203 inline post_am_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3204 inline post_am_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3205 inline post_am_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
3206 inline post_am_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3207 inline post_am_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3208 inline post_am_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3209 inline post_am_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3210 inline post_am_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3211 inline post_am_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3212 inline post_am_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3213 inline post_am_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3214 inline post_am_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3215 inline post_am_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3216 inline post_am_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3217
3219 status_t call() const;
3220 inline status_t operator()() const { return call(); }
3221};
3222
3223inline 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) {
3224 return post_am_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_comp_in).call();
3225}
3226
3227
3252
3258 public:
3259 // args declaration
3262 size_t m_size;
3277
3278 // constructor
3279 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) {}
3280
3281 // setter
3282 inline post_send_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3283 inline post_send_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3284 inline post_send_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3285 inline post_send_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3286 inline post_send_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3287 inline post_send_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3288 inline post_send_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3289 inline post_send_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3290 inline post_send_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3291 inline post_send_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3292 inline post_send_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3293 inline post_send_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3294 inline post_send_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3295 inline post_send_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
3296 inline post_send_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3297 inline post_send_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3298 inline post_send_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3299
3301 status_t call() const;
3302 inline status_t operator()() const { return call(); }
3303};
3304
3305inline status_t post_send(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) {
3306 return post_send_x(rank_in, local_buffer_in, size_in, tag_in, local_comp_in).call();
3307}
3308
3309
3334
3340 public:
3341 // args declaration
3344 size_t m_size;
3359
3360 // constructor
3361 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) {}
3362
3363 // setter
3364 inline post_recv_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3365 inline post_recv_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3366 inline post_recv_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3367 inline post_recv_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3368 inline post_recv_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3369 inline post_recv_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3370 inline post_recv_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3371 inline post_recv_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3372 inline post_recv_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3373 inline post_recv_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3374 inline post_recv_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3375 inline post_recv_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3376 inline post_recv_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3377 inline post_recv_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
3378 inline post_recv_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3379 inline post_recv_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3380 inline post_recv_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3381
3383 status_t call() const;
3384 inline status_t operator()() const { return call(); }
3385};
3386
3387inline status_t post_recv(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) {
3388 return post_recv_x(rank_in, local_buffer_in, size_in, tag_in, local_comp_in).call();
3389}
3390
3391
3417
3423 public:
3424 // args declaration
3427 size_t m_size;
3429 uintptr_t m_remote_disp;
3443
3444 // constructor
3445 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) {}
3446
3447 // setter
3448 inline post_put_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3449 inline post_put_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3450 inline post_put_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3451 inline post_put_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3452 inline post_put_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
3453 inline post_put_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
3454 inline post_put_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3455 inline post_put_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3456 inline post_put_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3457 inline post_put_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3458 inline post_put_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3459 inline post_put_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3460 inline post_put_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3461 inline post_put_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
3462 inline post_put_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3463 inline post_put_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3464 inline post_put_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3465 inline post_put_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3466
3468 status_t call() const;
3469 inline status_t operator()() const { return call(); }
3470};
3471
3472inline 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) {
3473 return post_put_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_disp_in, rmr_in).call();
3474}
3475
3476
3502
3508 public:
3509 // args declaration
3512 size_t m_size;
3514 uintptr_t m_remote_disp;
3528
3529 // constructor
3530 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) {}
3531
3532 // setter
3533 inline post_get_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3534 inline post_get_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3535 inline post_get_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3536 inline post_get_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3537 inline post_get_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
3538 inline post_get_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
3539 inline post_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3540 inline post_get_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3541 inline post_get_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3542 inline post_get_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3543 inline post_get_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3544 inline post_get_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3545 inline post_get_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3546 inline post_get_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
3547 inline post_get_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3548 inline post_get_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3549 inline post_get_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3550 inline post_get_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3551
3553 status_t call() const;
3554 inline status_t operator()() const { return call(); }
3555};
3556
3557inline 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) {
3558 return post_get_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_disp_in, rmr_in).call();
3559}
3560
3561
3572
3578 public:
3579 // args declaration
3583
3584 // constructor
3586
3587 // setter
3588 inline progress_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3589 inline progress_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3590 inline progress_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3591
3593 error_t call() const;
3594 inline error_t operator()() const { return call(); }
3595};
3596
3598 return progress_x().call();
3599}
3600
3601
3611
3617 public:
3618 // args declaration
3621
3622 // constructor
3624
3625 // setter
3626 inline test_drained_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3627 inline test_drained_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3628
3630 error_t call() const;
3631 inline error_t operator()() const { return call(); }
3632};
3633
3635 return test_drained_x().call();
3636}
3637
3638
3648
3654 public:
3655 // args declaration
3658
3659 // constructor
3661
3662 // setter
3663 inline wait_drained_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3664 inline wait_drained_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3665
3667 void call() const;
3668 inline void operator()() const { return call(); }
3669};
3670
3671inline void wait_drained() {
3672 return wait_drained_x().call();
3673}
3674
3675
3676} // namespace lci
3677
3678#endif // LCI_BINDING_POST_HPP_
The actual implementation for allgather.
Definition lci_binding_post.hpp:2022
allgather_x && size(size_t size_in)
Definition lci_binding_post.hpp:2039
allgather_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2038
void * m_recvbuf
Definition lci_binding_post.hpp:2026
size_t m_size
Definition lci_binding_post.hpp:2027
void call() const
Definition binding.cpp:596
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2028
const void * m_sendbuf
Definition lci_binding_post.hpp:2025
allgather_x && device(device_t device_in)
Definition lci_binding_post.hpp:2041
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2031
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2030
allgather_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2040
allgather_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2042
allgather_x(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:2034
allgather_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2043
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:2029
void operator()() const
Definition lci_binding_post.hpp:2047
allgather_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2037
The actual implementation for alloc_counter.
Definition lci_binding_post.hpp:1215
alloc_counter_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1226
alloc_counter_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1228
option_t< const char * > m_name
Definition lci_binding_post.hpp:1219
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1218
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1220
comp_t operator()() const
Definition lci_binding_post.hpp:1232
comp_t call_impl(runtime_t runtime, const char *name, void *user_context) const
comp_t call() const
Definition binding.cpp:436
alloc_counter_x && name(const char *name_in)
Definition lci_binding_post.hpp:1227
alloc_counter_x()
Definition lci_binding_post.hpp:1223
The actual implementation for alloc_cq.
Definition lci_binding_post.hpp:1335
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1338
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:1340
alloc_cq_x && cq_type(attr_cq_type_t cq_type_in)
Definition lci_binding_post.hpp:1352
alloc_cq_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:1351
comp_t operator()() const
Definition lci_binding_post.hpp:1358
option_t< int > m_default_length
Definition lci_binding_post.hpp:1339
option_t< attr_cq_type_t > m_cq_type
Definition lci_binding_post.hpp:1341
alloc_cq_x && default_length(int default_length_in)
Definition lci_binding_post.hpp:1350
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:1353
alloc_cq_x()
Definition lci_binding_post.hpp:1346
comp_t call() const
Definition binding.cpp:456
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1343
alloc_cq_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1354
option_t< const char * > m_name
Definition lci_binding_post.hpp:1342
alloc_cq_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1349
The actual implementation for alloc_device.
Definition lci_binding_post.hpp:2252
alloc_device_x && alloc_default_endpoint(bool alloc_default_endpoint_in)
Definition lci_binding_post.hpp:2285
alloc_device_x && shm_ring_size(size_t shm_ring_size_in)
Definition lci_binding_post.hpp:2289
option_t< size_t > m_shm_slot_size
Definition lci_binding_post.hpp:2265
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, bool shm_enable, size_t shm_ring_size, size_t shm_slot_size, size_t shm_producer_cas_attempts, size_t shm_consumer_cas_attempts, size_t shm_max_polls, 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()
Definition lci_binding_post.hpp:2277
option_t< bool > m_use_reg_cache
Definition lci_binding_post.hpp:2262
option_t< const char * > m_name
Definition lci_binding_post.hpp:2270
option_t< bool > m_alloc_progress_endpoint
Definition lci_binding_post.hpp:2261
option_t< net_context_t > m_net_context
Definition lci_binding_post.hpp:2273
alloc_device_x && net_max_recvs(size_t net_max_recvs_in)
Definition lci_binding_post.hpp:2281
option_t< size_t > m_shm_ring_size
Definition lci_binding_post.hpp:2264
option_t< attr_ibv_td_strategy_t > m_ibv_td_strategy
Definition lci_binding_post.hpp:2269
alloc_device_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2296
option_t< size_t > m_net_max_recvs
Definition lci_binding_post.hpp:2256
alloc_device_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:2299
alloc_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2297
alloc_device_x && use_reg_cache(bool use_reg_cache_in)
Definition lci_binding_post.hpp:2287
alloc_device_x && name(const char *name_in)
Definition lci_binding_post.hpp:2295
option_t< double > m_net_send_reserved_pct
Definition lci_binding_post.hpp:2258
alloc_device_x && ofi_lock_mode(uint64_t ofi_lock_mode_in)
Definition lci_binding_post.hpp:2284
option_t< uint64_t > m_ofi_lock_mode
Definition lci_binding_post.hpp:2259
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2271
option_t< size_t > m_net_max_sends
Definition lci_binding_post.hpp:2255
option_t< bool > m_shm_enable
Definition lci_binding_post.hpp:2263
alloc_device_x && net_send_reserved_pct(double net_send_reserved_pct_in)
Definition lci_binding_post.hpp:2283
option_t< size_t > m_shm_producer_cas_attempts
Definition lci_binding_post.hpp:2266
alloc_device_x && shm_slot_size(size_t shm_slot_size_in)
Definition lci_binding_post.hpp:2290
alloc_device_x && shm_consumer_cas_attempts(size_t shm_consumer_cas_attempts_in)
Definition lci_binding_post.hpp:2292
alloc_device_x && shm_producer_cas_attempts(size_t shm_producer_cas_attempts_in)
Definition lci_binding_post.hpp:2291
alloc_device_x && alloc_progress_endpoint(bool alloc_progress_endpoint_in)
Definition lci_binding_post.hpp:2286
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:2274
option_t< size_t > m_net_max_cqes
Definition lci_binding_post.hpp:2257
alloc_device_x && net_context(net_context_t net_context_in)
Definition lci_binding_post.hpp:2298
option_t< bool > m_alloc_default_endpoint
Definition lci_binding_post.hpp:2260
alloc_device_x && shm_max_polls(size_t shm_max_polls_in)
Definition lci_binding_post.hpp:2293
option_t< size_t > m_shm_consumer_cas_attempts
Definition lci_binding_post.hpp:2267
device_t operator()() const
Definition lci_binding_post.hpp:2303
device_t call() const
Definition binding.cpp:678
alloc_device_x && net_max_cqes(size_t net_max_cqes_in)
Definition lci_binding_post.hpp:2282
alloc_device_x && ibv_td_strategy(attr_ibv_td_strategy_t ibv_td_strategy_in)
Definition lci_binding_post.hpp:2294
option_t< size_t > m_shm_max_polls
Definition lci_binding_post.hpp:2268
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2272
alloc_device_x && shm_enable(bool shm_enable_in)
Definition lci_binding_post.hpp:2288
alloc_device_x && net_max_sends(size_t net_max_sends_in)
Definition lci_binding_post.hpp:2280
The actual implementation for alloc_endpoint.
Definition lci_binding_post.hpp:2481
endpoint_t call() const
Definition binding.cpp:737
alloc_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2495
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:2485
alloc_endpoint_x()
Definition lci_binding_post.hpp:2490
option_t< device_t > m_device
Definition lci_binding_post.hpp:2487
option_t< const char * > m_name
Definition lci_binding_post.hpp:2484
alloc_endpoint_x && device(device_t device_in)
Definition lci_binding_post.hpp:2496
endpoint_t operator()() const
Definition lci_binding_post.hpp:2500
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2486
alloc_endpoint_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2494
alloc_endpoint_x && name(const char *name_in)
Definition lci_binding_post.hpp:2493
The actual implementation for alloc_graph.
Definition lci_binding_post.hpp:1465
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1471
alloc_graph_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1480
comp_t call() const
Definition binding.cpp:481
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1470
alloc_graph_x && name(const char *name_in)
Definition lci_binding_post.hpp:1478
alloc_graph_x()
Definition lci_binding_post.hpp:1474
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:1479
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:1468
alloc_graph_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1477
comp_t operator()() const
Definition lci_binding_post.hpp:1484
option_t< const char * > m_name
Definition lci_binding_post.hpp:1469
The actual implementation for alloc_handler.
Definition lci_binding_post.hpp:1420
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:1424
option_t< const char * > m_name
Definition lci_binding_post.hpp:1426
alloc_handler_x && handler(comp_handler_t handler_in)
Definition lci_binding_post.hpp:1433
alloc_handler_x(comp_handler_t handler_in)
Definition lci_binding_post.hpp:1430
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1427
comp_t call() const
Definition binding.cpp:472
comp_t operator()() const
Definition lci_binding_post.hpp:1441
alloc_handler_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:1435
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:1425
alloc_handler_x && name(const char *name_in)
Definition lci_binding_post.hpp:1436
alloc_handler_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1437
alloc_handler_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1434
comp_handler_t m_handler
Definition lci_binding_post.hpp:1423
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:304
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:2138
alloc_net_context_x && ofi_provider_name(std::string ofi_provider_name_in)
Definition lci_binding_post.hpp:2160
option_t< int > m_ibv_gid_idx
Definition lci_binding_post.hpp:2145
alloc_net_context_x && device_name(std::string device_name_in)
Definition lci_binding_post.hpp:2165
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2153
alloc_net_context_x && ibv_prefetch_strategy(attr_ibv_prefetch_strategy_t ibv_prefetch_strategy_in)
Definition lci_binding_post.hpp:2167
alloc_net_context_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2171
option_t< attr_ibv_odp_strategy_t > m_ibv_odp_strategy
Definition lci_binding_post.hpp:2148
alloc_net_context_x && ibv_gid_idx(int ibv_gid_idx_in)
Definition lci_binding_post.hpp:2163
alloc_net_context_x()
Definition lci_binding_post.hpp:2156
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:2162
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2152
alloc_net_context_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2170
option_t< bool > m_use_dmabuf
Definition lci_binding_post.hpp:2150
alloc_net_context_x && backend(attr_backend_t backend_in)
Definition lci_binding_post.hpp:2159
option_t< std::string > m_device_name
Definition lci_binding_post.hpp:2147
option_t< const char * > m_name
Definition lci_binding_post.hpp:2151
alloc_net_context_x && ibv_force_gid_auto_select(bool ibv_force_gid_auto_select_in)
Definition lci_binding_post.hpp:2164
alloc_net_context_x && name(const char *name_in)
Definition lci_binding_post.hpp:2169
alloc_net_context_x && ibv_odp_strategy(attr_ibv_odp_strategy_t ibv_odp_strategy_in)
Definition lci_binding_post.hpp:2166
alloc_net_context_x && use_dmabuf(bool use_dmabuf_in)
Definition lci_binding_post.hpp:2168
option_t< attr_backend_t > m_backend
Definition lci_binding_post.hpp:2141
alloc_net_context_x && max_msg_size(size_t max_msg_size_in)
Definition lci_binding_post.hpp:2161
net_context_t call() const
Definition binding.cpp:635
option_t< std::string > m_ofi_provider_name
Definition lci_binding_post.hpp:2142
option_t< bool > m_ibv_force_gid_auto_select
Definition lci_binding_post.hpp:2146
option_t< size_t > m_max_inject_size
Definition lci_binding_post.hpp:2144
net_context_t operator()() const
Definition lci_binding_post.hpp:2175
option_t< size_t > m_max_msg_size
Definition lci_binding_post.hpp:2143
option_t< attr_ibv_prefetch_strategy_t > m_ibv_prefetch_strategy
Definition lci_binding_post.hpp:2149
The actual implementation for alloc_packet_pool.
Definition lci_binding_post.hpp:250
packet_pool_t call() const
Definition binding.cpp:258
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:207
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:1085
comp_t operator()() const
Definition lci_binding_post.hpp:1106
option_t< int > m_threshold
Definition lci_binding_post.hpp:1089
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1092
alloc_sync_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1102
alloc_sync_x && threshold(int threshold_in)
Definition lci_binding_post.hpp:1099
alloc_sync_x && name(const char *name_in)
Definition lci_binding_post.hpp:1101
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:1090
alloc_sync_x()
Definition lci_binding_post.hpp:1095
option_t< const char * > m_name
Definition lci_binding_post.hpp:1091
alloc_sync_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:1100
alloc_sync_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1098
comp_t call() const
Definition binding.cpp:411
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1088
The actual implementation for allreduce.
Definition lci_binding_post.hpp:1960
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:1983
void operator()() const
Definition lci_binding_post.hpp:1995
const void * m_sendbuf
Definition lci_binding_post.hpp:1963
option_t< device_t > m_device
Definition lci_binding_post.hpp:1969
allreduce_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:1980
reduce_op_t m_op
Definition lci_binding_post.hpp:1967
void * m_recvbuf
Definition lci_binding_post.hpp:1964
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:1974
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:1977
allreduce_x && device(device_t device_in)
Definition lci_binding_post.hpp:1986
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1971
size_t m_count
Definition lci_binding_post.hpp:1965
allreduce_x && count(size_t count_in)
Definition lci_binding_post.hpp:1982
allreduce_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:1981
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1970
allreduce_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1987
option_t< allreduce_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:1973
allreduce_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:1984
allreduce_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1985
allreduce_x && algorithm(allreduce_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:1990
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1968
allreduce_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:1991
size_t m_item_size
Definition lci_binding_post.hpp:1966
allreduce_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1989
void call() const
Definition binding.cpp:580
allreduce_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1988
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:1972
The actual implementation for alltoall.
Definition lci_binding_post.hpp:2076
const void * m_sendbuf
Definition lci_binding_post.hpp:2079
void call() const
Definition binding.cpp:607
alltoall_x && device(device_t device_in)
Definition lci_binding_post.hpp:2097
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_t comp, comp_semantic_t comp_semantic) const
alltoall_x && size(size_t size_in)
Definition lci_binding_post.hpp:2095
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2085
alltoall_x(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:2090
void * m_recvbuf
Definition lci_binding_post.hpp:2080
alltoall_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2094
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2086
option_t< device_t > m_device
Definition lci_binding_post.hpp:2083
alltoall_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2099
alltoall_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2098
alltoall_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2096
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2082
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2084
alltoall_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2093
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:2087
alltoall_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:2101
size_t m_size
Definition lci_binding_post.hpp:2081
alltoall_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2100
void operator()() const
Definition lci_binding_post.hpp:2105
The actual implementation for barrier.
Definition lci_binding_post.hpp:1716
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:1724
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1722
barrier_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1733
barrier_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1735
barrier_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:1734
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:1720
void call() const
Definition binding.cpp:526
barrier_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1732
barrier_x()
Definition lci_binding_post.hpp:1727
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1721
barrier_x && device(device_t device_in)
Definition lci_binding_post.hpp:1731
void operator()() const
Definition lci_binding_post.hpp:1739
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:1723
barrier_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1730
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1719
The actual implementation for broadcast.
Definition lci_binding_post.hpp:1769
broadcast_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1793
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1777
void call() const
Definition binding.cpp:536
void operator()() const
Definition lci_binding_post.hpp:1800
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1778
int m_root
Definition lci_binding_post.hpp:1774
broadcast_x && root(int root_in)
Definition lci_binding_post.hpp:1789
broadcast_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1794
broadcast_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1790
broadcast_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:1796
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1775
broadcast_x && size(size_t size_in)
Definition lci_binding_post.hpp:1788
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:1781
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:1779
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:1784
broadcast_x && device(device_t device_in)
Definition lci_binding_post.hpp:1791
option_t< broadcast_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:1780
void * m_buffer
Definition lci_binding_post.hpp:1772
option_t< device_t > m_device
Definition lci_binding_post.hpp:1776
broadcast_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1787
broadcast_x && algorithm(broadcast_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:1795
broadcast_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1792
size_t m_size
Definition lci_binding_post.hpp:1773
The actual implementation for comp_signal.
Definition lci_binding_post.hpp:929
comp_signal_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:942
comp_signal_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:940
status_t m_status
Definition lci_binding_post.hpp:933
comp_t m_comp
Definition lci_binding_post.hpp:932
void call() const
Definition binding.cpp:385
comp_signal_x(comp_t comp_in, status_t status_in)
Definition lci_binding_post.hpp:937
void call_impl(comp_t comp, status_t status, runtime_t runtime) const
void operator()() const
Definition lci_binding_post.hpp:946
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:934
comp_signal_x && status(status_t status_in)
Definition lci_binding_post.hpp:941
The actual implementation for RESOURCE comp.
Definition lci_binding_pre.hpp:352
The actual implementation for counter_get.
Definition lci_binding_post.hpp:1254
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1258
int64_t call_impl(comp_t comp, runtime_t runtime) const
int64_t operator()() const
Definition lci_binding_post.hpp:1269
counter_get_x(comp_t comp_in)
Definition lci_binding_post.hpp:1261
int64_t call() const
Definition binding.cpp:443
counter_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1265
comp_t m_comp
Definition lci_binding_post.hpp:1257
counter_get_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1264
The actual implementation for counter_set.
Definition lci_binding_post.hpp:1292
counter_set_x(comp_t comp_in, int64_t value_in)
Definition lci_binding_post.hpp:1300
int64_t m_value
Definition lci_binding_post.hpp:1296
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1297
comp_t m_comp
Definition lci_binding_post.hpp:1295
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:1305
counter_set_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1303
void operator()() const
Definition lci_binding_post.hpp:1309
counter_set_x && value(int64_t value_in)
Definition lci_binding_post.hpp:1304
void call() const
Definition binding.cpp:449
The actual implementation for cq_pop.
Definition lci_binding_post.hpp:1380
status_t operator()() const
Definition lci_binding_post.hpp:1395
comp_t m_comp
Definition lci_binding_post.hpp:1383
status_t call_impl(comp_t comp, runtime_t runtime) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1384
cq_pop_x(comp_t comp_in)
Definition lci_binding_post.hpp:1387
cq_pop_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1390
cq_pop_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1391
status_t call() const
Definition binding.cpp:466
The actual implementation for deregister_memory.
Definition lci_binding_post.hpp:2405
void operator()() const
Definition lci_binding_post.hpp:2420
void call() const
Definition binding.cpp:720
mr_t * m_mr
Definition lci_binding_post.hpp:2408
deregister_memory_x && mr(mr_t *mr_in)
Definition lci_binding_post.hpp:2415
deregister_memory_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2416
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2409
void call_impl(mr_t *mr, runtime_t runtime) const
deregister_memory_x(mr_t *mr_in)
Definition lci_binding_post.hpp:2412
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:280
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:1045
deregister_rcomp_x(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:1052
void operator()() const
Definition lci_binding_post.hpp:1060
rcomp_t m_rcomp
Definition lci_binding_post.hpp:1048
void call_impl(rcomp_t rcomp, runtime_t runtime) const
void call() const
Definition binding.cpp:405
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1049
deregister_rcomp_x && rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:1055
deregister_rcomp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1056
The actual implementation for RESOURCE device.
Definition lci_binding_pre.hpp:461
The actual implementation for RESOURCE endpoint.
Definition lci_binding_pre.hpp:544
The actual implementation for free_comp.
Definition lci_binding_post.hpp:891
free_comp_x(comp_t *comp_in)
Definition lci_binding_post.hpp:898
free_comp_x && comp(comp_t *comp_in)
Definition lci_binding_post.hpp:901
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:895
comp_t * m_comp
Definition lci_binding_post.hpp:894
void call() const
Definition binding.cpp:379
free_comp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:902
void operator()() const
Definition lci_binding_post.hpp:906
void call_impl(comp_t *comp, runtime_t runtime) const
The actual implementation for free_device.
Definition lci_binding_post.hpp:2325
void call_impl(device_t *device, runtime_t runtime) const
free_device_x && device(device_t *device_in)
Definition lci_binding_post.hpp:2335
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2329
device_t * m_device
Definition lci_binding_post.hpp:2328
void operator()() const
Definition lci_binding_post.hpp:2340
void call() const
Definition binding.cpp:702
free_device_x(device_t *device_in)
Definition lci_binding_post.hpp:2332
free_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2336
The actual implementation for free_endpoint.
Definition lci_binding_post.hpp:2522
void operator()() const
Definition lci_binding_post.hpp:2537
endpoint_t * m_endpoint
Definition lci_binding_post.hpp:2525
free_endpoint_x && endpoint(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:2532
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2526
free_endpoint_x(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:2529
void call_impl(endpoint_t *endpoint, runtime_t runtime) const
void call() const
Definition binding.cpp:745
free_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2533
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:312
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:2197
void operator()() const
Definition lci_binding_post.hpp:2212
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:2208
free_net_context_x(net_context_t *net_context_in)
Definition lci_binding_post.hpp:2204
void call() const
Definition binding.cpp:652
net_context_t * m_net_context
Definition lci_binding_post.hpp:2200
free_net_context_x && net_context(net_context_t *net_context_in)
Definition lci_binding_post.hpp:2207
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2201
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:267
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:222
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:243
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:228
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:333
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:343
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:348
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:359
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:338
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:354
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:248
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:364
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:2442
get_rmr_x(mr_t mr_in)
Definition lci_binding_post.hpp:2449
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2446
get_rmr_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:2452
rmr_t operator()() const
Definition lci_binding_post.hpp:2457
mr_t m_mr
Definition lci_binding_post.hpp:2445
rmr_t call() const
Definition binding.cpp:726
get_rmr_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2453
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:287
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:1555
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:1558
void call() const
Definition binding.cpp:498
graph_add_edge_x(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in)
Definition lci_binding_post.hpp:1565
graph_add_edge_x && dst(graph_node_t dst_in)
Definition lci_binding_post.hpp:1570
graph_add_edge_x && fn(graph_edge_run_cb_t fn_in)
Definition lci_binding_post.hpp:1571
void operator()() const
Definition lci_binding_post.hpp:1576
option_t< graph_edge_run_cb_t > m_fn
Definition lci_binding_post.hpp:1561
graph_add_edge_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1568
graph_node_t m_dst
Definition lci_binding_post.hpp:1560
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1562
graph_add_edge_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1572
graph_add_edge_x && src(graph_node_t src_in)
Definition lci_binding_post.hpp:1569
graph_node_t m_src
Definition lci_binding_post.hpp:1559
The actual implementation for graph_add_node.
Definition lci_binding_post.hpp:1509
option_t< void * > m_value
Definition lci_binding_post.hpp:1514
graph_node_t operator()() const
Definition lci_binding_post.hpp:1530
graph_add_node_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1526
graph_node_t call() const
Definition binding.cpp:489
graph_add_node_x(comp_t comp_in, graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:1519
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:1523
graph_node_run_cb_t m_fn
Definition lci_binding_post.hpp:1513
comp_t m_comp
Definition lci_binding_post.hpp:1512
graph_add_node_x && free_cb(graph_node_free_cb_t free_cb_in)
Definition lci_binding_post.hpp:1525
graph_add_node_x && value(void *value_in)
Definition lci_binding_post.hpp:1524
option_t< graph_node_free_cb_t > m_free_cb
Definition lci_binding_post.hpp:1515
graph_add_node_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1522
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1516
The actual implementation for graph_node_mark_complete.
Definition lci_binding_post.hpp:1599
void operator()() const
Definition lci_binding_post.hpp:1616
void call() const
Definition binding.cpp:507
graph_node_t m_node
Definition lci_binding_post.hpp:1602
graph_node_mark_complete_x(graph_node_t node_in)
Definition lci_binding_post.hpp:1607
option_t< status_t > m_status
Definition lci_binding_post.hpp:1603
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:1610
graph_node_mark_complete_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1612
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1604
graph_node_mark_complete_x && status(status_t status_in)
Definition lci_binding_post.hpp:1611
The actual implementation for graph_start.
Definition lci_binding_post.hpp:1638
graph_start_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1649
comp_t m_comp
Definition lci_binding_post.hpp:1641
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1642
graph_start_x(comp_t comp_in)
Definition lci_binding_post.hpp:1645
void call_impl(comp_t comp, runtime_t runtime) const
void call() const
Definition binding.cpp:514
void operator()() const
Definition lci_binding_post.hpp:1653
graph_start_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1648
The actual implementation for graph_test.
Definition lci_binding_post.hpp:1675
comp_t m_comp
Definition lci_binding_post.hpp:1678
status_t call_impl(comp_t comp, runtime_t runtime) const
graph_test_x(comp_t comp_in)
Definition lci_binding_post.hpp:1682
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1679
graph_test_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1686
status_t operator()() const
Definition lci_binding_post.hpp:1690
status_t call() const
Definition binding.cpp:520
graph_test_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1685
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:318
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:313
The actual implementation for RESOURCE mr.
Definition lci_binding_pre.hpp:510
The actual implementation for RESOURCE net_context.
Definition lci_binding_pre.hpp:401
The actual implementation for net_poll_cq.
Definition lci_binding_post.hpp:2561
net_poll_cq_x && device(device_t device_in)
Definition lci_binding_post.hpp:2576
net_poll_cq_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2575
option_t< device_t > m_device
Definition lci_binding_post.hpp:2567
net_poll_cq_x(size_t max_polls_in, net_status_t *statuses_in)
Definition lci_binding_post.hpp:2570
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2566
net_poll_cq_x && statuses(net_status_t *statuses_in)
Definition lci_binding_post.hpp:2574
size_t operator()() const
Definition lci_binding_post.hpp:2580
size_t call() const
Definition binding.cpp:751
net_poll_cq_x && max_polls(size_t max_polls_in)
Definition lci_binding_post.hpp:2573
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:2564
net_status_t * m_statuses
Definition lci_binding_post.hpp:2565
The actual implementation for net_post_get.
Definition lci_binding_post.hpp:3016
net_post_get_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:3035
net_post_get_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3042
net_post_get_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:3039
option_t< device_t > m_device
Definition lci_binding_post.hpp:3026
int m_rank
Definition lci_binding_post.hpp:3019
net_post_get_x && device(device_t device_in)
Definition lci_binding_post.hpp:3041
net_post_get_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3037
error_t operator()() const
Definition lci_binding_post.hpp:3047
net_post_get_x && size(size_t size_in)
Definition lci_binding_post.hpp:3036
error_t call() const
Definition binding.cpp:850
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3025
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3027
mr_t m_mr
Definition lci_binding_post.hpp:3022
void * m_buffer
Definition lci_binding_post.hpp:3020
net_post_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3040
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:3023
net_post_get_x && rank(int rank_in)
Definition lci_binding_post.hpp:3034
rmr_t m_rmr
Definition lci_binding_post.hpp:3024
size_t m_size
Definition lci_binding_post.hpp:3021
net_post_get_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3043
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3028
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:3031
net_post_get_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:3038
The actual implementation for net_post_putImm.
Definition lci_binding_post.hpp:2953
net_post_putImm_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2980
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:2969
rmr_t m_rmr
Definition lci_binding_post.hpp:2961
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2962
net_post_putImm_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:2975
net_post_putImm_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:2977
error_t call() const
Definition binding.cpp:835
net_post_putImm_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:2981
int m_rank
Definition lci_binding_post.hpp:2956
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:2965
net_post_putImm_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2978
option_t< device_t > m_device
Definition lci_binding_post.hpp:2963
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2964
mr_t m_mr
Definition lci_binding_post.hpp:2959
net_post_putImm_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:2973
void * m_buffer
Definition lci_binding_post.hpp:2957
net_post_putImm_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2982
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2966
error_t operator()() const
Definition lci_binding_post.hpp:2986
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:2958
net_post_putImm_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:2976
uint64_t m_offset
Definition lci_binding_post.hpp:2960
net_post_putImm_x && size(size_t size_in)
Definition lci_binding_post.hpp:2974
net_post_putImm_x && rank(int rank_in)
Definition lci_binding_post.hpp:2972
net_post_putImm_x && device(device_t device_in)
Definition lci_binding_post.hpp:2979
The actual implementation for net_post_putImms.
Definition lci_binding_post.hpp:2891
net_post_putImms_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:2910
net_post_putImms_x && device(device_t device_in)
Definition lci_binding_post.hpp:2915
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2901
option_t< device_t > m_device
Definition lci_binding_post.hpp:2900
net_post_putImms_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:2913
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:2909
uint64_t m_offset
Definition lci_binding_post.hpp:2897
void * m_buffer
Definition lci_binding_post.hpp:2895
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:2902
int m_rank
Definition lci_binding_post.hpp:2894
error_t operator()() const
Definition lci_binding_post.hpp:2922
net_post_putImms_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:2912
error_t call() const
Definition binding.cpp:821
rmr_t m_rmr
Definition lci_binding_post.hpp:2898
net_post_putImms_x && size(size_t size_in)
Definition lci_binding_post.hpp:2911
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2903
net_post_putImms_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2916
net_post_putImms_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:2917
size_t m_size
Definition lci_binding_post.hpp:2896
net_post_putImms_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2914
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2899
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:2906
net_post_putImms_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2918
The actual implementation for net_post_put.
Definition lci_binding_post.hpp:2830
rmr_t m_rmr
Definition lci_binding_post.hpp:2838
net_post_put_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:2849
mr_t m_mr
Definition lci_binding_post.hpp:2836
net_post_put_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:2853
int m_rank
Definition lci_binding_post.hpp:2833
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:2845
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:2839
error_t call() const
Definition binding.cpp:807
net_post_put_x && rank(int rank_in)
Definition lci_binding_post.hpp:2848
option_t< device_t > m_device
Definition lci_binding_post.hpp:2840
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2841
net_post_put_x && device(device_t device_in)
Definition lci_binding_post.hpp:2855
net_post_put_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2857
net_post_put_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2856
net_post_put_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:2851
net_post_put_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:2852
net_post_put_x && size(size_t size_in)
Definition lci_binding_post.hpp:2850
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2842
size_t m_size
Definition lci_binding_post.hpp:2835
net_post_put_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2854
error_t operator()() const
Definition lci_binding_post.hpp:2861
uint64_t m_offset
Definition lci_binding_post.hpp:2837
void * m_buffer
Definition lci_binding_post.hpp:2834
The actual implementation for net_post_puts.
Definition lci_binding_post.hpp:2771
net_post_puts_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:2792
net_post_puts_x && rank(int rank_in)
Definition lci_binding_post.hpp:2788
error_t operator()() const
Definition lci_binding_post.hpp:2800
net_post_puts_x && size(size_t size_in)
Definition lci_binding_post.hpp:2790
option_t< device_t > m_device
Definition lci_binding_post.hpp:2780
void * m_buffer
Definition lci_binding_post.hpp:2775
net_post_puts_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:2791
net_post_puts_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2793
net_post_puts_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:2789
net_post_puts_x && device(device_t device_in)
Definition lci_binding_post.hpp:2794
error_t call() const
Definition binding.cpp:794
int m_rank
Definition lci_binding_post.hpp:2774
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:2785
rmr_t m_rmr
Definition lci_binding_post.hpp:2778
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2779
size_t m_size
Definition lci_binding_post.hpp:2776
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2782
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:2796
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2781
net_post_puts_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2795
uint64_t m_offset
Definition lci_binding_post.hpp:2777
The actual implementation for net_post_recv.
Definition lci_binding_post.hpp:2606
net_post_recv_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2623
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2614
net_post_recv_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:2620
error_t call() const
Definition binding.cpp:759
net_post_recv_x(void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:2617
net_post_recv_x && size(size_t size_in)
Definition lci_binding_post.hpp:2621
net_post_recv_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:2622
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2612
option_t< device_t > m_device
Definition lci_binding_post.hpp:2613
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:2611
size_t m_size
Definition lci_binding_post.hpp:2610
error_t operator()() const
Definition lci_binding_post.hpp:2629
net_post_recv_x && device(device_t device_in)
Definition lci_binding_post.hpp:2624
void * m_buffer
Definition lci_binding_post.hpp:2609
net_post_recv_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2625
The actual implementation for net_post_send.
Definition lci_binding_post.hpp:2713
net_post_send_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:2737
net_post_send_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2734
net_post_send_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:2731
void * m_buffer
Definition lci_binding_post.hpp:2717
int m_rank
Definition lci_binding_post.hpp:2716
mr_t m_mr
Definition lci_binding_post.hpp:2719
size_t m_size
Definition lci_binding_post.hpp:2718
net_post_send_x && size(size_t size_in)
Definition lci_binding_post.hpp:2732
error_t call() const
Definition binding.cpp:781
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2720
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:2723
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2722
net_post_send_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:2733
net_post_send_x && device(device_t device_in)
Definition lci_binding_post.hpp:2735
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2724
net_post_send_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2736
net_post_send_x(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:2727
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:2721
error_t operator()() const
Definition lci_binding_post.hpp:2742
net_post_send_x && rank(int rank_in)
Definition lci_binding_post.hpp:2730
net_post_send_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2738
The actual implementation for net_post_sends.
Definition lci_binding_post.hpp:2657
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2667
net_post_sends_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:2679
net_post_sends_x && size(size_t size_in)
Definition lci_binding_post.hpp:2675
error_t call() const
Definition binding.cpp:769
option_t< device_t > m_device
Definition lci_binding_post.hpp:2664
net_post_sends_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2678
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:2660
net_post_sends_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2676
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:2666
net_post_sends_x(int rank_in, void *buffer_in, size_t size_in)
Definition lci_binding_post.hpp:2670
net_post_sends_x && rank(int rank_in)
Definition lci_binding_post.hpp:2673
void * m_buffer
Definition lci_binding_post.hpp:2661
net_post_sends_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2680
error_t operator()() const
Definition lci_binding_post.hpp:2684
net_post_sends_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:2674
size_t m_size
Definition lci_binding_post.hpp:2662
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2665
net_post_sends_x && device(device_t device_in)
Definition lci_binding_post.hpp:2677
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2663
The actual implementation for RESOURCE packet_pool.
Definition lci_binding_pre.hpp:277
The actual implementation for post_am.
Definition lci_binding_post.hpp:3177
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3190
option_t< device_t > m_device
Definition lci_binding_post.hpp:3186
post_am_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3209
rcomp_t m_remote_comp
Definition lci_binding_post.hpp:3184
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:3191
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3194
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:3198
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3187
post_am_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3214
post_am_x && size(size_t size_in)
Definition lci_binding_post.hpp:3203
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3195
post_am_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3206
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3185
post_am_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3212
int m_rank
Definition lci_binding_post.hpp:3180
post_am_x && rank(int rank_in)
Definition lci_binding_post.hpp:3201
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3188
post_am_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3210
status_t call() const
Definition binding.cpp:889
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3189
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:3211
comp_t m_local_comp
Definition lci_binding_post.hpp:3183
post_am_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3216
post_am_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3215
post_am_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3202
size_t m_size
Definition lci_binding_post.hpp:3182
post_am_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3208
post_am_x && device(device_t device_in)
Definition lci_binding_post.hpp:3207
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3193
post_am_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3213
void * m_local_buffer
Definition lci_binding_post.hpp:3181
post_am_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3204
status_t operator()() const
Definition lci_binding_post.hpp:3220
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3192
post_am_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:3205
The actual implementation for post_comm.
Definition lci_binding_post.hpp:3088
status_t call() const
Definition binding.cpp:864
void * m_local_buffer
Definition lci_binding_post.hpp:3093
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3107
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:3108
post_comm_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:3132
option_t< device_t > m_device
Definition lci_binding_post.hpp:3097
post_comm_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3126
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3111
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:3092
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:3100
post_comm_x && rank(int rank_in)
Definition lci_binding_post.hpp:3118
post_comm_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3122
post_comm_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3119
size_t m_size
Definition lci_binding_post.hpp:3094
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3096
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3102
comp_t m_local_comp
Definition lci_binding_post.hpp:3095
status_t operator()() const
Definition lci_binding_post.hpp:3141
option_t< rmr_t > m_rmr
Definition lci_binding_post.hpp:3104
post_comm_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3133
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3110
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:3114
option_t< uintptr_t > m_remote_disp
Definition lci_binding_post.hpp:3103
post_comm_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3125
post_comm_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3135
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3098
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:3106
post_comm_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3121
post_comm_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3131
post_comm_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:3130
post_comm_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3128
post_comm_x && direction(direction_t direction_in)
Definition lci_binding_post.hpp:3117
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3109
post_comm_x && size(size_t size_in)
Definition lci_binding_post.hpp:3120
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3099
post_comm_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3124
post_comm_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3136
post_comm_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3127
post_comm_x && device(device_t device_in)
Definition lci_binding_post.hpp:3123
post_comm_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3137
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3101
post_comm_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:3134
direction_t m_direction
Definition lci_binding_post.hpp:3091
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:3105
post_comm_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:3129
The actual implementation for post_get.
Definition lci_binding_post.hpp:3507
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:3523
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3524
post_get_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3548
post_get_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3545
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3520
comp_t m_local_comp
Definition lci_binding_post.hpp:3513
post_get_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3543
post_get_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:3537
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:3530
post_get_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3544
status_t operator()() const
Definition lci_binding_post.hpp:3554
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3519
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3527
uintptr_t m_remote_disp
Definition lci_binding_post.hpp:3514
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:3511
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3525
option_t< device_t > m_device
Definition lci_binding_post.hpp:3517
post_get_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:3538
int m_rank
Definition lci_binding_post.hpp:3510
post_get_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3534
post_get_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:3546
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3516
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3526
post_get_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3549
post_get_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3542
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3518
post_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3539
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3521
post_get_x && size(size_t size_in)
Definition lci_binding_post.hpp:3535
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:3522
post_get_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3541
status_t call() const
Definition binding.cpp:973
post_get_x && rank(int rank_in)
Definition lci_binding_post.hpp:3533
post_get_x && device(device_t device_in)
Definition lci_binding_post.hpp:3540
post_get_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3536
post_get_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3547
size_t m_size
Definition lci_binding_post.hpp:3512
rmr_t m_rmr
Definition lci_binding_post.hpp:3515
post_get_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3550
The actual implementation for post_put.
Definition lci_binding_post.hpp:3422
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:3440
post_put_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3462
post_put_x && device(device_t device_in)
Definition lci_binding_post.hpp:3455
status_t operator()() const
Definition lci_binding_post.hpp:3469
post_put_x && rank(int rank_in)
Definition lci_binding_post.hpp:3448
post_put_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3454
post_put_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3456
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3441
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3433
comp_t m_local_comp
Definition lci_binding_post.hpp:3428
uintptr_t m_remote_disp
Definition lci_binding_post.hpp:3429
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3442
option_t< device_t > m_device
Definition lci_binding_post.hpp:3432
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3439
post_put_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3449
int m_rank
Definition lci_binding_post.hpp:3425
post_put_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3457
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:3438
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:3445
post_put_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3460
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3436
post_put_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3463
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:3437
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3435
post_put_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3458
status_t call() const
Definition binding.cpp:951
post_put_x && size(size_t size_in)
Definition lci_binding_post.hpp:3450
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3431
post_put_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3465
post_put_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:3453
post_put_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3451
post_put_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:3452
rmr_t m_rmr
Definition lci_binding_post.hpp:3430
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3434
size_t m_size
Definition lci_binding_post.hpp:3427
post_put_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:3461
post_put_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3459
void * m_local_buffer
Definition lci_binding_post.hpp:3426
post_put_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3464
The actual implementation for post_recv.
Definition lci_binding_post.hpp:3339
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3358
post_recv_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3379
size_t m_size
Definition lci_binding_post.hpp:3344
post_recv_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3378
post_recv_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3367
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3354
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:3351
tag_t m_tag
Definition lci_binding_post.hpp:3345
post_recv_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3372
post_recv_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3369
option_t< device_t > m_device
Definition lci_binding_post.hpp:3348
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3356
post_recv_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3374
post_recv_x && size(size_t size_in)
Definition lci_binding_post.hpp:3366
status_t operator()() const
Definition lci_binding_post.hpp:3384
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3350
post_recv_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3376
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3352
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3353
void * m_local_buffer
Definition lci_binding_post.hpp:3343
post_recv_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3371
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3349
post_recv_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3373
comp_t m_local_comp
Definition lci_binding_post.hpp:3346
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3357
post_recv_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3375
post_recv_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3380
post_recv_x && device(device_t device_in)
Definition lci_binding_post.hpp:3370
int m_rank
Definition lci_binding_post.hpp:3342
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:3361
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3347
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:3355
post_recv_x && rank(int rank_in)
Definition lci_binding_post.hpp:3364
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:3368
post_recv_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:3377
post_recv_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3365
status_t call() const
Definition binding.cpp:930
The actual implementation for post_send.
Definition lci_binding_post.hpp:3257
post_send_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3296
post_send_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3286
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3268
status_t call() const
Definition binding.cpp:909
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:3269
post_send_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3289
void * m_local_buffer
Definition lci_binding_post.hpp:3261
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3272
post_send_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3293
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3274
size_t m_size
Definition lci_binding_post.hpp:3262
int m_rank
Definition lci_binding_post.hpp:3260
post_send_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3283
tag_t m_tag
Definition lci_binding_post.hpp:3263
post_send_x && size(size_t size_in)
Definition lci_binding_post.hpp:3284
comp_t m_local_comp
Definition lci_binding_post.hpp:3264
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:3279
status_t operator()() const
Definition lci_binding_post.hpp:3302
post_send_x && rank(int rank_in)
Definition lci_binding_post.hpp:3282
post_send_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3287
post_send_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3298
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3271
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3267
post_send_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3291
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:3292
post_send_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3297
option_t< device_t > m_device
Definition lci_binding_post.hpp:3266
post_send_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3294
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3270
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:3273
post_send_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3285
post_send_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:3295
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3276
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3275
post_send_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3290
post_send_x && device(device_t device_in)
Definition lci_binding_post.hpp:3288
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3265
The actual implementation for progress.
Definition lci_binding_post.hpp:3577
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3580
error_t call() const
Definition binding.cpp:995
progress_x()
Definition lci_binding_post.hpp:3585
progress_x && device(device_t device_in)
Definition lci_binding_post.hpp:3589
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3582
option_t< device_t > m_device
Definition lci_binding_post.hpp:3581
error_t operator()() const
Definition lci_binding_post.hpp:3594
progress_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3588
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:3590
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:293
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:1893
reduce_scatter_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:1914
reduce_scatter_x && item_size(size_t item_size_in)
Definition lci_binding_post.hpp:1916
reduce_scatter_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1921
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:1907
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1903
reduce_scatter_x && device(device_t device_in)
Definition lci_binding_post.hpp:1919
reduce_scatter_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:1913
reduce_scatter_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1922
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:1905
option_t< reduce_scatter_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:1906
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1901
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:1897
size_t m_item_size
Definition lci_binding_post.hpp:1899
const void * m_sendbuf
Definition lci_binding_post.hpp:1896
size_t m_recvcount
Definition lci_binding_post.hpp:1898
reduce_scatter_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:1917
void operator()() const
Definition lci_binding_post.hpp:1928
reduce_scatter_x && algorithm(reduce_scatter_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:1923
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1904
reduce_op_t m_op
Definition lci_binding_post.hpp:1900
void call() const
Definition binding.cpp:564
reduce_scatter_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1918
option_t< device_t > m_device
Definition lci_binding_post.hpp:1902
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:1910
reduce_scatter_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1920
reduce_scatter_x && recvcount(size_t recvcount_in)
Definition lci_binding_post.hpp:1915
reduce_scatter_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:1924
The actual implementation for reduce.
Definition lci_binding_post.hpp:1830
void operator()() const
Definition lci_binding_post.hpp:1861
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:1845
reduce_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:1852
reduce_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1857
reduce_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:1849
option_t< device_t > m_device
Definition lci_binding_post.hpp:1840
int m_root
Definition lci_binding_post.hpp:1838
size_t m_count
Definition lci_binding_post.hpp:1835
reduce_x && count(size_t count_in)
Definition lci_binding_post.hpp:1850
reduce_op_t m_op
Definition lci_binding_post.hpp:1837
reduce_x && device(device_t device_in)
Definition lci_binding_post.hpp:1855
size_t m_item_size
Definition lci_binding_post.hpp:1836
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1841
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:1834
reduce_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:1848
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1842
reduce_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1854
reduce_x && item_size(size_t item_size_in)
Definition lci_binding_post.hpp:1851
reduce_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1856
reduce_x && root(int root_in)
Definition lci_binding_post.hpp:1853
const void * m_sendbuf
Definition lci_binding_post.hpp:1833
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1839
void call() const
Definition binding.cpp:550
The actual implementation for register_memory.
Definition lci_binding_post.hpp:2364
register_memory_x && address(void *address_in)
Definition lci_binding_post.hpp:2376
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2369
register_memory_x && device(device_t device_in)
Definition lci_binding_post.hpp:2379
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:2377
option_t< device_t > m_device
Definition lci_binding_post.hpp:2370
void * m_address
Definition lci_binding_post.hpp:2367
mr_t operator()() const
Definition lci_binding_post.hpp:2383
register_memory_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2378
register_memory_x(void *address_in, size_t size_in)
Definition lci_binding_post.hpp:2373
size_t m_size
Definition lci_binding_post.hpp:2368
mr_t call() const
Definition binding.cpp:712
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:273
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:1006
rcomp_t call() const
Definition binding.cpp:398
rcomp_t operator()() const
Definition lci_binding_post.hpp:1023
comp_t m_comp
Definition lci_binding_post.hpp:1009
option_t< rcomp_t > m_rcomp
Definition lci_binding_post.hpp:1011
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1010
register_rcomp_x && rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:1019
register_rcomp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1018
register_rcomp_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1017
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:1014
The actual implementation for reserve_rcomps.
Definition lci_binding_post.hpp:968
rcomp_t call_impl(rcomp_t n, runtime_t runtime) const
rcomp_t m_n
Definition lci_binding_post.hpp:971
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:972
reserve_rcomps_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:979
rcomp_t call() const
Definition binding.cpp:392
reserve_rcomps_x(rcomp_t n_in)
Definition lci_binding_post.hpp:975
rcomp_t operator()() const
Definition lci_binding_post.hpp:983
reserve_rcomps_x && n(rcomp_t n_in)
Definition lci_binding_post.hpp:978
The actual implementation for RESOURCE runtime.
Definition lci_binding_pre.hpp:231
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:327
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:1129
comp_t m_comp
Definition lci_binding_post.hpp:1132
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:1141
status_t * m_p_out
Definition lci_binding_post.hpp:1133
sync_test_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1142
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1134
bool operator()() const
Definition lci_binding_post.hpp:1146
sync_test_x(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:1137
sync_test_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1140
bool call() const
Definition binding.cpp:420
The actual implementation for sync_wait.
Definition lci_binding_post.hpp:1171
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1176
sync_wait_x(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:1181
comp_t m_comp
Definition lci_binding_post.hpp:1174
sync_wait_x && p_out(status_t *p_out_in)
Definition lci_binding_post.hpp:1185
option_t< device_t > m_device
Definition lci_binding_post.hpp:1178
sync_wait_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1186
void call() const
Definition binding.cpp:427
status_t * m_p_out
Definition lci_binding_post.hpp:1175
option_t< bool > m_do_progress
Definition lci_binding_post.hpp:1177
sync_wait_x && device(device_t device_in)
Definition lci_binding_post.hpp:1188
sync_wait_x && do_progress(bool do_progress_in)
Definition lci_binding_post.hpp:1187
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:1192
sync_wait_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1184
The actual implementation for test_drained.
Definition lci_binding_post.hpp:3616
option_t< device_t > m_device
Definition lci_binding_post.hpp:3620
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3619
test_drained_x()
Definition lci_binding_post.hpp:3623
error_t operator()() const
Definition lci_binding_post.hpp:3631
test_drained_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3626
test_drained_x && device(device_t device_in)
Definition lci_binding_post.hpp:3627
error_t call() const
Definition binding.cpp:1002
error_t call_impl(runtime_t runtime, device_t device) const
The actual implementation for wait_drained.
Definition lci_binding_post.hpp:3653
option_t< device_t > m_device
Definition lci_binding_post.hpp:3657
void operator()() const
Definition lci_binding_post.hpp:3668
wait_drained_x()
Definition lci_binding_post.hpp:3660
void call() const
Definition binding.cpp:1008
void call_impl(runtime_t runtime, device_t device) const
wait_drained_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3663
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3656
wait_drained_x && device(device_t device_in)
Definition lci_binding_post.hpp:3664
broadcast_algorithm_t
The type of broadcast algorithm.
Definition lci.hpp:263
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:618
uint64_t matching_entry_key_t
The type of matching engine entry key.
Definition lci.hpp:444
status_t(*)(void *value) graph_node_run_cb_t
The function signature for a node function in the completion graph.
Definition lci.hpp:597
direction_t
The enum class of comunication direction.
Definition lci.hpp:394
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:612
void(*)(const void *left, const void *right, void *dst, size_t n) reduce_op_t
The user-defined reduction operation.
Definition lci.hpp:577
matching_policy_t
Enum class for matching policy.
Definition lci.hpp:433
void * graph_node_t
The node type for the completion graph.
Definition lci.hpp:583
allreduce_algorithm_t
The type of allreduce algorithm.
Definition lci.hpp:299
reduce_scatter_algorithm_t
The type of reduce scatter algorithm.
Definition lci.hpp:281
void * matching_entry_val_t
The type of matching engine entry value.
Definition lci.hpp:449
matching_entry_type_t
The type of matching entry.
Definition lci.hpp:424
uint32_t rcomp_t
The type of remote completion handler.
Definition lci.hpp:405
void(*)(status_t status) comp_handler_t
Function Signature for completion handler.
Definition lci.hpp:570
uint64_t tag_t
The type of tag.
Definition lci.hpp:388
comp_semantic_t
The enum class of completion semantic.
Definition lci.hpp:459
uint32_t net_imm_data_t
The type of network-layer immediate data field.
Definition lci.hpp:318
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:3144
error_t net_post_send(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:2745
void graph_node_mark_complete(graph_node_t node_in)
Definition lci_binding_post.hpp:1619
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:1803
device_t alloc_device()
Definition lci_binding_post.hpp:2306
net_context_t alloc_net_context()
Definition lci_binding_post.hpp:2178
void free_net_context(net_context_t *net_context_in)
Definition lci_binding_post.hpp:2215
error_t net_post_recv(void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:2632
attr_backend_t
Definition lci.hpp:66
void deregister_rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:1063
void deregister_memory(mr_t *mr_in)
Definition lci_binding_post.hpp:2423
comp_t alloc_counter()
Definition lci_binding_post.hpp:1235
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:3223
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:3671
rcomp_t reserve_rcomps(rcomp_t n_in)
Definition lci_binding_post.hpp:986
void sync_wait(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:1195
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:2925
void alltoall(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:2108
status_t graph_test(comp_t comp_in)
Definition lci_binding_post.hpp:1693
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:1398
size_t net_poll_cq(size_t max_polls_in, net_status_t *statuses_in)
Definition lci_binding_post.hpp:2583
attr_rdv_protocol_t
Definition lci_binding_pre.hpp:28
void graph_start(comp_t comp_in)
Definition lci_binding_post.hpp:1656
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:1361
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:2803
rcomp_t register_rcomp(comp_t comp_in)
Definition lci_binding_post.hpp:1026
error_t net_post_sends(int rank_in, void *buffer_in, size_t size_in)
Definition lci_binding_post.hpp:2687
void graph_add_edge(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in)
Definition lci_binding_post.hpp:1579
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:2343
void free_comp(comp_t *comp_in)
Definition lci_binding_post.hpp:909
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:1444
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:2989
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:1864
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:1312
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:3305
void comp_signal(comp_t comp_in, status_t status_in)
Definition lci_binding_post.hpp:949
mr_t register_memory(void *address_in, size_t size_in)
Definition lci_binding_post.hpp:2386
rmr_t get_rmr(mr_t mr_in)
Definition lci_binding_post.hpp:2460
endpoint_t alloc_endpoint()
Definition lci_binding_post.hpp:2503
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:3472
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:1998
graph_node_t graph_add_node(comp_t comp_in, graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:1533
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:2050
bool sync_test(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:1149
attr_ibv_td_strategy_t
Definition lci_binding_pre.hpp:66
error_t progress()
Definition lci_binding_post.hpp:3597
attr_ibv_odp_strategy_t
Definition lci_binding_pre.hpp:53
error_t test_drained()
Definition lci_binding_post.hpp:3634
device_t get_default_device()
Definition lci_binding_post.hpp:730
int64_t counter_get(comp_t comp_in)
Definition lci_binding_post.hpp:1272
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:1931
packet_pool_t alloc_packet_pool()
Definition lci_binding_post.hpp:274
attr_ibv_prefetch_strategy_t
Definition lci_binding_pre.hpp:59
void barrier()
Definition lci_binding_post.hpp:1742
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:3050
attr_cq_type_t
Definition lci_binding_pre.hpp:48
comp_t alloc_graph()
Definition lci_binding_post.hpp:1487
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:3387
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:2864
comp_t alloc_sync()
Definition lci_binding_post.hpp:1109
void free_endpoint(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:2540
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:3557
The user-defined allocator type.
Definition lci.hpp:468
Wrapper class for error code.
Definition lci.hpp:193
The struct for network status.
Definition lci.hpp:329
Definition lci.hpp:85
The type of remote memory region.
Definition lci.hpp:367
The type of the completion desciptor for a posted communication.
Definition lci.hpp:484