Class tcp_buffer_transport

Inheritance Relationships

Base Type

Class Documentation

class comm::tcp_buffer_transport : public comm::buffer_transport

Public Functions

tcp_buffer_transport(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, ctpl::thread_pool<BlazingThread> *allocate_copy_buffer_pool, bool require_acknowledge)
~tcp_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()