LCI v2.0.0-dev
For Asynchronous Multithreaded Communication
Loading...
Searching...
No Matches
lci_binding_post.hpp
Go to the documentation of this file.
1
2// Copyright (c) 2025 The LCI Project Authors
3// SPDX-License-Identifier: NCSA
4
5// clang-format off
6// This file is generated by generate_binding.py
7#ifndef LCI_BINDING_POST_HPP_
8#define LCI_BINDING_POST_HPP_
9
10namespace lci {
11
12
30
36 public:
37 // args declaration
48
49 // constructor
51
52 // setter
53 inline alloc_runtime_x&& packet_return_threshold(size_t packet_return_threshold_in) { m_packet_return_threshold = packet_return_threshold_in; return std::move(*this); }
54 inline alloc_runtime_x&& imm_nbits_tag(int imm_nbits_tag_in) { m_imm_nbits_tag = imm_nbits_tag_in; return std::move(*this); }
55 inline alloc_runtime_x&& imm_nbits_rcomp(int imm_nbits_rcomp_in) { m_imm_nbits_rcomp = imm_nbits_rcomp_in; return std::move(*this); }
56 inline alloc_runtime_x&& rdv_protocol(attr_rdv_protocol_t rdv_protocol_in) { m_rdv_protocol = rdv_protocol_in; return std::move(*this); }
57 inline alloc_runtime_x&& alloc_default_device(bool alloc_default_device_in) { m_alloc_default_device = alloc_default_device_in; return std::move(*this); }
58 inline alloc_runtime_x&& alloc_default_packet_pool(bool alloc_default_packet_pool_in) { m_alloc_default_packet_pool = alloc_default_packet_pool_in; return std::move(*this); }
59 inline alloc_runtime_x&& alloc_default_matching_engine(bool alloc_default_matching_engine_in) { m_alloc_default_matching_engine = alloc_default_matching_engine_in; return std::move(*this); }
60 inline alloc_runtime_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
61 inline alloc_runtime_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
62 inline alloc_runtime_x&& device_name(std::string device_name_in) { m_device_name = device_name_in; return std::move(*this); }
63
65 runtime_t call() const;
66 inline runtime_t operator()() const { return call(); }
67};
68
70 return alloc_runtime_x().call();
71}
72
73
82
88 public:
89 // args declaration
91
92 // constructor
93 free_runtime_x(runtime_t* runtime_in) : m_runtime(runtime_in) {}
94
95 // setter
96 inline free_runtime_x&& runtime(runtime_t* runtime_in) { m_runtime = runtime_in; return std::move(*this); }
97
99 void call() const;
100 inline void operator()() const { return call(); }
101};
102
103inline void free_runtime(runtime_t* runtime_in) {
104 return free_runtime_x(runtime_in).call();
105}
106
107
125
131 public:
132 // args declaration
143
144 // constructor
146
147 // setter
148 inline g_runtime_init_x&& packet_return_threshold(size_t packet_return_threshold_in) { m_packet_return_threshold = packet_return_threshold_in; return std::move(*this); }
149 inline g_runtime_init_x&& imm_nbits_tag(int imm_nbits_tag_in) { m_imm_nbits_tag = imm_nbits_tag_in; return std::move(*this); }
150 inline g_runtime_init_x&& imm_nbits_rcomp(int imm_nbits_rcomp_in) { m_imm_nbits_rcomp = imm_nbits_rcomp_in; return std::move(*this); }
151 inline g_runtime_init_x&& rdv_protocol(attr_rdv_protocol_t rdv_protocol_in) { m_rdv_protocol = rdv_protocol_in; return std::move(*this); }
152 inline g_runtime_init_x&& alloc_default_device(bool alloc_default_device_in) { m_alloc_default_device = alloc_default_device_in; return std::move(*this); }
153 inline g_runtime_init_x&& alloc_default_packet_pool(bool alloc_default_packet_pool_in) { m_alloc_default_packet_pool = alloc_default_packet_pool_in; return std::move(*this); }
154 inline g_runtime_init_x&& alloc_default_matching_engine(bool alloc_default_matching_engine_in) { m_alloc_default_matching_engine = alloc_default_matching_engine_in; return std::move(*this); }
155 inline g_runtime_init_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
156 inline g_runtime_init_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
157 inline g_runtime_init_x&& device_name(std::string device_name_in) { m_device_name = device_name_in; return std::move(*this); }
158
160 runtime_t call() const;
161 inline runtime_t operator()() const { return call(); }
162};
163
165 return g_runtime_init_x().call();
166}
167
168
177
183 public:
184 // args declaration
185
186 // constructor
188
189 // setter
190
191 void call_impl() const;
192 void call() const;
193 inline void operator()() const { return call(); }
194};
195
196inline void g_runtime_fina() {
197 return g_runtime_fina_x().call();
198}
199
200
209
215 public:
216 // args declaration
217
218 // constructor
220
221 // setter
222
224 runtime_t call() const;
225 inline runtime_t operator()() const { return call(); }
226};
227
229 return get_g_runtime_x().call();
230}
231
232
245
251 public:
252 // args declaration
258
259 // constructor
261
262 // setter
263 inline alloc_packet_pool_x&& packet_size(size_t packet_size_in) { m_packet_size = packet_size_in; return std::move(*this); }
264 inline alloc_packet_pool_x&& npackets(size_t npackets_in) { m_npackets = npackets_in; return std::move(*this); }
265 inline alloc_packet_pool_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
266 inline alloc_packet_pool_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
267 inline alloc_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
268
269 packet_pool_t call_impl(size_t packet_size, size_t npackets, const char* name, void* user_context, runtime_t runtime) const;
270 packet_pool_t call() const;
271 inline packet_pool_t operator()() const { return call(); }
272};
273
277
278
288
294 public:
295 // args declaration
298
299 // constructor
300 free_packet_pool_x(packet_pool_t* packet_pool_in) : m_packet_pool(packet_pool_in) {}
301
302 // setter
303 inline free_packet_pool_x&& packet_pool(packet_pool_t* packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
304 inline free_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
305
307 void call() const;
308 inline void operator()() const { return call(); }
309};
310
311inline void free_packet_pool(packet_pool_t* packet_pool_in) {
312 return free_packet_pool_x(packet_pool_in).call();
313}
314
315
326
332 public:
333 // args declaration
337
338 // constructor
339 register_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in) : m_packet_pool(packet_pool_in), m_device(device_in) {}
340
341 // setter
342 inline register_packet_pool_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
343 inline register_packet_pool_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
344 inline register_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
345
347 void call() const;
348 inline void operator()() const { return call(); }
349};
350
351inline void register_packet_pool(packet_pool_t packet_pool_in, device_t device_in) {
352 return register_packet_pool_x(packet_pool_in, device_in).call();
353}
354
355
366
372 public:
373 // args declaration
377
378 // constructor
379 deregister_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in) : m_packet_pool(packet_pool_in), m_device(device_in) {}
380
381 // setter
382 inline deregister_packet_pool_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
383 inline deregister_packet_pool_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
384 inline deregister_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
385
387 void call() const;
388 inline void operator()() const { return call(); }
389};
390
391inline void deregister_packet_pool(packet_pool_t packet_pool_in, device_t device_in) {
392 return deregister_packet_pool_x(packet_pool_in, device_in).call();
393}
394
395
405
411 public:
412 // args declaration
415
416 // constructor
418
419 // setter
420 inline get_upacket_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
421 inline get_upacket_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
422
424 void* call() const;
425 inline void* operator()() const { return call(); }
426};
427
428inline void* get_upacket() {
429 return get_upacket_x().call();
430}
431
432
442
448 public:
449 // args declaration
450 void* m_packet;
452
453 // constructor
454 put_upacket_x(void* packet_in) : m_packet(packet_in) {}
455
456 // setter
457 inline put_upacket_x&& packet(void* packet_in) { m_packet = packet_in; return std::move(*this); }
458 inline put_upacket_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
459
460 void call_impl(void* packet, runtime_t runtime) const;
461 void call() const;
462 inline void operator()() const { return call(); }
463};
464
465inline void put_upacket(void* packet_in) {
466 return put_upacket_x(packet_in).call();
467}
468
469
481
487 public:
488 // args declaration
493
494 // constructor
496
497 // setter
498 inline alloc_matching_engine_x&& matching_engine_type(attr_matching_engine_type_t matching_engine_type_in) { m_matching_engine_type = matching_engine_type_in; return std::move(*this); }
499 inline alloc_matching_engine_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
500 inline alloc_matching_engine_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
501 inline alloc_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
502
504 matching_engine_t call() const;
505 inline matching_engine_t operator()() const { return call(); }
506};
507
511
512
522
528 public:
529 // args declaration
532
533 // constructor
534 free_matching_engine_x(matching_engine_t* matching_engine_in) : m_matching_engine(matching_engine_in) {}
535
536 // setter
537 inline free_matching_engine_x&& matching_engine(matching_engine_t* matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
538 inline free_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
539
541 void call() const;
542 inline void operator()() const { return call(); }
543};
544
545inline void free_matching_engine(matching_engine_t* matching_engine_in) {
546 return free_matching_engine_x(matching_engine_in).call();
547}
548
549
562
568 public:
569 // args declaration
575
576 // constructor
577 matching_engine_insert_x(matching_engine_t matching_engine_in, matching_entry_key_t key_in, matching_entry_val_t value_in, matching_entry_type_t entry_type_in) : m_matching_engine(matching_engine_in), m_key(key_in), m_value(value_in), m_entry_type(entry_type_in) {}
578
579 // setter
580 inline matching_engine_insert_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
581 inline matching_engine_insert_x&& key(matching_entry_key_t key_in) { m_key = key_in; return std::move(*this); }
582 inline matching_engine_insert_x&& value(matching_entry_val_t value_in) { m_value = value_in; return std::move(*this); }
583 inline matching_engine_insert_x&& entry_type(matching_entry_type_t entry_type_in) { m_entry_type = entry_type_in; return std::move(*this); }
584 inline matching_engine_insert_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
585
588 inline matching_entry_val_t operator()() const { return call(); }
589};
590
592 return matching_engine_insert_x(matching_engine_in, key_in, value_in, entry_type_in).call();
593}
594
595
605
611 public:
612 // args declaration
615
616 // constructor
617 set_allocator_x(allocator_base_t* allocator_in) : m_allocator(allocator_in) {}
618
619 // setter
620 inline set_allocator_x&& allocator(allocator_base_t* allocator_in) { m_allocator = allocator_in; return std::move(*this); }
621 inline set_allocator_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
622
624 void call() const;
625 inline void operator()() const { return call(); }
626};
627
628inline void set_allocator(allocator_base_t* allocator_in) {
629 return set_allocator_x(allocator_in).call();
630}
631
632
641
647 public:
648 // args declaration
650
651 // constructor
653
654 // setter
655 inline get_allocator_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
656
658 allocator_base_t* call() const;
659 inline allocator_base_t* operator()() const { return call(); }
660};
661
663 return get_allocator_x().call();
664}
665
666
675
681 public:
682 // args declaration
684
685 // constructor
687
688 // setter
689 inline get_default_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
690
692 net_context_t call() const;
693 inline net_context_t operator()() const { return call(); }
694};
695
699
700
709
715 public:
716 // args declaration
718
719 // constructor
721
722 // setter
723 inline get_default_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
724
726 device_t call() const;
727 inline device_t operator()() const { return call(); }
728};
729
731 return get_default_device_x().call();
732}
733
734
744
750 public:
751 // args declaration
754
755 // constructor
757
758 // setter
759 inline get_default_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
760 inline get_default_endpoint_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
761
763 endpoint_t call() const;
764 inline endpoint_t operator()() const { return call(); }
765};
766
770
771
780
786 public:
787 // args declaration
789
790 // constructor
792
793 // setter
794 inline get_default_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
795
797 packet_pool_t call() const;
798 inline packet_pool_t operator()() const { return call(); }
799};
800
804
805
814
820 public:
821 // args declaration
823
824 // constructor
826
827 // setter
828 inline get_default_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
829
831 matching_engine_t call() const;
832 inline matching_engine_t operator()() const { return call(); }
833};
834
838
839
849
855 public:
856 // args declaration
859
860 // constructor
862
863 // setter
864 inline get_max_bcopy_size_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
865 inline get_max_bcopy_size_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
866
868 size_t call() const;
869 inline size_t operator()() const { return call(); }
870};
871
872inline size_t get_max_bcopy_size() {
873 return get_max_bcopy_size_x().call();
874}
875
876
890
896 public:
897 // args declaration
904
905 // constructor
907
908 // setter
909 inline barrier_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
910 inline barrier_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
911 inline barrier_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
912 inline barrier_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
913 inline barrier_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
914 inline barrier_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
915
917 void call() const;
918 inline void operator()() const { return call(); }
919};
920
921inline void barrier() {
922 return barrier_x().call();
923}
924
925
943
949 public:
950 // args declaration
951 void* m_buffer;
952 size_t m_size;
961
962 // constructor
963 broadcast_x(void* buffer_in, size_t size_in, int root_in) : m_buffer(buffer_in), m_size(size_in), m_root(root_in) {}
964
965 // setter
966 inline broadcast_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
967 inline broadcast_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
968 inline broadcast_x&& root(int root_in) { m_root = root_in; return std::move(*this); }
969 inline broadcast_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
970 inline broadcast_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
971 inline broadcast_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
972 inline broadcast_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
973 inline broadcast_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
974 inline broadcast_x&& algorithm(broadcast_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
975 inline broadcast_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
976
978 void call() const;
979 inline void operator()() const { return call(); }
980};
981
982inline void broadcast(void* buffer_in, size_t size_in, int root_in) {
983 return broadcast_x(buffer_in, size_in, root_in).call();
984}
985
986
1004
1010 public:
1011 // args declaration
1012 const void* m_sendbuf;
1014 size_t m_count;
1022
1023 // constructor
1024 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) {}
1025
1026 // setter
1027 inline reduce_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
1028 inline reduce_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
1029 inline reduce_x&& count(size_t count_in) { m_count = count_in; return std::move(*this); }
1030 inline reduce_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
1031 inline reduce_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
1032 inline reduce_x&& root(int root_in) { m_root = root_in; return std::move(*this); }
1033 inline reduce_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1034 inline reduce_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1035 inline reduce_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1036 inline reduce_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1037
1039 void call() const;
1040 inline void operator()() const { return call(); }
1041};
1042
1043inline 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) {
1044 return reduce_x(sendbuf_in, recvbuf_in, count_in, item_size_in, op_in, root_in).call();
1045}
1046
1047
1067
1073 public:
1074 // args declaration
1075 const void* m_sendbuf;
1087
1088 // constructor
1089 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) {}
1090
1091 // setter
1092 inline reduce_scatter_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
1093 inline reduce_scatter_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
1094 inline reduce_scatter_x&& recvcount(size_t recvcount_in) { m_recvcount = recvcount_in; return std::move(*this); }
1095 inline reduce_scatter_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
1096 inline reduce_scatter_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
1097 inline reduce_scatter_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1098 inline reduce_scatter_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1099 inline reduce_scatter_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1100 inline reduce_scatter_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1101 inline reduce_scatter_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1102 inline reduce_scatter_x&& algorithm(reduce_scatter_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
1103 inline reduce_scatter_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
1104
1106 void call() const;
1107 inline void operator()() const { return call(); }
1108};
1109
1110inline void reduce_scatter(const void* sendbuf_in, void* recvbuf_in, size_t recvcount_in, size_t item_size_in, reduce_op_t op_in) {
1111 return reduce_scatter_x(sendbuf_in, recvbuf_in, recvcount_in, item_size_in, op_in).call();
1112}
1113
1114
1134
1140 public:
1141 // args declaration
1142 const void* m_sendbuf;
1144 size_t m_count;
1154
1155 // constructor
1156 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) {}
1157
1158 // setter
1159 inline allreduce_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
1160 inline allreduce_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
1161 inline allreduce_x&& count(size_t count_in) { m_count = count_in; return std::move(*this); }
1162 inline allreduce_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
1163 inline allreduce_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
1164 inline allreduce_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1165 inline allreduce_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1166 inline allreduce_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1167 inline allreduce_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1168 inline allreduce_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1169 inline allreduce_x&& algorithm(allreduce_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
1170 inline allreduce_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
1171
1173 void call() const;
1174 inline void operator()() const { return call(); }
1175};
1176
1177inline void allreduce(const void* sendbuf_in, void* recvbuf_in, size_t count_in, size_t item_size_in, reduce_op_t op_in) {
1178 return allreduce_x(sendbuf_in, recvbuf_in, count_in, item_size_in, op_in).call();
1179}
1180
1181
1196
1202 public:
1203 // args declaration
1204 const void* m_sendbuf;
1206 size_t m_size;
1211
1212 // constructor
1213 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) {}
1214
1215 // setter
1216 inline allgather_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
1217 inline allgather_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
1218 inline allgather_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1219 inline allgather_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1220 inline allgather_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1221 inline allgather_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1222 inline allgather_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1223
1225 void call() const;
1226 inline void operator()() const { return call(); }
1227};
1228
1229inline void allgather(const void* sendbuf_in, void* recvbuf_in, size_t size_in) {
1230 return allgather_x(sendbuf_in, recvbuf_in, size_in).call();
1231}
1232
1233
1250
1256 public:
1257 // args declaration
1258 const void* m_sendbuf;
1260 size_t m_size;
1267
1268 // constructor
1269 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) {}
1270
1271 // setter
1272 inline alltoall_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
1273 inline alltoall_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
1274 inline alltoall_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1275 inline alltoall_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1276 inline alltoall_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1277 inline alltoall_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1278 inline alltoall_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1279 inline alltoall_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1280 inline alltoall_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1281
1283 void call() const;
1284 inline void operator()() const { return call(); }
1285};
1286
1287inline void alltoall(const void* sendbuf_in, void* recvbuf_in, size_t size_in) {
1288 return alltoall_x(sendbuf_in, recvbuf_in, size_in).call();
1289}
1290
1291
1320
1326 public:
1327 // args declaration
1331 size_t m_size;
1349
1350 // constructor
1351 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) {}
1352
1353 // setter
1354 inline post_comm_x&& direction(direction_t direction_in) { m_direction = direction_in; return std::move(*this); }
1355 inline post_comm_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1356 inline post_comm_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
1357 inline post_comm_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1358 inline post_comm_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
1359 inline post_comm_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1360 inline post_comm_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1361 inline post_comm_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1362 inline post_comm_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1363 inline post_comm_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1364 inline post_comm_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1365 inline post_comm_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1366 inline post_comm_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
1367 inline post_comm_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1368 inline post_comm_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
1369 inline post_comm_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
1370 inline post_comm_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1371 inline post_comm_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
1372 inline post_comm_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
1373 inline post_comm_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
1374 inline post_comm_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
1375
1377 status_t call() const;
1378 inline status_t operator()() const { return call(); }
1379};
1380
1381inline status_t post_comm(direction_t direction_in, int rank_in, void* local_buffer_in, size_t size_in, comp_t local_comp_in) {
1382 return post_comm_x(direction_in, rank_in, local_buffer_in, size_in, local_comp_in).call();
1383}
1384
1385
1409
1415 public:
1416 // args declaration
1419 size_t m_size;
1433
1434 // constructor
1435 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) {}
1436
1437 // setter
1438 inline post_am_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1439 inline post_am_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
1440 inline post_am_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1441 inline post_am_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
1442 inline post_am_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
1443 inline post_am_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1444 inline post_am_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1445 inline post_am_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1446 inline post_am_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1447 inline post_am_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1448 inline post_am_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1449 inline post_am_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
1450 inline post_am_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1451 inline post_am_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
1452 inline post_am_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
1453 inline post_am_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
1454
1456 status_t call() const;
1457 inline status_t operator()() const { return call(); }
1458};
1459
1460inline 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) {
1461 return post_am_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_comp_in).call();
1462}
1463
1464
1489
1495 public:
1496 // args declaration
1499 size_t m_size;
1514
1515 // constructor
1516 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) {}
1517
1518 // setter
1519 inline post_send_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1520 inline post_send_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
1521 inline post_send_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1522 inline post_send_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
1523 inline post_send_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
1524 inline post_send_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1525 inline post_send_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1526 inline post_send_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1527 inline post_send_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1528 inline post_send_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1529 inline post_send_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1530 inline post_send_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1531 inline post_send_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1532 inline post_send_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
1533 inline post_send_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
1534 inline post_send_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
1535 inline post_send_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
1536
1538 status_t call() const;
1539 inline status_t operator()() const { return call(); }
1540};
1541
1542inline status_t post_send(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) {
1543 return post_send_x(rank_in, local_buffer_in, size_in, tag_in, local_comp_in).call();
1544}
1545
1546
1571
1577 public:
1578 // args declaration
1581 size_t m_size;
1596
1597 // constructor
1598 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) {}
1599
1600 // setter
1601 inline post_recv_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1602 inline post_recv_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
1603 inline post_recv_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1604 inline post_recv_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
1605 inline post_recv_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
1606 inline post_recv_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1607 inline post_recv_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1608 inline post_recv_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1609 inline post_recv_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1610 inline post_recv_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1611 inline post_recv_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1612 inline post_recv_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1613 inline post_recv_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1614 inline post_recv_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
1615 inline post_recv_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
1616 inline post_recv_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
1617 inline post_recv_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
1618
1620 status_t call() const;
1621 inline status_t operator()() const { return call(); }
1622};
1623
1624inline status_t post_recv(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) {
1625 return post_recv_x(rank_in, local_buffer_in, size_in, tag_in, local_comp_in).call();
1626}
1627
1628
1654
1660 public:
1661 // args declaration
1664 size_t m_size;
1666 uintptr_t m_remote_disp;
1680
1681 // constructor
1682 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) {}
1683
1684 // setter
1685 inline post_put_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1686 inline post_put_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
1687 inline post_put_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1688 inline post_put_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
1689 inline post_put_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
1690 inline post_put_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1691 inline post_put_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1692 inline post_put_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1693 inline post_put_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1694 inline post_put_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1695 inline post_put_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1696 inline post_put_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1697 inline post_put_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
1698 inline post_put_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
1699 inline post_put_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1700 inline post_put_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
1701 inline post_put_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
1702 inline post_put_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
1703
1705 status_t call() const;
1706 inline status_t operator()() const { return call(); }
1707};
1708
1709inline 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) {
1710 return post_put_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_disp_in, rmr_in).call();
1711}
1712
1713
1739
1745 public:
1746 // args declaration
1749 size_t m_size;
1751 uintptr_t m_remote_disp;
1765
1766 // constructor
1767 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) {}
1768
1769 // setter
1770 inline post_get_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
1771 inline post_get_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
1772 inline post_get_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
1773 inline post_get_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
1774 inline post_get_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
1775 inline post_get_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
1776 inline post_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1777 inline post_get_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1778 inline post_get_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1779 inline post_get_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1780 inline post_get_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
1781 inline post_get_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
1782 inline post_get_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
1783 inline post_get_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
1784 inline post_get_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1785 inline post_get_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
1786 inline post_get_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
1787 inline post_get_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
1788
1790 status_t call() const;
1791 inline status_t operator()() const { return call(); }
1792};
1793
1794inline 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) {
1795 return post_get_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_disp_in, rmr_in).call();
1796}
1797
1798
1809
1815 public:
1816 // args declaration
1820
1821 // constructor
1823
1824 // setter
1825 inline progress_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1826 inline progress_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1827 inline progress_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
1828
1830 error_t call() const;
1831 inline error_t operator()() const { return call(); }
1832};
1833
1835 return progress_x().call();
1836}
1837
1838
1848
1854 public:
1855 // args declaration
1858
1859 // constructor
1861
1862 // setter
1863 inline test_drained_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1864 inline test_drained_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1865
1867 error_t call() const;
1868 inline error_t operator()() const { return call(); }
1869};
1870
1872 return test_drained_x().call();
1873}
1874
1875
1885
1891 public:
1892 // args declaration
1895
1896 // constructor
1898
1899 // setter
1900 inline wait_drained_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1901 inline wait_drained_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1902
1904 void call() const;
1905 inline void operator()() const { return call(); }
1906};
1907
1908inline void wait_drained() {
1909 return wait_drained_x().call();
1910}
1911
1912
1933
1939 public:
1940 // args declaration
1954
1955 // constructor
1957
1958 // setter
1959 inline alloc_net_context_x&& backend(attr_backend_t backend_in) { m_backend = backend_in; return std::move(*this); }
1960 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); }
1961 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); }
1962 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); }
1963 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); }
1964 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); }
1965 inline alloc_net_context_x&& device_name(std::string device_name_in) { m_device_name = device_name_in; return std::move(*this); }
1966 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); }
1967 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); }
1968 inline alloc_net_context_x&& use_dmabuf(bool use_dmabuf_in) { m_use_dmabuf = use_dmabuf_in; return std::move(*this); }
1969 inline alloc_net_context_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
1970 inline alloc_net_context_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1971 inline alloc_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1972
1974 net_context_t call() const;
1975 inline net_context_t operator()() const { return call(); }
1976};
1977
1981
1982
1992
1998 public:
1999 // args declaration
2002
2003 // constructor
2004 free_net_context_x(net_context_t* net_context_in) : m_net_context(net_context_in) {}
2005
2006 // setter
2007 inline free_net_context_x&& net_context(net_context_t* net_context_in) { m_net_context = net_context_in; return std::move(*this); }
2008 inline free_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2009
2011 void call() const;
2012 inline void operator()() const { return call(); }
2013};
2014
2015inline void free_net_context(net_context_t* net_context_in) {
2016 return free_net_context_x(net_context_in).call();
2017}
2018
2019
2047
2053 public:
2054 // args declaration
2075
2076 // constructor
2078
2079 // setter
2080 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); }
2081 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); }
2082 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); }
2083 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); }
2084 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); }
2085 inline alloc_device_x&& alloc_default_endpoint(bool alloc_default_endpoint_in) { m_alloc_default_endpoint = alloc_default_endpoint_in; return std::move(*this); }
2086 inline alloc_device_x&& alloc_progress_endpoint(bool alloc_progress_endpoint_in) { m_alloc_progress_endpoint = alloc_progress_endpoint_in; return std::move(*this); }
2087 inline alloc_device_x&& use_reg_cache(bool use_reg_cache_in) { m_use_reg_cache = use_reg_cache_in; return std::move(*this); }
2088 inline alloc_device_x&& shm_enable(bool shm_enable_in) { m_shm_enable = shm_enable_in; return std::move(*this); }
2089 inline alloc_device_x&& shm_ring_size(size_t shm_ring_size_in) { m_shm_ring_size = shm_ring_size_in; return std::move(*this); }
2090 inline alloc_device_x&& shm_slot_size(size_t shm_slot_size_in) { m_shm_slot_size = shm_slot_size_in; return std::move(*this); }
2091 inline alloc_device_x&& shm_producer_cas_attempts(size_t shm_producer_cas_attempts_in) { m_shm_producer_cas_attempts = shm_producer_cas_attempts_in; return std::move(*this); }
2092 inline alloc_device_x&& shm_consumer_cas_attempts(size_t shm_consumer_cas_attempts_in) { m_shm_consumer_cas_attempts = shm_consumer_cas_attempts_in; return std::move(*this); }
2093 inline alloc_device_x&& shm_max_polls(size_t shm_max_polls_in) { m_shm_max_polls = shm_max_polls_in; return std::move(*this); }
2094 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); }
2095 inline alloc_device_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2096 inline alloc_device_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2097 inline alloc_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2098 inline alloc_device_x&& net_context(net_context_t net_context_in) { m_net_context = net_context_in; return std::move(*this); }
2099 inline alloc_device_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
2100
2102 device_t call() const;
2103 inline device_t operator()() const { return call(); }
2104};
2105
2107 return alloc_device_x().call();
2108}
2109
2110
2120
2126 public:
2127 // args declaration
2130
2131 // constructor
2132 free_device_x(device_t* device_in) : m_device(device_in) {}
2133
2134 // setter
2135 inline free_device_x&& device(device_t* device_in) { m_device = device_in; return std::move(*this); }
2136 inline free_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2137
2139 void call() const;
2140 inline void operator()() const { return call(); }
2141};
2142
2143inline void free_device(device_t* device_in) {
2144 return free_device_x(device_in).call();
2145}
2146
2147
2159
2165 public:
2166 // args declaration
2168 size_t m_size;
2171
2172 // constructor
2173 register_memory_x(void* address_in, size_t size_in) : m_address(address_in), m_size(size_in) {}
2174
2175 // setter
2176 inline register_memory_x&& address(void* address_in) { m_address = address_in; return std::move(*this); }
2177 inline register_memory_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2178 inline register_memory_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2179 inline register_memory_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2180
2182 mr_t call() const;
2183 inline mr_t operator()() const { return call(); }
2184};
2185
2186inline mr_t register_memory(void* address_in, size_t size_in) {
2187 return register_memory_x(address_in, size_in).call();
2188}
2189
2190
2200
2206 public:
2207 // args declaration
2210
2211 // constructor
2212 deregister_memory_x(mr_t* mr_in) : m_mr(mr_in) {}
2213
2214 // setter
2215 inline deregister_memory_x&& mr(mr_t* mr_in) { m_mr = mr_in; return std::move(*this); }
2216 inline deregister_memory_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2217
2219 void call() const;
2220 inline void operator()() const { return call(); }
2221};
2222
2223inline void deregister_memory(mr_t* mr_in) {
2224 return deregister_memory_x(mr_in).call();
2225}
2226
2227
2237
2243 public:
2244 // args declaration
2247
2248 // constructor
2249 get_rmr_x(mr_t mr_in) : m_mr(mr_in) {}
2250
2251 // setter
2252 inline get_rmr_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
2253 inline get_rmr_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2254
2256 rmr_t call() const;
2257 inline rmr_t operator()() const { return call(); }
2258};
2259
2260inline rmr_t get_rmr(mr_t mr_in) {
2261 return get_rmr_x(mr_in).call();
2262}
2263
2264
2276
2282 public:
2283 // args declaration
2288
2289 // constructor
2291
2292 // setter
2293 inline alloc_endpoint_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
2294 inline alloc_endpoint_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2295 inline alloc_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2296 inline alloc_endpoint_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2297
2299 endpoint_t call() const;
2300 inline endpoint_t operator()() const { return call(); }
2301};
2302
2304 return alloc_endpoint_x().call();
2305}
2306
2307
2317
2323 public:
2324 // args declaration
2327
2328 // constructor
2329 free_endpoint_x(endpoint_t* endpoint_in) : m_endpoint(endpoint_in) {}
2330
2331 // setter
2332 inline free_endpoint_x&& endpoint(endpoint_t* endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2333 inline free_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2334
2336 void call() const;
2337 inline void operator()() const { return call(); }
2338};
2339
2340inline void free_endpoint(endpoint_t* endpoint_in) {
2341 return free_endpoint_x(endpoint_in).call();
2342}
2343
2344
2356
2362 public:
2363 // args declaration
2368
2369 // constructor
2370 net_poll_cq_x(size_t max_polls_in, net_status_t* statuses_in) : m_max_polls(max_polls_in), m_statuses(statuses_in) {}
2371
2372 // setter
2373 inline net_poll_cq_x&& max_polls(size_t max_polls_in) { m_max_polls = max_polls_in; return std::move(*this); }
2374 inline net_poll_cq_x&& statuses(net_status_t* statuses_in) { m_statuses = statuses_in; return std::move(*this); }
2375 inline net_poll_cq_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2376 inline net_poll_cq_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2377
2379 size_t call() const;
2380 inline size_t operator()() const { return call(); }
2381};
2382
2383inline size_t net_poll_cq(size_t max_polls_in, net_status_t* statuses_in) {
2384 return net_poll_cq_x(max_polls_in, statuses_in).call();
2385}
2386
2387
2401
2407 public:
2408 // args declaration
2410 size_t m_size;
2415
2416 // constructor
2417 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) {}
2418
2419 // setter
2420 inline net_post_recv_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
2421 inline net_post_recv_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2422 inline net_post_recv_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
2423 inline net_post_recv_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2424 inline net_post_recv_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2425 inline net_post_recv_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2426
2428 error_t call() const;
2429 inline error_t operator()() const { return call(); }
2430};
2431
2432inline error_t net_post_recv(void* buffer_in, size_t size_in, mr_t mr_in) {
2433 return net_post_recv_x(buffer_in, size_in, mr_in).call();
2434}
2435
2436
2452
2458 public:
2459 // args declaration
2462 size_t m_size;
2468
2469 // constructor
2470 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) {}
2471
2472 // setter
2473 inline net_post_sends_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2474 inline net_post_sends_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
2475 inline net_post_sends_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2476 inline net_post_sends_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2477 inline net_post_sends_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2478 inline net_post_sends_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2479 inline net_post_sends_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
2480 inline net_post_sends_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2481
2483 error_t call() const;
2484 inline error_t operator()() const { return call(); }
2485};
2486
2487inline error_t net_post_sends(int rank_in, void* buffer_in, size_t size_in) {
2488 return net_post_sends_x(rank_in, buffer_in, size_in).call();
2489}
2490
2491
2508
2514 public:
2515 // args declaration
2518 size_t m_size;
2525
2526 // constructor
2527 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) {}
2528
2529 // setter
2530 inline net_post_send_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2531 inline net_post_send_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
2532 inline net_post_send_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2533 inline net_post_send_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
2534 inline net_post_send_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2535 inline net_post_send_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2536 inline net_post_send_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2537 inline net_post_send_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
2538 inline net_post_send_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2539
2541 error_t call() const;
2542 inline error_t operator()() const { return call(); }
2543};
2544
2545inline error_t net_post_send(int rank_in, void* buffer_in, size_t size_in, mr_t mr_in) {
2546 return net_post_send_x(rank_in, buffer_in, size_in, mr_in).call();
2547}
2548
2549
2566
2572 public:
2573 // args declaration
2576 size_t m_size;
2577 uint64_t m_offset;
2583
2584 // constructor
2585 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) {}
2586
2587 // setter
2588 inline net_post_puts_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2589 inline net_post_puts_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
2590 inline net_post_puts_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2591 inline net_post_puts_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
2592 inline net_post_puts_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
2593 inline net_post_puts_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2594 inline net_post_puts_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2595 inline net_post_puts_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2596 inline net_post_puts_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2597
2599 error_t call() const;
2600 inline error_t operator()() const { return call(); }
2601};
2602
2603inline error_t net_post_puts(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) {
2604 return net_post_puts_x(rank_in, buffer_in, size_in, offset_in, rmr_in).call();
2605}
2606
2607
2625
2631 public:
2632 // args declaration
2635 size_t m_size;
2637 uint64_t m_offset;
2643
2644 // constructor
2645 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) {}
2646
2647 // setter
2648 inline net_post_put_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2649 inline net_post_put_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
2650 inline net_post_put_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2651 inline net_post_put_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
2652 inline net_post_put_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
2653 inline net_post_put_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
2654 inline net_post_put_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2655 inline net_post_put_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2656 inline net_post_put_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2657 inline net_post_put_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2658
2660 error_t call() const;
2661 inline error_t operator()() const { return call(); }
2662};
2663
2664inline 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) {
2665 return net_post_put_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
2666}
2667
2668
2686
2692 public:
2693 // args declaration
2696 size_t m_size;
2697 uint64_t m_offset;
2704
2705 // constructor
2706 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) {}
2707
2708 // setter
2709 inline net_post_putImms_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2710 inline net_post_putImms_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
2711 inline net_post_putImms_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2712 inline net_post_putImms_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
2713 inline net_post_putImms_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
2714 inline net_post_putImms_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2715 inline net_post_putImms_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2716 inline net_post_putImms_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2717 inline net_post_putImms_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
2718 inline net_post_putImms_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2719
2721 error_t call() const;
2722 inline error_t operator()() const { return call(); }
2723};
2724
2725inline error_t net_post_putImms(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) {
2726 return net_post_putImms_x(rank_in, buffer_in, size_in, offset_in, rmr_in).call();
2727}
2728
2729
2748
2754 public:
2755 // args declaration
2758 size_t m_size;
2760 uint64_t m_offset;
2767
2768 // constructor
2769 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) {}
2770
2771 // setter
2772 inline net_post_putImm_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2773 inline net_post_putImm_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
2774 inline net_post_putImm_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2775 inline net_post_putImm_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
2776 inline net_post_putImm_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
2777 inline net_post_putImm_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
2778 inline net_post_putImm_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2779 inline net_post_putImm_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2780 inline net_post_putImm_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2781 inline net_post_putImm_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
2782 inline net_post_putImm_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2783
2785 error_t call() const;
2786 inline error_t operator()() const { return call(); }
2787};
2788
2789inline 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) {
2790 return net_post_putImm_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
2791}
2792
2793
2811
2817 public:
2818 // args declaration
2821 size_t m_size;
2823 uint64_t m_offset;
2829
2830 // constructor
2831 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) {}
2832
2833 // setter
2834 inline net_post_get_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
2835 inline net_post_get_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
2836 inline net_post_get_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2837 inline net_post_get_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
2838 inline net_post_get_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
2839 inline net_post_get_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
2840 inline net_post_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2841 inline net_post_get_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2842 inline net_post_get_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2843 inline net_post_get_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2844
2846 error_t call() const;
2847 inline error_t operator()() const { return call(); }
2848};
2849
2850inline 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) {
2851 return net_post_get_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
2852}
2853
2854
2864
2870 public:
2871 // args declaration
2874
2875 // constructor
2876 free_comp_x(comp_t* comp_in) : m_comp(comp_in) {}
2877
2878 // setter
2879 inline free_comp_x&& comp(comp_t* comp_in) { m_comp = comp_in; return std::move(*this); }
2880 inline free_comp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2881
2883 void call() const;
2884 inline void operator()() const { return call(); }
2885};
2886
2887inline void free_comp(comp_t* comp_in) {
2888 return free_comp_x(comp_in).call();
2889}
2890
2891
2902
2908 public:
2909 // args declaration
2913
2914 // constructor
2915 comp_signal_x(comp_t comp_in, status_t status_in) : m_comp(comp_in), m_status(status_in) {}
2916
2917 // setter
2918 inline comp_signal_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2919 inline comp_signal_x&& status(status_t status_in) { m_status = status_in; return std::move(*this); }
2920 inline comp_signal_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2921
2923 void call() const;
2924 inline void operator()() const { return call(); }
2925};
2926
2927inline void comp_signal(comp_t comp_in, status_t status_in) {
2928 return comp_signal_x(comp_in, status_in).call();
2929}
2930
2931
2941
2947 public:
2948 // args declaration
2951
2952 // constructor
2954
2955 // setter
2956 inline reserve_rcomps_x&& n(rcomp_t n_in) { m_n = n_in; return std::move(*this); }
2957 inline reserve_rcomps_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2958
2960 rcomp_t call() const;
2961 inline rcomp_t operator()() const { return call(); }
2962};
2963
2965 return reserve_rcomps_x(n_in).call();
2966}
2967
2968
2979
2985 public:
2986 // args declaration
2990
2991 // constructor
2992 register_rcomp_x(comp_t comp_in) : m_comp(comp_in) {}
2993
2994 // setter
2995 inline register_rcomp_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2996 inline register_rcomp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2997 inline register_rcomp_x&& rcomp(rcomp_t rcomp_in) { m_rcomp = rcomp_in; return std::move(*this); }
2998
3000 rcomp_t call() const;
3001 inline rcomp_t operator()() const { return call(); }
3002};
3003
3005 return register_rcomp_x(comp_in).call();
3006}
3007
3008
3018
3024 public:
3025 // args declaration
3028
3029 // constructor
3030 deregister_rcomp_x(rcomp_t rcomp_in) : m_rcomp(rcomp_in) {}
3031
3032 // setter
3033 inline deregister_rcomp_x&& rcomp(rcomp_t rcomp_in) { m_rcomp = rcomp_in; return std::move(*this); }
3034 inline deregister_rcomp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3035
3037 void call() const;
3038 inline void operator()() const { return call(); }
3039};
3040
3041inline void deregister_rcomp(rcomp_t rcomp_in) {
3042 return deregister_rcomp_x(rcomp_in).call();
3043}
3044
3045
3058
3064 public:
3065 // args declaration
3071
3072 // constructor
3074
3075 // setter
3076 inline alloc_sync_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3077 inline alloc_sync_x&& threshold(int threshold_in) { m_threshold = threshold_in; return std::move(*this); }
3078 inline alloc_sync_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
3079 inline alloc_sync_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3080 inline alloc_sync_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3081
3083 comp_t call() const;
3084 inline comp_t operator()() const { return call(); }
3085};
3086
3088 return alloc_sync_x().call();
3089}
3090
3091
3102
3108 public:
3109 // args declaration
3113
3114 // constructor
3115 sync_test_x(comp_t comp_in, status_t* p_out_in) : m_comp(comp_in), m_p_out(p_out_in) {}
3116
3117 // setter
3118 inline sync_test_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3119 inline sync_test_x&& p_out(status_t* p_out_in) { m_p_out = p_out_in; return std::move(*this); }
3120 inline sync_test_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3121
3123 bool call() const;
3124 inline bool operator()() const { return call(); }
3125};
3126
3127inline bool sync_test(comp_t comp_in, status_t* p_out_in) {
3128 return sync_test_x(comp_in, p_out_in).call();
3129}
3130
3131
3144
3150 public:
3151 // args declaration
3157
3158 // constructor
3159 sync_wait_x(comp_t comp_in, status_t* p_out_in) : m_comp(comp_in), m_p_out(p_out_in) {}
3160
3161 // setter
3162 inline sync_wait_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3163 inline sync_wait_x&& p_out(status_t* p_out_in) { m_p_out = p_out_in; return std::move(*this); }
3164 inline sync_wait_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3165 inline sync_wait_x&& do_progress(bool do_progress_in) { m_do_progress = do_progress_in; return std::move(*this); }
3166 inline sync_wait_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3167
3169 void call() const;
3170 inline void operator()() const { return call(); }
3171};
3172
3173inline void sync_wait(comp_t comp_in, status_t* p_out_in) {
3174 return sync_wait_x(comp_in, p_out_in).call();
3175}
3176
3177
3188
3194 public:
3195 // args declaration
3199
3200 // constructor
3202
3203 // setter
3204 inline alloc_counter_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3205 inline alloc_counter_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3206 inline alloc_counter_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3207
3209 comp_t call() const;
3210 inline comp_t operator()() const { return call(); }
3211};
3212
3214 return alloc_counter_x().call();
3215}
3216
3217
3227
3233 public:
3234 // args declaration
3237
3238 // constructor
3239 counter_get_x(comp_t comp_in) : m_comp(comp_in) {}
3240
3241 // setter
3242 inline counter_get_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3243 inline counter_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3244
3246 int64_t call() const;
3247 inline int64_t operator()() const { return call(); }
3248};
3249
3250inline int64_t counter_get(comp_t comp_in) {
3251 return counter_get_x(comp_in).call();
3252}
3253
3254
3265
3271 public:
3272 // args declaration
3274 int64_t m_value;
3276
3277 // constructor
3278 counter_set_x(comp_t comp_in, int64_t value_in) : m_comp(comp_in), m_value(value_in) {}
3279
3280 // setter
3281 inline counter_set_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3282 inline counter_set_x&& value(int64_t value_in) { m_value = value_in; return std::move(*this); }
3283 inline counter_set_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3284
3286 void call() const;
3287 inline void operator()() const { return call(); }
3288};
3289
3290inline void counter_set(comp_t comp_in, int64_t value_in) {
3291 return counter_set_x(comp_in, value_in).call();
3292}
3293
3294
3308
3314 public:
3315 // args declaration
3322
3323 // constructor
3325
3326 // setter
3327 inline alloc_cq_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3328 inline alloc_cq_x&& default_length(int default_length_in) { m_default_length = default_length_in; return std::move(*this); }
3329 inline alloc_cq_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
3330 inline alloc_cq_x&& cq_type(attr_cq_type_t cq_type_in) { m_cq_type = cq_type_in; return std::move(*this); }
3331 inline alloc_cq_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3332 inline alloc_cq_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3333
3335 comp_t call() const;
3336 inline comp_t operator()() const { return call(); }
3337};
3338
3340 return alloc_cq_x().call();
3341}
3342
3343
3353
3359 public:
3360 // args declaration
3363
3364 // constructor
3365 cq_pop_x(comp_t comp_in) : m_comp(comp_in) {}
3366
3367 // setter
3368 inline cq_pop_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3369 inline cq_pop_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3370
3372 status_t call() const;
3373 inline status_t operator()() const { return call(); }
3374};
3375
3376inline status_t cq_pop(comp_t comp_in) {
3377 return cq_pop_x(comp_in).call();
3378}
3379
3380
3393
3399 public:
3400 // args declaration
3406
3407 // constructor
3408 alloc_handler_x(comp_handler_t handler_in) : m_handler(handler_in) {}
3409
3410 // setter
3411 inline alloc_handler_x&& handler(comp_handler_t handler_in) { m_handler = handler_in; return std::move(*this); }
3412 inline alloc_handler_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3413 inline alloc_handler_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
3414 inline alloc_handler_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3415 inline alloc_handler_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3416
3418 comp_t call() const;
3419 inline comp_t operator()() const { return call(); }
3420};
3421
3423 return alloc_handler_x(handler_in).call();
3424}
3425
3426
3438
3444 public:
3445 // args declaration
3450
3451 // constructor
3453
3454 // setter
3455 inline alloc_graph_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3456 inline alloc_graph_x&& name(const char* name_in) { m_name = name_in; return std::move(*this); }
3457 inline alloc_graph_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3458 inline alloc_graph_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3459
3461 comp_t call() const;
3462 inline comp_t operator()() const { return call(); }
3463};
3464
3466 return alloc_graph_x().call();
3467}
3468
3469
3482
3488 public:
3489 // args declaration
3495
3496 // constructor
3497 graph_add_node_x(comp_t comp_in, graph_node_run_cb_t fn_in) : m_comp(comp_in), m_fn(fn_in) {}
3498
3499 // setter
3500 inline graph_add_node_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3501 inline graph_add_node_x&& fn(graph_node_run_cb_t fn_in) { m_fn = fn_in; return std::move(*this); }
3502 inline graph_add_node_x&& value(void* value_in) { m_value = value_in; return std::move(*this); }
3503 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); }
3504 inline graph_add_node_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3505
3507 graph_node_t call() const;
3508 inline graph_node_t operator()() const { return call(); }
3509};
3510
3512 return graph_add_node_x(comp_in, fn_in).call();
3513}
3514
3515
3528
3534 public:
3535 // args declaration
3541
3542 // constructor
3543 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) {}
3544
3545 // setter
3546 inline graph_add_edge_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3547 inline graph_add_edge_x&& src(graph_node_t src_in) { m_src = src_in; return std::move(*this); }
3548 inline graph_add_edge_x&& dst(graph_node_t dst_in) { m_dst = dst_in; return std::move(*this); }
3549 inline graph_add_edge_x&& fn(graph_edge_run_cb_t fn_in) { m_fn = fn_in; return std::move(*this); }
3550 inline graph_add_edge_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3551
3553 void call() const;
3554 inline void operator()() const { return call(); }
3555};
3556
3557inline void graph_add_edge(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in) {
3558 return graph_add_edge_x(comp_in, src_in, dst_in).call();
3559}
3560
3561
3572
3578 public:
3579 // args declaration
3583
3584 // constructor
3586
3587 // setter
3588 inline graph_node_mark_complete_x&& node(graph_node_t node_in) { m_node = node_in; return std::move(*this); }
3589 inline graph_node_mark_complete_x&& status(status_t status_in) { m_status = status_in; return std::move(*this); }
3590 inline graph_node_mark_complete_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3591
3593 void call() const;
3594 inline void operator()() const { return call(); }
3595};
3596
3598 return graph_node_mark_complete_x(node_in).call();
3599}
3600
3601
3611
3617 public:
3618 // args declaration
3621
3622 // constructor
3623 graph_start_x(comp_t comp_in) : m_comp(comp_in) {}
3624
3625 // setter
3626 inline graph_start_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3627 inline graph_start_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3628
3630 void call() const;
3631 inline void operator()() const { return call(); }
3632};
3633
3634inline void graph_start(comp_t comp_in) {
3635 return graph_start_x(comp_in).call();
3636}
3637
3638
3648
3654 public:
3655 // args declaration
3658
3659 // constructor
3660 graph_test_x(comp_t comp_in) : m_comp(comp_in) {}
3661
3662 // setter
3663 inline graph_test_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
3664 inline graph_test_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3665
3667 status_t call() const;
3668 inline status_t operator()() const { return call(); }
3669};
3670
3671inline status_t graph_test(comp_t comp_in) {
3672 return graph_test_x(comp_in).call();
3673}
3674
3675
3676} // namespace lci
3677
3678#endif // LCI_BINDING_POST_HPP_
The actual implementation for allgather.
Definition lci_binding_post.hpp:1201
allgather_x && size(size_t size_in)
Definition lci_binding_post.hpp:1218
allgather_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:1217
void * m_recvbuf
Definition lci_binding_post.hpp:1205
size_t m_size
Definition lci_binding_post.hpp:1206
void call() const
Definition binding.cpp:440
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1207
const void * m_sendbuf
Definition lci_binding_post.hpp:1204
allgather_x && device(device_t device_in)
Definition lci_binding_post.hpp:1220
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1210
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1209
allgather_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1219
allgather_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1221
allgather_x(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:1213
allgather_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1222
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:1208
void operator()() const
Definition lci_binding_post.hpp:1226
allgather_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:1216
The actual implementation for alloc_counter.
Definition lci_binding_post.hpp:3193
alloc_counter_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3204
alloc_counter_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3206
option_t< const char * > m_name
Definition lci_binding_post.hpp:3197
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3196
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3198
comp_t operator()() const
Definition lci_binding_post.hpp:3210
comp_t call_impl(runtime_t runtime, const char *name, void *user_context) const
comp_t call() const
Definition binding.cpp:924
alloc_counter_x && name(const char *name_in)
Definition lci_binding_post.hpp:3205
alloc_counter_x()
Definition lci_binding_post.hpp:3201
The actual implementation for alloc_cq.
Definition lci_binding_post.hpp:3313
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3316
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:3318
alloc_cq_x && cq_type(attr_cq_type_t cq_type_in)
Definition lci_binding_post.hpp:3330
alloc_cq_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:3329
comp_t operator()() const
Definition lci_binding_post.hpp:3336
option_t< int > m_default_length
Definition lci_binding_post.hpp:3317
option_t< attr_cq_type_t > m_cq_type
Definition lci_binding_post.hpp:3319
alloc_cq_x && default_length(int default_length_in)
Definition lci_binding_post.hpp:3328
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:3331
alloc_cq_x()
Definition lci_binding_post.hpp:3324
comp_t call() const
Definition binding.cpp:944
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3321
alloc_cq_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3332
option_t< const char * > m_name
Definition lci_binding_post.hpp:3320
alloc_cq_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3327
The actual implementation for alloc_device.
Definition lci_binding_post.hpp:2052
alloc_device_x && alloc_default_endpoint(bool alloc_default_endpoint_in)
Definition lci_binding_post.hpp:2085
alloc_device_x && shm_ring_size(size_t shm_ring_size_in)
Definition lci_binding_post.hpp:2089
option_t< size_t > m_shm_slot_size
Definition lci_binding_post.hpp:2065
device_t call_impl(size_t net_max_sends, size_t net_max_recvs, size_t net_max_cqes, double net_send_reserved_pct, uint64_t ofi_lock_mode, bool alloc_default_endpoint, bool alloc_progress_endpoint, bool use_reg_cache, bool shm_enable, size_t shm_ring_size, size_t shm_slot_size, size_t shm_producer_cas_attempts, size_t shm_consumer_cas_attempts, size_t shm_max_polls, attr_ibv_td_strategy_t ibv_td_strategy, const char *name, void *user_context, runtime_t runtime, net_context_t net_context, packet_pool_t packet_pool) const
alloc_device_x()
Definition lci_binding_post.hpp:2077
option_t< bool > m_use_reg_cache
Definition lci_binding_post.hpp:2062
option_t< const char * > m_name
Definition lci_binding_post.hpp:2070
option_t< bool > m_alloc_progress_endpoint
Definition lci_binding_post.hpp:2061
option_t< net_context_t > m_net_context
Definition lci_binding_post.hpp:2073
alloc_device_x && net_max_recvs(size_t net_max_recvs_in)
Definition lci_binding_post.hpp:2081
option_t< size_t > m_shm_ring_size
Definition lci_binding_post.hpp:2064
option_t< attr_ibv_td_strategy_t > m_ibv_td_strategy
Definition lci_binding_post.hpp:2069
alloc_device_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2096
option_t< size_t > m_net_max_recvs
Definition lci_binding_post.hpp:2056
alloc_device_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:2099
alloc_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2097
alloc_device_x && use_reg_cache(bool use_reg_cache_in)
Definition lci_binding_post.hpp:2087
alloc_device_x && name(const char *name_in)
Definition lci_binding_post.hpp:2095
option_t< double > m_net_send_reserved_pct
Definition lci_binding_post.hpp:2058
alloc_device_x && ofi_lock_mode(uint64_t ofi_lock_mode_in)
Definition lci_binding_post.hpp:2084
option_t< uint64_t > m_ofi_lock_mode
Definition lci_binding_post.hpp:2059
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2071
option_t< size_t > m_net_max_sends
Definition lci_binding_post.hpp:2055
option_t< bool > m_shm_enable
Definition lci_binding_post.hpp:2063
alloc_device_x && net_send_reserved_pct(double net_send_reserved_pct_in)
Definition lci_binding_post.hpp:2083
option_t< size_t > m_shm_producer_cas_attempts
Definition lci_binding_post.hpp:2066
alloc_device_x && shm_slot_size(size_t shm_slot_size_in)
Definition lci_binding_post.hpp:2090
alloc_device_x && shm_consumer_cas_attempts(size_t shm_consumer_cas_attempts_in)
Definition lci_binding_post.hpp:2092
alloc_device_x && shm_producer_cas_attempts(size_t shm_producer_cas_attempts_in)
Definition lci_binding_post.hpp:2091
alloc_device_x && alloc_progress_endpoint(bool alloc_progress_endpoint_in)
Definition lci_binding_post.hpp:2086
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:2074
option_t< size_t > m_net_max_cqes
Definition lci_binding_post.hpp:2057
alloc_device_x && net_context(net_context_t net_context_in)
Definition lci_binding_post.hpp:2098
option_t< bool > m_alloc_default_endpoint
Definition lci_binding_post.hpp:2060
alloc_device_x && shm_max_polls(size_t shm_max_polls_in)
Definition lci_binding_post.hpp:2093
option_t< size_t > m_shm_consumer_cas_attempts
Definition lci_binding_post.hpp:2067
device_t operator()() const
Definition lci_binding_post.hpp:2103
device_t call() const
Definition binding.cpp:672
alloc_device_x && net_max_cqes(size_t net_max_cqes_in)
Definition lci_binding_post.hpp:2082
alloc_device_x && ibv_td_strategy(attr_ibv_td_strategy_t ibv_td_strategy_in)
Definition lci_binding_post.hpp:2094
option_t< size_t > m_shm_max_polls
Definition lci_binding_post.hpp:2068
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2072
alloc_device_x && shm_enable(bool shm_enable_in)
Definition lci_binding_post.hpp:2088
alloc_device_x && net_max_sends(size_t net_max_sends_in)
Definition lci_binding_post.hpp:2080
The actual implementation for alloc_endpoint.
Definition lci_binding_post.hpp:2281
endpoint_t call() const
Definition binding.cpp:731
alloc_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2295
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:2285
alloc_endpoint_x()
Definition lci_binding_post.hpp:2290
option_t< device_t > m_device
Definition lci_binding_post.hpp:2287
option_t< const char * > m_name
Definition lci_binding_post.hpp:2284
alloc_endpoint_x && device(device_t device_in)
Definition lci_binding_post.hpp:2296
endpoint_t operator()() const
Definition lci_binding_post.hpp:2300
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2286
alloc_endpoint_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2294
alloc_endpoint_x && name(const char *name_in)
Definition lci_binding_post.hpp:2293
The actual implementation for alloc_graph.
Definition lci_binding_post.hpp:3443
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3449
alloc_graph_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3458
comp_t call() const
Definition binding.cpp:969
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3448
alloc_graph_x && name(const char *name_in)
Definition lci_binding_post.hpp:3456
alloc_graph_x()
Definition lci_binding_post.hpp:3452
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:3457
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:3446
alloc_graph_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3455
comp_t operator()() const
Definition lci_binding_post.hpp:3462
option_t< const char * > m_name
Definition lci_binding_post.hpp:3447
The actual implementation for alloc_handler.
Definition lci_binding_post.hpp:3398
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:3402
option_t< const char * > m_name
Definition lci_binding_post.hpp:3404
alloc_handler_x && handler(comp_handler_t handler_in)
Definition lci_binding_post.hpp:3411
alloc_handler_x(comp_handler_t handler_in)
Definition lci_binding_post.hpp:3408
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3405
comp_t call() const
Definition binding.cpp:960
comp_t operator()() const
Definition lci_binding_post.hpp:3419
alloc_handler_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:3413
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:3403
alloc_handler_x && name(const char *name_in)
Definition lci_binding_post.hpp:3414
alloc_handler_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3415
alloc_handler_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3412
comp_handler_t m_handler
Definition lci_binding_post.hpp:3401
The actual implementation for alloc_matching_engine.
Definition lci_binding_post.hpp:486
matching_engine_t operator()() const
Definition lci_binding_post.hpp:505
matching_engine_t call() const
Definition binding.cpp:304
alloc_matching_engine_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:500
option_t< attr_matching_engine_type_t > m_matching_engine_type
Definition lci_binding_post.hpp:489
option_t< void * > m_user_context
Definition lci_binding_post.hpp:491
alloc_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:501
alloc_matching_engine_x && name(const char *name_in)
Definition lci_binding_post.hpp:499
option_t< const char * > m_name
Definition lci_binding_post.hpp:490
matching_engine_t call_impl(attr_matching_engine_type_t matching_engine_type, const char *name, void *user_context, runtime_t runtime) const
alloc_matching_engine_x && matching_engine_type(attr_matching_engine_type_t matching_engine_type_in)
Definition lci_binding_post.hpp:498
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:492
alloc_matching_engine_x()
Definition lci_binding_post.hpp:495
The actual implementation for alloc_net_context.
Definition lci_binding_post.hpp:1938
alloc_net_context_x && ofi_provider_name(std::string ofi_provider_name_in)
Definition lci_binding_post.hpp:1960
option_t< int > m_ibv_gid_idx
Definition lci_binding_post.hpp:1945
alloc_net_context_x && device_name(std::string device_name_in)
Definition lci_binding_post.hpp:1965
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1953
alloc_net_context_x && ibv_prefetch_strategy(attr_ibv_prefetch_strategy_t ibv_prefetch_strategy_in)
Definition lci_binding_post.hpp:1967
alloc_net_context_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1971
option_t< attr_ibv_odp_strategy_t > m_ibv_odp_strategy
Definition lci_binding_post.hpp:1948
alloc_net_context_x && ibv_gid_idx(int ibv_gid_idx_in)
Definition lci_binding_post.hpp:1963
alloc_net_context_x()
Definition lci_binding_post.hpp:1956
net_context_t call_impl(attr_backend_t backend, std::string ofi_provider_name, size_t max_msg_size, size_t max_inject_size, int ibv_gid_idx, bool ibv_force_gid_auto_select, std::string device_name, attr_ibv_odp_strategy_t ibv_odp_strategy, attr_ibv_prefetch_strategy_t ibv_prefetch_strategy, bool use_dmabuf, const char *name, void *user_context, runtime_t runtime) const
alloc_net_context_x && max_inject_size(size_t max_inject_size_in)
Definition lci_binding_post.hpp:1962
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1952
alloc_net_context_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1970
option_t< bool > m_use_dmabuf
Definition lci_binding_post.hpp:1950
alloc_net_context_x && backend(attr_backend_t backend_in)
Definition lci_binding_post.hpp:1959
option_t< std::string > m_device_name
Definition lci_binding_post.hpp:1947
option_t< const char * > m_name
Definition lci_binding_post.hpp:1951
alloc_net_context_x && ibv_force_gid_auto_select(bool ibv_force_gid_auto_select_in)
Definition lci_binding_post.hpp:1964
alloc_net_context_x && name(const char *name_in)
Definition lci_binding_post.hpp:1969
alloc_net_context_x && ibv_odp_strategy(attr_ibv_odp_strategy_t ibv_odp_strategy_in)
Definition lci_binding_post.hpp:1966
alloc_net_context_x && use_dmabuf(bool use_dmabuf_in)
Definition lci_binding_post.hpp:1968
option_t< attr_backend_t > m_backend
Definition lci_binding_post.hpp:1941
alloc_net_context_x && max_msg_size(size_t max_msg_size_in)
Definition lci_binding_post.hpp:1961
net_context_t call() const
Definition binding.cpp:629
option_t< std::string > m_ofi_provider_name
Definition lci_binding_post.hpp:1942
option_t< bool > m_ibv_force_gid_auto_select
Definition lci_binding_post.hpp:1946
option_t< size_t > m_max_inject_size
Definition lci_binding_post.hpp:1944
net_context_t operator()() const
Definition lci_binding_post.hpp:1975
option_t< size_t > m_max_msg_size
Definition lci_binding_post.hpp:1943
option_t< attr_ibv_prefetch_strategy_t > m_ibv_prefetch_strategy
Definition lci_binding_post.hpp:1949
The actual implementation for alloc_packet_pool.
Definition lci_binding_post.hpp:250
packet_pool_t call() const
Definition binding.cpp:258
alloc_packet_pool_x()
Definition lci_binding_post.hpp:260
packet_pool_t call_impl(size_t packet_size, size_t npackets, const char *name, void *user_context, runtime_t runtime) const
alloc_packet_pool_x && npackets(size_t npackets_in)
Definition lci_binding_post.hpp:264
alloc_packet_pool_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:266
alloc_packet_pool_x && packet_size(size_t packet_size_in)
Definition lci_binding_post.hpp:263
alloc_packet_pool_x && name(const char *name_in)
Definition lci_binding_post.hpp:265
option_t< size_t > m_packet_size
Definition lci_binding_post.hpp:253
alloc_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:267
option_t< const char * > m_name
Definition lci_binding_post.hpp:255
packet_pool_t operator()() const
Definition lci_binding_post.hpp:271
option_t< void * > m_user_context
Definition lci_binding_post.hpp:256
option_t< size_t > m_npackets
Definition lci_binding_post.hpp:254
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:257
The actual implementation for alloc_runtime.
Definition lci_binding_post.hpp:35
alloc_runtime_x && imm_nbits_tag(int imm_nbits_tag_in)
Definition lci_binding_post.hpp:54
alloc_runtime_x && imm_nbits_rcomp(int imm_nbits_rcomp_in)
Definition lci_binding_post.hpp:55
option_t< bool > m_alloc_default_packet_pool
Definition lci_binding_post.hpp:43
alloc_runtime_x && name(const char *name_in)
Definition lci_binding_post.hpp:60
runtime_t operator()() const
Definition lci_binding_post.hpp:66
option_t< bool > m_alloc_default_matching_engine
Definition lci_binding_post.hpp:44
runtime_t call() const
Definition binding.cpp:207
alloc_runtime_x && alloc_default_packet_pool(bool alloc_default_packet_pool_in)
Definition lci_binding_post.hpp:58
alloc_runtime_x && rdv_protocol(attr_rdv_protocol_t rdv_protocol_in)
Definition lci_binding_post.hpp:56
alloc_runtime_x()
Definition lci_binding_post.hpp:50
option_t< std::string > m_device_name
Definition lci_binding_post.hpp:47
alloc_runtime_x && alloc_default_matching_engine(bool alloc_default_matching_engine_in)
Definition lci_binding_post.hpp:59
alloc_runtime_x && alloc_default_device(bool alloc_default_device_in)
Definition lci_binding_post.hpp:57
alloc_runtime_x && packet_return_threshold(size_t packet_return_threshold_in)
Definition lci_binding_post.hpp:53
option_t< const char * > m_name
Definition lci_binding_post.hpp:45
alloc_runtime_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:61
alloc_runtime_x && device_name(std::string device_name_in)
Definition lci_binding_post.hpp:62
option_t< bool > m_alloc_default_device
Definition lci_binding_post.hpp:42
runtime_t call_impl(size_t packet_return_threshold, int imm_nbits_tag, int imm_nbits_rcomp, attr_rdv_protocol_t rdv_protocol, bool alloc_default_device, bool alloc_default_packet_pool, bool alloc_default_matching_engine, const char *name, void *user_context, std::string device_name) const
option_t< attr_rdv_protocol_t > m_rdv_protocol
Definition lci_binding_post.hpp:41
option_t< void * > m_user_context
Definition lci_binding_post.hpp:46
option_t< int > m_imm_nbits_rcomp
Definition lci_binding_post.hpp:40
option_t< size_t > m_packet_return_threshold
Definition lci_binding_post.hpp:38
option_t< int > m_imm_nbits_tag
Definition lci_binding_post.hpp:39
The actual implementation for alloc_sync.
Definition lci_binding_post.hpp:3063
comp_t operator()() const
Definition lci_binding_post.hpp:3084
option_t< int > m_threshold
Definition lci_binding_post.hpp:3067
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3070
alloc_sync_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3080
alloc_sync_x && threshold(int threshold_in)
Definition lci_binding_post.hpp:3077
alloc_sync_x && name(const char *name_in)
Definition lci_binding_post.hpp:3079
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:3068
alloc_sync_x()
Definition lci_binding_post.hpp:3073
option_t< const char * > m_name
Definition lci_binding_post.hpp:3069
alloc_sync_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:3078
alloc_sync_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3076
comp_t call() const
Definition binding.cpp:899
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3066
The actual implementation for allreduce.
Definition lci_binding_post.hpp:1139
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:1162
void operator()() const
Definition lci_binding_post.hpp:1174
const void * m_sendbuf
Definition lci_binding_post.hpp:1142
option_t< device_t > m_device
Definition lci_binding_post.hpp:1148
allreduce_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:1159
reduce_op_t m_op
Definition lci_binding_post.hpp:1146
void * m_recvbuf
Definition lci_binding_post.hpp:1143
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:1153
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:1156
allreduce_x && device(device_t device_in)
Definition lci_binding_post.hpp:1165
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1150
size_t m_count
Definition lci_binding_post.hpp:1144
allreduce_x && count(size_t count_in)
Definition lci_binding_post.hpp:1161
allreduce_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:1160
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1149
allreduce_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1166
option_t< allreduce_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:1152
allreduce_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:1163
allreduce_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1164
allreduce_x && algorithm(allreduce_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:1169
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1147
allreduce_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:1170
size_t m_item_size
Definition lci_binding_post.hpp:1145
allreduce_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1168
void call() const
Definition binding.cpp:424
allreduce_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1167
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:1151
The actual implementation for alltoall.
Definition lci_binding_post.hpp:1255
const void * m_sendbuf
Definition lci_binding_post.hpp:1258
void call() const
Definition binding.cpp:451
alltoall_x && device(device_t device_in)
Definition lci_binding_post.hpp:1276
void call_impl(const void *sendbuf, void *recvbuf, size_t size, runtime_t runtime, device_t device, endpoint_t endpoint, matching_engine_t matching_engine, comp_t comp, comp_semantic_t comp_semantic) const
alltoall_x && size(size_t size_in)
Definition lci_binding_post.hpp:1274
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1264
alltoall_x(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:1269
void * m_recvbuf
Definition lci_binding_post.hpp:1259
alltoall_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:1273
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:1265
option_t< device_t > m_device
Definition lci_binding_post.hpp:1262
alltoall_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1278
alltoall_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1277
alltoall_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1275
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1261
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1263
alltoall_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:1272
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:1266
alltoall_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:1280
size_t m_size
Definition lci_binding_post.hpp:1260
alltoall_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1279
void operator()() const
Definition lci_binding_post.hpp:1284
The actual implementation for barrier.
Definition lci_binding_post.hpp:895
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:903
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:901
barrier_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:912
barrier_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:914
barrier_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:913
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:899
void call() const
Definition binding.cpp:370
barrier_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:911
barrier_x()
Definition lci_binding_post.hpp:906
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:900
barrier_x && device(device_t device_in)
Definition lci_binding_post.hpp:910
void operator()() const
Definition lci_binding_post.hpp:918
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:902
barrier_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:909
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:898
The actual implementation for broadcast.
Definition lci_binding_post.hpp:948
broadcast_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:972
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:956
void call() const
Definition binding.cpp:380
void operator()() const
Definition lci_binding_post.hpp:979
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:957
int m_root
Definition lci_binding_post.hpp:953
broadcast_x && root(int root_in)
Definition lci_binding_post.hpp:968
broadcast_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:973
broadcast_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:969
broadcast_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:975
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:954
broadcast_x && size(size_t size_in)
Definition lci_binding_post.hpp:967
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:960
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:958
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:963
broadcast_x && device(device_t device_in)
Definition lci_binding_post.hpp:970
option_t< broadcast_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:959
void * m_buffer
Definition lci_binding_post.hpp:951
option_t< device_t > m_device
Definition lci_binding_post.hpp:955
broadcast_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:966
broadcast_x && algorithm(broadcast_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:974
broadcast_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:971
size_t m_size
Definition lci_binding_post.hpp:952
The actual implementation for comp_signal.
Definition lci_binding_post.hpp:2907
comp_signal_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2920
comp_signal_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2918
status_t m_status
Definition lci_binding_post.hpp:2911
comp_t m_comp
Definition lci_binding_post.hpp:2910
void call() const
Definition binding.cpp:873
comp_signal_x(comp_t comp_in, status_t status_in)
Definition lci_binding_post.hpp:2915
void call_impl(comp_t comp, status_t status, runtime_t runtime) const
void operator()() const
Definition lci_binding_post.hpp:2924
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2912
comp_signal_x && status(status_t status_in)
Definition lci_binding_post.hpp:2919
The actual implementation for RESOURCE comp.
Definition lci_binding_pre.hpp:540
The actual implementation for counter_get.
Definition lci_binding_post.hpp:3232
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3236
int64_t call_impl(comp_t comp, runtime_t runtime) const
int64_t operator()() const
Definition lci_binding_post.hpp:3247
counter_get_x(comp_t comp_in)
Definition lci_binding_post.hpp:3239
int64_t call() const
Definition binding.cpp:931
counter_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3243
comp_t m_comp
Definition lci_binding_post.hpp:3235
counter_get_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3242
The actual implementation for counter_set.
Definition lci_binding_post.hpp:3270
counter_set_x(comp_t comp_in, int64_t value_in)
Definition lci_binding_post.hpp:3278
int64_t m_value
Definition lci_binding_post.hpp:3274
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3275
comp_t m_comp
Definition lci_binding_post.hpp:3273
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:3283
counter_set_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3281
void operator()() const
Definition lci_binding_post.hpp:3287
counter_set_x && value(int64_t value_in)
Definition lci_binding_post.hpp:3282
void call() const
Definition binding.cpp:937
The actual implementation for cq_pop.
Definition lci_binding_post.hpp:3358
status_t operator()() const
Definition lci_binding_post.hpp:3373
comp_t m_comp
Definition lci_binding_post.hpp:3361
status_t call_impl(comp_t comp, runtime_t runtime) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3362
cq_pop_x(comp_t comp_in)
Definition lci_binding_post.hpp:3365
cq_pop_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3368
cq_pop_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3369
status_t call() const
Definition binding.cpp:954
The actual implementation for deregister_memory.
Definition lci_binding_post.hpp:2205
void operator()() const
Definition lci_binding_post.hpp:2220
void call() const
Definition binding.cpp:714
mr_t * m_mr
Definition lci_binding_post.hpp:2208
deregister_memory_x && mr(mr_t *mr_in)
Definition lci_binding_post.hpp:2215
deregister_memory_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2216
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2209
void call_impl(mr_t *mr, runtime_t runtime) const
deregister_memory_x(mr_t *mr_in)
Definition lci_binding_post.hpp:2212
The actual implementation for deregister_packet_pool.
Definition lci_binding_post.hpp:371
deregister_packet_pool_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:382
void call_impl(packet_pool_t packet_pool, device_t device, runtime_t runtime) const
packet_pool_t m_packet_pool
Definition lci_binding_post.hpp:374
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:376
void operator()() const
Definition lci_binding_post.hpp:388
void call() const
Definition binding.cpp:280
deregister_packet_pool_x && device(device_t device_in)
Definition lci_binding_post.hpp:383
device_t m_device
Definition lci_binding_post.hpp:375
deregister_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:384
deregister_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:379
The actual implementation for deregister_rcomp.
Definition lci_binding_post.hpp:3023
deregister_rcomp_x(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:3030
void operator()() const
Definition lci_binding_post.hpp:3038
rcomp_t m_rcomp
Definition lci_binding_post.hpp:3026
void call_impl(rcomp_t rcomp, runtime_t runtime) const
void call() const
Definition binding.cpp:893
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3027
deregister_rcomp_x && rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:3033
deregister_rcomp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3034
The actual implementation for RESOURCE device.
Definition lci_binding_pre.hpp:418
The actual implementation for RESOURCE endpoint.
Definition lci_binding_pre.hpp:501
The actual implementation for free_comp.
Definition lci_binding_post.hpp:2869
free_comp_x(comp_t *comp_in)
Definition lci_binding_post.hpp:2876
free_comp_x && comp(comp_t *comp_in)
Definition lci_binding_post.hpp:2879
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2873
comp_t * m_comp
Definition lci_binding_post.hpp:2872
void call() const
Definition binding.cpp:867
free_comp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2880
void operator()() const
Definition lci_binding_post.hpp:2884
void call_impl(comp_t *comp, runtime_t runtime) const
The actual implementation for free_device.
Definition lci_binding_post.hpp:2125
void call_impl(device_t *device, runtime_t runtime) const
free_device_x && device(device_t *device_in)
Definition lci_binding_post.hpp:2135
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2129
device_t * m_device
Definition lci_binding_post.hpp:2128
void operator()() const
Definition lci_binding_post.hpp:2140
void call() const
Definition binding.cpp:696
free_device_x(device_t *device_in)
Definition lci_binding_post.hpp:2132
free_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2136
The actual implementation for free_endpoint.
Definition lci_binding_post.hpp:2322
void operator()() const
Definition lci_binding_post.hpp:2337
endpoint_t * m_endpoint
Definition lci_binding_post.hpp:2325
free_endpoint_x && endpoint(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:2332
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2326
free_endpoint_x(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:2329
void call_impl(endpoint_t *endpoint, runtime_t runtime) const
void call() const
Definition binding.cpp:739
free_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2333
The actual implementation for free_matching_engine.
Definition lci_binding_post.hpp:527
void call_impl(matching_engine_t *matching_engine, runtime_t runtime) const
free_matching_engine_x && matching_engine(matching_engine_t *matching_engine_in)
Definition lci_binding_post.hpp:537
free_matching_engine_x(matching_engine_t *matching_engine_in)
Definition lci_binding_post.hpp:534
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:531
matching_engine_t * m_matching_engine
Definition lci_binding_post.hpp:530
void call() const
Definition binding.cpp:312
free_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:538
void operator()() const
Definition lci_binding_post.hpp:542
The actual implementation for free_net_context.
Definition lci_binding_post.hpp:1997
void operator()() const
Definition lci_binding_post.hpp:2012
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:2008
free_net_context_x(net_context_t *net_context_in)
Definition lci_binding_post.hpp:2004
void call() const
Definition binding.cpp:646
net_context_t * m_net_context
Definition lci_binding_post.hpp:2000
free_net_context_x && net_context(net_context_t *net_context_in)
Definition lci_binding_post.hpp:2007
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2001
The actual implementation for free_packet_pool.
Definition lci_binding_post.hpp:293
void operator()() const
Definition lci_binding_post.hpp:308
free_packet_pool_x(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:300
void call() const
Definition binding.cpp:267
void call_impl(packet_pool_t *packet_pool, runtime_t runtime) const
packet_pool_t * m_packet_pool
Definition lci_binding_post.hpp:296
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:297
free_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:304
free_packet_pool_x && packet_pool(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:303
The actual implementation for free_runtime.
Definition lci_binding_post.hpp:87
void call_impl(runtime_t *runtime) const
free_runtime_x(runtime_t *runtime_in)
Definition lci_binding_post.hpp:93
runtime_t * m_runtime
Definition lci_binding_post.hpp:90
free_runtime_x && runtime(runtime_t *runtime_in)
Definition lci_binding_post.hpp:96
void operator()() const
Definition lci_binding_post.hpp:100
void call() const
Definition binding.cpp:222
The actual implementation for g_runtime_fina.
Definition lci_binding_post.hpp:182
g_runtime_fina_x()
Definition lci_binding_post.hpp:187
void call() const
Definition binding.cpp:243
void operator()() const
Definition lci_binding_post.hpp:193
void call_impl() const
The actual implementation for g_runtime_init.
Definition lci_binding_post.hpp:130
g_runtime_init_x && imm_nbits_rcomp(int imm_nbits_rcomp_in)
Definition lci_binding_post.hpp:150
g_runtime_init_x && alloc_default_packet_pool(bool alloc_default_packet_pool_in)
Definition lci_binding_post.hpp:153
g_runtime_init_x && imm_nbits_tag(int imm_nbits_tag_in)
Definition lci_binding_post.hpp:149
runtime_t call_impl(size_t packet_return_threshold, int imm_nbits_tag, int imm_nbits_rcomp, attr_rdv_protocol_t rdv_protocol, bool alloc_default_device, bool alloc_default_packet_pool, bool alloc_default_matching_engine, const char *name, void *user_context, std::string device_name) const
option_t< int > m_imm_nbits_tag
Definition lci_binding_post.hpp:134
option_t< int > m_imm_nbits_rcomp
Definition lci_binding_post.hpp:135
option_t< size_t > m_packet_return_threshold
Definition lci_binding_post.hpp:133
g_runtime_init_x && name(const char *name_in)
Definition lci_binding_post.hpp:155
option_t< attr_rdv_protocol_t > m_rdv_protocol
Definition lci_binding_post.hpp:136
option_t< void * > m_user_context
Definition lci_binding_post.hpp:141
option_t< std::string > m_device_name
Definition lci_binding_post.hpp:142
option_t< bool > m_alloc_default_device
Definition lci_binding_post.hpp:137
g_runtime_init_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:156
g_runtime_init_x && alloc_default_matching_engine(bool alloc_default_matching_engine_in)
Definition lci_binding_post.hpp:154
runtime_t call() const
Definition binding.cpp:228
option_t< bool > m_alloc_default_matching_engine
Definition lci_binding_post.hpp:139
g_runtime_init_x && device_name(std::string device_name_in)
Definition lci_binding_post.hpp:157
option_t< bool > m_alloc_default_packet_pool
Definition lci_binding_post.hpp:138
g_runtime_init_x()
Definition lci_binding_post.hpp:145
g_runtime_init_x && alloc_default_device(bool alloc_default_device_in)
Definition lci_binding_post.hpp:152
option_t< const char * > m_name
Definition lci_binding_post.hpp:140
g_runtime_init_x && packet_return_threshold(size_t packet_return_threshold_in)
Definition lci_binding_post.hpp:148
runtime_t operator()() const
Definition lci_binding_post.hpp:161
g_runtime_init_x && rdv_protocol(attr_rdv_protocol_t rdv_protocol_in)
Definition lci_binding_post.hpp:151
The actual implementation for get_allocator.
Definition lci_binding_post.hpp:646
allocator_base_t * call_impl(runtime_t runtime) const
allocator_base_t * call() const
Definition binding.cpp:333
allocator_base_t * operator()() const
Definition lci_binding_post.hpp:659
get_allocator_x()
Definition lci_binding_post.hpp:652
get_allocator_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:655
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:649
The actual implementation for get_default_device.
Definition lci_binding_post.hpp:714
device_t call_impl(runtime_t runtime) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:717
get_default_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:723
device_t call() const
Definition binding.cpp:343
get_default_device_x()
Definition lci_binding_post.hpp:720
device_t operator()() const
Definition lci_binding_post.hpp:727
The actual implementation for get_default_endpoint.
Definition lci_binding_post.hpp:749
endpoint_t call_impl(runtime_t runtime, device_t device) const
get_default_endpoint_x && device(device_t device_in)
Definition lci_binding_post.hpp:760
endpoint_t operator()() const
Definition lci_binding_post.hpp:764
endpoint_t call() const
Definition binding.cpp:348
get_default_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:759
get_default_endpoint_x()
Definition lci_binding_post.hpp:756
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:752
option_t< device_t > m_device
Definition lci_binding_post.hpp:753
The actual implementation for get_default_matching_engine.
Definition lci_binding_post.hpp:819
get_default_matching_engine_x()
Definition lci_binding_post.hpp:825
matching_engine_t call() const
Definition binding.cpp:359
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:822
matching_engine_t call_impl(runtime_t runtime) const
matching_engine_t operator()() const
Definition lci_binding_post.hpp:832
get_default_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:828
The actual implementation for get_default_net_context.
Definition lci_binding_post.hpp:680
net_context_t operator()() const
Definition lci_binding_post.hpp:693
get_default_net_context_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:689
get_default_net_context_x()
Definition lci_binding_post.hpp:686
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:683
net_context_t call_impl(runtime_t runtime) const
net_context_t call() const
Definition binding.cpp:338
The actual implementation for get_default_packet_pool.
Definition lci_binding_post.hpp:785
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:788
packet_pool_t operator()() const
Definition lci_binding_post.hpp:798
packet_pool_t call_impl(runtime_t runtime) const
packet_pool_t call() const
Definition binding.cpp:354
get_default_packet_pool_x()
Definition lci_binding_post.hpp:791
get_default_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:794
The actual implementation for get_g_runtime.
Definition lci_binding_post.hpp:214
runtime_t operator()() const
Definition lci_binding_post.hpp:225
get_g_runtime_x()
Definition lci_binding_post.hpp:219
runtime_t call() const
Definition binding.cpp:248
runtime_t call_impl() const
The actual implementation for get_max_bcopy_size.
Definition lci_binding_post.hpp:854
size_t operator()() const
Definition lci_binding_post.hpp:869
get_max_bcopy_size_x()
Definition lci_binding_post.hpp:861
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:857
size_t call_impl(runtime_t runtime, packet_pool_t packet_pool) const
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:858
get_max_bcopy_size_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:865
size_t call() const
Definition binding.cpp:364
get_max_bcopy_size_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:864
The actual implementation for get_rmr.
Definition lci_binding_post.hpp:2242
get_rmr_x(mr_t mr_in)
Definition lci_binding_post.hpp:2249
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2246
get_rmr_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:2252
rmr_t operator()() const
Definition lci_binding_post.hpp:2257
mr_t m_mr
Definition lci_binding_post.hpp:2245
rmr_t call() const
Definition binding.cpp:720
get_rmr_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2253
rmr_t call_impl(mr_t mr, runtime_t runtime) const
The actual implementation for get_upacket.
Definition lci_binding_post.hpp:410
get_upacket_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:421
void * call() const
Definition binding.cpp:287
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:413
get_upacket_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:420
void * operator()() const
Definition lci_binding_post.hpp:425
void * call_impl(runtime_t runtime, packet_pool_t packet_pool) const
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:414
get_upacket_x()
Definition lci_binding_post.hpp:417
The actual implementation for graph_add_edge.
Definition lci_binding_post.hpp:3533
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:3536
void call() const
Definition binding.cpp:986
graph_add_edge_x(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in)
Definition lci_binding_post.hpp:3543
graph_add_edge_x && dst(graph_node_t dst_in)
Definition lci_binding_post.hpp:3548
graph_add_edge_x && fn(graph_edge_run_cb_t fn_in)
Definition lci_binding_post.hpp:3549
void operator()() const
Definition lci_binding_post.hpp:3554
option_t< graph_edge_run_cb_t > m_fn
Definition lci_binding_post.hpp:3539
graph_add_edge_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3546
graph_node_t m_dst
Definition lci_binding_post.hpp:3538
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3540
graph_add_edge_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3550
graph_add_edge_x && src(graph_node_t src_in)
Definition lci_binding_post.hpp:3547
graph_node_t m_src
Definition lci_binding_post.hpp:3537
The actual implementation for graph_add_node.
Definition lci_binding_post.hpp:3487
option_t< void * > m_value
Definition lci_binding_post.hpp:3492
graph_node_t operator()() const
Definition lci_binding_post.hpp:3508
graph_add_node_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3504
graph_node_t call() const
Definition binding.cpp:977
graph_add_node_x(comp_t comp_in, graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:3497
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:3501
graph_node_run_cb_t m_fn
Definition lci_binding_post.hpp:3491
comp_t m_comp
Definition lci_binding_post.hpp:3490
graph_add_node_x && free_cb(graph_node_free_cb_t free_cb_in)
Definition lci_binding_post.hpp:3503
graph_add_node_x && value(void *value_in)
Definition lci_binding_post.hpp:3502
option_t< graph_node_free_cb_t > m_free_cb
Definition lci_binding_post.hpp:3493
graph_add_node_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3500
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3494
The actual implementation for graph_node_mark_complete.
Definition lci_binding_post.hpp:3577
void operator()() const
Definition lci_binding_post.hpp:3594
void call() const
Definition binding.cpp:995
graph_node_t m_node
Definition lci_binding_post.hpp:3580
graph_node_mark_complete_x(graph_node_t node_in)
Definition lci_binding_post.hpp:3585
option_t< status_t > m_status
Definition lci_binding_post.hpp:3581
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:3588
graph_node_mark_complete_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3590
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3582
graph_node_mark_complete_x && status(status_t status_in)
Definition lci_binding_post.hpp:3589
The actual implementation for graph_start.
Definition lci_binding_post.hpp:3616
graph_start_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3627
comp_t m_comp
Definition lci_binding_post.hpp:3619
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3620
graph_start_x(comp_t comp_in)
Definition lci_binding_post.hpp:3623
void call_impl(comp_t comp, runtime_t runtime) const
void call() const
Definition binding.cpp:1002
void operator()() const
Definition lci_binding_post.hpp:3631
graph_start_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3626
The actual implementation for graph_test.
Definition lci_binding_post.hpp:3653
comp_t m_comp
Definition lci_binding_post.hpp:3656
status_t call_impl(comp_t comp, runtime_t runtime) const
graph_test_x(comp_t comp_in)
Definition lci_binding_post.hpp:3660
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3657
graph_test_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3664
status_t operator()() const
Definition lci_binding_post.hpp:3668
status_t call() const
Definition binding.cpp:1008
graph_test_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3663
The actual implementation for matching_engine_insert.
Definition lci_binding_post.hpp:567
matching_engine_insert_x && value(matching_entry_val_t value_in)
Definition lci_binding_post.hpp:582
matching_engine_insert_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:584
matching_entry_val_t operator()() const
Definition lci_binding_post.hpp:588
matching_entry_val_t call() const
Definition binding.cpp:318
matching_engine_insert_x && entry_type(matching_entry_type_t entry_type_in)
Definition lci_binding_post.hpp:583
matching_engine_insert_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:580
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:574
matching_entry_type_t m_entry_type
Definition lci_binding_post.hpp:573
matching_engine_t m_matching_engine
Definition lci_binding_post.hpp:570
matching_entry_key_t m_key
Definition lci_binding_post.hpp:571
matching_engine_insert_x && key(matching_entry_key_t key_in)
Definition lci_binding_post.hpp:581
matching_engine_insert_x(matching_engine_t matching_engine_in, matching_entry_key_t key_in, matching_entry_val_t value_in, matching_entry_type_t entry_type_in)
Definition lci_binding_post.hpp:577
matching_entry_val_t call_impl(matching_engine_t matching_engine, matching_entry_key_t key, matching_entry_val_t value, matching_entry_type_t entry_type, runtime_t runtime) const
matching_entry_val_t m_value
Definition lci_binding_post.hpp:572
The actual implementation for RESOURCE matching_engine.
Definition lci_binding_pre.hpp:313
The actual implementation for RESOURCE mr.
Definition lci_binding_pre.hpp:467
The actual implementation for RESOURCE net_context.
Definition lci_binding_pre.hpp:358
The actual implementation for net_poll_cq.
Definition lci_binding_post.hpp:2361
net_poll_cq_x && device(device_t device_in)
Definition lci_binding_post.hpp:2376
net_poll_cq_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2375
option_t< device_t > m_device
Definition lci_binding_post.hpp:2367
net_poll_cq_x(size_t max_polls_in, net_status_t *statuses_in)
Definition lci_binding_post.hpp:2370
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2366
net_poll_cq_x && statuses(net_status_t *statuses_in)
Definition lci_binding_post.hpp:2374
size_t operator()() const
Definition lci_binding_post.hpp:2380
size_t call() const
Definition binding.cpp:745
net_poll_cq_x && max_polls(size_t max_polls_in)
Definition lci_binding_post.hpp:2373
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:2364
net_status_t * m_statuses
Definition lci_binding_post.hpp:2365
The actual implementation for net_post_get.
Definition lci_binding_post.hpp:2816
net_post_get_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:2835
net_post_get_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2842
net_post_get_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:2839
option_t< device_t > m_device
Definition lci_binding_post.hpp:2826
int m_rank
Definition lci_binding_post.hpp:2819
net_post_get_x && device(device_t device_in)
Definition lci_binding_post.hpp:2841
net_post_get_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:2837
error_t operator()() const
Definition lci_binding_post.hpp:2847
net_post_get_x && size(size_t size_in)
Definition lci_binding_post.hpp:2836
error_t call() const
Definition binding.cpp:844
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2825
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2827
mr_t m_mr
Definition lci_binding_post.hpp:2822
void * m_buffer
Definition lci_binding_post.hpp:2820
net_post_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2840
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:2823
net_post_get_x && rank(int rank_in)
Definition lci_binding_post.hpp:2834
rmr_t m_rmr
Definition lci_binding_post.hpp:2824
size_t m_size
Definition lci_binding_post.hpp:2821
net_post_get_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2843
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2828
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:2831
net_post_get_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:2838
The actual implementation for net_post_putImm.
Definition lci_binding_post.hpp:2753
net_post_putImm_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2780
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:2769
rmr_t m_rmr
Definition lci_binding_post.hpp:2761
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2762
net_post_putImm_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:2775
net_post_putImm_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:2777
error_t call() const
Definition binding.cpp:829
net_post_putImm_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:2781
int m_rank
Definition lci_binding_post.hpp:2756
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:2765
net_post_putImm_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2778
option_t< device_t > m_device
Definition lci_binding_post.hpp:2763
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2764
mr_t m_mr
Definition lci_binding_post.hpp:2759
net_post_putImm_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:2773
void * m_buffer
Definition lci_binding_post.hpp:2757
net_post_putImm_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2782
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2766
error_t operator()() const
Definition lci_binding_post.hpp:2786
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:2758
net_post_putImm_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:2776
uint64_t m_offset
Definition lci_binding_post.hpp:2760
net_post_putImm_x && size(size_t size_in)
Definition lci_binding_post.hpp:2774
net_post_putImm_x && rank(int rank_in)
Definition lci_binding_post.hpp:2772
net_post_putImm_x && device(device_t device_in)
Definition lci_binding_post.hpp:2779
The actual implementation for net_post_putImms.
Definition lci_binding_post.hpp:2691
net_post_putImms_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:2710
net_post_putImms_x && device(device_t device_in)
Definition lci_binding_post.hpp:2715
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2701
option_t< device_t > m_device
Definition lci_binding_post.hpp:2700
net_post_putImms_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:2713
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:2709
uint64_t m_offset
Definition lci_binding_post.hpp:2697
void * m_buffer
Definition lci_binding_post.hpp:2695
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:2702
int m_rank
Definition lci_binding_post.hpp:2694
error_t operator()() const
Definition lci_binding_post.hpp:2722
net_post_putImms_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:2712
error_t call() const
Definition binding.cpp:815
rmr_t m_rmr
Definition lci_binding_post.hpp:2698
net_post_putImms_x && size(size_t size_in)
Definition lci_binding_post.hpp:2711
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2703
net_post_putImms_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2716
net_post_putImms_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:2717
size_t m_size
Definition lci_binding_post.hpp:2696
net_post_putImms_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2714
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2699
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:2706
net_post_putImms_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2718
The actual implementation for net_post_put.
Definition lci_binding_post.hpp:2630
rmr_t m_rmr
Definition lci_binding_post.hpp:2638
net_post_put_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:2649
mr_t m_mr
Definition lci_binding_post.hpp:2636
net_post_put_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:2653
int m_rank
Definition lci_binding_post.hpp:2633
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:2645
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:2639
error_t call() const
Definition binding.cpp:801
net_post_put_x && rank(int rank_in)
Definition lci_binding_post.hpp:2648
option_t< device_t > m_device
Definition lci_binding_post.hpp:2640
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2641
net_post_put_x && device(device_t device_in)
Definition lci_binding_post.hpp:2655
net_post_put_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2657
net_post_put_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2656
net_post_put_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:2651
net_post_put_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:2652
net_post_put_x && size(size_t size_in)
Definition lci_binding_post.hpp:2650
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2642
size_t m_size
Definition lci_binding_post.hpp:2635
net_post_put_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2654
error_t operator()() const
Definition lci_binding_post.hpp:2661
uint64_t m_offset
Definition lci_binding_post.hpp:2637
void * m_buffer
Definition lci_binding_post.hpp:2634
The actual implementation for net_post_puts.
Definition lci_binding_post.hpp:2571
net_post_puts_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:2592
net_post_puts_x && rank(int rank_in)
Definition lci_binding_post.hpp:2588
error_t operator()() const
Definition lci_binding_post.hpp:2600
net_post_puts_x && size(size_t size_in)
Definition lci_binding_post.hpp:2590
option_t< device_t > m_device
Definition lci_binding_post.hpp:2580
void * m_buffer
Definition lci_binding_post.hpp:2575
net_post_puts_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:2591
net_post_puts_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2593
net_post_puts_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:2589
net_post_puts_x && device(device_t device_in)
Definition lci_binding_post.hpp:2594
error_t call() const
Definition binding.cpp:788
int m_rank
Definition lci_binding_post.hpp:2574
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:2585
rmr_t m_rmr
Definition lci_binding_post.hpp:2578
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2579
size_t m_size
Definition lci_binding_post.hpp:2576
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2582
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:2596
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2581
net_post_puts_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2595
uint64_t m_offset
Definition lci_binding_post.hpp:2577
The actual implementation for net_post_recv.
Definition lci_binding_post.hpp:2406
net_post_recv_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2423
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2414
net_post_recv_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:2420
error_t call() const
Definition binding.cpp:753
net_post_recv_x(void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:2417
net_post_recv_x && size(size_t size_in)
Definition lci_binding_post.hpp:2421
net_post_recv_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:2422
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2412
option_t< device_t > m_device
Definition lci_binding_post.hpp:2413
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:2411
size_t m_size
Definition lci_binding_post.hpp:2410
error_t operator()() const
Definition lci_binding_post.hpp:2429
net_post_recv_x && device(device_t device_in)
Definition lci_binding_post.hpp:2424
void * m_buffer
Definition lci_binding_post.hpp:2409
net_post_recv_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2425
The actual implementation for net_post_send.
Definition lci_binding_post.hpp:2513
net_post_send_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:2537
net_post_send_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2534
net_post_send_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:2531
void * m_buffer
Definition lci_binding_post.hpp:2517
int m_rank
Definition lci_binding_post.hpp:2516
mr_t m_mr
Definition lci_binding_post.hpp:2519
size_t m_size
Definition lci_binding_post.hpp:2518
net_post_send_x && size(size_t size_in)
Definition lci_binding_post.hpp:2532
error_t call() const
Definition binding.cpp:775
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2520
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:2523
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2522
net_post_send_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:2533
net_post_send_x && device(device_t device_in)
Definition lci_binding_post.hpp:2535
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2524
net_post_send_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2536
net_post_send_x(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:2527
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:2521
error_t operator()() const
Definition lci_binding_post.hpp:2542
net_post_send_x && rank(int rank_in)
Definition lci_binding_post.hpp:2530
net_post_send_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2538
The actual implementation for net_post_sends.
Definition lci_binding_post.hpp:2457
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2467
net_post_sends_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:2479
net_post_sends_x && size(size_t size_in)
Definition lci_binding_post.hpp:2475
error_t call() const
Definition binding.cpp:763
option_t< device_t > m_device
Definition lci_binding_post.hpp:2464
net_post_sends_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2478
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:2460
net_post_sends_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2476
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:2466
net_post_sends_x(int rank_in, void *buffer_in, size_t size_in)
Definition lci_binding_post.hpp:2470
net_post_sends_x && rank(int rank_in)
Definition lci_binding_post.hpp:2473
void * m_buffer
Definition lci_binding_post.hpp:2461
net_post_sends_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2480
error_t operator()() const
Definition lci_binding_post.hpp:2484
net_post_sends_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:2474
size_t m_size
Definition lci_binding_post.hpp:2462
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2465
net_post_sends_x && device(device_t device_in)
Definition lci_binding_post.hpp:2477
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2463
The actual implementation for RESOURCE packet_pool.
Definition lci_binding_pre.hpp:277
The actual implementation for post_am.
Definition lci_binding_post.hpp:1414
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:1427
option_t< device_t > m_device
Definition lci_binding_post.hpp:1423
post_am_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1446
rcomp_t m_remote_comp
Definition lci_binding_post.hpp:1421
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:1428
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:1431
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:1435
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1424
post_am_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:1451
post_am_x && size(size_t size_in)
Definition lci_binding_post.hpp:1440
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:1432
post_am_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1443
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1422
post_am_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:1449
int m_rank
Definition lci_binding_post.hpp:1417
post_am_x && rank(int rank_in)
Definition lci_binding_post.hpp:1438
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:1425
post_am_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:1447
status_t call() const
Definition binding.cpp:489
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:1426
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:1448
comp_t m_local_comp
Definition lci_binding_post.hpp:1420
post_am_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:1453
post_am_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:1452
post_am_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:1439
size_t m_size
Definition lci_binding_post.hpp:1419
post_am_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1445
post_am_x && device(device_t device_in)
Definition lci_binding_post.hpp:1444
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:1430
post_am_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1450
void * m_local_buffer
Definition lci_binding_post.hpp:1418
post_am_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:1441
status_t operator()() const
Definition lci_binding_post.hpp:1457
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1429
post_am_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:1442
The actual implementation for post_comm.
Definition lci_binding_post.hpp:1325
status_t call() const
Definition binding.cpp:464
void * m_local_buffer
Definition lci_binding_post.hpp:1330
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1344
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:1345
post_comm_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:1369
option_t< device_t > m_device
Definition lci_binding_post.hpp:1334
post_comm_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1363
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:1348
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:1329
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1337
post_comm_x && rank(int rank_in)
Definition lci_binding_post.hpp:1355
post_comm_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1359
post_comm_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:1356
size_t m_size
Definition lci_binding_post.hpp:1331
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1333
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:1339
comp_t m_local_comp
Definition lci_binding_post.hpp:1332
status_t operator()() const
Definition lci_binding_post.hpp:1378
option_t< rmr_t > m_rmr
Definition lci_binding_post.hpp:1341
post_comm_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1370
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:1347
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:1351
option_t< uintptr_t > m_remote_disp
Definition lci_binding_post.hpp:1340
post_comm_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1362
post_comm_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:1372
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1335
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:1343
post_comm_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:1358
post_comm_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:1368
post_comm_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1367
post_comm_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1365
post_comm_x && direction(direction_t direction_in)
Definition lci_binding_post.hpp:1354
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:1346
post_comm_x && size(size_t size_in)
Definition lci_binding_post.hpp:1357
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:1336
post_comm_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1361
post_comm_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:1373
post_comm_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:1364
post_comm_x && device(device_t device_in)
Definition lci_binding_post.hpp:1360
post_comm_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:1374
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:1338
post_comm_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:1371
direction_t m_direction
Definition lci_binding_post.hpp:1328
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:1342
post_comm_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:1366
The actual implementation for post_get.
Definition lci_binding_post.hpp:1744
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:1760
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1761
post_get_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:1785
post_get_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:1782
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:1757
comp_t m_local_comp
Definition lci_binding_post.hpp:1750
post_get_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:1780
post_get_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:1774
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:1767
post_get_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1781
status_t operator()() const
Definition lci_binding_post.hpp:1791
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:1756
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:1764
uintptr_t m_remote_disp
Definition lci_binding_post.hpp:1751
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:1748
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:1762
option_t< device_t > m_device
Definition lci_binding_post.hpp:1754
post_get_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1775
int m_rank
Definition lci_binding_post.hpp:1747
post_get_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:1771
post_get_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:1783
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1753
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:1763
post_get_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:1786
post_get_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1779
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1755
post_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1776
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:1758
post_get_x && size(size_t size_in)
Definition lci_binding_post.hpp:1772
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:1759
post_get_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1778
status_t call() const
Definition binding.cpp:573
post_get_x && rank(int rank_in)
Definition lci_binding_post.hpp:1770
post_get_x && device(device_t device_in)
Definition lci_binding_post.hpp:1777
post_get_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:1773
post_get_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1784
size_t m_size
Definition lci_binding_post.hpp:1749
rmr_t m_rmr
Definition lci_binding_post.hpp:1752
post_get_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:1787
The actual implementation for post_put.
Definition lci_binding_post.hpp:1659
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:1677
post_put_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1699
post_put_x && device(device_t device_in)
Definition lci_binding_post.hpp:1692
status_t operator()() const
Definition lci_binding_post.hpp:1706
post_put_x && rank(int rank_in)
Definition lci_binding_post.hpp:1685
post_put_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1691
post_put_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1693
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:1678
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1670
comp_t m_local_comp
Definition lci_binding_post.hpp:1665
uintptr_t m_remote_disp
Definition lci_binding_post.hpp:1666
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:1679
option_t< device_t > m_device
Definition lci_binding_post.hpp:1669
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1676
post_put_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:1686
int m_rank
Definition lci_binding_post.hpp:1662
post_put_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1694
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:1675
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:1682
post_put_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:1697
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:1673
post_put_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:1700
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:1674
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:1672
post_put_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:1695
status_t call() const
Definition binding.cpp:551
post_put_x && size(size_t size_in)
Definition lci_binding_post.hpp:1687
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1668
post_put_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:1702
post_put_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:1690
post_put_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:1688
post_put_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:1689
rmr_t m_rmr
Definition lci_binding_post.hpp:1667
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:1671
size_t m_size
Definition lci_binding_post.hpp:1664
post_put_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:1698
post_put_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1696
void * m_local_buffer
Definition lci_binding_post.hpp:1663
post_put_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:1701
The actual implementation for post_recv.
Definition lci_binding_post.hpp:1576
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:1595
post_recv_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:1616
size_t m_size
Definition lci_binding_post.hpp:1581
post_recv_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:1615
post_recv_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:1604
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1591
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1588
tag_t m_tag
Definition lci_binding_post.hpp:1582
post_recv_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1609
post_recv_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1606
option_t< device_t > m_device
Definition lci_binding_post.hpp:1585
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:1593
post_recv_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:1611
post_recv_x && size(size_t size_in)
Definition lci_binding_post.hpp:1603
status_t operator()() const
Definition lci_binding_post.hpp:1621
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:1587
post_recv_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1613
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:1589
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:1590
void * m_local_buffer
Definition lci_binding_post.hpp:1580
post_recv_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1608
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1586
post_recv_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1610
comp_t m_local_comp
Definition lci_binding_post.hpp:1583
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:1594
post_recv_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1612
post_recv_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:1617
post_recv_x && device(device_t device_in)
Definition lci_binding_post.hpp:1607
int m_rank
Definition lci_binding_post.hpp:1579
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:1598
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1584
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:1592
post_recv_x && rank(int rank_in)
Definition lci_binding_post.hpp:1601
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:1605
post_recv_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:1614
post_recv_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:1602
status_t call() const
Definition binding.cpp:530
The actual implementation for post_send.
Definition lci_binding_post.hpp:1494
post_send_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:1533
post_send_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:1523
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:1505
status_t call() const
Definition binding.cpp:509
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1506
post_send_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1526
void * m_local_buffer
Definition lci_binding_post.hpp:1498
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1509
post_send_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:1530
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:1511
size_t m_size
Definition lci_binding_post.hpp:1499
int m_rank
Definition lci_binding_post.hpp:1497
post_send_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:1520
tag_t m_tag
Definition lci_binding_post.hpp:1500
post_send_x && size(size_t size_in)
Definition lci_binding_post.hpp:1521
comp_t m_local_comp
Definition lci_binding_post.hpp:1501
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:1516
status_t operator()() const
Definition lci_binding_post.hpp:1539
post_send_x && rank(int rank_in)
Definition lci_binding_post.hpp:1519
post_send_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1524
post_send_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:1535
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:1508
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1504
post_send_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1528
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:1529
post_send_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:1534
option_t< device_t > m_device
Definition lci_binding_post.hpp:1503
post_send_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1531
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:1507
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:1510
post_send_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:1522
post_send_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:1532
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:1513
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:1512
post_send_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1527
post_send_x && device(device_t device_in)
Definition lci_binding_post.hpp:1525
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1502
The actual implementation for progress.
Definition lci_binding_post.hpp:1814
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1817
error_t call() const
Definition binding.cpp:595
progress_x()
Definition lci_binding_post.hpp:1822
progress_x && device(device_t device_in)
Definition lci_binding_post.hpp:1826
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1819
option_t< device_t > m_device
Definition lci_binding_post.hpp:1818
error_t operator()() const
Definition lci_binding_post.hpp:1831
progress_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1825
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:1827
The actual implementation for put_upacket.
Definition lci_binding_post.hpp:447
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:451
void * m_packet
Definition lci_binding_post.hpp:450
void call() const
Definition binding.cpp:293
void operator()() const
Definition lci_binding_post.hpp:462
put_upacket_x && packet(void *packet_in)
Definition lci_binding_post.hpp:457
put_upacket_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:458
put_upacket_x(void *packet_in)
Definition lci_binding_post.hpp:454
void call_impl(void *packet, runtime_t runtime) const
The actual implementation for reduce_scatter.
Definition lci_binding_post.hpp:1072
reduce_scatter_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:1093
reduce_scatter_x && item_size(size_t item_size_in)
Definition lci_binding_post.hpp:1095
reduce_scatter_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1100
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:1086
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1082
reduce_scatter_x && device(device_t device_in)
Definition lci_binding_post.hpp:1098
reduce_scatter_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:1092
reduce_scatter_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1101
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:1084
option_t< reduce_scatter_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:1085
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1080
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:1076
size_t m_item_size
Definition lci_binding_post.hpp:1078
const void * m_sendbuf
Definition lci_binding_post.hpp:1075
size_t m_recvcount
Definition lci_binding_post.hpp:1077
reduce_scatter_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:1096
void operator()() const
Definition lci_binding_post.hpp:1107
reduce_scatter_x && algorithm(reduce_scatter_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:1102
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1083
reduce_op_t m_op
Definition lci_binding_post.hpp:1079
void call() const
Definition binding.cpp:408
reduce_scatter_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1097
option_t< device_t > m_device
Definition lci_binding_post.hpp:1081
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:1089
reduce_scatter_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1099
reduce_scatter_x && recvcount(size_t recvcount_in)
Definition lci_binding_post.hpp:1094
reduce_scatter_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:1103
The actual implementation for reduce.
Definition lci_binding_post.hpp:1009
void operator()() const
Definition lci_binding_post.hpp:1040
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:1024
reduce_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:1031
reduce_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1036
reduce_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:1028
option_t< device_t > m_device
Definition lci_binding_post.hpp:1019
int m_root
Definition lci_binding_post.hpp:1017
size_t m_count
Definition lci_binding_post.hpp:1014
reduce_x && count(size_t count_in)
Definition lci_binding_post.hpp:1029
reduce_op_t m_op
Definition lci_binding_post.hpp:1016
reduce_x && device(device_t device_in)
Definition lci_binding_post.hpp:1034
size_t m_item_size
Definition lci_binding_post.hpp:1015
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:1020
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:1013
reduce_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:1027
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:1021
reduce_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1033
reduce_x && item_size(size_t item_size_in)
Definition lci_binding_post.hpp:1030
reduce_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:1035
reduce_x && root(int root_in)
Definition lci_binding_post.hpp:1032
const void * m_sendbuf
Definition lci_binding_post.hpp:1012
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1018
void call() const
Definition binding.cpp:394
The actual implementation for register_memory.
Definition lci_binding_post.hpp:2164
register_memory_x && address(void *address_in)
Definition lci_binding_post.hpp:2176
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2169
register_memory_x && device(device_t device_in)
Definition lci_binding_post.hpp:2179
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:2177
option_t< device_t > m_device
Definition lci_binding_post.hpp:2170
void * m_address
Definition lci_binding_post.hpp:2167
mr_t operator()() const
Definition lci_binding_post.hpp:2183
register_memory_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2178
register_memory_x(void *address_in, size_t size_in)
Definition lci_binding_post.hpp:2173
size_t m_size
Definition lci_binding_post.hpp:2168
mr_t call() const
Definition binding.cpp:706
The actual implementation for register_packet_pool.
Definition lci_binding_post.hpp:331
device_t m_device
Definition lci_binding_post.hpp:335
void call_impl(packet_pool_t packet_pool, device_t device, runtime_t runtime) const
void operator()() const
Definition lci_binding_post.hpp:348
register_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:339
register_packet_pool_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:342
void call() const
Definition binding.cpp:273
register_packet_pool_x && device(device_t device_in)
Definition lci_binding_post.hpp:343
packet_pool_t m_packet_pool
Definition lci_binding_post.hpp:334
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:336
register_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:344
The actual implementation for register_rcomp.
Definition lci_binding_post.hpp:2984
rcomp_t call() const
Definition binding.cpp:886
rcomp_t operator()() const
Definition lci_binding_post.hpp:3001
comp_t m_comp
Definition lci_binding_post.hpp:2987
option_t< rcomp_t > m_rcomp
Definition lci_binding_post.hpp:2989
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2988
register_rcomp_x && rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:2997
register_rcomp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2996
register_rcomp_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2995
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:2992
The actual implementation for reserve_rcomps.
Definition lci_binding_post.hpp:2946
rcomp_t call_impl(rcomp_t n, runtime_t runtime) const
rcomp_t m_n
Definition lci_binding_post.hpp:2949
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2950
reserve_rcomps_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2957
rcomp_t call() const
Definition binding.cpp:880
reserve_rcomps_x(rcomp_t n_in)
Definition lci_binding_post.hpp:2953
rcomp_t operator()() const
Definition lci_binding_post.hpp:2961
reserve_rcomps_x && n(rcomp_t n_in)
Definition lci_binding_post.hpp:2956
The actual implementation for RESOURCE runtime.
Definition lci_binding_pre.hpp:231
The actual implementation for set_allocator.
Definition lci_binding_post.hpp:610
set_allocator_x(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:617
set_allocator_x && allocator(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:620
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:614
void call_impl(allocator_base_t *allocator, runtime_t runtime) const
set_allocator_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:621
void call() const
Definition binding.cpp:327
allocator_base_t * m_allocator
Definition lci_binding_post.hpp:613
void operator()() const
Definition lci_binding_post.hpp:625
The actual implementation for sync_test.
Definition lci_binding_post.hpp:3107
comp_t m_comp
Definition lci_binding_post.hpp:3110
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:3119
status_t * m_p_out
Definition lci_binding_post.hpp:3111
sync_test_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3120
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3112
bool operator()() const
Definition lci_binding_post.hpp:3124
sync_test_x(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:3115
sync_test_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3118
bool call() const
Definition binding.cpp:908
The actual implementation for sync_wait.
Definition lci_binding_post.hpp:3149
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3154
sync_wait_x(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:3159
comp_t m_comp
Definition lci_binding_post.hpp:3152
sync_wait_x && p_out(status_t *p_out_in)
Definition lci_binding_post.hpp:3163
option_t< device_t > m_device
Definition lci_binding_post.hpp:3156
sync_wait_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3164
void call() const
Definition binding.cpp:915
status_t * m_p_out
Definition lci_binding_post.hpp:3153
option_t< bool > m_do_progress
Definition lci_binding_post.hpp:3155
sync_wait_x && device(device_t device_in)
Definition lci_binding_post.hpp:3166
sync_wait_x && do_progress(bool do_progress_in)
Definition lci_binding_post.hpp:3165
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:3170
sync_wait_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:3162
The actual implementation for test_drained.
Definition lci_binding_post.hpp:1853
option_t< device_t > m_device
Definition lci_binding_post.hpp:1857
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1856
test_drained_x()
Definition lci_binding_post.hpp:1860
error_t operator()() const
Definition lci_binding_post.hpp:1868
test_drained_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1863
test_drained_x && device(device_t device_in)
Definition lci_binding_post.hpp:1864
error_t call() const
Definition binding.cpp:602
error_t call_impl(runtime_t runtime, device_t device) const
The actual implementation for wait_drained.
Definition lci_binding_post.hpp:1890
option_t< device_t > m_device
Definition lci_binding_post.hpp:1894
void operator()() const
Definition lci_binding_post.hpp:1905
wait_drained_x()
Definition lci_binding_post.hpp:1897
void call() const
Definition binding.cpp:608
void call_impl(runtime_t runtime, device_t device) const
wait_drained_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1900
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1893
wait_drained_x && device(device_t device_in)
Definition lci_binding_post.hpp:1901
broadcast_algorithm_t
The type of broadcast algorithm.
Definition lci.hpp:263
void(*)(status_t status, void *src_value, void *dst_value) graph_edge_run_cb_t
The function signature for a edge funciton in the completion graph.
Definition lci.hpp:618
uint64_t matching_entry_key_t
The type of matching engine entry key.
Definition lci.hpp:444
status_t(*)(void *value) graph_node_run_cb_t
The function signature for a node function in the completion graph.
Definition lci.hpp:597
direction_t
The enum class of comunication direction.
Definition lci.hpp:394
void(*)(void *value) graph_node_free_cb_t
The function signature for a callback that will be triggered when the node was freed.
Definition lci.hpp:612
void(*)(const void *left, const void *right, void *dst, size_t n) reduce_op_t
The user-defined reduction operation.
Definition lci.hpp:577
matching_policy_t
Enum class for matching policy.
Definition lci.hpp:433
void * graph_node_t
The node type for the completion graph.
Definition lci.hpp:583
allreduce_algorithm_t
The type of allreduce algorithm.
Definition lci.hpp:299
reduce_scatter_algorithm_t
The type of reduce scatter algorithm.
Definition lci.hpp:281
void * matching_entry_val_t
The type of matching engine entry value.
Definition lci.hpp:449
matching_entry_type_t
The type of matching entry.
Definition lci.hpp:424
uint32_t rcomp_t
The type of remote completion handler.
Definition lci.hpp:405
void(*)(status_t status) comp_handler_t
Function Signature for completion handler.
Definition lci.hpp:570
uint64_t tag_t
The type of tag.
Definition lci.hpp:388
comp_semantic_t
The enum class of completion semantic.
Definition lci.hpp:459
uint32_t net_imm_data_t
The type of network-layer immediate data field.
Definition lci.hpp:318
All LCI API functions and classes are defined in this namespace.
status_t post_comm(direction_t direction_in, int rank_in, void *local_buffer_in, size_t size_in, comp_t local_comp_in)
Definition lci_binding_post.hpp:1381
error_t net_post_send(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:2545
void graph_node_mark_complete(graph_node_t node_in)
Definition lci_binding_post.hpp:3597
size_t get_max_bcopy_size()
Definition lci_binding_post.hpp:872
attr_matching_engine_type_t
Definition lci_binding_pre.hpp:34
void broadcast(void *buffer_in, size_t size_in, int root_in)
Definition lci_binding_post.hpp:982
device_t alloc_device()
Definition lci_binding_post.hpp:2106
net_context_t alloc_net_context()
Definition lci_binding_post.hpp:1978
void free_net_context(net_context_t *net_context_in)
Definition lci_binding_post.hpp:2015
error_t net_post_recv(void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:2432
attr_backend_t
Definition lci.hpp:66
void deregister_rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:3041
void deregister_memory(mr_t *mr_in)
Definition lci_binding_post.hpp:2223
comp_t alloc_counter()
Definition lci_binding_post.hpp:3213
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:1460
matching_entry_val_t matching_engine_insert(matching_engine_t matching_engine_in, matching_entry_key_t key_in, matching_entry_val_t value_in, matching_entry_type_t entry_type_in)
Definition lci_binding_post.hpp:591
void wait_drained()
Definition lci_binding_post.hpp:1908
rcomp_t reserve_rcomps(rcomp_t n_in)
Definition lci_binding_post.hpp:2964
void sync_wait(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:3173
matching_engine_t alloc_matching_engine()
Definition lci_binding_post.hpp:508
error_t net_post_putImms(int rank_in, void *buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in)
Definition lci_binding_post.hpp:2725
void alltoall(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:1287
status_t graph_test(comp_t comp_in)
Definition lci_binding_post.hpp:3671
void register_packet_pool(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:351
matching_engine_t get_default_matching_engine()
Definition lci_binding_post.hpp:835
status_t cq_pop(comp_t comp_in)
Definition lci_binding_post.hpp:3376
size_t net_poll_cq(size_t max_polls_in, net_status_t *statuses_in)
Definition lci_binding_post.hpp:2383
attr_rdv_protocol_t
Definition lci_binding_pre.hpp:28
void graph_start(comp_t comp_in)
Definition lci_binding_post.hpp:3634
void free_matching_engine(matching_engine_t *matching_engine_in)
Definition lci_binding_post.hpp:545
void put_upacket(void *packet_in)
Definition lci_binding_post.hpp:465
comp_t alloc_cq()
Definition lci_binding_post.hpp:3339
void g_runtime_fina()
Definition lci_binding_post.hpp:196
error_t net_post_puts(int rank_in, void *buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in)
Definition lci_binding_post.hpp:2603
rcomp_t register_rcomp(comp_t comp_in)
Definition lci_binding_post.hpp:3004
error_t net_post_sends(int rank_in, void *buffer_in, size_t size_in)
Definition lci_binding_post.hpp:2487
void graph_add_edge(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in)
Definition lci_binding_post.hpp:3557
void set_allocator(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:628
allocator_base_t * get_allocator()
Definition lci_binding_post.hpp:662
net_context_t get_default_net_context()
Definition lci_binding_post.hpp:696
void free_device(device_t *device_in)
Definition lci_binding_post.hpp:2143
void free_comp(comp_t *comp_in)
Definition lci_binding_post.hpp:2887
packet_pool_t get_default_packet_pool()
Definition lci_binding_post.hpp:801
void free_runtime(runtime_t *runtime_in)
Definition lci_binding_post.hpp:103
comp_t alloc_handler(comp_handler_t handler_in)
Definition lci_binding_post.hpp:3422
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:2789
runtime_t get_g_runtime()
Definition lci_binding_post.hpp:228
void free_packet_pool(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:311
void reduce(const void *sendbuf_in, void *recvbuf_in, size_t count_in, size_t item_size_in, reduce_op_t op_in, int root_in)
Definition lci_binding_post.hpp:1043
void deregister_packet_pool(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:391
runtime_t g_runtime_init()
Definition lci_binding_post.hpp:164
void counter_set(comp_t comp_in, int64_t value_in)
Definition lci_binding_post.hpp:3290
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:1542
void comp_signal(comp_t comp_in, status_t status_in)
Definition lci_binding_post.hpp:2927
mr_t register_memory(void *address_in, size_t size_in)
Definition lci_binding_post.hpp:2186
rmr_t get_rmr(mr_t mr_in)
Definition lci_binding_post.hpp:2260
endpoint_t alloc_endpoint()
Definition lci_binding_post.hpp:2303
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:1709
endpoint_t get_default_endpoint()
Definition lci_binding_post.hpp:767
void allreduce(const void *sendbuf_in, void *recvbuf_in, size_t count_in, size_t item_size_in, reduce_op_t op_in)
Definition lci_binding_post.hpp:1177
graph_node_t graph_add_node(comp_t comp_in, graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:3511
runtime_t alloc_runtime()
Definition lci_binding_post.hpp:69
void allgather(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:1229
bool sync_test(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:3127
attr_ibv_td_strategy_t
Definition lci_binding_pre.hpp:52
error_t progress()
Definition lci_binding_post.hpp:1834
attr_ibv_odp_strategy_t
Definition lci_binding_pre.hpp:39
error_t test_drained()
Definition lci_binding_post.hpp:1871
device_t get_default_device()
Definition lci_binding_post.hpp:730
int64_t counter_get(comp_t comp_in)
Definition lci_binding_post.hpp:3250
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:1110
packet_pool_t alloc_packet_pool()
Definition lci_binding_post.hpp:274
attr_ibv_prefetch_strategy_t
Definition lci_binding_pre.hpp:45
void barrier()
Definition lci_binding_post.hpp:921
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:2850
attr_cq_type_t
Definition lci_binding_pre.hpp:67
comp_t alloc_graph()
Definition lci_binding_post.hpp:3465
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:1624
void * get_upacket()
Definition lci_binding_post.hpp:428
error_t net_post_put(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in, uint64_t offset_in, rmr_t rmr_in)
Definition lci_binding_post.hpp:2664
comp_t alloc_sync()
Definition lci_binding_post.hpp:3087
void free_endpoint(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:2340
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:1794
The user-defined allocator type.
Definition lci.hpp:468
Wrapper class for error code.
Definition lci.hpp:193
The struct for network status.
Definition lci.hpp:329
Definition lci.hpp:85
The type of remote memory region.
Definition lci.hpp:367
The type of the completion desciptor for a posted communication.
Definition lci.hpp:484