Line data    Source code

       1             : /*
       2             :  * Copyright (c) 2014 Juniper Networks, Inc. All rights reserved.
       3             :  */
       4             : 
       5             : #include "base/logging.h"
       6             : #include "base/timer.h"
       7             : #include <sandesh/sandesh_trace.h>
       8             : #include "cmn/agent_cmn.h"
       9             : #include "init/agent_param.h"
      10             : #include "xmpp/xmpp_init.h"
      11             : #include "pugixml/pugixml.hpp"
      12             : #include "oper/global_system_config.h"
      13             : #include "oper/vrf.h"
      14             : #include "oper/peer.h"
      15             : #include "oper/mirror_table.h"
      16             : #include "oper/multicast.h"
      17             : #include "oper/operdb_init.h"
      18             : #include "oper/instance_manager.h"
      19             : #include "controller/controller_types.h"
      20             : #include "controller/controller_init.h"
      21             : #include "controller/controller_timer.h"
      22             : #include "controller/controller_peer.h"
      23             : #include "controller/controller_ifmap.h"
      24             : 
      25             : #define SECS_TO_USECS(t) t * 1000 * 1000
      26             : #define SECS_TO_MSECS(t) t * 1000
      27             : 
      28             : // Creates new timer
      29           5 : ControllerTimer::ControllerTimer(Agent *agent,
      30             :                                  const std::string &timer_name,
      31           5 :                                  uint32_t timer_interval)
      32           5 :     : agent_(agent), last_restart_time_(0),
      33           5 :     xmpp_server_(""), timer_name_(timer_name),
      34           5 :     timer_interval_(timer_interval) {
      35           5 :     controller_timer_ =
      36          10 :         TimerManager::CreateTimer(*(agent->event_manager()->
      37           5 :                                     io_service()), timer_name,
      38             :                                   TaskScheduler::GetInstance()->
      39             :                                   GetTaskId("Agent::ControllerXmpp"), 0);
      40           5 : }
      41             : 
      42           5 : ControllerTimer::~ControllerTimer() {
      43             :     //Delete timer
      44           5 :     if (controller_timer_) {
      45           5 :         TimerManager::DeleteTimer(controller_timer_);
      46             :     }
      47           5 : }
      48             : 
      49           0 : void ControllerTimer::Fire() {
      50           0 :     controller_timer_->Fire();
      51           0 : }
      52             : 
      53           1 : bool ControllerTimer::Cancel() {
      54           1 :     CONTROLLER_TRACE(Timer, "ControllerTimer", timer_name(), "");
      55           1 :     last_restart_time_ = 0;
      56           1 :     xmpp_server_.clear();
      57             : 
      58           1 :     if (controller_timer_ == NULL) {
      59           0 :         CONTROLLER_TRACE(Timer, "No controller timer", timer_name(), "");
      60           0 :         return true;
      61             :     }
      62             : 
      63           1 :     return controller_timer_->Cancel();
      64             : }
      65             : 
      66             : // Set the last_restart_time and update the owner of the timer with XmppServer
      67           1 : void ControllerTimer::Start(AgentXmppChannel *agent_xmpp_channel) {
      68           1 :     if (controller_timer_->running()) {
      69           0 :         if (controller_timer_->Cancel() == false) {
      70           0 :             CONTROLLER_TRACE(Timer, "Cancel during restart of timer failed",
      71             :                              timer_name(), agent_xmpp_channel->GetXmppServer());
      72             :         }
      73             :     }
      74             : 
      75             :     // Start the timer fresh
      76           1 :     controller_timer_->Start(GetTimerInterval(),
      77             :         boost::bind(&ControllerTimer::TimerExpiredCallback, this));
      78           1 :     CONTROLLER_TRACE(Timer, "Start", timer_name(),
      79             :                      agent_xmpp_channel->GetXmppServer());
      80             : 
      81           1 :     last_restart_time_ = UTCTimestampUsec();
      82           1 :     xmpp_server_ = agent_xmpp_channel->GetXmppServer();
      83           1 : }
      84             : 
      85           0 : bool ControllerTimer::running() const {
      86           0 :     return controller_timer_->running();
      87             : }
      88             : 
      89             : // Start the timer again if extension interval is not zero.
      90             : // If extension interval is not present then execute the expiration
      91             : // handler.
      92           1 : bool ControllerTimer::TimerExpiredCallback() {
      93             : 
      94           1 :     bool ret = TimerExpirationDone();
      95           1 :     CONTROLLER_TRACE(Timer, "Called Timer Expiration Routine", timer_name(),
      96             :                      xmpp_server_);
      97             : 
      98             :     //Reset all parameters
      99           1 :     xmpp_server_.clear();
     100           1 :     return ret;
     101             : }
     102             : 
     103           1 : ConfigCleanupTimer::ConfigCleanupTimer(Agent *agent) :
     104             :     ControllerTimer(agent, "Agent Config Stale cleanup timer",
     105           1 :                     SECS_TO_MSECS(agent->params()->
     106             :                                   llgr_params().stale_config_cleanup_time())),
     107           2 :     sequence_number_(0) {
     108           1 : }
     109             : 
     110           0 : void ConfigCleanupTimer::Start(AgentXmppChannel *channel) {
     111           0 :     sequence_number_ =
     112           0 :         agent_->ifmap_xmpp_channel(agent_->ifmap_active_xmpp_server_index())->
     113           0 :         GetSeqNumber();
     114             : 
     115           0 :     ControllerTimer::Start(channel);
     116           0 : }
     117             : 
     118           0 : bool ConfigCleanupTimer::TimerExpirationDone() {
     119           0 :     agent_->ifmap_stale_cleaner()->StaleTimeout(sequence_number_);
     120           0 :     agent_->oper_db()->instance_manager()->StaleTimeout();
     121           0 :     return false;
     122             : }
     123             : 
     124           0 : uint32_t ConfigCleanupTimer::GetTimerInterval() const {
     125           0 :     return SECS_TO_MSECS(agent_->params()->
     126             :                          llgr_params().stale_config_cleanup_time());
     127             : }
     128             : 
     129           1 : EndOfConfigTimer::EndOfConfigTimer(Agent *agent,
     130           1 :                                    AgentIfMapXmppChannel *config_channel) :
     131             :     ControllerTimer(agent, "End of config identification timer",
     132           1 :                     SECS_TO_MSECS(agent->params()->
     133             :                                   llgr_params().config_poll_time())),
     134           2 :     config_channel_(config_channel) {
     135           1 :     Reset();
     136           1 : }
     137             : 
     138           1 : void EndOfConfigTimer::Reset() {
     139           1 :     last_config_receive_time_ = 0;
     140           1 :     inactivity_detected_time_ = 0;
     141           1 :     end_of_config_processed_time_ = 0;
     142           1 :     config_inactivity_time_ = 0;
     143           1 :     fallback_interval_ = 0;
     144           1 :     fallback_ = false;
     145           1 :     GresEnabled(agent_->oper_db()->global_system_config()->
     146           1 :                 gres_parameters().IsEnabled());
     147           1 : }
     148             : 
     149           0 : void EndOfConfigTimer::Start(AgentXmppChannel *agent_xmpp_channel) {
     150           0 :     Reset();
     151           0 :     agent_->controller()->StopEndOfRibTx();
     152           0 :     ControllerTimer::Start(agent_xmpp_channel);
     153           0 : }
     154             : 
     155             : //Identify silence of 30 seconds on config channel
     156           0 : bool EndOfConfigTimer::TimerExpirationDone() {
     157           0 :     uint64_t current_time = UTCTimestampUsec();
     158             :     //Config has been seen within inactivity time
     159           0 :     bool config_seen = false;
     160             : 
     161           0 :     if (last_config_receive_time_ != 0) {
     162           0 :         if ((current_time - last_config_receive_time_) <
     163           0 :             GetInactivityInterval()) {
     164           0 :             config_seen = true;
     165             :         }
     166             :     }
     167             : 
     168             :     //When config is regularly seen on channel, put stale timeout to worst.
     169           0 :     if ((current_time - last_restart_time_) >= GetFallbackInterval()) {
     170           0 :         fallback_ = true;
     171             :     }
     172             : 
     173             :     // End of config is enqueued in VNController work queue for processing.
     174           0 :     if (fallback_ || !config_seen) {
     175           0 :         inactivity_detected_time_ = UTCTimestampUsec();
     176           0 :         config_channel_->EnqueueEndOfConfig();
     177           0 :         return false;
     178             :     }
     179           0 :     return true;
     180             : }
     181             : 
     182           0 : uint32_t EndOfConfigTimer::GetTimerInterval() const {
     183           0 :     return SECS_TO_MSECS(agent_->params()->
     184             :                          llgr_params().config_poll_time());
     185             : }
     186             : 
     187           0 : uint32_t EndOfConfigTimer::GetFallbackInterval() const {
     188           0 :     return fallback_interval_;
     189             : }
     190             : 
     191           0 : uint32_t EndOfConfigTimer::GetInactivityInterval() const {
     192           0 :     return config_inactivity_time_;
     193             : }
     194             : 
     195           1 : void EndOfConfigTimer::GresEnabled(bool enable) {
     196           1 :     if (enable) {
     197           0 :         config_inactivity_time_ = SECS_TO_USECS(agent_->params()->
     198             :                                   llgr_params().config_inactivity_time());
     199           0 :         fallback_interval_ = SECS_TO_USECS(agent_->params()->
     200             :                                            llgr_params().config_fallback_time());
     201             :     } else {
     202           1 :         config_inactivity_time_ = 0;
     203           1 :         fallback_interval_ = 0;
     204             :     }
     205           1 : }
     206             : 
     207           1 : EndOfRibTxTimer::EndOfRibTxTimer(Agent *agent) :
     208             :     ControllerTimer(agent, "End of rib Tx identification timer",
     209           1 :                     SECS_TO_MSECS(agent->params()->
     210             :                                   llgr_params().end_of_rib_tx_poll_time())),
     211           2 :     agent_xmpp_channel_(NULL) {
     212           1 :     Reset();
     213           1 : }
     214             : 
     215           1 : void EndOfRibTxTimer::Reset() {
     216           1 :     end_of_rib_tx_time_ = 0;
     217           1 :     last_route_published_time_ = 0;
     218           1 :     fallback_ = false;
     219           1 :     fallback_interval_ = 0;
     220           1 :     GresEnabled(agent_->oper_db()->global_system_config()->
     221           1 :                 gres_parameters().IsEnabled());
     222           1 : }
     223             : 
     224           0 : void EndOfRibTxTimer::Start(AgentXmppChannel *agent_xmpp_channel) {
     225           0 :     Reset();
     226           0 :     agent_xmpp_channel_ = agent_xmpp_channel;
     227           0 :     ControllerTimer::Start(agent_xmpp_channel);
     228           0 : }
     229             : 
     230           0 : bool EndOfRibTxTimer::TimerExpirationDone() {
     231           0 :     uint64_t current_time = UTCTimestampUsec();
     232           0 :     uint8_t index = agent_xmpp_channel_->GetXmppServerIdx();
     233           0 :     bool end_of_rib = false;
     234             : 
     235             :     // Check for fallback
     236           0 :     if (last_route_published_time_ == 0) {
     237           0 :         if ((current_time - agent_->controller_xmpp_channel_setup_time(index)) >
     238           0 :             GetFallbackInterval()) {
     239           0 :             end_of_rib = true;
     240             :         }  else {
     241           0 :             return true;
     242             :         }
     243             :     }
     244             : 
     245             :     // Check for inactivity
     246           0 :     if ((current_time - last_route_published_time_) > GetInactivityInterval()) {
     247           0 :         end_of_rib = true;
     248             :     }
     249             : 
     250           0 :     if (end_of_rib) {
     251             :         // Start walk to delete stale routes.
     252           0 :         agent_xmpp_channel_->StartEndOfRibTxWalker();
     253             :         //Notify
     254           0 :         agent_->event_notifier()->
     255           0 :             Notify(new EventNotifyKey(EventNotifyKey::END_OF_RIB));
     256           0 :         return false;
     257             :     }
     258             : 
     259           0 :     return true;
     260             : }
     261             : 
     262           0 : uint32_t EndOfRibTxTimer::GetTimerInterval() const {
     263           0 :     return SECS_TO_MSECS(agent_->params()->
     264             :                          llgr_params().end_of_rib_tx_poll_time());
     265             : }
     266             : 
     267           0 : uint32_t EndOfRibTxTimer::GetFallbackInterval() const {
     268           0 :     return fallback_interval_;
     269             : }
     270             : 
     271           0 : uint32_t EndOfRibTxTimer::GetInactivityInterval() const {
     272           0 :     return end_of_rib_tx_time_;
     273             : }
     274             : 
     275           1 : void EndOfRibTxTimer::GresEnabled(bool enable) {
     276           1 :     if (enable) {
     277           0 :         end_of_rib_tx_time_ = SECS_TO_USECS(agent_->params()->
     278             :                               llgr_params().end_of_rib_tx_inactivity_time());
     279           0 :         fallback_interval_ = SECS_TO_USECS(agent_->params()->
     280             :                              llgr_params().end_of_rib_tx_fallback_time());
     281             :     } else {
     282           1 :         end_of_rib_tx_time_ = 0;
     283           1 :         fallback_interval_ = 0;
     284             :     }
     285           1 : }
     286             : 
     287           1 : EndOfRibRxTimer::EndOfRibRxTimer(Agent *agent) :
     288             :     ControllerTimer(agent, "End of rib Rx path timer",
     289           1 :               SECS_TO_MSECS(agent->params()->
     290             :                             llgr_params().end_of_rib_rx_fallback_time())),
     291           2 :               agent_xmpp_channel_(NULL) {
     292           1 :     Reset();
     293           1 : }
     294             : 
     295           0 : void EndOfRibRxTimer::Start(AgentXmppChannel *agent_xmpp_channel) {
     296           0 :     agent_xmpp_channel_ = agent_xmpp_channel;
     297           0 :     ControllerTimer::Start(agent_xmpp_channel);
     298           0 : }
     299             : 
     300           0 : bool EndOfRibRxTimer::TimerExpirationDone() {
     301           0 :     end_of_rib_rx_time_ = UTCTimestampUsec();
     302           0 :     fallback_ = true;
     303           0 :     agent_xmpp_channel_->EndOfRibRx();
     304           0 :     return false;
     305             : }
     306             : 
     307           1 : void EndOfRibRxTimer::Reset() {
     308           1 :     end_of_rib_rx_time_ = 0;
     309           1 :     end_of_rib_rx_fallback_time_ = 0;
     310           1 :     fallback_ = false;
     311           1 :     GresEnabled(agent_->oper_db()->global_system_config()->
     312           1 :                 gres_parameters().IsEnabled());
     313           1 : }
     314             : 
     315           0 : uint32_t EndOfRibRxTimer::GetTimerInterval() const {
     316           0 :     return end_of_rib_rx_fallback_time_;
     317             : }
     318             : 
     319           1 : void EndOfRibRxTimer::GresEnabled(bool enable) {
     320           1 :     if (enable) {
     321           0 :         end_of_rib_rx_fallback_time_ = agent_->oper_db()->
     322           0 :             global_system_config()->gres_parameters().end_of_rib_time();
     323           0 :         if (end_of_rib_rx_fallback_time_ == 0) {
     324           0 :             end_of_rib_rx_fallback_time_ = SECS_TO_MSECS(agent_->params()->
     325             :                                    llgr_params().end_of_rib_rx_fallback_time());
     326             :         }
     327             :     } else {
     328           1 :         end_of_rib_rx_fallback_time_ = 0;
     329             :     }
     330           1 : }
     331             : 
     332           1 : LlgrStaleTimer::LlgrStaleTimer(Agent *agent) :
     333             :     ControllerTimer(agent, "Llgr stale timer",
     334           1 :               SECS_TO_MSECS(agent->oper_db()->global_system_config()->
     335             :                             gres_parameters().llgr_stale_time())),
     336           2 :               agent_xmpp_channel_(NULL) {
     337           1 :     Reset();
     338           1 : }
     339             : 
     340           1 : void LlgrStaleTimer::Start(AgentXmppChannel *agent_xmpp_channel) {
     341           1 :     Reset();
     342           1 :     agent_xmpp_channel_ = agent_xmpp_channel;
     343           1 :     ControllerTimer::Start(agent_xmpp_channel);
     344           1 : }
     345             : 
     346           1 : bool LlgrStaleTimer::TimerExpirationDone() {
     347           1 :     agent_xmpp_channel_->EndOfRibRx();
     348           1 :     return false;
     349             : }
     350             : 
     351           2 : void LlgrStaleTimer::Reset() {
     352           2 :     llgr_stale_time_ = 0;
     353           2 :     GresEnabled(agent_->oper_db()->global_system_config()->
     354           2 :                 gres_parameters().IsEnabled());
     355           2 : }
     356             : 
     357           1 : uint32_t LlgrStaleTimer::GetTimerInterval() const {
     358           1 :     return llgr_stale_time_;
     359             : }
     360             : 
     361           2 : void LlgrStaleTimer::GresEnabled(bool enable) {
     362           2 :     if (enable) {
     363           0 :         llgr_stale_time_ = SECS_TO_MSECS(agent_->oper_db()->
     364             :             global_system_config()->gres_parameters().llgr_stale_time());
     365           0 :         if (llgr_stale_time_ == 0) {
     366           0 :             llgr_stale_time_ = SECS_TO_MSECS(agent_->params()->
     367             :                                              llgr_params().llgr_stale_time());
     368             :         }
     369             :     } else {
     370           2 :         llgr_stale_time_ = 0;
     371             :     }
     372           2 : }