Line data Source code
1 : /* 2 : * Copyright (c) 2013 Juniper Networks, Inc. All rights reserved. 3 : */ 4 : 5 : #include "ifmap_node.h" 6 : 7 : #include <iostream> 8 : 9 : #include <pugixml/pugixml.hpp> 10 : 11 : #include "ifmap/ifmap_table.h" 12 : 13 : using namespace std; 14 : using pugi::xml_node; 15 : 16 : 17 1064786 : IFMapNode::IFMapNode(IFMapTable *table) 18 1064786 : : table_(table) { 19 1064786 : } 20 : 21 : struct IFMapObjectDeleter { 22 105673 : void operator()(IFMapObject *obj) const { 23 105673 : intrusive_ptr_release(obj); 24 105673 : } 25 : }; 26 : 27 2129572 : IFMapNode::~IFMapNode() { 28 1064786 : list_.clear_and_dispose(IFMapObjectDeleter()); 29 2129572 : } 30 : 31 2096780 : string IFMapNode::ToString() const { 32 2096780 : string repr(table_->Typename()); 33 2096780 : repr += ":"; 34 2096780 : repr += name_; 35 2096780 : return repr; 36 0 : } 37 : 38 139589 : IFMapObject *IFMapNode::Find(IFMapOrigin origin) { 39 279566 : for (ObjectList::iterator iter = list_.begin(); iter != list_.end(); 40 : ++iter) { 41 40023 : IFMapObject *object = iter.operator->(); 42 40023 : if (object->origin() == origin) { 43 39829 : return object; 44 : } 45 : } 46 99760 : return NULL; 47 : } 48 : 49 133283 : void IFMapNode::Insert(IFMapObject *obj) { 50 133283 : intrusive_ptr_add_ref(obj); 51 133283 : if (obj->origin().IsOriginXmpp()) { 52 80 : list_.push_back(*obj); 53 : } else { 54 133203 : list_.push_front(*obj); 55 : } 56 133283 : } 57 : 58 27610 : void IFMapNode::Remove(IFMapObject *obj) { 59 55220 : list_.erase(list_.iterator_to(*obj)); 60 27610 : intrusive_ptr_release(obj); 61 27610 : } 62 : 63 1984810 : IFMapObject *IFMapNode::GetObject() { 64 1984810 : if (list_.empty()) { 65 192056 : return NULL; 66 : } 67 1792754 : return &list_.front(); 68 : } 69 : 70 49150 : const IFMapObject *IFMapNode::GetObject() const { 71 49150 : if (list_.empty()) { 72 24 : return NULL; 73 : } 74 49126 : return &list_.front(); 75 : } 76 : 77 3602 : IFMapNode::crc32type IFMapNode::GetConfigCrc() { 78 3602 : IFMapNode::crc32type crc = 0; 79 3602 : IFMapObject *object = Find(IFMapOrigin(IFMapOrigin::CASSANDRA)); 80 3602 : if (object) { 81 3062 : crc = object->CalculateCrc(); 82 3062 : if (crc == 0) { 83 510 : crc = 0xffffffff; 84 : } 85 : } 86 : 87 3602 : return crc; 88 : } 89 : 90 0 : void IFMapNode::PrintAllObjects() { 91 0 : cout << name_ << ": " << list_.size() << " objects" << endl; 92 0 : for (ObjectList::iterator iter = list_.begin(); iter != list_.end(); 93 : ++iter) { 94 0 : IFMapObject *object = iter.operator->(); 95 0 : cout << "\t" << object->origin().ToString() << endl; 96 : } 97 0 : } 98 : 99 444 : void IFMapNode::EncodeNodeDetail(pugi::xml_node *parent) const { 100 444 : xml_node node = parent->append_child("node"); 101 444 : node.append_attribute("type") = table_->Typename(); 102 444 : node.append_child("name").text().set(name_.c_str()); 103 444 : const IFMapObject *object = GetObject(); 104 444 : if (object != NULL) { 105 420 : object->EncodeUpdate(&node); 106 : } 107 444 : } 108 : 109 0 : void IFMapNode::EncodeNode(xml_node *parent) const { 110 0 : xml_node node = parent->append_child("node"); 111 0 : node.append_attribute("type") = table_->Typename(); 112 0 : node.append_child("name").text().set(name_.c_str()); 113 0 : } 114 : 115 916 : void IFMapNode::EncodeNode(const Descriptor &descriptor, xml_node *parent) { 116 916 : xml_node node = parent->append_child("node"); 117 916 : node.append_attribute("type") = descriptor.first.c_str(); 118 916 : node.append_child("name").text().set(descriptor.second.c_str()); 119 916 : } 120 : 121 1756 : DBEntryBase::KeyPtr IFMapNode::GetDBRequestKey() const { 122 1756 : IFMapTable::RequestKey *keyptr = new IFMapTable::RequestKey(); 123 1756 : keyptr->id_name = name_; 124 1756 : return KeyPtr(keyptr); 125 : } 126 : 127 1064786 : void IFMapNode::SetKey(const DBRequestKey *genkey) { 128 1064786 : const IFMapTable::RequestKey *keyptr = 129 : static_cast<const IFMapTable::RequestKey *>(genkey); 130 1064786 : name_ = keyptr->id_name; 131 1064786 : } 132 : 133 128340 : IFMapNode *IFMapNode::DescriptorLookup( 134 : DB *db, const IFMapNode::Descriptor &descriptor) { 135 128340 : if (db == NULL) { 136 0 : return NULL; 137 : } 138 128340 : IFMapTable *table = IFMapTable::FindTable(db, descriptor.first); 139 128340 : if (table == NULL) { 140 0 : return NULL; 141 : } 142 128340 : return table->FindNode(descriptor.second); 143 : }