SunnyQjm/ChronoSync
1
0 Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Drop redundant calls to Interest::setCanBePrefix(false)

Browse Source 
Change-Id: I319ec178e3bb27c0dd77318d0cb201850a1e7126
This commit is contained in:
Davide Pesavento committed 2022-03-07 13:32:04 -05:00
1 parent 22eeb2914f
commit 44ec20773e
2 files changed
+4 -7
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

src/logic.cpp
+1 -2
View File
@@ -1,6 +1,6 @@
/* -*- Mode: C++; c-file-style: "gnu"; indent-tabs-mode:nil -*- */
/*
* Copyright (c) 2012-2021 University of California, Los Angeles
* Copyright (c) 2012-2022 University of California, Los Angeles
*
* This file is part of ChronoSync, synchronization library for distributed realtime
* applications for NDN.
@@ -596,7 +596,6 @@ Logic::sendResetInterest()
Interest interest(m_syncReset);
interest.setMustBeFresh(true);
interest.setCanBePrefix(false); // no data is expected
interest.setInterestLifetime(m_resetInterestLifetime);
// Assigning to m_pendingResetInterest cancels the previous reset Interest.
src/socket.cpp
+3 -5
View File
@@ -1,6 +1,6 @@
/* -*- Mode: C++; c-file-style: "gnu"; indent-tabs-mode:nil -*- */
/*
* Copyright (c) 2012-2021 University of California, Los Angeles
* Copyright (c) 2012-2022 University of California, Los Angeles
*
* This file is part of ChronoSync, synchronization library for distributed realtime
* applications for NDN.
@@ -124,7 +124,7 @@ void
Socket::publishData(const Block& content, const ndn::time::milliseconds& freshness,
const Name& prefix)
{
shared_ptr<Data> data = make_shared<Data>();
auto data = std::make_shared<Data>();
data->setContent(content);
data->setFreshnessPeriod(freshness);
@@ -147,7 +147,7 @@ void
Socket::publishData(const Block& content, const ndn::time::milliseconds& freshness,
const uint64_t& seqNo, const Name& prefix)
{
shared_ptr<Data> data = make_shared<Data>();
auto data = std::make_shared<Data>();
data->setContent(content);
data->setFreshnessPeriod(freshness);
@@ -176,7 +176,6 @@ Socket::fetchData(const Name& sessionName, const SeqNo& seqNo,
Interest interest(interestName);
interest.setMustBeFresh(true);
interest.setCanBePrefix(false);
DataValidationErrorCallback failureCallback =
bind(&Socket::onDataValidationFailed, this, _1, _2);
@@ -202,7 +201,6 @@ Socket::fetchData(const Name& sessionName, const SeqNo& seqNo,
Interest interest(interestName);
interest.setMustBeFresh(true);
interest.setCanBePrefix(false);
m_face.expressInterest(interest,
bind(&Socket::onData, this, _1, _2, dataCallback, failureCallback),