commit f0b3de3b5c7a06bf309b6169d52c7d6b58785cbc
author Yingdi Yu <yuyingdi@gmail.com> Thu Jul 11 12:59:00 2013 -0700
committer Yingdi Yu <yuyingdi@gmail.com> Thu Aug 15 15:14:10 2013 -0700
tree 3b8c9db325b50eedbf071a5f2438670e8a8592f5
parent 57f667b19d9af97496e1dd4b982d4ff6b68d3b1f

Add slow start and back-off timeout in Fetcher

Change-Id: I0b1698f118819f32bd93b5a4ab46cfde0bc4c03a

src/fetcher.h

diff --git a/src/fetcher.h b/src/fetcher.h
index 515b2e9..1bc5d03 100644
--- a/src/fetcher.h
+++ b/src/fetcher.h
@@ -133,6 +133,11 @@
 
   uint32_t m_pipeline;
   uint32_t m_activePipeline;
+  double m_rto;
+  double m_maxRto;
+  bool m_slowStart;
+  uint32_t m_threshold;
+  uint32_t m_roundCount;
 
   boost::posix_time::ptime m_lastPositiveActivity;
 
@@ -142,6 +147,8 @@
   ExecutorPtr m_executor; // to serialize FillPipeline events
 
   boost::mutex m_seqNoMutex;
+  boost::mutex m_rtoMutex;
+  boost::mutex m_pipelineMutex;
 };
 
 typedef boost::error_info<struct tag_errmsg, std::string> errmsg_info_str;