12 #include <ucp/api/ucp_def.h> 13 #include <ucp/api/ucp_compat.h> 14 #include <ucp/api/ucp_version.h> 15 #include <ucs/type/thread_mode.h> 16 #include <ucs/type/cpu_set.h> 17 #include <ucs/config/types.h> 18 #include <ucs/sys/compiler_def.h> 19 #include <ucs/memory/memory_type.h> 21 #include <sys/types.h> 690 #define ucp_dt_make_contig(_elem_size) \ 691 (((ucp_datatype_t)(_elem_size) << UCP_DATATYPE_SHIFT) | UCP_DATATYPE_CONTIG) 707 #define ucp_dt_make_iov() ((ucp_datatype_t)UCP_DATATYPE_IOV) 755 void* (*start_pack)(
void *context,
const void *buffer,
size_t count);
771 void* (*start_unpack)(
void *context,
void *buffer,
size_t count);
804 size_t (*
pack) (
void *state,
size_t offset,
void *dest,
size_t max_length);
1570 const char *title, ucs_config_print_flags_t print_flags);
1583 void ucp_get_version(
unsigned *major_version,
unsigned *minor_version,
1584 unsigned *release_number);
1605 ucs_status_t ucp_init_version(
unsigned api_major_version,
unsigned api_minor_version,
1650 return ucp_init_version(UCP_API_MAJOR, UCP_API_MINOR, params, config,
1798 size_t *address_length_p);
2566 void **rkey_buffer_p,
size_t *size_p);
2738 const void *buffer,
size_t count,
2793 const void *header,
size_t header_length,
2794 const void *buffer,
size_t count,
2839 void *buffer,
size_t count,
3211 size_t *length,
unsigned flags);
3806 size_t op_size, uint64_t remote_addr,
ucp_rkey_h rkey);
3857 uint64_t value,
void *result,
size_t op_size,
3930 size_t count, uint64_t remote_addr,
ucp_rkey_h rkey,
ucs_status_t ucp_ep_rkey_unpack(ucp_ep_h ep, const void *rkey_buffer, ucp_rkey_h *rkey_p)
Create remote access key from packed buffer.
void ucp_context_print_info(const ucp_context_h context, FILE *stream)
Print context information.
ucp_listener_params_field
UCP listener parameters field mask.
Definition: ucp.h:180
size_t estimated_num_eps
Definition: ucp.h:935
Tuning parameters for the UCP endpoint.
Definition: ucp_def.h:673
uint32_t flags
Definition: ucp.h:1459
void ucp_rkey_buffer_release(void *rkey_buffer)
Release packed remote key buffer.
ucs_status_t ucp_context_query(ucp_context_h context_p, ucp_context_attr_t *attr)
Get attributes specific to a particular context.
ucs_status_ptr_t ucp_tag_send_nbx(ucp_ep_h ep, const void *buffer, size_t count, ucp_tag_t tag, const ucp_request_param_t *param)
Non-blocking tagged-send operation.
ucp_mem_map_params_field
UCP memory mapping parameters field mask.
Definition: ucp.h:323
UCP receive information descriptor.
Definition: ucp.h:1316
uint64_t field_mask
Definition: ucp.h:2493
struct ucp_mem * ucp_mem_h
UCP Memory handle.
Definition: ucp_def.h:165
ucs_status_t ucp_put_nbi(ucp_ep_h ep, const void *buffer, size_t length, uint64_t remote_addr, ucp_rkey_h rkey)
Non-blocking implicit remote memory put operation.
ucp_am_cb_flags
Flags for a UCP Active Message callback.
Definition: ucp.h:471
ucs_status_t ucp_worker_get_address(ucp_worker_h worker, ucp_address_t **address_p, size_t *address_length_p)
Get the address of the worker object.
ucs_status_t ucp_dt_create_generic(const ucp_generic_dt_ops_t *ops, void *context, ucp_datatype_t *datatype_p)
Create a generic datatype.
void(* ucp_tag_recv_callback_t)(void *request, ucs_status_t status, ucp_tag_recv_info_t *info)
Completion callback for non-blocking tag receives.
Definition: ucp_def.h:484
ucs_status_t ucp_mem_unmap(ucp_context_h context, ucp_mem_h memh)
Unmap memory segment.
uint64_t ucp_datatype_t
UCP Datatype Identifier.
Definition: ucp_def.h:270
uint64_t field_mask
Definition: ucp.h:1125
void(* ucp_stream_recv_callback_t)(void *request, ucs_status_t status, size_t length)
Completion callback for non-blocking stream oriented receives.
Definition: ucp_def.h:439
ucs_status_ptr_t ucp_tag_send_sync_nbx(ucp_ep_h ep, const void *buffer, size_t count, ucp_tag_t tag, const ucp_request_param_t *param)
Non-blocking synchronous tagged-send operation.
ucp_request_cleanup_callback_t request_cleanup
Definition: ucp.h:901
uint32_t op_attr_mask
Definition: ucp.h:1370
Tuning parameters for the UCP worker.
Definition: ucp.h:1043
ucp_am_recv_attr_t
UCP AM receive data parameter fields and flags.
Definition: ucp.h:626
ucp_tag_t sender_tag
Definition: ucp.h:1318
ucs_status_t ucp_mem_map(ucp_context_h context, const ucp_mem_map_params_t *params, ucp_mem_h *memh_p)
Map or allocate memory for zero-copy operations.
ssize_t ucp_stream_worker_poll(ucp_worker_h worker, ucp_stream_poll_ep_t *poll_eps, size_t max_eps, unsigned flags)
Poll for endpoints that are ready to consume streaming data.
ucp_listener_conn_handler_t conn_handler
Definition: ucp.h:1198
ucs_status_ptr_t ucp_atomic_fetch_nb(ucp_ep_h ep, ucp_atomic_fetch_op_t opcode, uint64_t value, void *result, size_t op_size, uint64_t remote_addr, ucp_rkey_h rkey, ucp_send_callback_t cb)
Post an atomic fetch operation.
ucp_tag_message_h ucp_tag_probe_nb(ucp_worker_h worker, ucp_tag_t tag, ucp_tag_t tag_mask, int remove, ucp_tag_recv_info_t *info)
Non-blocking probe and return a message.
struct ucp_context * ucp_context_h
UCP Application Context.
Definition: ucp_def.h:58
ucp_params_field
UCP context parameters field mask.
Definition: ucp.h:119
ucs_status_t ucp_rkey_ptr(ucp_rkey_h rkey, uint64_t raddr, void **addr_p)
Get a local pointer to remote memory.
void * ucp_request_alloc(ucp_worker_h worker)
Create an empty communications request.
uint64_t field_mask
Definition: ucp.h:860
ucs_status_ptr_t ucp_ep_flush_nbx(ucp_ep_h ep, const ucp_request_param_t *param)
Non-blocking flush of outstanding AMO and RMA operations on the endpoint.
void(* ucp_tag_recv_nbx_callback_t)(void *request, ucs_status_t status, const ucp_tag_recv_info_t *tag_info, void *user_data)
Completion callback for non-blocking tag receives ucp_tag_recv_nbx call.
Definition: ucp_def.h:509
ucs_status_t ucp_worker_arm(ucp_worker_h worker)
Turn on event notification for the next event.
struct ucp_listener_params ucp_listener_params_t
Parameters for a UCP listener object.
struct ucp_conn_request * ucp_conn_request_h
UCP connection request.
Definition: ucp_def.h:100
void ucp_dt_destroy(ucp_datatype_t datatype)
Destroy a datatype and release its resources.
void * request
Definition: ucp.h:1381
uint8_t reserved[16]
Definition: ucp.h:1228
struct ucp_dt_iov ucp_dt_iov_t
Structure for scatter-gather I/O.
struct ucp_listener * ucp_listener_h
UCP listen handle.
Definition: ucp_def.h:175
ucs_thread_mode_t thread_mode
Definition: ucp.h:1005
void(* ucp_request_cleanup_callback_t)(void *request)
Request cleanup callback.
Definition: ucp_def.h:293
uint32_t flags
Definition: ucp.h:1373
Tuning parameters for the UCP memory mapping.
Definition: ucp.h:1239
ucs_status_ptr_t ucp_am_send_nbx(ucp_ep_h ep, unsigned id, const void *header, size_t header_length, const void *buffer, size_t count, const ucp_request_param_t *param)
Send Active Message.
unsigned flags
Definition: ucp.h:1223
ucp_atomic_fetch_op_t
Atomic operation requested for ucp_atomic_fetch.
Definition: ucp.h:537
ucs_status_t ucp_mem_query(const ucp_mem_h memh, ucp_mem_attr_t *attr)
query mapped memory segment
ucs_status_ptr_t ucp_stream_send_nbx(ucp_ep_h ep, const void *buffer, size_t count, const ucp_request_param_t *param)
Non-blocking stream send operation.
void ucp_worker_wait_mem(ucp_worker_h worker, void *address)
Wait for memory update on the address.
ucs_status_ptr_t ucp_stream_recv_nbx(ucp_ep_h ep, void *buffer, size_t count, size_t *length, const ucp_request_param_t *param)
Non-blocking stream receive operation of structured data into a user-supplied buffer.
void ucp_listener_destroy(ucp_listener_h listener)
Stop accepting connections on a local address of the worker object.
ucp_address_t * address
Definition: ucp.h:1022
void ucp_mem_print_info(const char *mem_size, ucp_context_h context, FILE *stream)
Print memory mapping information.
void ucp_cleanup(ucp_context_h context_p)
Release UCP application context.
Attributes of the UCP Memory handle, filled by ucp_mem_query function.
Definition: ucp_def.h:183
ucp_worker_params_field
UCP worker parameters field mask.
Definition: ucp.h:163
ucs_status_ptr_t ucp_tag_msg_recv_nb(ucp_worker_h worker, void *buffer, size_t count, ucp_datatype_t datatype, ucp_tag_message_h message, ucp_tag_recv_callback_t cb)
Non-blocking receive operation for a probed message.
unsigned events
Definition: ucp.h:1081
struct ucp_am_handler_param ucp_am_handler_param_t
Active Message handler parameters passed to ucp_worker_set_am_recv_handler routine.
unsigned flags
Definition: ucp.h:1276
ucp_context_attr_field
UCP context attributes field mask.
Definition: ucp.h:357
size_t estimated_num_ppn
Definition: ucp.h:945
ucp_ep_h reply_ep
Definition: ucp.h:1490
void ucp_worker_release_address(ucp_worker_h worker, ucp_address_t *address)
Release an address of the worker object.
ucs_thread_mode_t
Thread sharing mode.
Definition: thread_mode.h:19
void ucp_ep_print_info(ucp_ep_h ep, FILE *stream)
Print endpoint information.
ucs_status_t ucp_ep_create(ucp_worker_h worker, const ucp_ep_params_t *params, ucp_ep_h *ep_p)
Create and connect an endpoint.
ucp_listener_attr_field
UCP listener attributes field mask.
Definition: ucp.h:387
void ucp_request_cancel(ucp_worker_h worker, void *request)
Cancel an outstanding communications request.
ucs_status_t ucp_worker_wait(ucp_worker_h worker)
Wait for an event of the worker.
Definition: ucp_compat.h:23
unsigned id
Definition: ucp.h:1454
size_t length
Definition: ucp.h:722
void(* ucp_send_nbx_callback_t)(void *request, ucs_status_t status, void *user_data)
Completion callback for non-blocking sends ucp_tag_send_nbx call.
Definition: ucp_def.h:331
void * address
Definition: ucp.h:1258
ucs_status_t ucp_config_read(const char *env_prefix, const char *filename, ucp_config_t **config_p)
Read UCP configuration descriptor.
uint64_t features
Definition: ucp.h:868
uint64_t field_mask
Definition: ucp.h:1173
void(* ucp_request_init_callback_t)(void *request)
Request initialization callback.
Definition: ucp_def.h:281
size_t(* packed_size)(void *state)
Get the total size of packed data.
Definition: ucp.h:786
unsigned prot
Definition: ucp.h:1285
ucs_status_ptr_t ucp_tag_recv_nbx(ucp_worker_h worker, void *buffer, size_t count, ucp_tag_t tag, ucp_tag_t tag_mask, const ucp_request_param_t *param)
Non-blocking tagged-receive operation.
ucp_ep_h ep
Definition: ucp.h:1212
ucs_status_t ucp_stream_recv_request_test(void *request, size_t *length_p)
Check the status and currently available state of non-blocking request returned from ucp_stream_recv_...
ucs_status_t ucp_tag_send_nbr(ucp_ep_h ep, const void *buffer, size_t count, ucp_datatype_t datatype, ucp_tag_t tag, void *req)
Non-blocking tagged-send operations with user provided request.
struct ucp_conn_request_attr ucp_conn_request_attr_t
UCP listener's connection request attributes.
size_t max_am_header
Definition: ucp.h:1032
size_t address_length
Definition: ucp.h:1027
ucs_status_t
Status codes.
Definition: status.h:45
ucp_mem_advise_params_field
UCP memory advice parameters field mask.
Definition: ucp.h:343
ucs_status_ptr_t ucp_am_send_nb(ucp_ep_h ep, uint16_t id, const void *buffer, size_t count, ucp_datatype_t datatype, ucp_send_callback_t cb, unsigned flags)
Send Active Message.
struct ucp_address ucp_address_t
UCP worker address.
Definition: ucp_def.h:110
struct ucp_params ucp_params_t
Tuning parameters for UCP library.
Output parameter of ucp_stream_worker_poll function.
Definition: ucp.h:1208
void(* ucp_stream_recv_nbx_callback_t)(void *request, ucs_status_t status, size_t length, void *user_data)
Completion callback for non-blocking stream receives ucp_stream_recv_nbx call.
Definition: ucp_def.h:461
void(* ucp_send_callback_t)(void *request, ucs_status_t status)
Completion callback for non-blocking sends.
Definition: ucp_def.h:311
void ucp_worker_destroy(ucp_worker_h worker)
Destroy a worker object.
struct ucp_worker_params ucp_worker_params_t
Tuning parameters for the UCP worker.
size_t length
Definition: ucp.h:1320
ucs_status_ptr_t ucp_worker_flush_nb(ucp_worker_h worker, unsigned flags, ucp_send_callback_t cb)
Flush outstanding AMO and RMA operations on the worker.
ucs_status_t ucp_get_nbi(ucp_ep_h ep, void *buffer, size_t length, uint64_t remote_addr, ucp_rkey_h rkey)
Non-blocking implicit remote memory get operation.
ucs_status_t ucp_request_check_status(void *request)
Check the status of non-blocking request.
ucs_status_ptr_t ucp_stream_recv_data_nb(ucp_ep_h ep, size_t *length)
Non-blocking stream receive operation of unstructured data into a UCP-supplied buffer.
unsigned ucp_worker_progress(ucp_worker_h worker)
Progress all communications on a specific worker.
ucs_status_t ucp_worker_fence(ucp_worker_h worker)
Assures ordering between non-blocking operations.
ucp_request_init_callback_t request_init
Definition: ucp.h:890
ucs_status_t(* ucp_am_recv_callback_t)(void *arg, const void *header, size_t header_length, void *data, size_t length, const ucp_am_recv_param_t *param)
Callback to process incoming Active Message sent by ucp_am_send_nbx routine.
Definition: ucp_def.h:660
ucp_atomic_post_op_t
Atomic operation requested for ucp_atomic_post.
Definition: ucp.h:520
uint64_t memory_types
Definition: ucp.h:982
uint64_t field_mask
Definition: ucp.h:1149
UCP generic data type descriptor.
Definition: ucp.h:739
void ucp_get_version(unsigned *major_version, unsigned *minor_version, unsigned *release_number)
Get UCP library version.
ucp_cb_param_flags
Descriptor flags for Active Message callback.
Definition: ucp.h:507
struct ucp_config ucp_config_t
UCP configuration descriptor.
Definition: ucp_def.h:75
size_t length
Definition: ucp.h:1267
ucs_status_ptr_t ucp_tag_send_nb(ucp_ep_h ep, const void *buffer, size_t count, ucp_datatype_t datatype, ucp_tag_t tag, ucp_send_callback_t cb)
Non-blocking tagged-send operations.
void ucp_stream_data_release(ucp_ep_h ep, void *data)
Release UCP data buffer returned by ucp_stream_recv_data_nb.
Operation parameters provided in ucp_am_recv_callback_t callback.
Definition: ucp.h:1479
ucs_status_ptr_t ucp_ep_close_nbx(ucp_ep_h ep, const ucp_request_param_t *param)
Non-blocking endpoint closure.
void ucp_request_free(void *request)
Release a communications request.
struct ucp_recv_desc * ucp_tag_message_h
UCP Message descriptor.
Definition: ucp_def.h:260
ucp_mem_advice_t advice
Definition: ucp.h:2508
ucp_ep_params_field
UCP endpoint parameters field mask.
Definition: ucp.h:221
ucp_stream_recv_flags_t
Flags to define behavior of ucp_stream_recv_nb function.
Definition: ucp.h:572
enum ucp_mem_advice ucp_mem_advice_t
list of UCP memory use advice.
ucp_ep_close_mode
Close UCP endpoint modes.
Definition: ucp.h:296
uint64_t recv_attr
Definition: ucp.h:1485
uint64_t tag_sender_mask
Definition: ucp.h:908
void * arg
Definition: ucp.h:1471
ucs_status_ptr_t ucp_get_nbx(ucp_ep_h ep, void *buffer, size_t count, uint64_t remote_addr, ucp_rkey_h rkey, const ucp_request_param_t *param)
Non-blocking remote memory get operation.
UCP listener's connection request attributes.
Definition: ucp.h:1142
ucs_status_t(* unpack)(void *state, size_t offset, const void *src, size_t length)
Unpack data.
Definition: ucp.h:821
void ucp_config_release(ucp_config_t *config)
Release configuration descriptor.
ucs_status_t ucp_listener_reject(ucp_listener_h listener, ucp_conn_request_h conn_request)
Reject an incoming connection request.
ucp_am_handler_param_field
UCP AM receive data parameters fields and flags.
Definition: ucp.h:656
ucs_status_ptr_t ucp_tag_msg_recv_nbx(ucp_worker_h worker, void *buffer, size_t count, ucp_tag_message_h message, const ucp_request_param_t *param)
Non-blocking receive operation for a probed message.
uint64_t field_mask
Definition: ucp.h:1049
ucs_status_t ucp_mem_advise(ucp_context_h context, ucp_mem_h memh, ucp_mem_advise_params_t *params)
give advice about the use of memory
ucp_atomic_op_t
Atomic operation requested for ucp_atomic_op_nbx.
Definition: ucp.h:555
struct ucp_stream_poll_ep ucp_stream_poll_ep_t
Output parameter of ucp_stream_worker_poll function.
ucs_status_ptr_t ucp_stream_send_nb(ucp_ep_h ep, const void *buffer, size_t count, ucp_datatype_t datatype, ucp_send_callback_t cb, unsigned flags)
Non-blocking stream send operation.
void(* finish)(void *state)
Finish packing/unpacking.
Definition: ucp.h:837
enum ucs_memory_type ucs_memory_type_t
Memory types.
ucs_status_t ucp_atomic_post(ucp_ep_h ep, ucp_atomic_post_op_t opcode, uint64_t value, size_t op_size, uint64_t remote_addr, ucp_rkey_h rkey)
Post an atomic memory operation.
uint64_t field_mask
Definition: ucp.h:1449
ucp_feature
UCP configuration features.
Definition: ucp.h:139
Structure for scatter-gather I/O.
Definition: ucp.h:720
struct sockaddr_storage sockaddr
Definition: ucp.h:1131
Context attributes.
Definition: ucp.h:956
const char * ucp_get_version_string(void)
Get UCP library version as a string.
ucs_status_t ucp_tag_recv_nbr(ucp_worker_h worker, void *buffer, size_t count, ucp_datatype_t datatype, ucp_tag_t tag, ucp_tag_t tag_mask, void *req)
Non-blocking tagged-receive operation.
ucs_status_t ucp_worker_query(ucp_worker_h worker, ucp_worker_attr_t *attr)
Get attributes specific to a particular worker.
ucp_send_am_flags
Flags for sending a UCP Active Message.
Definition: ucp.h:483
void * ucs_status_ptr_t
Status pointer.
Definition: status.h:106
static ucs_status_t ucp_init(const ucp_params_t *params, const ucp_config_t *config, ucp_context_h *context_p)
UCP context initialization.
Definition: ucp.h:1646
ucp_am_recv_callback_t cb
Definition: ucp.h:1465
uint64_t ucp_tag_t
UCP Tag Identifier.
Definition: ucp_def.h:249
UCP listener attributes.
Definition: ucp.h:1118
ucp_op_attr_t
UCP operation fields and flags.
Definition: ucp.h:590
uint64_t field_mask
Definition: ucp.h:1246
void * user_data
Definition: ucp.h:1404
ucs_status_t ucp_conn_request_query(ucp_conn_request_h conn_request, ucp_conn_request_attr_t *attr)
Get attributes specific to a particular connection request received on the server side.
ucs_status_t ucp_config_modify(ucp_config_t *config, const char *name, const char *value)
Modify context configuration.
UCP worker attributes.
Definition: ucp.h:993
struct ucp_mem_advise_params ucp_mem_advise_params_t
Tuning parameters for the UCP memory advice.
ucs_memory_type_t memory_type
Definition: ucp.h:1303
void * reply_buffer
Definition: ucp.h:1410
ucs_status_ptr_t ucp_atomic_op_nbx(ucp_ep_h ep, ucp_atomic_op_t opcode, const void *buffer, size_t count, uint64_t remote_addr, ucp_rkey_h rkey, const ucp_request_param_t *param)
Post an atomic memory operation.
void ucp_config_print(const ucp_config_t *config, FILE *stream, const char *title, ucs_config_print_flags_t print_flags)
Print configuration information.
Tuning parameters for UCP library.
Definition: ucp.h:854
ucs_status_t ucp_worker_set_am_recv_handler(ucp_worker_h worker, const ucp_am_handler_param_t *param)
Add user defined callback for Active Message.
struct ucp_worker * ucp_worker_h
UCP Worker.
Definition: ucp_def.h:238
ucp_worker_address_flags_t
UCP worker address flags.
Definition: ucp.h:205
ucs_status_t ucp_tag_recv_request_test(void *request, ucp_tag_recv_info_t *info)
Check the status and currently available state of non-blocking request returned from ucp_tag_recv_nb ...
Tuning parameters for the UCP memory advice.
Definition: ucp.h:2487
void ucp_worker_print_info(ucp_worker_h worker, FILE *stream)
Print information about the worker.
uint64_t field_mask
Definition: ucp.h:1000
Parameters for a UCP listener object.
Definition: ucp.h:1166
struct ucp_context_attr ucp_context_attr_t
Context attributes.
ucs_status_ptr_t ucp_tag_recv_nb(ucp_worker_h worker, void *buffer, size_t count, ucp_datatype_t datatype, ucp_tag_t tag, ucp_tag_t tag_mask, ucp_tag_recv_callback_t cb)
Non-blocking tagged-receive operation.
Active Message handler parameters passed to ucp_worker_set_am_recv_handler routine.
Definition: ucp.h:1443
ucs_status_ptr_t ucp_ep_close_nb(ucp_ep_h ep, unsigned mode)
Non-blocking endpoint closure.
int mt_workers_shared
Definition: ucp.h:924
ucs_status_t ucp_worker_set_am_handler(ucp_worker_h worker, uint16_t id, ucp_am_callback_t cb, void *arg, uint32_t flags)
Add user defined callback for Active Message.
struct sockaddr_storage client_address
Definition: ucp.h:1155
ucs_memory_type_t memory_type
Definition: ucp.h:1419
ucp_worker_attr_field
UCP worker attributes field mask.
Definition: ucp.h:371
ucp_conn_request_attr_field
UCP listener's connection request attributes field mask.
Definition: ucp.h:399
ucp_listener_accept_handler_t accept_handler
Definition: ucp.h:1190
size_t(* pack)(void *state, size_t offset, void *dest, size_t max_length)
Pack data.
Definition: ucp.h:804
ucp_ep_close_flags_t
Close UCP endpoint modes.
Definition: ucp.h:269
size_t length
Definition: ucp.h:2503
void ucp_am_data_release(ucp_worker_h worker, void *data)
Releases Active Message data.
ucs_status_t ucp_rkey_pack(ucp_context_h context, ucp_mem_h memh, void **rkey_buffer_p, size_t *size_p)
Pack memory region remote access key.
ucs_status_t ucp_worker_create(ucp_context_h context, const ucp_worker_params_t *params, ucp_worker_h *worker_p)
Create a worker object.
struct ucp_ep * ucp_ep_h
UCP Endpoint.
Definition: ucp_def.h:90
struct ucp_mem_map_params ucp_mem_map_params_t
Tuning parameters for the UCP memory mapping.
void * address
Definition: ucp.h:2498
ucs_status_t ucp_listener_create(ucp_worker_h worker, const ucp_listener_params_t *params, ucp_listener_h *listener_p)
Accept connections on a local address of the worker object.
ucs_status_ptr_t ucp_tag_send_sync_nb(ucp_ep_h ep, const void *buffer, size_t count, ucp_datatype_t datatype, ucp_tag_t tag, ucp_send_callback_t cb)
Non-blocking synchronous tagged-send operation.
ucs_status_t ucp_worker_get_efd(ucp_worker_h worker, int *fd)
Obtain an event file descriptor for event notification.
ucs_status_ptr_t ucp_am_recv_data_nbx(ucp_worker_h worker, void *data_desc, void *buffer, size_t count, const ucp_request_param_t *param)
Receive Active Message sent with rendezvous protocol.
UCP callback to handle the connection request in a client-server connection establishment flow.
Definition: ucp_def.h:417
ucs_status_ptr_t ucp_get_nb(ucp_ep_h ep, void *buffer, size_t length, uint64_t remote_addr, ucp_rkey_h rkey, ucp_send_callback_t cb)
Non-blocking remote memory get operation.
uint32_t address_flags
Definition: ucp.h:1013
Operation parameters passed to ucp_tag_send_nbx, ucp_tag_send_sync_nbx, ucp_tag_recv_nbx,...
Definition: ucp.h:1364
size_t request_size
Definition: ucp.h:970
ucs_thread_mode_t thread_mode
Definition: ucp.h:976
ucs_cpu_set_t cpu_mask
Definition: ucp.h:1072
ucs_thread_mode_t thread_mode
Definition: ucp.h:1063
struct ucp_rkey * ucp_rkey_h
UCP Remote memory handle.
Definition: ucp_def.h:150
ucp_mem_advice
list of UCP memory use advice.
Definition: ucp.h:2470
void * user_data
Definition: ucp.h:1089
ucs_status_t(* ucp_am_callback_t)(void *arg, void *data, size_t length, ucp_ep_h reply_ep, unsigned flags)
Callback to process incoming Active Message.
Definition: ucp_def.h:604
struct ucp_worker_attr ucp_worker_attr_t
UCP worker attributes.
void ucp_rkey_destroy(ucp_rkey_h rkey)
Destroy the remote key.
ucs_status_ptr_t ucp_worker_flush_nbx(ucp_worker_h worker, const ucp_request_param_t *param)
Flush outstanding AMO and RMA operations on the worker.
ucs_status_ptr_t ucp_put_nb(ucp_ep_h ep, const void *buffer, size_t length, uint64_t remote_addr, ucp_rkey_h rkey, ucp_send_callback_t cb)
Non-blocking remote memory put operation.
ucp_dt_type
UCP data type classification.
Definition: ucp.h:410
struct ucp_generic_dt_ops ucp_generic_dt_ops_t
UCP generic data type descriptor.
ucs_status_ptr_t ucp_stream_recv_nb(ucp_ep_h ep, void *buffer, size_t count, ucp_datatype_t datatype, ucp_stream_recv_callback_t cb, size_t *length, unsigned flags)
Non-blocking stream receive operation of structured data into a user-supplied buffer.
ucs_status_ptr_t ucp_put_nbx(ucp_ep_h ep, const void *buffer, size_t count, uint64_t remote_addr, ucp_rkey_h rkey, const ucp_request_param_t *param)
Non-blocking remote memory put operation.
void(* ucp_am_recv_data_nbx_callback_t)(void *request, ucs_status_t status, size_t length, void *user_data)
Completion callback for non-blocking Active Message receives.
Definition: ucp_def.h:531
ucp_datatype_t datatype
Definition: ucp.h:1399
ucs_status_t ucp_listener_query(ucp_listener_h listener, ucp_listener_attr_t *attr)
Get attributes specific to a particular listener.
size_t request_size
Definition: ucp.h:878
uint64_t field_mask
Definition: ucp.h:963
ucp_ep_params_flags_field
UCP endpoint parameters flags.
Definition: ucp.h:242
ucs_status_t ucp_worker_signal(ucp_worker_h worker)
Cause an event of the worker.
int event_fd
Definition: ucp.h:1106
void * buffer
Definition: ucp.h:721
struct ucp_listener_attr ucp_listener_attr_t
UCP listener attributes.
void * user_data
Definition: ucp.h:1218
ucs_status_ptr_t ucp_ep_flush_nb(ucp_ep_h ep, unsigned flags, ucp_send_callback_t cb)
Non-blocking flush of outstanding AMO and RMA operations on the endpoint.
ucs_sock_addr_t sockaddr
Definition: ucp.h:1182