Line data    Source code

       1             : /*
       2             :  * Copyright (c) 2013 Juniper Networks, Inc. All rights reserved.
       3             :  */
       4             : 
       5             : #include "ifmap/ifmap_update.h"
       6             : 
       7             : #include "base/time_util.h"
       8             : #include "ifmap/ifmap_node.h"
       9             : 
      10           0 : IFMapObjectPtr::IFMapObjectPtr()
      11           0 :     : type(NIL) {
      12           0 :       u.ptr = NULL;
      13           0 : }
      14             : 
      15        3056 : IFMapObjectPtr::IFMapObjectPtr(IFMapNode *node)
      16        3056 :     : type(NODE) {
      17        3056 :       u.node = node;
      18        3056 : }
      19             : 
      20        3345 : IFMapObjectPtr::IFMapObjectPtr(IFMapLink *link)
      21        3345 :     : type(LINK) {
      22        3345 :       u.link = link;
      23        3345 : }
      24             : 
      25        1578 : void IFMapListEntry::set_queue_insert_at_to_now() {
      26        1578 :     queue_insert_at = UTCTimestampUsec();
      27        1578 : }
      28             : 
      29           0 : std::string IFMapListEntry::queue_insert_ago_str() {
      30           0 :     return duration_usecs_to_string(UTCTimestampUsec() - queue_insert_at);
      31             : }
      32             : 
      33         634 : IFMapUpdate::IFMapUpdate(IFMapNode *node, bool positive)
      34             :     : IFMapListEntry(positive ? UPDATE : DEL),
      35         634 :       data_(node) {
      36         634 : }
      37             : 
      38         589 : IFMapUpdate::IFMapUpdate(IFMapLink *link, bool positive)
      39             :     : IFMapListEntry(positive ? UPDATE : DEL),
      40         589 :       data_(link) {
      41         589 : }
      42             : 
      43         892 : std::string IFMapUpdate::ConfigName() {
      44         892 :     std::string name;
      45         892 :     if (data().type == IFMapObjectPtr::NODE) {
      46         434 :         IFMapNode *node = data().u.node;
      47         434 :         name = node->ToString();
      48         458 :     } else if (data().type == IFMapObjectPtr::LINK) {
      49         458 :         IFMapLink *link = data().u.link;
      50         458 :         name = link->ToString();
      51             :     }
      52         892 :     return name;
      53           0 : }
      54             : 
      55           0 : std::string IFMapUpdate::ToString() {
      56           0 :     return TypeToString() + ":" + ConfigName();
      57             : }
      58             : 
      59        1805 : void IFMapUpdate::AdvertiseReset(const BitSet &set) {
      60        1805 :     advertise_.Reset(set);
      61        1805 : }
      62             : 
      63        1108 : void IFMapUpdate::AdvertiseOr(const BitSet &set) {
      64        1108 :     advertise_ |= set;
      65        1108 : }
      66             : 
      67         169 : void IFMapUpdate::SetAdvertise(const BitSet &set) {
      68         169 :     advertise_ = set;
      69         169 : }
      70             : 
      71         217 : IFMapMarker::IFMapMarker()
      72         217 :     : IFMapListEntry(MARKER) {
      73         217 : }
      74             : 
      75          52 : std::string IFMapMarker::ToString() {
      76         104 :     return std::string("Marker:") + mask.ToNumberedString();
      77             : }
      78             : 
      79        2422 : IFMapState::IFMapState(IFMapNode *node)
      80        2422 :     : sig_(kInvalidSig), data_(node), crc_(0) {
      81        2422 : }
      82             : 
      83        2756 : IFMapState::IFMapState(IFMapLink *link)
      84        2756 :     : sig_(kInvalidSig), data_(link), crc_(0) {
      85        2756 : }
      86             : 
      87        5178 : IFMapState::~IFMapState() {
      88        5178 :     assert(update_list_.empty());
      89        5178 : }
      90             : 
      91       15394 : IFMapUpdate *IFMapState::GetUpdate(IFMapListEntry::EntryType type) {
      92       15394 :     for (UpdateList::iterator iter = update_list_.begin();
      93       34246 :          iter != update_list_.end(); ++iter) {
      94        3058 :         IFMapUpdate *update = iter.operator->();
      95        3058 :         if (update->type == type) {
      96        1329 :             return update;
      97             :         }
      98             :     }
      99       14065 :     return NULL;
     100             : }
     101             : 
     102        1181 : void IFMapState::Insert(IFMapUpdate *update) {
     103        1181 :     update_list_.push_front(*update);
     104        1181 : }
     105             : 
     106        1147 : void IFMapState::Remove(IFMapUpdate *update) {
     107        2294 :     update_list_.erase(update_list_.s_iterator_to(*update));
     108        1147 : }
     109             : 
     110          70 : IFMapNode *IFMapState::GetIFMapNode() const {
     111          70 :     if (data_.IsNode()) {
     112          70 :         return data_.u.node;
     113             :     } else {
     114           0 :         return NULL;
     115             :     }
     116             : }
     117             : 
     118           0 : IFMapLink *IFMapState::GetIFMapLink() const {
     119           0 :     if (data_.IsLink()) {
     120           0 :         return data_.u.link;
     121             :     } else {
     122           0 :         return NULL;
     123             :     }
     124             : }
     125             : 
     126        2422 : IFMapNodeState::IFMapNodeState(IFMapNode *node)
     127        2422 :     : IFMapState(node) {
     128        2422 : }
     129             : 
     130         186 : bool IFMapNodeState::HasDependents() const {
     131         186 :     return !dependents_.empty();
     132             : }
     133             : 
     134        2756 : IFMapLinkState::IFMapLinkState(IFMapLink *link)
     135        2756 :     : IFMapState(link), left_(link), right_(link) {
     136        2756 : }
     137             : 
     138        2759 : void IFMapLinkState::SetDependency(IFMapNodeState *first,
     139             :                                    IFMapNodeState *second) {
     140        2759 :     left_.reset(first);
     141        2759 :     right_.reset(second);
     142        2759 : }
     143             : 
     144          57 : void IFMapLinkState::RemoveDependency() {
     145          57 :     left_.clear();
     146          57 :     right_.clear();
     147          57 : }
     148             : 
     149         640 : bool IFMapLinkState::HasDependency() const {
     150         640 :     return left_.get() != NULL;
     151             : }
     152             :