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
29
35 public:
36 // args declaration
46
47 // constructor
49
50 // setter
51 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); }
52 inline alloc_runtime_x&& imm_nbits_tag(int imm_nbits_tag_in) { m_imm_nbits_tag = imm_nbits_tag_in; return std::move(*this); }
53 inline alloc_runtime_x&& imm_nbits_rcomp(int imm_nbits_rcomp_in) { m_imm_nbits_rcomp = imm_nbits_rcomp_in; return std::move(*this); }
54 inline alloc_runtime_x&& rdv_protocol(attr_rdv_protocol_t rdv_protocol_in) { m_rdv_protocol = rdv_protocol_in; return std::move(*this); }
55 inline alloc_runtime_x&& alloc_default_device(bool alloc_default_device_in) { m_alloc_default_device = alloc_default_device_in; return std::move(*this); }
56 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); }
57 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); }
58 inline alloc_runtime_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
59 inline alloc_runtime_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
60
62 runtime_t call() const;
63 inline runtime_t operator()() const { return call(); }
64};
65
67 return alloc_runtime_x().call();
68}
69
70
79
85 public:
86 // args declaration
88
89 // constructor
90 free_runtime_x(runtime_t* runtime_in) : m_runtime(runtime_in) {}
91
92 // setter
93 inline free_runtime_x&& runtime(runtime_t* runtime_in) { m_runtime = runtime_in; return std::move(*this); }
94
96 void call() const;
97 inline void operator()() const { return call(); }
98};
99
100inline void free_runtime(runtime_t* runtime_in) {
101 return free_runtime_x(runtime_in).call();
102}
103
104
121
127 public:
128 // args declaration
138
139 // constructor
141
142 // setter
143 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); }
144 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); }
145 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); }
146 inline g_runtime_init_x&& rdv_protocol(attr_rdv_protocol_t rdv_protocol_in) { m_rdv_protocol = rdv_protocol_in; return std::move(*this); }
147 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); }
148 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); }
149 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); }
150 inline g_runtime_init_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
151 inline g_runtime_init_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
152
154 runtime_t call() const;
155 inline runtime_t operator()() const { return call(); }
156};
157
159 return g_runtime_init_x().call();
160}
161
162
171
177 public:
178 // args declaration
179
180 // constructor
182
183 // setter
184
185 void call_impl() const;
186 void call() const;
187 inline void operator()() const { return call(); }
188};
189
190inline void g_runtime_fina() {
191 return g_runtime_fina_x().call();
192}
193
194
203
209 public:
210 // args declaration
211
212 // constructor
214
215 // setter
216
218 runtime_t call() const;
219 inline runtime_t operator()() const { return call(); }
220};
221
223 return get_g_runtime_x().call();
224}
225
226
239
245 public:
246 // args declaration
252
253 // constructor
255
256 // setter
257 inline alloc_packet_pool_x&& packet_size(size_t packet_size_in) { m_packet_size = packet_size_in; return std::move(*this); }
258 inline alloc_packet_pool_x&& npackets(size_t npackets_in) { m_npackets = npackets_in; return std::move(*this); }
259 inline alloc_packet_pool_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
260 inline alloc_packet_pool_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
261 inline alloc_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
262
263 packet_pool_t call_impl(size_t packet_size, size_t npackets, const char* name, void* user_context, runtime_t runtime) const;
264 packet_pool_t call() const;
265 inline packet_pool_t operator()() const { return call(); }
266};
267
271
272
282
288 public:
289 // args declaration
292
293 // constructor
294 free_packet_pool_x(packet_pool_t* packet_pool_in) : m_packet_pool(packet_pool_in) {}
295
296 // setter
297 inline free_packet_pool_x&& packet_pool(packet_pool_t* packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
298 inline free_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
299
301 void call() const;
302 inline void operator()() const { return call(); }
303};
304
305inline void free_packet_pool(packet_pool_t* packet_pool_in) {
306 return free_packet_pool_x(packet_pool_in).call();
307}
308
309
320
326 public:
327 // args declaration
331
332 // constructor
333 register_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in) : m_packet_pool(packet_pool_in), m_device(device_in) {}
334
335 // setter
336 inline register_packet_pool_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
337 inline register_packet_pool_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
338 inline register_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
339
341 void call() const;
342 inline void operator()() const { return call(); }
343};
344
345inline void register_packet_pool(packet_pool_t packet_pool_in, device_t device_in) {
346 return register_packet_pool_x(packet_pool_in, device_in).call();
347}
348
349
360
366 public:
367 // args declaration
371
372 // constructor
373 deregister_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in) : m_packet_pool(packet_pool_in), m_device(device_in) {}
374
375 // setter
376 inline deregister_packet_pool_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
377 inline deregister_packet_pool_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
378 inline deregister_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
379
381 void call() const;
382 inline void operator()() const { return call(); }
383};
384
385inline void deregister_packet_pool(packet_pool_t packet_pool_in, device_t device_in) {
386 return deregister_packet_pool_x(packet_pool_in, device_in).call();
387}
388
389
399
405 public:
406 // args declaration
409
410 // constructor
412
413 // setter
414 inline get_upacket_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
415 inline get_upacket_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
416
418 void* call() const;
419 inline void* operator()() const { return call(); }
420};
421
422inline void* get_upacket() {
423 return get_upacket_x().call();
424}
425
426
436
442 public:
443 // args declaration
444 void* m_packet;
446
447 // constructor
448 put_upacket_x(void* packet_in) : m_packet(packet_in) {}
449
450 // setter
451 inline put_upacket_x&& packet(void* packet_in) { m_packet = packet_in; return std::move(*this); }
452 inline put_upacket_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
453
454 void call_impl(void* packet, runtime_t runtime) const;
455 void call() const;
456 inline void operator()() const { return call(); }
457};
458
459inline void put_upacket(void* packet_in) {
460 return put_upacket_x(packet_in).call();
461}
462
463
475
481 public:
482 // args declaration
487
488 // constructor
490
491 // setter
492 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); }
493 inline alloc_matching_engine_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
494 inline alloc_matching_engine_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
495 inline alloc_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
496
498 matching_engine_t call() const;
499 inline matching_engine_t operator()() const { return call(); }
500};
501
505
506
516
522 public:
523 // args declaration
526
527 // constructor
528 free_matching_engine_x(matching_engine_t* matching_engine_in) : m_matching_engine(matching_engine_in) {}
529
530 // setter
531 inline free_matching_engine_x&& matching_engine(matching_engine_t* matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
532 inline free_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
533
535 void call() const;
536 inline void operator()() const { return call(); }
537};
538
539inline void free_matching_engine(matching_engine_t* matching_engine_in) {
540 return free_matching_engine_x(matching_engine_in).call();
541}
542
543
556
562 public:
563 // args declaration
569
570 // constructor
571 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) {}
572
573 // setter
574 inline matching_engine_insert_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
575 inline matching_engine_insert_x&& key(matching_entry_key_t key_in) { m_key = key_in; return std::move(*this); }
576 inline matching_engine_insert_x&& value(matching_entry_val_t value_in) { m_value = value_in; return std::move(*this); }
577 inline matching_engine_insert_x&& entry_type(matching_entry_type_t entry_type_in) { m_entry_type = entry_type_in; return std::move(*this); }
578 inline matching_engine_insert_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
579
582 inline matching_entry_val_t operator()() const { return call(); }
583};
584
586 return matching_engine_insert_x(matching_engine_in, key_in, value_in, entry_type_in).call();
587}
588
589
599
605 public:
606 // args declaration
609
610 // constructor
611 set_allocator_x(allocator_base_t* allocator_in) : m_allocator(allocator_in) {}
612
613 // setter
614 inline set_allocator_x&& allocator(allocator_base_t* allocator_in) { m_allocator = allocator_in; return std::move(*this); }
615 inline set_allocator_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
616
618 void call() const;
619 inline void operator()() const { return call(); }
620};
621
622inline void set_allocator(allocator_base_t* allocator_in) {
623 return set_allocator_x(allocator_in).call();
624}
625
626
635
641 public:
642 // args declaration
644
645 // constructor
647
648 // setter
649 inline get_allocator_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
650
652 allocator_base_t* call() const;
653 inline allocator_base_t* operator()() const { return call(); }
654};
655
657 return get_allocator_x().call();
658}
659
660
669
675 public:
676 // args declaration
678
679 // constructor
681
682 // setter
683 inline get_default_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
684
686 net_context_t call() const;
687 inline net_context_t operator()() const { return call(); }
688};
689
693
694
703
709 public:
710 // args declaration
712
713 // constructor
715
716 // setter
717 inline get_default_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
718
720 device_t call() const;
721 inline device_t operator()() const { return call(); }
722};
723
725 return get_default_device_x().call();
726}
727
728
738
744 public:
745 // args declaration
748
749 // constructor
751
752 // setter
753 inline get_default_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
754 inline get_default_endpoint_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
755
757 endpoint_t call() const;
758 inline endpoint_t operator()() const { return call(); }
759};
760
764
765
774
780 public:
781 // args declaration
783
784 // constructor
786
787 // setter
788 inline get_default_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
789
791 packet_pool_t call() const;
792 inline packet_pool_t operator()() const { return call(); }
793};
794
798
799
808
814 public:
815 // args declaration
817
818 // constructor
820
821 // setter
822 inline get_default_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
823
825 matching_engine_t call() const;
826 inline matching_engine_t operator()() const { return call(); }
827};
828
832
833
843
849 public:
850 // args declaration
853
854 // constructor
856
857 // setter
858 inline get_max_bcopy_size_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
859 inline get_max_bcopy_size_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
860
862 size_t call() const;
863 inline size_t operator()() const { return call(); }
864};
865
866inline size_t get_max_bcopy_size() {
867 return get_max_bcopy_size_x().call();
868}
869
870
890
896 public:
897 // args declaration
910
911 // constructor
913
914 // setter
915 inline alloc_net_context_x&& backend(attr_backend_t backend_in) { m_backend = backend_in; return std::move(*this); }
916 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); }
917 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); }
918 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); }
919 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); }
920 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); }
921 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); }
922 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); }
923 inline alloc_net_context_x&& use_dmabuf(bool use_dmabuf_in) { m_use_dmabuf = use_dmabuf_in; return std::move(*this); }
924 inline alloc_net_context_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
925 inline alloc_net_context_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
926 inline alloc_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
927
929 net_context_t call() const;
930 inline net_context_t operator()() const { return call(); }
931};
932
936
937
947
953 public:
954 // args declaration
957
958 // constructor
959 free_net_context_x(net_context_t* net_context_in) : m_net_context(net_context_in) {}
960
961 // setter
962 inline free_net_context_x&& net_context(net_context_t* net_context_in) { m_net_context = net_context_in; return std::move(*this); }
963 inline free_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
964
966 void call() const;
967 inline void operator()() const { return call(); }
968};
969
970inline void free_net_context(net_context_t* net_context_in) {
971 return free_net_context_x(net_context_in).call();
972}
973
974
996
1002 public:
1003 // args declaration
1018
1019 // constructor
1021
1022 // setter
1023 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); }
1024 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); }
1025 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); }
1026 inline alloc_device_x&& net_send_reserved_pct(double net_send_reserved_pct_in) { m_net_send_reserved_pct = net_send_reserved_pct_in; return std::move(*this); }
1027 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); }
1028 inline alloc_device_x&& alloc_default_endpoint(bool alloc_default_endpoint_in) { m_alloc_default_endpoint = alloc_default_endpoint_in; return std::move(*this); }
1029 inline alloc_device_x&& alloc_progress_endpoint(bool alloc_progress_endpoint_in) { m_alloc_progress_endpoint = alloc_progress_endpoint_in; return std::move(*this); }
1030 inline alloc_device_x&& use_reg_cache(bool use_reg_cache_in) { m_use_reg_cache = use_reg_cache_in; return std::move(*this); }
1031 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); }
1032 inline alloc_device_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
1033 inline alloc_device_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1034 inline alloc_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1035 inline alloc_device_x&& net_context(net_context_t net_context_in) { m_net_context = net_context_in; return std::move(*this); }
1036 inline alloc_device_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1037
1039 device_t call() const;
1040 inline device_t operator()() const { return call(); }
1041};
1042
1044 return alloc_device_x().call();
1045}
1046
1047
1057
1063 public:
1064 // args declaration
1067
1068 // constructor
1069 free_device_x(device_t* device_in) : m_device(device_in) {}
1070
1071 // setter
1072 inline free_device_x&& device(device_t* device_in) { m_device = device_in; return std::move(*this); }
1073 inline free_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1074
1076 void call() const;
1077 inline void operator()() const { return call(); }
1078};
1079
1080inline void free_device(device_t* device_in) {
1081 return free_device_x(device_in).call();
1082}
1083
1084
1096
1102 public:
1103 // args declaration
1105 size_t m_size;
1108
1109 // constructor
1110 register_memory_x(void* address_in, size_t size_in) : m_address(address_in), m_size(size_in) {}
1111
1112 // setter
1113 inline register_memory_x&& address(void* address_in) { m_address = address_in; return std::move(*this); }
1114 inline register_memory_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1115 inline register_memory_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1116 inline register_memory_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1117
1119 mr_t call() const;
1120 inline mr_t operator()() const { return call(); }
1121};
1122
1123inline mr_t register_memory(void* address_in, size_t size_in) {
1124 return register_memory_x(address_in, size_in).call();
1125}
1126
1127
1137
1143 public:
1144 // args declaration
1147
1148 // constructor
1149 deregister_memory_x(mr_t* mr_in) : m_mr(mr_in) {}
1150
1151 // setter
1152 inline deregister_memory_x&& mr(mr_t* mr_in) { m_mr = mr_in; return std::move(*this); }
1153 inline deregister_memory_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1154
1156 void call() const;
1157 inline void operator()() const { return call(); }
1158};
1159
1160inline void deregister_memory(mr_t* mr_in) {
1161 return deregister_memory_x(mr_in).call();
1162}
1163
1164
1174
1180 public:
1181 // args declaration
1184
1185 // constructor
1186 get_rmr_x(mr_t mr_in) : m_mr(mr_in) {}
1187
1188 // setter
1189 inline get_rmr_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1190 inline get_rmr_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1191
1193 rmr_t call() const;
1194 inline rmr_t operator()() const { return call(); }
1195};
1196
1197inline rmr_t get_rmr(mr_t mr_in) {
1198 return get_rmr_x(mr_in).call();
1199}
1200
1201
1213
1219 public:
1220 // args declaration
1225
1226 // constructor
1228
1229 // setter
1230 inline alloc_endpoint_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
1231 inline alloc_endpoint_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1232 inline alloc_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1233 inline alloc_endpoint_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1234
1236 endpoint_t call() const;
1237 inline endpoint_t operator()() const { return call(); }
1238};
1239
1241 return alloc_endpoint_x().call();
1242}
1243
1244
1254
1260 public:
1261 // args declaration
1264
1265 // constructor
1266 free_endpoint_x(endpoint_t* endpoint_in) : m_endpoint(endpoint_in) {}
1267
1268 // setter
1269 inline free_endpoint_x&& endpoint(endpoint_t* endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1270 inline free_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1271
1273 void call() const;
1274 inline void operator()() const { return call(); }
1275};
1276
1277inline void free_endpoint(endpoint_t* endpoint_in) {
1278 return free_endpoint_x(endpoint_in).call();
1279}
1280
1281
1293
1299 public:
1300 // args declaration
1305
1306 // constructor
1307 net_poll_cq_x(size_t max_polls_in, net_status_t* statuses_in) : m_max_polls(max_polls_in), m_statuses(statuses_in) {}
1308
1309 // setter
1310 inline net_poll_cq_x&& max_polls(size_t max_polls_in) { m_max_polls = max_polls_in; return std::move(*this); }
1311 inline net_poll_cq_x&& statuses(net_status_t* statuses_in) { m_statuses = statuses_in; return std::move(*this); }
1312 inline net_poll_cq_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1313 inline net_poll_cq_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1314
1316 size_t call() const;
1317 inline size_t operator()() const { return call(); }
1318};
1319
1320inline size_t net_poll_cq(size_t max_polls_in, net_status_t* statuses_in) {
1321 return net_poll_cq_x(max_polls_in, statuses_in).call();
1322}
1323
1324
1338
1344 public:
1345 // args declaration
1347 size_t m_size;
1352
1353 // constructor
1354 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) {}
1355
1356 // setter
1357 inline net_post_recv_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1358 inline net_post_recv_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1359 inline net_post_recv_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1360 inline net_post_recv_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1361 inline net_post_recv_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1362 inline net_post_recv_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1363
1365 error_t call() const;
1366 inline error_t operator()() const { return call(); }
1367};
1368
1369inline error_t net_post_recv(void* buffer_in, size_t size_in, mr_t mr_in) {
1370 return net_post_recv_x(buffer_in, size_in, mr_in).call();
1371}
1372
1373
1389
1395 public:
1396 // args declaration
1399 size_t m_size;
1405
1406 // constructor
1407 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) {}
1408
1409 // setter
1410 inline net_post_sends_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1411 inline net_post_sends_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1412 inline net_post_sends_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1413 inline net_post_sends_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1414 inline net_post_sends_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1415 inline net_post_sends_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1416 inline net_post_sends_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1417 inline net_post_sends_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1418
1420 error_t call() const;
1421 inline error_t operator()() const { return call(); }
1422};
1423
1424inline error_t net_post_sends(int rank_in, void* buffer_in, size_t size_in) {
1425 return net_post_sends_x(rank_in, buffer_in, size_in).call();
1426}
1427
1428
1445
1451 public:
1452 // args declaration
1455 size_t m_size;
1462
1463 // constructor
1464 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) {}
1465
1466 // setter
1467 inline net_post_send_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1468 inline net_post_send_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1469 inline net_post_send_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1470 inline net_post_send_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1471 inline net_post_send_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1472 inline net_post_send_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1473 inline net_post_send_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1474 inline net_post_send_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1475 inline net_post_send_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1476
1478 error_t call() const;
1479 inline error_t operator()() const { return call(); }
1480};
1481
1482inline error_t net_post_send(int rank_in, void* buffer_in, size_t size_in, mr_t mr_in) {
1483 return net_post_send_x(rank_in, buffer_in, size_in, mr_in).call();
1484}
1485
1486
1503
1509 public:
1510 // args declaration
1513 size_t m_size;
1514 uint64_t m_offset;
1520
1521 // constructor
1522 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) {}
1523
1524 // setter
1525 inline net_post_puts_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1526 inline net_post_puts_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1527 inline net_post_puts_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1528 inline net_post_puts_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1529 inline net_post_puts_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1530 inline net_post_puts_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1531 inline net_post_puts_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1532 inline net_post_puts_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1533 inline net_post_puts_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1534
1536 error_t call() const;
1537 inline error_t operator()() const { return call(); }
1538};
1539
1540inline error_t net_post_puts(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) {
1541 return net_post_puts_x(rank_in, buffer_in, size_in, offset_in, rmr_in).call();
1542}
1543
1544
1562
1568 public:
1569 // args declaration
1572 size_t m_size;
1574 uint64_t m_offset;
1580
1581 // constructor
1582 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) {}
1583
1584 // setter
1585 inline net_post_put_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1586 inline net_post_put_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1587 inline net_post_put_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1588 inline net_post_put_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1589 inline net_post_put_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1590 inline net_post_put_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1591 inline net_post_put_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1592 inline net_post_put_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1593 inline net_post_put_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1594 inline net_post_put_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1595
1597 error_t call() const;
1598 inline error_t operator()() const { return call(); }
1599};
1600
1601inline 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) {
1602 return net_post_put_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
1603}
1604
1605
1623
1629 public:
1630 // args declaration
1633 size_t m_size;
1634 uint64_t m_offset;
1641
1642 // constructor
1643 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) {}
1644
1645 // setter
1646 inline net_post_putImms_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1647 inline net_post_putImms_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1648 inline net_post_putImms_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1649 inline net_post_putImms_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1650 inline net_post_putImms_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1651 inline net_post_putImms_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1652 inline net_post_putImms_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1653 inline net_post_putImms_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1654 inline net_post_putImms_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1655 inline net_post_putImms_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1656
1658 error_t call() const;
1659 inline error_t operator()() const { return call(); }
1660};
1661
1662inline error_t net_post_putImms(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) {
1663 return net_post_putImms_x(rank_in, buffer_in, size_in, offset_in, rmr_in).call();
1664}
1665
1666
1685
1691 public:
1692 // args declaration
1695 size_t m_size;
1697 uint64_t m_offset;
1704
1705 // constructor
1706 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) {}
1707
1708 // setter
1709 inline net_post_putImm_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1710 inline net_post_putImm_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1711 inline net_post_putImm_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1712 inline net_post_putImm_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1713 inline net_post_putImm_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1714 inline net_post_putImm_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1715 inline net_post_putImm_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1716 inline net_post_putImm_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1717 inline net_post_putImm_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1718 inline net_post_putImm_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
1719 inline net_post_putImm_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1720
1722 error_t call() const;
1723 inline error_t operator()() const { return call(); }
1724};
1725
1726inline 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) {
1727 return net_post_putImm_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
1728}
1729
1730
1748
1754 public:
1755 // args declaration
1758 size_t m_size;
1760 uint64_t m_offset;
1766
1767 // constructor
1768 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) {}
1769
1770 // setter
1771 inline net_post_get_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1772 inline net_post_get_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
1773 inline net_post_get_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1774 inline net_post_get_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1775 inline net_post_get_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
1776 inline net_post_get_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1777 inline net_post_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1778 inline net_post_get_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1779 inline net_post_get_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1780 inline net_post_get_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1781
1783 error_t call() const;
1784 inline error_t operator()() const { return call(); }
1785};
1786
1787inline 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) {
1788 return net_post_get_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
1789}
1790
1791
1801
1807 public:
1808 // args declaration
1811
1812 // constructor
1813 free_comp_x(comp_t* comp_in) : m_comp(comp_in) {}
1814
1815 // setter
1816 inline free_comp_x&& comp(comp_t* comp_in) { m_comp = comp_in; return std::move(*this); }
1817 inline free_comp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1818
1820 void call() const;
1821 inline void operator()() const { return call(); }
1822};
1823
1824inline void free_comp(comp_t* comp_in) {
1825 return free_comp_x(comp_in).call();
1826}
1827
1828
1839
1845 public:
1846 // args declaration
1850
1851 // constructor
1852 comp_signal_x(comp_t comp_in, status_t status_in) : m_comp(comp_in), m_status(status_in) {}
1853
1854 // setter
1855 inline comp_signal_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1856 inline comp_signal_x&& status(status_t status_in) { m_status = status_in; return std::move(*this); }
1857 inline comp_signal_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1858
1860 void call() const;
1861 inline void operator()() const { return call(); }
1862};
1863
1864inline void comp_signal(comp_t comp_in, status_t status_in) {
1865 return comp_signal_x(comp_in, status_in).call();
1866}
1867
1868
1878
1884 public:
1885 // args declaration
1888
1889 // constructor
1891
1892 // setter
1893 inline reserve_rcomps_x&& n(rcomp_t n_in) { m_n = n_in; return std::move(*this); }
1894 inline reserve_rcomps_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1895
1897 rcomp_t call() const;
1898 inline rcomp_t operator()() const { return call(); }
1899};
1900
1902 return reserve_rcomps_x(n_in).call();
1903}
1904
1905
1916
1922 public:
1923 // args declaration
1927
1928 // constructor
1929 register_rcomp_x(comp_t comp_in) : m_comp(comp_in) {}
1930
1931 // setter
1932 inline register_rcomp_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1933 inline register_rcomp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1934 inline register_rcomp_x&& rcomp(rcomp_t rcomp_in) { m_rcomp = rcomp_in; return std::move(*this); }
1935
1937 rcomp_t call() const;
1938 inline rcomp_t operator()() const { return call(); }
1939};
1940
1942 return register_rcomp_x(comp_in).call();
1943}
1944
1945
1955
1961 public:
1962 // args declaration
1965
1966 // constructor
1967 deregister_rcomp_x(rcomp_t rcomp_in) : m_rcomp(rcomp_in) {}
1968
1969 // setter
1970 inline deregister_rcomp_x&& rcomp(rcomp_t rcomp_in) { m_rcomp = rcomp_in; return std::move(*this); }
1971 inline deregister_rcomp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1972
1974 void call() const;
1975 inline void operator()() const { return call(); }
1976};
1977
1978inline void deregister_rcomp(rcomp_t rcomp_in) {
1979 return deregister_rcomp_x(rcomp_in).call();
1980}
1981
1982
1995
2001 public:
2002 // args declaration
2008
2009 // constructor
2011
2012 // setter
2013 inline alloc_sync_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2014 inline alloc_sync_x&& threshold(int threshold_in) { m_threshold = threshold_in; return std::move(*this); }
2015 inline alloc_sync_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
2016 inline alloc_sync_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2017 inline alloc_sync_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2018
2020 comp_t call() const;
2021 inline comp_t operator()() const { return call(); }
2022};
2023
2025 return alloc_sync_x().call();
2026}
2027
2028
2039
2045 public:
2046 // args declaration
2050
2051 // constructor
2052 sync_test_x(comp_t comp_in, status_t* p_out_in) : m_comp(comp_in), m_p_out(p_out_in) {}
2053
2054 // setter
2055 inline sync_test_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2056 inline sync_test_x&& p_out(status_t* p_out_in) { m_p_out = p_out_in; return std::move(*this); }
2057 inline sync_test_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2058
2060 bool call() const;
2061 inline bool operator()() const { return call(); }
2062};
2063
2064inline bool sync_test(comp_t comp_in, status_t* p_out_in) {
2065 return sync_test_x(comp_in, p_out_in).call();
2066}
2067
2068
2081
2087 public:
2088 // args declaration
2094
2095 // constructor
2096 sync_wait_x(comp_t comp_in, status_t* p_out_in) : m_comp(comp_in), m_p_out(p_out_in) {}
2097
2098 // setter
2099 inline sync_wait_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2100 inline sync_wait_x&& p_out(status_t* p_out_in) { m_p_out = p_out_in; return std::move(*this); }
2101 inline sync_wait_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2102 inline sync_wait_x&& do_progress(bool do_progress_in) { m_do_progress = do_progress_in; return std::move(*this); }
2103 inline sync_wait_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2104
2106 void call() const;
2107 inline void operator()() const { return call(); }
2108};
2109
2110inline void sync_wait(comp_t comp_in, status_t* p_out_in) {
2111 return sync_wait_x(comp_in, p_out_in).call();
2112}
2113
2114
2125
2131 public:
2132 // args declaration
2136
2137 // constructor
2139
2140 // setter
2141 inline alloc_counter_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2142 inline alloc_counter_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2143 inline alloc_counter_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2144
2146 comp_t call() const;
2147 inline comp_t operator()() const { return call(); }
2148};
2149
2151 return alloc_counter_x().call();
2152}
2153
2154
2164
2170 public:
2171 // args declaration
2174
2175 // constructor
2176 counter_get_x(comp_t comp_in) : m_comp(comp_in) {}
2177
2178 // setter
2179 inline counter_get_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2180 inline counter_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2181
2183 int64_t call() const;
2184 inline int64_t operator()() const { return call(); }
2185};
2186
2187inline int64_t counter_get(comp_t comp_in) {
2188 return counter_get_x(comp_in).call();
2189}
2190
2191
2202
2208 public:
2209 // args declaration
2211 int64_t m_value;
2213
2214 // constructor
2215 counter_set_x(comp_t comp_in, int64_t value_in) : m_comp(comp_in), m_value(value_in) {}
2216
2217 // setter
2218 inline counter_set_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2219 inline counter_set_x&& value(int64_t value_in) { m_value = value_in; return std::move(*this); }
2220 inline counter_set_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2221
2223 void call() const;
2224 inline void operator()() const { return call(); }
2225};
2226
2227inline void counter_set(comp_t comp_in, int64_t value_in) {
2228 return counter_set_x(comp_in, value_in).call();
2229}
2230
2231
2245
2251 public:
2252 // args declaration
2259
2260 // constructor
2262
2263 // setter
2264 inline alloc_cq_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2265 inline alloc_cq_x&& default_length(int default_length_in) { m_default_length = default_length_in; return std::move(*this); }
2266 inline alloc_cq_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
2267 inline alloc_cq_x&& cq_type(attr_cq_type_t cq_type_in) { m_cq_type = cq_type_in; return std::move(*this); }
2268 inline alloc_cq_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2269 inline alloc_cq_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2270
2272 comp_t call() const;
2273 inline comp_t operator()() const { return call(); }
2274};
2275
2277 return alloc_cq_x().call();
2278}
2279
2280
2290
2296 public:
2297 // args declaration
2300
2301 // constructor
2302 cq_pop_x(comp_t comp_in) : m_comp(comp_in) {}
2303
2304 // setter
2305 inline cq_pop_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2306 inline cq_pop_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2307
2309 status_t call() const;
2310 inline status_t operator()() const { return call(); }
2311};
2312
2313inline status_t cq_pop(comp_t comp_in) {
2314 return cq_pop_x(comp_in).call();
2315}
2316
2317
2330
2336 public:
2337 // args declaration
2343
2344 // constructor
2345 alloc_handler_x(comp_handler_t handler_in) : m_handler(handler_in) {}
2346
2347 // setter
2348 inline alloc_handler_x&& handler(comp_handler_t handler_in) { m_handler = handler_in; return std::move(*this); }
2349 inline alloc_handler_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2350 inline alloc_handler_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
2351 inline alloc_handler_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2352 inline alloc_handler_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2353
2355 comp_t call() const;
2356 inline comp_t operator()() const { return call(); }
2357};
2358
2360 return alloc_handler_x(handler_in).call();
2361}
2362
2363
2375
2381 public:
2382 // args declaration
2387
2388 // constructor
2390
2391 // setter
2392 inline alloc_graph_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2393 inline alloc_graph_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2394 inline alloc_graph_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2395 inline alloc_graph_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2396
2398 comp_t call() const;
2399 inline comp_t operator()() const { return call(); }
2400};
2401
2403 return alloc_graph_x().call();
2404}
2405
2406
2419
2425 public:
2426 // args declaration
2432
2433 // constructor
2434 graph_add_node_x(comp_t comp_in, graph_node_run_cb_t fn_in) : m_comp(comp_in), m_fn(fn_in) {}
2435
2436 // setter
2437 inline graph_add_node_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2438 inline graph_add_node_x&& fn(graph_node_run_cb_t fn_in) { m_fn = fn_in; return std::move(*this); }
2439 inline graph_add_node_x&& value(void* value_in) { m_value = value_in; return std::move(*this); }
2440 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); }
2441 inline graph_add_node_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2442
2444 graph_node_t call() const;
2445 inline graph_node_t operator()() const { return call(); }
2446};
2447
2449 return graph_add_node_x(comp_in, fn_in).call();
2450}
2451
2452
2465
2471 public:
2472 // args declaration
2478
2479 // constructor
2480 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) {}
2481
2482 // setter
2483 inline graph_add_edge_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2484 inline graph_add_edge_x&& src(graph_node_t src_in) { m_src = src_in; return std::move(*this); }
2485 inline graph_add_edge_x&& dst(graph_node_t dst_in) { m_dst = dst_in; return std::move(*this); }
2486 inline graph_add_edge_x&& fn(graph_edge_run_cb_t fn_in) { m_fn = fn_in; return std::move(*this); }
2487 inline graph_add_edge_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2488
2490 void call() const;
2491 inline void operator()() const { return call(); }
2492};
2493
2494inline void graph_add_edge(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in) {
2495 return graph_add_edge_x(comp_in, src_in, dst_in).call();
2496}
2497
2498
2509
2515 public:
2516 // args declaration
2520
2521 // constructor
2523
2524 // setter
2525 inline graph_node_mark_complete_x&& node(graph_node_t node_in) { m_node = node_in; return std::move(*this); }
2526 inline graph_node_mark_complete_x&& status(status_t status_in) { m_status = status_in; return std::move(*this); }
2527 inline graph_node_mark_complete_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2528
2530 void call() const;
2531 inline void operator()() const { return call(); }
2532};
2533
2535 return graph_node_mark_complete_x(node_in).call();
2536}
2537
2538
2548
2554 public:
2555 // args declaration
2558
2559 // constructor
2560 graph_start_x(comp_t comp_in) : m_comp(comp_in) {}
2561
2562 // setter
2563 inline graph_start_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2564 inline graph_start_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2565
2567 void call() const;
2568 inline void operator()() const { return call(); }
2569};
2570
2571inline void graph_start(comp_t comp_in) {
2572 return graph_start_x(comp_in).call();
2573}
2574
2575
2585
2591 public:
2592 // args declaration
2595
2596 // constructor
2597 graph_test_x(comp_t comp_in) : m_comp(comp_in) {}
2598
2599 // setter
2600 inline graph_test_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2601 inline graph_test_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2602
2604 status_t call() const;
2605 inline status_t operator()() const { return call(); }
2606};
2607
2608inline status_t graph_test(comp_t comp_in) {
2609 return graph_test_x(comp_in).call();
2610}
2611
2612
2626
2632 public:
2633 // args declaration
2640
2641 // constructor
2643
2644 // setter
2645 inline barrier_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2646 inline barrier_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2647 inline barrier_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2648 inline barrier_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2649 inline barrier_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
2650 inline barrier_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2651
2653 void call() const;
2654 inline void operator()() const { return call(); }
2655};
2656
2657inline void barrier() {
2658 return barrier_x().call();
2659}
2660
2661
2679
2685 public:
2686 // args declaration
2688 size_t m_size;
2697
2698 // constructor
2699 broadcast_x(void* buffer_in, size_t size_in, int root_in) : m_buffer(buffer_in), m_size(size_in), m_root(root_in) {}
2700
2701 // setter
2702 inline broadcast_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
2703 inline broadcast_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2704 inline broadcast_x&& root(int root_in) { m_root = root_in; return std::move(*this); }
2705 inline broadcast_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2706 inline broadcast_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2707 inline broadcast_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2708 inline broadcast_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2709 inline broadcast_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2710 inline broadcast_x&& algorithm(broadcast_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
2711 inline broadcast_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
2712
2714 void call() const;
2715 inline void operator()() const { return call(); }
2716};
2717
2718inline void broadcast(void* buffer_in, size_t size_in, int root_in) {
2719 return broadcast_x(buffer_in, size_in, root_in).call();
2720}
2721
2722
2740
2746 public:
2747 // args declaration
2748 const void* m_sendbuf;
2750 size_t m_count;
2758
2759 // constructor
2760 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) {}
2761
2762 // setter
2763 inline reduce_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2764 inline reduce_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2765 inline reduce_x&& count(size_t count_in) { m_count = count_in; return std::move(*this); }
2766 inline reduce_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
2767 inline reduce_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
2768 inline reduce_x&& root(int root_in) { m_root = root_in; return std::move(*this); }
2769 inline reduce_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2770 inline reduce_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2771 inline reduce_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2772 inline reduce_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2773
2775 void call() const;
2776 inline void operator()() const { return call(); }
2777};
2778
2779inline 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) {
2780 return reduce_x(sendbuf_in, recvbuf_in, count_in, item_size_in, op_in, root_in).call();
2781}
2782
2783
2803
2809 public:
2810 // args declaration
2811 const void* m_sendbuf;
2823
2824 // constructor
2825 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) {}
2826
2827 // setter
2828 inline reduce_scatter_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2829 inline reduce_scatter_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2830 inline reduce_scatter_x&& recvcount(size_t recvcount_in) { m_recvcount = recvcount_in; return std::move(*this); }
2831 inline reduce_scatter_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
2832 inline reduce_scatter_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
2833 inline reduce_scatter_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2834 inline reduce_scatter_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2835 inline reduce_scatter_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2836 inline reduce_scatter_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2837 inline reduce_scatter_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2838 inline reduce_scatter_x&& algorithm(reduce_scatter_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
2839 inline reduce_scatter_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
2840
2842 void call() const;
2843 inline void operator()() const { return call(); }
2844};
2845
2846inline void reduce_scatter(const void* sendbuf_in, void* recvbuf_in, size_t recvcount_in, size_t item_size_in, reduce_op_t op_in) {
2847 return reduce_scatter_x(sendbuf_in, recvbuf_in, recvcount_in, item_size_in, op_in).call();
2848}
2849
2850
2870
2876 public:
2877 // args declaration
2878 const void* m_sendbuf;
2880 size_t m_count;
2890
2891 // constructor
2892 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) {}
2893
2894 // setter
2895 inline allreduce_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2896 inline allreduce_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2897 inline allreduce_x&& count(size_t count_in) { m_count = count_in; return std::move(*this); }
2898 inline allreduce_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
2899 inline allreduce_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
2900 inline allreduce_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2901 inline allreduce_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2902 inline allreduce_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2903 inline allreduce_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2904 inline allreduce_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2905 inline allreduce_x&& algorithm(allreduce_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
2906 inline allreduce_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
2907
2909 void call() const;
2910 inline void operator()() const { return call(); }
2911};
2912
2913inline void allreduce(const void* sendbuf_in, void* recvbuf_in, size_t count_in, size_t item_size_in, reduce_op_t op_in) {
2914 return allreduce_x(sendbuf_in, recvbuf_in, count_in, item_size_in, op_in).call();
2915}
2916
2917
2932
2938 public:
2939 // args declaration
2940 const void* m_sendbuf;
2942 size_t m_size;
2947
2948 // constructor
2949 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) {}
2950
2951 // setter
2952 inline allgather_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2953 inline allgather_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2954 inline allgather_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2955 inline allgather_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2956 inline allgather_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2957 inline allgather_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2958 inline allgather_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2959
2961 void call() const;
2962 inline void operator()() const { return call(); }
2963};
2964
2965inline void allgather(const void* sendbuf_in, void* recvbuf_in, size_t size_in) {
2966 return allgather_x(sendbuf_in, recvbuf_in, size_in).call();
2967}
2968
2969
2985
2991 public:
2992 // args declaration
2993 const void* m_sendbuf;
2995 size_t m_size;
3001
3002 // constructor
3003 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) {}
3004
3005 // setter
3006 inline alltoall_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
3007 inline alltoall_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
3008 inline alltoall_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3009 inline alltoall_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3010 inline alltoall_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3011 inline alltoall_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3012 inline alltoall_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3013 inline alltoall_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3014
3016 void call() const;
3017 inline void operator()() const { return call(); }
3018};
3019
3020inline void alltoall(const void* sendbuf_in, void* recvbuf_in, size_t size_in) {
3021 return alltoall_x(sendbuf_in, recvbuf_in, size_in).call();
3022}
3023
3024
3053
3059 public:
3060 // args declaration
3064 size_t m_size;
3082
3083 // constructor
3084 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) {}
3085
3086 // setter
3087 inline post_comm_x&& direction(direction_t direction_in) { m_direction = direction_in; return std::move(*this); }
3088 inline post_comm_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3089 inline post_comm_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3090 inline post_comm_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3091 inline post_comm_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3092 inline post_comm_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3093 inline post_comm_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3094 inline post_comm_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3095 inline post_comm_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3096 inline post_comm_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3097 inline post_comm_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3098 inline post_comm_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3099 inline post_comm_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
3100 inline post_comm_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
3101 inline post_comm_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3102 inline post_comm_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
3103 inline post_comm_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3104 inline post_comm_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
3105 inline post_comm_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3106 inline post_comm_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3107 inline post_comm_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3108
3110 status_t call() const;
3111 inline status_t operator()() const { return call(); }
3112};
3113
3114inline status_t post_comm(direction_t direction_in, int rank_in, void* local_buffer_in, size_t size_in, comp_t local_comp_in) {
3115 return post_comm_x(direction_in, rank_in, local_buffer_in, size_in, local_comp_in).call();
3116}
3117
3118
3142
3148 public:
3149 // args declaration
3152 size_t m_size;
3166
3167 // constructor
3168 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) {}
3169
3170 // setter
3171 inline post_am_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3172 inline post_am_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3173 inline post_am_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3174 inline post_am_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3175 inline post_am_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
3176 inline post_am_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3177 inline post_am_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3178 inline post_am_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3179 inline post_am_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3180 inline post_am_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3181 inline post_am_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3182 inline post_am_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3183 inline post_am_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3184 inline post_am_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3185 inline post_am_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3186 inline post_am_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3187
3189 status_t call() const;
3190 inline status_t operator()() const { return call(); }
3191};
3192
3193inline 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) {
3194 return post_am_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_comp_in).call();
3195}
3196
3197
3222
3228 public:
3229 // args declaration
3232 size_t m_size;
3247
3248 // constructor
3249 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) {}
3250
3251 // setter
3252 inline post_send_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3253 inline post_send_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3254 inline post_send_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3255 inline post_send_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3256 inline post_send_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3257 inline post_send_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3258 inline post_send_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3259 inline post_send_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3260 inline post_send_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3261 inline post_send_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3262 inline post_send_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3263 inline post_send_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3264 inline post_send_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3265 inline post_send_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
3266 inline post_send_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3267 inline post_send_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3268 inline post_send_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3269
3271 status_t call() const;
3272 inline status_t operator()() const { return call(); }
3273};
3274
3275inline status_t post_send(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) {
3276 return post_send_x(rank_in, local_buffer_in, size_in, tag_in, local_comp_in).call();
3277}
3278
3279
3304
3310 public:
3311 // args declaration
3314 size_t m_size;
3329
3330 // constructor
3331 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) {}
3332
3333 // setter
3334 inline post_recv_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3335 inline post_recv_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3336 inline post_recv_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3337 inline post_recv_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3338 inline post_recv_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3339 inline post_recv_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3340 inline post_recv_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3341 inline post_recv_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3342 inline post_recv_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3343 inline post_recv_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3344 inline post_recv_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3345 inline post_recv_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3346 inline post_recv_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3347 inline post_recv_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
3348 inline post_recv_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3349 inline post_recv_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3350 inline post_recv_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3351
3353 status_t call() const;
3354 inline status_t operator()() const { return call(); }
3355};
3356
3357inline status_t post_recv(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) {
3358 return post_recv_x(rank_in, local_buffer_in, size_in, tag_in, local_comp_in).call();
3359}
3360
3361
3387
3393 public:
3394 // args declaration
3397 size_t m_size;
3399 uintptr_t m_remote_disp;
3413
3414 // constructor
3415 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) {}
3416
3417 // setter
3418 inline post_put_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3419 inline post_put_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3420 inline post_put_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3421 inline post_put_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3422 inline post_put_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
3423 inline post_put_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
3424 inline post_put_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3425 inline post_put_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3426 inline post_put_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3427 inline post_put_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3428 inline post_put_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3429 inline post_put_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3430 inline post_put_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3431 inline post_put_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
3432 inline post_put_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3433 inline post_put_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3434 inline post_put_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3435 inline post_put_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3436
3438 status_t call() const;
3439 inline status_t operator()() const { return call(); }
3440};
3441
3442inline 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) {
3443 return post_put_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_disp_in, rmr_in).call();
3444}
3445
3446
3472
3478 public:
3479 // args declaration
3482 size_t m_size;
3484 uintptr_t m_remote_disp;
3498
3499 // constructor
3500 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) {}
3501
3502 // setter
3503 inline post_get_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3504 inline post_get_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3505 inline post_get_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3506 inline post_get_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3507 inline post_get_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
3508 inline post_get_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
3509 inline post_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3510 inline post_get_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3511 inline post_get_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3512 inline post_get_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3513 inline post_get_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3514 inline post_get_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3515 inline post_get_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3516 inline post_get_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
3517 inline post_get_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3518 inline post_get_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3519 inline post_get_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3520 inline post_get_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3521
3523 status_t call() const;
3524 inline status_t operator()() const { return call(); }
3525};
3526
3527inline 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) {
3528 return post_get_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_disp_in, rmr_in).call();
3529}
3530
3531
3542
3548 public:
3549 // args declaration
3553
3554 // constructor
3556
3557 // setter
3558 inline progress_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3559 inline progress_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3560 inline progress_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3561
3563 error_t call() const;
3564 inline error_t operator()() const { return call(); }
3565};
3566
3568 return progress_x().call();
3569}
3570
3571
3581
3587 public:
3588 // args declaration
3591
3592 // constructor
3594
3595 // setter
3596 inline test_drained_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3597 inline test_drained_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3598
3600 error_t call() const;
3601 inline error_t operator()() const { return call(); }
3602};
3603
3605 return test_drained_x().call();
3606}
3607
3608
3618
3624 public:
3625 // args declaration
3628
3629 // constructor
3631
3632 // setter
3633 inline wait_drained_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3634 inline wait_drained_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3635
3637 void call() const;
3638 inline void operator()() const { return call(); }
3639};
3640
3641inline void wait_drained() {
3642 return wait_drained_x().call();
3643}
3644
3645
3646} // namespace lci
3647
3648#endif // LCI_BINDING_POST_HPP_
The actual implementation for allgather.
Definition lci_binding_post.hpp:2937
allgather_x && size(size_t size_in)
Definition lci_binding_post.hpp:2954
allgather_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2953
void * m_recvbuf
Definition lci_binding_post.hpp:2941
size_t m_size
Definition lci_binding_post.hpp:2942
void call() const
Definition binding.cpp:810
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2943
const void * m_sendbuf
Definition lci_binding_post.hpp:2940
allgather_x && device(device_t device_in)
Definition lci_binding_post.hpp:2956
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2946
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2945
allgather_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2955
allgather_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2957
allgather_x(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:2949
allgather_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2958
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:2944
void operator()() const
Definition lci_binding_post.hpp:2962
allgather_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2952
The actual implementation for alloc_counter.
Definition lci_binding_post.hpp:2130
alloc_counter_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2141
alloc_counter_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2143
option_t< const char * > m_name
Definition lci_binding_post.hpp:2134
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2133
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2135
comp_t operator()() const
Definition lci_binding_post.hpp:2147
comp_t call_impl(runtime_t runtime, const char *name, void *user_context) const
comp_t call() const
Definition binding.cpp:650
alloc_counter_x && name(const char *name_in)
Definition lci_binding_post.hpp:2142
alloc_counter_x()
Definition lci_binding_post.hpp:2138
The actual implementation for alloc_cq.
Definition lci_binding_post.hpp:2250
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2253
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:2255
alloc_cq_x && cq_type(attr_cq_type_t cq_type_in)
Definition lci_binding_post.hpp:2267
alloc_cq_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:2266
comp_t operator()() const
Definition lci_binding_post.hpp:2273
option_t< int > m_default_length
Definition lci_binding_post.hpp:2254
option_t< attr_cq_type_t > m_cq_type
Definition lci_binding_post.hpp:2256
alloc_cq_x && default_length(int default_length_in)
Definition lci_binding_post.hpp:2265
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:2268
alloc_cq_x()
Definition lci_binding_post.hpp:2261
comp_t call() const
Definition binding.cpp:670
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2258
alloc_cq_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2269
option_t< const char * > m_name
Definition lci_binding_post.hpp:2257
alloc_cq_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2264
The actual implementation for alloc_device.
Definition lci_binding_post.hpp:1001
alloc_device_x && alloc_default_endpoint(bool alloc_default_endpoint_in)
Definition lci_binding_post.hpp:1028
alloc_device_x()
Definition lci_binding_post.hpp:1020
option_t< bool > m_use_reg_cache
Definition lci_binding_post.hpp:1011
option_t< const char * > m_name
Definition lci_binding_post.hpp:1013
option_t< bool > m_alloc_progress_endpoint
Definition lci_binding_post.hpp:1010
option_t< net_context_t > m_net_context
Definition lci_binding_post.hpp:1016
alloc_device_x && net_max_recvs(size_t net_max_recvs_in)
Definition lci_binding_post.hpp:1024
option_t< attr_ibv_td_strategy_t > m_ibv_td_strategy
Definition lci_binding_post.hpp:1012
alloc_device_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1033
option_t< size_t > m_net_max_recvs
Definition lci_binding_post.hpp:1005
alloc_device_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1036
alloc_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1034
alloc_device_x && use_reg_cache(bool use_reg_cache_in)
Definition lci_binding_post.hpp:1030
alloc_device_x && name(const char *name_in)
Definition lci_binding_post.hpp:1032
option_t< double > m_net_send_reserved_pct
Definition lci_binding_post.hpp:1007
alloc_device_x && ofi_lock_mode(uint64_t ofi_lock_mode_in)
Definition lci_binding_post.hpp:1027
option_t< uint64_t > m_ofi_lock_mode
Definition lci_binding_post.hpp:1008
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1014
option_t< size_t > m_net_max_sends
Definition lci_binding_post.hpp:1004
alloc_device_x && net_send_reserved_pct(double net_send_reserved_pct_in)
Definition lci_binding_post.hpp:1026
device_t call_impl(size_t net_max_sends, size_t net_max_recvs, size_t net_max_cqes, double net_send_reserved_pct, uint64_t ofi_lock_mode, bool alloc_default_endpoint, bool alloc_progress_endpoint, bool use_reg_cache, attr_ibv_td_strategy_t ibv_td_strategy, const char *name, void *user_context, runtime_t runtime, net_context_t net_context, packet_pool_t packet_pool) const
alloc_device_x && alloc_progress_endpoint(bool alloc_progress_endpoint_in)
Definition lci_binding_post.hpp:1029
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:1017
option_t< size_t > m_net_max_cqes
Definition lci_binding_post.hpp:1006
alloc_device_x && net_context(net_context_t net_context_in)
Definition lci_binding_post.hpp:1035
option_t< bool > m_alloc_default_endpoint
Definition lci_binding_post.hpp:1009
device_t operator()() const
Definition lci_binding_post.hpp:1040
device_t call() const
Definition binding.cpp:404
alloc_device_x && net_max_cqes(size_t net_max_cqes_in)
Definition lci_binding_post.hpp:1025
alloc_device_x && ibv_td_strategy(attr_ibv_td_strategy_t ibv_td_strategy_in)
Definition lci_binding_post.hpp:1031
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1015
alloc_device_x && net_max_sends(size_t net_max_sends_in)
Definition lci_binding_post.hpp:1023
The actual implementation for alloc_endpoint.
Definition lci_binding_post.hpp:1218
endpoint_t call() const
Definition binding.cpp:457
alloc_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1232
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:1222
alloc_endpoint_x()
Definition lci_binding_post.hpp:1227
option_t< device_t > m_device
Definition lci_binding_post.hpp:1224
option_t< const char * > m_name
Definition lci_binding_post.hpp:1221
alloc_endpoint_x && device(device_t device_in)
Definition lci_binding_post.hpp:1233
endpoint_t operator()() const
Definition lci_binding_post.hpp:1237
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1223
alloc_endpoint_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1231
alloc_endpoint_x && name(const char *name_in)
Definition lci_binding_post.hpp:1230
The actual implementation for alloc_graph.
Definition lci_binding_post.hpp:2380
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2386
alloc_graph_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2395
comp_t call() const
Definition binding.cpp:695
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2385
alloc_graph_x && name(const char *name_in)
Definition lci_binding_post.hpp:2393
alloc_graph_x()
Definition lci_binding_post.hpp:2389
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:2394
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2383
alloc_graph_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2392
comp_t operator()() const
Definition lci_binding_post.hpp:2399
option_t< const char * > m_name
Definition lci_binding_post.hpp:2384
The actual implementation for alloc_handler.
Definition lci_binding_post.hpp:2335
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:2339
option_t< const char * > m_name
Definition lci_binding_post.hpp:2341
alloc_handler_x && handler(comp_handler_t handler_in)
Definition lci_binding_post.hpp:2348
alloc_handler_x(comp_handler_t handler_in)
Definition lci_binding_post.hpp:2345
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2342
comp_t call() const
Definition binding.cpp:686
comp_t operator()() const
Definition lci_binding_post.hpp:2356
alloc_handler_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:2350
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:2340
alloc_handler_x && name(const char *name_in)
Definition lci_binding_post.hpp:2351
alloc_handler_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2352
alloc_handler_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2349
comp_handler_t m_handler
Definition lci_binding_post.hpp:2338
The actual implementation for alloc_matching_engine.
Definition lci_binding_post.hpp:480
matching_engine_t operator()() const
Definition lci_binding_post.hpp:499
matching_engine_t call() const
Definition binding.cpp:288
alloc_matching_engine_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:494
option_t< attr_matching_engine_type_t > m_matching_engine_type
Definition lci_binding_post.hpp:483
option_t< void * > m_user_context
Definition lci_binding_post.hpp:485
alloc_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:495
alloc_matching_engine_x && name(const char *name_in)
Definition lci_binding_post.hpp:493
option_t< const char * > m_name
Definition lci_binding_post.hpp:484
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:492
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:486
alloc_matching_engine_x()
Definition lci_binding_post.hpp:489
The actual implementation for alloc_net_context.
Definition lci_binding_post.hpp:895
alloc_net_context_x && ofi_provider_name(std::string ofi_provider_name_in)
Definition lci_binding_post.hpp:916
option_t< int > m_ibv_gid_idx
Definition lci_binding_post.hpp:902
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:909
alloc_net_context_x && ibv_prefetch_strategy(attr_ibv_prefetch_strategy_t ibv_prefetch_strategy_in)
Definition lci_binding_post.hpp:922
alloc_net_context_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:926
option_t< attr_ibv_odp_strategy_t > m_ibv_odp_strategy
Definition lci_binding_post.hpp:904
alloc_net_context_x && ibv_gid_idx(int ibv_gid_idx_in)
Definition lci_binding_post.hpp:919
alloc_net_context_x()
Definition lci_binding_post.hpp:912
alloc_net_context_x && max_inject_size(size_t max_inject_size_in)
Definition lci_binding_post.hpp:918
option_t< void * > m_user_context
Definition lci_binding_post.hpp:908
alloc_net_context_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:925
option_t< bool > m_use_dmabuf
Definition lci_binding_post.hpp:906
alloc_net_context_x && backend(attr_backend_t backend_in)
Definition lci_binding_post.hpp:915
option_t< const char * > m_name
Definition lci_binding_post.hpp:907
alloc_net_context_x && ibv_force_gid_auto_select(bool ibv_force_gid_auto_select_in)
Definition lci_binding_post.hpp:920
alloc_net_context_x && name(const char *name_in)
Definition lci_binding_post.hpp:924
alloc_net_context_x && ibv_odp_strategy(attr_ibv_odp_strategy_t ibv_odp_strategy_in)
Definition lci_binding_post.hpp:921
alloc_net_context_x && use_dmabuf(bool use_dmabuf_in)
Definition lci_binding_post.hpp:923
option_t< attr_backend_t > m_backend
Definition lci_binding_post.hpp:898
alloc_net_context_x && max_msg_size(size_t max_msg_size_in)
Definition lci_binding_post.hpp:917
net_context_t call() const
Definition binding.cpp:368
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:899
option_t< bool > m_ibv_force_gid_auto_select
Definition lci_binding_post.hpp:903
option_t< size_t > m_max_inject_size
Definition lci_binding_post.hpp:901
net_context_t operator()() const
Definition lci_binding_post.hpp:930
option_t< size_t > m_max_msg_size
Definition lci_binding_post.hpp:900
option_t< attr_ibv_prefetch_strategy_t > m_ibv_prefetch_strategy
Definition lci_binding_post.hpp:905
The actual implementation for alloc_packet_pool.
Definition lci_binding_post.hpp:244
packet_pool_t call() const
Definition binding.cpp:242
alloc_packet_pool_x()
Definition lci_binding_post.hpp:254
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:258
alloc_packet_pool_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:260
alloc_packet_pool_x && packet_size(size_t packet_size_in)
Definition lci_binding_post.hpp:257
alloc_packet_pool_x && name(const char *name_in)
Definition lci_binding_post.hpp:259
option_t< size_t > m_packet_size
Definition lci_binding_post.hpp:247
alloc_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:261
option_t< const char * > m_name
Definition lci_binding_post.hpp:249
packet_pool_t operator()() const
Definition lci_binding_post.hpp:265
option_t< void * > m_user_context
Definition lci_binding_post.hpp:250
option_t< size_t > m_npackets
Definition lci_binding_post.hpp:248
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:251
The actual implementation for alloc_runtime.
Definition lci_binding_post.hpp:34
alloc_runtime_x && imm_nbits_tag(int imm_nbits_tag_in)
Definition lci_binding_post.hpp:52
alloc_runtime_x && imm_nbits_rcomp(int imm_nbits_rcomp_in)
Definition lci_binding_post.hpp:53
option_t< bool > m_alloc_default_packet_pool
Definition lci_binding_post.hpp:42
alloc_runtime_x && name(const char *name_in)
Definition lci_binding_post.hpp:58
runtime_t operator()() const
Definition lci_binding_post.hpp:63
option_t< bool > m_alloc_default_matching_engine
Definition lci_binding_post.hpp:43
runtime_t call() const
Definition binding.cpp:193
alloc_runtime_x && alloc_default_packet_pool(bool alloc_default_packet_pool_in)
Definition lci_binding_post.hpp:56
alloc_runtime_x && rdv_protocol(attr_rdv_protocol_t rdv_protocol_in)
Definition lci_binding_post.hpp:54
alloc_runtime_x()
Definition lci_binding_post.hpp:48
runtime_t call_impl(size_t packet_return_threshold, int imm_nbits_tag, int imm_nbits_rcomp, attr_rdv_protocol_t rdv_protocol, bool alloc_default_device, bool alloc_default_packet_pool, bool alloc_default_matching_engine, const char *name, void *user_context) const
alloc_runtime_x && alloc_default_matching_engine(bool alloc_default_matching_engine_in)
Definition lci_binding_post.hpp:57
alloc_runtime_x && alloc_default_device(bool alloc_default_device_in)
Definition lci_binding_post.hpp:55
alloc_runtime_x && packet_return_threshold(size_t packet_return_threshold_in)
Definition lci_binding_post.hpp:51
option_t< const char * > m_name
Definition lci_binding_post.hpp:44
alloc_runtime_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:59
option_t< bool > m_alloc_default_device
Definition lci_binding_post.hpp:41
option_t< attr_rdv_protocol_t > m_rdv_protocol
Definition lci_binding_post.hpp:40
option_t< void * > m_user_context
Definition lci_binding_post.hpp:45
option_t< int > m_imm_nbits_rcomp
Definition lci_binding_post.hpp:39
option_t< size_t > m_packet_return_threshold
Definition lci_binding_post.hpp:37
option_t< int > m_imm_nbits_tag
Definition lci_binding_post.hpp:38
The actual implementation for alloc_sync.
Definition lci_binding_post.hpp:2000
comp_t operator()() const
Definition lci_binding_post.hpp:2021
option_t< int > m_threshold
Definition lci_binding_post.hpp:2004
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2007
alloc_sync_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2017
alloc_sync_x && threshold(int threshold_in)
Definition lci_binding_post.hpp:2014
alloc_sync_x && name(const char *name_in)
Definition lci_binding_post.hpp:2016
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:2005
alloc_sync_x()
Definition lci_binding_post.hpp:2010
option_t< const char * > m_name
Definition lci_binding_post.hpp:2006
alloc_sync_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:2015
alloc_sync_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2013
comp_t call() const
Definition binding.cpp:625
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2003
The actual implementation for allreduce.
Definition lci_binding_post.hpp:2875
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:2898
void operator()() const
Definition lci_binding_post.hpp:2910
const void * m_sendbuf
Definition lci_binding_post.hpp:2878
option_t< device_t > m_device
Definition lci_binding_post.hpp:2884
allreduce_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2895
reduce_op_t m_op
Definition lci_binding_post.hpp:2882
void * m_recvbuf
Definition lci_binding_post.hpp:2879
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:2889
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:2892
allreduce_x && device(device_t device_in)
Definition lci_binding_post.hpp:2901
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2886
size_t m_count
Definition lci_binding_post.hpp:2880
allreduce_x && count(size_t count_in)
Definition lci_binding_post.hpp:2897
allreduce_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2896
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2885
allreduce_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2902
option_t< allreduce_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:2888
allreduce_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:2899
allreduce_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2900
allreduce_x && algorithm(allreduce_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:2905
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2883
allreduce_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:2906
size_t m_item_size
Definition lci_binding_post.hpp:2881
allreduce_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2904
void call() const
Definition binding.cpp:794
allreduce_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2903
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2887
The actual implementation for alltoall.
Definition lci_binding_post.hpp:2990
const void * m_sendbuf
Definition lci_binding_post.hpp:2993
void call() const
Definition binding.cpp:821
alltoall_x && device(device_t device_in)
Definition lci_binding_post.hpp:3010
alltoall_x && size(size_t size_in)
Definition lci_binding_post.hpp:3008
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2999
alltoall_x(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:3003
void * m_recvbuf
Definition lci_binding_post.hpp:2994
alltoall_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:3007
option_t< device_t > m_device
Definition lci_binding_post.hpp:2997
alltoall_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3012
alltoall_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3011
alltoall_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3009
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2996
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2998
alltoall_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:3006
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3000
alltoall_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3013
size_t m_size
Definition lci_binding_post.hpp:2995
void operator()() const
Definition lci_binding_post.hpp:3017
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:2631
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2639
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2637
barrier_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2648
barrier_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2650
barrier_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:2649
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:2635
void call() const
Definition binding.cpp:740
barrier_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2647
barrier_x()
Definition lci_binding_post.hpp:2642
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2636
barrier_x && device(device_t device_in)
Definition lci_binding_post.hpp:2646
void operator()() const
Definition lci_binding_post.hpp:2654
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:2638
barrier_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2645
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2634
The actual implementation for broadcast.
Definition lci_binding_post.hpp:2684
broadcast_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2708
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2692
void call() const
Definition binding.cpp:750
void operator()() const
Definition lci_binding_post.hpp:2715
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2693
int m_root
Definition lci_binding_post.hpp:2689
broadcast_x && root(int root_in)
Definition lci_binding_post.hpp:2704
broadcast_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2709
broadcast_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2705
broadcast_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:2711
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2690
broadcast_x && size(size_t size_in)
Definition lci_binding_post.hpp:2703
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:2696
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2694
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:2699
broadcast_x && device(device_t device_in)
Definition lci_binding_post.hpp:2706
option_t< broadcast_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:2695
void * m_buffer
Definition lci_binding_post.hpp:2687
option_t< device_t > m_device
Definition lci_binding_post.hpp:2691
broadcast_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:2702
broadcast_x && algorithm(broadcast_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:2710
broadcast_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2707
size_t m_size
Definition lci_binding_post.hpp:2688
The actual implementation for comp_signal.
Definition lci_binding_post.hpp:1844
comp_signal_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1857
comp_signal_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1855
status_t m_status
Definition lci_binding_post.hpp:1848
comp_t m_comp
Definition lci_binding_post.hpp:1847
void call() const
Definition binding.cpp:599
comp_signal_x(comp_t comp_in, status_t status_in)
Definition lci_binding_post.hpp:1852
void call_impl(comp_t comp, status_t status, runtime_t runtime) const
void operator()() const
Definition lci_binding_post.hpp:1861
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1849
comp_signal_x && status(status_t status_in)
Definition lci_binding_post.hpp:1856
The actual implementation for RESOURCE comp.
Definition lci_binding_pre.hpp:512
The actual implementation for counter_get.
Definition lci_binding_post.hpp:2169
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2173
int64_t call_impl(comp_t comp, runtime_t runtime) const
int64_t operator()() const
Definition lci_binding_post.hpp:2184
counter_get_x(comp_t comp_in)
Definition lci_binding_post.hpp:2176
int64_t call() const
Definition binding.cpp:657
counter_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2180
comp_t m_comp
Definition lci_binding_post.hpp:2172
counter_get_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2179
The actual implementation for counter_set.
Definition lci_binding_post.hpp:2207
counter_set_x(comp_t comp_in, int64_t value_in)
Definition lci_binding_post.hpp:2215
int64_t m_value
Definition lci_binding_post.hpp:2211
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2212
comp_t m_comp
Definition lci_binding_post.hpp:2210
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:2220
counter_set_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2218
void operator()() const
Definition lci_binding_post.hpp:2224
counter_set_x && value(int64_t value_in)
Definition lci_binding_post.hpp:2219
void call() const
Definition binding.cpp:663
The actual implementation for cq_pop.
Definition lci_binding_post.hpp:2295
status_t operator()() const
Definition lci_binding_post.hpp:2310
comp_t m_comp
Definition lci_binding_post.hpp:2298
status_t call_impl(comp_t comp, runtime_t runtime) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2299
cq_pop_x(comp_t comp_in)
Definition lci_binding_post.hpp:2302
cq_pop_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2305
cq_pop_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2306
status_t call() const
Definition binding.cpp:680
The actual implementation for deregister_memory.
Definition lci_binding_post.hpp:1142
void operator()() const
Definition lci_binding_post.hpp:1157
void call() const
Definition binding.cpp:440
mr_t * m_mr
Definition lci_binding_post.hpp:1145
deregister_memory_x && mr(mr_t *mr_in)
Definition lci_binding_post.hpp:1152
deregister_memory_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1153
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1146
void call_impl(mr_t *mr, runtime_t runtime) const
deregister_memory_x(mr_t *mr_in)
Definition lci_binding_post.hpp:1149
The actual implementation for deregister_packet_pool.
Definition lci_binding_post.hpp:365
deregister_packet_pool_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:376
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:368
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:370
void operator()() const
Definition lci_binding_post.hpp:382
void call() const
Definition binding.cpp:264
deregister_packet_pool_x && device(device_t device_in)
Definition lci_binding_post.hpp:377
device_t m_device
Definition lci_binding_post.hpp:369
deregister_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:378
deregister_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:373
The actual implementation for deregister_rcomp.
Definition lci_binding_post.hpp:1960
deregister_rcomp_x(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:1967
void operator()() const
Definition lci_binding_post.hpp:1975
rcomp_t m_rcomp
Definition lci_binding_post.hpp:1963
void call_impl(rcomp_t rcomp, runtime_t runtime) const
void call() const
Definition binding.cpp:619
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1964
deregister_rcomp_x && rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:1970
deregister_rcomp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1971
The actual implementation for RESOURCE device.
Definition lci_binding_pre.hpp:396
The actual implementation for RESOURCE endpoint.
Definition lci_binding_pre.hpp:473
The actual implementation for free_comp.
Definition lci_binding_post.hpp:1806
free_comp_x(comp_t *comp_in)
Definition lci_binding_post.hpp:1813
free_comp_x && comp(comp_t *comp_in)
Definition lci_binding_post.hpp:1816
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1810
comp_t * m_comp
Definition lci_binding_post.hpp:1809
void call() const
Definition binding.cpp:593
free_comp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1817
void operator()() const
Definition lci_binding_post.hpp:1821
void call_impl(comp_t *comp, runtime_t runtime) const
The actual implementation for free_device.
Definition lci_binding_post.hpp:1062
void call_impl(device_t *device, runtime_t runtime) const
free_device_x && device(device_t *device_in)
Definition lci_binding_post.hpp:1072
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1066
device_t * m_device
Definition lci_binding_post.hpp:1065
void operator()() const
Definition lci_binding_post.hpp:1077
void call() const
Definition binding.cpp:422
free_device_x(device_t *device_in)
Definition lci_binding_post.hpp:1069
free_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1073
The actual implementation for free_endpoint.
Definition lci_binding_post.hpp:1259
void operator()() const
Definition lci_binding_post.hpp:1274
endpoint_t * m_endpoint
Definition lci_binding_post.hpp:1262
free_endpoint_x && endpoint(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:1269
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1263
free_endpoint_x(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:1266
void call_impl(endpoint_t *endpoint, runtime_t runtime) const
void call() const
Definition binding.cpp:465
free_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1270
The actual implementation for free_matching_engine.
Definition lci_binding_post.hpp:521
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:531
free_matching_engine_x(matching_engine_t *matching_engine_in)
Definition lci_binding_post.hpp:528
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:525
matching_engine_t * m_matching_engine
Definition lci_binding_post.hpp:524
void call() const
Definition binding.cpp:296
free_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:532
void operator()() const
Definition lci_binding_post.hpp:536
The actual implementation for free_net_context.
Definition lci_binding_post.hpp:952
void operator()() const
Definition lci_binding_post.hpp:967
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:963
free_net_context_x(net_context_t *net_context_in)
Definition lci_binding_post.hpp:959
void call() const
Definition binding.cpp:384
net_context_t * m_net_context
Definition lci_binding_post.hpp:955
free_net_context_x && net_context(net_context_t *net_context_in)
Definition lci_binding_post.hpp:962
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:956
The actual implementation for free_packet_pool.
Definition lci_binding_post.hpp:287
void operator()() const
Definition lci_binding_post.hpp:302
free_packet_pool_x(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:294
void call() const
Definition binding.cpp:251
void call_impl(packet_pool_t *packet_pool, runtime_t runtime) const
packet_pool_t * m_packet_pool
Definition lci_binding_post.hpp:290
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:291
free_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:298
free_packet_pool_x && packet_pool(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:297
The actual implementation for free_runtime.
Definition lci_binding_post.hpp:84
void call_impl(runtime_t *runtime) const
free_runtime_x(runtime_t *runtime_in)
Definition lci_binding_post.hpp:90
runtime_t * m_runtime
Definition lci_binding_post.hpp:87
free_runtime_x && runtime(runtime_t *runtime_in)
Definition lci_binding_post.hpp:93
void operator()() const
Definition lci_binding_post.hpp:97
void call() const
Definition binding.cpp:207
The actual implementation for g_runtime_fina.
Definition lci_binding_post.hpp:176
g_runtime_fina_x()
Definition lci_binding_post.hpp:181
void call() const
Definition binding.cpp:227
void operator()() const
Definition lci_binding_post.hpp:187
void call_impl() const
The actual implementation for g_runtime_init.
Definition lci_binding_post.hpp:126
g_runtime_init_x && imm_nbits_rcomp(int imm_nbits_rcomp_in)
Definition lci_binding_post.hpp:145
g_runtime_init_x && alloc_default_packet_pool(bool alloc_default_packet_pool_in)
Definition lci_binding_post.hpp:148
g_runtime_init_x && imm_nbits_tag(int imm_nbits_tag_in)
Definition lci_binding_post.hpp:144
option_t< int > m_imm_nbits_tag
Definition lci_binding_post.hpp:130
option_t< int > m_imm_nbits_rcomp
Definition lci_binding_post.hpp:131
option_t< size_t > m_packet_return_threshold
Definition lci_binding_post.hpp:129
g_runtime_init_x && name(const char *name_in)
Definition lci_binding_post.hpp:150
option_t< attr_rdv_protocol_t > m_rdv_protocol
Definition lci_binding_post.hpp:132
option_t< void * > m_user_context
Definition lci_binding_post.hpp:137
option_t< bool > m_alloc_default_device
Definition lci_binding_post.hpp:133
g_runtime_init_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:151
g_runtime_init_x && alloc_default_matching_engine(bool alloc_default_matching_engine_in)
Definition lci_binding_post.hpp:149
runtime_t call() const
Definition binding.cpp:213
option_t< bool > m_alloc_default_matching_engine
Definition lci_binding_post.hpp:135
runtime_t call_impl(size_t packet_return_threshold, int imm_nbits_tag, int imm_nbits_rcomp, attr_rdv_protocol_t rdv_protocol, bool alloc_default_device, bool alloc_default_packet_pool, bool alloc_default_matching_engine, const char *name, void *user_context) const
option_t< bool > m_alloc_default_packet_pool
Definition lci_binding_post.hpp:134
g_runtime_init_x()
Definition lci_binding_post.hpp:140
g_runtime_init_x && alloc_default_device(bool alloc_default_device_in)
Definition lci_binding_post.hpp:147
option_t< const char * > m_name
Definition lci_binding_post.hpp:136
g_runtime_init_x && packet_return_threshold(size_t packet_return_threshold_in)
Definition lci_binding_post.hpp:143
runtime_t operator()() const
Definition lci_binding_post.hpp:155
g_runtime_init_x && rdv_protocol(attr_rdv_protocol_t rdv_protocol_in)
Definition lci_binding_post.hpp:146
The actual implementation for get_allocator.
Definition lci_binding_post.hpp:640
allocator_base_t * call_impl(runtime_t runtime) const
allocator_base_t * call() const
Definition binding.cpp:317
allocator_base_t * operator()() const
Definition lci_binding_post.hpp:653
get_allocator_x()
Definition lci_binding_post.hpp:646
get_allocator_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:649
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:643
The actual implementation for get_default_device.
Definition lci_binding_post.hpp:708
device_t call_impl(runtime_t runtime) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:711
get_default_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:717
device_t call() const
Definition binding.cpp:327
get_default_device_x()
Definition lci_binding_post.hpp:714
device_t operator()() const
Definition lci_binding_post.hpp:721
The actual implementation for get_default_endpoint.
Definition lci_binding_post.hpp:743
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:754
endpoint_t operator()() const
Definition lci_binding_post.hpp:758
endpoint_t call() const
Definition binding.cpp:332
get_default_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:753
get_default_endpoint_x()
Definition lci_binding_post.hpp:750
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:746
option_t< device_t > m_device
Definition lci_binding_post.hpp:747
The actual implementation for get_default_matching_engine.
Definition lci_binding_post.hpp:813
get_default_matching_engine_x()
Definition lci_binding_post.hpp:819
matching_engine_t call() const
Definition binding.cpp:343
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:816
matching_engine_t call_impl(runtime_t runtime) const
matching_engine_t operator()() const
Definition lci_binding_post.hpp:826
get_default_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:822
The actual implementation for get_default_net_context.
Definition lci_binding_post.hpp:674
net_context_t operator()() const
Definition lci_binding_post.hpp:687
get_default_net_context_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:683
get_default_net_context_x()
Definition lci_binding_post.hpp:680
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:677
net_context_t call_impl(runtime_t runtime) const
net_context_t call() const
Definition binding.cpp:322
The actual implementation for get_default_packet_pool.
Definition lci_binding_post.hpp:779
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:782
packet_pool_t operator()() const
Definition lci_binding_post.hpp:792
packet_pool_t call_impl(runtime_t runtime) const
packet_pool_t call() const
Definition binding.cpp:338
get_default_packet_pool_x()
Definition lci_binding_post.hpp:785
get_default_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:788
The actual implementation for get_g_runtime.
Definition lci_binding_post.hpp:208
runtime_t operator()() const
Definition lci_binding_post.hpp:219
get_g_runtime_x()
Definition lci_binding_post.hpp:213
runtime_t call() const
Definition binding.cpp:232
runtime_t call_impl() const
The actual implementation for get_max_bcopy_size.
Definition lci_binding_post.hpp:848
size_t operator()() const
Definition lci_binding_post.hpp:863
get_max_bcopy_size_x()
Definition lci_binding_post.hpp:855
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:851
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:852
get_max_bcopy_size_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:859
size_t call() const
Definition binding.cpp:348
get_max_bcopy_size_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:858
The actual implementation for get_rmr.
Definition lci_binding_post.hpp:1179
get_rmr_x(mr_t mr_in)
Definition lci_binding_post.hpp:1186
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1183
get_rmr_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1189
rmr_t operator()() const
Definition lci_binding_post.hpp:1194
mr_t m_mr
Definition lci_binding_post.hpp:1182
rmr_t call() const
Definition binding.cpp:446
get_rmr_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1190
rmr_t call_impl(mr_t mr, runtime_t runtime) const
The actual implementation for get_upacket.
Definition lci_binding_post.hpp:404
get_upacket_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:415
void * call() const
Definition binding.cpp:271
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:407
get_upacket_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:414
void * operator()() const
Definition lci_binding_post.hpp:419
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:408
get_upacket_x()
Definition lci_binding_post.hpp:411
The actual implementation for graph_add_edge.
Definition lci_binding_post.hpp:2470
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:2473
void call() const
Definition binding.cpp:712
graph_add_edge_x(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in)
Definition lci_binding_post.hpp:2480
graph_add_edge_x && dst(graph_node_t dst_in)
Definition lci_binding_post.hpp:2485
graph_add_edge_x && fn(graph_edge_run_cb_t fn_in)
Definition lci_binding_post.hpp:2486
void operator()() const
Definition lci_binding_post.hpp:2491
option_t< graph_edge_run_cb_t > m_fn
Definition lci_binding_post.hpp:2476
graph_add_edge_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2483
graph_node_t m_dst
Definition lci_binding_post.hpp:2475
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2477
graph_add_edge_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2487
graph_add_edge_x && src(graph_node_t src_in)
Definition lci_binding_post.hpp:2484
graph_node_t m_src
Definition lci_binding_post.hpp:2474
The actual implementation for graph_add_node.
Definition lci_binding_post.hpp:2424
option_t< void * > m_value
Definition lci_binding_post.hpp:2429
graph_node_t operator()() const
Definition lci_binding_post.hpp:2445
graph_add_node_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2441
graph_node_t call() const
Definition binding.cpp:703
graph_add_node_x(comp_t comp_in, graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:2434
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:2438
graph_node_run_cb_t m_fn
Definition lci_binding_post.hpp:2428
comp_t m_comp
Definition lci_binding_post.hpp:2427
graph_add_node_x && free_cb(graph_node_free_cb_t free_cb_in)
Definition lci_binding_post.hpp:2440
graph_add_node_x && value(void *value_in)
Definition lci_binding_post.hpp:2439
option_t< graph_node_free_cb_t > m_free_cb
Definition lci_binding_post.hpp:2430
graph_add_node_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2437
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2431
The actual implementation for graph_node_mark_complete.
Definition lci_binding_post.hpp:2514
void operator()() const
Definition lci_binding_post.hpp:2531
void call() const
Definition binding.cpp:721
graph_node_t m_node
Definition lci_binding_post.hpp:2517
graph_node_mark_complete_x(graph_node_t node_in)
Definition lci_binding_post.hpp:2522
option_t< status_t > m_status
Definition lci_binding_post.hpp:2518
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:2525
graph_node_mark_complete_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2527
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2519
graph_node_mark_complete_x && status(status_t status_in)
Definition lci_binding_post.hpp:2526
The actual implementation for graph_start.
Definition lci_binding_post.hpp:2553
graph_start_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2564
comp_t m_comp
Definition lci_binding_post.hpp:2556
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2557
graph_start_x(comp_t comp_in)
Definition lci_binding_post.hpp:2560
void call_impl(comp_t comp, runtime_t runtime) const
void call() const
Definition binding.cpp:728
void operator()() const
Definition lci_binding_post.hpp:2568
graph_start_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2563
The actual implementation for graph_test.
Definition lci_binding_post.hpp:2590
comp_t m_comp
Definition lci_binding_post.hpp:2593
status_t call_impl(comp_t comp, runtime_t runtime) const
graph_test_x(comp_t comp_in)
Definition lci_binding_post.hpp:2597
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2594
graph_test_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2601
status_t operator()() const
Definition lci_binding_post.hpp:2605
status_t call() const
Definition binding.cpp:734
graph_test_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2600
The actual implementation for matching_engine_insert.
Definition lci_binding_post.hpp:561
matching_engine_insert_x && value(matching_entry_val_t value_in)
Definition lci_binding_post.hpp:576
matching_engine_insert_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:578
matching_entry_val_t operator()() const
Definition lci_binding_post.hpp:582
matching_entry_val_t call() const
Definition binding.cpp:302
matching_engine_insert_x && entry_type(matching_entry_type_t entry_type_in)
Definition lci_binding_post.hpp:577
matching_engine_insert_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:574
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:568
matching_entry_type_t m_entry_type
Definition lci_binding_post.hpp:567
matching_engine_t m_matching_engine
Definition lci_binding_post.hpp:564
matching_entry_key_t m_key
Definition lci_binding_post.hpp:565
matching_engine_insert_x && key(matching_entry_key_t key_in)
Definition lci_binding_post.hpp:575
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:571
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:566
The actual implementation for RESOURCE matching_engine.
Definition lci_binding_pre.hpp:299
The actual implementation for RESOURCE mr.
Definition lci_binding_pre.hpp:439
The actual implementation for RESOURCE net_context.
Definition lci_binding_pre.hpp:343
The actual implementation for net_poll_cq.
Definition lci_binding_post.hpp:1298
net_poll_cq_x && device(device_t device_in)
Definition lci_binding_post.hpp:1313
net_poll_cq_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1312
option_t< device_t > m_device
Definition lci_binding_post.hpp:1304
net_poll_cq_x(size_t max_polls_in, net_status_t *statuses_in)
Definition lci_binding_post.hpp:1307
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1303
net_poll_cq_x && statuses(net_status_t *statuses_in)
Definition lci_binding_post.hpp:1311
size_t operator()() const
Definition lci_binding_post.hpp:1317
size_t call() const
Definition binding.cpp:471
net_poll_cq_x && max_polls(size_t max_polls_in)
Definition lci_binding_post.hpp:1310
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:1301
net_status_t * m_statuses
Definition lci_binding_post.hpp:1302
The actual implementation for net_post_get.
Definition lci_binding_post.hpp:1753
net_post_get_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1772
net_post_get_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1779
net_post_get_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1776
option_t< device_t > m_device
Definition lci_binding_post.hpp:1763
int m_rank
Definition lci_binding_post.hpp:1756
net_post_get_x && device(device_t device_in)
Definition lci_binding_post.hpp:1778
net_post_get_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1774
error_t operator()() const
Definition lci_binding_post.hpp:1784
net_post_get_x && size(size_t size_in)
Definition lci_binding_post.hpp:1773
error_t call() const
Definition binding.cpp:570
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1762
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1764
mr_t m_mr
Definition lci_binding_post.hpp:1759
void * m_buffer
Definition lci_binding_post.hpp:1757
net_post_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1777
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:1760
net_post_get_x && rank(int rank_in)
Definition lci_binding_post.hpp:1771
rmr_t m_rmr
Definition lci_binding_post.hpp:1761
size_t m_size
Definition lci_binding_post.hpp:1758
net_post_get_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1780
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1765
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:1768
net_post_get_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1775
The actual implementation for net_post_putImm.
Definition lci_binding_post.hpp:1690
net_post_putImm_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1717
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:1706
rmr_t m_rmr
Definition lci_binding_post.hpp:1698
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1699
net_post_putImm_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1712
net_post_putImm_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1714
error_t call() const
Definition binding.cpp:555
net_post_putImm_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1718
int m_rank
Definition lci_binding_post.hpp:1693
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1702
net_post_putImm_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1715
option_t< device_t > m_device
Definition lci_binding_post.hpp:1700
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1701
mr_t m_mr
Definition lci_binding_post.hpp:1696
net_post_putImm_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1710
void * m_buffer
Definition lci_binding_post.hpp:1694
net_post_putImm_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1719
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1703
error_t operator()() const
Definition lci_binding_post.hpp:1723
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:1695
net_post_putImm_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1713
uint64_t m_offset
Definition lci_binding_post.hpp:1697
net_post_putImm_x && size(size_t size_in)
Definition lci_binding_post.hpp:1711
net_post_putImm_x && rank(int rank_in)
Definition lci_binding_post.hpp:1709
net_post_putImm_x && device(device_t device_in)
Definition lci_binding_post.hpp:1716
The actual implementation for net_post_putImms.
Definition lci_binding_post.hpp:1628
net_post_putImms_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1647
net_post_putImms_x && device(device_t device_in)
Definition lci_binding_post.hpp:1652
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1638
option_t< device_t > m_device
Definition lci_binding_post.hpp:1637
net_post_putImms_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1650
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:1646
uint64_t m_offset
Definition lci_binding_post.hpp:1634
void * m_buffer
Definition lci_binding_post.hpp:1632
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1639
int m_rank
Definition lci_binding_post.hpp:1631
error_t operator()() const
Definition lci_binding_post.hpp:1659
net_post_putImms_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1649
error_t call() const
Definition binding.cpp:541
rmr_t m_rmr
Definition lci_binding_post.hpp:1635
net_post_putImms_x && size(size_t size_in)
Definition lci_binding_post.hpp:1648
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1640
net_post_putImms_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1653
net_post_putImms_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1654
size_t m_size
Definition lci_binding_post.hpp:1633
net_post_putImms_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1651
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1636
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:1643
net_post_putImms_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1655
The actual implementation for net_post_put.
Definition lci_binding_post.hpp:1567
rmr_t m_rmr
Definition lci_binding_post.hpp:1575
net_post_put_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1586
mr_t m_mr
Definition lci_binding_post.hpp:1573
net_post_put_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1590
int m_rank
Definition lci_binding_post.hpp:1570
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:1582
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:1576
error_t call() const
Definition binding.cpp:527
net_post_put_x && rank(int rank_in)
Definition lci_binding_post.hpp:1585
option_t< device_t > m_device
Definition lci_binding_post.hpp:1577
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1578
net_post_put_x && device(device_t device_in)
Definition lci_binding_post.hpp:1592
net_post_put_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1594
net_post_put_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1593
net_post_put_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1588
net_post_put_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1589
net_post_put_x && size(size_t size_in)
Definition lci_binding_post.hpp:1587
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1579
size_t m_size
Definition lci_binding_post.hpp:1572
net_post_put_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1591
error_t operator()() const
Definition lci_binding_post.hpp:1598
uint64_t m_offset
Definition lci_binding_post.hpp:1574
void * m_buffer
Definition lci_binding_post.hpp:1571
The actual implementation for net_post_puts.
Definition lci_binding_post.hpp:1508
net_post_puts_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1529
net_post_puts_x && rank(int rank_in)
Definition lci_binding_post.hpp:1525
error_t operator()() const
Definition lci_binding_post.hpp:1537
net_post_puts_x && size(size_t size_in)
Definition lci_binding_post.hpp:1527
option_t< device_t > m_device
Definition lci_binding_post.hpp:1517
void * m_buffer
Definition lci_binding_post.hpp:1512
net_post_puts_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:1528
net_post_puts_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1530
net_post_puts_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1526
net_post_puts_x && device(device_t device_in)
Definition lci_binding_post.hpp:1531
error_t call() const
Definition binding.cpp:514
int m_rank
Definition lci_binding_post.hpp:1511
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:1522
rmr_t m_rmr
Definition lci_binding_post.hpp:1515
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1516
size_t m_size
Definition lci_binding_post.hpp:1513
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1519
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:1533
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1518
net_post_puts_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1532
uint64_t m_offset
Definition lci_binding_post.hpp:1514
The actual implementation for net_post_recv.
Definition lci_binding_post.hpp:1343
net_post_recv_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1360
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1351
net_post_recv_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1357
error_t call() const
Definition binding.cpp:479
net_post_recv_x(void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1354
net_post_recv_x && size(size_t size_in)
Definition lci_binding_post.hpp:1358
net_post_recv_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1359
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1349
option_t< device_t > m_device
Definition lci_binding_post.hpp:1350
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:1348
size_t m_size
Definition lci_binding_post.hpp:1347
error_t operator()() const
Definition lci_binding_post.hpp:1366
net_post_recv_x && device(device_t device_in)
Definition lci_binding_post.hpp:1361
void * m_buffer
Definition lci_binding_post.hpp:1346
net_post_recv_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1362
The actual implementation for net_post_send.
Definition lci_binding_post.hpp:1450
net_post_send_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1474
net_post_send_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1471
net_post_send_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1468
void * m_buffer
Definition lci_binding_post.hpp:1454
int m_rank
Definition lci_binding_post.hpp:1453
mr_t m_mr
Definition lci_binding_post.hpp:1456
size_t m_size
Definition lci_binding_post.hpp:1455
net_post_send_x && size(size_t size_in)
Definition lci_binding_post.hpp:1469
error_t call() const
Definition binding.cpp:501
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1457
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1460
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1459
net_post_send_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1470
net_post_send_x && device(device_t device_in)
Definition lci_binding_post.hpp:1472
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1461
net_post_send_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1473
net_post_send_x(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1464
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:1458
error_t operator()() const
Definition lci_binding_post.hpp:1479
net_post_send_x && rank(int rank_in)
Definition lci_binding_post.hpp:1467
net_post_send_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1475
The actual implementation for net_post_sends.
Definition lci_binding_post.hpp:1394
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1404
net_post_sends_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:1416
net_post_sends_x && size(size_t size_in)
Definition lci_binding_post.hpp:1412
error_t call() const
Definition binding.cpp:489
option_t< device_t > m_device
Definition lci_binding_post.hpp:1401
net_post_sends_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1415
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:1397
net_post_sends_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1413
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:1403
net_post_sends_x(int rank_in, void *buffer_in, size_t size_in)
Definition lci_binding_post.hpp:1407
net_post_sends_x && rank(int rank_in)
Definition lci_binding_post.hpp:1410
void * m_buffer
Definition lci_binding_post.hpp:1398
net_post_sends_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1417
error_t operator()() const
Definition lci_binding_post.hpp:1421
net_post_sends_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:1411
size_t m_size
Definition lci_binding_post.hpp:1399
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1402
net_post_sends_x && device(device_t device_in)
Definition lci_binding_post.hpp:1414
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1400
The actual implementation for RESOURCE packet_pool.
Definition lci_binding_pre.hpp:263
The actual implementation for post_am.
Definition lci_binding_post.hpp:3147
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3160
option_t< device_t > m_device
Definition lci_binding_post.hpp:3156
post_am_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3179
rcomp_t m_remote_comp
Definition lci_binding_post.hpp:3154
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:3161
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3164
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:3168
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3157
post_am_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3184
post_am_x && size(size_t size_in)
Definition lci_binding_post.hpp:3173
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3165
post_am_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3176
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3155
post_am_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3182
int m_rank
Definition lci_binding_post.hpp:3150
post_am_x && rank(int rank_in)
Definition lci_binding_post.hpp:3171
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3158
post_am_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3180
status_t call() const
Definition binding.cpp:858
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3159
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:3181
comp_t m_local_comp
Definition lci_binding_post.hpp:3153
post_am_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3186
post_am_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3185
post_am_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3172
size_t m_size
Definition lci_binding_post.hpp:3152
post_am_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3178
post_am_x && device(device_t device_in)
Definition lci_binding_post.hpp:3177
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3163
post_am_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3183
void * m_local_buffer
Definition lci_binding_post.hpp:3151
post_am_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3174
status_t operator()() const
Definition lci_binding_post.hpp:3190
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3162
post_am_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:3175
The actual implementation for post_comm.
Definition lci_binding_post.hpp:3058
status_t call() const
Definition binding.cpp:833
void * m_local_buffer
Definition lci_binding_post.hpp:3063
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3077
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:3078
post_comm_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:3102
option_t< device_t > m_device
Definition lci_binding_post.hpp:3067
post_comm_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3096
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3081
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:3062
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:3070
post_comm_x && rank(int rank_in)
Definition lci_binding_post.hpp:3088
post_comm_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3092
post_comm_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3089
size_t m_size
Definition lci_binding_post.hpp:3064
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3066
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3072
comp_t m_local_comp
Definition lci_binding_post.hpp:3065
status_t operator()() const
Definition lci_binding_post.hpp:3111
option_t< rmr_t > m_rmr
Definition lci_binding_post.hpp:3074
post_comm_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3103
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3080
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:3084
option_t< uintptr_t > m_remote_disp
Definition lci_binding_post.hpp:3073
post_comm_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3095
post_comm_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3105
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3068
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:3076
post_comm_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3091
post_comm_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3101
post_comm_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:3100
post_comm_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3098
post_comm_x && direction(direction_t direction_in)
Definition lci_binding_post.hpp:3087
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3079
post_comm_x && size(size_t size_in)
Definition lci_binding_post.hpp:3090
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3069
post_comm_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3094
post_comm_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3106
post_comm_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3097
post_comm_x && device(device_t device_in)
Definition lci_binding_post.hpp:3093
post_comm_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3107
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3071
post_comm_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:3104
direction_t m_direction
Definition lci_binding_post.hpp:3061
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:3075
post_comm_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:3099
The actual implementation for post_get.
Definition lci_binding_post.hpp:3477
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:3493
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3494
post_get_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3518
post_get_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3515
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3490
comp_t m_local_comp
Definition lci_binding_post.hpp:3483
post_get_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3513
post_get_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:3507
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:3500
post_get_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3514
status_t operator()() const
Definition lci_binding_post.hpp:3524
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3489
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3497
uintptr_t m_remote_disp
Definition lci_binding_post.hpp:3484
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:3481
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3495
option_t< device_t > m_device
Definition lci_binding_post.hpp:3487
post_get_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:3508
int m_rank
Definition lci_binding_post.hpp:3480
post_get_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3504
post_get_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:3516
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3486
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3496
post_get_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3519
post_get_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3512
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3488
post_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3509
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3491
post_get_x && size(size_t size_in)
Definition lci_binding_post.hpp:3505
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:3492
post_get_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3511
status_t call() const
Definition binding.cpp:942
post_get_x && rank(int rank_in)
Definition lci_binding_post.hpp:3503
post_get_x && device(device_t device_in)
Definition lci_binding_post.hpp:3510
post_get_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3506
post_get_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3517
size_t m_size
Definition lci_binding_post.hpp:3482
rmr_t m_rmr
Definition lci_binding_post.hpp:3485
post_get_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3520
The actual implementation for post_put.
Definition lci_binding_post.hpp:3392
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:3410
post_put_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3432
post_put_x && device(device_t device_in)
Definition lci_binding_post.hpp:3425
status_t operator()() const
Definition lci_binding_post.hpp:3439
post_put_x && rank(int rank_in)
Definition lci_binding_post.hpp:3418
post_put_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3424
post_put_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3426
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3411
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3403
comp_t m_local_comp
Definition lci_binding_post.hpp:3398
uintptr_t m_remote_disp
Definition lci_binding_post.hpp:3399
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3412
option_t< device_t > m_device
Definition lci_binding_post.hpp:3402
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3409
post_put_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3419
int m_rank
Definition lci_binding_post.hpp:3395
post_put_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3427
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:3408
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:3415
post_put_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3430
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3406
post_put_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3433
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:3407
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3405
post_put_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3428
status_t call() const
Definition binding.cpp:920
post_put_x && size(size_t size_in)
Definition lci_binding_post.hpp:3420
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3401
post_put_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3435
post_put_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:3423
post_put_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3421
post_put_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:3422
rmr_t m_rmr
Definition lci_binding_post.hpp:3400
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3404
size_t m_size
Definition lci_binding_post.hpp:3397
post_put_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:3431
post_put_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3429
void * m_local_buffer
Definition lci_binding_post.hpp:3396
post_put_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3434
The actual implementation for post_recv.
Definition lci_binding_post.hpp:3309
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3328
post_recv_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3349
size_t m_size
Definition lci_binding_post.hpp:3314
post_recv_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3348
post_recv_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3337
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3324
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:3321
tag_t m_tag
Definition lci_binding_post.hpp:3315
post_recv_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3342
post_recv_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3339
option_t< device_t > m_device
Definition lci_binding_post.hpp:3318
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3326
post_recv_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3344
post_recv_x && size(size_t size_in)
Definition lci_binding_post.hpp:3336
status_t operator()() const
Definition lci_binding_post.hpp:3354
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3320
post_recv_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3346
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3322
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3323
void * m_local_buffer
Definition lci_binding_post.hpp:3313
post_recv_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3341
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3319
post_recv_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3343
comp_t m_local_comp
Definition lci_binding_post.hpp:3316
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3327
post_recv_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3345
post_recv_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3350
post_recv_x && device(device_t device_in)
Definition lci_binding_post.hpp:3340
int m_rank
Definition lci_binding_post.hpp:3312
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:3331
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3317
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:3325
post_recv_x && rank(int rank_in)
Definition lci_binding_post.hpp:3334
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:3338
post_recv_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:3347
post_recv_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3335
status_t call() const
Definition binding.cpp:899
The actual implementation for post_send.
Definition lci_binding_post.hpp:3227
post_send_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3266
post_send_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3256
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3238
status_t call() const
Definition binding.cpp:878
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:3239
post_send_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3259
void * m_local_buffer
Definition lci_binding_post.hpp:3231
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3242
post_send_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3263
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3244
size_t m_size
Definition lci_binding_post.hpp:3232
int m_rank
Definition lci_binding_post.hpp:3230
post_send_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3253
tag_t m_tag
Definition lci_binding_post.hpp:3233
post_send_x && size(size_t size_in)
Definition lci_binding_post.hpp:3254
comp_t m_local_comp
Definition lci_binding_post.hpp:3234
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:3249
status_t operator()() const
Definition lci_binding_post.hpp:3272
post_send_x && rank(int rank_in)
Definition lci_binding_post.hpp:3252
post_send_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3257
post_send_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3268
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3241
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3237
post_send_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3261
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:3262
post_send_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3267
option_t< device_t > m_device
Definition lci_binding_post.hpp:3236
post_send_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3264
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3240
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:3243
post_send_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3255
post_send_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:3265
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3246
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3245
post_send_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3260
post_send_x && device(device_t device_in)
Definition lci_binding_post.hpp:3258
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3235
The actual implementation for progress.
Definition lci_binding_post.hpp:3547
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3550
error_t call() const
Definition binding.cpp:964
progress_x()
Definition lci_binding_post.hpp:3555
progress_x && device(device_t device_in)
Definition lci_binding_post.hpp:3559
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3552
option_t< device_t > m_device
Definition lci_binding_post.hpp:3551
error_t operator()() const
Definition lci_binding_post.hpp:3564
progress_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3558
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:3560
The actual implementation for put_upacket.
Definition lci_binding_post.hpp:441
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:445
void * m_packet
Definition lci_binding_post.hpp:444
void call() const
Definition binding.cpp:277
void operator()() const
Definition lci_binding_post.hpp:456
put_upacket_x && packet(void *packet_in)
Definition lci_binding_post.hpp:451
put_upacket_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:452
put_upacket_x(void *packet_in)
Definition lci_binding_post.hpp:448
void call_impl(void *packet, runtime_t runtime) const
The actual implementation for reduce_scatter.
Definition lci_binding_post.hpp:2808
reduce_scatter_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2829
reduce_scatter_x && item_size(size_t item_size_in)
Definition lci_binding_post.hpp:2831
reduce_scatter_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2836
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:2822
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2818
reduce_scatter_x && device(device_t device_in)
Definition lci_binding_post.hpp:2834
reduce_scatter_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2828
reduce_scatter_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2837
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2820
option_t< reduce_scatter_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:2821
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2816
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:2812
size_t m_item_size
Definition lci_binding_post.hpp:2814
const void * m_sendbuf
Definition lci_binding_post.hpp:2811
size_t m_recvcount
Definition lci_binding_post.hpp:2813
reduce_scatter_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:2832
void operator()() const
Definition lci_binding_post.hpp:2843
reduce_scatter_x && algorithm(reduce_scatter_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:2838
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2819
reduce_op_t m_op
Definition lci_binding_post.hpp:2815
void call() const
Definition binding.cpp:778
reduce_scatter_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2833
option_t< device_t > m_device
Definition lci_binding_post.hpp:2817
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:2825
reduce_scatter_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2835
reduce_scatter_x && recvcount(size_t recvcount_in)
Definition lci_binding_post.hpp:2830
reduce_scatter_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:2839
The actual implementation for reduce.
Definition lci_binding_post.hpp:2745
void operator()() const
Definition lci_binding_post.hpp:2776
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:2760
reduce_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:2767
reduce_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2772
reduce_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2764
option_t< device_t > m_device
Definition lci_binding_post.hpp:2755
int m_root
Definition lci_binding_post.hpp:2753
size_t m_count
Definition lci_binding_post.hpp:2750
reduce_x && count(size_t count_in)
Definition lci_binding_post.hpp:2765
reduce_op_t m_op
Definition lci_binding_post.hpp:2752
reduce_x && device(device_t device_in)
Definition lci_binding_post.hpp:2770
size_t m_item_size
Definition lci_binding_post.hpp:2751
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2756
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:2749
reduce_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2763
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2757
reduce_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2769
reduce_x && item_size(size_t item_size_in)
Definition lci_binding_post.hpp:2766
reduce_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2771
reduce_x && root(int root_in)
Definition lci_binding_post.hpp:2768
const void * m_sendbuf
Definition lci_binding_post.hpp:2748
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2754
void call() const
Definition binding.cpp:764
The actual implementation for register_memory.
Definition lci_binding_post.hpp:1101
register_memory_x && address(void *address_in)
Definition lci_binding_post.hpp:1113
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1106
register_memory_x && device(device_t device_in)
Definition lci_binding_post.hpp:1116
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:1114
option_t< device_t > m_device
Definition lci_binding_post.hpp:1107
void * m_address
Definition lci_binding_post.hpp:1104
mr_t operator()() const
Definition lci_binding_post.hpp:1120
register_memory_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1115
register_memory_x(void *address_in, size_t size_in)
Definition lci_binding_post.hpp:1110
size_t m_size
Definition lci_binding_post.hpp:1105
mr_t call() const
Definition binding.cpp:432
The actual implementation for register_packet_pool.
Definition lci_binding_post.hpp:325
device_t m_device
Definition lci_binding_post.hpp:329
void call_impl(packet_pool_t packet_pool, device_t device, runtime_t runtime) const
void operator()() const
Definition lci_binding_post.hpp:342
register_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:333
register_packet_pool_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:336
void call() const
Definition binding.cpp:257
register_packet_pool_x && device(device_t device_in)
Definition lci_binding_post.hpp:337
packet_pool_t m_packet_pool
Definition lci_binding_post.hpp:328
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:330
register_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:338
The actual implementation for register_rcomp.
Definition lci_binding_post.hpp:1921
rcomp_t call() const
Definition binding.cpp:612
rcomp_t operator()() const
Definition lci_binding_post.hpp:1938
comp_t m_comp
Definition lci_binding_post.hpp:1924
option_t< rcomp_t > m_rcomp
Definition lci_binding_post.hpp:1926
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1925
register_rcomp_x && rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:1934
register_rcomp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1933
register_rcomp_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1932
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:1929
The actual implementation for reserve_rcomps.
Definition lci_binding_post.hpp:1883
rcomp_t call_impl(rcomp_t n, runtime_t runtime) const
rcomp_t m_n
Definition lci_binding_post.hpp:1886
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1887
reserve_rcomps_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1894
rcomp_t call() const
Definition binding.cpp:606
reserve_rcomps_x(rcomp_t n_in)
Definition lci_binding_post.hpp:1890
rcomp_t operator()() const
Definition lci_binding_post.hpp:1898
reserve_rcomps_x && n(rcomp_t n_in)
Definition lci_binding_post.hpp:1893
The actual implementation for RESOURCE runtime.
Definition lci_binding_pre.hpp:217
The actual implementation for set_allocator.
Definition lci_binding_post.hpp:604
set_allocator_x(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:611
set_allocator_x && allocator(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:614
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:608
void call_impl(allocator_base_t *allocator, runtime_t runtime) const
set_allocator_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:615
void call() const
Definition binding.cpp:311
allocator_base_t * m_allocator
Definition lci_binding_post.hpp:607
void operator()() const
Definition lci_binding_post.hpp:619
The actual implementation for sync_test.
Definition lci_binding_post.hpp:2044
comp_t m_comp
Definition lci_binding_post.hpp:2047
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:2056
status_t * m_p_out
Definition lci_binding_post.hpp:2048
sync_test_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2057
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2049
bool operator()() const
Definition lci_binding_post.hpp:2061
sync_test_x(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:2052
sync_test_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2055
bool call() const
Definition binding.cpp:634
The actual implementation for sync_wait.
Definition lci_binding_post.hpp:2086
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2091
sync_wait_x(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:2096
comp_t m_comp
Definition lci_binding_post.hpp:2089
sync_wait_x && p_out(status_t *p_out_in)
Definition lci_binding_post.hpp:2100
option_t< device_t > m_device
Definition lci_binding_post.hpp:2093
sync_wait_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2101
void call() const
Definition binding.cpp:641
status_t * m_p_out
Definition lci_binding_post.hpp:2090
option_t< bool > m_do_progress
Definition lci_binding_post.hpp:2092
sync_wait_x && device(device_t device_in)
Definition lci_binding_post.hpp:2103
sync_wait_x && do_progress(bool do_progress_in)
Definition lci_binding_post.hpp:2102
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:2107
sync_wait_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2099
The actual implementation for test_drained.
Definition lci_binding_post.hpp:3586
option_t< device_t > m_device
Definition lci_binding_post.hpp:3590
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3589
test_drained_x()
Definition lci_binding_post.hpp:3593
error_t operator()() const
Definition lci_binding_post.hpp:3601
test_drained_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3596
test_drained_x && device(device_t device_in)
Definition lci_binding_post.hpp:3597
error_t call() const
Definition binding.cpp:971
error_t call_impl(runtime_t runtime, device_t device) const
The actual implementation for wait_drained.
Definition lci_binding_post.hpp:3623
option_t< device_t > m_device
Definition lci_binding_post.hpp:3627
void operator()() const
Definition lci_binding_post.hpp:3638
wait_drained_x()
Definition lci_binding_post.hpp:3630
void call() const
Definition binding.cpp:977
void call_impl(runtime_t runtime, device_t device) const
wait_drained_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3633
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3626
wait_drained_x && device(device_t device_in)
Definition lci_binding_post.hpp:3634
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:3114
error_t net_post_send(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1482
void graph_node_mark_complete(graph_node_t node_in)
Definition lci_binding_post.hpp:2534
size_t get_max_bcopy_size()
Definition lci_binding_post.hpp:866
attr_matching_engine_type_t
Definition lci_binding_pre.hpp:34
void broadcast(void *buffer_in, size_t size_in, int root_in)
Definition lci_binding_post.hpp:2718
device_t alloc_device()
Definition lci_binding_post.hpp:1043
net_context_t alloc_net_context()
Definition lci_binding_post.hpp:933
void free_net_context(net_context_t *net_context_in)
Definition lci_binding_post.hpp:970
error_t net_post_recv(void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:1369
attr_backend_t
Definition lci.hpp:65
void deregister_rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:1978
void deregister_memory(mr_t *mr_in)
Definition lci_binding_post.hpp:1160
comp_t alloc_counter()
Definition lci_binding_post.hpp:2150
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:3193
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:585
void wait_drained()
Definition lci_binding_post.hpp:3641
rcomp_t reserve_rcomps(rcomp_t n_in)
Definition lci_binding_post.hpp:1901
void sync_wait(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:2110
matching_engine_t alloc_matching_engine()
Definition lci_binding_post.hpp:502
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:1662
void alltoall(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:3020
status_t graph_test(comp_t comp_in)
Definition lci_binding_post.hpp:2608
void register_packet_pool(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:345
matching_engine_t get_default_matching_engine()
Definition lci_binding_post.hpp:829
status_t cq_pop(comp_t comp_in)
Definition lci_binding_post.hpp:2313
size_t net_poll_cq(size_t max_polls_in, net_status_t *statuses_in)
Definition lci_binding_post.hpp:1320
attr_rdv_protocol_t
Definition lci_binding_pre.hpp:28
void graph_start(comp_t comp_in)
Definition lci_binding_post.hpp:2571
void free_matching_engine(matching_engine_t *matching_engine_in)
Definition lci_binding_post.hpp:539
void put_upacket(void *packet_in)
Definition lci_binding_post.hpp:459
comp_t alloc_cq()
Definition lci_binding_post.hpp:2276
void g_runtime_fina()
Definition lci_binding_post.hpp:190
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:1540
rcomp_t register_rcomp(comp_t comp_in)
Definition lci_binding_post.hpp:1941
error_t net_post_sends(int rank_in, void *buffer_in, size_t size_in)
Definition lci_binding_post.hpp:1424
void graph_add_edge(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in)
Definition lci_binding_post.hpp:2494
void set_allocator(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:622
allocator_base_t * get_allocator()
Definition lci_binding_post.hpp:656
net_context_t get_default_net_context()
Definition lci_binding_post.hpp:690
void free_device(device_t *device_in)
Definition lci_binding_post.hpp:1080
void free_comp(comp_t *comp_in)
Definition lci_binding_post.hpp:1824
packet_pool_t get_default_packet_pool()
Definition lci_binding_post.hpp:795
void free_runtime(runtime_t *runtime_in)
Definition lci_binding_post.hpp:100
comp_t alloc_handler(comp_handler_t handler_in)
Definition lci_binding_post.hpp:2359
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:1726
runtime_t get_g_runtime()
Definition lci_binding_post.hpp:222
void free_packet_pool(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:305
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:2779
void deregister_packet_pool(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:385
runtime_t g_runtime_init()
Definition lci_binding_post.hpp:158
void counter_set(comp_t comp_in, int64_t value_in)
Definition lci_binding_post.hpp:2227
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:3275
void comp_signal(comp_t comp_in, status_t status_in)
Definition lci_binding_post.hpp:1864
mr_t register_memory(void *address_in, size_t size_in)
Definition lci_binding_post.hpp:1123
rmr_t get_rmr(mr_t mr_in)
Definition lci_binding_post.hpp:1197
endpoint_t alloc_endpoint()
Definition lci_binding_post.hpp:1240
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:3442
endpoint_t get_default_endpoint()
Definition lci_binding_post.hpp:761
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:2913
graph_node_t graph_add_node(comp_t comp_in, graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:2448
runtime_t alloc_runtime()
Definition lci_binding_post.hpp:66
void allgather(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:2965
bool sync_test(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:2064
attr_ibv_td_strategy_t
Definition lci_binding_pre.hpp:52
error_t progress()
Definition lci_binding_post.hpp:3567
attr_ibv_odp_strategy_t
Definition lci_binding_pre.hpp:39
error_t test_drained()
Definition lci_binding_post.hpp:3604
device_t get_default_device()
Definition lci_binding_post.hpp:724
int64_t counter_get(comp_t comp_in)
Definition lci_binding_post.hpp:2187
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:2846
packet_pool_t alloc_packet_pool()
Definition lci_binding_post.hpp:268
attr_ibv_prefetch_strategy_t
Definition lci_binding_pre.hpp:45
void barrier()
Definition lci_binding_post.hpp:2657
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:1787
attr_cq_type_t
Definition lci_binding_pre.hpp:67
comp_t alloc_graph()
Definition lci_binding_post.hpp:2402
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:3357
void * get_upacket()
Definition lci_binding_post.hpp:422
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:1601
comp_t alloc_sync()
Definition lci_binding_post.hpp:2024
void free_endpoint(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:1277
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:3527
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