23 gbp_subnet::type_t::type_t(
int v,
const std::string s)
24 : enum_base<gbp_subnet::type_t>(v, s)
37 singular_db<gbp_subnet::key_t, gbp_subnet> gbp_subnet::m_db;
61 , m_type(
type_t::STITCHED_EXTERNAL)
84 , m_prefix(o.m_prefix)
86 , m_recirc(o.m_recirc)
88 , m_sclass(o.m_sclass)
95 m_db.release(
key(),
this);
101 return (std::make_pair(m_rd->key(), m_prefix));
107 return ((
key() == gs.
key()) && (m_type == gs.m_type) &&
108 (m_recirc == gs.m_recirc) && (m_epg == gs.m_epg) &&
109 (m_sclass == gs.m_sclass));
126 m_hw, m_rd->id(), m_prefix, m_type,
128 (m_epg ? m_epg->sclass() : m_sclass)));
135 std::ostringstream s;
136 s <<
"gbp-subnet:[" << m_type.
to_string() <<
", " << m_rd->to_string() <<
":" 139 s <<
", " << m_recirc->to_string();
141 s <<
", " << m_epg->to_string();
153 m_hw, m_rd->id(), m_prefix, m_type,
155 (m_epg ? m_epg->sclass() : m_sclass)));
157 if (m_type != r.m_type) {
159 m_recirc = r.m_recirc;
163 m_hw, m_rd->id(), m_prefix, m_type,
165 (m_epg ? m_epg->sclass() : m_sclass)));
170 std::shared_ptr<gbp_subnet>
171 gbp_subnet::find_or_add(
const gbp_subnet& temp)
173 return (m_db.find_or_add(temp.
key(), temp));
176 std::shared_ptr<gbp_subnet>
179 return (m_db.find(k));
182 std::shared_ptr<gbp_subnet>
185 return find_or_add(*
this);
201 gbp_subnet::event_handler::handle_replay()
209 std::shared_ptr<gbp_subnet_cmds::dump_cmd>
cmd =
210 std::make_shared<gbp_subnet_cmds::dump_cmd>();
215 for (
auto& record : *cmd) {
216 auto& payload = record.get_payload();
219 std::shared_ptr<gbp_route_domain> rd =
223 switch (payload.subnet.type) {
237 gbp_subnet gs(*rd, pfx, payload.subnet.sclass);
243 std::shared_ptr<interface> itf =
245 std::shared_ptr<gbp_endpoint_group> epg =
264 gbp_subnet::event_handler::order()
const 278 os <<
"[" << key.first <<
", " << key.second <<
"]";
void db_dump(const DB &db, std::ostream &os)
Print each of the objects in the DB into the stream provided.
std::string to_string() const
convert to string format for debug purposes
const std::string key_t
In the opflex world each entity is known by a URI which can be converted into a string.
static std::shared_ptr< interface > find(const handle_t &h)
The the singular instance of the interface in the DB by handle.
static void register_handler(const std::vector< std::string > &cmds, const std::string &help, command_handler *ch)
Register a command handler for inspection.
static const type_t TRANSPORT
A transport subnet, sent via the RD's UU-fwd interface.
static rc_t write()
Write/Execute all commands hitherto enqueued.
rc_t rc() const
Get the HW return code.
static const log_level_t DEBUG
static const handle_t INVALID
A value of an interface handle_t that means the itf does not exist.
std::shared_ptr< gbp_subnet > singular() const
Return the matching 'singular instance'.
void replay(void)
replay the object to create it in hardware
static const type_t STITCHED_INTERNAL
Internal subnet is reachable through the source EPG's uplink interface.
std::string to_string() const
Convert to string for debugging.
static void dump(std::ostream &os)
Dump all bridge_domain-doamin into the stream provided.
static std::shared_ptr< gbp_subnet > find(const key_t &k)
Find the instnace of the bridge_domain domain in the OM.
A recirculation interface for GBP use pre/post NAT.
std::pair< gbp_route_domain::key_t, route::prefix_t > key_t
The key for a GBP subnet; table and prefix.
gbp_subnet(const gbp_route_domain &rd, const route::prefix_t &prefix, const type_t &type)
Construct an internal GBP subnet.
A cmd class that deletes a GBP subnet.
static const type_t STITCHED_EXTERNAL
External subnet requires NAT translation before egress.
A entry in the ARP termination table of a Bridge Domain.
const std::string & to_string() const
convert to string format for debug purposes
static rc_t commit(const client_db::key_t &key, const OBJ &obj)
Make the State in VPP reflect the expressed desired state.
void event_handler(void *tls_async)
dependency_t
There needs to be a strict order in which object types are read from VPP (at boot time) and replayed ...
static const rc_t OK
The HW write was successfull.
static void enqueue(cmd *f)
Enqueue A command for execution.
A command class that creates or updates the GBP subnet.
static std::shared_ptr< gbp_recirc > find(const key_t &k)
Find the instnace of the recirc interface in the OM.
std::ostream & operator<<(std::ostream &os, const std::pair< direction_t, interface::key_t > &key)
A entry in the ARP termination table of a Route Domain.
The VPP Object Model (VOM) library.
const neighbour::flags_t from_api(vapi_enum_ip_neighbor_flags f)
A representation of a method call to VPP.
bool operator==(const gbp_subnet &bdae) const
comparison operator
static std::shared_ptr< gbp_route_domain > find(const key_t &k)
Find the instnace of the route_domain domain in the OM.
static std::shared_ptr< gbp_endpoint_group > find(const key_t &k)
Find the instnace of the bridge_domain domain in the OM.
static bool register_listener(listener *listener)
Register a listener of events.
static const type_t L3_OUT
A transport subnet, sent via the RD's UU-fwd interface.
const key_t key() const
Return the object's key.