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
28
34 public:
35 // args declaration
44
45 // constructor
47
48 // setter
49 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); }
50 inline alloc_runtime_x&& imm_nbits_tag(int imm_nbits_tag_in) { m_imm_nbits_tag = imm_nbits_tag_in; return std::move(*this); }
51 inline alloc_runtime_x&& imm_nbits_rcomp(int imm_nbits_rcomp_in) { m_imm_nbits_rcomp = imm_nbits_rcomp_in; return std::move(*this); }
52 inline alloc_runtime_x&& alloc_default_device(bool alloc_default_device_in) { m_alloc_default_device = alloc_default_device_in; return std::move(*this); }
53 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); }
54 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); }
55 inline alloc_runtime_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
56 inline alloc_runtime_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
57
59 runtime_t call() const;
60 inline runtime_t operator()() const { return call(); }
61};
62
64 return alloc_runtime_x().call();
65}
66
67
76
82 public:
83 // args declaration
85
86 // constructor
87 free_runtime_x(runtime_t* runtime_in) : m_runtime(runtime_in) {}
88
89 // setter
90 inline free_runtime_x&& runtime(runtime_t* runtime_in) { m_runtime = runtime_in; return std::move(*this); }
91
93 void call() const;
94 inline void operator()() const { return call(); }
95};
96
97inline void free_runtime(runtime_t* runtime_in) {
98 return free_runtime_x(runtime_in).call();
99}
100
101
117
123 public:
124 // args declaration
133
134 // constructor
136
137 // setter
138 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); }
139 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); }
140 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); }
141 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); }
142 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); }
143 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); }
144 inline g_runtime_init_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
145 inline g_runtime_init_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
146
148 runtime_t call() const;
149 inline runtime_t operator()() const { return call(); }
150};
151
153 return g_runtime_init_x().call();
154}
155
156
165
171 public:
172 // args declaration
173
174 // constructor
176
177 // setter
178
179 void call_impl() const;
180 void call() const;
181 inline void operator()() const { return call(); }
182};
183
184inline void g_runtime_fina() {
185 return g_runtime_fina_x().call();
186}
187
188
197
203 public:
204 // args declaration
205
206 // constructor
208
209 // setter
210
212 runtime_t call() const;
213 inline runtime_t operator()() const { return call(); }
214};
215
217 return get_g_runtime_x().call();
218}
219
220
233
239 public:
240 // args declaration
246
247 // constructor
249
250 // setter
251 inline alloc_packet_pool_x&& packet_size(size_t packet_size_in) { m_packet_size = packet_size_in; return std::move(*this); }
252 inline alloc_packet_pool_x&& npackets(size_t npackets_in) { m_npackets = npackets_in; return std::move(*this); }
253 inline alloc_packet_pool_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
254 inline alloc_packet_pool_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
255 inline alloc_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
256
257 packet_pool_t call_impl(size_t packet_size, size_t npackets, const char* name, void* user_context, runtime_t runtime) const;
258 packet_pool_t call() const;
259 inline packet_pool_t operator()() const { return call(); }
260};
261
265
266
276
282 public:
283 // args declaration
286
287 // constructor
288 free_packet_pool_x(packet_pool_t* packet_pool_in) : m_packet_pool(packet_pool_in) {}
289
290 // setter
291 inline free_packet_pool_x&& packet_pool(packet_pool_t* packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
292 inline free_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
293
295 void call() const;
296 inline void operator()() const { return call(); }
297};
298
299inline void free_packet_pool(packet_pool_t* packet_pool_in) {
300 return free_packet_pool_x(packet_pool_in).call();
301}
302
303
314
320 public:
321 // args declaration
325
326 // constructor
327 register_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in) : m_packet_pool(packet_pool_in), m_device(device_in) {}
328
329 // setter
330 inline register_packet_pool_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
331 inline register_packet_pool_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
332 inline register_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
333
335 void call() const;
336 inline void operator()() const { return call(); }
337};
338
339inline void register_packet_pool(packet_pool_t packet_pool_in, device_t device_in) {
340 return register_packet_pool_x(packet_pool_in, device_in).call();
341}
342
343
354
360 public:
361 // args declaration
365
366 // constructor
367 deregister_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in) : m_packet_pool(packet_pool_in), m_device(device_in) {}
368
369 // setter
370 inline deregister_packet_pool_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
371 inline deregister_packet_pool_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
372 inline deregister_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
373
375 void call() const;
376 inline void operator()() const { return call(); }
377};
378
379inline void deregister_packet_pool(packet_pool_t packet_pool_in, device_t device_in) {
380 return deregister_packet_pool_x(packet_pool_in, device_in).call();
381}
382
383
393
399 public:
400 // args declaration
403
404 // constructor
406
407 // setter
408 inline get_upacket_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
409 inline get_upacket_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
410
412 void* call() const;
413 inline void* operator()() const { return call(); }
414};
415
416inline void* get_upacket() {
417 return get_upacket_x().call();
418}
419
420
430
436 public:
437 // args declaration
438 void* m_packet;
440
441 // constructor
442 put_upacket_x(void* packet_in) : m_packet(packet_in) {}
443
444 // setter
445 inline put_upacket_x&& packet(void* packet_in) { m_packet = packet_in; return std::move(*this); }
446 inline put_upacket_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
447
448 void call_impl(void* packet, runtime_t runtime) const;
449 void call() const;
450 inline void operator()() const { return call(); }
451};
452
453inline void put_upacket(void* packet_in) {
454 return put_upacket_x(packet_in).call();
455}
456
457
469
475 public:
476 // args declaration
481
482 // constructor
484
485 // setter
486 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); }
487 inline alloc_matching_engine_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
488 inline alloc_matching_engine_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
489 inline alloc_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
490
492 matching_engine_t call() const;
493 inline matching_engine_t operator()() const { return call(); }
494};
495
499
500
510
516 public:
517 // args declaration
520
521 // constructor
522 free_matching_engine_x(matching_engine_t* matching_engine_in) : m_matching_engine(matching_engine_in) {}
523
524 // setter
525 inline free_matching_engine_x&& matching_engine(matching_engine_t* matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
526 inline free_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
527
529 void call() const;
530 inline void operator()() const { return call(); }
531};
532
533inline void free_matching_engine(matching_engine_t* matching_engine_in) {
534 return free_matching_engine_x(matching_engine_in).call();
535}
536
537
550
556 public:
557 // args declaration
563
564 // constructor
565 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) {}
566
567 // setter
568 inline matching_engine_insert_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
569 inline matching_engine_insert_x&& key(matching_entry_key_t key_in) { m_key = key_in; return std::move(*this); }
570 inline matching_engine_insert_x&& value(matching_entry_val_t value_in) { m_value = value_in; return std::move(*this); }
571 inline matching_engine_insert_x&& entry_type(matching_entry_type_t entry_type_in) { m_entry_type = entry_type_in; return std::move(*this); }
572 inline matching_engine_insert_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
573
576 inline matching_entry_val_t operator()() const { return call(); }
577};
578
580 return matching_engine_insert_x(matching_engine_in, key_in, value_in, entry_type_in).call();
581}
582
583
593
599 public:
600 // args declaration
603
604 // constructor
605 set_allocator_x(allocator_base_t* allocator_in) : m_allocator(allocator_in) {}
606
607 // setter
608 inline set_allocator_x&& allocator(allocator_base_t* allocator_in) { m_allocator = allocator_in; return std::move(*this); }
609 inline set_allocator_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
610
612 void call() const;
613 inline void operator()() const { return call(); }
614};
615
616inline void set_allocator(allocator_base_t* allocator_in) {
617 return set_allocator_x(allocator_in).call();
618}
619
620
629
635 public:
636 // args declaration
638
639 // constructor
641
642 // setter
643 inline get_allocator_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
644
646 allocator_base_t* call() const;
647 inline allocator_base_t* operator()() const { return call(); }
648};
649
651 return get_allocator_x().call();
652}
653
654
663
669 public:
670 // args declaration
672
673 // constructor
675
676 // setter
677 inline get_default_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
678
680 net_context_t call() const;
681 inline net_context_t operator()() const { return call(); }
682};
683
687
688
697
703 public:
704 // args declaration
706
707 // constructor
709
710 // setter
711 inline get_default_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
712
714 device_t call() const;
715 inline device_t operator()() const { return call(); }
716};
717
719 return get_default_device_x().call();
720}
721
722
732
738 public:
739 // args declaration
742
743 // constructor
745
746 // setter
747 inline get_default_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
748 inline get_default_endpoint_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
749
751 endpoint_t call() const;
752 inline endpoint_t operator()() const { return call(); }
753};
754
758
759
768
774 public:
775 // args declaration
777
778 // constructor
780
781 // setter
782 inline get_default_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
783
785 packet_pool_t call() const;
786 inline packet_pool_t operator()() const { return call(); }
787};
788
792
793
802
808 public:
809 // args declaration
811
812 // constructor
814
815 // setter
816 inline get_default_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
817
819 matching_engine_t call() const;
820 inline matching_engine_t operator()() const { return call(); }
821};
822
826
827
837
843 public:
844 // args declaration
847
848 // constructor
850
851 // setter
852 inline get_max_bcopy_size_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
853 inline get_max_bcopy_size_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
854
856 size_t call() const;
857 inline size_t operator()() const { return call(); }
858};
859
860inline size_t get_max_bcopy_size() {
861 return get_max_bcopy_size_x().call();
862}
863
864
884
890 public:
891 // args declaration
904
905 // constructor
907
908 // setter
909 inline alloc_net_context_x&& backend(attr_backend_t backend_in) { m_backend = backend_in; return std::move(*this); }
910 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); }
911 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); }
912 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); }
913 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); }
914 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); }
915 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); }
916 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); }
917 inline alloc_net_context_x&& use_dmabuf(bool use_dmabuf_in) { m_use_dmabuf = use_dmabuf_in; return std::move(*this); }
918 inline alloc_net_context_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
919 inline alloc_net_context_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
920 inline alloc_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
921
923 net_context_t call() const;
924 inline net_context_t operator()() const { return call(); }
925};
926
930
931
941
947 public:
948 // args declaration
951
952 // constructor
953 free_net_context_x(net_context_t* net_context_in) : m_net_context(net_context_in) {}
954
955 // setter
956 inline free_net_context_x&& net_context(net_context_t* net_context_in) { m_net_context = net_context_in; return std::move(*this); }
957 inline free_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
958
960 void call() const;
961 inline void operator()() const { return call(); }
962};
963
964inline void free_net_context(net_context_t* net_context_in) {
965 return free_net_context_x(net_context_in).call();
966}
967
968
987
993 public:
994 // args declaration
1006
1007 // constructor
1009
1010 // setter
1011 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); }
1012 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); }
1013 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); }
1014 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); }
1015 inline alloc_device_x&& alloc_default_endpoint(bool alloc_default_endpoint_in) { m_alloc_default_endpoint = alloc_default_endpoint_in; return std::move(*this); }
1016 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); }
1017 inline alloc_device_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
1018 inline alloc_device_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1019 inline alloc_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1020 inline alloc_device_x&& net_context(net_context_t net_context_in) { m_net_context = net_context_in; return std::move(*this); }
1021 inline alloc_device_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1022
1024 device_t call() const;
1025 inline device_t operator()() const { return call(); }
1026};
1027
1029 return alloc_device_x().call();
1030}
1031
1032
1042
1048 public:
1049 // args declaration
1052
1053 // constructor
1054 free_device_x(device_t* device_in) : m_device(device_in) {}
1055
1056 // setter
1057 inline free_device_x&& device(device_t* device_in) { m_device = device_in; return std::move(*this); }
1058 inline free_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1059
1061 void call() const;
1062 inline void operator()() const { return call(); }
1063};
1064
1065inline void free_device(device_t* device_in) {
1066 return free_device_x(device_in).call();
1067}
1068
1069
1081
1087 public:
1088 // args declaration
1090 size_t m_size;
1093
1094 // constructor
1095 register_memory_x(void* address_in, size_t size_in) : m_address(address_in), m_size(size_in) {}
1096
1097 // setter
1098 inline register_memory_x&& address(void* address_in) { m_address = address_in; return std::move(*this); }
1099 inline register_memory_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1100 inline register_memory_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1101 inline register_memory_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1102
1104 mr_t call() const;
1105 inline mr_t operator()() const { return call(); }
1106};
1107
1108inline mr_t register_memory(void* address_in, size_t size_in) {
1109 return register_memory_x(address_in, size_in).call();
1110}
1111
1112
1122
1128 public:
1129 // args declaration
1132
1133 // constructor
1134 deregister_memory_x(mr_t* mr_in) : m_mr(mr_in) {}
1135
1136 // setter
1137 inline deregister_memory_x&& mr(mr_t* mr_in) { m_mr = mr_in; return std::move(*this); }
1138 inline deregister_memory_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1139
1141 void call() const;
1142 inline void operator()() const { return call(); }
1143};
1144
1145inline void deregister_memory(mr_t* mr_in) {
1146 return deregister_memory_x(mr_in).call();
1147}
1148
1149
1159
1165 public:
1166 // args declaration
1169
1170 // constructor
1171 get_rmr_x(mr_t mr_in) : m_mr(mr_in) {}
1172
1173 // setter
1174 inline get_rmr_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1175 inline get_rmr_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1176
1178 rmr_t call() const;
1179 inline rmr_t operator()() const { return call(); }
1180};
1181
1182inline rmr_t get_rmr(mr_t mr_in) {
1183 return get_rmr_x(mr_in).call();
1184}
1185
1186
1198
1204 public:
1205 // args declaration
1210
1211 // constructor
1213
1214 // setter
1215 inline alloc_endpoint_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
1216 inline alloc_endpoint_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1217 inline alloc_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1218 inline alloc_endpoint_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1219
1221 endpoint_t call() const;
1222 inline endpoint_t operator()() const { return call(); }
1223};
1224
1226 return alloc_endpoint_x().call();
1227}
1228
1229
1239
1245 public:
1246 // args declaration
1249
1250 // constructor
1251 free_endpoint_x(endpoint_t* endpoint_in) : m_endpoint(endpoint_in) {}
1252
1253 // setter
1254 inline free_endpoint_x&& endpoint(endpoint_t* endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1255 inline free_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1256
1258 void call() const;
1259 inline void operator()() const { return call(); }
1260};
1261
1262inline void free_endpoint(endpoint_t* endpoint_in) {
1263 return free_endpoint_x(endpoint_in).call();
1264}
1265
1266
1278
1284 public:
1285 // args declaration
1290
1291 // constructor
1292 net_poll_cq_x(size_t max_polls_in, net_status_t* statuses_in) : m_max_polls(max_polls_in), m_statuses(statuses_in) {}
1293
1294 // setter
1295 inline net_poll_cq_x&& max_polls(size_t max_polls_in) { m_max_polls = max_polls_in; return std::move(*this); }
1296 inline net_poll_cq_x&& statuses(net_status_t* statuses_in) { m_statuses = statuses_in; return std::move(*this); }
1297 inline net_poll_cq_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1298 inline net_poll_cq_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1299
1301 size_t call() const;
1302 inline size_t operator()() const { return call(); }
1303};
1304
1305inline size_t net_poll_cq(size_t max_polls_in, net_status_t* statuses_in) {
1306 return net_poll_cq_x(max_polls_in, statuses_in).call();
1307}
1308
1309
1323
1329 public:
1330 // args declaration
1332 size_t m_size;
1337
1338 // constructor
1339 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) {}
1340
1341 // setter
1342 inline net_post_recv_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1343 inline net_post_recv_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1344 inline net_post_recv_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1345 inline net_post_recv_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1346 inline net_post_recv_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1347 inline net_post_recv_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1348
1350 error_t call() const;
1351 inline error_t operator()() const { return call(); }
1352};
1353
1354inline error_t net_post_recv(void* buffer_in, size_t size_in, mr_t mr_in) {
1355 return net_post_recv_x(buffer_in, size_in, mr_in).call();
1356}
1357
1358
1374
1380 public:
1381 // args declaration
1384 size_t m_size;
1390
1391 // constructor
1392 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) {}
1393
1394 // setter
1395 inline net_post_sends_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1396 inline net_post_sends_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1397 inline net_post_sends_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1398 inline net_post_sends_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1399 inline net_post_sends_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1400 inline net_post_sends_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1401 inline net_post_sends_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1402 inline net_post_sends_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1403
1405 error_t call() const;
1406 inline error_t operator()() const { return call(); }
1407};
1408
1409inline error_t net_post_sends(int rank_in, void* buffer_in, size_t size_in) {
1410 return net_post_sends_x(rank_in, buffer_in, size_in).call();
1411}
1412
1413
1430
1436 public:
1437 // args declaration
1440 size_t m_size;
1447
1448 // constructor
1449 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) {}
1450
1451 // setter
1452 inline net_post_send_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1453 inline net_post_send_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1454 inline net_post_send_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1455 inline net_post_send_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1456 inline net_post_send_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1457 inline net_post_send_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1458 inline net_post_send_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1459 inline net_post_send_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1460 inline net_post_send_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1461
1463 error_t call() const;
1464 inline error_t operator()() const { return call(); }
1465};
1466
1467inline error_t net_post_send(int rank_in, void* buffer_in, size_t size_in, mr_t mr_in) {
1468 return net_post_send_x(rank_in, buffer_in, size_in, mr_in).call();
1469}
1470
1471
1488
1494 public:
1495 // args declaration
1498 size_t m_size;
1499 uint64_t m_offset;
1505
1506 // constructor
1507 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) {}
1508
1509 // setter
1510 inline net_post_puts_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1511 inline net_post_puts_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1512 inline net_post_puts_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1513 inline net_post_puts_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1514 inline net_post_puts_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1515 inline net_post_puts_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1516 inline net_post_puts_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1517 inline net_post_puts_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1518 inline net_post_puts_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1519
1521 error_t call() const;
1522 inline error_t operator()() const { return call(); }
1523};
1524
1525inline error_t net_post_puts(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) {
1526 return net_post_puts_x(rank_in, buffer_in, size_in, offset_in, rmr_in).call();
1527}
1528
1529
1547
1553 public:
1554 // args declaration
1557 size_t m_size;
1559 uint64_t m_offset;
1565
1566 // constructor
1567 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) {}
1568
1569 // setter
1570 inline net_post_put_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1571 inline net_post_put_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1572 inline net_post_put_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1573 inline net_post_put_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1574 inline net_post_put_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1575 inline net_post_put_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1576 inline net_post_put_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1577 inline net_post_put_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1578 inline net_post_put_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1579 inline net_post_put_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1580
1582 error_t call() const;
1583 inline error_t operator()() const { return call(); }
1584};
1585
1586inline 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) {
1587 return net_post_put_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
1588}
1589
1590
1608
1614 public:
1615 // args declaration
1618 size_t m_size;
1619 uint64_t m_offset;
1626
1627 // constructor
1628 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) {}
1629
1630 // setter
1631 inline net_post_putImms_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1632 inline net_post_putImms_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1633 inline net_post_putImms_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1634 inline net_post_putImms_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1635 inline net_post_putImms_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1636 inline net_post_putImms_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1637 inline net_post_putImms_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1638 inline net_post_putImms_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1639 inline net_post_putImms_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1640 inline net_post_putImms_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1641
1643 error_t call() const;
1644 inline error_t operator()() const { return call(); }
1645};
1646
1647inline error_t net_post_putImms(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) {
1648 return net_post_putImms_x(rank_in, buffer_in, size_in, offset_in, rmr_in).call();
1649}
1650
1651
1670
1676 public:
1677 // args declaration
1680 size_t m_size;
1682 uint64_t m_offset;
1689
1690 // constructor
1691 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) {}
1692
1693 // setter
1694 inline net_post_putImm_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1695 inline net_post_putImm_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1696 inline net_post_putImm_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1697 inline net_post_putImm_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1698 inline net_post_putImm_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1699 inline net_post_putImm_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1700 inline net_post_putImm_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1701 inline net_post_putImm_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1702 inline net_post_putImm_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1703 inline net_post_putImm_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1704 inline net_post_putImm_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1705
1707 error_t call() const;
1708 inline error_t operator()() const { return call(); }
1709};
1710
1711inline 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) {
1712 return net_post_putImm_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
1713}
1714
1715
1733
1739 public:
1740 // args declaration
1743 size_t m_size;
1745 uint64_t m_offset;
1751
1752 // constructor
1753 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) {}
1754
1755 // setter
1756 inline net_post_get_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1757 inline net_post_get_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1758 inline net_post_get_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1759 inline net_post_get_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1760 inline net_post_get_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1761 inline net_post_get_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1762 inline net_post_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1763 inline net_post_get_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1764 inline net_post_get_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1765 inline net_post_get_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1766
1768 error_t call() const;
1769 inline error_t operator()() const { return call(); }
1770};
1771
1772inline 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) {
1773 return net_post_get_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
1774}
1775
1776
1786
1792 public:
1793 // args declaration
1796
1797 // constructor
1798 free_comp_x(comp_t* comp_in) : m_comp(comp_in) {}
1799
1800 // setter
1801 inline free_comp_x&& comp(comp_t* comp_in) { m_comp = comp_in; return std::move(*this); }
1802 inline free_comp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1803
1805 void call() const;
1806 inline void operator()() const { return call(); }
1807};
1808
1809inline void free_comp(comp_t* comp_in) {
1810 return free_comp_x(comp_in).call();
1811}
1812
1813
1824
1830 public:
1831 // args declaration
1835
1836 // constructor
1837 comp_signal_x(comp_t comp_in, status_t status_in) : m_comp(comp_in), m_status(status_in) {}
1838
1839 // setter
1840 inline comp_signal_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1841 inline comp_signal_x&& status(status_t status_in) { m_status = status_in; return std::move(*this); }
1842 inline comp_signal_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1843
1845 void call() const;
1846 inline void operator()() const { return call(); }
1847};
1848
1849inline void comp_signal(comp_t comp_in, status_t status_in) {
1850 return comp_signal_x(comp_in, status_in).call();
1851}
1852
1853
1863
1869 public:
1870 // args declaration
1873
1874 // constructor
1876
1877 // setter
1878 inline reserve_rcomps_x&& n(rcomp_t n_in) { m_n = n_in; return std::move(*this); }
1879 inline reserve_rcomps_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1880
1882 rcomp_t call() const;
1883 inline rcomp_t operator()() const { return call(); }
1884};
1885
1887 return reserve_rcomps_x(n_in).call();
1888}
1889
1890
1901
1907 public:
1908 // args declaration
1912
1913 // constructor
1914 register_rcomp_x(comp_t comp_in) : m_comp(comp_in) {}
1915
1916 // setter
1917 inline register_rcomp_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1918 inline register_rcomp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1919 inline register_rcomp_x&& rcomp(rcomp_t rcomp_in) { m_rcomp = rcomp_in; return std::move(*this); }
1920
1922 rcomp_t call() const;
1923 inline rcomp_t operator()() const { return call(); }
1924};
1925
1927 return register_rcomp_x(comp_in).call();
1928}
1929
1930
1940
1946 public:
1947 // args declaration
1950
1951 // constructor
1952 deregister_rcomp_x(rcomp_t rcomp_in) : m_rcomp(rcomp_in) {}
1953
1954 // setter
1955 inline deregister_rcomp_x&& rcomp(rcomp_t rcomp_in) { m_rcomp = rcomp_in; return std::move(*this); }
1956 inline deregister_rcomp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1957
1959 void call() const;
1960 inline void operator()() const { return call(); }
1961};
1962
1963inline void deregister_rcomp(rcomp_t rcomp_in) {
1964 return deregister_rcomp_x(rcomp_in).call();
1965}
1966
1967
1980
1986 public:
1987 // args declaration
1993
1994 // constructor
1996
1997 // setter
1998 inline alloc_sync_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1999 inline alloc_sync_x&& threshold(int threshold_in) { m_threshold = threshold_in; return std::move(*this); }
2000 inline alloc_sync_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
2001 inline alloc_sync_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2002 inline alloc_sync_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2003
2005 comp_t call() const;
2006 inline comp_t operator()() const { return call(); }
2007};
2008
2010 return alloc_sync_x().call();
2011}
2012
2013
2024
2030 public:
2031 // args declaration
2035
2036 // constructor
2037 sync_test_x(comp_t comp_in, status_t* p_out_in) : m_comp(comp_in), m_p_out(p_out_in) {}
2038
2039 // setter
2040 inline sync_test_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2041 inline sync_test_x&& p_out(status_t* p_out_in) { m_p_out = p_out_in; return std::move(*this); }
2042 inline sync_test_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2043
2045 bool call() const;
2046 inline bool operator()() const { return call(); }
2047};
2048
2049inline bool sync_test(comp_t comp_in, status_t* p_out_in) {
2050 return sync_test_x(comp_in, p_out_in).call();
2051}
2052
2053
2066
2072 public:
2073 // args declaration
2079
2080 // constructor
2081 sync_wait_x(comp_t comp_in, status_t* p_out_in) : m_comp(comp_in), m_p_out(p_out_in) {}
2082
2083 // setter
2084 inline sync_wait_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2085 inline sync_wait_x&& p_out(status_t* p_out_in) { m_p_out = p_out_in; return std::move(*this); }
2086 inline sync_wait_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2087 inline sync_wait_x&& do_progress(bool do_progress_in) { m_do_progress = do_progress_in; return std::move(*this); }
2088 inline sync_wait_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2089
2091 void call() const;
2092 inline void operator()() const { return call(); }
2093};
2094
2095inline void sync_wait(comp_t comp_in, status_t* p_out_in) {
2096 return sync_wait_x(comp_in, p_out_in).call();
2097}
2098
2099
2110
2116 public:
2117 // args declaration
2121
2122 // constructor
2124
2125 // setter
2126 inline alloc_counter_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2127 inline alloc_counter_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2128 inline alloc_counter_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2129
2131 comp_t call() const;
2132 inline comp_t operator()() const { return call(); }
2133};
2134
2136 return alloc_counter_x().call();
2137}
2138
2139
2149
2155 public:
2156 // args declaration
2159
2160 // constructor
2161 counter_get_x(comp_t comp_in) : m_comp(comp_in) {}
2162
2163 // setter
2164 inline counter_get_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2165 inline counter_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2166
2168 int64_t call() const;
2169 inline int64_t operator()() const { return call(); }
2170};
2171
2172inline int64_t counter_get(comp_t comp_in) {
2173 return counter_get_x(comp_in).call();
2174}
2175
2176
2187
2193 public:
2194 // args declaration
2196 int64_t m_value;
2198
2199 // constructor
2200 counter_set_x(comp_t comp_in, int64_t value_in) : m_comp(comp_in), m_value(value_in) {}
2201
2202 // setter
2203 inline counter_set_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2204 inline counter_set_x&& value(int64_t value_in) { m_value = value_in; return std::move(*this); }
2205 inline counter_set_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2206
2208 void call() const;
2209 inline void operator()() const { return call(); }
2210};
2211
2212inline void counter_set(comp_t comp_in, int64_t value_in) {
2213 return counter_set_x(comp_in, value_in).call();
2214}
2215
2216
2230
2236 public:
2237 // args declaration
2244
2245 // constructor
2247
2248 // setter
2249 inline alloc_cq_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2250 inline alloc_cq_x&& default_length(int default_length_in) { m_default_length = default_length_in; return std::move(*this); }
2251 inline alloc_cq_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
2252 inline alloc_cq_x&& cq_type(attr_cq_type_t cq_type_in) { m_cq_type = cq_type_in; return std::move(*this); }
2253 inline alloc_cq_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2254 inline alloc_cq_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2255
2257 comp_t call() const;
2258 inline comp_t operator()() const { return call(); }
2259};
2260
2262 return alloc_cq_x().call();
2263}
2264
2265
2275
2281 public:
2282 // args declaration
2285
2286 // constructor
2287 cq_pop_x(comp_t comp_in) : m_comp(comp_in) {}
2288
2289 // setter
2290 inline cq_pop_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2291 inline cq_pop_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2292
2294 status_t call() const;
2295 inline status_t operator()() const { return call(); }
2296};
2297
2298inline status_t cq_pop(comp_t comp_in) {
2299 return cq_pop_x(comp_in).call();
2300}
2301
2302
2315
2321 public:
2322 // args declaration
2328
2329 // constructor
2330 alloc_handler_x(comp_handler_t handler_in) : m_handler(handler_in) {}
2331
2332 // setter
2333 inline alloc_handler_x&& handler(comp_handler_t handler_in) { m_handler = handler_in; return std::move(*this); }
2334 inline alloc_handler_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2335 inline alloc_handler_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
2336 inline alloc_handler_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2337 inline alloc_handler_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2338
2340 comp_t call() const;
2341 inline comp_t operator()() const { return call(); }
2342};
2343
2345 return alloc_handler_x(handler_in).call();
2346}
2347
2348
2360
2366 public:
2367 // args declaration
2372
2373 // constructor
2375
2376 // setter
2377 inline alloc_graph_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2378 inline alloc_graph_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2379 inline alloc_graph_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2380 inline alloc_graph_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2381
2383 comp_t call() const;
2384 inline comp_t operator()() const { return call(); }
2385};
2386
2388 return alloc_graph_x().call();
2389}
2390
2391
2404
2410 public:
2411 // args declaration
2417
2418 // constructor
2419 graph_add_node_x(comp_t comp_in, graph_node_run_cb_t fn_in) : m_comp(comp_in), m_fn(fn_in) {}
2420
2421 // setter
2422 inline graph_add_node_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2423 inline graph_add_node_x&& fn(graph_node_run_cb_t fn_in) { m_fn = fn_in; return std::move(*this); }
2424 inline graph_add_node_x&& value(void* value_in) { m_value = value_in; return std::move(*this); }
2425 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); }
2426 inline graph_add_node_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2427
2429 graph_node_t call() const;
2430 inline graph_node_t operator()() const { return call(); }
2431};
2432
2434 return graph_add_node_x(comp_in, fn_in).call();
2435}
2436
2437
2450
2456 public:
2457 // args declaration
2463
2464 // constructor
2465 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) {}
2466
2467 // setter
2468 inline graph_add_edge_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2469 inline graph_add_edge_x&& src(graph_node_t src_in) { m_src = src_in; return std::move(*this); }
2470 inline graph_add_edge_x&& dst(graph_node_t dst_in) { m_dst = dst_in; return std::move(*this); }
2471 inline graph_add_edge_x&& fn(graph_edge_run_cb_t fn_in) { m_fn = fn_in; return std::move(*this); }
2472 inline graph_add_edge_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2473
2475 void call() const;
2476 inline void operator()() const { return call(); }
2477};
2478
2479inline void graph_add_edge(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in) {
2480 return graph_add_edge_x(comp_in, src_in, dst_in).call();
2481}
2482
2483
2494
2500 public:
2501 // args declaration
2505
2506 // constructor
2508
2509 // setter
2510 inline graph_node_mark_complete_x&& node(graph_node_t node_in) { m_node = node_in; return std::move(*this); }
2511 inline graph_node_mark_complete_x&& status(status_t status_in) { m_status = status_in; return std::move(*this); }
2512 inline graph_node_mark_complete_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2513
2515 void call() const;
2516 inline void operator()() const { return call(); }
2517};
2518
2520 return graph_node_mark_complete_x(node_in).call();
2521}
2522
2523
2533
2539 public:
2540 // args declaration
2543
2544 // constructor
2545 graph_start_x(comp_t comp_in) : m_comp(comp_in) {}
2546
2547 // setter
2548 inline graph_start_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2549 inline graph_start_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2550
2552 void call() const;
2553 inline void operator()() const { return call(); }
2554};
2555
2556inline void graph_start(comp_t comp_in) {
2557 return graph_start_x(comp_in).call();
2558}
2559
2560
2570
2576 public:
2577 // args declaration
2580
2581 // constructor
2582 graph_test_x(comp_t comp_in) : m_comp(comp_in) {}
2583
2584 // setter
2585 inline graph_test_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2586 inline graph_test_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2587
2589 status_t call() const;
2590 inline status_t operator()() const { return call(); }
2591};
2592
2593inline status_t graph_test(comp_t comp_in) {
2594 return graph_test_x(comp_in).call();
2595}
2596
2597
2611
2617 public:
2618 // args declaration
2625
2626 // constructor
2628
2629 // setter
2630 inline barrier_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2631 inline barrier_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2632 inline barrier_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2633 inline barrier_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2634 inline barrier_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
2635 inline barrier_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2636
2638 void call() const;
2639 inline void operator()() const { return call(); }
2640};
2641
2642inline void barrier() {
2643 return barrier_x().call();
2644}
2645
2646
2664
2670 public:
2671 // args declaration
2673 size_t m_size;
2682
2683 // constructor
2684 broadcast_x(void* buffer_in, size_t size_in, int root_in) : m_buffer(buffer_in), m_size(size_in), m_root(root_in) {}
2685
2686 // setter
2687 inline broadcast_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
2688 inline broadcast_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2689 inline broadcast_x&& root(int root_in) { m_root = root_in; return std::move(*this); }
2690 inline broadcast_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2691 inline broadcast_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2692 inline broadcast_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2693 inline broadcast_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2694 inline broadcast_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2695 inline broadcast_x&& algorithm(broadcast_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
2696 inline broadcast_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
2697
2699 void call() const;
2700 inline void operator()() const { return call(); }
2701};
2702
2703inline void broadcast(void* buffer_in, size_t size_in, int root_in) {
2704 return broadcast_x(buffer_in, size_in, root_in).call();
2705}
2706
2707
2725
2731 public:
2732 // args declaration
2733 const void* m_sendbuf;
2735 size_t m_count;
2743
2744 // constructor
2745 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) {}
2746
2747 // setter
2748 inline reduce_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2749 inline reduce_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2750 inline reduce_x&& count(size_t count_in) { m_count = count_in; return std::move(*this); }
2751 inline reduce_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
2752 inline reduce_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
2753 inline reduce_x&& root(int root_in) { m_root = root_in; return std::move(*this); }
2754 inline reduce_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2755 inline reduce_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2756 inline reduce_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2757 inline reduce_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2758
2760 void call() const;
2761 inline void operator()() const { return call(); }
2762};
2763
2764inline 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) {
2765 return reduce_x(sendbuf_in, recvbuf_in, count_in, item_size_in, op_in, root_in).call();
2766}
2767
2768
2788
2794 public:
2795 // args declaration
2796 const void* m_sendbuf;
2808
2809 // constructor
2810 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) {}
2811
2812 // setter
2813 inline reduce_scatter_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2814 inline reduce_scatter_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2815 inline reduce_scatter_x&& recvcount(size_t recvcount_in) { m_recvcount = recvcount_in; return std::move(*this); }
2816 inline reduce_scatter_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
2817 inline reduce_scatter_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
2818 inline reduce_scatter_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2819 inline reduce_scatter_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2820 inline reduce_scatter_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2821 inline reduce_scatter_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2822 inline reduce_scatter_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2823 inline reduce_scatter_x&& algorithm(reduce_scatter_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
2824 inline reduce_scatter_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
2825
2827 void call() const;
2828 inline void operator()() const { return call(); }
2829};
2830
2831inline void reduce_scatter(const void* sendbuf_in, void* recvbuf_in, size_t recvcount_in, size_t item_size_in, reduce_op_t op_in) {
2832 return reduce_scatter_x(sendbuf_in, recvbuf_in, recvcount_in, item_size_in, op_in).call();
2833}
2834
2835
2855
2861 public:
2862 // args declaration
2863 const void* m_sendbuf;
2865 size_t m_count;
2875
2876 // constructor
2877 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) {}
2878
2879 // setter
2880 inline allreduce_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2881 inline allreduce_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2882 inline allreduce_x&& count(size_t count_in) { m_count = count_in; return std::move(*this); }
2883 inline allreduce_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
2884 inline allreduce_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
2885 inline allreduce_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2886 inline allreduce_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2887 inline allreduce_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2888 inline allreduce_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2889 inline allreduce_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2890 inline allreduce_x&& algorithm(allreduce_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
2891 inline allreduce_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
2892
2894 void call() const;
2895 inline void operator()() const { return call(); }
2896};
2897
2898inline void allreduce(const void* sendbuf_in, void* recvbuf_in, size_t count_in, size_t item_size_in, reduce_op_t op_in) {
2899 return allreduce_x(sendbuf_in, recvbuf_in, count_in, item_size_in, op_in).call();
2900}
2901
2902
2917
2923 public:
2924 // args declaration
2925 const void* m_sendbuf;
2927 size_t m_size;
2932
2933 // constructor
2934 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) {}
2935
2936 // setter
2937 inline allgather_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2938 inline allgather_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2939 inline allgather_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2940 inline allgather_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2941 inline allgather_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2942 inline allgather_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2943 inline allgather_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2944
2946 void call() const;
2947 inline void operator()() const { return call(); }
2948};
2949
2950inline void allgather(const void* sendbuf_in, void* recvbuf_in, size_t size_in) {
2951 return allgather_x(sendbuf_in, recvbuf_in, size_in).call();
2952}
2953
2954
2970
2976 public:
2977 // args declaration
2978 const void* m_sendbuf;
2980 size_t m_size;
2986
2987 // constructor
2988 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) {}
2989
2990 // setter
2991 inline alltoall_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2992 inline alltoall_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2993 inline alltoall_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2994 inline alltoall_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2995 inline alltoall_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2996 inline alltoall_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2997 inline alltoall_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2998 inline alltoall_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
2999
3001 void call() const;
3002 inline void operator()() const { return call(); }
3003};
3004
3005inline void alltoall(const void* sendbuf_in, void* recvbuf_in, size_t size_in) {
3006 return alltoall_x(sendbuf_in, recvbuf_in, size_in).call();
3007}
3008
3009
3038
3044 public:
3045 // args declaration
3049 size_t m_size;
3067
3068 // constructor
3069 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) {}
3070
3071 // setter
3072 inline post_comm_x&& direction(direction_t direction_in) { m_direction = direction_in; return std::move(*this); }
3073 inline post_comm_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3074 inline post_comm_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3075 inline post_comm_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3076 inline post_comm_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3077 inline post_comm_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3078 inline post_comm_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3079 inline post_comm_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3080 inline post_comm_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3081 inline post_comm_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3082 inline post_comm_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3083 inline post_comm_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3084 inline post_comm_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
3085 inline post_comm_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
3086 inline post_comm_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3087 inline post_comm_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
3088 inline post_comm_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3089 inline post_comm_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
3090 inline post_comm_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3091 inline post_comm_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3092 inline post_comm_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3093
3095 status_t call() const;
3096 inline status_t operator()() const { return call(); }
3097};
3098
3099inline status_t post_comm(direction_t direction_in, int rank_in, void* local_buffer_in, size_t size_in, comp_t local_comp_in) {
3100 return post_comm_x(direction_in, rank_in, local_buffer_in, size_in, local_comp_in).call();
3101}
3102
3103
3127
3133 public:
3134 // args declaration
3137 size_t m_size;
3151
3152 // constructor
3153 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) {}
3154
3155 // setter
3156 inline post_am_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3157 inline post_am_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3158 inline post_am_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3159 inline post_am_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3160 inline post_am_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
3161 inline post_am_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3162 inline post_am_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3163 inline post_am_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3164 inline post_am_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3165 inline post_am_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3166 inline post_am_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3167 inline post_am_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3168 inline post_am_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3169 inline post_am_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3170 inline post_am_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3171 inline post_am_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3172
3174 status_t call() const;
3175 inline status_t operator()() const { return call(); }
3176};
3177
3178inline 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) {
3179 return post_am_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_comp_in).call();
3180}
3181
3182
3207
3213 public:
3214 // args declaration
3217 size_t m_size;
3232
3233 // constructor
3234 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) {}
3235
3236 // setter
3237 inline post_send_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3238 inline post_send_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3239 inline post_send_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3240 inline post_send_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3241 inline post_send_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3242 inline post_send_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3243 inline post_send_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3244 inline post_send_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3245 inline post_send_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3246 inline post_send_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3247 inline post_send_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3248 inline post_send_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3249 inline post_send_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3250 inline post_send_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
3251 inline post_send_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3252 inline post_send_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3253 inline post_send_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3254
3256 status_t call() const;
3257 inline status_t operator()() const { return call(); }
3258};
3259
3260inline status_t post_send(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) {
3261 return post_send_x(rank_in, local_buffer_in, size_in, tag_in, local_comp_in).call();
3262}
3263
3264
3289
3295 public:
3296 // args declaration
3299 size_t m_size;
3314
3315 // constructor
3316 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) {}
3317
3318 // setter
3319 inline post_recv_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3320 inline post_recv_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3321 inline post_recv_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3322 inline post_recv_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3323 inline post_recv_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3324 inline post_recv_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3325 inline post_recv_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3326 inline post_recv_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3327 inline post_recv_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3328 inline post_recv_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3329 inline post_recv_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3330 inline post_recv_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3331 inline post_recv_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3332 inline post_recv_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
3333 inline post_recv_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3334 inline post_recv_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3335 inline post_recv_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3336
3338 status_t call() const;
3339 inline status_t operator()() const { return call(); }
3340};
3341
3342inline status_t post_recv(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) {
3343 return post_recv_x(rank_in, local_buffer_in, size_in, tag_in, local_comp_in).call();
3344}
3345
3346
3372
3378 public:
3379 // args declaration
3382 size_t m_size;
3384 uintptr_t m_remote_disp;
3398
3399 // constructor
3400 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) {}
3401
3402 // setter
3403 inline post_put_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3404 inline post_put_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3405 inline post_put_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3406 inline post_put_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3407 inline post_put_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
3408 inline post_put_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
3409 inline post_put_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3410 inline post_put_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3411 inline post_put_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3412 inline post_put_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3413 inline post_put_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3414 inline post_put_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3415 inline post_put_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3416 inline post_put_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
3417 inline post_put_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3418 inline post_put_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3419 inline post_put_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3420 inline post_put_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3421
3423 status_t call() const;
3424 inline status_t operator()() const { return call(); }
3425};
3426
3427inline 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) {
3428 return post_put_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_disp_in, rmr_in).call();
3429}
3430
3431
3457
3463 public:
3464 // args declaration
3467 size_t m_size;
3469 uintptr_t m_remote_disp;
3483
3484 // constructor
3485 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) {}
3486
3487 // setter
3488 inline post_get_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3489 inline post_get_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3490 inline post_get_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3491 inline post_get_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3492 inline post_get_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
3493 inline post_get_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
3494 inline post_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3495 inline post_get_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3496 inline post_get_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3497 inline post_get_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3498 inline post_get_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3499 inline post_get_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3500 inline post_get_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3501 inline post_get_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
3502 inline post_get_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3503 inline post_get_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3504 inline post_get_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3505 inline post_get_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3506
3508 status_t call() const;
3509 inline status_t operator()() const { return call(); }
3510};
3511
3512inline 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) {
3513 return post_get_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_disp_in, rmr_in).call();
3514}
3515
3516
3527
3533 public:
3534 // args declaration
3538
3539 // constructor
3541
3542 // setter
3543 inline progress_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3544 inline progress_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3545 inline progress_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3546
3548 error_t call() const;
3549 inline error_t operator()() const { return call(); }
3550};
3551
3553 return progress_x().call();
3554}
3555
3556
3566
3572 public:
3573 // args declaration
3576
3577 // constructor
3579
3580 // setter
3581 inline test_drained_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3582 inline test_drained_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3583
3585 error_t call() const;
3586 inline error_t operator()() const { return call(); }
3587};
3588
3590 return test_drained_x().call();
3591}
3592
3593
3603
3609 public:
3610 // args declaration
3613
3614 // constructor
3616
3617 // setter
3618 inline wait_drained_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3619 inline wait_drained_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3620
3622 void call() const;
3623 inline void operator()() const { return call(); }
3624};
3625
3626inline void wait_drained() {
3627 return wait_drained_x().call();
3628}
3629
3630
3631} // namespace lci
3632
3633#endif // LCI_BINDING_POST_HPP_
The actual implementation for allgather.
Definition lci_binding_post.hpp:2922
allgather_x && size(size_t size_in)
Definition lci_binding_post.hpp:2939
allgather_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2938
void * m_recvbuf
Definition lci_binding_post.hpp:2926
size_t m_size
Definition lci_binding_post.hpp:2927
void call() const
Definition binding.cpp:776
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2928
const void * m_sendbuf
Definition lci_binding_post.hpp:2925
allgather_x && device(device_t device_in)
Definition lci_binding_post.hpp:2941
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2931
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2930
allgather_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2940
allgather_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2942
allgather_x(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:2934
allgather_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2943
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:2929
void operator()() const
Definition lci_binding_post.hpp:2947
allgather_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2937
The actual implementation for alloc_counter.
Definition lci_binding_post.hpp:2115
alloc_counter_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2126
alloc_counter_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2128
option_t< const char * > m_name
Definition lci_binding_post.hpp:2119
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2118
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2120
comp_t operator()() const
Definition lci_binding_post.hpp:2132
comp_t call_impl(runtime_t runtime, const char *name, void *user_context) const
comp_t call() const
Definition binding.cpp:616
alloc_counter_x && name(const char *name_in)
Definition lci_binding_post.hpp:2127
alloc_counter_x()
Definition lci_binding_post.hpp:2123
The actual implementation for alloc_cq.
Definition lci_binding_post.hpp:2235
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2238
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:2240
alloc_cq_x && cq_type(attr_cq_type_t cq_type_in)
Definition lci_binding_post.hpp:2252
alloc_cq_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:2251
comp_t operator()() const
Definition lci_binding_post.hpp:2258
option_t< int > m_default_length
Definition lci_binding_post.hpp:2239
option_t< attr_cq_type_t > m_cq_type
Definition lci_binding_post.hpp:2241
alloc_cq_x && default_length(int default_length_in)
Definition lci_binding_post.hpp:2250
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:2253
alloc_cq_x()
Definition lci_binding_post.hpp:2246
comp_t call() const
Definition binding.cpp:636
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2243
alloc_cq_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2254
option_t< const char * > m_name
Definition lci_binding_post.hpp:2242
alloc_cq_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2249
The actual implementation for alloc_device.
Definition lci_binding_post.hpp:992
alloc_device_x && alloc_default_endpoint(bool alloc_default_endpoint_in)
Definition lci_binding_post.hpp:1015
alloc_device_x()
Definition lci_binding_post.hpp:1008
option_t< const char * > m_name
Definition lci_binding_post.hpp:1001
option_t< net_context_t > m_net_context
Definition lci_binding_post.hpp:1004
alloc_device_x && net_max_recvs(size_t net_max_recvs_in)
Definition lci_binding_post.hpp:1012
option_t< attr_ibv_td_strategy_t > m_ibv_td_strategy
Definition lci_binding_post.hpp:1000
alloc_device_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1018
option_t< size_t > m_net_max_recvs
Definition lci_binding_post.hpp:996
alloc_device_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1021
alloc_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1019
alloc_device_x && name(const char *name_in)
Definition lci_binding_post.hpp:1017
alloc_device_x && ofi_lock_mode(uint64_t ofi_lock_mode_in)
Definition lci_binding_post.hpp:1014
option_t< uint64_t > m_ofi_lock_mode
Definition lci_binding_post.hpp:998
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1002
option_t< size_t > m_net_max_sends
Definition lci_binding_post.hpp:995
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:1005
device_t call_impl(size_t net_max_sends, size_t net_max_recvs, size_t net_max_cqes, uint64_t ofi_lock_mode, bool alloc_default_endpoint, attr_ibv_td_strategy_t ibv_td_strategy, const char *name, void *user_context, runtime_t runtime, net_context_t net_context, packet_pool_t packet_pool) const
option_t< size_t > m_net_max_cqes
Definition lci_binding_post.hpp:997
alloc_device_x && net_context(net_context_t net_context_in)
Definition lci_binding_post.hpp:1020
option_t< bool > m_alloc_default_endpoint
Definition lci_binding_post.hpp:999
device_t operator()() const
Definition lci_binding_post.hpp:1025
device_t call() const
Definition binding.cpp:373
alloc_device_x && net_max_cqes(size_t net_max_cqes_in)
Definition lci_binding_post.hpp:1013
alloc_device_x && ibv_td_strategy(attr_ibv_td_strategy_t ibv_td_strategy_in)
Definition lci_binding_post.hpp:1016
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1003
alloc_device_x && net_max_sends(size_t net_max_sends_in)
Definition lci_binding_post.hpp:1011
The actual implementation for alloc_endpoint.
Definition lci_binding_post.hpp:1203
endpoint_t call() const
Definition binding.cpp:423
alloc_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1217
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:1207
alloc_endpoint_x()
Definition lci_binding_post.hpp:1212
option_t< device_t > m_device
Definition lci_binding_post.hpp:1209
option_t< const char * > m_name
Definition lci_binding_post.hpp:1206
alloc_endpoint_x && device(device_t device_in)
Definition lci_binding_post.hpp:1218
endpoint_t operator()() const
Definition lci_binding_post.hpp:1222
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1208
alloc_endpoint_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1216
alloc_endpoint_x && name(const char *name_in)
Definition lci_binding_post.hpp:1215
The actual implementation for alloc_graph.
Definition lci_binding_post.hpp:2365
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2371
alloc_graph_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2380
comp_t call() const
Definition binding.cpp:661
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2370
alloc_graph_x && name(const char *name_in)
Definition lci_binding_post.hpp:2378
alloc_graph_x()
Definition lci_binding_post.hpp:2374
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:2379
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2368
alloc_graph_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2377
comp_t operator()() const
Definition lci_binding_post.hpp:2384
option_t< const char * > m_name
Definition lci_binding_post.hpp:2369
The actual implementation for alloc_handler.
Definition lci_binding_post.hpp:2320
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:2324
option_t< const char * > m_name
Definition lci_binding_post.hpp:2326
alloc_handler_x && handler(comp_handler_t handler_in)
Definition lci_binding_post.hpp:2333
alloc_handler_x(comp_handler_t handler_in)
Definition lci_binding_post.hpp:2330
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2327
comp_t call() const
Definition binding.cpp:652
comp_t operator()() const
Definition lci_binding_post.hpp:2341
alloc_handler_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:2335
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:2325
alloc_handler_x && name(const char *name_in)
Definition lci_binding_post.hpp:2336
alloc_handler_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2337
alloc_handler_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2334
comp_handler_t m_handler
Definition lci_binding_post.hpp:2323
The actual implementation for alloc_matching_engine.
Definition lci_binding_post.hpp:474
matching_engine_t operator()() const
Definition lci_binding_post.hpp:493
matching_engine_t call() const
Definition binding.cpp:260
alloc_matching_engine_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:488
option_t< attr_matching_engine_type_t > m_matching_engine_type
Definition lci_binding_post.hpp:477
option_t< void * > m_user_context
Definition lci_binding_post.hpp:479
alloc_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:489
alloc_matching_engine_x && name(const char *name_in)
Definition lci_binding_post.hpp:487
option_t< const char * > m_name
Definition lci_binding_post.hpp:478
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:486
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:480
alloc_matching_engine_x()
Definition lci_binding_post.hpp:483
The actual implementation for alloc_net_context.
Definition lci_binding_post.hpp:889
alloc_net_context_x && ofi_provider_name(std::string ofi_provider_name_in)
Definition lci_binding_post.hpp:910
option_t< int > m_ibv_gid_idx
Definition lci_binding_post.hpp:896
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:903
alloc_net_context_x && ibv_prefetch_strategy(attr_ibv_prefetch_strategy_t ibv_prefetch_strategy_in)
Definition lci_binding_post.hpp:916
alloc_net_context_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:920
option_t< attr_ibv_odp_strategy_t > m_ibv_odp_strategy
Definition lci_binding_post.hpp:898
alloc_net_context_x && ibv_gid_idx(int ibv_gid_idx_in)
Definition lci_binding_post.hpp:913
alloc_net_context_x()
Definition lci_binding_post.hpp:906
alloc_net_context_x && max_inject_size(size_t max_inject_size_in)
Definition lci_binding_post.hpp:912
option_t< void * > m_user_context
Definition lci_binding_post.hpp:902
alloc_net_context_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:919
option_t< bool > m_use_dmabuf
Definition lci_binding_post.hpp:900
alloc_net_context_x && backend(attr_backend_t backend_in)
Definition lci_binding_post.hpp:909
option_t< const char * > m_name
Definition lci_binding_post.hpp:901
alloc_net_context_x && ibv_force_gid_auto_select(bool ibv_force_gid_auto_select_in)
Definition lci_binding_post.hpp:914
alloc_net_context_x && name(const char *name_in)
Definition lci_binding_post.hpp:918
alloc_net_context_x && ibv_odp_strategy(attr_ibv_odp_strategy_t ibv_odp_strategy_in)
Definition lci_binding_post.hpp:915
alloc_net_context_x && use_dmabuf(bool use_dmabuf_in)
Definition lci_binding_post.hpp:917
option_t< attr_backend_t > m_backend
Definition lci_binding_post.hpp:892
alloc_net_context_x && max_msg_size(size_t max_msg_size_in)
Definition lci_binding_post.hpp:911
net_context_t call() const
Definition binding.cpp:340
net_context_t call_impl(attr_backend_t backend, std::string ofi_provider_name, size_t max_msg_size, size_t max_inject_size, int ibv_gid_idx, bool ibv_force_gid_auto_select, attr_ibv_odp_strategy_t ibv_odp_strategy, attr_ibv_prefetch_strategy_t ibv_prefetch_strategy, bool use_dmabuf, const char *name, void *user_context, runtime_t runtime) const
option_t< std::string > m_ofi_provider_name
Definition lci_binding_post.hpp:893
option_t< bool > m_ibv_force_gid_auto_select
Definition lci_binding_post.hpp:897
option_t< size_t > m_max_inject_size
Definition lci_binding_post.hpp:895
net_context_t operator()() const
Definition lci_binding_post.hpp:924
option_t< size_t > m_max_msg_size
Definition lci_binding_post.hpp:894
option_t< attr_ibv_prefetch_strategy_t > m_ibv_prefetch_strategy
Definition lci_binding_post.hpp:899
The actual implementation for alloc_packet_pool.
Definition lci_binding_post.hpp:238
packet_pool_t call() const
Definition binding.cpp:214
alloc_packet_pool_x()
Definition lci_binding_post.hpp:248
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:252
alloc_packet_pool_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:254
alloc_packet_pool_x && packet_size(size_t packet_size_in)
Definition lci_binding_post.hpp:251
alloc_packet_pool_x && name(const char *name_in)
Definition lci_binding_post.hpp:253
option_t< size_t > m_packet_size
Definition lci_binding_post.hpp:241
alloc_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:255
option_t< const char * > m_name
Definition lci_binding_post.hpp:243
packet_pool_t operator()() const
Definition lci_binding_post.hpp:259
option_t< void * > m_user_context
Definition lci_binding_post.hpp:244
option_t< size_t > m_npackets
Definition lci_binding_post.hpp:242
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:245
The actual implementation for alloc_runtime.
Definition lci_binding_post.hpp:33
alloc_runtime_x && imm_nbits_tag(int imm_nbits_tag_in)
Definition lci_binding_post.hpp:50
alloc_runtime_x && imm_nbits_rcomp(int imm_nbits_rcomp_in)
Definition lci_binding_post.hpp:51
option_t< bool > m_alloc_default_packet_pool
Definition lci_binding_post.hpp:40
alloc_runtime_x && name(const char *name_in)
Definition lci_binding_post.hpp:55
runtime_t operator()() const
Definition lci_binding_post.hpp:60
option_t< bool > m_alloc_default_matching_engine
Definition lci_binding_post.hpp:41
runtime_t call() const
Definition binding.cpp:167
alloc_runtime_x && alloc_default_packet_pool(bool alloc_default_packet_pool_in)
Definition lci_binding_post.hpp:53
alloc_runtime_x()
Definition lci_binding_post.hpp:46
alloc_runtime_x && alloc_default_matching_engine(bool alloc_default_matching_engine_in)
Definition lci_binding_post.hpp:54
alloc_runtime_x && alloc_default_device(bool alloc_default_device_in)
Definition lci_binding_post.hpp:52
alloc_runtime_x && packet_return_threshold(size_t packet_return_threshold_in)
Definition lci_binding_post.hpp:49
option_t< const char * > m_name
Definition lci_binding_post.hpp:42
alloc_runtime_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:56
runtime_t call_impl(size_t packet_return_threshold, int imm_nbits_tag, int imm_nbits_rcomp, bool alloc_default_device, bool alloc_default_packet_pool, bool alloc_default_matching_engine, const char *name, void *user_context) const
option_t< bool > m_alloc_default_device
Definition lci_binding_post.hpp:39
option_t< void * > m_user_context
Definition lci_binding_post.hpp:43
option_t< int > m_imm_nbits_rcomp
Definition lci_binding_post.hpp:38
option_t< size_t > m_packet_return_threshold
Definition lci_binding_post.hpp:36
option_t< int > m_imm_nbits_tag
Definition lci_binding_post.hpp:37
The actual implementation for alloc_sync.
Definition lci_binding_post.hpp:1985
comp_t operator()() const
Definition lci_binding_post.hpp:2006
option_t< int > m_threshold
Definition lci_binding_post.hpp:1989
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1992
alloc_sync_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2002
alloc_sync_x && threshold(int threshold_in)
Definition lci_binding_post.hpp:1999
alloc_sync_x && name(const char *name_in)
Definition lci_binding_post.hpp:2001
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:1990
alloc_sync_x()
Definition lci_binding_post.hpp:1995
option_t< const char * > m_name
Definition lci_binding_post.hpp:1991
alloc_sync_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:2000
alloc_sync_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1998
comp_t call() const
Definition binding.cpp:591
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1988
The actual implementation for allreduce.
Definition lci_binding_post.hpp:2860
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:2883
void operator()() const
Definition lci_binding_post.hpp:2895
const void * m_sendbuf
Definition lci_binding_post.hpp:2863
option_t< device_t > m_device
Definition lci_binding_post.hpp:2869
allreduce_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2880
reduce_op_t m_op
Definition lci_binding_post.hpp:2867
void * m_recvbuf
Definition lci_binding_post.hpp:2864
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:2874
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:2877
allreduce_x && device(device_t device_in)
Definition lci_binding_post.hpp:2886
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2871
size_t m_count
Definition lci_binding_post.hpp:2865
allreduce_x && count(size_t count_in)
Definition lci_binding_post.hpp:2882
allreduce_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2881
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2870
allreduce_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2887
option_t< allreduce_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:2873
allreduce_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:2884
allreduce_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2885
allreduce_x && algorithm(allreduce_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:2890
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2868
allreduce_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:2891
size_t m_item_size
Definition lci_binding_post.hpp:2866
allreduce_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2889
void call() const
Definition binding.cpp:760
allreduce_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2888
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2872
The actual implementation for alltoall.
Definition lci_binding_post.hpp:2975
const void * m_sendbuf
Definition lci_binding_post.hpp:2978
void call() const
Definition binding.cpp:787
alltoall_x && device(device_t device_in)
Definition lci_binding_post.hpp:2995
alltoall_x && size(size_t size_in)
Definition lci_binding_post.hpp:2993
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2984
alltoall_x(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:2988
void * m_recvbuf
Definition lci_binding_post.hpp:2979
alltoall_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2992
option_t< device_t > m_device
Definition lci_binding_post.hpp:2982
alltoall_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2997
alltoall_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2996
alltoall_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2994
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2981
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2983
alltoall_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2991
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:2985
alltoall_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:2998
size_t m_size
Definition lci_binding_post.hpp:2980
void operator()() const
Definition lci_binding_post.hpp:3002
void call_impl(const void *sendbuf, void *recvbuf, size_t size, runtime_t runtime, device_t device, endpoint_t endpoint, matching_engine_t matching_engine, comp_semantic_t comp_semantic) const
The actual implementation for barrier.
Definition lci_binding_post.hpp:2616
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2624
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2622
barrier_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2633
barrier_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2635
barrier_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:2634
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:2620
void call() const
Definition binding.cpp:706
barrier_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2632
barrier_x()
Definition lci_binding_post.hpp:2627
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2621
barrier_x && device(device_t device_in)
Definition lci_binding_post.hpp:2631
void operator()() const
Definition lci_binding_post.hpp:2639
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:2623
barrier_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2630
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2619
The actual implementation for broadcast.
Definition lci_binding_post.hpp:2669
broadcast_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2693
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2677
void call() const
Definition binding.cpp:716
void operator()() const
Definition lci_binding_post.hpp:2700
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2678
int m_root
Definition lci_binding_post.hpp:2674
broadcast_x && root(int root_in)
Definition lci_binding_post.hpp:2689
broadcast_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2694
broadcast_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2690
broadcast_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:2696
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2675
broadcast_x && size(size_t size_in)
Definition lci_binding_post.hpp:2688
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:2681
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2679
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:2684
broadcast_x && device(device_t device_in)
Definition lci_binding_post.hpp:2691
option_t< broadcast_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:2680
void * m_buffer
Definition lci_binding_post.hpp:2672
option_t< device_t > m_device
Definition lci_binding_post.hpp:2676
broadcast_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:2687
broadcast_x && algorithm(broadcast_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:2695
broadcast_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2692
size_t m_size
Definition lci_binding_post.hpp:2673
The actual implementation for comp_signal.
Definition lci_binding_post.hpp:1829
comp_signal_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1842
comp_signal_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1840
status_t m_status
Definition lci_binding_post.hpp:1833
comp_t m_comp
Definition lci_binding_post.hpp:1832
void call() const
Definition binding.cpp:565
comp_signal_x(comp_t comp_in, status_t status_in)
Definition lci_binding_post.hpp:1837
void call_impl(comp_t comp, status_t status, runtime_t runtime) const
void operator()() const
Definition lci_binding_post.hpp:1846
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1834
comp_signal_x && status(status_t status_in)
Definition lci_binding_post.hpp:1841
The actual implementation for RESOURCE comp.
Definition lci_binding_pre.hpp:490
The actual implementation for counter_get.
Definition lci_binding_post.hpp:2154
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2158
int64_t call_impl(comp_t comp, runtime_t runtime) const
int64_t operator()() const
Definition lci_binding_post.hpp:2169
counter_get_x(comp_t comp_in)
Definition lci_binding_post.hpp:2161
int64_t call() const
Definition binding.cpp:623
counter_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2165
comp_t m_comp
Definition lci_binding_post.hpp:2157
counter_get_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2164
The actual implementation for counter_set.
Definition lci_binding_post.hpp:2192
counter_set_x(comp_t comp_in, int64_t value_in)
Definition lci_binding_post.hpp:2200
int64_t m_value
Definition lci_binding_post.hpp:2196
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2197
comp_t m_comp
Definition lci_binding_post.hpp:2195
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:2205
counter_set_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2203
void operator()() const
Definition lci_binding_post.hpp:2209
counter_set_x && value(int64_t value_in)
Definition lci_binding_post.hpp:2204
void call() const
Definition binding.cpp:629
The actual implementation for cq_pop.
Definition lci_binding_post.hpp:2280
status_t operator()() const
Definition lci_binding_post.hpp:2295
comp_t m_comp
Definition lci_binding_post.hpp:2283
status_t call_impl(comp_t comp, runtime_t runtime) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2284
cq_pop_x(comp_t comp_in)
Definition lci_binding_post.hpp:2287
cq_pop_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2290
cq_pop_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2291
status_t call() const
Definition binding.cpp:646
The actual implementation for deregister_memory.
Definition lci_binding_post.hpp:1127
void operator()() const
Definition lci_binding_post.hpp:1142
void call() const
Definition binding.cpp:406
mr_t * m_mr
Definition lci_binding_post.hpp:1130
deregister_memory_x && mr(mr_t *mr_in)
Definition lci_binding_post.hpp:1137
deregister_memory_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1138
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1131
void call_impl(mr_t *mr, runtime_t runtime) const
deregister_memory_x(mr_t *mr_in)
Definition lci_binding_post.hpp:1134
The actual implementation for deregister_packet_pool.
Definition lci_binding_post.hpp:359
deregister_packet_pool_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:370
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:362
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:364
void operator()() const
Definition lci_binding_post.hpp:376
void call() const
Definition binding.cpp:236
deregister_packet_pool_x && device(device_t device_in)
Definition lci_binding_post.hpp:371
device_t m_device
Definition lci_binding_post.hpp:363
deregister_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:372
deregister_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:367
The actual implementation for deregister_rcomp.
Definition lci_binding_post.hpp:1945
deregister_rcomp_x(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:1952
void operator()() const
Definition lci_binding_post.hpp:1960
rcomp_t m_rcomp
Definition lci_binding_post.hpp:1948
void call_impl(rcomp_t rcomp, runtime_t runtime) const
void call() const
Definition binding.cpp:585
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1949
deregister_rcomp_x && rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:1955
deregister_rcomp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1956
The actual implementation for RESOURCE device.
Definition lci_binding_pre.hpp:377
The actual implementation for RESOURCE endpoint.
Definition lci_binding_pre.hpp:451
The actual implementation for free_comp.
Definition lci_binding_post.hpp:1791
free_comp_x(comp_t *comp_in)
Definition lci_binding_post.hpp:1798
free_comp_x && comp(comp_t *comp_in)
Definition lci_binding_post.hpp:1801
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1795
comp_t * m_comp
Definition lci_binding_post.hpp:1794
void call() const
Definition binding.cpp:559
free_comp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1802
void operator()() const
Definition lci_binding_post.hpp:1806
void call_impl(comp_t *comp, runtime_t runtime) const
The actual implementation for free_device.
Definition lci_binding_post.hpp:1047
void call_impl(device_t *device, runtime_t runtime) const
free_device_x && device(device_t *device_in)
Definition lci_binding_post.hpp:1057
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1051
device_t * m_device
Definition lci_binding_post.hpp:1050
void operator()() const
Definition lci_binding_post.hpp:1062
void call() const
Definition binding.cpp:388
free_device_x(device_t *device_in)
Definition lci_binding_post.hpp:1054
free_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1058
The actual implementation for free_endpoint.
Definition lci_binding_post.hpp:1244
void operator()() const
Definition lci_binding_post.hpp:1259
endpoint_t * m_endpoint
Definition lci_binding_post.hpp:1247
free_endpoint_x && endpoint(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:1254
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1248
free_endpoint_x(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:1251
void call_impl(endpoint_t *endpoint, runtime_t runtime) const
void call() const
Definition binding.cpp:431
free_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1255
The actual implementation for free_matching_engine.
Definition lci_binding_post.hpp:515
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:525
free_matching_engine_x(matching_engine_t *matching_engine_in)
Definition lci_binding_post.hpp:522
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:519
matching_engine_t * m_matching_engine
Definition lci_binding_post.hpp:518
void call() const
Definition binding.cpp:268
free_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:526
void operator()() const
Definition lci_binding_post.hpp:530
The actual implementation for free_net_context.
Definition lci_binding_post.hpp:946
void operator()() const
Definition lci_binding_post.hpp:961
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:957
free_net_context_x(net_context_t *net_context_in)
Definition lci_binding_post.hpp:953
void call() const
Definition binding.cpp:356
net_context_t * m_net_context
Definition lci_binding_post.hpp:949
free_net_context_x && net_context(net_context_t *net_context_in)
Definition lci_binding_post.hpp:956
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:950
The actual implementation for free_packet_pool.
Definition lci_binding_post.hpp:281
void operator()() const
Definition lci_binding_post.hpp:296
free_packet_pool_x(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:288
void call() const
Definition binding.cpp:223
void call_impl(packet_pool_t *packet_pool, runtime_t runtime) const
packet_pool_t * m_packet_pool
Definition lci_binding_post.hpp:284
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:285
free_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:292
free_packet_pool_x && packet_pool(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:291
The actual implementation for free_runtime.
Definition lci_binding_post.hpp:81
void call_impl(runtime_t *runtime) const
free_runtime_x(runtime_t *runtime_in)
Definition lci_binding_post.hpp:87
runtime_t * m_runtime
Definition lci_binding_post.hpp:84
free_runtime_x && runtime(runtime_t *runtime_in)
Definition lci_binding_post.hpp:90
void operator()() const
Definition lci_binding_post.hpp:94
void call() const
Definition binding.cpp:180
The actual implementation for g_runtime_fina.
Definition lci_binding_post.hpp:170
g_runtime_fina_x()
Definition lci_binding_post.hpp:175
void call() const
Definition binding.cpp:199
void operator()() const
Definition lci_binding_post.hpp:181
void call_impl() const
The actual implementation for g_runtime_init.
Definition lci_binding_post.hpp:122
g_runtime_init_x && imm_nbits_rcomp(int imm_nbits_rcomp_in)
Definition lci_binding_post.hpp:140
g_runtime_init_x && alloc_default_packet_pool(bool alloc_default_packet_pool_in)
Definition lci_binding_post.hpp:142
g_runtime_init_x && imm_nbits_tag(int imm_nbits_tag_in)
Definition lci_binding_post.hpp:139
option_t< int > m_imm_nbits_tag
Definition lci_binding_post.hpp:126
option_t< int > m_imm_nbits_rcomp
Definition lci_binding_post.hpp:127
option_t< size_t > m_packet_return_threshold
Definition lci_binding_post.hpp:125
g_runtime_init_x && name(const char *name_in)
Definition lci_binding_post.hpp:144
option_t< void * > m_user_context
Definition lci_binding_post.hpp:132
option_t< bool > m_alloc_default_device
Definition lci_binding_post.hpp:128
g_runtime_init_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:145
g_runtime_init_x && alloc_default_matching_engine(bool alloc_default_matching_engine_in)
Definition lci_binding_post.hpp:143
runtime_t call() const
Definition binding.cpp:186
option_t< bool > m_alloc_default_matching_engine
Definition lci_binding_post.hpp:130
option_t< bool > m_alloc_default_packet_pool
Definition lci_binding_post.hpp:129
g_runtime_init_x()
Definition lci_binding_post.hpp:135
runtime_t call_impl(size_t packet_return_threshold, int imm_nbits_tag, int imm_nbits_rcomp, bool alloc_default_device, bool alloc_default_packet_pool, bool alloc_default_matching_engine, const char *name, void *user_context) const
g_runtime_init_x && alloc_default_device(bool alloc_default_device_in)
Definition lci_binding_post.hpp:141
option_t< const char * > m_name
Definition lci_binding_post.hpp:131
g_runtime_init_x && packet_return_threshold(size_t packet_return_threshold_in)
Definition lci_binding_post.hpp:138
runtime_t operator()() const
Definition lci_binding_post.hpp:149
The actual implementation for get_allocator.
Definition lci_binding_post.hpp:634
allocator_base_t * call_impl(runtime_t runtime) const
allocator_base_t * call() const
Definition binding.cpp:289
allocator_base_t * operator()() const
Definition lci_binding_post.hpp:647
get_allocator_x()
Definition lci_binding_post.hpp:640
get_allocator_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:643
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:637
The actual implementation for get_default_device.
Definition lci_binding_post.hpp:702
device_t call_impl(runtime_t runtime) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:705
get_default_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:711
device_t call() const
Definition binding.cpp:299
get_default_device_x()
Definition lci_binding_post.hpp:708
device_t operator()() const
Definition lci_binding_post.hpp:715
The actual implementation for get_default_endpoint.
Definition lci_binding_post.hpp:737
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:748
endpoint_t operator()() const
Definition lci_binding_post.hpp:752
endpoint_t call() const
Definition binding.cpp:304
get_default_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:747
get_default_endpoint_x()
Definition lci_binding_post.hpp:744
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:740
option_t< device_t > m_device
Definition lci_binding_post.hpp:741
The actual implementation for get_default_matching_engine.
Definition lci_binding_post.hpp:807
get_default_matching_engine_x()
Definition lci_binding_post.hpp:813
matching_engine_t call() const
Definition binding.cpp:315
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:810
matching_engine_t call_impl(runtime_t runtime) const
matching_engine_t operator()() const
Definition lci_binding_post.hpp:820
get_default_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:816
The actual implementation for get_default_net_context.
Definition lci_binding_post.hpp:668
net_context_t operator()() const
Definition lci_binding_post.hpp:681
get_default_net_context_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:677
get_default_net_context_x()
Definition lci_binding_post.hpp:674
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:671
net_context_t call_impl(runtime_t runtime) const
net_context_t call() const
Definition binding.cpp:294
The actual implementation for get_default_packet_pool.
Definition lci_binding_post.hpp:773
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:776
packet_pool_t operator()() const
Definition lci_binding_post.hpp:786
packet_pool_t call_impl(runtime_t runtime) const
packet_pool_t call() const
Definition binding.cpp:310
get_default_packet_pool_x()
Definition lci_binding_post.hpp:779
get_default_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:782
The actual implementation for get_g_runtime.
Definition lci_binding_post.hpp:202
runtime_t operator()() const
Definition lci_binding_post.hpp:213
get_g_runtime_x()
Definition lci_binding_post.hpp:207
runtime_t call() const
Definition binding.cpp:204
runtime_t call_impl() const
The actual implementation for get_max_bcopy_size.
Definition lci_binding_post.hpp:842
size_t operator()() const
Definition lci_binding_post.hpp:857
get_max_bcopy_size_x()
Definition lci_binding_post.hpp:849
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:845
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:846
get_max_bcopy_size_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:853
size_t call() const
Definition binding.cpp:320
get_max_bcopy_size_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:852
The actual implementation for get_rmr.
Definition lci_binding_post.hpp:1164
get_rmr_x(mr_t mr_in)
Definition lci_binding_post.hpp:1171
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1168
get_rmr_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1174
rmr_t operator()() const
Definition lci_binding_post.hpp:1179
mr_t m_mr
Definition lci_binding_post.hpp:1167
rmr_t call() const
Definition binding.cpp:412
get_rmr_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1175
rmr_t call_impl(mr_t mr, runtime_t runtime) const
The actual implementation for get_upacket.
Definition lci_binding_post.hpp:398
get_upacket_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:409
void * call() const
Definition binding.cpp:243
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:401
get_upacket_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:408
void * operator()() const
Definition lci_binding_post.hpp:413
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:402
get_upacket_x()
Definition lci_binding_post.hpp:405
The actual implementation for graph_add_edge.
Definition lci_binding_post.hpp:2455
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:2458
void call() const
Definition binding.cpp:678
graph_add_edge_x(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in)
Definition lci_binding_post.hpp:2465
graph_add_edge_x && dst(graph_node_t dst_in)
Definition lci_binding_post.hpp:2470
graph_add_edge_x && fn(graph_edge_run_cb_t fn_in)
Definition lci_binding_post.hpp:2471
void operator()() const
Definition lci_binding_post.hpp:2476
option_t< graph_edge_run_cb_t > m_fn
Definition lci_binding_post.hpp:2461
graph_add_edge_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2468
graph_node_t m_dst
Definition lci_binding_post.hpp:2460
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2462
graph_add_edge_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2472
graph_add_edge_x && src(graph_node_t src_in)
Definition lci_binding_post.hpp:2469
graph_node_t m_src
Definition lci_binding_post.hpp:2459
The actual implementation for graph_add_node.
Definition lci_binding_post.hpp:2409
option_t< void * > m_value
Definition lci_binding_post.hpp:2414
graph_node_t operator()() const
Definition lci_binding_post.hpp:2430
graph_add_node_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2426
graph_node_t call() const
Definition binding.cpp:669
graph_add_node_x(comp_t comp_in, graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:2419
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:2423
graph_node_run_cb_t m_fn
Definition lci_binding_post.hpp:2413
comp_t m_comp
Definition lci_binding_post.hpp:2412
graph_add_node_x && free_cb(graph_node_free_cb_t free_cb_in)
Definition lci_binding_post.hpp:2425
graph_add_node_x && value(void *value_in)
Definition lci_binding_post.hpp:2424
option_t< graph_node_free_cb_t > m_free_cb
Definition lci_binding_post.hpp:2415
graph_add_node_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2422
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2416
The actual implementation for graph_node_mark_complete.
Definition lci_binding_post.hpp:2499
void operator()() const
Definition lci_binding_post.hpp:2516
void call() const
Definition binding.cpp:687
graph_node_t m_node
Definition lci_binding_post.hpp:2502
graph_node_mark_complete_x(graph_node_t node_in)
Definition lci_binding_post.hpp:2507
option_t< status_t > m_status
Definition lci_binding_post.hpp:2503
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:2510
graph_node_mark_complete_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2512
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2504
graph_node_mark_complete_x && status(status_t status_in)
Definition lci_binding_post.hpp:2511
The actual implementation for graph_start.
Definition lci_binding_post.hpp:2538
graph_start_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2549
comp_t m_comp
Definition lci_binding_post.hpp:2541
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2542
graph_start_x(comp_t comp_in)
Definition lci_binding_post.hpp:2545
void call_impl(comp_t comp, runtime_t runtime) const
void call() const
Definition binding.cpp:694
void operator()() const
Definition lci_binding_post.hpp:2553
graph_start_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2548
The actual implementation for graph_test.
Definition lci_binding_post.hpp:2575
comp_t m_comp
Definition lci_binding_post.hpp:2578
status_t call_impl(comp_t comp, runtime_t runtime) const
graph_test_x(comp_t comp_in)
Definition lci_binding_post.hpp:2582
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2579
graph_test_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2586
status_t operator()() const
Definition lci_binding_post.hpp:2590
status_t call() const
Definition binding.cpp:700
graph_test_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2585
The actual implementation for matching_engine_insert.
Definition lci_binding_post.hpp:555
matching_engine_insert_x && value(matching_entry_val_t value_in)
Definition lci_binding_post.hpp:570
matching_engine_insert_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:572
matching_entry_val_t operator()() const
Definition lci_binding_post.hpp:576
matching_entry_val_t call() const
Definition binding.cpp:274
matching_engine_insert_x && entry_type(matching_entry_type_t entry_type_in)
Definition lci_binding_post.hpp:571
matching_engine_insert_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:568
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:562
matching_entry_type_t m_entry_type
Definition lci_binding_post.hpp:561
matching_engine_t m_matching_engine
Definition lci_binding_post.hpp:558
matching_entry_key_t m_key
Definition lci_binding_post.hpp:559
matching_engine_insert_x && key(matching_entry_key_t key_in)
Definition lci_binding_post.hpp:569
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:565
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:560
The actual implementation for RESOURCE matching_engine.
Definition lci_binding_pre.hpp:283
The actual implementation for RESOURCE mr.
Definition lci_binding_pre.hpp:417
The actual implementation for RESOURCE net_context.
Definition lci_binding_pre.hpp:327
The actual implementation for net_poll_cq.
Definition lci_binding_post.hpp:1283
net_poll_cq_x && device(device_t device_in)
Definition lci_binding_post.hpp:1298
net_poll_cq_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1297
option_t< device_t > m_device
Definition lci_binding_post.hpp:1289
net_poll_cq_x(size_t max_polls_in, net_status_t *statuses_in)
Definition lci_binding_post.hpp:1292
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1288
net_poll_cq_x && statuses(net_status_t *statuses_in)
Definition lci_binding_post.hpp:1296
size_t operator()() const
Definition lci_binding_post.hpp:1302
size_t call() const
Definition binding.cpp:437
net_poll_cq_x && max_polls(size_t max_polls_in)
Definition lci_binding_post.hpp:1295
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:1286
net_status_t * m_statuses
Definition lci_binding_post.hpp:1287
The actual implementation for net_post_get.
Definition lci_binding_post.hpp:1738
net_post_get_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1757
net_post_get_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1764
net_post_get_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1761
option_t< device_t > m_device
Definition lci_binding_post.hpp:1748
int m_rank
Definition lci_binding_post.hpp:1741
net_post_get_x && device(device_t device_in)
Definition lci_binding_post.hpp:1763
net_post_get_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1759
error_t operator()() const
Definition lci_binding_post.hpp:1769
net_post_get_x && size(size_t size_in)
Definition lci_binding_post.hpp:1758
error_t call() const
Definition binding.cpp:536
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1747
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1749
mr_t m_mr
Definition lci_binding_post.hpp:1744
void * m_buffer
Definition lci_binding_post.hpp:1742
net_post_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1762
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:1745
net_post_get_x && rank(int rank_in)
Definition lci_binding_post.hpp:1756
rmr_t m_rmr
Definition lci_binding_post.hpp:1746
size_t m_size
Definition lci_binding_post.hpp:1743
net_post_get_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1765
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1750
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:1753
net_post_get_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1760
The actual implementation for net_post_putImm.
Definition lci_binding_post.hpp:1675
net_post_putImm_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1702
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:1691
rmr_t m_rmr
Definition lci_binding_post.hpp:1683
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1684
net_post_putImm_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1697
net_post_putImm_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1699
error_t call() const
Definition binding.cpp:521
net_post_putImm_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1703
int m_rank
Definition lci_binding_post.hpp:1678
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1687
net_post_putImm_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1700
option_t< device_t > m_device
Definition lci_binding_post.hpp:1685
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1686
mr_t m_mr
Definition lci_binding_post.hpp:1681
net_post_putImm_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1695
void * m_buffer
Definition lci_binding_post.hpp:1679
net_post_putImm_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1704
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1688
error_t operator()() const
Definition lci_binding_post.hpp:1708
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:1680
net_post_putImm_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1698
uint64_t m_offset
Definition lci_binding_post.hpp:1682
net_post_putImm_x && size(size_t size_in)
Definition lci_binding_post.hpp:1696
net_post_putImm_x && rank(int rank_in)
Definition lci_binding_post.hpp:1694
net_post_putImm_x && device(device_t device_in)
Definition lci_binding_post.hpp:1701
The actual implementation for net_post_putImms.
Definition lci_binding_post.hpp:1613
net_post_putImms_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1632
net_post_putImms_x && device(device_t device_in)
Definition lci_binding_post.hpp:1637
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1623
option_t< device_t > m_device
Definition lci_binding_post.hpp:1622
net_post_putImms_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1635
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:1631
uint64_t m_offset
Definition lci_binding_post.hpp:1619
void * m_buffer
Definition lci_binding_post.hpp:1617
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1624
int m_rank
Definition lci_binding_post.hpp:1616
error_t operator()() const
Definition lci_binding_post.hpp:1644
net_post_putImms_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1634
error_t call() const
Definition binding.cpp:507
rmr_t m_rmr
Definition lci_binding_post.hpp:1620
net_post_putImms_x && size(size_t size_in)
Definition lci_binding_post.hpp:1633
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1625
net_post_putImms_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1638
net_post_putImms_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1639
size_t m_size
Definition lci_binding_post.hpp:1618
net_post_putImms_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1636
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1621
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:1628
net_post_putImms_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1640
The actual implementation for net_post_put.
Definition lci_binding_post.hpp:1552
rmr_t m_rmr
Definition lci_binding_post.hpp:1560
net_post_put_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1571
mr_t m_mr
Definition lci_binding_post.hpp:1558
net_post_put_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1575
int m_rank
Definition lci_binding_post.hpp:1555
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:1567
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:1561
error_t call() const
Definition binding.cpp:493
net_post_put_x && rank(int rank_in)
Definition lci_binding_post.hpp:1570
option_t< device_t > m_device
Definition lci_binding_post.hpp:1562
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1563
net_post_put_x && device(device_t device_in)
Definition lci_binding_post.hpp:1577
net_post_put_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1579
net_post_put_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1578
net_post_put_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1573
net_post_put_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1574
net_post_put_x && size(size_t size_in)
Definition lci_binding_post.hpp:1572
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1564
size_t m_size
Definition lci_binding_post.hpp:1557
net_post_put_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1576
error_t operator()() const
Definition lci_binding_post.hpp:1583
uint64_t m_offset
Definition lci_binding_post.hpp:1559
void * m_buffer
Definition lci_binding_post.hpp:1556
The actual implementation for net_post_puts.
Definition lci_binding_post.hpp:1493
net_post_puts_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1514
net_post_puts_x && rank(int rank_in)
Definition lci_binding_post.hpp:1510
error_t operator()() const
Definition lci_binding_post.hpp:1522
net_post_puts_x && size(size_t size_in)
Definition lci_binding_post.hpp:1512
option_t< device_t > m_device
Definition lci_binding_post.hpp:1502
void * m_buffer
Definition lci_binding_post.hpp:1497
net_post_puts_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1513
net_post_puts_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1515
net_post_puts_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1511
net_post_puts_x && device(device_t device_in)
Definition lci_binding_post.hpp:1516
error_t call() const
Definition binding.cpp:480
int m_rank
Definition lci_binding_post.hpp:1496
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:1507
rmr_t m_rmr
Definition lci_binding_post.hpp:1500
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1501
size_t m_size
Definition lci_binding_post.hpp:1498
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1504
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:1518
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1503
net_post_puts_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1517
uint64_t m_offset
Definition lci_binding_post.hpp:1499
The actual implementation for net_post_recv.
Definition lci_binding_post.hpp:1328
net_post_recv_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1345
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1336
net_post_recv_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1342
error_t call() const
Definition binding.cpp:445
net_post_recv_x(void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1339
net_post_recv_x && size(size_t size_in)
Definition lci_binding_post.hpp:1343
net_post_recv_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1344
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1334
option_t< device_t > m_device
Definition lci_binding_post.hpp:1335
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:1333
size_t m_size
Definition lci_binding_post.hpp:1332
error_t operator()() const
Definition lci_binding_post.hpp:1351
net_post_recv_x && device(device_t device_in)
Definition lci_binding_post.hpp:1346
void * m_buffer
Definition lci_binding_post.hpp:1331
net_post_recv_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1347
The actual implementation for net_post_send.
Definition lci_binding_post.hpp:1435
net_post_send_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1459
net_post_send_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1456
net_post_send_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1453
void * m_buffer
Definition lci_binding_post.hpp:1439
int m_rank
Definition lci_binding_post.hpp:1438
mr_t m_mr
Definition lci_binding_post.hpp:1441
size_t m_size
Definition lci_binding_post.hpp:1440
net_post_send_x && size(size_t size_in)
Definition lci_binding_post.hpp:1454
error_t call() const
Definition binding.cpp:467
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1442
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1445
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1444
net_post_send_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1455
net_post_send_x && device(device_t device_in)
Definition lci_binding_post.hpp:1457
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1446
net_post_send_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1458
net_post_send_x(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1449
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:1443
error_t operator()() const
Definition lci_binding_post.hpp:1464
net_post_send_x && rank(int rank_in)
Definition lci_binding_post.hpp:1452
net_post_send_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1460
The actual implementation for net_post_sends.
Definition lci_binding_post.hpp:1379
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1389
net_post_sends_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1401
net_post_sends_x && size(size_t size_in)
Definition lci_binding_post.hpp:1397
error_t call() const
Definition binding.cpp:455
option_t< device_t > m_device
Definition lci_binding_post.hpp:1386
net_post_sends_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1400
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:1382
net_post_sends_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1398
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1388
net_post_sends_x(int rank_in, void *buffer_in, size_t size_in)
Definition lci_binding_post.hpp:1392
net_post_sends_x && rank(int rank_in)
Definition lci_binding_post.hpp:1395
void * m_buffer
Definition lci_binding_post.hpp:1383
net_post_sends_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1402
error_t operator()() const
Definition lci_binding_post.hpp:1406
net_post_sends_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1396
size_t m_size
Definition lci_binding_post.hpp:1384
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1387
net_post_sends_x && device(device_t device_in)
Definition lci_binding_post.hpp:1399
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1385
The actual implementation for RESOURCE packet_pool.
Definition lci_binding_pre.hpp:247
The actual implementation for post_am.
Definition lci_binding_post.hpp:3132
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3145
option_t< device_t > m_device
Definition lci_binding_post.hpp:3141
post_am_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3164
rcomp_t m_remote_comp
Definition lci_binding_post.hpp:3139
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:3146
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3149
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:3153
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3142
post_am_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3169
post_am_x && size(size_t size_in)
Definition lci_binding_post.hpp:3158
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3150
post_am_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3161
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3140
post_am_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3167
int m_rank
Definition lci_binding_post.hpp:3135
post_am_x && rank(int rank_in)
Definition lci_binding_post.hpp:3156
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3143
post_am_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3165
status_t call() const
Definition binding.cpp:824
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3144
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:3166
comp_t m_local_comp
Definition lci_binding_post.hpp:3138
post_am_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3171
post_am_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3170
post_am_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3157
size_t m_size
Definition lci_binding_post.hpp:3137
post_am_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3163
post_am_x && device(device_t device_in)
Definition lci_binding_post.hpp:3162
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3148
post_am_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3168
void * m_local_buffer
Definition lci_binding_post.hpp:3136
post_am_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3159
status_t operator()() const
Definition lci_binding_post.hpp:3175
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3147
post_am_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:3160
The actual implementation for post_comm.
Definition lci_binding_post.hpp:3043
status_t call() const
Definition binding.cpp:799
void * m_local_buffer
Definition lci_binding_post.hpp:3048
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3062
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:3063
post_comm_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:3087
option_t< device_t > m_device
Definition lci_binding_post.hpp:3052
post_comm_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3081
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3066
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:3047
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:3055
post_comm_x && rank(int rank_in)
Definition lci_binding_post.hpp:3073
post_comm_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3077
post_comm_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3074
size_t m_size
Definition lci_binding_post.hpp:3049
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3051
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3057
comp_t m_local_comp
Definition lci_binding_post.hpp:3050
status_t operator()() const
Definition lci_binding_post.hpp:3096
option_t< rmr_t > m_rmr
Definition lci_binding_post.hpp:3059
post_comm_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3088
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3065
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:3069
option_t< uintptr_t > m_remote_disp
Definition lci_binding_post.hpp:3058
post_comm_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3080
post_comm_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3090
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3053
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:3061
post_comm_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3076
post_comm_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3086
post_comm_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:3085
post_comm_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3083
post_comm_x && direction(direction_t direction_in)
Definition lci_binding_post.hpp:3072
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3064
post_comm_x && size(size_t size_in)
Definition lci_binding_post.hpp:3075
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3054
post_comm_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3079
post_comm_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3091
post_comm_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3082
post_comm_x && device(device_t device_in)
Definition lci_binding_post.hpp:3078
post_comm_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3092
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3056
post_comm_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:3089
direction_t m_direction
Definition lci_binding_post.hpp:3046
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:3060
post_comm_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:3084
The actual implementation for post_get.
Definition lci_binding_post.hpp:3462
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:3478
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3479
post_get_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3503
post_get_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3500
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3475
comp_t m_local_comp
Definition lci_binding_post.hpp:3468
post_get_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3498
post_get_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:3492
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:3485
post_get_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3499
status_t operator()() const
Definition lci_binding_post.hpp:3509
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3474
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3482
uintptr_t m_remote_disp
Definition lci_binding_post.hpp:3469
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:3466
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3480
option_t< device_t > m_device
Definition lci_binding_post.hpp:3472
post_get_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:3493
int m_rank
Definition lci_binding_post.hpp:3465
post_get_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3489
post_get_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:3501
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3471
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3481
post_get_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3504
post_get_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3497
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3473
post_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3494
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3476
post_get_x && size(size_t size_in)
Definition lci_binding_post.hpp:3490
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:3477
post_get_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3496
status_t call() const
Definition binding.cpp:908
post_get_x && rank(int rank_in)
Definition lci_binding_post.hpp:3488
post_get_x && device(device_t device_in)
Definition lci_binding_post.hpp:3495
post_get_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3491
post_get_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3502
size_t m_size
Definition lci_binding_post.hpp:3467
rmr_t m_rmr
Definition lci_binding_post.hpp:3470
post_get_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3505
The actual implementation for post_put.
Definition lci_binding_post.hpp:3377
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:3395
post_put_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3417
post_put_x && device(device_t device_in)
Definition lci_binding_post.hpp:3410
status_t operator()() const
Definition lci_binding_post.hpp:3424
post_put_x && rank(int rank_in)
Definition lci_binding_post.hpp:3403
post_put_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3409
post_put_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3411
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3396
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3388
comp_t m_local_comp
Definition lci_binding_post.hpp:3383
uintptr_t m_remote_disp
Definition lci_binding_post.hpp:3384
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3397
option_t< device_t > m_device
Definition lci_binding_post.hpp:3387
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3394
post_put_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3404
int m_rank
Definition lci_binding_post.hpp:3380
post_put_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3412
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:3393
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:3400
post_put_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3415
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3391
post_put_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3418
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:3392
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3390
post_put_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3413
status_t call() const
Definition binding.cpp:886
post_put_x && size(size_t size_in)
Definition lci_binding_post.hpp:3405
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3386
post_put_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3420
post_put_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:3408
post_put_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3406
post_put_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:3407
rmr_t m_rmr
Definition lci_binding_post.hpp:3385
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3389
size_t m_size
Definition lci_binding_post.hpp:3382
post_put_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:3416
post_put_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3414
void * m_local_buffer
Definition lci_binding_post.hpp:3381
post_put_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3419
The actual implementation for post_recv.
Definition lci_binding_post.hpp:3294
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3313
post_recv_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3334
size_t m_size
Definition lci_binding_post.hpp:3299
post_recv_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3333
post_recv_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3322
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3309
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:3306
tag_t m_tag
Definition lci_binding_post.hpp:3300
post_recv_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3327
post_recv_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3324
option_t< device_t > m_device
Definition lci_binding_post.hpp:3303
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3311
post_recv_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3329
post_recv_x && size(size_t size_in)
Definition lci_binding_post.hpp:3321
status_t operator()() const
Definition lci_binding_post.hpp:3339
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3305
post_recv_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3331
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3307
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3308
void * m_local_buffer
Definition lci_binding_post.hpp:3298
post_recv_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3326
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3304
post_recv_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3328
comp_t m_local_comp
Definition lci_binding_post.hpp:3301
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3312
post_recv_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3330
post_recv_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3335
post_recv_x && device(device_t device_in)
Definition lci_binding_post.hpp:3325
int m_rank
Definition lci_binding_post.hpp:3297
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:3316
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3302
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:3310
post_recv_x && rank(int rank_in)
Definition lci_binding_post.hpp:3319
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:3323
post_recv_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:3332
post_recv_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3320
status_t call() const
Definition binding.cpp:865
The actual implementation for post_send.
Definition lci_binding_post.hpp:3212
post_send_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3251
post_send_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3241
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3223
status_t call() const
Definition binding.cpp:844
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:3224
post_send_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3244
void * m_local_buffer
Definition lci_binding_post.hpp:3216
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3227
post_send_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3248
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3229
size_t m_size
Definition lci_binding_post.hpp:3217
int m_rank
Definition lci_binding_post.hpp:3215
post_send_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3238
tag_t m_tag
Definition lci_binding_post.hpp:3218
post_send_x && size(size_t size_in)
Definition lci_binding_post.hpp:3239
comp_t m_local_comp
Definition lci_binding_post.hpp:3219
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:3234
status_t operator()() const
Definition lci_binding_post.hpp:3257
post_send_x && rank(int rank_in)
Definition lci_binding_post.hpp:3237
post_send_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3242
post_send_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3253
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3226
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3222
post_send_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3246
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:3247
post_send_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3252
option_t< device_t > m_device
Definition lci_binding_post.hpp:3221
post_send_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3249
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3225
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:3228
post_send_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3240
post_send_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:3250
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3231
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3230
post_send_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3245
post_send_x && device(device_t device_in)
Definition lci_binding_post.hpp:3243
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3220
The actual implementation for progress.
Definition lci_binding_post.hpp:3532
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3535
error_t call() const
Definition binding.cpp:930
progress_x()
Definition lci_binding_post.hpp:3540
progress_x && device(device_t device_in)
Definition lci_binding_post.hpp:3544
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3537
option_t< device_t > m_device
Definition lci_binding_post.hpp:3536
error_t operator()() const
Definition lci_binding_post.hpp:3549
progress_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3543
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:3545
The actual implementation for put_upacket.
Definition lci_binding_post.hpp:435
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:439
void * m_packet
Definition lci_binding_post.hpp:438
void call() const
Definition binding.cpp:249
void operator()() const
Definition lci_binding_post.hpp:450
put_upacket_x && packet(void *packet_in)
Definition lci_binding_post.hpp:445
put_upacket_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:446
put_upacket_x(void *packet_in)
Definition lci_binding_post.hpp:442
void call_impl(void *packet, runtime_t runtime) const
The actual implementation for reduce_scatter.
Definition lci_binding_post.hpp:2793
reduce_scatter_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2814
reduce_scatter_x && item_size(size_t item_size_in)
Definition lci_binding_post.hpp:2816
reduce_scatter_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2821
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:2807
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2803
reduce_scatter_x && device(device_t device_in)
Definition lci_binding_post.hpp:2819
reduce_scatter_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2813
reduce_scatter_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2822
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2805
option_t< reduce_scatter_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:2806
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2801
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:2797
size_t m_item_size
Definition lci_binding_post.hpp:2799
const void * m_sendbuf
Definition lci_binding_post.hpp:2796
size_t m_recvcount
Definition lci_binding_post.hpp:2798
reduce_scatter_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:2817
void operator()() const
Definition lci_binding_post.hpp:2828
reduce_scatter_x && algorithm(reduce_scatter_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:2823
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2804
reduce_op_t m_op
Definition lci_binding_post.hpp:2800
void call() const
Definition binding.cpp:744
reduce_scatter_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2818
option_t< device_t > m_device
Definition lci_binding_post.hpp:2802
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:2810
reduce_scatter_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2820
reduce_scatter_x && recvcount(size_t recvcount_in)
Definition lci_binding_post.hpp:2815
reduce_scatter_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:2824
The actual implementation for reduce.
Definition lci_binding_post.hpp:2730
void operator()() const
Definition lci_binding_post.hpp:2761
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:2745
reduce_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:2752
reduce_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2757
reduce_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2749
option_t< device_t > m_device
Definition lci_binding_post.hpp:2740
int m_root
Definition lci_binding_post.hpp:2738
size_t m_count
Definition lci_binding_post.hpp:2735
reduce_x && count(size_t count_in)
Definition lci_binding_post.hpp:2750
reduce_op_t m_op
Definition lci_binding_post.hpp:2737
reduce_x && device(device_t device_in)
Definition lci_binding_post.hpp:2755
size_t m_item_size
Definition lci_binding_post.hpp:2736
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2741
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:2734
reduce_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2748
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2742
reduce_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2754
reduce_x && item_size(size_t item_size_in)
Definition lci_binding_post.hpp:2751
reduce_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2756
reduce_x && root(int root_in)
Definition lci_binding_post.hpp:2753
const void * m_sendbuf
Definition lci_binding_post.hpp:2733
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2739
void call() const
Definition binding.cpp:730
The actual implementation for register_memory.
Definition lci_binding_post.hpp:1086
register_memory_x && address(void *address_in)
Definition lci_binding_post.hpp:1098
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1091
register_memory_x && device(device_t device_in)
Definition lci_binding_post.hpp:1101
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:1099
option_t< device_t > m_device
Definition lci_binding_post.hpp:1092
void * m_address
Definition lci_binding_post.hpp:1089
mr_t operator()() const
Definition lci_binding_post.hpp:1105
register_memory_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1100
register_memory_x(void *address_in, size_t size_in)
Definition lci_binding_post.hpp:1095
size_t m_size
Definition lci_binding_post.hpp:1090
mr_t call() const
Definition binding.cpp:398
The actual implementation for register_packet_pool.
Definition lci_binding_post.hpp:319
device_t m_device
Definition lci_binding_post.hpp:323
void call_impl(packet_pool_t packet_pool, device_t device, runtime_t runtime) const
void operator()() const
Definition lci_binding_post.hpp:336
register_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:327
register_packet_pool_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:330
void call() const
Definition binding.cpp:229
register_packet_pool_x && device(device_t device_in)
Definition lci_binding_post.hpp:331
packet_pool_t m_packet_pool
Definition lci_binding_post.hpp:322
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:324
register_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:332
The actual implementation for register_rcomp.
Definition lci_binding_post.hpp:1906
rcomp_t call() const
Definition binding.cpp:578
rcomp_t operator()() const
Definition lci_binding_post.hpp:1923
comp_t m_comp
Definition lci_binding_post.hpp:1909
option_t< rcomp_t > m_rcomp
Definition lci_binding_post.hpp:1911
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1910
register_rcomp_x && rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:1919
register_rcomp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1918
register_rcomp_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1917
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:1914
The actual implementation for reserve_rcomps.
Definition lci_binding_post.hpp:1868
rcomp_t call_impl(rcomp_t n, runtime_t runtime) const
rcomp_t m_n
Definition lci_binding_post.hpp:1871
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1872
reserve_rcomps_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1879
rcomp_t call() const
Definition binding.cpp:572
reserve_rcomps_x(rcomp_t n_in)
Definition lci_binding_post.hpp:1875
rcomp_t operator()() const
Definition lci_binding_post.hpp:1883
reserve_rcomps_x && n(rcomp_t n_in)
Definition lci_binding_post.hpp:1878
The actual implementation for RESOURCE runtime.
Definition lci_binding_pre.hpp:202
The actual implementation for set_allocator.
Definition lci_binding_post.hpp:598
set_allocator_x(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:605
set_allocator_x && allocator(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:608
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:602
void call_impl(allocator_base_t *allocator, runtime_t runtime) const
set_allocator_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:609
void call() const
Definition binding.cpp:283
allocator_base_t * m_allocator
Definition lci_binding_post.hpp:601
void operator()() const
Definition lci_binding_post.hpp:613
The actual implementation for sync_test.
Definition lci_binding_post.hpp:2029
comp_t m_comp
Definition lci_binding_post.hpp:2032
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:2041
status_t * m_p_out
Definition lci_binding_post.hpp:2033
sync_test_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2042
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2034
bool operator()() const
Definition lci_binding_post.hpp:2046
sync_test_x(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:2037
sync_test_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2040
bool call() const
Definition binding.cpp:600
The actual implementation for sync_wait.
Definition lci_binding_post.hpp:2071
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2076
sync_wait_x(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:2081
comp_t m_comp
Definition lci_binding_post.hpp:2074
sync_wait_x && p_out(status_t *p_out_in)
Definition lci_binding_post.hpp:2085
option_t< device_t > m_device
Definition lci_binding_post.hpp:2078
sync_wait_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2086
void call() const
Definition binding.cpp:607
status_t * m_p_out
Definition lci_binding_post.hpp:2075
option_t< bool > m_do_progress
Definition lci_binding_post.hpp:2077
sync_wait_x && device(device_t device_in)
Definition lci_binding_post.hpp:2088
sync_wait_x && do_progress(bool do_progress_in)
Definition lci_binding_post.hpp:2087
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:2092
sync_wait_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2084
The actual implementation for test_drained.
Definition lci_binding_post.hpp:3571
option_t< device_t > m_device
Definition lci_binding_post.hpp:3575
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3574
test_drained_x()
Definition lci_binding_post.hpp:3578
error_t operator()() const
Definition lci_binding_post.hpp:3586
test_drained_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3581
test_drained_x && device(device_t device_in)
Definition lci_binding_post.hpp:3582
error_t call() const
Definition binding.cpp:937
error_t call_impl(runtime_t runtime, device_t device) const
The actual implementation for wait_drained.
Definition lci_binding_post.hpp:3608
option_t< device_t > m_device
Definition lci_binding_post.hpp:3612
void operator()() const
Definition lci_binding_post.hpp:3623
wait_drained_x()
Definition lci_binding_post.hpp:3615
void call() const
Definition binding.cpp:943
void call_impl(runtime_t runtime, device_t device) const
wait_drained_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3618
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3611
wait_drained_x && device(device_t device_in)
Definition lci_binding_post.hpp:3619
broadcast_algorithm_t
The type of broadcast algorithm.
Definition lci.hpp:231
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:579
uint64_t matching_entry_key_t
The type of matching engine entry key.
Definition lci.hpp:405
status_t(*)(void *value) graph_node_run_cb_t
The function signature for a node function in the completion graph.
Definition lci.hpp:558
direction_t
The enum class of comunication direction.
Definition lci.hpp:355
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:573
void(*)(const void *left, const void *right, void *dst, size_t n) reduce_op_t
The user-defined reduction operation.
Definition lci.hpp:538
matching_policy_t
Enum class for matching policy.
Definition lci.hpp:394
void * graph_node_t
The node type for the completion graph.
Definition lci.hpp:544
allreduce_algorithm_t
The type of allreduce algorithm.
Definition lci.hpp:267
reduce_scatter_algorithm_t
The type of reduce scatter algorithm.
Definition lci.hpp:249
void * matching_entry_val_t
The type of matching engine entry value.
Definition lci.hpp:410
matching_entry_type_t
The type of matching entry.
Definition lci.hpp:385
uint32_t rcomp_t
The type of remote completion handler.
Definition lci.hpp:366
void(*)(status_t status) comp_handler_t
Function Signature for completion handler.
Definition lci.hpp:531
uint64_t tag_t
The type of tag.
Definition lci.hpp:349
comp_semantic_t
The enum class of completion semantic.
Definition lci.hpp:420
uint32_t net_imm_data_t
The type of network-layer immediate data field.
Definition lci.hpp:286
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:3099
error_t net_post_send(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1467
void graph_node_mark_complete(graph_node_t node_in)
Definition lci_binding_post.hpp:2519
size_t get_max_bcopy_size()
Definition lci_binding_post.hpp:860
attr_matching_engine_type_t
Definition lci_binding_pre.hpp:28
void broadcast(void *buffer_in, size_t size_in, int root_in)
Definition lci_binding_post.hpp:2703
device_t alloc_device()
Definition lci_binding_post.hpp:1028
net_context_t alloc_net_context()
Definition lci_binding_post.hpp:927
void free_net_context(net_context_t *net_context_in)
Definition lci_binding_post.hpp:964
error_t net_post_recv(void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1354
attr_backend_t
Definition lci.hpp:65
void deregister_rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:1963
void deregister_memory(mr_t *mr_in)
Definition lci_binding_post.hpp:1145
comp_t alloc_counter()
Definition lci_binding_post.hpp:2135
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:3178
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:579
void wait_drained()
Definition lci_binding_post.hpp:3626
rcomp_t reserve_rcomps(rcomp_t n_in)
Definition lci_binding_post.hpp:1886
void sync_wait(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:2095
matching_engine_t alloc_matching_engine()
Definition lci_binding_post.hpp:496
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:1647
void alltoall(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:3005
status_t graph_test(comp_t comp_in)
Definition lci_binding_post.hpp:2593
void register_packet_pool(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:339
matching_engine_t get_default_matching_engine()
Definition lci_binding_post.hpp:823
status_t cq_pop(comp_t comp_in)
Definition lci_binding_post.hpp:2298
size_t net_poll_cq(size_t max_polls_in, net_status_t *statuses_in)
Definition lci_binding_post.hpp:1305
void graph_start(comp_t comp_in)
Definition lci_binding_post.hpp:2556
void free_matching_engine(matching_engine_t *matching_engine_in)
Definition lci_binding_post.hpp:533
void put_upacket(void *packet_in)
Definition lci_binding_post.hpp:453
comp_t alloc_cq()
Definition lci_binding_post.hpp:2261
void g_runtime_fina()
Definition lci_binding_post.hpp:184
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:1525
rcomp_t register_rcomp(comp_t comp_in)
Definition lci_binding_post.hpp:1926
error_t net_post_sends(int rank_in, void *buffer_in, size_t size_in)
Definition lci_binding_post.hpp:1409
void graph_add_edge(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in)
Definition lci_binding_post.hpp:2479
void set_allocator(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:616
allocator_base_t * get_allocator()
Definition lci_binding_post.hpp:650
net_context_t get_default_net_context()
Definition lci_binding_post.hpp:684
void free_device(device_t *device_in)
Definition lci_binding_post.hpp:1065
void free_comp(comp_t *comp_in)
Definition lci_binding_post.hpp:1809
packet_pool_t get_default_packet_pool()
Definition lci_binding_post.hpp:789
void free_runtime(runtime_t *runtime_in)
Definition lci_binding_post.hpp:97
comp_t alloc_handler(comp_handler_t handler_in)
Definition lci_binding_post.hpp:2344
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:1711
runtime_t get_g_runtime()
Definition lci_binding_post.hpp:216
void free_packet_pool(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:299
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:2764
void deregister_packet_pool(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:379
runtime_t g_runtime_init()
Definition lci_binding_post.hpp:152
void counter_set(comp_t comp_in, int64_t value_in)
Definition lci_binding_post.hpp:2212
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:3260
void comp_signal(comp_t comp_in, status_t status_in)
Definition lci_binding_post.hpp:1849
mr_t register_memory(void *address_in, size_t size_in)
Definition lci_binding_post.hpp:1108
rmr_t get_rmr(mr_t mr_in)
Definition lci_binding_post.hpp:1182
endpoint_t alloc_endpoint()
Definition lci_binding_post.hpp:1225
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:3427
endpoint_t get_default_endpoint()
Definition lci_binding_post.hpp:755
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:2898
graph_node_t graph_add_node(comp_t comp_in, graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:2433
runtime_t alloc_runtime()
Definition lci_binding_post.hpp:63
void allgather(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:2950
bool sync_test(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:2049
attr_ibv_td_strategy_t
Definition lci_binding_pre.hpp:46
error_t progress()
Definition lci_binding_post.hpp:3552
attr_ibv_odp_strategy_t
Definition lci_binding_pre.hpp:33
error_t test_drained()
Definition lci_binding_post.hpp:3589
device_t get_default_device()
Definition lci_binding_post.hpp:718
int64_t counter_get(comp_t comp_in)
Definition lci_binding_post.hpp:2172
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:2831
packet_pool_t alloc_packet_pool()
Definition lci_binding_post.hpp:262
attr_ibv_prefetch_strategy_t
Definition lci_binding_pre.hpp:39
void barrier()
Definition lci_binding_post.hpp:2642
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:1772
attr_cq_type_t
Definition lci_binding_pre.hpp:61
comp_t alloc_graph()
Definition lci_binding_post.hpp:2387
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:3342
void * get_upacket()
Definition lci_binding_post.hpp:416
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:1586
comp_t alloc_sync()
Definition lci_binding_post.hpp:2009
void free_endpoint(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:1262
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:3512
The user-defined allocator type.
Definition lci.hpp:429
Wrapper class for error code.
Definition lci.hpp:162
The struct for network status.
Definition lci.hpp:294
Definition lci.hpp:81
The type of remote memory region.
Definition lci.hpp:332
The type of the completion desciptor for a posted communication.
Definition lci.hpp:445