NVIDIA DOCA SDK Data Center on a Chip Framework Documentation
control_channel.cpp File Reference
#include <storage_common/control_channel.hpp>
#include <chrono>
#include <thread>
#include <doca_comch.h>
#include <doca_log.h>
#include <doca_pe.h>
#include <storage_common/buffer_utils.hpp>
#include <storage_common/definitions.hpp>
#include <storage_common/doca_utils.hpp>
#include <storage_common/tcp_socket.hpp>
Include dependency graph for control_channel.cpp:

Go to the source code of this file.

Namespaces

 storage
 
 storage::control
 

Functions

 DOCA_LOG_REGISTER (CONTROL_CHANNEL)
 
std::unique_ptr< storage::control::comch_channelstorage::control::make_comch_client_control_channel (doca_dev *dev, char const *channel_name, void *callback_user_data, comch_channel::consumer_event_callback new_consumer_event_cb, comch_channel::consumer_event_callback expired_consumer_event_cb)
 
std::unique_ptr< storage::control::comch_channelstorage::control::make_comch_server_control_channel (doca_dev *dev, doca_dev_rep *dev_rep, char const *channel_name, void *callback_user_data, comch_channel::consumer_event_callback new_consumer_event_cb, comch_channel::consumer_event_callback expired_consumer_event_cb)
 
std::unique_ptr< storage::control::channelstorage::control::make_tcp_client_control_channel (storage::ip_address const &server_address)
 
std::unique_ptr< storage::control::channelstorage::control::make_tcp_server_control_channel (uint16_t listen_port)
 

Function Documentation

◆ DOCA_LOG_REGISTER()

DOCA_LOG_REGISTER ( CONTROL_CHANNEL  )

Variable Documentation

◆ m_connection

doca_comch_connection* m_connection
protected

Definition at line 177 of file control_channel.cpp.

◆ m_connection_cb

comch_channel::consumer_event_callback m_connection_cb
protected

Definition at line 179 of file control_channel.cpp.

◆ m_consumer_cb_data

doca_data m_consumer_cb_data
protected

Definition at line 178 of file control_channel.cpp.

◆ m_error_message

std::string m_error_message
protected

Definition at line 102 of file control_channel.cpp.

◆ m_expiry_cb

comch_channel::consumer_event_callback m_expiry_cb
protected

Definition at line 180 of file control_channel.cpp.

◆ m_pe

doca_pe* m_pe
protected

Definition at line 176 of file control_channel.cpp.

◆ m_rx_buffer

std::vector<char> m_rx_buffer
protected

Definition at line 100 of file control_channel.cpp.

◆ m_rx_message

message m_rx_message
protected

Definition at line 101 of file control_channel.cpp.

◆ m_tx_buffer

std::vector<char> m_tx_buffer
protected

Definition at line 99 of file control_channel.cpp.