27 namespace interface_cmds {
29 const std::string& name)
30 : create_cmd(item, name)
37 msg_t req(con.
ctx(), std::ref(*
this));
59 const std::string& name)
67 msg_t req(con.
ctx(), std::ref(*
this));
69 auto& payload = req.get_request().get_payload();
71 payload.use_random_hw_addr = 1;
72 memset(payload.host_if_name, 0,
sizeof(payload.host_if_name));
73 memcpy(payload.host_if_name,
m_name.c_str(),
74 std::min(
m_name.length(),
sizeof(payload.host_if_name)));
96 const std::string& name)
104 msg_t req(con.
ctx(), std::ref(*
this));
106 auto& payload = req.get_request().get_payload();
108 memset(payload.tap_name, 0,
sizeof(payload.tap_name));
109 memcpy(payload.tap_name,
m_name.c_str(),
110 std::min(
m_name.length(),
sizeof(payload.tap_name)));
111 payload.use_random_mac = 1;
127 std::ostringstream s;
134 const std::string& name,
135 const std::string& tag)
144 msg_t req(con.
ctx(), std::ref(*
this));
146 auto& payload = req.get_request().get_payload();
147 memset(payload.sock_filename, 0,
sizeof(payload.sock_filename));
148 memcpy(payload.sock_filename,
m_name.c_str(),
149 std::min(
m_name.length(),
sizeof(payload.sock_filename)));
150 memset(payload.tag, 0,
sizeof(payload.tag));
153 memcpy(payload.tag, m_tag.c_str(),
154 std::min(m_tag.length(),
sizeof(payload.tag)));
156 payload.is_server = 0;
157 payload.use_custom_mac = 0;
158 payload.renumber = 0;
174 std::ostringstream s;
189 msg_t req(con.
ctx(), std::ref(*
this));
191 auto& payload = req.get_request().get_payload();
206 std::ostringstream s;
213 const std::string& name)
221 msg_t req(con.
ctx(), std::ref(*
this));
223 auto& payload = req.get_request().get_payload();
224 memset(payload.host_if_name, 0,
sizeof(payload.host_if_name));
225 memcpy(payload.host_if_name,
m_name.c_str(),
226 std::min(
m_name.length(),
sizeof(payload.host_if_name)));
239 std::ostringstream s;
261 std::ostringstream s;
268 const std::string& name)
276 msg_t req(con.
ctx(), std::ref(*
this));
278 auto& payload = req.get_request().get_payload();
291 std::ostringstream s;
313 msg_t req(con.
ctx(), std::ref(*
this));
315 auto& payload = req.get_request().get_payload();
316 payload.sw_if_index = m_hdl.
data().
value();
329 std::ostringstream s;
347 return ((m_hdl == other.m_hdl) && (m_proto == other.m_proto) &&
354 msg_t req(con.
ctx(), std::ref(*
this));
356 auto& payload = req.get_request().get_payload();
357 payload.sw_if_index = m_hdl.
data().
value();
358 payload.is_ipv6 = m_proto.
is_ipv6();
371 std::ostringstream s;
393 msg_t req(con.
ctx(), std::ref(*
this));
395 auto& payload = req.get_request().get_payload();
396 payload.sw_if_index = m_hdl.
data().
value();
398 sizeof(payload.mac_address));
410 std::ostringstream s;
430 (m_enable == other.m_enable));
436 msg_t req(con.
ctx(), std::ref(*
this));
438 auto& payload = req.get_request().get_payload();
439 payload.sw_if_index = m_hdl.
value();
440 payload.enable_disable = m_enable;
452 std::ostringstream s;
475 m_reg.reset(
new reg_t(con.
ctx(), std::ref(*(static_cast<event_cmd*>(
this)))));
480 msg_t req(con.
ctx(), std::ref(*(static_cast<rpc_cmd*>(
this))));
482 auto& payload = req.get_request().get_payload();
483 payload.enable_disable = 1;
484 payload.pid = getpid();
499 msg_t req(con.
ctx(), std::ref(*(static_cast<rpc_cmd*>(
this))));
501 auto& payload = req.get_request().get_payload();
502 payload.enable_disable = 0;
503 payload.pid = getpid();
519 return (
"itf-events");
529 , m_swifindex(handle)
545 m_reg.reset(
new reg_t(con.
ctx(), std::ref(*(static_cast<event_cmd*>(
this)))));
550 msg_t req(con.
ctx(), 1, std::ref(*(static_cast<rpc_cmd*>(
this))));
552 auto& payload = req.get_request().get_payload();
553 payload.enable_disable = 1;
554 payload.pid = getpid();
557 payload.sw_ifs[0] = m_swifindex.
value();
572 msg_t req(con.
ctx(), 1, std::ref(*(static_cast<rpc_cmd*>(
this))));
574 auto& payload = req.get_request().get_payload();
575 payload.enable_disable = 0;
576 payload.pid = getpid();
578 payload.sw_ifs[0] = m_swifindex.
value();
606 std::ostringstream s;
607 s <<
"itf-stats-enable itf:" << m_swifindex.
to_string();
613 , m_swifindex(handle)
629 msg_t req(con.
ctx(), 1, std::ref(*
this));
631 auto& payload = req.get_request().get_payload();
632 payload.enable_disable = 0;
633 payload.pid = getpid();
636 payload.sw_ifs[0] = m_swifindex.
value();
648 std::ostringstream s;
649 s <<
"itf-stats-disable itf:" << m_swifindex.
to_string();
666 m_dump.reset(
new msg_t(con.
ctx(), std::ref(*
this)));
668 auto& payload = m_dump->get_request().get_payload();
669 payload.name_filter_valid = 0;
697 m_dump.reset(
new msg_t(con.
ctx(), std::ref(*
this)));
709 return (
"vhost-itf-dump");
721 msg_t req(con.
ctx(), std::ref(*
this));
723 auto& payload = req.get_request().get_payload();
726 memcpy(payload.tag, m_name.c_str(), m_name.length());
737 std::ostringstream s;
bool operator==(const set_tag &i) const
Comparison operator - only used for UT.
rc_t issue(connection &con)
Issue the command to VPP/HW.
std::string to_string() const
convert to string format for debug purposes
static const rc_t NOOP
The HW write/update action was/has not been attempted.
void retire(connection &con)
Retires the command - unsubscribe from the events.
delete_cmd(HW::item< handle_t > &item, const std::string &name)
HW::item< handle_t > & m_hw_item
A reference to an object's HW::item that the command will update.
bool operator==(const set_mac_cmd &i) const
Comparison operator - only used for UT.
std::string to_string() const
convert to string format for debug purposes
A command class represents our desire to recieve interface stats.
vhost_create_cmd(HW::item< handle_t > &item, const std::string &name, const std::string &tag)
rc_t issue(connection &con)
Issue the command to VPP/HW.
DEFINE_VAPI_MSG_IDS_AF_PACKET_API_JSON
int value() const
Return the value of the enum - same as integer conversion.
std::string to_string() const
convert to string format for debug purposes
void remove_interface()
remove the deleted interface from the DB
uint32_t value() const
get the value of the handle
set_tag(HW::item< handle_t > &item, const std::string &name)
Constructor taking the HW::item to update.
rc_t issue(connection &con)
Issue the command to VPP/HW.
std::string to_string() const
convert to string format for debug purposes
collect_detail_stats_change_cmd(HW::item< interface::stats_type_t > &item, const handle_t &h, bool enable)
Constructor taking the HW::item to update and the handle of the interface.
bool operator==(const set_table_cmd &i) const
Comparison operator - only used for UT.
void notify()
Called when it's time to poke the listeners.
rc_t issue(connection &con)
Issue the command to VPP/HW.
stats_disable_cmd(const handle_t &handle)
Constructor taking the listner to notify.
A command class to set tag on interfaces.
Error codes that VPP will return during a HW write.
std::string to_string() const
convert to string format for debug purposes
std::string to_string() const
convert to string format for debug purposes
An L3 protocol can be used to construct a prefix that is used to match packets are part of a route...
set_mac_cmd(HW::item< l2_address_t > &item, const HW::item< handle_t > &h)
Constructor taking the HW::item to update and the handle of the interface.
create_cmd(HW::item< handle_t > &item, const std::string &name)
virtual void handle_interface_event(interface_cmds::events_cmd *cmd)=0
Virtual function called on the listener when the command has data ready to process.
A command class that enables detailed stats collection on an interface.
std::string to_string() const
convert to string format for debug purposes
std::string to_string() const
convert to string format for debug purposes
std::string to_string() const
convert to string format for debug purposes
T & data()
Return the data read/written.
rc_t issue(connection &con)
Issue the command to VPP/HW.
DEFINE_VAPI_MSG_IDS_VPE_API_JSON
std::string to_string() const
convert to string format for debug purposes
rc_t issue(connection &con)
Issue the command to VPP/HW.
std::string to_string() const
convert to string format for debug purposes
rc_t issue(connection &con)
Issue the command to VPP/HW.
A command class that changes the MAC address on an interface.
const std::string & m_name
The name of the interface to be created.
dump_cmd()
Default Constructor.
A representation of the connection to VPP.
bool operator==(const events_cmd &i) const
Comparison operator - only used for UT.
set_table_cmd(HW::item< route::table_id_t > &item, const l3_proto_t &proto, const HW::item< handle_t > &h)
Constructor taking the HW::item to update and the name handle of the interface whose table is to chan...
A class that listens to interface Stats.
DEFINE_VAPI_MSG_IDS_VHOST_USER_API_JSON
std::string to_string() const
convert to string format for debug purposes
std::string to_string() const
convert to string format for debug purposes
tap_create_cmd(HW::item< handle_t > &item, const std::string &name)
Constructor taking the HW::item to update and the name of the interface to create.
rc_t issue(connection &con)
Issue the command to VPP/HW.
std::string to_string() const
convert to string format for debug purposes
state_change_cmd(HW::item< interface::admin_state_t > &s, const HW::item< handle_t > &h)
Constructor taking the HW::item to update and the name handle of the interface whose state is to chan...
rc_t issue(connection &con)
Issue the command to VPP/HW.
rc_t issue(connection &con)
Issue the command to VPP/HW.
HW::item< handle_t > & item()
return the HW item the command updates
A class that listens to interface Events.
A base class for all RPC commands to VPP.
af_packet_delete_cmd(HW::item< handle_t > &item, const std::string &name)
Constructor taking the HW::item to update and the name of the interface to delete.
bool operator==(const stats_enable_cmd &i) const
Comparison operator - only used for UT.
#define VAPI_CALL(_stmt)
Convenince wrapper macro for error handling in VAPI sends.
A cmd class that changes the admin state.
std::string to_string() const
convert to string format for debug purposes
vhost_dump_cmd()
Default Constructor.
std::string to_string() const
convert to string format for debug purposes
af_packet_create_cmd(HW::item< handle_t > &item, const std::string &name)
Constructor taking the HW::item to update and the name of the interface to create.
A command class that binds an interface to an L3 table.
bool operator==(const dump_cmd &i) const
Comparison operator - only used for UT.
A command class represents our desire to recieve interface events.
stats_enable_cmd(interface::stat_listener &el, const handle_t &handle)
Constructor taking the listner to notify.
DEFINE_VAPI_MSG_IDS_STATS_API_JSON
std::unique_ptr< vapi::Event_registration< vapi::Sw_interface_event > > m_reg
The VAPI event registration.
A cmd class that Dumps all the Vpp Interfaces.
HW::item< bool > & status()
Return the HW::item representing the status.
rc_t issue(connection &con)
Issue the command to VPP/HW.
std::string to_string() const
convert to string format for debug purposes
A type declaration of an interface handle in VPP.
vapi::Event_registration< vapi::Sw_interface_event > reg_t
rc_t issue(connection &con)
Issue the command to VPP/HW.
bool operator==(const vhost_dump_cmd &i) const
Comparison operator - only used for UT.
rc_t issue(connection &con)
Issue the command to VPP/HW.
static const rc_t OK
The HW write was successfull.
bool operator==(const state_change_cmd &i) const
Comparison operator - only used for UT.
void notify()
Called when it's time to poke the listeners.
DEFINE_VAPI_MSG_IDS_TAP_API_JSON
vhost_vring_state_t state
std::string to_string() const
convert to string format for debug purposes
const std::string m_name
The name of the interface to be created.
loopback_delete_cmd(HW::item< handle_t > &item)
Constructor taking the HW::item to update.
A command class represents our desire to recieve interface stats.
vapi::Connection & ctx()
Retrun the VAPI context the commands will use.
void to_bytes(uint8_t *array, uint8_t len) const
Convert to byte array.
rc_t issue(connection &con)
Issue the command to VPP/HW.
void insert_interface()
add the created interface to the DB
The VPP Object Model (VOM) library.
DEFINE_VAPI_MSG_IDS_INTERFACE_API_JSON
void set(const rc_t &rc)
(re)set status
rc_t issue(connection &con)
Issue the command to VPP/HW.
void set(const rc_t &rc)
Set the HW return code - should only be called from the family of Command objects.
tap_delete_cmd(HW::item< handle_t > &item)
Constructor taking the HW::item to update.
vhost_delete_cmd(HW::item< handle_t > &item, const std::string &name)
virtual void handle_interface_stat(interface_cmds::stats_enable_cmd *cmd)=0
Virtual function called on the listener when the command has data ready to process.
interface::stat_listener & listener() const
get listener
vapi::Create_loopback msg_t
convenient typedef
An Event command base class.
rc_t issue(connection &con)
Issue the command to VPP/HW.
const std::string & to_string() const
convert to string format for debug purposes
void retire(connection &con)
Retires the command - unsubscribe from the stats.
rc_t issue(connection &con)
Issue the command to VPP/HW.
events_cmd(interface::event_listener &el)
Constructor taking the listner to notify.
std::string to_string() const
convert to string format for debug purposes
A cmd class that Dumps all the Vpp interfaces.
std::string to_string() const
convert to string format for debug purposes
mac_address_t to_mac() const
MAC address conversion.
loopback_create_cmd(HW::item< handle_t > &item, const std::string &name)
Constructor taking the HW::item to update and the name of the interface to create.
bool operator==(const stats_disable_cmd &i) const
Comparison operator - only used for UT.
bool operator==(const collect_detail_stats_change_cmd &i) const
Comparison operator - only used for UT.
HW::item< handle_t > wait()
Wait on the commands promise.
rc_t issue(connection &con)
Issue the command to VPP/HW.