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     HW::write();
  91   }
  92 }
  93
  94 void
  95 OM::dump(const client_db::key_t& key, std::ostream& os)
  96 {
  97   m_db->dump(key, os);
  98 }
  99
 100 void
 101 OM::dump(std::ostream& os)
 102 {
 103   m_db->dump(os);
 104 }
 105
 106 void
 107 OM::populate(const client_db::key_t& key)
 108 {
 109   /*
 110    * the listeners are sorted in dependency order
 111    */
 112   for (listener* l : *m_listeners) {
 113     l->handle_populate(key);
 114   }
 115
 116   /*
 117    * once we have it all, mark it stale.
 118    */
 119   mark(key);
 120 }
 121
 122 bool
 123 OM::register_listener(OM::listener* listener)
 124 {
 125   if (!m_listeners) {
 126     m_listeners.reset(new listener_list);
 127   }
 128
 129   m_listeners->insert(listener);
 130
 131   return (true);
 132 }
 133
 134 OM::mark_n_sweep::mark_n_sweep(const client_db::key_t& key)
 135   : m_key(key)
 136 {
 137   OM::mark(m_key);
 138 }
 139
 140 OM::mark_n_sweep::~mark_n_sweep()
 141 {
 142   OM::sweep(m_key);
 143 }
 144 }
 145
 146 /*
 147  * fd.io coding-style-patch-verification: ON
 148  *
 149  * Local Variables:
 150  * eval: (c-set-style "mozilla")
 151  * End:
 152  */