From dd25624f0dc2d42d8b78693f419a3017a4e83b8a Mon Sep 17 00:00:00 2001 From: Ananth Suryanarayana Date: Fri, 18 Nov 2016 12:43:58 -0800 Subject: [PATCH] Use correct timer to reschedule in BgpXmppChannel::EndOfRibSendTimerExpired() Also rename BgpXmppChannel::ResetEndOfRibState() to ResetEndOfRibSendState() Change-Id: I0e4005c80ae5eb9cf7202a78d0817bd9c69f64d9 Closes-Bug: #1643058 --- src/bgp/bgp_xmpp_channel.cc | 10 +++++----- src/bgp/bgp_xmpp_channel.h | 2 +- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/src/bgp/bgp_xmpp_channel.cc b/src/bgp/bgp_xmpp_channel.cc index eb80494923b..1514af046f7 100644 --- a/src/bgp/bgp_xmpp_channel.cc +++ b/src/bgp/bgp_xmpp_channel.cc @@ -384,7 +384,7 @@ class BgpXmppChannel::XmppPeer : public IPeer { send_ready_ = true; // Restart EndOfRib Send timer if necessary. - parent_->ResetEndOfRibState(); + parent_->ResetEndOfRibSendState(); } BgpServer *server_; @@ -1725,7 +1725,7 @@ bool BgpXmppChannel::MembershipResponseHandler(string table_name) { channel_stats_.table_unsubscribe); // Restart EndOfRib send if necessary. - ResetEndOfRibState(); + ResetEndOfRibSendState(); // If Close manager is waiting to use membership, try now. if (close_manager_->IsMembershipInWait()) @@ -2223,7 +2223,7 @@ bool BgpXmppChannel::EndOfRibSendTimerExpired() { // seconds, delay EoR send event. if (channel_->LastReceived(kEndOfRibSendRetryTimeMsecs * 3) || channel_->LastSent(kEndOfRibSendRetryTimeMsecs * 3)) { - eor_receive_timer_->Reschedule(kEndOfRibSendRetryTimeMsecs); + eor_send_timer_->Reschedule(kEndOfRibSendRetryTimeMsecs); BGP_LOG_PEER(Message, Peer(), SandeshLevel::SYS_INFO, BGP_LOG_FLAG_ALL, BGP_PEER_DIR_IN, "EndOfRib Send timer rescheduled to fire after " << @@ -2251,7 +2251,7 @@ void BgpXmppChannel::StartEndOfRibReceiveTimer() { boost::bind(&BgpXmppChannel::EndOfRibTimerErrorHandler, this, _1, _2)); } -void BgpXmppChannel::ResetEndOfRibState() { +void BgpXmppChannel::ResetEndOfRibSendState() { if (eor_sent_) return; @@ -2558,7 +2558,7 @@ void BgpXmppChannelManager::XmppHandleChannelEvent(XmppChannel *channel, bgp_xmpp_channel->eor_sent_ = false; bgp_xmpp_channel->StartEndOfRibReceiveTimer(); - bgp_xmpp_channel->ResetEndOfRibState(); + bgp_xmpp_channel->ResetEndOfRibSendState(); } else if (state == xmps::NOT_READY) { if (it != channel_map_.end()) { bgp_xmpp_channel = (*it).second; diff --git a/src/bgp/bgp_xmpp_channel.h b/src/bgp/bgp_xmpp_channel.h index 05867e9c6f1..3da520b52c8 100644 --- a/src/bgp/bgp_xmpp_channel.h +++ b/src/bgp/bgp_xmpp_channel.h @@ -145,7 +145,7 @@ class BgpXmppChannel { const XmppChannel *channel() const { return channel_; } XmppChannel *channel() { return channel_; } void StartEndOfRibReceiveTimer(); - void ResetEndOfRibState(); + void ResetEndOfRibSendState(); bool EndOfRibSendTimerExpired(); bool MembershipResponseHandler(std::string table_name); Timer *eor_send_timer() const { return eor_send_timer_; }