/* * Copyright (c) 2017 Cisco and/or its affiliates. * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at: * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ #include "vom/dhcp_config.hpp" #include "vom/dhcp_config_cmds.hpp" namespace VOM { /** * A DB of all DHCP configs */ singular_db dhcp_config::m_db; dhcp_config::event_handler dhcp_config::m_evh; dhcp_config::dhcp_config(const interface& itf, const std::string& hostname, bool set_broadcast_flag) : m_itf(itf.singular()) , m_hostname(hostname) , m_client_id(l2_address_t::ZERO) , m_set_broadcast_flag(set_broadcast_flag) , m_binding(0) { } dhcp_config::dhcp_config(const interface& itf, const std::string& hostname, const l2_address_t& client_id, bool set_broadcast_flag) : m_itf(itf.singular()) , m_hostname(hostname) , m_client_id(client_id) , m_set_broadcast_flag(set_broadcast_flag) , m_binding(0) { } dhcp_config::dhcp_config(const dhcp_config& o) : m_itf(o.m_itf) , m_hostname(o.m_hostname) , m_client_id(o.m_client_id) , m_set_broadcast_flag(o.m_set_broadcast_flag) , m_binding(0) { } dhcp_config::~dhcp_config() { sweep(); // not in the DB anymore. m_db.release(m_itf->key(), this); } bool dhcp_config::operator==(const dhcp_config& l) const { return ((key() == l.key()) && (m_hostname == l.m_hostname) && (m_client_id == l.m_client_id)); } const dhcp_config::key_t& dhcp_config::key() const { return (m_itf->key()); } void dhcp_config::sweep() { if (m_binding) { HW::enqueue( new dhcp_config_cmds::unbind_cmd(m_binding, m_itf->handle(), m_hostname)); } HW::write(); } void dhcp_config::dump(std::ostream& os) { m_db.dump(os); } void dhcp_config::replay() { if (m_binding) { HW::enqueue(new dhcp_config_cmds::bind_cmd(m_binding, m_itf->handle(), m_hostname, m_client_id)); } } std::string dhcp_config::to_string() const { std::ostringstream s; s << "Dhcp-config: " << m_itf->to_string() << " hostname:" << m_hostname << " client_id:[" << m_client_id << "] " << m_binding.to_string(); return (s.str()); } void dhcp_config::update(const dhcp_config& desired) { /* * the desired state is always that the interface should be created */ if (!m_binding) { HW::enqueue(new dhcp_config_cmds::bind_cmd(m_binding, m_itf->handle(), m_hostname, m_client_id)); } } std::shared_ptr dhcp_config::find_or_add(const dhcp_config& temp) { return (m_db.find_or_add(temp.m_itf->key(), temp)); } std::shared_ptr dhcp_config::find(const key_t& k) { return (m_db.find(k)); } std::shared_ptr dhcp_config::singular() const { return find_or_add(*this); } dhcp_config::event_listener::event_listener() : m_status(rc_t::NOOP) { } HW::item& dhcp_config::event_listener::status() { return (m_status); } dhcp_config::event_handler::event_handler() { OM::register_listener(this); inspect::register_handler({ "dhcp" }, "DHCP configurations", this); } void dhcp_config::event_handler::handle_replay() { m_db.replay(); } void dhcp_config::event_handler::handle_populate(const client_db::key_t& key) { // FIXME } dependency_t dhcp_config::event_handler::order() const { return (dependency_t::BINDING); } void dhcp_config::event_handler::show(std::ostream& os) { m_db.dump(os); } } /* * fd.io coding-style-patch-verification: ON * * Local Variables: * eval: (c-set-style "mozilla") * End: */