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_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
54 inline alloc_net_context_x&& backend(attr_backend_t backend_in) { m_backend = backend_in; return std::move(*this); }
55 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); }
56 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); }
57 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); }
58 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); }
59 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); }
60 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); }
61 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); }
62 inline alloc_net_context_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
63
65 net_context_t call() const;
66 inline net_context_t operator()() const { return call(); }
67};
68
72
73
83
89 public:
90 // args declaration
93
94 // constructor
95 free_net_context_x(net_context_t* net_context_in) : m_net_context(net_context_in) {}
96
97 // setter
98 inline free_net_context_x&& net_context(net_context_t* net_context_in) { m_net_context = net_context_in; return std::move(*this); }
99 inline free_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
100
102 void call() const;
103 inline void operator()() const { return call(); }
104};
105
106inline void free_net_context(net_context_t* net_context_in) {
107 return free_net_context_x(net_context_in).call();
108}
109
110
128
134 public:
135 // args declaration
146
147 // constructor
149
150 // setter
151 inline alloc_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
152 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); }
153 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); }
154 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); }
155 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); }
156 inline alloc_device_x&& alloc_default_endpoint(bool alloc_default_endpoint_in) { m_alloc_default_endpoint = alloc_default_endpoint_in; return std::move(*this); }
157 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); }
158 inline alloc_device_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
159 inline alloc_device_x&& net_context(net_context_t net_context_in) { m_net_context = net_context_in; return std::move(*this); }
160 inline alloc_device_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
161
163 device_t call() const;
164 inline device_t operator()() const { return call(); }
165};
166
168 return alloc_device_x().call();
169}
170
171
181
187 public:
188 // args declaration
191
192 // constructor
193 free_device_x(device_t* device_in) : m_device(device_in) {}
194
195 // setter
196 inline free_device_x&& device(device_t* device_in) { m_device = device_in; return std::move(*this); }
197 inline free_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
198
200 void call() const;
201 inline void operator()() const { return call(); }
202};
203
204inline void free_device(device_t* device_in) {
205 return free_device_x(device_in).call();
206}
207
208
220
226 public:
227 // args declaration
229 size_t m_size;
232
233 // constructor
234 register_memory_x(void* address_in, size_t size_in) : m_address(address_in), m_size(size_in) {}
235
236 // setter
237 inline register_memory_x&& address(void* address_in) { m_address = address_in; return std::move(*this); }
238 inline register_memory_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
239 inline register_memory_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
240 inline register_memory_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
241
243 mr_t call() const;
244 inline mr_t operator()() const { return call(); }
245};
246
247inline mr_t register_memory(void* address_in, size_t size_in) {
248 return register_memory_x(address_in, size_in).call();
249}
250
251
261
267 public:
268 // args declaration
271
272 // constructor
273 deregister_memory_x(mr_t* mr_in) : m_mr(mr_in) {}
274
275 // setter
276 inline deregister_memory_x&& mr(mr_t* mr_in) { m_mr = mr_in; return std::move(*this); }
277 inline deregister_memory_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
278
280 void call() const;
281 inline void operator()() const { return call(); }
282};
283
284inline void deregister_memory(mr_t* mr_in) {
285 return deregister_memory_x(mr_in).call();
286}
287
288
298
304 public:
305 // args declaration
308
309 // constructor
310 get_rmr_x(mr_t mr_in) : m_mr(mr_in) {}
311
312 // setter
313 inline get_rmr_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
314 inline get_rmr_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
315
317 rmr_t call() const;
318 inline rmr_t operator()() const { return call(); }
319};
320
321inline rmr_t get_rmr(mr_t mr_in) {
322 return get_rmr_x(mr_in).call();
323}
324
325
336
342 public:
343 // args declaration
347
348 // constructor
350
351 // setter
352 inline alloc_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
353 inline alloc_endpoint_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
354 inline alloc_endpoint_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
355
357 endpoint_t call() const;
358 inline endpoint_t operator()() const { return call(); }
359};
360
362 return alloc_endpoint_x().call();
363}
364
365
375
381 public:
382 // args declaration
385
386 // constructor
387 free_endpoint_x(endpoint_t* endpoint_in) : m_endpoint(endpoint_in) {}
388
389 // setter
390 inline free_endpoint_x&& endpoint(endpoint_t* endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
391 inline free_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
392
394 void call() const;
395 inline void operator()() const { return call(); }
396};
397
398inline void free_endpoint(endpoint_t* endpoint_in) {
399 return free_endpoint_x(endpoint_in).call();
400}
401
402
414
420 public:
421 // args declaration
426
427 // constructor
428 net_poll_cq_x(size_t max_polls_in, net_status_t* statuses_in) : m_max_polls(max_polls_in), m_statuses(statuses_in) {}
429
430 // setter
431 inline net_poll_cq_x&& max_polls(size_t max_polls_in) { m_max_polls = max_polls_in; return std::move(*this); }
432 inline net_poll_cq_x&& statuses(net_status_t* statuses_in) { m_statuses = statuses_in; return std::move(*this); }
433 inline net_poll_cq_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
434 inline net_poll_cq_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
435
437 size_t call() const;
438 inline size_t operator()() const { return call(); }
439};
440
441inline size_t net_poll_cq(size_t max_polls_in, net_status_t* statuses_in) {
442 return net_poll_cq_x(max_polls_in, statuses_in).call();
443}
444
445
459
465 public:
466 // args declaration
467 void* m_buffer;
468 size_t m_size;
473
474 // constructor
475 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) {}
476
477 // setter
478 inline net_post_recv_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
479 inline net_post_recv_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
480 inline net_post_recv_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
481 inline net_post_recv_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
482 inline net_post_recv_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
483 inline net_post_recv_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
484
486 error_t call() const;
487 inline error_t operator()() const { return call(); }
488};
489
490inline error_t net_post_recv(void* buffer_in, size_t size_in, mr_t mr_in) {
491 return net_post_recv_x(buffer_in, size_in, mr_in).call();
492}
493
494
509
515 public:
516 // args declaration
518 void* m_buffer;
519 size_t m_size;
524
525 // constructor
526 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) {}
527
528 // setter
529 inline net_post_sends_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
530 inline net_post_sends_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
531 inline net_post_sends_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
532 inline net_post_sends_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
533 inline net_post_sends_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
534 inline net_post_sends_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
535 inline net_post_sends_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
536
538 error_t call() const;
539 inline error_t operator()() const { return call(); }
540};
541
542inline error_t net_post_sends(int rank_in, void* buffer_in, size_t size_in) {
543 return net_post_sends_x(rank_in, buffer_in, size_in).call();
544}
545
546
563
569 public:
570 // args declaration
572 void* m_buffer;
573 size_t m_size;
580
581 // constructor
582 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) {}
583
584 // setter
585 inline net_post_send_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
586 inline net_post_send_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
587 inline net_post_send_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
588 inline net_post_send_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
589 inline net_post_send_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
590 inline net_post_send_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
591 inline net_post_send_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
592 inline net_post_send_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
593 inline net_post_send_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
594
596 error_t call() const;
597 inline error_t operator()() const { return call(); }
598};
599
600inline error_t net_post_send(int rank_in, void* buffer_in, size_t size_in, mr_t mr_in) {
601 return net_post_send_x(rank_in, buffer_in, size_in, mr_in).call();
602}
603
604
620
626 public:
627 // args declaration
629 void* m_buffer;
630 size_t m_size;
631 uint64_t m_offset;
636
637 // constructor
638 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) {}
639
640 // setter
641 inline net_post_puts_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
642 inline net_post_puts_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
643 inline net_post_puts_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
644 inline net_post_puts_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
645 inline net_post_puts_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
646 inline net_post_puts_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
647 inline net_post_puts_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
648 inline net_post_puts_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
649
651 error_t call() const;
652 inline error_t operator()() const { return call(); }
653};
654
655inline error_t net_post_puts(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) {
656 return net_post_puts_x(rank_in, buffer_in, size_in, offset_in, rmr_in).call();
657}
658
659
677
683 public:
684 // args declaration
686 void* m_buffer;
687 size_t m_size;
689 uint64_t m_offset;
695
696 // constructor
697 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) {}
698
699 // setter
700 inline net_post_put_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
701 inline net_post_put_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
702 inline net_post_put_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
703 inline net_post_put_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
704 inline net_post_put_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
705 inline net_post_put_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
706 inline net_post_put_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
707 inline net_post_put_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
708 inline net_post_put_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
709 inline net_post_put_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
710
712 error_t call() const;
713 inline error_t operator()() const { return call(); }
714};
715
716inline 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) {
717 return net_post_put_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
718}
719
720
737
743 public:
744 // args declaration
746 void* m_buffer;
747 size_t m_size;
748 uint64_t m_offset;
754
755 // constructor
756 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) {}
757
758 // setter
759 inline net_post_putImms_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
760 inline net_post_putImms_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
761 inline net_post_putImms_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
762 inline net_post_putImms_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
763 inline net_post_putImms_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
764 inline net_post_putImms_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
765 inline net_post_putImms_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
766 inline net_post_putImms_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
767 inline net_post_putImms_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
768
770 error_t call() const;
771 inline error_t operator()() const { return call(); }
772};
773
774inline error_t net_post_putImms(int rank_in, void* buffer_in, size_t size_in, uint64_t offset_in, rmr_t rmr_in) {
775 return net_post_putImms_x(rank_in, buffer_in, size_in, offset_in, rmr_in).call();
776}
777
778
797
803 public:
804 // args declaration
806 void* m_buffer;
807 size_t m_size;
809 uint64_t m_offset;
816
817 // constructor
818 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) {}
819
820 // setter
821 inline net_post_putImm_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
822 inline net_post_putImm_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
823 inline net_post_putImm_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
824 inline net_post_putImm_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
825 inline net_post_putImm_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
826 inline net_post_putImm_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
827 inline net_post_putImm_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
828 inline net_post_putImm_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
829 inline net_post_putImm_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
830 inline net_post_putImm_x&& imm_data(net_imm_data_t imm_data_in) { m_imm_data = imm_data_in; return std::move(*this); }
831 inline net_post_putImm_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
832
834 error_t call() const;
835 inline error_t operator()() const { return call(); }
836};
837
838inline 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) {
839 return net_post_putImm_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
840}
841
842
860
866 public:
867 // args declaration
869 void* m_buffer;
870 size_t m_size;
872 uint64_t m_offset;
878
879 // constructor
880 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) {}
881
882 // setter
883 inline net_post_get_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
884 inline net_post_get_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
885 inline net_post_get_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
886 inline net_post_get_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
887 inline net_post_get_x&& offset(uint64_t offset_in) { m_offset = offset_in; return std::move(*this); }
888 inline net_post_get_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
889 inline net_post_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
890 inline net_post_get_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
891 inline net_post_get_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
892 inline net_post_get_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
893
895 error_t call() const;
896 inline error_t operator()() const { return call(); }
897};
898
899inline 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) {
900 return net_post_get_x(rank_in, buffer_in, size_in, mr_in, offset_in, rmr_in).call();
901}
902
903
912
918 public:
919 // args declaration
920
921 // constructor
923
924 // setter
925
926 int call_impl() const;
927 int call() const;
928 inline int operator()() const { return call(); }
929};
930
931inline int get_rank_me() {
932 return get_rank_me_x().call();
933}
934
935
944
950 public:
951 // args declaration
952
953 // constructor
955
956 // setter
957
958 int call_impl() const;
959 int call() const;
960 inline int operator()() const { return call(); }
961};
962
963inline int get_rank_n() {
964 return get_rank_n_x().call();
965}
966
967
982
988 public:
989 // args declaration
997
998 // constructor
1000
1001 // setter
1002 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); }
1003 inline alloc_runtime_x&& imm_nbits_tag(int imm_nbits_tag_in) { m_imm_nbits_tag = imm_nbits_tag_in; return std::move(*this); }
1004 inline alloc_runtime_x&& imm_nbits_rcomp(int imm_nbits_rcomp_in) { m_imm_nbits_rcomp = imm_nbits_rcomp_in; return std::move(*this); }
1005 inline alloc_runtime_x&& alloc_default_device(bool alloc_default_device_in) { m_alloc_default_device = alloc_default_device_in; return std::move(*this); }
1006 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); }
1007 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); }
1008 inline alloc_runtime_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1009
1011 runtime_t call() const;
1012 inline runtime_t operator()() const { return call(); }
1013};
1014
1016 return alloc_runtime_x().call();
1017}
1018
1019
1028
1034 public:
1035 // args declaration
1037
1038 // constructor
1039 free_runtime_x(runtime_t* runtime_in) : m_runtime(runtime_in) {}
1040
1041 // setter
1042 inline free_runtime_x&& runtime(runtime_t* runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1043
1045 void call() const;
1046 inline void operator()() const { return call(); }
1047};
1048
1049inline void free_runtime(runtime_t* runtime_in) {
1050 return free_runtime_x(runtime_in).call();
1051}
1052
1053
1067
1073 public:
1074 // args declaration
1081
1082 // constructor
1084
1085 // setter
1086 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); }
1087 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); }
1088 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); }
1089 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); }
1090 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); }
1091 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); }
1092
1094 void call() const;
1095 inline void operator()() const { return call(); }
1096};
1097
1098inline void g_runtime_init() {
1099 return g_runtime_init_x().call();
1100}
1101
1102
1111
1117 public:
1118 // args declaration
1119
1120 // constructor
1122
1123 // setter
1124
1125 void call_impl() const;
1126 void call() const;
1127 inline void operator()() const { return call(); }
1128};
1129
1130inline void g_runtime_fina() {
1131 return g_runtime_fina_x().call();
1132}
1133
1134
1143
1149 public:
1150 // args declaration
1151
1152 // constructor
1154
1155 // setter
1156
1158 runtime_t call() const;
1159 inline runtime_t operator()() const { return call(); }
1160};
1161
1163 return get_g_runtime_x().call();
1164}
1165
1166
1178
1184 public:
1185 // args declaration
1190
1191 // constructor
1193
1194 // setter
1195 inline alloc_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1196 inline alloc_packet_pool_x&& packet_size(size_t packet_size_in) { m_packet_size = packet_size_in; return std::move(*this); }
1197 inline alloc_packet_pool_x&& npackets(size_t npackets_in) { m_npackets = npackets_in; return std::move(*this); }
1198 inline alloc_packet_pool_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1199
1201 packet_pool_t call() const;
1202 inline packet_pool_t operator()() const { return call(); }
1203};
1204
1208
1209
1219
1225 public:
1226 // args declaration
1229
1230 // constructor
1231 free_packet_pool_x(packet_pool_t* packet_pool_in) : m_packet_pool(packet_pool_in) {}
1232
1233 // setter
1234 inline free_packet_pool_x&& packet_pool(packet_pool_t* packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1235 inline free_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1236
1238 void call() const;
1239 inline void operator()() const { return call(); }
1240};
1241
1242inline void free_packet_pool(packet_pool_t* packet_pool_in) {
1243 return free_packet_pool_x(packet_pool_in).call();
1244}
1245
1246
1257
1263 public:
1264 // args declaration
1268
1269 // constructor
1270 register_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in) : m_packet_pool(packet_pool_in), m_device(device_in) {}
1271
1272 // setter
1273 inline register_packet_pool_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1274 inline register_packet_pool_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1275 inline register_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1276
1278 void call() const;
1279 inline void operator()() const { return call(); }
1280};
1281
1282inline void register_packet_pool(packet_pool_t packet_pool_in, device_t device_in) {
1283 return register_packet_pool_x(packet_pool_in, device_in).call();
1284}
1285
1286
1297
1303 public:
1304 // args declaration
1308
1309 // constructor
1310 deregister_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in) : m_packet_pool(packet_pool_in), m_device(device_in) {}
1311
1312 // setter
1313 inline deregister_packet_pool_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1314 inline deregister_packet_pool_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1315 inline deregister_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1316
1318 void call() const;
1319 inline void operator()() const { return call(); }
1320};
1321
1322inline void deregister_packet_pool(packet_pool_t packet_pool_in, device_t device_in) {
1323 return deregister_packet_pool_x(packet_pool_in, device_in).call();
1324}
1325
1326
1336
1342 public:
1343 // args declaration
1346
1347 // constructor
1349
1350 // setter
1351 inline get_upacket_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1352 inline get_upacket_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1353
1355 void* call() const;
1356 inline void* operator()() const { return call(); }
1357};
1358
1359inline void* get_upacket() {
1360 return get_upacket_x().call();
1361}
1362
1363
1373
1379 public:
1380 // args declaration
1383
1384 // constructor
1385 put_upacket_x(void* packet_in) : m_packet(packet_in) {}
1386
1387 // setter
1388 inline put_upacket_x&& packet(void* packet_in) { m_packet = packet_in; return std::move(*this); }
1389 inline put_upacket_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1390
1391 void call_impl(void* packet, runtime_t runtime) const;
1392 void call() const;
1393 inline void operator()() const { return call(); }
1394};
1395
1396inline void put_upacket(void* packet_in) {
1397 return put_upacket_x(packet_in).call();
1398}
1399
1400
1411
1417 public:
1418 // args declaration
1422
1423 // constructor
1425
1426 // setter
1427 inline alloc_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1428 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); }
1429 inline alloc_matching_engine_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
1430
1432 matching_engine_t call() const;
1433 inline matching_engine_t operator()() const { return call(); }
1434};
1435
1439
1440
1450
1456 public:
1457 // args declaration
1460
1461 // constructor
1462 free_matching_engine_x(matching_engine_t* matching_engine_in) : m_matching_engine(matching_engine_in) {}
1463
1464 // setter
1465 inline free_matching_engine_x&& matching_engine(matching_engine_t* matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1466 inline free_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1467
1469 void call() const;
1470 inline void operator()() const { return call(); }
1471};
1472
1473inline void free_matching_engine(matching_engine_t* matching_engine_in) {
1474 return free_matching_engine_x(matching_engine_in).call();
1475}
1476
1477
1490
1496 public:
1497 // args declaration
1503
1504 // constructor
1505 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) {}
1506
1507 // setter
1508 inline matching_engine_insert_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
1509 inline matching_engine_insert_x&& key(matching_entry_key_t key_in) { m_key = key_in; return std::move(*this); }
1510 inline matching_engine_insert_x&& value(matching_entry_val_t value_in) { m_value = value_in; return std::move(*this); }
1511 inline matching_engine_insert_x&& entry_type(matching_entry_type_t entry_type_in) { m_entry_type = entry_type_in; return std::move(*this); }
1512 inline matching_engine_insert_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1513
1515 matching_entry_val_t call() const;
1516 inline matching_entry_val_t operator()() const { return call(); }
1517};
1518
1520 return matching_engine_insert_x(matching_engine_in, key_in, value_in, entry_type_in).call();
1521}
1522
1523
1533
1539 public:
1540 // args declaration
1543
1544 // constructor
1545 set_allocator_x(allocator_base_t* allocator_in) : m_allocator(allocator_in) {}
1546
1547 // setter
1548 inline set_allocator_x&& allocator(allocator_base_t* allocator_in) { m_allocator = allocator_in; return std::move(*this); }
1549 inline set_allocator_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1550
1552 void call() const;
1553 inline void operator()() const { return call(); }
1554};
1555
1556inline void set_allocator(allocator_base_t* allocator_in) {
1557 return set_allocator_x(allocator_in).call();
1558}
1559
1560
1569
1575 public:
1576 // args declaration
1578
1579 // constructor
1581
1582 // setter
1583 inline get_allocator_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1584
1586 allocator_base_t* call() const;
1587 inline allocator_base_t* operator()() const { return call(); }
1588};
1589
1591 return get_allocator_x().call();
1592}
1593
1594
1603
1609 public:
1610 // args declaration
1612
1613 // constructor
1615
1616 // setter
1617 inline get_default_net_context_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1618
1620 net_context_t call() const;
1621 inline net_context_t operator()() const { return call(); }
1622};
1623
1627
1628
1637
1643 public:
1644 // args declaration
1646
1647 // constructor
1649
1650 // setter
1651 inline get_default_device_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1652
1654 device_t call() const;
1655 inline device_t operator()() const { return call(); }
1656};
1657
1659 return get_default_device_x().call();
1660}
1661
1662
1672
1678 public:
1679 // args declaration
1682
1683 // constructor
1685
1686 // setter
1687 inline get_default_endpoint_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1688 inline get_default_endpoint_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
1689
1691 endpoint_t call() const;
1692 inline endpoint_t operator()() const { return call(); }
1693};
1694
1698
1699
1708
1714 public:
1715 // args declaration
1717
1718 // constructor
1720
1721 // setter
1722 inline get_default_packet_pool_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1723
1725 packet_pool_t call() const;
1726 inline packet_pool_t operator()() const { return call(); }
1727};
1728
1732
1733
1742
1748 public:
1749 // args declaration
1751
1752 // constructor
1754
1755 // setter
1756 inline get_default_matching_engine_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1757
1759 matching_engine_t call() const;
1760 inline matching_engine_t operator()() const { return call(); }
1761};
1762
1766
1767
1777
1783 public:
1784 // args declaration
1787
1788 // constructor
1790
1791 // setter
1792 inline get_max_bcopy_size_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1793 inline get_max_bcopy_size_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
1794
1796 size_t call() const;
1797 inline size_t operator()() const { return call(); }
1798};
1799
1800inline size_t get_max_bcopy_size() {
1801 return get_max_bcopy_size_x().call();
1802}
1803
1804
1814
1820 public:
1821 // args declaration
1824
1825 // constructor
1826 free_comp_x(comp_t* comp_in) : m_comp(comp_in) {}
1827
1828 // setter
1829 inline free_comp_x&& comp(comp_t* comp_in) { m_comp = comp_in; return std::move(*this); }
1830 inline free_comp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1831
1833 void call() const;
1834 inline void operator()() const { return call(); }
1835};
1836
1837inline void free_comp(comp_t* comp_in) {
1838 return free_comp_x(comp_in).call();
1839}
1840
1841
1852
1858 public:
1859 // args declaration
1863
1864 // constructor
1865 comp_signal_x(comp_t comp_in, status_t status_in) : m_comp(comp_in), m_status(status_in) {}
1866
1867 // setter
1868 inline comp_signal_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1869 inline comp_signal_x&& status(status_t status_in) { m_status = status_in; return std::move(*this); }
1870 inline comp_signal_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1871
1873 void call() const;
1874 inline void operator()() const { return call(); }
1875};
1876
1877inline void comp_signal(comp_t comp_in, status_t status_in) {
1878 return comp_signal_x(comp_in, status_in).call();
1879}
1880
1881
1891
1897 public:
1898 // args declaration
1901
1902 // constructor
1904
1905 // setter
1906 inline reserve_rcomps_x&& n(rcomp_t n_in) { m_n = n_in; return std::move(*this); }
1907 inline reserve_rcomps_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1908
1910 rcomp_t call() const;
1911 inline rcomp_t operator()() const { return call(); }
1912};
1913
1915 return reserve_rcomps_x(n_in).call();
1916}
1917
1918
1929
1935 public:
1936 // args declaration
1940
1941 // constructor
1942 register_rcomp_x(comp_t comp_in) : m_comp(comp_in) {}
1943
1944 // setter
1945 inline register_rcomp_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
1946 inline register_rcomp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1947 inline register_rcomp_x&& rcomp(rcomp_t rcomp_in) { m_rcomp = rcomp_in; return std::move(*this); }
1948
1950 rcomp_t call() const;
1951 inline rcomp_t operator()() const { return call(); }
1952};
1953
1955 return register_rcomp_x(comp_in).call();
1956}
1957
1958
1968
1974 public:
1975 // args declaration
1978
1979 // constructor
1980 deregister_rcomp_x(rcomp_t rcomp_in) : m_rcomp(rcomp_in) {}
1981
1982 // setter
1983 inline deregister_rcomp_x&& rcomp(rcomp_t rcomp_in) { m_rcomp = rcomp_in; return std::move(*this); }
1984 inline deregister_rcomp_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
1985
1987 void call() const;
1988 inline void operator()() const { return call(); }
1989};
1990
1991inline void deregister_rcomp(rcomp_t rcomp_in) {
1992 return deregister_rcomp_x(rcomp_in).call();
1993}
1994
1995
2007
2013 public:
2014 // args declaration
2019
2020 // constructor
2022
2023 // setter
2024 inline alloc_sync_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2025 inline alloc_sync_x&& threshold(int threshold_in) { m_threshold = threshold_in; return std::move(*this); }
2026 inline alloc_sync_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
2027 inline alloc_sync_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2028
2030 comp_t call() const;
2031 inline comp_t operator()() const { return call(); }
2032};
2033
2035 return alloc_sync_x().call();
2036}
2037
2038
2049
2055 public:
2056 // args declaration
2060
2061 // constructor
2062 sync_test_x(comp_t comp_in, status_t* p_out_in) : m_comp(comp_in), m_p_out(p_out_in) {}
2063
2064 // setter
2065 inline sync_test_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2066 inline sync_test_x&& p_out(status_t* p_out_in) { m_p_out = p_out_in; return std::move(*this); }
2067 inline sync_test_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2068
2070 bool call() const;
2071 inline bool operator()() const { return call(); }
2072};
2073
2074inline bool sync_test(comp_t comp_in, status_t* p_out_in) {
2075 return sync_test_x(comp_in, p_out_in).call();
2076}
2077
2078
2091
2097 public:
2098 // args declaration
2104
2105 // constructor
2106 sync_wait_x(comp_t comp_in, status_t* p_out_in) : m_comp(comp_in), m_p_out(p_out_in) {}
2107
2108 // setter
2109 inline sync_wait_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2110 inline sync_wait_x&& p_out(status_t* p_out_in) { m_p_out = p_out_in; return std::move(*this); }
2111 inline sync_wait_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2112 inline sync_wait_x&& do_progress(bool do_progress_in) { m_do_progress = do_progress_in; return std::move(*this); }
2113 inline sync_wait_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2114
2116 void call() const;
2117 inline void operator()() const { return call(); }
2118};
2119
2120inline void sync_wait(comp_t comp_in, status_t* p_out_in) {
2121 return sync_wait_x(comp_in, p_out_in).call();
2122}
2123
2124
2133
2139 public:
2140 // args declaration
2142
2143 // constructor
2145
2146 // setter
2147 inline alloc_counter_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2148
2150 comp_t call() const;
2151 inline comp_t operator()() const { return call(); }
2152};
2153
2155 return alloc_counter_x().call();
2156}
2157
2158
2168
2174 public:
2175 // args declaration
2178
2179 // constructor
2180 counter_get_x(comp_t comp_in) : m_comp(comp_in) {}
2181
2182 // setter
2183 inline counter_get_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2184 inline counter_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2185
2187 int64_t call() const;
2188 inline int64_t operator()() const { return call(); }
2189};
2190
2191inline int64_t counter_get(comp_t comp_in) {
2192 return counter_get_x(comp_in).call();
2193}
2194
2195
2206
2212 public:
2213 // args declaration
2215 int64_t m_value;
2217
2218 // constructor
2219 counter_set_x(comp_t comp_in, int64_t value_in) : m_comp(comp_in), m_value(value_in) {}
2220
2221 // setter
2222 inline counter_set_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2223 inline counter_set_x&& value(int64_t value_in) { m_value = value_in; return std::move(*this); }
2224 inline counter_set_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2225
2227 void call() const;
2228 inline void operator()() const { return call(); }
2229};
2230
2231inline void counter_set(comp_t comp_in, int64_t value_in) {
2232 return counter_set_x(comp_in, value_in).call();
2233}
2234
2235
2248
2254 public:
2255 // args declaration
2261
2262 // constructor
2264
2265 // setter
2266 inline alloc_cq_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2267 inline alloc_cq_x&& default_length(int default_length_in) { m_default_length = default_length_in; return std::move(*this); }
2268 inline alloc_cq_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
2269 inline alloc_cq_x&& cq_type(attr_cq_type_t cq_type_in) { m_cq_type = cq_type_in; return std::move(*this); }
2270 inline alloc_cq_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2271
2273 comp_t call() const;
2274 inline comp_t operator()() const { return call(); }
2275};
2276
2278 return alloc_cq_x().call();
2279}
2280
2281
2291
2297 public:
2298 // args declaration
2301
2302 // constructor
2303 cq_pop_x(comp_t comp_in) : m_comp(comp_in) {}
2304
2305 // setter
2306 inline cq_pop_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2307 inline cq_pop_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2308
2310 status_t call() const;
2311 inline status_t operator()() const { return call(); }
2312};
2313
2314inline status_t cq_pop(comp_t comp_in) {
2315 return cq_pop_x(comp_in).call();
2316}
2317
2318
2330
2336 public:
2337 // args declaration
2342
2343 // constructor
2344 alloc_handler_x(comp_handler_t handler_in) : m_handler(handler_in) {}
2345
2346 // setter
2347 inline alloc_handler_x&& handler(comp_handler_t handler_in) { m_handler = handler_in; return std::move(*this); }
2348 inline alloc_handler_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2349 inline alloc_handler_x&& zero_copy_am(bool zero_copy_am_in) { m_zero_copy_am = zero_copy_am_in; return std::move(*this); }
2350 inline alloc_handler_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2351
2353 comp_t call() const;
2354 inline comp_t operator()() const { return call(); }
2355};
2356
2358 return alloc_handler_x(handler_in).call();
2359}
2360
2361
2372
2378 public:
2379 // args declaration
2383
2384 // constructor
2386
2387 // setter
2388 inline alloc_graph_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2389 inline alloc_graph_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
2390 inline alloc_graph_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2391
2393 comp_t call() const;
2394 inline comp_t operator()() const { return call(); }
2395};
2396
2398 return alloc_graph_x().call();
2399}
2400
2401
2414
2420 public:
2421 // args declaration
2427
2428 // constructor
2429 graph_add_node_x(comp_t comp_in, graph_node_run_cb_t fn_in) : m_comp(comp_in), m_fn(fn_in) {}
2430
2431 // setter
2432 inline graph_add_node_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2433 inline graph_add_node_x&& fn(graph_node_run_cb_t fn_in) { m_fn = fn_in; return std::move(*this); }
2434 inline graph_add_node_x&& value(void* value_in) { m_value = value_in; return std::move(*this); }
2435 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); }
2436 inline graph_add_node_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2437
2439 graph_node_t call() const;
2440 inline graph_node_t operator()() const { return call(); }
2441};
2442
2444 return graph_add_node_x(comp_in, fn_in).call();
2445}
2446
2447
2460
2466 public:
2467 // args declaration
2473
2474 // constructor
2475 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) {}
2476
2477 // setter
2478 inline graph_add_edge_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2479 inline graph_add_edge_x&& src(graph_node_t src_in) { m_src = src_in; return std::move(*this); }
2480 inline graph_add_edge_x&& dst(graph_node_t dst_in) { m_dst = dst_in; return std::move(*this); }
2481 inline graph_add_edge_x&& fn(graph_edge_run_cb_t fn_in) { m_fn = fn_in; return std::move(*this); }
2482 inline graph_add_edge_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2483
2485 void call() const;
2486 inline void operator()() const { return call(); }
2487};
2488
2489inline void graph_add_edge(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in) {
2490 return graph_add_edge_x(comp_in, src_in, dst_in).call();
2491}
2492
2493
2504
2510 public:
2511 // args declaration
2515
2516 // constructor
2518
2519 // setter
2520 inline graph_node_mark_complete_x&& node(graph_node_t node_in) { m_node = node_in; return std::move(*this); }
2521 inline graph_node_mark_complete_x&& status(status_t status_in) { m_status = status_in; return std::move(*this); }
2522 inline graph_node_mark_complete_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2523
2525 void call() const;
2526 inline void operator()() const { return call(); }
2527};
2528
2530 return graph_node_mark_complete_x(node_in).call();
2531}
2532
2533
2543
2549 public:
2550 // args declaration
2553
2554 // constructor
2555 graph_start_x(comp_t comp_in) : m_comp(comp_in) {}
2556
2557 // setter
2558 inline graph_start_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2559 inline graph_start_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2560
2562 void call() const;
2563 inline void operator()() const { return call(); }
2564};
2565
2566inline void graph_start(comp_t comp_in) {
2567 return graph_start_x(comp_in).call();
2568}
2569
2570
2580
2586 public:
2587 // args declaration
2590
2591 // constructor
2592 graph_test_x(comp_t comp_in) : m_comp(comp_in) {}
2593
2594 // setter
2595 inline graph_test_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2596 inline graph_test_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2597
2599 status_t call() const;
2600 inline status_t operator()() const { return call(); }
2601};
2602
2603inline status_t graph_test(comp_t comp_in) {
2604 return graph_test_x(comp_in).call();
2605}
2606
2607
2621
2627 public:
2628 // args declaration
2635
2636 // constructor
2638
2639 // setter
2640 inline barrier_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2641 inline barrier_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2642 inline barrier_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2643 inline barrier_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2644 inline barrier_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
2645 inline barrier_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2646
2648 void call() const;
2649 inline void operator()() const { return call(); }
2650};
2651
2652inline void barrier() {
2653 return barrier_x().call();
2654}
2655
2656
2674
2680 public:
2681 // args declaration
2683 size_t m_size;
2692
2693 // constructor
2694 broadcast_x(void* buffer_in, size_t size_in, int root_in) : m_buffer(buffer_in), m_size(size_in), m_root(root_in) {}
2695
2696 // setter
2697 inline broadcast_x&& buffer(void* buffer_in) { m_buffer = buffer_in; return std::move(*this); }
2698 inline broadcast_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2699 inline broadcast_x&& root(int root_in) { m_root = root_in; return std::move(*this); }
2700 inline broadcast_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2701 inline broadcast_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2702 inline broadcast_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2703 inline broadcast_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2704 inline broadcast_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2705 inline broadcast_x&& algorithm(broadcast_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
2706 inline broadcast_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
2707
2709 void call() const;
2710 inline void operator()() const { return call(); }
2711};
2712
2713inline void broadcast(void* buffer_in, size_t size_in, int root_in) {
2714 return broadcast_x(buffer_in, size_in, root_in).call();
2715}
2716
2717
2735
2741 public:
2742 // args declaration
2743 const void* m_sendbuf;
2745 size_t m_count;
2753
2754 // constructor
2755 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) {}
2756
2757 // setter
2758 inline reduce_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2759 inline reduce_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2760 inline reduce_x&& count(size_t count_in) { m_count = count_in; return std::move(*this); }
2761 inline reduce_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
2762 inline reduce_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
2763 inline reduce_x&& root(int root_in) { m_root = root_in; return std::move(*this); }
2764 inline reduce_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2765 inline reduce_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2766 inline reduce_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2767 inline reduce_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2768
2770 void call() const;
2771 inline void operator()() const { return call(); }
2772};
2773
2774inline 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) {
2775 return reduce_x(sendbuf_in, recvbuf_in, count_in, item_size_in, op_in, root_in).call();
2776}
2777
2778
2798
2804 public:
2805 // args declaration
2806 const void* m_sendbuf;
2818
2819 // constructor
2820 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) {}
2821
2822 // setter
2823 inline reduce_scatter_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2824 inline reduce_scatter_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2825 inline reduce_scatter_x&& recvcount(size_t recvcount_in) { m_recvcount = recvcount_in; return std::move(*this); }
2826 inline reduce_scatter_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
2827 inline reduce_scatter_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
2828 inline reduce_scatter_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2829 inline reduce_scatter_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2830 inline reduce_scatter_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2831 inline reduce_scatter_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2832 inline reduce_scatter_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2833 inline reduce_scatter_x&& algorithm(reduce_scatter_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
2834 inline reduce_scatter_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
2835
2837 void call() const;
2838 inline void operator()() const { return call(); }
2839};
2840
2841inline void reduce_scatter(const void* sendbuf_in, void* recvbuf_in, size_t recvcount_in, size_t item_size_in, reduce_op_t op_in) {
2842 return reduce_scatter_x(sendbuf_in, recvbuf_in, recvcount_in, item_size_in, op_in).call();
2843}
2844
2845
2865
2871 public:
2872 // args declaration
2873 const void* m_sendbuf;
2875 size_t m_count;
2885
2886 // constructor
2887 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) {}
2888
2889 // setter
2890 inline allreduce_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2891 inline allreduce_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2892 inline allreduce_x&& count(size_t count_in) { m_count = count_in; return std::move(*this); }
2893 inline allreduce_x&& item_size(size_t item_size_in) { m_item_size = item_size_in; return std::move(*this); }
2894 inline allreduce_x&& op(reduce_op_t op_in) { m_op = op_in; return std::move(*this); }
2895 inline allreduce_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2896 inline allreduce_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2897 inline allreduce_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2898 inline allreduce_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2899 inline allreduce_x&& comp(comp_t comp_in) { m_comp = comp_in; return std::move(*this); }
2900 inline allreduce_x&& algorithm(allreduce_algorithm_t algorithm_in) { m_algorithm = algorithm_in; return std::move(*this); }
2901 inline allreduce_x&& ring_nsteps(int ring_nsteps_in) { m_ring_nsteps = ring_nsteps_in; return std::move(*this); }
2902
2904 void call() const;
2905 inline void operator()() const { return call(); }
2906};
2907
2908inline void allreduce(const void* sendbuf_in, void* recvbuf_in, size_t count_in, size_t item_size_in, reduce_op_t op_in) {
2909 return allreduce_x(sendbuf_in, recvbuf_in, count_in, item_size_in, op_in).call();
2910}
2911
2912
2927
2933 public:
2934 // args declaration
2935 const void* m_sendbuf;
2937 size_t m_size;
2942
2943 // constructor
2944 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) {}
2945
2946 // setter
2947 inline allgather_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
2948 inline allgather_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
2949 inline allgather_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
2950 inline allgather_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
2951 inline allgather_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
2952 inline allgather_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
2953 inline allgather_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
2954
2956 void call() const;
2957 inline void operator()() const { return call(); }
2958};
2959
2960inline void allgather(const void* sendbuf_in, void* recvbuf_in, size_t size_in) {
2961 return allgather_x(sendbuf_in, recvbuf_in, size_in).call();
2962}
2963
2964
2979
2985 public:
2986 // args declaration
2987 const void* m_sendbuf;
2989 size_t m_size;
2994
2995 // constructor
2996 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) {}
2997
2998 // setter
2999 inline alltoall_x&& sendbuf(const void* sendbuf_in) { m_sendbuf = sendbuf_in; return std::move(*this); }
3000 inline alltoall_x&& recvbuf(void* recvbuf_in) { m_recvbuf = recvbuf_in; return std::move(*this); }
3001 inline alltoall_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3002 inline alltoall_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3003 inline alltoall_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3004 inline alltoall_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3005 inline alltoall_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3006
3008 void call() const;
3009 inline void operator()() const { return call(); }
3010};
3011
3012inline void alltoall(const void* sendbuf_in, void* recvbuf_in, size_t size_in) {
3013 return alltoall_x(sendbuf_in, recvbuf_in, size_in).call();
3014}
3015
3016
3045
3051 public:
3052 // args declaration
3056 size_t m_size;
3074
3075 // constructor
3076 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) {}
3077
3078 // setter
3079 inline post_comm_x&& direction(direction_t direction_in) { m_direction = direction_in; return std::move(*this); }
3080 inline post_comm_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3081 inline post_comm_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3082 inline post_comm_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3083 inline post_comm_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3084 inline post_comm_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3085 inline post_comm_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3086 inline post_comm_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3087 inline post_comm_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3088 inline post_comm_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3089 inline post_comm_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3090 inline post_comm_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3091 inline post_comm_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
3092 inline post_comm_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
3093 inline post_comm_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3094 inline post_comm_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
3095 inline post_comm_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3096 inline post_comm_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
3097 inline post_comm_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3098 inline post_comm_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3099 inline post_comm_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3100
3102 status_t call() const;
3103 inline status_t operator()() const { return call(); }
3104};
3105
3106inline status_t post_comm(direction_t direction_in, int rank_in, void* local_buffer_in, size_t size_in, comp_t local_comp_in) {
3107 return post_comm_x(direction_in, rank_in, local_buffer_in, size_in, local_comp_in).call();
3108}
3109
3110
3134
3140 public:
3141 // args declaration
3144 size_t m_size;
3158
3159 // constructor
3160 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) {}
3161
3162 // setter
3163 inline post_am_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3164 inline post_am_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3165 inline post_am_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3166 inline post_am_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3167 inline post_am_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
3168 inline post_am_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3169 inline post_am_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3170 inline post_am_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3171 inline post_am_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3172 inline post_am_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3173 inline post_am_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3174 inline post_am_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3175 inline post_am_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3176 inline post_am_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3177 inline post_am_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3178 inline post_am_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3179
3181 status_t call() const;
3182 inline status_t operator()() const { return call(); }
3183};
3184
3185inline 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) {
3186 return post_am_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_comp_in).call();
3187}
3188
3189
3214
3220 public:
3221 // args declaration
3224 size_t m_size;
3239
3240 // constructor
3241 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) {}
3242
3243 // setter
3244 inline post_send_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3245 inline post_send_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3246 inline post_send_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3247 inline post_send_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3248 inline post_send_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3249 inline post_send_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3250 inline post_send_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3251 inline post_send_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3252 inline post_send_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3253 inline post_send_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3254 inline post_send_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3255 inline post_send_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3256 inline post_send_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3257 inline post_send_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
3258 inline post_send_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3259 inline post_send_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3260 inline post_send_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3261
3263 status_t call() const;
3264 inline status_t operator()() const { return call(); }
3265};
3266
3267inline status_t post_send(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) {
3268 return post_send_x(rank_in, local_buffer_in, size_in, tag_in, local_comp_in).call();
3269}
3270
3271
3295
3301 public:
3302 // args declaration
3305 size_t m_size;
3319
3320 // constructor
3321 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) {}
3322
3323 // setter
3324 inline post_recv_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3325 inline post_recv_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3326 inline post_recv_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3327 inline post_recv_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3328 inline post_recv_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3329 inline post_recv_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3330 inline post_recv_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3331 inline post_recv_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3332 inline post_recv_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3333 inline post_recv_x&& matching_engine(matching_engine_t matching_engine_in) { m_matching_engine = matching_engine_in; return std::move(*this); }
3334 inline post_recv_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3335 inline post_recv_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3336 inline post_recv_x&& matching_policy(matching_policy_t matching_policy_in) { m_matching_policy = matching_policy_in; return std::move(*this); }
3337 inline post_recv_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3338 inline post_recv_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3339 inline post_recv_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3340
3342 status_t call() const;
3343 inline status_t operator()() const { return call(); }
3344};
3345
3346inline status_t post_recv(int rank_in, void* local_buffer_in, size_t size_in, tag_t tag_in, comp_t local_comp_in) {
3347 return post_recv_x(rank_in, local_buffer_in, size_in, tag_in, local_comp_in).call();
3348}
3349
3350
3376
3382 public:
3383 // args declaration
3386 size_t m_size;
3388 uintptr_t m_remote_disp;
3402
3403 // constructor
3404 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) {}
3405
3406 // setter
3407 inline post_put_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3408 inline post_put_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3409 inline post_put_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3410 inline post_put_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3411 inline post_put_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
3412 inline post_put_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
3413 inline post_put_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3414 inline post_put_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3415 inline post_put_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3416 inline post_put_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3417 inline post_put_x&& comp_semantic(comp_semantic_t comp_semantic_in) { m_comp_semantic = comp_semantic_in; return std::move(*this); }
3418 inline post_put_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3419 inline post_put_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3420 inline post_put_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
3421 inline post_put_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3422 inline post_put_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3423 inline post_put_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3424 inline post_put_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3425
3427 status_t call() const;
3428 inline status_t operator()() const { return call(); }
3429};
3430
3431inline 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) {
3432 return post_put_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_disp_in, rmr_in).call();
3433}
3434
3435
3460
3466 public:
3467 // args declaration
3470 size_t m_size;
3472 uintptr_t m_remote_disp;
3485
3486 // constructor
3487 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) {}
3488
3489 // setter
3490 inline post_get_x&& rank(int rank_in) { m_rank = rank_in; return std::move(*this); }
3491 inline post_get_x&& local_buffer(void* local_buffer_in) { m_local_buffer = local_buffer_in; return std::move(*this); }
3492 inline post_get_x&& size(size_t size_in) { m_size = size_in; return std::move(*this); }
3493 inline post_get_x&& local_comp(comp_t local_comp_in) { m_local_comp = local_comp_in; return std::move(*this); }
3494 inline post_get_x&& remote_disp(uintptr_t remote_disp_in) { m_remote_disp = remote_disp_in; return std::move(*this); }
3495 inline post_get_x&& rmr(rmr_t rmr_in) { m_rmr = rmr_in; return std::move(*this); }
3496 inline post_get_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3497 inline post_get_x&& packet_pool(packet_pool_t packet_pool_in) { m_packet_pool = packet_pool_in; return std::move(*this); }
3498 inline post_get_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3499 inline post_get_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3500 inline post_get_x&& mr(mr_t mr_in) { m_mr = mr_in; return std::move(*this); }
3501 inline post_get_x&& tag(tag_t tag_in) { m_tag = tag_in; return std::move(*this); }
3502 inline post_get_x&& remote_comp(rcomp_t remote_comp_in) { m_remote_comp = remote_comp_in; return std::move(*this); }
3503 inline post_get_x&& user_context(void* user_context_in) { m_user_context = user_context_in; return std::move(*this); }
3504 inline post_get_x&& allow_done(bool allow_done_in) { m_allow_done = allow_done_in; return std::move(*this); }
3505 inline post_get_x&& allow_posted(bool allow_posted_in) { m_allow_posted = allow_posted_in; return std::move(*this); }
3506 inline post_get_x&& allow_retry(bool allow_retry_in) { m_allow_retry = allow_retry_in; return std::move(*this); }
3507
3509 status_t call() const;
3510 inline status_t operator()() const { return call(); }
3511};
3512
3513inline 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) {
3514 return post_get_x(rank_in, local_buffer_in, size_in, local_comp_in, remote_disp_in, rmr_in).call();
3515}
3516
3517
3528
3534 public:
3535 // args declaration
3539
3540 // constructor
3542
3543 // setter
3544 inline progress_x&& runtime(runtime_t runtime_in) { m_runtime = runtime_in; return std::move(*this); }
3545 inline progress_x&& device(device_t device_in) { m_device = device_in; return std::move(*this); }
3546 inline progress_x&& endpoint(endpoint_t endpoint_in) { m_endpoint = endpoint_in; return std::move(*this); }
3547
3549 error_t call() const;
3550 inline error_t operator()() const { return call(); }
3551};
3552
3554 return progress_x().call();
3555}
3556
3557
3558} // namespace lci
3559
3560#endif // LCI_BINDING_POST_HPP_
The actual implementation for allgather.
Definition lci_binding_post.hpp:2932
allgather_x && size(size_t size_in)
Definition lci_binding_post.hpp:2949
allgather_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2948
void * m_recvbuf
Definition lci_binding_post.hpp:2936
size_t m_size
Definition lci_binding_post.hpp:2937
void call() const
Definition binding.cpp:755
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2938
const void * m_sendbuf
Definition lci_binding_post.hpp:2935
allgather_x && device(device_t device_in)
Definition lci_binding_post.hpp:2951
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2941
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2940
allgather_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2950
allgather_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2952
allgather_x(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:2944
allgather_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2953
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:2939
void operator()() const
Definition lci_binding_post.hpp:2957
allgather_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2947
The actual implementation for alloc_counter.
Definition lci_binding_post.hpp:2138
alloc_counter_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2147
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2141
comp_t operator()() const
Definition lci_binding_post.hpp:2151
comp_t call_impl(runtime_t runtime) const
comp_t call() const
Definition binding.cpp:600
alloc_counter_x()
Definition lci_binding_post.hpp:2144
The actual implementation for alloc_cq.
Definition lci_binding_post.hpp:2253
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2256
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:2258
alloc_cq_x && cq_type(attr_cq_type_t cq_type_in)
Definition lci_binding_post.hpp:2269
alloc_cq_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:2268
comp_t operator()() const
Definition lci_binding_post.hpp:2274
option_t< int > m_default_length
Definition lci_binding_post.hpp:2257
option_t< attr_cq_type_t > m_cq_type
Definition lci_binding_post.hpp:2259
alloc_cq_x && default_length(int default_length_in)
Definition lci_binding_post.hpp:2267
alloc_cq_x()
Definition lci_binding_post.hpp:2263
comp_t call() const
Definition binding.cpp:618
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2260
alloc_cq_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2270
alloc_cq_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2266
comp_t call_impl(runtime_t runtime, int default_length, bool zero_copy_am, attr_cq_type_t cq_type, void *user_context) const
The actual implementation for alloc_device.
Definition lci_binding_post.hpp:133
alloc_device_x && alloc_default_endpoint(bool alloc_default_endpoint_in)
Definition lci_binding_post.hpp:156
alloc_device_x()
Definition lci_binding_post.hpp:148
device_t call_impl(runtime_t runtime, size_t net_max_sends, size_t net_max_recvs, size_t net_max_cqes, uint64_t ofi_lock_mode, bool alloc_default_endpoint, attr_ibv_td_strategy_t ibv_td_strategy, void *user_context, net_context_t net_context, packet_pool_t packet_pool) const
option_t< net_context_t > m_net_context
Definition lci_binding_post.hpp:144
alloc_device_x && net_max_recvs(size_t net_max_recvs_in)
Definition lci_binding_post.hpp:153
option_t< attr_ibv_td_strategy_t > m_ibv_td_strategy
Definition lci_binding_post.hpp:142
alloc_device_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:158
option_t< size_t > m_net_max_recvs
Definition lci_binding_post.hpp:138
alloc_device_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:160
alloc_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:151
alloc_device_x && ofi_lock_mode(uint64_t ofi_lock_mode_in)
Definition lci_binding_post.hpp:155
option_t< uint64_t > m_ofi_lock_mode
Definition lci_binding_post.hpp:140
option_t< void * > m_user_context
Definition lci_binding_post.hpp:143
option_t< size_t > m_net_max_sends
Definition lci_binding_post.hpp:137
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:145
option_t< size_t > m_net_max_cqes
Definition lci_binding_post.hpp:139
alloc_device_x && net_context(net_context_t net_context_in)
Definition lci_binding_post.hpp:159
option_t< bool > m_alloc_default_endpoint
Definition lci_binding_post.hpp:141
device_t operator()() const
Definition lci_binding_post.hpp:164
device_t call() const
Definition binding.cpp:193
alloc_device_x && net_max_cqes(size_t net_max_cqes_in)
Definition lci_binding_post.hpp:154
alloc_device_x && ibv_td_strategy(attr_ibv_td_strategy_t ibv_td_strategy_in)
Definition lci_binding_post.hpp:157
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:136
alloc_device_x && net_max_sends(size_t net_max_sends_in)
Definition lci_binding_post.hpp:152
The actual implementation for alloc_endpoint.
Definition lci_binding_post.hpp:341
endpoint_t call() const
Definition binding.cpp:240
endpoint_t call_impl(runtime_t runtime, void *user_context, device_t device) const
alloc_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:352
option_t< void * > m_user_context
Definition lci_binding_post.hpp:345
alloc_endpoint_x()
Definition lci_binding_post.hpp:349
option_t< device_t > m_device
Definition lci_binding_post.hpp:346
alloc_endpoint_x && device(device_t device_in)
Definition lci_binding_post.hpp:354
endpoint_t operator()() const
Definition lci_binding_post.hpp:358
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:344
alloc_endpoint_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:353
The actual implementation for alloc_graph.
Definition lci_binding_post.hpp:2377
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2382
alloc_graph_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2390
comp_t call() const
Definition binding.cpp:641
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2381
alloc_graph_x()
Definition lci_binding_post.hpp:2385
comp_t call_impl(comp_t comp, void *user_context, runtime_t runtime) const
alloc_graph_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2389
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2380
alloc_graph_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2388
comp_t operator()() const
Definition lci_binding_post.hpp:2394
The actual implementation for alloc_handler.
Definition lci_binding_post.hpp:2335
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2339
alloc_handler_x && handler(comp_handler_t handler_in)
Definition lci_binding_post.hpp:2347
alloc_handler_x(comp_handler_t handler_in)
Definition lci_binding_post.hpp:2344
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2341
comp_t call() const
Definition binding.cpp:633
comp_t operator()() const
Definition lci_binding_post.hpp:2354
alloc_handler_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:2349
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:2340
comp_t call_impl(comp_handler_t handler, runtime_t runtime, bool zero_copy_am, void *user_context) const
alloc_handler_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2350
alloc_handler_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2348
comp_handler_t m_handler
Definition lci_binding_post.hpp:2338
The actual implementation for alloc_matching_engine.
Definition lci_binding_post.hpp:1416
matching_engine_t operator()() const
Definition lci_binding_post.hpp:1433
matching_engine_t call() const
Definition binding.cpp:471
alloc_matching_engine_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1429
option_t< attr_matching_engine_type_t > m_matching_engine_type
Definition lci_binding_post.hpp:1420
matching_engine_t call_impl(runtime_t runtime, attr_matching_engine_type_t matching_engine_type, void *user_context) const
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1421
alloc_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1427
alloc_matching_engine_x && matching_engine_type(attr_matching_engine_type_t matching_engine_type_in)
Definition lci_binding_post.hpp:1428
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1419
alloc_matching_engine_x()
Definition lci_binding_post.hpp:1424
The actual implementation for alloc_net_context.
Definition lci_binding_post.hpp:35
net_context_t call_impl(runtime_t runtime, attr_backend_t backend, std::string ofi_provider_name, size_t max_msg_size, size_t max_inject_size, int ibv_gid_idx, bool ibv_force_gid_auto_select, attr_ibv_odp_strategy_t ibv_odp_strategy, attr_ibv_prefetch_strategy_t ibv_prefetch_strategy, void *user_context) const
alloc_net_context_x && ofi_provider_name(std::string ofi_provider_name_in)
Definition lci_binding_post.hpp:55
option_t< int > m_ibv_gid_idx
Definition lci_binding_post.hpp:43
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:38
alloc_net_context_x && ibv_prefetch_strategy(attr_ibv_prefetch_strategy_t ibv_prefetch_strategy_in)
Definition lci_binding_post.hpp:61
alloc_net_context_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:53
option_t< attr_ibv_odp_strategy_t > m_ibv_odp_strategy
Definition lci_binding_post.hpp:45
alloc_net_context_x && ibv_gid_idx(int ibv_gid_idx_in)
Definition lci_binding_post.hpp:58
alloc_net_context_x()
Definition lci_binding_post.hpp:50
alloc_net_context_x && max_inject_size(size_t max_inject_size_in)
Definition lci_binding_post.hpp:57
option_t< void * > m_user_context
Definition lci_binding_post.hpp:47
alloc_net_context_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:62
alloc_net_context_x && backend(attr_backend_t backend_in)
Definition lci_binding_post.hpp:54
alloc_net_context_x && ibv_force_gid_auto_select(bool ibv_force_gid_auto_select_in)
Definition lci_binding_post.hpp:59
alloc_net_context_x && ibv_odp_strategy(attr_ibv_odp_strategy_t ibv_odp_strategy_in)
Definition lci_binding_post.hpp:60
option_t< attr_backend_t > m_backend
Definition lci_binding_post.hpp:39
alloc_net_context_x && max_msg_size(size_t max_msg_size_in)
Definition lci_binding_post.hpp:56
net_context_t call() const
Definition binding.cpp:163
option_t< std::string > m_ofi_provider_name
Definition lci_binding_post.hpp:40
option_t< bool > m_ibv_force_gid_auto_select
Definition lci_binding_post.hpp:44
option_t< size_t > m_max_inject_size
Definition lci_binding_post.hpp:42
net_context_t operator()() const
Definition lci_binding_post.hpp:66
option_t< size_t > m_max_msg_size
Definition lci_binding_post.hpp:41
option_t< attr_ibv_prefetch_strategy_t > m_ibv_prefetch_strategy
Definition lci_binding_post.hpp:46
The actual implementation for alloc_packet_pool.
Definition lci_binding_post.hpp:1183
packet_pool_t call() const
Definition binding.cpp:427
alloc_packet_pool_x()
Definition lci_binding_post.hpp:1192
packet_pool_t call_impl(runtime_t runtime, size_t packet_size, size_t npackets, void *user_context) const
alloc_packet_pool_x && npackets(size_t npackets_in)
Definition lci_binding_post.hpp:1197
alloc_packet_pool_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1198
alloc_packet_pool_x && packet_size(size_t packet_size_in)
Definition lci_binding_post.hpp:1196
option_t< size_t > m_packet_size
Definition lci_binding_post.hpp:1187
alloc_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1195
packet_pool_t operator()() const
Definition lci_binding_post.hpp:1202
option_t< void * > m_user_context
Definition lci_binding_post.hpp:1189
option_t< size_t > m_npackets
Definition lci_binding_post.hpp:1188
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1186
The actual implementation for alloc_runtime.
Definition lci_binding_post.hpp:987
alloc_runtime_x && imm_nbits_tag(int imm_nbits_tag_in)
Definition lci_binding_post.hpp:1003
alloc_runtime_x && imm_nbits_rcomp(int imm_nbits_rcomp_in)
Definition lci_binding_post.hpp:1004
option_t< bool > m_alloc_default_packet_pool
Definition lci_binding_post.hpp:994
runtime_t operator()() const
Definition lci_binding_post.hpp:1012
option_t< bool > m_alloc_default_matching_engine
Definition lci_binding_post.hpp:995
runtime_t call() const
Definition binding.cpp:384
alloc_runtime_x && alloc_default_packet_pool(bool alloc_default_packet_pool_in)
Definition lci_binding_post.hpp:1006
alloc_runtime_x()
Definition lci_binding_post.hpp:999
alloc_runtime_x && alloc_default_matching_engine(bool alloc_default_matching_engine_in)
Definition lci_binding_post.hpp:1007
alloc_runtime_x && alloc_default_device(bool alloc_default_device_in)
Definition lci_binding_post.hpp:1005
alloc_runtime_x && packet_return_threshold(size_t packet_return_threshold_in)
Definition lci_binding_post.hpp:1002
alloc_runtime_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:1008
option_t< bool > m_alloc_default_device
Definition lci_binding_post.hpp:993
runtime_t call_impl(size_t packet_return_threshold, int imm_nbits_tag, int imm_nbits_rcomp, bool alloc_default_device, bool alloc_default_packet_pool, bool alloc_default_matching_engine, void *user_context) const
option_t< void * > m_user_context
Definition lci_binding_post.hpp:996
option_t< int > m_imm_nbits_rcomp
Definition lci_binding_post.hpp:992
option_t< size_t > m_packet_return_threshold
Definition lci_binding_post.hpp:990
option_t< int > m_imm_nbits_tag
Definition lci_binding_post.hpp:991
The actual implementation for alloc_sync.
Definition lci_binding_post.hpp:2012
comp_t operator()() const
Definition lci_binding_post.hpp:2031
option_t< int > m_threshold
Definition lci_binding_post.hpp:2016
option_t< void * > m_user_context
Definition lci_binding_post.hpp:2018
alloc_sync_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:2027
alloc_sync_x && threshold(int threshold_in)
Definition lci_binding_post.hpp:2025
option_t< bool > m_zero_copy_am
Definition lci_binding_post.hpp:2017
alloc_sync_x()
Definition lci_binding_post.hpp:2021
alloc_sync_x && zero_copy_am(bool zero_copy_am_in)
Definition lci_binding_post.hpp:2026
alloc_sync_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2024
comp_t call_impl(runtime_t runtime, int threshold, bool zero_copy_am, void *user_context) const
comp_t call() const
Definition binding.cpp:576
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2015
The actual implementation for allreduce.
Definition lci_binding_post.hpp:2870
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:2893
void operator()() const
Definition lci_binding_post.hpp:2905
const void * m_sendbuf
Definition lci_binding_post.hpp:2873
option_t< device_t > m_device
Definition lci_binding_post.hpp:2879
allreduce_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2890
reduce_op_t m_op
Definition lci_binding_post.hpp:2877
void * m_recvbuf
Definition lci_binding_post.hpp:2874
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:2884
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:2887
allreduce_x && device(device_t device_in)
Definition lci_binding_post.hpp:2896
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2881
size_t m_count
Definition lci_binding_post.hpp:2875
allreduce_x && count(size_t count_in)
Definition lci_binding_post.hpp:2892
allreduce_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2891
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2880
allreduce_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2897
option_t< allreduce_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:2883
allreduce_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:2894
allreduce_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2895
allreduce_x && algorithm(allreduce_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:2900
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2878
allreduce_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:2901
size_t m_item_size
Definition lci_binding_post.hpp:2876
allreduce_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2899
void call() const
Definition binding.cpp:739
allreduce_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2898
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2882
The actual implementation for alltoall.
Definition lci_binding_post.hpp:2984
const void * m_sendbuf
Definition lci_binding_post.hpp:2987
void call() const
Definition binding.cpp:766
alltoall_x && device(device_t device_in)
Definition lci_binding_post.hpp:3003
alltoall_x && size(size_t size_in)
Definition lci_binding_post.hpp:3001
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< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2993
alltoall_x(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:2996
void * m_recvbuf
Definition lci_binding_post.hpp:2988
alltoall_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:3000
option_t< device_t > m_device
Definition lci_binding_post.hpp:2991
alltoall_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3005
alltoall_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3004
alltoall_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3002
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2990
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2992
alltoall_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2999
size_t m_size
Definition lci_binding_post.hpp:2989
void operator()() const
Definition lci_binding_post.hpp:3009
The actual implementation for barrier.
Definition lci_binding_post.hpp:2626
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2634
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2632
barrier_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2643
barrier_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2645
barrier_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:2644
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:2630
void call() const
Definition binding.cpp:685
barrier_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2642
barrier_x()
Definition lci_binding_post.hpp:2637
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2631
barrier_x && device(device_t device_in)
Definition lci_binding_post.hpp:2641
void operator()() const
Definition lci_binding_post.hpp:2649
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:2633
barrier_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2640
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2629
The actual implementation for broadcast.
Definition lci_binding_post.hpp:2679
broadcast_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2703
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2687
void call() const
Definition binding.cpp:695
void operator()() const
Definition lci_binding_post.hpp:2710
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2688
int m_root
Definition lci_binding_post.hpp:2684
broadcast_x && root(int root_in)
Definition lci_binding_post.hpp:2699
broadcast_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2704
broadcast_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2700
broadcast_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:2706
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2685
broadcast_x && size(size_t size_in)
Definition lci_binding_post.hpp:2698
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:2691
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2689
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:2694
broadcast_x && device(device_t device_in)
Definition lci_binding_post.hpp:2701
option_t< broadcast_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:2690
void * m_buffer
Definition lci_binding_post.hpp:2682
option_t< device_t > m_device
Definition lci_binding_post.hpp:2686
broadcast_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:2697
broadcast_x && algorithm(broadcast_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:2705
broadcast_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2702
size_t m_size
Definition lci_binding_post.hpp:2683
The actual implementation for comp_signal.
Definition lci_binding_post.hpp:1857
comp_signal_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1870
comp_signal_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1868
status_t m_status
Definition lci_binding_post.hpp:1861
comp_t m_comp
Definition lci_binding_post.hpp:1860
void call() const
Definition binding.cpp:550
comp_signal_x(comp_t comp_in, status_t status_in)
Definition lci_binding_post.hpp:1865
void call_impl(comp_t comp, status_t status, runtime_t runtime) const
void operator()() const
Definition lci_binding_post.hpp:1874
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1862
comp_signal_x && status(status_t status_in)
Definition lci_binding_post.hpp:1869
The actual implementation for RESOURCE comp.
Definition lci_binding_pre.hpp:460
The actual implementation for counter_get.
Definition lci_binding_post.hpp:2173
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2177
int64_t call_impl(comp_t comp, runtime_t runtime) const
int64_t operator()() const
Definition lci_binding_post.hpp:2188
counter_get_x(comp_t comp_in)
Definition lci_binding_post.hpp:2180
int64_t call() const
Definition binding.cpp:605
counter_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2184
comp_t m_comp
Definition lci_binding_post.hpp:2176
counter_get_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2183
The actual implementation for counter_set.
Definition lci_binding_post.hpp:2211
counter_set_x(comp_t comp_in, int64_t value_in)
Definition lci_binding_post.hpp:2219
int64_t m_value
Definition lci_binding_post.hpp:2215
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2216
comp_t m_comp
Definition lci_binding_post.hpp:2214
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:2224
counter_set_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2222
void operator()() const
Definition lci_binding_post.hpp:2228
counter_set_x && value(int64_t value_in)
Definition lci_binding_post.hpp:2223
void call() const
Definition binding.cpp:611
The actual implementation for cq_pop.
Definition lci_binding_post.hpp:2296
status_t operator()() const
Definition lci_binding_post.hpp:2311
comp_t m_comp
Definition lci_binding_post.hpp:2299
status_t call_impl(comp_t comp, runtime_t runtime) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2300
cq_pop_x(comp_t comp_in)
Definition lci_binding_post.hpp:2303
cq_pop_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2306
cq_pop_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2307
status_t call() const
Definition binding.cpp:627
The actual implementation for deregister_memory.
Definition lci_binding_post.hpp:266
void operator()() const
Definition lci_binding_post.hpp:281
void call() const
Definition binding.cpp:224
mr_t * m_mr
Definition lci_binding_post.hpp:269
deregister_memory_x && mr(mr_t *mr_in)
Definition lci_binding_post.hpp:276
deregister_memory_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:277
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:270
void call_impl(mr_t *mr, runtime_t runtime) const
deregister_memory_x(mr_t *mr_in)
Definition lci_binding_post.hpp:273
The actual implementation for deregister_packet_pool.
Definition lci_binding_post.hpp:1302
deregister_packet_pool_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1313
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:1305
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1307
void operator()() const
Definition lci_binding_post.hpp:1319
void call() const
Definition binding.cpp:448
deregister_packet_pool_x && device(device_t device_in)
Definition lci_binding_post.hpp:1314
device_t m_device
Definition lci_binding_post.hpp:1306
deregister_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1315
deregister_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:1310
The actual implementation for deregister_rcomp.
Definition lci_binding_post.hpp:1973
deregister_rcomp_x(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:1980
void operator()() const
Definition lci_binding_post.hpp:1988
rcomp_t m_rcomp
Definition lci_binding_post.hpp:1976
void call_impl(rcomp_t rcomp, runtime_t runtime) const
void call() const
Definition binding.cpp:570
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1977
deregister_rcomp_x && rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:1983
deregister_rcomp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1984
The actual implementation for RESOURCE device.
Definition lci_binding_pre.hpp:191
The actual implementation for RESOURCE endpoint.
Definition lci_binding_pre.hpp:270
The actual implementation for free_comp.
Definition lci_binding_post.hpp:1819
free_comp_x(comp_t *comp_in)
Definition lci_binding_post.hpp:1826
free_comp_x && comp(comp_t *comp_in)
Definition lci_binding_post.hpp:1829
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1823
comp_t * m_comp
Definition lci_binding_post.hpp:1822
void call() const
Definition binding.cpp:544
free_comp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1830
void operator()() const
Definition lci_binding_post.hpp:1834
void call_impl(comp_t *comp, runtime_t runtime) const
The actual implementation for free_device.
Definition lci_binding_post.hpp:186
void call_impl(device_t *device, runtime_t runtime) const
free_device_x && device(device_t *device_in)
Definition lci_binding_post.hpp:196
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:190
device_t * m_device
Definition lci_binding_post.hpp:189
void operator()() const
Definition lci_binding_post.hpp:201
void call() const
Definition binding.cpp:207
free_device_x(device_t *device_in)
Definition lci_binding_post.hpp:193
free_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:197
The actual implementation for free_endpoint.
Definition lci_binding_post.hpp:380
void operator()() const
Definition lci_binding_post.hpp:395
endpoint_t * m_endpoint
Definition lci_binding_post.hpp:383
free_endpoint_x && endpoint(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:390
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:384
free_endpoint_x(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:387
void call_impl(endpoint_t *endpoint, runtime_t runtime) const
void call() const
Definition binding.cpp:247
free_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:391
The actual implementation for free_matching_engine.
Definition lci_binding_post.hpp:1455
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:1465
free_matching_engine_x(matching_engine_t *matching_engine_in)
Definition lci_binding_post.hpp:1462
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1459
matching_engine_t * m_matching_engine
Definition lci_binding_post.hpp:1458
void call() const
Definition binding.cpp:478
free_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1466
void operator()() const
Definition lci_binding_post.hpp:1470
The actual implementation for free_net_context.
Definition lci_binding_post.hpp:88
void operator()() const
Definition lci_binding_post.hpp:103
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:99
free_net_context_x(net_context_t *net_context_in)
Definition lci_binding_post.hpp:95
void call() const
Definition binding.cpp:177
net_context_t * m_net_context
Definition lci_binding_post.hpp:91
free_net_context_x && net_context(net_context_t *net_context_in)
Definition lci_binding_post.hpp:98
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:92
The actual implementation for free_packet_pool.
Definition lci_binding_post.hpp:1224
void operator()() const
Definition lci_binding_post.hpp:1239
free_packet_pool_x(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:1231
void call() const
Definition binding.cpp:435
void call_impl(packet_pool_t *packet_pool, runtime_t runtime) const
packet_pool_t * m_packet_pool
Definition lci_binding_post.hpp:1227
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1228
free_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1235
free_packet_pool_x && packet_pool(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:1234
The actual implementation for free_runtime.
Definition lci_binding_post.hpp:1033
void call_impl(runtime_t *runtime) const
free_runtime_x(runtime_t *runtime_in)
Definition lci_binding_post.hpp:1039
runtime_t * m_runtime
Definition lci_binding_post.hpp:1036
free_runtime_x && runtime(runtime_t *runtime_in)
Definition lci_binding_post.hpp:1042
void operator()() const
Definition lci_binding_post.hpp:1046
void call() const
Definition binding.cpp:396
The actual implementation for g_runtime_fina.
Definition lci_binding_post.hpp:1116
g_runtime_fina_x()
Definition lci_binding_post.hpp:1121
void call() const
Definition binding.cpp:413
void operator()() const
Definition lci_binding_post.hpp:1127
void call_impl() const
The actual implementation for g_runtime_init.
Definition lci_binding_post.hpp:1072
g_runtime_init_x && imm_nbits_rcomp(int imm_nbits_rcomp_in)
Definition lci_binding_post.hpp:1088
g_runtime_init_x && alloc_default_packet_pool(bool alloc_default_packet_pool_in)
Definition lci_binding_post.hpp:1090
g_runtime_init_x && imm_nbits_tag(int imm_nbits_tag_in)
Definition lci_binding_post.hpp:1087
option_t< int > m_imm_nbits_tag
Definition lci_binding_post.hpp:1076
void operator()() const
Definition lci_binding_post.hpp:1095
option_t< int > m_imm_nbits_rcomp
Definition lci_binding_post.hpp:1077
option_t< size_t > m_packet_return_threshold
Definition lci_binding_post.hpp:1075
void call() const
Definition binding.cpp:402
option_t< bool > m_alloc_default_device
Definition lci_binding_post.hpp:1078
void call_impl(size_t packet_return_threshold, int imm_nbits_tag, int imm_nbits_rcomp, bool alloc_default_device, bool alloc_default_packet_pool, bool alloc_default_matching_engine) const
g_runtime_init_x && alloc_default_matching_engine(bool alloc_default_matching_engine_in)
Definition lci_binding_post.hpp:1091
option_t< bool > m_alloc_default_matching_engine
Definition lci_binding_post.hpp:1080
option_t< bool > m_alloc_default_packet_pool
Definition lci_binding_post.hpp:1079
g_runtime_init_x()
Definition lci_binding_post.hpp:1083
g_runtime_init_x && alloc_default_device(bool alloc_default_device_in)
Definition lci_binding_post.hpp:1089
g_runtime_init_x && packet_return_threshold(size_t packet_return_threshold_in)
Definition lci_binding_post.hpp:1086
The actual implementation for get_allocator.
Definition lci_binding_post.hpp:1574
allocator_base_t * call_impl(runtime_t runtime) const
allocator_base_t * call() const
Definition binding.cpp:499
allocator_base_t * operator()() const
Definition lci_binding_post.hpp:1587
get_allocator_x()
Definition lci_binding_post.hpp:1580
get_allocator_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1583
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1577
The actual implementation for get_default_device.
Definition lci_binding_post.hpp:1642
device_t call_impl(runtime_t runtime) const
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1645
get_default_device_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1651
device_t call() const
Definition binding.cpp:509
get_default_device_x()
Definition lci_binding_post.hpp:1648
device_t operator()() const
Definition lci_binding_post.hpp:1655
The actual implementation for get_default_endpoint.
Definition lci_binding_post.hpp:1677
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:1688
endpoint_t operator()() const
Definition lci_binding_post.hpp:1692
endpoint_t call() const
Definition binding.cpp:514
get_default_endpoint_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1687
get_default_endpoint_x()
Definition lci_binding_post.hpp:1684
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1680
option_t< device_t > m_device
Definition lci_binding_post.hpp:1681
The actual implementation for get_default_matching_engine.
Definition lci_binding_post.hpp:1747
get_default_matching_engine_x()
Definition lci_binding_post.hpp:1753
matching_engine_t call() const
Definition binding.cpp:525
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1750
matching_engine_t call_impl(runtime_t runtime) const
matching_engine_t operator()() const
Definition lci_binding_post.hpp:1760
get_default_matching_engine_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1756
The actual implementation for get_default_net_context.
Definition lci_binding_post.hpp:1608
net_context_t operator()() const
Definition lci_binding_post.hpp:1621
get_default_net_context_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1617
get_default_net_context_x()
Definition lci_binding_post.hpp:1614
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1611
net_context_t call_impl(runtime_t runtime) const
net_context_t call() const
Definition binding.cpp:504
The actual implementation for get_default_packet_pool.
Definition lci_binding_post.hpp:1713
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1716
packet_pool_t operator()() const
Definition lci_binding_post.hpp:1726
packet_pool_t call_impl(runtime_t runtime) const
packet_pool_t call() const
Definition binding.cpp:520
get_default_packet_pool_x()
Definition lci_binding_post.hpp:1719
get_default_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1722
The actual implementation for get_g_runtime.
Definition lci_binding_post.hpp:1148
runtime_t operator()() const
Definition lci_binding_post.hpp:1159
get_g_runtime_x()
Definition lci_binding_post.hpp:1153
runtime_t call() const
Definition binding.cpp:418
runtime_t call_impl() const
The actual implementation for get_max_bcopy_size.
Definition lci_binding_post.hpp:1782
size_t operator()() const
Definition lci_binding_post.hpp:1797
get_max_bcopy_size_x()
Definition lci_binding_post.hpp:1789
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1785
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:1786
get_max_bcopy_size_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1793
size_t call() const
Definition binding.cpp:530
get_max_bcopy_size_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1792
The actual implementation for get_rank_me.
Definition lci_binding_post.hpp:917
int call_impl() const
int call() const
Definition binding.cpp:363
int operator()() const
Definition lci_binding_post.hpp:928
get_rank_me_x()
Definition lci_binding_post.hpp:922
The actual implementation for get_rank_n.
Definition lci_binding_post.hpp:949
int call_impl() const
int call() const
Definition binding.cpp:367
int operator()() const
Definition lci_binding_post.hpp:960
get_rank_n_x()
Definition lci_binding_post.hpp:954
The actual implementation for get_rmr.
Definition lci_binding_post.hpp:303
get_rmr_x(mr_t mr_in)
Definition lci_binding_post.hpp:310
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:307
get_rmr_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:313
rmr_t operator()() const
Definition lci_binding_post.hpp:318
mr_t m_mr
Definition lci_binding_post.hpp:306
rmr_t call() const
Definition binding.cpp:230
get_rmr_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:314
rmr_t call_impl(mr_t mr, runtime_t runtime) const
The actual implementation for get_upacket.
Definition lci_binding_post.hpp:1341
get_upacket_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1352
void * call() const
Definition binding.cpp:455
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1344
get_upacket_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1351
void * operator()() const
Definition lci_binding_post.hpp:1356
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:1345
get_upacket_x()
Definition lci_binding_post.hpp:1348
The actual implementation for graph_add_edge.
Definition lci_binding_post.hpp:2465
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:2468
void call() const
Definition binding.cpp:657
graph_add_edge_x(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in)
Definition lci_binding_post.hpp:2475
graph_add_edge_x && dst(graph_node_t dst_in)
Definition lci_binding_post.hpp:2480
graph_add_edge_x && fn(graph_edge_run_cb_t fn_in)
Definition lci_binding_post.hpp:2481
void operator()() const
Definition lci_binding_post.hpp:2486
option_t< graph_edge_run_cb_t > m_fn
Definition lci_binding_post.hpp:2471
graph_add_edge_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2478
graph_node_t m_dst
Definition lci_binding_post.hpp:2470
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2472
graph_add_edge_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2482
graph_add_edge_x && src(graph_node_t src_in)
Definition lci_binding_post.hpp:2479
graph_node_t m_src
Definition lci_binding_post.hpp:2469
The actual implementation for graph_add_node.
Definition lci_binding_post.hpp:2419
option_t< void * > m_value
Definition lci_binding_post.hpp:2424
graph_node_t operator()() const
Definition lci_binding_post.hpp:2440
graph_add_node_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2436
graph_node_t call() const
Definition binding.cpp:648
graph_add_node_x(comp_t comp_in, graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:2429
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:2433
graph_node_run_cb_t m_fn
Definition lci_binding_post.hpp:2423
comp_t m_comp
Definition lci_binding_post.hpp:2422
graph_add_node_x && free_cb(graph_node_free_cb_t free_cb_in)
Definition lci_binding_post.hpp:2435
graph_add_node_x && value(void *value_in)
Definition lci_binding_post.hpp:2434
option_t< graph_node_free_cb_t > m_free_cb
Definition lci_binding_post.hpp:2425
graph_add_node_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2432
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2426
The actual implementation for graph_node_mark_complete.
Definition lci_binding_post.hpp:2509
void operator()() const
Definition lci_binding_post.hpp:2526
void call() const
Definition binding.cpp:666
graph_node_t m_node
Definition lci_binding_post.hpp:2512
graph_node_mark_complete_x(graph_node_t node_in)
Definition lci_binding_post.hpp:2517
option_t< status_t > m_status
Definition lci_binding_post.hpp:2513
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:2520
graph_node_mark_complete_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2522
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2514
graph_node_mark_complete_x && status(status_t status_in)
Definition lci_binding_post.hpp:2521
The actual implementation for graph_start.
Definition lci_binding_post.hpp:2548
graph_start_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2559
comp_t m_comp
Definition lci_binding_post.hpp:2551
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2552
graph_start_x(comp_t comp_in)
Definition lci_binding_post.hpp:2555
void call_impl(comp_t comp, runtime_t runtime) const
void call() const
Definition binding.cpp:673
void operator()() const
Definition lci_binding_post.hpp:2563
graph_start_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2558
The actual implementation for graph_test.
Definition lci_binding_post.hpp:2585
comp_t m_comp
Definition lci_binding_post.hpp:2588
status_t call_impl(comp_t comp, runtime_t runtime) const
graph_test_x(comp_t comp_in)
Definition lci_binding_post.hpp:2592
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2589
graph_test_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2596
status_t operator()() const
Definition lci_binding_post.hpp:2600
status_t call() const
Definition binding.cpp:679
graph_test_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2595
The actual implementation for matching_engine_insert.
Definition lci_binding_post.hpp:1495
matching_engine_insert_x && value(matching_entry_val_t value_in)
Definition lci_binding_post.hpp:1510
matching_engine_insert_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1512
matching_entry_val_t operator()() const
Definition lci_binding_post.hpp:1516
matching_entry_val_t call() const
Definition binding.cpp:484
matching_engine_insert_x && entry_type(matching_entry_type_t entry_type_in)
Definition lci_binding_post.hpp:1511
matching_engine_insert_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:1508
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1502
matching_entry_type_t m_entry_type
Definition lci_binding_post.hpp:1501
matching_engine_t m_matching_engine
Definition lci_binding_post.hpp:1498
matching_entry_key_t m_key
Definition lci_binding_post.hpp:1499
matching_engine_insert_x && key(matching_entry_key_t key_in)
Definition lci_binding_post.hpp:1509
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:1505
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:1500
The actual implementation for RESOURCE matching_engine.
Definition lci_binding_pre.hpp:414
The actual implementation for RESOURCE mr.
Definition lci_binding_pre.hpp:233
The actual implementation for RESOURCE net_context.
Definition lci_binding_pre.hpp:133
The actual implementation for net_poll_cq.
Definition lci_binding_post.hpp:419
net_poll_cq_x && device(device_t device_in)
Definition lci_binding_post.hpp:434
net_poll_cq_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:433
option_t< device_t > m_device
Definition lci_binding_post.hpp:425
net_poll_cq_x(size_t max_polls_in, net_status_t *statuses_in)
Definition lci_binding_post.hpp:428
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:424
net_poll_cq_x && statuses(net_status_t *statuses_in)
Definition lci_binding_post.hpp:432
size_t operator()() const
Definition lci_binding_post.hpp:438
size_t call() const
Definition binding.cpp:253
net_poll_cq_x && max_polls(size_t max_polls_in)
Definition lci_binding_post.hpp:431
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:422
net_status_t * m_statuses
Definition lci_binding_post.hpp:423
The actual implementation for net_post_get.
Definition lci_binding_post.hpp:865
net_post_get_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:884
net_post_get_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:891
net_post_get_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:888
option_t< device_t > m_device
Definition lci_binding_post.hpp:875
int m_rank
Definition lci_binding_post.hpp:868
net_post_get_x && device(device_t device_in)
Definition lci_binding_post.hpp:890
net_post_get_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:886
error_t operator()() const
Definition lci_binding_post.hpp:896
net_post_get_x && size(size_t size_in)
Definition lci_binding_post.hpp:885
error_t call() const
Definition binding.cpp:349
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:874
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:876
mr_t m_mr
Definition lci_binding_post.hpp:871
void * m_buffer
Definition lci_binding_post.hpp:869
net_post_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:889
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:872
net_post_get_x && rank(int rank_in)
Definition lci_binding_post.hpp:883
rmr_t m_rmr
Definition lci_binding_post.hpp:873
size_t m_size
Definition lci_binding_post.hpp:870
net_post_get_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:892
option_t< void * > m_user_context
Definition lci_binding_post.hpp:877
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:880
net_post_get_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:887
The actual implementation for net_post_putImm.
Definition lci_binding_post.hpp:802
net_post_putImm_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:829
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:818
rmr_t m_rmr
Definition lci_binding_post.hpp:810
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:811
net_post_putImm_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:824
net_post_putImm_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:826
error_t call() const
Definition binding.cpp:334
net_post_putImm_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:830
int m_rank
Definition lci_binding_post.hpp:805
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:814
net_post_putImm_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:827
option_t< device_t > m_device
Definition lci_binding_post.hpp:812
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:813
mr_t m_mr
Definition lci_binding_post.hpp:808
net_post_putImm_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:822
void * m_buffer
Definition lci_binding_post.hpp:806
net_post_putImm_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:831
option_t< void * > m_user_context
Definition lci_binding_post.hpp:815
error_t operator()() const
Definition lci_binding_post.hpp:835
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:807
net_post_putImm_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:825
uint64_t m_offset
Definition lci_binding_post.hpp:809
net_post_putImm_x && size(size_t size_in)
Definition lci_binding_post.hpp:823
net_post_putImm_x && rank(int rank_in)
Definition lci_binding_post.hpp:821
net_post_putImm_x && device(device_t device_in)
Definition lci_binding_post.hpp:828
The actual implementation for net_post_putImms.
Definition lci_binding_post.hpp:742
net_post_putImms_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:760
net_post_putImms_x && device(device_t device_in)
Definition lci_binding_post.hpp:765
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:752
option_t< device_t > m_device
Definition lci_binding_post.hpp:751
net_post_putImms_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:763
net_post_putImms_x && rank(int rank_in)
Definition lci_binding_post.hpp:759
uint64_t m_offset
Definition lci_binding_post.hpp:748
void * m_buffer
Definition lci_binding_post.hpp:746
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:753
int m_rank
Definition lci_binding_post.hpp:745
error_t operator()() const
Definition lci_binding_post.hpp:771
net_post_putImms_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:762
error_t call() const
Definition binding.cpp:321
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) const
rmr_t m_rmr
Definition lci_binding_post.hpp:749
net_post_putImms_x && size(size_t size_in)
Definition lci_binding_post.hpp:761
net_post_putImms_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:766
net_post_putImms_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:767
size_t m_size
Definition lci_binding_post.hpp:747
net_post_putImms_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:764
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:750
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:756
The actual implementation for net_post_put.
Definition lci_binding_post.hpp:682
rmr_t m_rmr
Definition lci_binding_post.hpp:690
net_post_put_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:701
mr_t m_mr
Definition lci_binding_post.hpp:688
net_post_put_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:705
int m_rank
Definition lci_binding_post.hpp:685
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:697
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:691
error_t call() const
Definition binding.cpp:307
net_post_put_x && rank(int rank_in)
Definition lci_binding_post.hpp:700
option_t< device_t > m_device
Definition lci_binding_post.hpp:692
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:693
net_post_put_x && device(device_t device_in)
Definition lci_binding_post.hpp:707
net_post_put_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:709
net_post_put_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:708
net_post_put_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:703
net_post_put_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:704
net_post_put_x && size(size_t size_in)
Definition lci_binding_post.hpp:702
option_t< void * > m_user_context
Definition lci_binding_post.hpp:694
size_t m_size
Definition lci_binding_post.hpp:687
net_post_put_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:706
error_t operator()() const
Definition lci_binding_post.hpp:713
uint64_t m_offset
Definition lci_binding_post.hpp:689
void * m_buffer
Definition lci_binding_post.hpp:686
The actual implementation for net_post_puts.
Definition lci_binding_post.hpp:625
net_post_puts_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:645
net_post_puts_x && rank(int rank_in)
Definition lci_binding_post.hpp:641
error_t operator()() const
Definition lci_binding_post.hpp:652
net_post_puts_x && size(size_t size_in)
Definition lci_binding_post.hpp:643
option_t< device_t > m_device
Definition lci_binding_post.hpp:634
void * m_buffer
Definition lci_binding_post.hpp:629
net_post_puts_x && offset(uint64_t offset_in)
Definition lci_binding_post.hpp:644
net_post_puts_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:646
net_post_puts_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:642
net_post_puts_x && device(device_t device_in)
Definition lci_binding_post.hpp:647
error_t call() const
Definition binding.cpp:295
int m_rank
Definition lci_binding_post.hpp:628
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:638
rmr_t m_rmr
Definition lci_binding_post.hpp:632
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:633
size_t m_size
Definition lci_binding_post.hpp:630
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) const
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:635
net_post_puts_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:648
uint64_t m_offset
Definition lci_binding_post.hpp:631
The actual implementation for net_post_recv.
Definition lci_binding_post.hpp:464
net_post_recv_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:481
option_t< void * > m_user_context
Definition lci_binding_post.hpp:472
net_post_recv_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:478
error_t call() const
Definition binding.cpp:261
net_post_recv_x(void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:475
net_post_recv_x && size(size_t size_in)
Definition lci_binding_post.hpp:479
net_post_recv_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:480
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:470
option_t< device_t > m_device
Definition lci_binding_post.hpp:471
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:469
size_t m_size
Definition lci_binding_post.hpp:468
error_t operator()() const
Definition lci_binding_post.hpp:487
net_post_recv_x && device(device_t device_in)
Definition lci_binding_post.hpp:482
void * m_buffer
Definition lci_binding_post.hpp:467
net_post_recv_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:483
The actual implementation for net_post_send.
Definition lci_binding_post.hpp:568
net_post_send_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:592
net_post_send_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:589
net_post_send_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:586
void * m_buffer
Definition lci_binding_post.hpp:572
int m_rank
Definition lci_binding_post.hpp:571
mr_t m_mr
Definition lci_binding_post.hpp:574
size_t m_size
Definition lci_binding_post.hpp:573
net_post_send_x && size(size_t size_in)
Definition lci_binding_post.hpp:587
error_t call() const
Definition binding.cpp:282
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:575
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:578
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:577
net_post_send_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:588
net_post_send_x && device(device_t device_in)
Definition lci_binding_post.hpp:590
option_t< void * > m_user_context
Definition lci_binding_post.hpp:579
net_post_send_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:591
net_post_send_x(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:582
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:576
error_t operator()() const
Definition lci_binding_post.hpp:597
net_post_send_x && rank(int rank_in)
Definition lci_binding_post.hpp:585
net_post_send_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:593
The actual implementation for net_post_sends.
Definition lci_binding_post.hpp:514
net_post_sends_x && imm_data(net_imm_data_t imm_data_in)
Definition lci_binding_post.hpp:535
net_post_sends_x && size(size_t size_in)
Definition lci_binding_post.hpp:531
error_t call() const
Definition binding.cpp:271
option_t< device_t > m_device
Definition lci_binding_post.hpp:521
net_post_sends_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:534
int m_rank
Definition lci_binding_post.hpp:517
net_post_sends_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:532
option_t< net_imm_data_t > m_imm_data
Definition lci_binding_post.hpp:523
net_post_sends_x(int rank_in, void *buffer_in, size_t size_in)
Definition lci_binding_post.hpp:526
net_post_sends_x && rank(int rank_in)
Definition lci_binding_post.hpp:529
void * m_buffer
Definition lci_binding_post.hpp:518
error_t operator()() const
Definition lci_binding_post.hpp:539
net_post_sends_x && buffer(void *buffer_in)
Definition lci_binding_post.hpp:530
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) const
size_t m_size
Definition lci_binding_post.hpp:519
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:522
net_post_sends_x && device(device_t device_in)
Definition lci_binding_post.hpp:533
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:520
The actual implementation for RESOURCE packet_pool.
Definition lci_binding_pre.hpp:375
The actual implementation for post_am.
Definition lci_binding_post.hpp:3139
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3152
option_t< device_t > m_device
Definition lci_binding_post.hpp:3149
post_am_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3169
rcomp_t m_remote_comp
Definition lci_binding_post.hpp:3146
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:3153
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3156
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:3160
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3150
post_am_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3176
post_am_x && size(size_t size_in)
Definition lci_binding_post.hpp:3165
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3157
post_am_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3168
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3147
post_am_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3174
int m_rank
Definition lci_binding_post.hpp:3142
post_am_x && rank(int rank_in)
Definition lci_binding_post.hpp:3163
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3148
post_am_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3172
status_t call() const
Definition binding.cpp:802
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3151
status_t call_impl(int rank, void *local_buffer, size_t size, comp_t local_comp, rcomp_t remote_comp, runtime_t runtime, packet_pool_t packet_pool, device_t device, endpoint_t endpoint, 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:3173
comp_t m_local_comp
Definition lci_binding_post.hpp:3145
post_am_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3178
post_am_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3177
post_am_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3164
size_t m_size
Definition lci_binding_post.hpp:3144
post_am_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3171
post_am_x && device(device_t device_in)
Definition lci_binding_post.hpp:3170
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3155
post_am_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3175
void * m_local_buffer
Definition lci_binding_post.hpp:3143
post_am_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3166
status_t operator()() const
Definition lci_binding_post.hpp:3182
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3154
post_am_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:3167
The actual implementation for post_comm.
Definition lci_binding_post.hpp:3050
status_t call() const
Definition binding.cpp:777
void * m_local_buffer
Definition lci_binding_post.hpp:3055
status_t call_impl(direction_t direction, int rank, void *local_buffer, size_t size, comp_t local_comp, runtime_t runtime, packet_pool_t packet_pool, device_t device, endpoint_t endpoint, 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
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3069
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:3070
post_comm_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:3094
option_t< device_t > m_device
Definition lci_binding_post.hpp:3060
post_comm_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3088
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3073
int m_rank
Definition lci_binding_post.hpp:3054
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:3062
post_comm_x && rank(int rank_in)
Definition lci_binding_post.hpp:3080
post_comm_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3084
post_comm_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3081
size_t m_size
Definition lci_binding_post.hpp:3056
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3058
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3064
comp_t m_local_comp
Definition lci_binding_post.hpp:3057
status_t operator()() const
Definition lci_binding_post.hpp:3103
option_t< rmr_t > m_rmr
Definition lci_binding_post.hpp:3066
post_comm_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3095
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3072
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:3076
option_t< uintptr_t > m_remote_disp
Definition lci_binding_post.hpp:3065
post_comm_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3085
post_comm_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3097
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3061
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:3068
post_comm_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3083
post_comm_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3093
post_comm_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:3092
post_comm_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3090
post_comm_x && direction(direction_t direction_in)
Definition lci_binding_post.hpp:3079
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3071
post_comm_x && size(size_t size_in)
Definition lci_binding_post.hpp:3082
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3059
post_comm_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3087
post_comm_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3098
post_comm_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3089
post_comm_x && device(device_t device_in)
Definition lci_binding_post.hpp:3086
post_comm_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3099
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3063
post_comm_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:3096
direction_t m_direction
Definition lci_binding_post.hpp:3053
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:3067
post_comm_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:3091
The actual implementation for post_get.
Definition lci_binding_post.hpp:3465
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:3480
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3481
post_get_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3504
post_get_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3501
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, packet_pool_t packet_pool, device_t device, endpoint_t endpoint, mr_t mr, tag_t tag, rcomp_t remote_comp, void *user_context, bool allow_done, bool allow_posted, bool allow_retry) const
comp_t m_local_comp
Definition lci_binding_post.hpp:3471
post_get_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:3494
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:3487
post_get_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3500
status_t operator()() const
Definition lci_binding_post.hpp:3510
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3475
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3484
uintptr_t m_remote_disp
Definition lci_binding_post.hpp:3472
void * m_local_buffer
Definition lci_binding_post.hpp:3469
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3482
option_t< device_t > m_device
Definition lci_binding_post.hpp:3476
post_get_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:3495
int m_rank
Definition lci_binding_post.hpp:3468
post_get_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3491
post_get_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:3502
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3474
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3483
post_get_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3505
post_get_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3497
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3477
post_get_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3496
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3478
post_get_x && size(size_t size_in)
Definition lci_binding_post.hpp:3492
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:3479
post_get_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3499
status_t call() const
Definition binding.cpp:885
post_get_x && rank(int rank_in)
Definition lci_binding_post.hpp:3490
post_get_x && device(device_t device_in)
Definition lci_binding_post.hpp:3498
post_get_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3493
post_get_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3503
size_t m_size
Definition lci_binding_post.hpp:3470
rmr_t m_rmr
Definition lci_binding_post.hpp:3473
post_get_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3506
The actual implementation for post_put.
Definition lci_binding_post.hpp:3381
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3399
post_put_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3421
post_put_x && device(device_t device_in)
Definition lci_binding_post.hpp:3415
status_t operator()() const
Definition lci_binding_post.hpp:3428
post_put_x && rank(int rank_in)
Definition lci_binding_post.hpp:3407
post_put_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3413
post_put_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3416
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3400
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3393
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, packet_pool_t packet_pool, device_t device, endpoint_t endpoint, 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
comp_t m_local_comp
Definition lci_binding_post.hpp:3387
uintptr_t m_remote_disp
Definition lci_binding_post.hpp:3388
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3401
option_t< device_t > m_device
Definition lci_binding_post.hpp:3392
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3398
post_put_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3408
int m_rank
Definition lci_binding_post.hpp:3384
post_put_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3414
option_t< rcomp_t > m_remote_comp
Definition lci_binding_post.hpp:3397
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:3404
post_put_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3419
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3395
post_put_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3422
option_t< tag_t > m_tag
Definition lci_binding_post.hpp:3396
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3394
post_put_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3417
status_t call() const
Definition binding.cpp:863
post_put_x && size(size_t size_in)
Definition lci_binding_post.hpp:3409
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3390
post_put_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3424
post_put_x && rmr(rmr_t rmr_in)
Definition lci_binding_post.hpp:3412
post_put_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3410
post_put_x && remote_disp(uintptr_t remote_disp_in)
Definition lci_binding_post.hpp:3411
rmr_t m_rmr
Definition lci_binding_post.hpp:3389
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3391
size_t m_size
Definition lci_binding_post.hpp:3386
post_put_x && remote_comp(rcomp_t remote_comp_in)
Definition lci_binding_post.hpp:3420
post_put_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3418
void * m_local_buffer
Definition lci_binding_post.hpp:3385
post_put_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3423
The actual implementation for post_recv.
Definition lci_binding_post.hpp:3300
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3318
post_recv_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3338
size_t m_size
Definition lci_binding_post.hpp:3305
post_recv_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3337
post_recv_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3327
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3314
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:3312
tag_t m_tag
Definition lci_binding_post.hpp:3306
post_recv_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3330
post_recv_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3329
option_t< device_t > m_device
Definition lci_binding_post.hpp:3310
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3316
post_recv_x && size(size_t size_in)
Definition lci_binding_post.hpp:3326
status_t operator()() const
Definition lci_binding_post.hpp:3343
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3309
post_recv_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3335
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3313
void * m_local_buffer
Definition lci_binding_post.hpp:3304
post_recv_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3332
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3311
post_recv_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3333
comp_t m_local_comp
Definition lci_binding_post.hpp:3307
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3317
post_recv_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3334
post_recv_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3339
post_recv_x && device(device_t device_in)
Definition lci_binding_post.hpp:3331
status_t call_impl(int rank, void *local_buffer, size_t size, tag_t tag, comp_t local_comp, runtime_t runtime, packet_pool_t packet_pool, device_t device, endpoint_t endpoint, matching_engine_t matching_engine, mr_t mr, 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:3303
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:3321
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3308
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:3315
post_recv_x && rank(int rank_in)
Definition lci_binding_post.hpp:3324
post_recv_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3328
post_recv_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:3336
post_recv_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3325
status_t call() const
Definition binding.cpp:843
The actual implementation for post_send.
Definition lci_binding_post.hpp:3219
post_send_x && allow_done(bool allow_done_in)
Definition lci_binding_post.hpp:3258
post_send_x && local_comp(comp_t local_comp_in)
Definition lci_binding_post.hpp:3248
option_t< packet_pool_t > m_packet_pool
Definition lci_binding_post.hpp:3228
status_t call() const
Definition binding.cpp:822
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:3231
post_send_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:3252
void * m_local_buffer
Definition lci_binding_post.hpp:3223
option_t< void * > m_user_context
Definition lci_binding_post.hpp:3234
post_send_x && mr(mr_t mr_in)
Definition lci_binding_post.hpp:3255
option_t< bool > m_allow_done
Definition lci_binding_post.hpp:3236
size_t m_size
Definition lci_binding_post.hpp:3224
int m_rank
Definition lci_binding_post.hpp:3222
post_send_x && local_buffer(void *local_buffer_in)
Definition lci_binding_post.hpp:3245
tag_t m_tag
Definition lci_binding_post.hpp:3225
post_send_x && size(size_t size_in)
Definition lci_binding_post.hpp:3246
comp_t m_local_comp
Definition lci_binding_post.hpp:3226
status_t call_impl(int rank, void *local_buffer, size_t size, tag_t tag, comp_t local_comp, runtime_t runtime, packet_pool_t packet_pool, device_t device, endpoint_t endpoint, 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(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:3241
status_t operator()() const
Definition lci_binding_post.hpp:3264
post_send_x && rank(int rank_in)
Definition lci_binding_post.hpp:3244
post_send_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3249
post_send_x && allow_retry(bool allow_retry_in)
Definition lci_binding_post.hpp:3260
option_t< mr_t > m_mr
Definition lci_binding_post.hpp:3233
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3230
post_send_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:3253
post_send_x && comp_semantic(comp_semantic_t comp_semantic_in)
Definition lci_binding_post.hpp:3254
post_send_x && allow_posted(bool allow_posted_in)
Definition lci_binding_post.hpp:3259
option_t< device_t > m_device
Definition lci_binding_post.hpp:3229
post_send_x && user_context(void *user_context_in)
Definition lci_binding_post.hpp:3256
option_t< comp_semantic_t > m_comp_semantic
Definition lci_binding_post.hpp:3232
option_t< matching_policy_t > m_matching_policy
Definition lci_binding_post.hpp:3235
post_send_x && tag(tag_t tag_in)
Definition lci_binding_post.hpp:3247
post_send_x && matching_policy(matching_policy_t matching_policy_in)
Definition lci_binding_post.hpp:3257
option_t< bool > m_allow_retry
Definition lci_binding_post.hpp:3238
option_t< bool > m_allow_posted
Definition lci_binding_post.hpp:3237
post_send_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:3250
post_send_x && device(device_t device_in)
Definition lci_binding_post.hpp:3251
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3227
The actual implementation for progress.
Definition lci_binding_post.hpp:3533
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:3536
error_t call() const
Definition binding.cpp:906
progress_x()
Definition lci_binding_post.hpp:3541
progress_x && device(device_t device_in)
Definition lci_binding_post.hpp:3545
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:3538
option_t< device_t > m_device
Definition lci_binding_post.hpp:3537
error_t operator()() const
Definition lci_binding_post.hpp:3550
progress_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:3544
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:3546
The actual implementation for put_upacket.
Definition lci_binding_post.hpp:1378
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1382
void * m_packet
Definition lci_binding_post.hpp:1381
void call() const
Definition binding.cpp:461
void operator()() const
Definition lci_binding_post.hpp:1393
put_upacket_x && packet(void *packet_in)
Definition lci_binding_post.hpp:1388
put_upacket_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1389
put_upacket_x(void *packet_in)
Definition lci_binding_post.hpp:1385
void call_impl(void *packet, runtime_t runtime) const
The actual implementation for reduce_scatter.
Definition lci_binding_post.hpp:2803
reduce_scatter_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2824
reduce_scatter_x && item_size(size_t item_size_in)
Definition lci_binding_post.hpp:2826
reduce_scatter_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2831
option_t< int > m_ring_nsteps
Definition lci_binding_post.hpp:2817
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2813
reduce_scatter_x && device(device_t device_in)
Definition lci_binding_post.hpp:2829
reduce_scatter_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2823
reduce_scatter_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2832
option_t< comp_t > m_comp
Definition lci_binding_post.hpp:2815
option_t< reduce_scatter_algorithm_t > m_algorithm
Definition lci_binding_post.hpp:2816
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2811
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:2807
size_t m_item_size
Definition lci_binding_post.hpp:2809
const void * m_sendbuf
Definition lci_binding_post.hpp:2806
size_t m_recvcount
Definition lci_binding_post.hpp:2808
reduce_scatter_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:2827
void operator()() const
Definition lci_binding_post.hpp:2838
reduce_scatter_x && algorithm(reduce_scatter_algorithm_t algorithm_in)
Definition lci_binding_post.hpp:2833
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2814
reduce_op_t m_op
Definition lci_binding_post.hpp:2810
void call() const
Definition binding.cpp:723
reduce_scatter_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2828
option_t< device_t > m_device
Definition lci_binding_post.hpp:2812
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:2820
reduce_scatter_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2830
reduce_scatter_x && recvcount(size_t recvcount_in)
Definition lci_binding_post.hpp:2825
reduce_scatter_x && ring_nsteps(int ring_nsteps_in)
Definition lci_binding_post.hpp:2834
The actual implementation for reduce.
Definition lci_binding_post.hpp:2740
void operator()() const
Definition lci_binding_post.hpp:2771
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:2755
reduce_x && op(reduce_op_t op_in)
Definition lci_binding_post.hpp:2762
reduce_x && matching_engine(matching_engine_t matching_engine_in)
Definition lci_binding_post.hpp:2767
reduce_x && recvbuf(void *recvbuf_in)
Definition lci_binding_post.hpp:2759
option_t< device_t > m_device
Definition lci_binding_post.hpp:2750
int m_root
Definition lci_binding_post.hpp:2748
size_t m_count
Definition lci_binding_post.hpp:2745
reduce_x && count(size_t count_in)
Definition lci_binding_post.hpp:2760
reduce_op_t m_op
Definition lci_binding_post.hpp:2747
reduce_x && device(device_t device_in)
Definition lci_binding_post.hpp:2765
size_t m_item_size
Definition lci_binding_post.hpp:2746
option_t< endpoint_t > m_endpoint
Definition lci_binding_post.hpp:2751
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:2744
reduce_x && sendbuf(const void *sendbuf_in)
Definition lci_binding_post.hpp:2758
option_t< matching_engine_t > m_matching_engine
Definition lci_binding_post.hpp:2752
reduce_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2764
reduce_x && item_size(size_t item_size_in)
Definition lci_binding_post.hpp:2761
reduce_x && endpoint(endpoint_t endpoint_in)
Definition lci_binding_post.hpp:2766
reduce_x && root(int root_in)
Definition lci_binding_post.hpp:2763
const void * m_sendbuf
Definition lci_binding_post.hpp:2743
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2749
void call() const
Definition binding.cpp:709
The actual implementation for register_memory.
Definition lci_binding_post.hpp:225
register_memory_x && address(void *address_in)
Definition lci_binding_post.hpp:237
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:230
register_memory_x && device(device_t device_in)
Definition lci_binding_post.hpp:240
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:238
option_t< device_t > m_device
Definition lci_binding_post.hpp:231
void * m_address
Definition lci_binding_post.hpp:228
mr_t operator()() const
Definition lci_binding_post.hpp:244
register_memory_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:239
register_memory_x(void *address_in, size_t size_in)
Definition lci_binding_post.hpp:234
size_t m_size
Definition lci_binding_post.hpp:229
mr_t call() const
Definition binding.cpp:216
The actual implementation for register_packet_pool.
Definition lci_binding_post.hpp:1262
device_t m_device
Definition lci_binding_post.hpp:1266
void call_impl(packet_pool_t packet_pool, device_t device, runtime_t runtime) const
void operator()() const
Definition lci_binding_post.hpp:1279
register_packet_pool_x(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:1270
register_packet_pool_x && packet_pool(packet_pool_t packet_pool_in)
Definition lci_binding_post.hpp:1273
void call() const
Definition binding.cpp:441
register_packet_pool_x && device(device_t device_in)
Definition lci_binding_post.hpp:1274
packet_pool_t m_packet_pool
Definition lci_binding_post.hpp:1265
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1267
register_packet_pool_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1275
The actual implementation for register_rcomp.
Definition lci_binding_post.hpp:1934
rcomp_t call() const
Definition binding.cpp:563
rcomp_t operator()() const
Definition lci_binding_post.hpp:1951
comp_t m_comp
Definition lci_binding_post.hpp:1937
option_t< rcomp_t > m_rcomp
Definition lci_binding_post.hpp:1939
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1938
register_rcomp_x && rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:1947
register_rcomp_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1946
register_rcomp_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:1945
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:1942
The actual implementation for reserve_rcomps.
Definition lci_binding_post.hpp:1896
rcomp_t call_impl(rcomp_t n, runtime_t runtime) const
rcomp_t m_n
Definition lci_binding_post.hpp:1899
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1900
reserve_rcomps_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1907
rcomp_t call() const
Definition binding.cpp:557
reserve_rcomps_x(rcomp_t n_in)
Definition lci_binding_post.hpp:1903
rcomp_t operator()() const
Definition lci_binding_post.hpp:1911
reserve_rcomps_x && n(rcomp_t n_in)
Definition lci_binding_post.hpp:1906
The actual implementation for RESOURCE runtime.
Definition lci_binding_pre.hpp:326
The actual implementation for set_allocator.
Definition lci_binding_post.hpp:1538
set_allocator_x(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:1545
set_allocator_x && allocator(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:1548
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:1542
void call_impl(allocator_base_t *allocator, runtime_t runtime) const
set_allocator_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:1549
void call() const
Definition binding.cpp:493
allocator_base_t * m_allocator
Definition lci_binding_post.hpp:1541
void operator()() const
Definition lci_binding_post.hpp:1553
The actual implementation for sync_test.
Definition lci_binding_post.hpp:2054
comp_t m_comp
Definition lci_binding_post.hpp:2057
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:2066
status_t * m_p_out
Definition lci_binding_post.hpp:2058
sync_test_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2067
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2059
bool operator()() const
Definition lci_binding_post.hpp:2071
sync_test_x(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:2062
sync_test_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2065
bool call() const
Definition binding.cpp:584
The actual implementation for sync_wait.
Definition lci_binding_post.hpp:2096
option_t< runtime_t > m_runtime
Definition lci_binding_post.hpp:2101
sync_wait_x(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:2106
comp_t m_comp
Definition lci_binding_post.hpp:2099
sync_wait_x && p_out(status_t *p_out_in)
Definition lci_binding_post.hpp:2110
option_t< device_t > m_device
Definition lci_binding_post.hpp:2103
sync_wait_x && runtime(runtime_t runtime_in)
Definition lci_binding_post.hpp:2111
void call() const
Definition binding.cpp:591
status_t * m_p_out
Definition lci_binding_post.hpp:2100
option_t< bool > m_do_progress
Definition lci_binding_post.hpp:2102
sync_wait_x && device(device_t device_in)
Definition lci_binding_post.hpp:2113
sync_wait_x && do_progress(bool do_progress_in)
Definition lci_binding_post.hpp:2112
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:2117
sync_wait_x && comp(comp_t comp_in)
Definition lci_binding_post.hpp:2109
broadcast_algorithm_t
The type of broadcast algorithm.
Definition lci.hpp:229
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:571
uint64_t matching_entry_key_t
The type of matching engine entry key.
Definition lci.hpp:403
status_t(*)(void *value) graph_node_run_cb_t
The function signature for a node function in the completion graph.
Definition lci.hpp:550
direction_t
The enum class of comunication direction.
Definition lci.hpp:353
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:565
void(*)(const void *left, const void *right, void *dst, size_t n) reduce_op_t
The user-defined reduction operation.
Definition lci.hpp:530
matching_policy_t
Enum class for matching policy.
Definition lci.hpp:392
void * graph_node_t
The node type for the completion graph.
Definition lci.hpp:536
allreduce_algorithm_t
The type of allreduce algorithm.
Definition lci.hpp:265
reduce_scatter_algorithm_t
The type of reduce scatter algorithm.
Definition lci.hpp:247
void * matching_entry_val_t
The type of matching engine entry value.
Definition lci.hpp:408
matching_entry_type_t
The type of matching entry.
Definition lci.hpp:383
uint32_t rcomp_t
The type of remote completion handler.
Definition lci.hpp:364
void(*)(status_t status) comp_handler_t
Function Signature for completion handler.
Definition lci.hpp:523
uint64_t tag_t
The type of tag.
Definition lci.hpp:347
comp_semantic_t
The enum class of completion semantic.
Definition lci.hpp:418
uint32_t net_imm_data_t
The type of network-layer immediate data field.
Definition lci.hpp:284
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:3106
error_t net_post_send(int rank_in, void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:600
void graph_node_mark_complete(graph_node_t node_in)
Definition lci_binding_post.hpp:2529
size_t get_max_bcopy_size()
Definition lci_binding_post.hpp:1800
attr_matching_engine_type_t
Definition lci_binding_pre.hpp:47
void broadcast(void *buffer_in, size_t size_in, int root_in)
Definition lci_binding_post.hpp:2713
device_t alloc_device()
Definition lci_binding_post.hpp:167
net_context_t alloc_net_context()
Definition lci_binding_post.hpp:69
void free_net_context(net_context_t *net_context_in)
Definition lci_binding_post.hpp:106
error_t net_post_recv(void *buffer_in, size_t size_in, mr_t mr_in)
Definition lci_binding_post.hpp:490
attr_backend_t
Definition lci.hpp:63
void deregister_rcomp(rcomp_t rcomp_in)
Definition lci_binding_post.hpp:1991
void deregister_memory(mr_t *mr_in)
Definition lci_binding_post.hpp:284
comp_t alloc_counter()
Definition lci_binding_post.hpp:2154
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:3185
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:1519
rcomp_t reserve_rcomps(rcomp_t n_in)
Definition lci_binding_post.hpp:1914
void sync_wait(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:2120
matching_engine_t alloc_matching_engine()
Definition lci_binding_post.hpp:1436
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:774
void alltoall(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:3012
status_t graph_test(comp_t comp_in)
Definition lci_binding_post.hpp:2603
void register_packet_pool(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:1282
matching_engine_t get_default_matching_engine()
Definition lci_binding_post.hpp:1763
status_t cq_pop(comp_t comp_in)
Definition lci_binding_post.hpp:2314
size_t net_poll_cq(size_t max_polls_in, net_status_t *statuses_in)
Definition lci_binding_post.hpp:441
void graph_start(comp_t comp_in)
Definition lci_binding_post.hpp:2566
void free_matching_engine(matching_engine_t *matching_engine_in)
Definition lci_binding_post.hpp:1473
int get_rank_n()
Definition lci_binding_post.hpp:963
void put_upacket(void *packet_in)
Definition lci_binding_post.hpp:1396
comp_t alloc_cq()
Definition lci_binding_post.hpp:2277
void g_runtime_fina()
Definition lci_binding_post.hpp:1130
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:655
rcomp_t register_rcomp(comp_t comp_in)
Definition lci_binding_post.hpp:1954
error_t net_post_sends(int rank_in, void *buffer_in, size_t size_in)
Definition lci_binding_post.hpp:542
void graph_add_edge(comp_t comp_in, graph_node_t src_in, graph_node_t dst_in)
Definition lci_binding_post.hpp:2489
void set_allocator(allocator_base_t *allocator_in)
Definition lci_binding_post.hpp:1556
allocator_base_t * get_allocator()
Definition lci_binding_post.hpp:1590
net_context_t get_default_net_context()
Definition lci_binding_post.hpp:1624
void free_device(device_t *device_in)
Definition lci_binding_post.hpp:204
void free_comp(comp_t *comp_in)
Definition lci_binding_post.hpp:1837
packet_pool_t get_default_packet_pool()
Definition lci_binding_post.hpp:1729
void free_runtime(runtime_t *runtime_in)
Definition lci_binding_post.hpp:1049
int get_rank_me()
Definition lci_binding_post.hpp:931
comp_t alloc_handler(comp_handler_t handler_in)
Definition lci_binding_post.hpp:2357
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:838
runtime_t get_g_runtime()
Definition lci_binding_post.hpp:1162
void free_packet_pool(packet_pool_t *packet_pool_in)
Definition lci_binding_post.hpp:1242
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:2774
void deregister_packet_pool(packet_pool_t packet_pool_in, device_t device_in)
Definition lci_binding_post.hpp:1322
void counter_set(comp_t comp_in, int64_t value_in)
Definition lci_binding_post.hpp:2231
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:3267
void comp_signal(comp_t comp_in, status_t status_in)
Definition lci_binding_post.hpp:1877
mr_t register_memory(void *address_in, size_t size_in)
Definition lci_binding_post.hpp:247
rmr_t get_rmr(mr_t mr_in)
Definition lci_binding_post.hpp:321
endpoint_t alloc_endpoint()
Definition lci_binding_post.hpp:361
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:3431
endpoint_t get_default_endpoint()
Definition lci_binding_post.hpp:1695
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:2908
graph_node_t graph_add_node(comp_t comp_in, graph_node_run_cb_t fn_in)
Definition lci_binding_post.hpp:2443
runtime_t alloc_runtime()
Definition lci_binding_post.hpp:1015
void allgather(const void *sendbuf_in, void *recvbuf_in, size_t size_in)
Definition lci_binding_post.hpp:2960
bool sync_test(comp_t comp_in, status_t *p_out_in)
Definition lci_binding_post.hpp:2074
attr_ibv_td_strategy_t
Definition lci_binding_pre.hpp:41
error_t progress()
Definition lci_binding_post.hpp:3553
attr_ibv_odp_strategy_t
Definition lci_binding_pre.hpp:28
device_t get_default_device()
Definition lci_binding_post.hpp:1658
int64_t counter_get(comp_t comp_in)
Definition lci_binding_post.hpp:2191
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:2841
packet_pool_t alloc_packet_pool()
Definition lci_binding_post.hpp:1205
attr_ibv_prefetch_strategy_t
Definition lci_binding_pre.hpp:34
void barrier()
Definition lci_binding_post.hpp:2652
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:899
attr_cq_type_t
Definition lci_binding_pre.hpp:61
comp_t alloc_graph()
Definition lci_binding_post.hpp:2397
void g_runtime_init()
Definition lci_binding_post.hpp:1098
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:3346
void * get_upacket()
Definition lci_binding_post.hpp:1359
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:716
comp_t alloc_sync()
Definition lci_binding_post.hpp:2034
void free_endpoint(endpoint_t *endpoint_in)
Definition lci_binding_post.hpp:398
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:3513
The user-defined allocator type.
Definition lci.hpp:427
Wrapper class for error code.
Definition lci.hpp:160
The struct for network status.
Definition lci.hpp:292
Definition lci.hpp:79
The type of remote memory region.
Definition lci.hpp:330
The type of the completion desciptor for a posted communication.
Definition lci.hpp:443