blob: 8897920b3527476ee2842fb27a741cb903008a0d [file] [log] [blame]
Junxiao Shi9f764b52016-08-10 02:59:48 +00001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
Junxiao Shi770f9042017-07-13 13:30:53 +00002/*
Davide Pesavento394977c2020-04-25 21:40:31 -04003 * Copyright (c) 2013-2020 Regents of the University of California.
Junxiao Shi9f764b52016-08-10 02:59:48 +00004 *
5 * This file is part of ndn-cxx library (NDN C++ library with eXperimental eXtensions).
6 *
7 * 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.
20 */
21
Davide Pesaventoeee3e822016-11-26 19:19:34 +010022#define BOOST_TEST_MODULE ndn-cxx Scheduler Benchmark
Davide Pesavento7e780642018-11-24 15:51:34 -050023#include "tests/boost-test.hpp"
Junxiao Shi9f764b52016-08-10 02:59:48 +000024
Davide Pesavento7e780642018-11-24 15:51:34 -050025#include "ndn-cxx/util/scheduler.hpp"
Davide Pesavento394977c2020-04-25 21:40:31 -040026#include "tests/benchmarks/timed-execute.hpp"
Junxiao Shi9f764b52016-08-10 02:59:48 +000027
Davide Pesaventobdcedf42017-10-15 14:56:28 -040028#include <boost/asio/io_service.hpp>
Davide Pesaventocdcde902017-08-23 15:40:22 -040029#include <iostream>
30
Junxiao Shi9f764b52016-08-10 02:59:48 +000031namespace ndn {
Junxiao Shi9f764b52016-08-10 02:59:48 +000032namespace scheduler {
33namespace tests {
34
Junxiao Shi770f9042017-07-13 13:30:53 +000035using namespace ndn::tests;
36
Junxiao Shi9f764b52016-08-10 02:59:48 +000037BOOST_AUTO_TEST_CASE(ScheduleCancel)
38{
39 boost::asio::io_service io;
40 Scheduler sched(io);
41
Davide Pesaventobdcedf42017-10-15 14:56:28 -040042 const size_t nEvents = 1000000;
Junxiao Shi9f764b52016-08-10 02:59:48 +000043 std::vector<EventId> eventIds(nEvents);
44
Junxiao Shi770f9042017-07-13 13:30:53 +000045 auto d1 = timedExecute([&] {
Davide Pesaventobdcedf42017-10-15 14:56:28 -040046 for (size_t i = 0; i < nEvents; ++i) {
Junxiao Shia5f233e2019-03-18 09:39:22 -060047 eventIds[i] = sched.schedule(1_s, []{});
Junxiao Shi770f9042017-07-13 13:30:53 +000048 }
49 });
Junxiao Shi9f764b52016-08-10 02:59:48 +000050
Junxiao Shi770f9042017-07-13 13:30:53 +000051 auto d2 = timedExecute([&] {
Davide Pesaventobdcedf42017-10-15 14:56:28 -040052 for (size_t i = 0; i < nEvents; ++i) {
Junxiao Shia5f233e2019-03-18 09:39:22 -060053 eventIds[i].cancel();
Junxiao Shi770f9042017-07-13 13:30:53 +000054 }
55 });
56
57 std::cout << "schedule " << nEvents << " events: " << d1 << std::endl;
58 std::cout << "cancel " << nEvents << " events: " << d2 << std::endl;
Junxiao Shi9f764b52016-08-10 02:59:48 +000059}
60
61BOOST_AUTO_TEST_CASE(Execute)
62{
63 boost::asio::io_service io;
64 Scheduler sched(io);
65
Davide Pesaventobdcedf42017-10-15 14:56:28 -040066 const size_t nEvents = 1000000;
67 size_t nExpired = 0;
Junxiao Shi9f764b52016-08-10 02:59:48 +000068
69 // Events should expire at t1, but execution finishes at t2. The difference is the overhead.
Davide Pesavento0f830802018-01-16 23:58:58 -050070 time::steady_clock::TimePoint t1 = time::steady_clock::now() + 5_s;
Junxiao Shi9f764b52016-08-10 02:59:48 +000071 time::steady_clock::TimePoint t2;
72 // +1ms ensures this extra event is executed last. In case the overhead is less than 1ms,
73 // it will be reported as 1ms.
Junxiao Shia5f233e2019-03-18 09:39:22 -060074 sched.schedule(t1 - time::steady_clock::now() + 1_ms, [&] {
Junxiao Shi9f764b52016-08-10 02:59:48 +000075 t2 = time::steady_clock::now();
76 BOOST_REQUIRE_EQUAL(nExpired, nEvents);
77 });
78
Davide Pesaventobdcedf42017-10-15 14:56:28 -040079 for (size_t i = 0; i < nEvents; ++i) {
Junxiao Shia5f233e2019-03-18 09:39:22 -060080 sched.schedule(t1 - time::steady_clock::now(), [&] { ++nExpired; });
Junxiao Shi9f764b52016-08-10 02:59:48 +000081 }
82
83 io.run();
84
85 BOOST_REQUIRE_EQUAL(nExpired, nEvents);
Junxiao Shi770f9042017-07-13 13:30:53 +000086 std::cout << "execute " << nEvents << " events: " << (t2 - t1) << std::endl;
Junxiao Shi9f764b52016-08-10 02:59:48 +000087}
88
89} // namespace tests
90} // namespace scheduler
Junxiao Shi9f764b52016-08-10 02:59:48 +000091} // namespace ndn