aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMauro Sardara <msardara@cisco.com>2019-03-29 13:52:31 +0100
committerMauro Sardara <msardara@cisco.com>2019-03-29 13:52:31 +0100
commit1eec68585d60ef29bead48c0a1c5950d50b0260f (patch)
treeb3e01e4fd2086d1096fa575e32d115c2539f06aa
parent092e4903066f66f51c60ca8a0cef4cabbe7bafaa (diff)
[HICN-152] Fix window size in CBR.
Change-Id: Ib2d6658a6118b29f57b99ecc58ac001030092982 Signed-off-by: Mauro Sardara <msardara@cisco.com>
-rw-r--r--libtransport/src/hicn/transport/protocols/cbr.cc6
-rw-r--r--libtransport/src/hicn/transport/protocols/cbr.h2
2 files changed, 6 insertions, 2 deletions
diff --git a/libtransport/src/hicn/transport/protocols/cbr.cc b/libtransport/src/hicn/transport/protocols/cbr.cc
index efd2149ad..02bc7b5e4 100644
--- a/libtransport/src/hicn/transport/protocols/cbr.cc
+++ b/libtransport/src/hicn/transport/protocols/cbr.cc
@@ -26,10 +26,12 @@ CbrTransportProtocol::CbrTransportProtocol(
interface::ConsumerSocket *icnet_socket)
: RaaqmTransportProtocol(icnet_socket) {}
-int CbrTransportProtocol::start() {
+int CbrTransportProtocol::start() { return RaaqmTransportProtocol::start(); }
+
+void CbrTransportProtocol::reset() {
+ RaaqmTransportProtocol::reset();
socket_->getSocketOption(GeneralTransportOptions::CURRENT_WINDOW_SIZE,
current_window_size_);
- return RaaqmTransportProtocol::start();
}
void CbrTransportProtocol::afterDataUnsatisfied(uint64_t segment) {}
diff --git a/libtransport/src/hicn/transport/protocols/cbr.h b/libtransport/src/hicn/transport/protocols/cbr.h
index a8eff2182..e80da14f5 100644
--- a/libtransport/src/hicn/transport/protocols/cbr.h
+++ b/libtransport/src/hicn/transport/protocols/cbr.h
@@ -27,6 +27,8 @@ class CbrTransportProtocol : public RaaqmTransportProtocol {
int start() override;
+ void reset() override;
+
private:
void afterContentReception(const Interest &interest,
const ContentObject &content_object) override;