diff options
author | Mauro Sardara <msardara@cisco.com> | 2019-03-19 16:21:55 +0100 |
---|---|---|
committer | Mauro Sardara <msardara@cisco.com> | 2019-03-19 16:23:22 +0100 |
commit | 393a0a4018936134fa1b343523bbafaab606973d (patch) | |
tree | eb587157a3ff5235ec02611287c02c5e08487eba /libtransport/src/hicn/transport/protocols/raaqm.cc | |
parent | 7266728a7857b038679fe35321ace30386f0c461 (diff) |
[HICN-125 HICN-126]
- Add MemBuf as return type of getPayload of transport::core::Packet
- Fix incremental index manager
Change-Id: Ib557d56b1bf42e3974364c611b825b21f1e3d3f1
Signed-off-by: Mauro Sardara <msardara@cisco.com>
Diffstat (limited to 'libtransport/src/hicn/transport/protocols/raaqm.cc')
-rw-r--r-- | libtransport/src/hicn/transport/protocols/raaqm.cc | 13 |
1 files changed, 5 insertions, 8 deletions
diff --git a/libtransport/src/hicn/transport/protocols/raaqm.cc b/libtransport/src/hicn/transport/protocols/raaqm.cc index cd3a6cb85..be76f7c23 100644 --- a/libtransport/src/hicn/transport/protocols/raaqm.cc +++ b/libtransport/src/hicn/transport/protocols/raaqm.cc @@ -98,6 +98,11 @@ int RaaqmTransportProtocol::start() { void RaaqmTransportProtocol::resume() { return TransportProtocol::resume(); } void RaaqmTransportProtocol::reset() { + // Set first segment to retrieve + core::Name *name; + socket_->getSocketOption(GeneralTransportOptions::NETWORK_NAME, &name); + index_manager_->setFirstSuffix(name->getSuffix()); + // Reset reassembly component BaseReassembly::reset(); @@ -333,17 +338,9 @@ void RaaqmTransportProtocol::onContentObject( index_manager_->onManifest(std::move(content_object)); } else if (content_object->getPayloadType() == PayloadType::CONTENT_OBJECT) { - if (TRANSPORT_EXPECT_FALSE(incremental_suffix == 0)) { - index_manager_ = incremental_index_manager_.get(); - } - onContentSegment(std::move(interest), std::move(content_object)); } - if (TRANSPORT_EXPECT_FALSE(incremental_suffix == 0)) { - BaseReassembly::index_ = index_manager_->getNextReassemblySegment(); - } - scheduleNextInterests(); } |