Class ucx_buffer_transport

Inheritance Relationships

Base Type

Class Documentation

class comm::ucx_buffer_transport : public comm::buffer_transport

A class that can send a buffer via ucx protocol

Public Functions

ucx_buffer_transport(size_t request_size, ucp_worker_h origin_node, std::vector<node> destinations, ral::cache::MetadataDictionary metadata, std::vector<size_t> buffer_sizes, std::vector<blazingdb::transport::ColumnTransport> column_transports, std::vector<ral::memory::blazing_chunked_column_info> chunked_column_infos, int ral_id, bool require_acknowledge)
~ucx_buffer_transport()
virtual void send_begin_transmission() override

Protected Functions

virtual void send_impl(const char *buffer, size_t buffer_size) override
virtual void receive_acknowledge()

Protected Static Attributes

static std::atomic<int> atomic_message_id