request_flush.h

 
#pragma once
#include <memory>
#include <string>
#include <utility>
 
#include <ucp/api/ucp.h>
 
#include <ucxx/delayed_submission.h>
#include <ucxx/request.h>
#include <ucxx/typedefs.h>
 
namespace ucxx {
 
class RequestFlush : public Request {
 private:
  RequestFlush(std::shared_ptr<Component> endpointOrWorker,
               const data::Flush requestData,
               const std::string operationName,
               const bool enablePythonFuture                = false,
               RequestCallbackUserFunction callbackFunction = nullptr,
               RequestCallbackUserData callbackData         = nullptr);
 
 public:
  [[nodiscard]] friend std::shared_ptr<RequestFlush> createRequestFlush(
    std::shared_ptr<Component> endpointOrWorker,
    const data::Flush requestData,
    const bool enablePythonFuture,
    RequestCallbackUserFunction callbackFunction,
    RequestCallbackUserData callbackData);
 
  virtual void populateDelayedSubmission();
 
  void request();
 
  static void flushCallback(void* request, ucs_status_t status, void* arg);
};
 
}  // namespace ucxx