blob: ecf63425068d6d122bbc9155228894a1bb5e7e4c [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/*
Junxiao Shia5f233e2019-03-18 09:39:22 -06003 * Copyright (c) 2013-2019 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"
26#include "tests/integrated/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 {
32namespace util {
33namespace scheduler {
34namespace tests {
35
Junxiao Shi770f9042017-07-13 13:30:53 +000036using namespace ndn::tests;
37
Junxiao Shi9f764b52016-08-10 02:59:48 +000038BOOST_AUTO_TEST_CASE(ScheduleCancel)
39{
40 boost::asio::io_service io;
41 Scheduler sched(io);
42
Davide Pesaventobdcedf42017-10-15 14:56:28 -040043 const size_t nEvents = 1000000;
Junxiao Shi9f764b52016-08-10 02:59:48 +000044 std::vector<EventId> eventIds(nEvents);
45
Junxiao Shi770f9042017-07-13 13:30:53 +000046 auto d1 = timedExecute([&] {
Davide Pesaventobdcedf42017-10-15 14:56:28 -040047 for (size_t i = 0; i < nEvents; ++i) {
Junxiao Shia5f233e2019-03-18 09:39:22 -060048 eventIds[i] = sched.schedule(1_s, []{});
Junxiao Shi770f9042017-07-13 13:30:53 +000049 }
50 });
Junxiao Shi9f764b52016-08-10 02:59:48 +000051
Junxiao Shi770f9042017-07-13 13:30:53 +000052 auto d2 = timedExecute([&] {
Davide Pesaventobdcedf42017-10-15 14:56:28 -040053 for (size_t i = 0; i < nEvents; ++i) {
Junxiao Shia5f233e2019-03-18 09:39:22 -060054 eventIds[i].cancel();
Junxiao Shi770f9042017-07-13 13:30:53 +000055 }
56 });
57
58 std::cout << "schedule " << nEvents << " events: " << d1 << std::endl;
59 std::cout << "cancel " << nEvents << " events: " << d2 << std::endl;
Junxiao Shi9f764b52016-08-10 02:59:48 +000060}
61
62BOOST_AUTO_TEST_CASE(Execute)
63{
64 boost::asio::io_service io;
65 Scheduler sched(io);
66
Davide Pesaventobdcedf42017-10-15 14:56:28 -040067 const size_t nEvents = 1000000;
68 size_t nExpired = 0;
Junxiao Shi9f764b52016-08-10 02:59:48 +000069
70 // Events should expire at t1, but execution finishes at t2. The difference is the overhead.
Davide Pesavento0f830802018-01-16 23:58:58 -050071 time::steady_clock::TimePoint t1 = time::steady_clock::now() + 5_s;
Junxiao Shi9f764b52016-08-10 02:59:48 +000072 time::steady_clock::TimePoint t2;
73 // +1ms ensures this extra event is executed last. In case the overhead is less than 1ms,
74 // it will be reported as 1ms.
Junxiao Shia5f233e2019-03-18 09:39:22 -060075 sched.schedule(t1 - time::steady_clock::now() + 1_ms, [&] {
Junxiao Shi9f764b52016-08-10 02:59:48 +000076 t2 = time::steady_clock::now();
77 BOOST_REQUIRE_EQUAL(nExpired, nEvents);
78 });
79
Davide Pesaventobdcedf42017-10-15 14:56:28 -040080 for (size_t i = 0; i < nEvents; ++i) {
Junxiao Shia5f233e2019-03-18 09:39:22 -060081 sched.schedule(t1 - time::steady_clock::now(), [&] { ++nExpired; });
Junxiao Shi9f764b52016-08-10 02:59:48 +000082 }
83
84 io.run();
85
86 BOOST_REQUIRE_EQUAL(nExpired, nEvents);
Junxiao Shi770f9042017-07-13 13:30:53 +000087 std::cout << "execute " << nEvents << " events: " << (t2 - t1) << std::endl;
Junxiao Shi9f764b52016-08-10 02:59:48 +000088}
89
90} // namespace tests
91} // namespace scheduler
92} // namespace util
93} // namespace ndn