9 #include <ucp/api/ucp.h>
11 #include <ucxx/delayed_submission.h>
12 #include <ucxx/request.h>
13 #include <ucxx/request_data.h>
14 #include <ucxx/typedefs.h>
48 const std::variant<data::StreamSend, data::StreamReceive> requestData,
49 const std::string operationName,
50 const bool enablePythonFuture =
false);
71 std::shared_ptr<Endpoint> endpoint,
72 const std::variant<data::StreamSend, data::StreamReceive> requestData,
73 const bool enablePythonFuture);
Send or receive a message with the UCX Stream API.
Definition: request_stream.h:24
void request()
Create and submit a stream request.
friend std::shared_ptr< RequestStream > createRequestStream(std::shared_ptr< Endpoint > endpoint, const std::variant< data::StreamSend, data::StreamReceive > requestData, const bool enablePythonFuture)
Constructor for std::shared_ptr<ucxx::RequestStream>.
virtual void populateDelayedSubmission()
Populate the internal submission dispatcher.
static void streamSendCallback(void *request, ucs_status_t status, void *arg)
Callback executed by UCX when a stream send request is completed.
static void streamRecvCallback(void *request, ucs_status_t status, size_t length, void *arg)
Callback executed by UCX when a stream receive request is completed.
void callback(void *request, ucs_status_t status, size_t length)
Implementation of the stream receive request callback.
Base type for a UCXX transfer request.
Definition: request.h:38