blob: 76f9853fbb403f2f2b6299c091da44209f0ae146 [file] [log] [blame]
Alexander Afanasyevc169a812014-05-20 20:37:29 -04001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
Davide Pesaventocdcde902017-08-23 15:40:22 -04002/*
Davide Pesavento0f830802018-01-16 23:58:58 -05003 * Copyright (c) 2013-2018 Regents of the University of California.
Alexander Afanasyevdfa52c42014-04-24 21:10:11 -07004 *
5 * This file is part of ndn-cxx library (NDN C++ library with eXperimental eXtensions).
Alexander Afanasyevdfa52c42014-04-24 21:10:11 -07006 *
Alexander Afanasyevc169a812014-05-20 20:37:29 -04007 * ndn-cxx library is free software: you can redistribute it and/or modify it under the
8 * terms of the GNU Lesser General Public License as published by the Free Software
9 * Foundation, either version 3 of the License, or (at your option) any later version.
10 *
11 * ndn-cxx library is distributed in the hope that it will be useful, but WITHOUT ANY
12 * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
13 * PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
14 *
15 * You should have received copies of the GNU General Public License and GNU Lesser
16 * General Public License along with ndn-cxx, e.g., in COPYING.md file. If not, see
17 * <http://www.gnu.org/licenses/>.
18 *
19 * See AUTHORS.md for complete list of ndn-cxx authors and contributors.
Alexander Afanasyevdfa52c42014-04-24 21:10:11 -070020 *
21 * @author Alexander Afanasyev <http://lasr.cs.ucla.edu/afanasyev/index.html>
Alexander Afanasyevf6468892014-01-29 01:04:14 -080022 */
23
Alexander Afanasyev766cea72014-04-24 19:16:42 -070024// correct way to include ndn-cxx headers
25// #include <ndn-cxx/face.hpp>
26// #include <ndn-cxx/util/scheduler.hpp>
Alexander Afanasyevf6468892014-01-29 01:04:14 -080027#include "face.hpp"
28#include "util/scheduler.hpp"
29
Davide Pesavento4d0d0962017-12-19 22:23:14 -050030#include <boost/asio/io_service.hpp>
Davide Pesaventocdcde902017-08-23 15:40:22 -040031#include <iostream>
32
Alexander Afanasyev151a8552014-04-11 00:54:43 -070033// Enclosing code in ndn simplifies coding (can also use `using namespace ndn`)
34namespace ndn {
Davide Pesaventocdcde902017-08-23 15:40:22 -040035// Additional nested namespaces can be used to prevent/limit name conflicts
Alexander Afanasyev151a8552014-04-11 00:54:43 -070036namespace examples {
37
Davide Pesavento4d0d0962017-12-19 22:23:14 -050038class ConsumerWithTimer
Alexander Afanasyevf6468892014-01-29 01:04:14 -080039{
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070040public:
41 ConsumerWithTimer()
42 : m_face(m_ioService) // Create face with io_service object
43 , m_scheduler(m_ioService)
44 {
45 }
Alexander Afanasyevf6468892014-01-29 01:04:14 -080046
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070047 void
48 run()
49 {
50 Interest interest(Name("/example/testApp/randomData"));
Davide Pesavento0f830802018-01-16 23:58:58 -050051 interest.setInterestLifetime(2_s); // 2 seconds
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070052 interest.setMustBeFresh(true);
Alexander Afanasyevf6468892014-01-29 01:04:14 -080053
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070054 m_face.expressInterest(interest,
55 bind(&ConsumerWithTimer::onData, this, _1, _2),
Weiwei Liuab9aad02016-10-09 13:56:04 -070056 bind(&ConsumerWithTimer::onNack, this, _1, _2),
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070057 bind(&ConsumerWithTimer::onTimeout, this, _1));
Alexander Afanasyev151a8552014-04-11 00:54:43 -070058
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070059 std::cout << "Sending " << interest << std::endl;
Alexander Afanasyev151a8552014-04-11 00:54:43 -070060
61 // Schedule a new event
Davide Pesavento0f830802018-01-16 23:58:58 -050062 m_scheduler.scheduleEvent(3_s, [this] { delayedInterest(); });
Alexander Afanasyev151a8552014-04-11 00:54:43 -070063
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070064 // m_ioService.run() will block until all events finished or m_ioService.stop() is called
65 m_ioService.run();
Alexander Afanasyev151a8552014-04-11 00:54:43 -070066
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070067 // Alternatively, m_face.processEvents() can also be called.
68 // processEvents will block until the requested data received or timeout occurs.
69 // m_face.processEvents();
Alexander Afanasyevf6468892014-01-29 01:04:14 -080070 }
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070071
72private:
73 void
74 onData(const Interest& interest, const Data& data)
75 {
76 std::cout << data << std::endl;
Alexander Afanasyevf6468892014-01-29 01:04:14 -080077 }
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070078
79 void
Weiwei Liuab9aad02016-10-09 13:56:04 -070080 onNack(const Interest& interest, const lp::Nack& nack)
81 {
82 std::cout << "received Nack with reason " << nack.getReason()
83 << " for interest " << interest << std::endl;
84 }
85
86 void
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070087 onTimeout(const Interest& interest)
88 {
89 std::cout << "Timeout " << interest << std::endl;
90 }
91
92 void
93 delayedInterest()
94 {
95 std::cout << "One more Interest, delayed by the scheduler" << std::endl;
96
97 Interest interest(Name("/example/testApp/randomData"));
Davide Pesavento0f830802018-01-16 23:58:58 -050098 interest.setInterestLifetime(2_s); // 2 seconds
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070099 interest.setMustBeFresh(true);
100
101 m_face.expressInterest(interest,
102 bind(&ConsumerWithTimer::onData, this, _1, _2),
Weiwei Liuab9aad02016-10-09 13:56:04 -0700103 bind(&ConsumerWithTimer::onNack, this, _1, _2),
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -0700104 bind(&ConsumerWithTimer::onTimeout, this, _1));
105
106 std::cout << "Sending " << interest << std::endl;
107 }
108
109private:
110 // Explicitly create io_service object, which can be shared between Face and Scheduler
111 boost::asio::io_service m_ioService;
112 Face m_face;
113 Scheduler m_scheduler;
114};
115
Alexander Afanasyev151a8552014-04-11 00:54:43 -0700116} // namespace examples
117} // namespace ndn
118
119int
120main(int argc, char** argv)
121{
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -0700122 ndn::examples::ConsumerWithTimer consumer;
123 try {
124 consumer.run();
125 }
126 catch (const std::exception& e) {
127 std::cerr << "ERROR: " << e.what() << std::endl;
128 }
129 return 0;
Alexander Afanasyev151a8552014-04-11 00:54:43 -0700130}