src/vpp-api/vom/om.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 <algorithm>
  17
  18 #include "vom/om.hpp"
  19
  20 namespace VOM {
  21 client_db* OM::m_db;
  22
  23 std::unique_ptr<OM::listener_list> OM::m_listeners;
  24
  25 /**
  26  * Initialse the connection to VPP
  27  */
  28 void
  29 OM::init()
  30 {
  31   m_db = new client_db();
  32 }
  33
  34 void
  35 OM::mark(const client_db::key_t& key)
  36 {
  37   /*
  38  * Find if the object already stored on behalf of this key.
  39  * and mark them stale
  40  */
  41   object_ref_list& objs = m_db->find(key);
  42
  43   auto mark_obj = [](const object_ref& oref) { oref.mark(); };
  44
  45   std::for_each(objs.begin(), objs.end(), mark_obj);
  46 }
  47
  48 void
  49 OM::sweep(const client_db::key_t& key)
  50 {
  51   /*
  52  * Find if the object already stored on behalf of this key.
  53  * and mark them stale
  54  */
  55   object_ref_list& objs = m_db->find(key);
  56
  57   for (auto it = objs.begin(); it != objs.end();) {
  58     if (it->stale()) {
  59       it = objs.erase(it);
  60     } else {
  61       ++it;
  62     }
  63   }
  64
  65   HW::write();
  66 }
  67
  68 void
  69 OM::remove(const client_db::key_t& key)
  70 {
  71   /*
  72  * Simply reset the list for this key. This will desctruct the
  73  * object list and shared_ptrs therein. When the last shared_ptr
  74  * goes the objects desctructor is called and the object is
  75  * removed from OM
  76  */
  77   m_db->flush(key);
  78
  79   HW::write();
  80 }
  81
  82 void
  83 OM::replay()
  84 {
  85   /*
  86  * the listeners are sorted in dependency order
  87  */
  88   for (listener* l : *m_listeners) {
  89     l->handle_replay();
  90   }
  91
  92   HW::write();
  93 }
  94
  95 void
  96 OM::dump(const client_db::key_t& key, std::ostream& os)
  97 {
  98   m_db->dump(key, os);
  99 }
 100
 101 void
 102 OM::dump(std::ostream& os)
 103 {
 104   m_db->dump(os);
 105 }
 106
 107 void
 108 OM::populate(const client_db::key_t& key)
 109 {
 110   /*
 111  * the listeners are sorted in dependency order
 112  */
 113   for (listener* l : *m_listeners) {
 114     l->handle_populate(key);
 115   }
 116
 117   /*
 118  * once we have it all, mark it stale.
 119  */
 120   mark(key);
 121 }
 122
 123 bool
 124 OM::register_listener(OM::listener* listener)
 125 {
 126   if (!m_listeners) {
 127     m_listeners.reset(new listener_list);
 128   }
 129
 130   m_listeners->insert(listener);
 131
 132   return (true);
 133 }
 134
 135 OM::mark_n_sweep::mark_n_sweep(const client_db::key_t& key)
 136   : m_key(key)
 137 {
 138   OM::mark(m_key);
 139 }
 140
 141 OM::mark_n_sweep::~mark_n_sweep()
 142 {
 143   OM::sweep(m_key);
 144 }
 145 }
 146
 147 /*
 148  * fd.io coding-style-patch-verification: ON
 149  *
 150  * Local Variables:
 151  * eval: (c-set-style "mozilla")
 152  * End:
 153  */