src/vpp-api/vom/tap_interface.cpp

   1 /*
   2  * Copyright (c) 2017 Cisco and/or its affiliates.
   3  * Licensed under the Apache License, Version 2.0 (the "License");
   4  * you may not use this file except in compliance with the License.
   5  * You may obtain a copy of the License at:
   6  *
   7  *     http://www.apache.org/licenses/LICENSE-2.0
   8  *
   9  * Unless required by applicable law or agreed to in writing, software
  10  * distributed under the License is distributed on an "AS IS" BASIS,
  11  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12  * See the License for the specific language governing permissions and
  13  * limitations under the License.
  14  */
  15
  16 #include "vom/tap_interface.hpp"
  17 #include "vom/cmd.hpp"
  18
  19 #include <vapi/vpe.api.vapi.hpp>
  20
  21 namespace VOM {
  22 tap_interface::event_handler tap_interface::m_evh;
  23
  24 /**
  25  * Construct a new object matching the desried state
  26  */
  27 tap_interface::tap_interface(const std::string& name,
  28                              admin_state_t state,
  29                              route::prefix_t prefix)
  30   : interface(name, type_t::TAP, state)
  31   , m_prefix(prefix)
  32   , m_l2_address(l2_address_t::ZERO)
  33 {
  34 }
  35
  36 tap_interface::tap_interface(const std::string& name,
  37                              admin_state_t state,
  38                              route::prefix_t prefix,
  39                              const l2_address_t& l2_address)
  40   : interface(name, type_t::TAP, state)
  41   , m_prefix(prefix)
  42   , m_l2_address(l2_address)
  43 {
  44 }
  45
  46 tap_interface::tap_interface(const handle_t& hdl,
  47                              const std::string& name,
  48                              admin_state_t state,
  49                              route::prefix_t prefix)
  50   : interface(hdl, l2_address_t::ZERO, name, type_t::TAP, state)
  51   , m_prefix(prefix)
  52   , m_l2_address(l2_address_t::ZERO)
  53 {
  54 }
  55
  56 tap_interface::~tap_interface()
  57 {
  58   sweep();
  59   release();
  60 }
  61
  62 tap_interface::tap_interface(const tap_interface& o)
  63   : interface(o)
  64   , m_prefix(o.m_prefix)
  65   , m_l2_address(o.m_l2_address)
  66 {
  67 }
  68
  69 std::queue<cmd*>&
  70 tap_interface::mk_create_cmd(std::queue<cmd*>& q)
  71 {
  72   q.push(new create_cmd(m_hdl, name(), m_prefix, m_l2_address));
  73
  74   return (q);
  75 }
  76
  77 std::queue<cmd*>&
  78 tap_interface::mk_delete_cmd(std::queue<cmd*>& q)
  79 {
  80   q.push(new delete_cmd(m_hdl));
  81
  82   return (q);
  83 }
  84
  85 std::shared_ptr<tap_interface>
  86 tap_interface::singular() const
  87 {
  88   return std::dynamic_pointer_cast<tap_interface>(singular_i());
  89 }
  90
  91 std::shared_ptr<interface>
  92 tap_interface::singular_i() const
  93 {
  94   return m_db.find_or_add(name(), *this);
  95 }
  96
  97 void
  98 tap_interface::event_handler::handle_populate(const client_db::key_t& key)
  99 {
 100   /*
 101  * dump VPP current states
 102  */
 103   std::shared_ptr<tap_interface::dump_cmd> cmd(new tap_interface::dump_cmd());
 104
 105   HW::enqueue(cmd);
 106   HW::write();
 107
 108   for (auto& record : *cmd) {
 109     auto& payload = record.get_payload();
 110
 111     std::string name = reinterpret_cast<const char*>(payload.dev_name);
 112
 113     tap_interface itf(name, interface::admin_state_t::UP,
 114                       route::prefix_t::ZERO);
 115
 116     VOM_LOG(log_level_t::DEBUG) << "tap-dump: " << itf.to_string();
 117
 118     /*
 119  * Write each of the discovered interfaces into the OM,
 120  * but disable the HW Command q whilst we do, so that no
 121  * commands are sent to VPP
 122  */
 123     OM::commit(key, itf);
 124   }
 125 }
 126
 127 tap_interface::event_handler::event_handler()
 128 {
 129   OM::register_listener(this);
 130   inspect::register_handler({ "tap" }, "tap_interfaces", this);
 131 }
 132
 133 void
 134 tap_interface::event_handler::handle_replay()
 135 {
 136   m_db.replay();
 137 }
 138
 139 dependency_t
 140 tap_interface::event_handler::order() const
 141 {
 142   return (dependency_t::INTERFACE);
 143 }
 144
 145 void
 146 tap_interface::event_handler::show(std::ostream& os)
 147 {
 148   m_db.dump(os);
 149 }
 150 }
 151
 152 /*
 153  * fd.io coding-style-patch-verification: ON
 154  *
 155  * Local Variables:
 156  * eval: (c-set-style "mozilla")
 157  * End:
 158  */