blob: b095d4c6869a46d3ed7c4bcc3e3d676d3b4b7f94 [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
Davide Pesavento19442812018-11-23 14:00:04 -050024#include <ndn-cxx/face.hpp>
25#include <ndn-cxx/util/scheduler.hpp>
Alexander Afanasyevf6468892014-01-29 01:04:14 -080026
Davide Pesavento4d0d0962017-12-19 22:23:14 -050027#include <boost/asio/io_service.hpp>
Davide Pesaventocdcde902017-08-23 15:40:22 -040028#include <iostream>
29
Alexander Afanasyev151a8552014-04-11 00:54:43 -070030// Enclosing code in ndn simplifies coding (can also use `using namespace ndn`)
31namespace ndn {
Davide Pesaventocdcde902017-08-23 15:40:22 -040032// Additional nested namespaces can be used to prevent/limit name conflicts
Alexander Afanasyev151a8552014-04-11 00:54:43 -070033namespace examples {
34
Davide Pesavento4d0d0962017-12-19 22:23:14 -050035class ConsumerWithTimer
Alexander Afanasyevf6468892014-01-29 01:04:14 -080036{
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070037public:
38 ConsumerWithTimer()
39 : m_face(m_ioService) // Create face with io_service object
40 , m_scheduler(m_ioService)
41 {
42 }
Alexander Afanasyevf6468892014-01-29 01:04:14 -080043
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070044 void
45 run()
46 {
47 Interest interest(Name("/example/testApp/randomData"));
Davide Pesavento0f830802018-01-16 23:58:58 -050048 interest.setInterestLifetime(2_s); // 2 seconds
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070049 interest.setMustBeFresh(true);
Alexander Afanasyevf6468892014-01-29 01:04:14 -080050
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070051 m_face.expressInterest(interest,
52 bind(&ConsumerWithTimer::onData, this, _1, _2),
Weiwei Liuab9aad02016-10-09 13:56:04 -070053 bind(&ConsumerWithTimer::onNack, this, _1, _2),
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070054 bind(&ConsumerWithTimer::onTimeout, this, _1));
Alexander Afanasyev151a8552014-04-11 00:54:43 -070055
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070056 std::cout << "Sending " << interest << std::endl;
Alexander Afanasyev151a8552014-04-11 00:54:43 -070057
58 // Schedule a new event
Davide Pesavento0f830802018-01-16 23:58:58 -050059 m_scheduler.scheduleEvent(3_s, [this] { delayedInterest(); });
Alexander Afanasyev151a8552014-04-11 00:54:43 -070060
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070061 // m_ioService.run() will block until all events finished or m_ioService.stop() is called
62 m_ioService.run();
Alexander Afanasyev151a8552014-04-11 00:54:43 -070063
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070064 // Alternatively, m_face.processEvents() can also be called.
65 // processEvents will block until the requested data received or timeout occurs.
66 // m_face.processEvents();
Alexander Afanasyevf6468892014-01-29 01:04:14 -080067 }
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070068
69private:
70 void
71 onData(const Interest& interest, const Data& data)
72 {
73 std::cout << data << std::endl;
Alexander Afanasyevf6468892014-01-29 01:04:14 -080074 }
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070075
76 void
Weiwei Liuab9aad02016-10-09 13:56:04 -070077 onNack(const Interest& interest, const lp::Nack& nack)
78 {
79 std::cout << "received Nack with reason " << nack.getReason()
80 << " for interest " << interest << std::endl;
81 }
82
83 void
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070084 onTimeout(const Interest& interest)
85 {
86 std::cout << "Timeout " << interest << std::endl;
87 }
88
89 void
90 delayedInterest()
91 {
92 std::cout << "One more Interest, delayed by the scheduler" << std::endl;
93
94 Interest interest(Name("/example/testApp/randomData"));
Davide Pesavento0f830802018-01-16 23:58:58 -050095 interest.setInterestLifetime(2_s); // 2 seconds
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -070096 interest.setMustBeFresh(true);
97
98 m_face.expressInterest(interest,
99 bind(&ConsumerWithTimer::onData, this, _1, _2),
Weiwei Liuab9aad02016-10-09 13:56:04 -0700100 bind(&ConsumerWithTimer::onNack, this, _1, _2),
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -0700101 bind(&ConsumerWithTimer::onTimeout, this, _1));
102
103 std::cout << "Sending " << interest << std::endl;
104 }
105
106private:
107 // Explicitly create io_service object, which can be shared between Face and Scheduler
108 boost::asio::io_service m_ioService;
109 Face m_face;
110 Scheduler m_scheduler;
111};
112
Alexander Afanasyev151a8552014-04-11 00:54:43 -0700113} // namespace examples
114} // namespace ndn
115
116int
117main(int argc, char** argv)
118{
Steve DiBenedetto9fcc24f2015-01-05 12:16:16 -0700119 ndn::examples::ConsumerWithTimer consumer;
120 try {
121 consumer.run();
122 }
123 catch (const std::exception& e) {
124 std::cerr << "ERROR: " << e.what() << std::endl;
125 }
126 return 0;
Alexander Afanasyev151a8552014-04-11 00:54:43 -0700127}