| Weiwei Liu | 245d791 | 2016-07-28 00:04:25 -0700 | [diff] [blame^] | 1 | /** |
| 2 | * Copyright (c) 2016, Regents of the University of California, |
| 3 | * Colorado State University, |
| 4 | * University Pierre & Marie Curie, Sorbonne University. |
| 5 | * |
| 6 | * This file is part of ndn-tools (Named Data Networking Essential Tools). |
| 7 | * See AUTHORS.md for complete list of ndn-tools authors and contributors. |
| 8 | * |
| 9 | * ndn-tools is free software: you can redistribute it and/or modify it under the terms |
| 10 | * of the GNU General Public License as published by the Free Software Foundation, |
| 11 | * either version 3 of the License, or (at your option) any later version. |
| 12 | * |
| 13 | * ndn-tools is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; |
| 14 | * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR |
| 15 | * PURPOSE. See the GNU General Public License for more details. |
| 16 | * |
| 17 | * You should have received a copy of the GNU General Public License along with |
| 18 | * ndn-tools, e.g., in COPYING.md file. If not, see <http://www.gnu.org/licenses/>. |
| 19 | * |
| 20 | * See AUTHORS.md for complete list of ndn-cxx authors and contributors. |
| 21 | * |
| 22 | * @author Weiwei Liu |
| 23 | */ |
| 24 | |
| 25 | #include "aimd-statistics-collector.hpp" |
| 26 | |
| 27 | namespace ndn { |
| 28 | namespace chunks { |
| 29 | namespace aimd { |
| 30 | |
| 31 | StatisticsCollector::StatisticsCollector(PipelineInterestsAimd& pipeline, RttEstimator& rttEstimator, |
| 32 | std::ostream& osCwnd, std::ostream& osRtt) |
| 33 | : m_osCwnd(osCwnd) |
| 34 | , m_osRtt(osRtt) |
| 35 | { |
| 36 | m_osCwnd << "time\tcwndsize\n"; |
| 37 | m_osRtt << "segment\trtt\trttvar\tsrtt\trto\n"; |
| 38 | pipeline.afterCwndChange.connect( |
| 39 | [this] (Milliseconds timeElapsed, double cwnd) { |
| 40 | m_osCwnd << timeElapsed.count() / 1000 << '\t' << cwnd << '\n'; |
| 41 | }); |
| 42 | rttEstimator.afterRttMeasurement.connect( |
| 43 | [this] (const RttRtoSample& rttSample) { |
| 44 | m_osRtt << rttSample.segNo << '\t' |
| 45 | << rttSample.rtt.count() << '\t' |
| 46 | << rttSample.rttVar.count() << '\t' |
| 47 | << rttSample.sRtt.count() << '\t' |
| 48 | << rttSample.rto.count() << '\n'; |
| 49 | }); |
| 50 | } |
| 51 | |
| 52 | } // namespace aimd |
| 53 | } // namespace chunks |
| 54 | } // namespace ndn |