Line data    Source code

       1             : /*
       2             :  * Copyright (c) 2013 Juniper Networks, Inc. All rights reserved.
       3             :  */
       4             : 
       5             : #include "ifmap/ifmap_link_table.h"
       6             : 
       7             : #include <boost/bind/bind.hpp>
       8             : 
       9             : #include "db/db.h"
      10             : #include "db/db_graph.h"
      11             : #include "db/db_table_partition.h"
      12             : #include "ifmap/ifmap_link.h"
      13             : #include "ifmap/ifmap_log.h"
      14             : #include "ifmap/ifmap_log_types.h"
      15             : 
      16             : using namespace std;
      17             : using namespace boost::placeholders;
      18             : 
      19        8216 : IFMapLinkTable::IFMapLinkTable(DB *db, const string &name, DBGraph *graph)
      20        8216 :         : DBGraphTable(db, name, graph) {
      21        8216 : }
      22             : 
      23           0 : void IFMapLinkTable::Input(DBTablePartition *partition, DBClient *client,
      24             :                            DBRequest *req) {
      25           0 :     assert(false);
      26             : }
      27             : 
      28      363589 : std::unique_ptr<DBEntry> IFMapLinkTable::AllocEntry(
      29             :         const DBRequestKey *key) const {
      30      363589 :     const RequestKey *rkey = static_cast<const RequestKey *>(key);
      31      363589 :     unique_ptr<DBEntry> entry(new IFMapLink(rkey->name));
      32      363589 :     return entry;
      33             : }
      34             : 
      35             : // Generate an unique name for the link node and it should
      36             : // be independent of the order in which the right and left nodes are specified
      37      363563 : std::string IFMapLinkTable::LinkKey(const string &metadata,
      38             :                                         IFMapNode *left, IFMapNode *right) {
      39      363563 :     ostringstream oss;
      40      363563 :     if (left->ToString() < right->ToString()) {
      41      155172 :         oss << metadata << "," << left->ToString() << "," << right->ToString();
      42             :     } else {
      43      208391 :         oss << metadata << "," << right->ToString() << "," << left->ToString();
      44             :     }
      45      727126 :     return oss.str();
      46      363563 : }
      47             : 
      48      160046 : IFMapLink *IFMapLinkTable::AddLink(IFMapNode *left, IFMapNode *right,
      49             :                              const string &metadata, uint64_t sequence_number,
      50             :                              const IFMapOrigin &origin) {
      51             :     DBTablePartition *partition =
      52      160046 :         static_cast<DBTablePartition *>(GetTablePartition(0));
      53             : 
      54      160046 :     string link_name = LinkKey(metadata, left, right);
      55      160046 :     IFMapLink *link = FindLink(link_name);
      56      160046 :     if (link) {
      57           4 :         assert(link->IsDeleted());
      58           4 :         link->SetLinkRevival(true);
      59           4 :         link->ClearDelete();
      60           4 :         link->set_last_change_at_to_now();
      61           4 :         partition->Change(link);
      62             :     } else {
      63      160042 :         link = new IFMapLink(link_name);
      64      160042 :         partition->Add(link);
      65             :     }
      66      160046 :     link->SetProperties(left, right, metadata, sequence_number, origin);
      67      160046 :     assert(dynamic_cast<IFMapNode *>(left));
      68      160046 :     assert(dynamic_cast<IFMapNode *>(right));
      69      160046 :     return link;
      70      160046 : }
      71             : 
      72      203485 : IFMapLink *IFMapLinkTable::FindLink(const string &metadata, IFMapNode *left, IFMapNode *right) {
      73      203485 :     string link_name = LinkKey(metadata, left, right);
      74      406970 :     return FindLink(link_name);
      75      203485 : }
      76             : 
      77      363589 : IFMapLink *IFMapLinkTable::FindLink(const string &name) {
      78             : 
      79             :     DBTablePartition *partition =
      80      363589 :         static_cast<DBTablePartition *>(GetTablePartition(0));
      81      363589 :     RequestKey key;
      82      363589 :     key.name = name;
      83      727178 :     return static_cast<IFMapLink *>(partition->Find(&key));
      84      363589 : }
      85             : 
      86           0 : IFMapLink *IFMapLinkTable::FindNextLink(const string &name) {
      87             : 
      88             :     DBTablePartition *partition =
      89           0 :         static_cast<DBTablePartition *>(GetTablePartition(0));
      90           0 :     RequestKey key;
      91           0 :     key.name = name;
      92           0 :     return static_cast<IFMapLink *>(partition->FindNext(&key));
      93           0 : }
      94             : 
      95       33514 : void IFMapLinkTable::DeleteLink(IFMapLink *link) {
      96       33514 :     DBGraphEdge *edge = static_cast<DBGraphEdge *>(link);
      97       33514 :     graph()->Unlink(edge);
      98       33514 :     link->set_last_change_at_to_now();
      99       33514 :     link->ClearNodes();
     100             :     DBTablePartition *partition =
     101       33514 :         static_cast<DBTablePartition *>(GetTablePartition(0));
     102       33514 :     partition->Delete(edge);
     103       33514 : }
     104             : 
     105       33300 : void IFMapLinkTable::DeleteLink(IFMapLink *link, const IFMapOrigin &origin) {
     106       33300 :     link->RemoveOriginInfo(origin.origin);
     107       33300 :     if (link->is_origin_empty()) {
     108       33294 :         DeleteLink(link);
     109             :     }
     110       33300 : }
     111             : 
     112        8214 : DBTable *IFMapLinkTable::CreateTable(DB *db, const string &name,
     113             :                                      DBGraph *graph) {
     114        8214 :     IFMapLinkTable *table = new IFMapLinkTable(db, name, graph);
     115        8214 :     table->Init();
     116        8214 :     return table;
     117             : }
     118             : 
     119        8216 : void IFMapLinkTable::Clear() {
     120             :     DBTablePartition *partition = static_cast<DBTablePartition *>(
     121        8216 :         GetTablePartition(0));
     122             : 
     123        8216 :     assert(!HasListeners());
     124        8216 :     for (IFMapLink *link = static_cast<IFMapLink *>(partition->GetFirst()),
     125      134748 :                  *next = NULL; link != NULL; link = next) {
     126      126532 :         next = static_cast<IFMapLink *>(partition->GetNext(link));
     127      126532 :         if (link->IsDeleted()) {
     128           0 :             continue;
     129             :         }
     130      126532 :         graph()->Unlink(link);
     131      126532 :         partition->Delete(link);
     132             :     }
     133        8216 : }
     134             : 
     135        8214 : void IFMapLinkTable_Init(DB *db, DBGraph *graph) {
     136             :     DBTable *table =
     137        8214 :             IFMapLinkTable::CreateTable(db, "__ifmap_metadata__.0", graph);
     138        8214 :     db->AddTable(table);
     139        8214 : }
     140             : 
     141         159 : void IFMapLinkTable_Clear(DB *db) {
     142             :     IFMapLinkTable *ltable = static_cast<IFMapLinkTable *>(
     143         159 :             db->FindTable("__ifmap_metadata__.0"));
     144         159 :     ltable->Clear();
     145         159 : }