summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-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;