Bug #1405 ยป consumer.cpp
|
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil -*- */
|
|
|
/**
|
|
|
* Copyright (C) 2013 Regents of the University of California.
|
|
|
* @author: Alexander Afanasyev <[email protected]>
|
|
|
* See COPYING for copyright and distribution information.
|
|
|
*/
|
|
|
|
|
|
// correct way to include NDN-CPP headers
|
|
|
// #include <ndn-cpp-dev/face.hpp>
|
|
|
#include "face.hpp"
|
|
|
|
|
|
static int COUNT = 0;
|
|
|
|
|
|
void
|
|
|
onData(ndn::Face &face,
|
|
|
const ndn::Interest& interest, ndn::Data& data);
|
|
|
|
|
|
void
|
|
|
onTimeout(ndn::Face &face,
|
|
|
const ndn::Interest& interest);
|
|
|
|
|
|
void
|
|
|
onData(ndn::Face &face,
|
|
|
const ndn::Interest& interest, ndn::Data& data)
|
|
|
{
|
|
|
std::cout << "I: " << interest.toUri() << std::endl;
|
|
|
std::cout << "D: " << data.getName().toUri() << std::endl;
|
|
|
|
|
|
if (COUNT < 2) {
|
|
|
++COUNT;
|
|
|
ndn::Interest i(ndn::Name("/non-existing/data"));
|
|
|
i.setScope(1);
|
|
|
i.setInterestLifetime(ndn::time::milliseconds(1000));
|
|
|
i.setMustBeFresh(true);
|
|
|
|
|
|
face.expressInterest(i,
|
|
|
ndn::bind(onData, boost::ref(face), _1, _2),
|
|
|
ndn::bind(onTimeout, boost::ref(face), _1));
|
|
|
}
|
|
|
}
|
|
|
|
|
|
void
|
|
|
onTimeout(ndn::Face &face,
|
|
|
const ndn::Interest& interest)
|
|
|
{
|
|
|
std::cout << "Timeout" << std::endl;
|
|
|
|
|
|
if (COUNT < 2) {
|
|
|
++COUNT;
|
|
|
ndn::Interest i(ndn::Name("/localhost/testApp/randomData"));
|
|
|
i.setScope(1);
|
|
|
i.setInterestLifetime(ndn::time::milliseconds(1000));
|
|
|
i.setMustBeFresh(true);
|
|
|
|
|
|
face.expressInterest(i,
|
|
|
ndn::bind(onData, boost::ref(face), _1, _2),
|
|
|
ndn::bind(onTimeout, boost::ref(face), _1));
|
|
|
}
|
|
|
}
|
|
|
|
|
|
int main()
|
|
|
{
|
|
|
try {
|
|
|
ndn::Interest i(ndn::Name("/localhost/testApp/randomData"));
|
|
|
i.setScope(1);
|
|
|
i.setInterestLifetime(ndn::time::milliseconds(1000));
|
|
|
i.setMustBeFresh(true);
|
|
|
|
|
|
ndn::Face face;
|
|
|
face.expressInterest(i,
|
|
|
ndn::bind(onData, boost::ref(face), _1, _2),
|
|
|
ndn::bind(onTimeout, boost::ref(face), _1));
|
|
|
|
|
|
// processEvents will block until the requested data received or timeout occurs
|
|
|
face.processEvents();
|
|
|
}
|
|
|
catch(std::exception &e) {
|
|
|
std::cerr << "ERROR: " << e.what() << std::endl;
|
|
|
}
|
|
|
return 0;
|
|
|
}
|