tests+tools: minor code cleanup
Change-Id: Ic3356d4a18a8e5eeb45fc076fc0563c3d1549c8a
diff --git a/tests/daemon/face/datagram-transport.t.cpp b/tests/daemon/face/datagram-transport.t.cpp
index d5ce2a8..fd1a8e0 100644
--- a/tests/daemon/face/datagram-transport.t.cpp
+++ b/tests/daemon/face/datagram-transport.t.cpp
@@ -1,6 +1,6 @@
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
- * Copyright (c) 2014-2018, Regents of the University of California,
+ * Copyright (c) 2014-2019, Regents of the University of California,
* Arizona Board of Regents,
* Colorado State University,
* University Pierre & Marie Curie, Sorbonne University,
@@ -149,7 +149,7 @@
this->limitedIo.afterOp();
});
- BOOST_REQUIRE_EQUAL(this->limitedIo.run(1, time::seconds(1)), LimitedIo::EXCEED_OPS);
+ BOOST_REQUIRE_EQUAL(this->limitedIo.run(1, 1_s), LimitedIo::EXCEED_OPS);
}
BOOST_FIXTURE_TEST_CASE_TEMPLATE(SendQueueLength, T, DatagramTransportFixtures, T)
diff --git a/tests/daemon/face/ethernet-channel.t.cpp b/tests/daemon/face/ethernet-channel.t.cpp
index d7a1cec..c1311da 100644
--- a/tests/daemon/face/ethernet-channel.t.cpp
+++ b/tests/daemon/face/ethernet-channel.t.cpp
@@ -39,7 +39,7 @@
makeChannel()
{
BOOST_ASSERT(netifs.size() > 0);
- return make_unique<EthernetChannel>(netifs.front(), time::seconds(2));
+ return make_unique<EthernetChannel>(netifs.front(), 2_s);
}
};
diff --git a/tests/daemon/face/ethernet-factory.t.cpp b/tests/daemon/face/ethernet-factory.t.cpp
index b69141d..e204cee 100644
--- a/tests/daemon/face/ethernet-factory.t.cpp
+++ b/tests/daemon/face/ethernet-factory.t.cpp
@@ -1,6 +1,6 @@
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
- * Copyright (c) 2014-2018, Regents of the University of California,
+ * Copyright (c) 2014-2019, Regents of the University of California,
* Arizona Board of Regents,
* Colorado State University,
* University Pierre & Marie Curie, Sorbonne University,
@@ -436,7 +436,7 @@
BOOST_CHECK_EQUAL(factory.getChannels().empty(), true);
SKIP_IF_ETHERNET_NETIF_COUNT_LT(1);
- factory.createChannel(netifs.front(), time::minutes(1));
+ factory.createChannel(netifs.front(), 1_min);
checkChannelListEqual(factory, {FaceUri::fromDev(netifs.front()->getName()).toString()});
}
@@ -444,14 +444,14 @@
{
SKIP_IF_ETHERNET_NETIF_COUNT_LT(1);
- auto channel1 = factory.createChannel(netifs.front(), time::minutes(1));
- auto channel1a = factory.createChannel(netifs.front(), time::minutes(5));
+ auto channel1 = factory.createChannel(netifs.front(), 1_min);
+ auto channel1a = factory.createChannel(netifs.front(), 5_min);
BOOST_CHECK_EQUAL(channel1, channel1a);
BOOST_CHECK_EQUAL(channel1->getUri().toString(), "dev://" + netifs.front()->getName());
SKIP_IF_ETHERNET_NETIF_COUNT_LT(2);
- auto channel2 = factory.createChannel(netifs.back(), time::minutes(1));
+ auto channel2 = factory.createChannel(netifs.back(), 1_min);
BOOST_CHECK_NE(channel1, channel2);
}
@@ -464,7 +464,7 @@
{CreateFaceExpectedResult::FAILURE, 504, "No channels available to connect"});
SKIP_IF_ETHERNET_NETIF_COUNT_LT(1);
- auto localUri = factory.createChannel(netifs.front(), time::minutes(1))->getUri();
+ auto localUri = factory.createChannel(netifs.front(), 1_min)->getUri();
createFace(factory,
FaceUri("ether://[00:00:5e:00:53:5e]"),
diff --git a/tests/daemon/face/ethernet-fixture.hpp b/tests/daemon/face/ethernet-fixture.hpp
index 5a8160e..1898d50 100644
--- a/tests/daemon/face/ethernet-fixture.hpp
+++ b/tests/daemon/face/ethernet-fixture.hpp
@@ -71,7 +71,7 @@
BOOST_ASSERT(netif != nullptr);
localEp = netif->getName();
remoteEp = remoteAddr;
- transport = make_unique<UnicastEthernetTransport>(*netif, remoteEp, persistency, time::seconds(2));
+ transport = make_unique<UnicastEthernetTransport>(*netif, remoteEp, persistency, 2_s);
}
/** \brief create a MulticastEthernetTransport
diff --git a/tests/daemon/face/generic-link-service.t.cpp b/tests/daemon/face/generic-link-service.t.cpp
index d10dba5..cf51e54 100644
--- a/tests/daemon/face/generic-link-service.t.cpp
+++ b/tests/daemon/face/generic-link-service.t.cpp
@@ -485,7 +485,7 @@
{
GenericLinkService::Options options;
options.allowCongestionMarking = true;
- options.baseCongestionMarkingInterval = time::milliseconds(100);
+ options.baseCongestionMarkingInterval = 100_ms;
initialize(options, MTU_UNLIMITED, 65536);
BOOST_CHECK_EQUAL(service->m_nextMarkTime, time::steady_clock::TimePoint::max());
BOOST_CHECK_EQUAL(service->m_nMarkedSinceInMarkingState, 0);
@@ -522,7 +522,7 @@
{
GenericLinkService::Options options;
options.allowCongestionMarking = true;
- options.baseCongestionMarkingInterval = time::milliseconds(100);
+ options.baseCongestionMarkingInterval = 100_ms;
initialize(options, MTU_UNLIMITED, 65536);
BOOST_CHECK_EQUAL(service->m_nextMarkTime, time::steady_clock::TimePoint::max());
BOOST_CHECK_EQUAL(service->m_lastMarkTime, time::steady_clock::TimePoint::min());
@@ -541,7 +541,7 @@
BOOST_REQUIRE_NO_THROW(pkt1.wireDecode(transport->sentPackets.back().packet));
BOOST_REQUIRE_EQUAL(pkt1.count<lp::CongestionMarkField>(), 1);
BOOST_CHECK_EQUAL(pkt1.get<lp::CongestionMarkField>(), 1);
- time::steady_clock::TimePoint nextMarkTime = time::steady_clock::now() + time::milliseconds(100);
+ time::steady_clock::TimePoint nextMarkTime = time::steady_clock::now() + 100_ms;
BOOST_CHECK_EQUAL(service->m_nextMarkTime, nextMarkTime);
time::steady_clock::TimePoint lastMarkTime = time::steady_clock::now();
BOOST_CHECK_EQUAL(service->m_lastMarkTime, lastMarkTime);
@@ -549,7 +549,7 @@
BOOST_CHECK_EQUAL(service->getCounters().nCongestionMarked, 1);
// advance clock to half of marking interval cycle
- advanceClocks(time::milliseconds(50));
+ advanceClocks(50_ms);
// second congested packet, but within marking interval, will not be marked
transport->setSendQueueLength(33000);
@@ -564,7 +564,7 @@
BOOST_CHECK_EQUAL(service->getCounters().nCongestionMarked, 1);
// advance clocks past end of initial interval cycle
- this->advanceClocks(time::milliseconds(51));
+ this->advanceClocks(51_ms);
// first congested packet after waiting marking interval, will be marked
transport->setSendQueueLength(40000);
@@ -585,7 +585,7 @@
BOOST_CHECK_EQUAL(service->getCounters().nCongestionMarked, 2);
// advance clock partway through current marking interval
- this->advanceClocks(markingInterval - time::milliseconds(10));
+ this->advanceClocks(markingInterval - 10_ms);
// still congested, but within marking interval cycle
transport->setSendQueueLength(38000);
@@ -600,7 +600,7 @@
BOOST_CHECK_EQUAL(service->getCounters().nCongestionMarked, 2);
// advance clocks past end of current marking interval cycle
- this->advanceClocks(time::milliseconds(11));
+ this->advanceClocks(11_ms);
// still congested, after marking interval cycle
transport->setSendQueueLength(39000);
@@ -620,7 +620,7 @@
BOOST_CHECK_EQUAL(service->m_nMarkedSinceInMarkingState, 3);
BOOST_CHECK_EQUAL(service->getCounters().nCongestionMarked, 3);
- this->advanceClocks(time::milliseconds(1));
+ this->advanceClocks(1_ms);
// still congested, but within marking interval cycle
transport->setSendQueueLength(38000);
@@ -666,7 +666,7 @@
BOOST_CHECK_EQUAL(service->m_nMarkedSinceInMarkingState, 0);
BOOST_CHECK_EQUAL(service->getCounters().nCongestionMarked, 4);
- this->advanceClocks(time::milliseconds(50));
+ this->advanceClocks(50_ms);
// send queue congested again, but can't mark packet because within one full interval of last mark
transport->setSendQueueLength(50000);
@@ -681,7 +681,7 @@
BOOST_CHECK_EQUAL(service->getCounters().nCongestionMarked, 4);
// advance clock past full 100ms interval since last mark
- this->advanceClocks(time::milliseconds(51));
+ this->advanceClocks(51_ms);
transport->setSendQueueLength(40000);
face->sendInterest(*interest);
@@ -690,7 +690,7 @@
BOOST_REQUIRE_NO_THROW(pkt10.wireDecode(transport->sentPackets.back().packet));
BOOST_REQUIRE_EQUAL(pkt10.count<lp::CongestionMarkField>(), 1);
BOOST_CHECK_EQUAL(pkt10.get<lp::CongestionMarkField>(), 1);
- nextMarkTime = time::steady_clock::now() + time::milliseconds(100);
+ nextMarkTime = time::steady_clock::now() + 100_ms;
BOOST_CHECK_EQUAL(service->m_nextMarkTime, nextMarkTime);
lastMarkTime = time::steady_clock::now();
BOOST_CHECK_EQUAL(service->m_lastMarkTime, lastMarkTime);
@@ -698,7 +698,7 @@
BOOST_CHECK_EQUAL(service->getCounters().nCongestionMarked, 5);
// advance clock partway through 100ms marking interval
- this->advanceClocks(time::milliseconds(50));
+ this->advanceClocks(50_ms);
// not marked since within 100ms window before can mark again
transport->setSendQueueLength(50000);
@@ -713,7 +713,7 @@
BOOST_CHECK_EQUAL(service->getCounters().nCongestionMarked, 5);
// advance clocks past m_nextMarkTime
- this->advanceClocks(time::milliseconds(51));
+ this->advanceClocks(51_ms);
// markable packet, queue length still above threshold
transport->setSendQueueLength(33000);
@@ -746,7 +746,7 @@
BOOST_CHECK_EQUAL(service->getCounters().nCongestionMarked, 6);
// advance clocks past one full interval since last mark
- this->advanceClocks(time::milliseconds(101));
+ this->advanceClocks(101_ms);
// start congestion again
transport->setSendQueueLength(50000);
@@ -756,7 +756,7 @@
BOOST_REQUIRE_NO_THROW(pkt14.wireDecode(transport->sentPackets.back().packet));
BOOST_REQUIRE_EQUAL(pkt14.count<lp::CongestionMarkField>(), 1);
BOOST_CHECK_EQUAL(pkt14.get<lp::CongestionMarkField>(), 1);
- nextMarkTime = time::steady_clock::now() + time::milliseconds(100);
+ nextMarkTime = time::steady_clock::now() + 100_ms;
BOOST_CHECK_EQUAL(service->m_nextMarkTime, nextMarkTime);
lastMarkTime = time::steady_clock::now();
BOOST_CHECK_EQUAL(service->m_lastMarkTime, lastMarkTime);
@@ -780,7 +780,7 @@
{
GenericLinkService::Options options;
options.allowCongestionMarking = true;
- options.baseCongestionMarkingInterval = time::milliseconds(100);
+ options.baseCongestionMarkingInterval = 100_ms;
initialize(options, MTU_UNLIMITED, QUEUE_UNSUPPORTED);
BOOST_CHECK_EQUAL(service->m_nextMarkTime, time::steady_clock::TimePoint::max());
BOOST_CHECK_EQUAL(service->m_nMarkedSinceInMarkingState, 0);
@@ -821,7 +821,7 @@
BOOST_REQUIRE_NO_THROW(pkt3.wireDecode(transport->sentPackets.back().packet));
BOOST_REQUIRE_EQUAL(pkt3.count<lp::CongestionMarkField>(), 1);
BOOST_CHECK_EQUAL(pkt3.get<lp::CongestionMarkField>(), 1);
- time::steady_clock::TimePoint nextMarkTime = time::steady_clock::now() + time::milliseconds(100);
+ time::steady_clock::TimePoint nextMarkTime = time::steady_clock::now() + 100_ms;
BOOST_CHECK_EQUAL(service->m_nextMarkTime, nextMarkTime);
BOOST_CHECK_EQUAL(service->m_nMarkedSinceInMarkingState, 1);
BOOST_CHECK_EQUAL(service->getCounters().nCongestionMarked, 1);
diff --git a/tests/daemon/face/internal-face.t.cpp b/tests/daemon/face/internal-face.t.cpp
index 4c1618b..9ea6903 100644
--- a/tests/daemon/face/internal-face.t.cpp
+++ b/tests/daemon/face/internal-face.t.cpp
@@ -83,19 +83,19 @@
BOOST_AUTO_TEST_CASE(ReceiveInterestTimeout)
{
shared_ptr<Interest> interest = makeInterest("/TLETccRv");
- interest->setInterestLifetime(time::milliseconds(100));
+ interest->setInterestLifetime(100_ms);
bool hasTimeout = false;
clientFace->expressInterest(*interest,
bind([] { BOOST_ERROR("unexpected Data"); }),
bind([] { BOOST_ERROR("unexpected Nack"); }),
bind([&hasTimeout] { hasTimeout = true; }));
- this->advanceClocks(time::milliseconds(1), 10);
+ this->advanceClocks(1_ms, 10);
BOOST_REQUIRE_EQUAL(receivedInterests.size(), 1);
BOOST_CHECK_EQUAL(receivedInterests.back().getName(), "/TLETccRv");
- this->advanceClocks(time::milliseconds(1), 100);
+ this->advanceClocks(1_ms, 100);
BOOST_CHECK(hasTimeout);
}
@@ -112,14 +112,14 @@
},
bind([] { BOOST_ERROR("unexpected Nack"); }),
bind([] { BOOST_ERROR("unexpected timeout"); }));
- this->advanceClocks(time::milliseconds(1), 10);
+ this->advanceClocks(1_ms, 10);
BOOST_REQUIRE_EQUAL(receivedInterests.size(), 1);
BOOST_CHECK_EQUAL(receivedInterests.back().getName(), "/PQstEJGdL");
shared_ptr<Data> data = makeData("/PQstEJGdL/aI7oCrDXNX");
forwarderFace->sendData(*data);
- this->advanceClocks(time::milliseconds(1), 10);
+ this->advanceClocks(1_ms, 10);
BOOST_CHECK(hasReceivedData);
}
@@ -136,14 +136,14 @@
BOOST_CHECK_EQUAL(nack.getReason(), lp::NackReason::NO_ROUTE);
},
bind([] { BOOST_ERROR("unexpected timeout"); }));
- this->advanceClocks(time::milliseconds(1), 10);
+ this->advanceClocks(1_ms, 10);
BOOST_REQUIRE_EQUAL(receivedInterests.size(), 1);
BOOST_CHECK_EQUAL(receivedInterests.back().getName(), "/1HrsRM1X");
lp::Nack nack = makeNack("/1HrsRM1X", 152, lp::NackReason::NO_ROUTE);
forwarderFace->sendNack(nack);
- this->advanceClocks(time::milliseconds(1), 10);
+ this->advanceClocks(1_ms, 10);
BOOST_CHECK(hasReceivedNack);
}
@@ -162,7 +162,7 @@
shared_ptr<Interest> interest = makeInterest("/Wpc8TnEeoF/f6SzV8hD");
forwarderFace->sendInterest(*interest);
- this->advanceClocks(time::milliseconds(1), 10);
+ this->advanceClocks(1_ms, 10);
BOOST_CHECK(hasDeliveredInterest);
BOOST_REQUIRE_EQUAL(receivedData.size(), 1);
@@ -183,7 +183,7 @@
shared_ptr<Interest> interest = makeInterest("/4YgJKWcXN/5oaTe05o", 191);
forwarderFace->sendInterest(*interest);
- this->advanceClocks(time::milliseconds(1), 10);
+ this->advanceClocks(1_ms, 10);
BOOST_CHECK(hasDeliveredInterest);
BOOST_REQUIRE_EQUAL(receivedNacks.size(), 1);
@@ -193,19 +193,19 @@
BOOST_AUTO_TEST_CASE(CloseForwarderFace)
{
forwarderFace->close();
- this->advanceClocks(time::milliseconds(1), 10);
+ this->advanceClocks(1_ms, 10);
BOOST_CHECK_EQUAL(forwarderFace->getState(), FaceState::CLOSED);
forwarderFace.reset();
shared_ptr<Interest> interest = makeInterest("/zpHsVesu0B");
- interest->setInterestLifetime(time::milliseconds(100));
+ interest->setInterestLifetime(100_ms);
bool hasTimeout = false;
clientFace->expressInterest(*interest,
bind([] { BOOST_ERROR("unexpected Data"); }),
bind([] { BOOST_ERROR("unexpected Nack"); }),
bind([&hasTimeout] { hasTimeout = true; }));
- BOOST_CHECK_NO_THROW(this->advanceClocks(time::milliseconds(1), 200));
+ BOOST_CHECK_NO_THROW(this->advanceClocks(1_ms, 200));
BOOST_CHECK_EQUAL(receivedInterests.size(), 0);
BOOST_CHECK(hasTimeout);
@@ -218,7 +218,7 @@
shared_ptr<Interest> interest = makeInterest("/aau42XQqb");
forwarderFace->sendInterest(*interest);
- BOOST_CHECK_NO_THROW(this->advanceClocks(time::milliseconds(1), 10));
+ BOOST_CHECK_NO_THROW(this->advanceClocks(1_ms, 10));
}
BOOST_AUTO_TEST_SUITE_END() // TestInternalFace
diff --git a/tests/daemon/face/lp-reassembler.t.cpp b/tests/daemon/face/lp-reassembler.t.cpp
index f24eb98..8e8bbce 100644
--- a/tests/daemon/face/lp-reassembler.t.cpp
+++ b/tests/daemon/face/lp-reassembler.t.cpp
@@ -312,7 +312,7 @@
BOOST_CHECK_EQUAL(reassembler.size(), 1);
BOOST_CHECK(timeoutHistory.empty());
- advanceClocks(time::milliseconds(1), 600);
+ advanceClocks(1_ms, 600);
BOOST_CHECK_EQUAL(reassembler.size(), 0);
BOOST_REQUIRE_EQUAL(timeoutHistory.size(), 1);
BOOST_CHECK_EQUAL(std::get<0>(timeoutHistory.back()), REMOTE_EP);
@@ -357,7 +357,7 @@
std::tie(isComplete, std::ignore, std::ignore) = reassembler.receiveFragment(0, received3);
BOOST_REQUIRE(!isComplete);
- advanceClocks(time::milliseconds(1), 600);
+ advanceClocks(1_ms, 600);
std::tie(isComplete, std::ignore, std::ignore) = reassembler.receiveFragment(0, received2);
BOOST_REQUIRE(!isComplete);
diff --git a/tests/daemon/face/lp-reliability.t.cpp b/tests/daemon/face/lp-reliability.t.cpp
index 8ec1dd0..f995174 100644
--- a/tests/daemon/face/lp-reliability.t.cpp
+++ b/tests/daemon/face/lp-reliability.t.cpp
@@ -198,7 +198,7 @@
// T+500ms
// 1024 rto: 1000ms, txSeq: 2, started T+0ms, retx 0
- advanceClocks(time::milliseconds(1), 500);
+ advanceClocks(1_ms, 500);
linkService->sendLpPackets({pkt2});
BOOST_CHECK_EQUAL(transport->sentPackets.size(), 2);
@@ -221,7 +221,7 @@
// T+1250ms
// 1024 rto: 1000ms, txSeq: 4, started T+1000ms, retx 1
// 3000 rto: 1000ms, txSeq: 3, started T+500ms, retx 0
- advanceClocks(time::milliseconds(1), 750);
+ advanceClocks(1_ms, 750);
BOOST_CHECK_EQUAL(reliability->m_unackedFrags.size(), 2);
BOOST_CHECK_EQUAL(reliability->m_unackedFrags.count(firstTxSeq), 0);
@@ -239,7 +239,7 @@
// T+2250ms
// 1024 rto: 1000ms, txSeq: 6, started T+2000ms, retx 2
// 3000 rto: 1000ms, txSeq: 5, started T+1500ms, retx 1
- advanceClocks(time::milliseconds(1), 1000);
+ advanceClocks(1_ms, 1000);
BOOST_CHECK_EQUAL(reliability->m_unackedFrags.size(), 2);
BOOST_CHECK_EQUAL(reliability->m_unackedFrags.count(firstTxSeq + 1), 0);
@@ -258,7 +258,7 @@
// T+3250ms
// 1024 rto: 1000ms, txSeq: 8, started T+3000ms, retx 3
// 3000 rto: 1000ms, txSeq: 7, started T+2500ms, retx 2
- advanceClocks(time::milliseconds(1), 1000);
+ advanceClocks(1_ms, 1000);
BOOST_CHECK_EQUAL(reliability->m_unackedFrags.size(), 2);
BOOST_CHECK_EQUAL(reliability->m_unackedFrags.count(firstTxSeq + 3), 0);
@@ -277,7 +277,7 @@
// T+4250ms
// 1024 rto: expired, removed
// 3000 rto: 1000ms, txSeq: 9, started T+3500ms, retx 3
- advanceClocks(time::milliseconds(1), 1000);
+ advanceClocks(1_ms, 1000);
BOOST_CHECK_EQUAL(reliability->m_unackedFrags.size(), 1);
BOOST_CHECK_EQUAL(reliability->m_unackedFrags.count(firstTxSeq + 5), 0);
@@ -295,7 +295,7 @@
// T+4750ms
// 1024 rto: expired, removed
// 3000 rto: expired, removed
- advanceClocks(time::milliseconds(1), 1000);
+ advanceClocks(1_ms, 1000);
BOOST_CHECK_EQUAL(reliability->m_unackedFrags.size(), 0);
BOOST_CHECK_EQUAL(reliability->m_ackQueue.size(), 0);
@@ -367,7 +367,7 @@
// 2048 rto: 1000ms, txSeq: 2, started T+0ms, retx 0
// 2049 rto: 1000ms, txSeq: 5, started T+250ms, retx 1
// 2050 rto: 1000ms, txSeq: 4, started T+0ms, retx 0
- advanceClocks(time::milliseconds(1), 250);
+ advanceClocks(1_ms, 250);
reliability->onLpPacketLost(3);
BOOST_CHECK_EQUAL(reliability->m_unackedFrags.count(2), 1);
@@ -401,7 +401,7 @@
// 2048 rto: 1000ms, txSeq: 2, started T+0ms, retx 0
// 2049 rto: 1000ms, txSeq: 6, started T+500ms, retx 2
// 2050 rto: 1000ms, txSeq: 4, started T+0ms, retx 0
- advanceClocks(time::milliseconds(1), 250);
+ advanceClocks(1_ms, 250);
reliability->onLpPacketLost(5);
BOOST_CHECK_EQUAL(reliability->m_unackedFrags.count(2), 1);
@@ -435,7 +435,7 @@
// 2048 rto: 1000ms, txSeq: 2, started T+0ms, retx 0
// 2049 rto: 1000ms, txSeq: 7, started T+750ms, retx 3
// 2050 rto: 1000ms, txSeq: 4, started T+0ms, retx 0
- advanceClocks(time::milliseconds(1), 250);
+ advanceClocks(1_ms, 250);
reliability->onLpPacketLost(6);
BOOST_REQUIRE_EQUAL(reliability->m_unackedFrags.count(2), 1);
@@ -469,7 +469,7 @@
// 2048 rto: expired, removed
// 2049 rto: expired, removed
// 2050 rto: expired, removed
- advanceClocks(time::milliseconds(1), 100);
+ advanceClocks(1_ms, 100);
reliability->onLpPacketLost(7);
BOOST_CHECK_EQUAL(reliability->m_unackedFrags.size(), 0);
@@ -698,13 +698,13 @@
linkService->sendLpPackets({makeFrag(1, 50)});
- advanceClocks(time::milliseconds(1), 500);
+ advanceClocks(1_ms, 500);
lp::Packet ackPkt;
ackPkt.add<lp::AckField>(1);
reliability->processIncomingPacket(ackPkt);
- advanceClocks(time::milliseconds(1), 1000);
+ advanceClocks(1_ms, 1000);
BOOST_CHECK_EQUAL(linkService->getCounters().nAcknowledged, 1);
BOOST_CHECK_EQUAL(linkService->getCounters().nRetransmitted, 0);
@@ -737,7 +737,7 @@
BOOST_CHECK_EQUAL(reliability->m_ackQueue.back(), 234567);
// T+5ms
- advanceClocks(time::milliseconds(1), 5);
+ advanceClocks(1_ms, 5);
BOOST_CHECK(!reliability->m_isIdleAckTimerRunning);
}
@@ -827,7 +827,7 @@
BOOST_CHECK(reliability->m_isIdleAckTimerRunning);
// T+1ms
- advanceClocks(time::milliseconds(1), 1);
+ advanceClocks(1_ms, 1);
BOOST_CHECK(reliability->m_isIdleAckTimerRunning);
lp::Packet pkt2 = makeFrag(2, 100);
@@ -836,7 +836,7 @@
BOOST_CHECK(reliability->m_isIdleAckTimerRunning);
// T+5ms
- advanceClocks(time::milliseconds(1), 4);
+ advanceClocks(1_ms, 4);
BOOST_CHECK(!reliability->m_isIdleAckTimerRunning);
lp::Packet pkt3 = makeFrag(3, 100);
@@ -845,11 +845,11 @@
BOOST_CHECK(reliability->m_isIdleAckTimerRunning);
// T+9ms
- advanceClocks(time::milliseconds(1), 4);
+ advanceClocks(1_ms, 4);
BOOST_CHECK(reliability->m_isIdleAckTimerRunning);
// T+10ms
- advanceClocks(time::milliseconds(1), 1);
+ advanceClocks(1_ms, 1);
BOOST_CHECK(!reliability->m_isIdleAckTimerRunning);
}
@@ -866,7 +866,7 @@
BOOST_CHECK(reliability->m_isIdleAckTimerRunning);
// T+4ms: idle ack timer has not yet expired, no IDLE packet generated
- advanceClocks(time::milliseconds(1), 4);
+ advanceClocks(1_ms, 4);
BOOST_CHECK(reliability->m_isIdleAckTimerRunning);
BOOST_CHECK_EQUAL(reliability->m_ackQueue.size(), 500);
BOOST_CHECK_EQUAL(reliability->m_ackQueue.front(), 1000);
@@ -874,7 +874,7 @@
BOOST_CHECK_EQUAL(transport->sentPackets.size(), 0);
// T+5ms: idle ack timer expires, IDLE packet generated
- advanceClocks(time::milliseconds(1), 1);
+ advanceClocks(1_ms, 1);
BOOST_CHECK(!reliability->m_isIdleAckTimerRunning);
BOOST_CHECK_EQUAL(reliability->m_ackQueue.size(), 0);
BOOST_REQUIRE_EQUAL(transport->sentPackets.size(), 1);
@@ -902,7 +902,7 @@
BOOST_CHECK(reliability->m_isIdleAckTimerRunning);
// T+4ms: idle ack timer has not yet expired, no IDLE packet generated
- advanceClocks(time::milliseconds(1), 4);
+ advanceClocks(1_ms, 4);
BOOST_CHECK(reliability->m_isIdleAckTimerRunning);
BOOST_CHECK_EQUAL(reliability->m_ackQueue.size(), 500);
BOOST_CHECK_EQUAL(reliability->m_ackQueue.front(), 1000);
@@ -910,7 +910,7 @@
BOOST_CHECK_EQUAL(transport->sentPackets.size(), 0);
// T+5ms: idle ack timer expires, IDLE packets generated
- advanceClocks(time::milliseconds(1), 1);
+ advanceClocks(1_ms, 1);
BOOST_CHECK(!reliability->m_isIdleAckTimerRunning);
BOOST_CHECK_EQUAL(reliability->m_ackQueue.size(), 0);
diff --git a/tests/daemon/face/multicast-ethernet-transport.t.cpp b/tests/daemon/face/multicast-ethernet-transport.t.cpp
index 220274c..db248ac 100644
--- a/tests/daemon/face/multicast-ethernet-transport.t.cpp
+++ b/tests/daemon/face/multicast-ethernet-transport.t.cpp
@@ -107,7 +107,7 @@
limitedIo.afterOp();
});
- BOOST_REQUIRE_EQUAL(limitedIo.run(1, time::seconds(1)), LimitedIo::EXCEED_OPS);
+ BOOST_REQUIRE_EQUAL(limitedIo.run(1, 1_s), LimitedIo::EXCEED_OPS);
}
BOOST_AUTO_TEST_CASE(SendQueueLength)
diff --git a/tests/daemon/face/multicast-udp-transport-fixture.hpp b/tests/daemon/face/multicast-udp-transport-fixture.hpp
index 775b12d..626c37a 100644
--- a/tests/daemon/face/multicast-udp-transport-fixture.hpp
+++ b/tests/daemon/face/multicast-udp-transport-fixture.hpp
@@ -98,14 +98,14 @@
}
limitedIo.afterOp();
});
- BOOST_REQUIRE_EQUAL(limitedIo.run(1, time::seconds(1)), LimitedIo::EXCEED_OPS);
+ BOOST_REQUIRE_EQUAL(limitedIo.run(1, 1_s), LimitedIo::EXCEED_OPS);
}
void
remoteWrite(const std::vector<uint8_t>& buf, bool needToCheck = true)
{
sendToGroup(remoteSockTx, buf, needToCheck);
- limitedIo.defer(time::seconds(1));
+ limitedIo.defer(1_s);
}
void
diff --git a/tests/daemon/face/multicast-udp-transport.t.cpp b/tests/daemon/face/multicast-udp-transport.t.cpp
index d8e7a60..80d4c30 100644
--- a/tests/daemon/face/multicast-udp-transport.t.cpp
+++ b/tests/daemon/face/multicast-udp-transport.t.cpp
@@ -1,6 +1,6 @@
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
- * Copyright (c) 2014-2018, Regents of the University of California,
+ * Copyright (c) 2014-2019, Regents of the University of California,
* Arizona Board of Regents,
* Colorado State University,
* University Pierre & Marie Curie, Sorbonne University,
@@ -98,7 +98,7 @@
this->sendToGroup(remoteSockTx2, buf1);
this->sendToGroup(remoteSockTx2, buf2);
- this->limitedIo.defer(time::seconds(1));
+ this->limitedIo.defer(1_s);
BOOST_CHECK_EQUAL(this->transport->getCounters().nInPackets, 4);
BOOST_CHECK_EQUAL(this->transport->getCounters().nInBytes, 2 * buf1.size() + 2 * buf2.size());
diff --git a/tests/daemon/face/stream-transport.t.cpp b/tests/daemon/face/stream-transport.t.cpp
index 6628b92..de32a4d 100644
--- a/tests/daemon/face/stream-transport.t.cpp
+++ b/tests/daemon/face/stream-transport.t.cpp
@@ -1,6 +1,6 @@
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
- * Copyright (c) 2014-2018, Regents of the University of California,
+ * Copyright (c) 2014-2019, Regents of the University of California,
* Arizona Board of Regents,
* Colorado State University,
* University Pierre & Marie Curie, Sorbonne University,
@@ -63,7 +63,7 @@
this->limitedIo.afterOp();
});
- BOOST_REQUIRE_EQUAL(this->limitedIo.run(1, time::seconds(1)), LimitedIo::EXCEED_OPS);
+ BOOST_REQUIRE_EQUAL(this->limitedIo.run(1, 1_s), LimitedIo::EXCEED_OPS);
BOOST_CHECK_EQUAL_COLLECTIONS(readBuf.begin(), readBuf.begin() + block1.size(), block1.begin(), block1.end());
BOOST_CHECK_EQUAL_COLLECTIONS(readBuf.begin() + block1.size(), readBuf.end(), block2.begin(), block2.end());
@@ -189,7 +189,7 @@
this->limitedIo.afterOp();
});
- BOOST_REQUIRE_EQUAL(this->limitedIo.run(1, time::seconds(1)), LimitedIo::EXCEED_OPS);
+ BOOST_REQUIRE_EQUAL(this->limitedIo.run(1, 1_s), LimitedIo::EXCEED_OPS);
}
BOOST_FIXTURE_TEST_CASE_TEMPLATE(RemoteClose, T, StreamTransportFixtures, T)
@@ -203,7 +203,7 @@
});
this->remoteSocket.close();
- BOOST_REQUIRE_EQUAL(this->limitedIo.run(1, time::seconds(1)), LimitedIo::EXCEED_OPS);
+ BOOST_REQUIRE_EQUAL(this->limitedIo.run(1, 1_s), LimitedIo::EXCEED_OPS);
this->transport->afterStateChange.connectSingleShot([this] (TransportState oldState, TransportState newState) {
BOOST_CHECK_EQUAL(oldState, TransportState::CLOSING);
@@ -211,7 +211,7 @@
this->limitedIo.afterOp();
});
- BOOST_REQUIRE_EQUAL(this->limitedIo.run(1, time::seconds(1)), LimitedIo::EXCEED_OPS);
+ BOOST_REQUIRE_EQUAL(this->limitedIo.run(1, 1_s), LimitedIo::EXCEED_OPS);
}
BOOST_FIXTURE_TEST_CASE_TEMPLATE(SendQueueLength, T, StreamTransportFixtures, T)
diff --git a/tests/daemon/face/tcp-channel.t.cpp b/tests/daemon/face/tcp-channel.t.cpp
index 1c2b170..6789966 100644
--- a/tests/daemon/face/tcp-channel.t.cpp
+++ b/tests/daemon/face/tcp-channel.t.cpp
@@ -1,6 +1,6 @@
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
- * Copyright (c) 2014-2018, Regents of the University of California,
+ * Copyright (c) 2014-2019, Regents of the University of California,
* Arizona Board of Regents,
* Colorado State University,
* University Pierre & Marie Curie, Sorbonne University,
@@ -55,9 +55,9 @@
BOOST_CHECK_EQUAL(reason.empty(), false);
this->limitedIo.afterOp();
},
- time::seconds(1));
+ 1_s);
- BOOST_CHECK_EQUAL(this->limitedIo.run(1, time::seconds(2)), LimitedIo::EXCEED_OPS);
+ BOOST_CHECK_EQUAL(this->limitedIo.run(1, 2_s), LimitedIo::EXCEED_OPS);
BOOST_CHECK_EQUAL(channel->size(), 0);
}
diff --git a/tests/daemon/face/tcp-transport-fixture.hpp b/tests/daemon/face/tcp-transport-fixture.hpp
index 631abe1..dd77a95 100644
--- a/tests/daemon/face/tcp-transport-fixture.hpp
+++ b/tests/daemon/face/tcp-transport-fixture.hpp
@@ -86,7 +86,7 @@
limitedIo.afterOp();
});
- BOOST_REQUIRE_EQUAL(limitedIo.run(2, time::seconds(1)), LimitedIo::EXCEED_OPS);
+ BOOST_REQUIRE_EQUAL(limitedIo.run(2, 1_s), LimitedIo::EXCEED_OPS);
localEp = sock.local_endpoint();
@@ -115,7 +115,7 @@
BOOST_REQUIRE_EQUAL(error, boost::system::errc::success);
}
});
- limitedIo.defer(time::seconds(1));
+ limitedIo.defer(1_s);
}
protected:
diff --git a/tests/daemon/face/tcp-udp-channel.t.cpp b/tests/daemon/face/tcp-udp-channel.t.cpp
index f883f22..5b86e9d 100644
--- a/tests/daemon/face/tcp-udp-channel.t.cpp
+++ b/tests/daemon/face/tcp-udp-channel.t.cpp
@@ -1,6 +1,6 @@
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
- * Copyright (c) 2014-2017, Regents of the University of California,
+ * Copyright (c) 2014-2019, Regents of the University of California,
* Arizona Board of Regents,
* Colorado State University,
* University Pierre & Marie Curie, Sorbonne University,
@@ -83,7 +83,7 @@
auto ch1 = this->makeChannel(typename T::Address());
this->connect(*ch1);
- BOOST_CHECK_EQUAL(this->limitedIo.run(2, time::seconds(1)), LimitedIo::EXCEED_OPS);
+ BOOST_CHECK_EQUAL(this->limitedIo.run(2, 1_s), LimitedIo::EXCEED_OPS);
BOOST_CHECK_EQUAL(this->listenerChannel->size(), 1);
BOOST_CHECK_EQUAL(ch1->size(), 1);
@@ -94,7 +94,7 @@
this->connect(*ch2);
this->connect(*ch3);
- BOOST_CHECK_EQUAL(this->limitedIo.run(4, time::seconds(2)), LimitedIo::EXCEED_OPS);
+ BOOST_CHECK_EQUAL(this->limitedIo.run(4, 2_s), LimitedIo::EXCEED_OPS);
BOOST_CHECK_EQUAL(this->listenerChannel->size(), 3);
BOOST_CHECK_EQUAL(ch1->size(), 1);
@@ -113,7 +113,7 @@
// connect twice to the same endpoint
this->connect(*ch3);
- BOOST_CHECK_EQUAL(this->limitedIo.run(1, time::seconds(1)), LimitedIo::EXCEED_OPS);
+ BOOST_CHECK_EQUAL(this->limitedIo.run(1, 1_s), LimitedIo::EXCEED_OPS);
BOOST_CHECK_EQUAL(this->listenerChannel->size(), 3);
BOOST_CHECK_EQUAL(ch1->size(), 1);
@@ -132,14 +132,14 @@
auto clientChannel = this->makeChannel(typename T::Address());
this->connect(*clientChannel);
- BOOST_CHECK_EQUAL(this->limitedIo.run(2, time::seconds(1)), LimitedIo::EXCEED_OPS);
+ BOOST_CHECK_EQUAL(this->limitedIo.run(2, 1_s), LimitedIo::EXCEED_OPS);
BOOST_CHECK_EQUAL(this->listenerChannel->size(), 1);
BOOST_CHECK_EQUAL(clientChannel->size(), 1);
this->clientFaces.at(0)->close();
- BOOST_CHECK_EQUAL(this->limitedIo.run(2, time::seconds(5)), LimitedIo::EXCEED_OPS);
+ BOOST_CHECK_EQUAL(this->limitedIo.run(2, 5_s), LimitedIo::EXCEED_OPS);
BOOST_CHECK_EQUAL(this->listenerChannel->size(), 0);
BOOST_CHECK_EQUAL(clientChannel->size(), 0);
diff --git a/tests/daemon/face/transport.t.cpp b/tests/daemon/face/transport.t.cpp
index d586c20..747622e 100644
--- a/tests/daemon/face/transport.t.cpp
+++ b/tests/daemon/face/transport.t.cpp
@@ -45,6 +45,7 @@
namespace tests {
namespace mpl = boost::mpl;
+using namespace nfd::tests;
BOOST_AUTO_TEST_SUITE(Face)
BOOST_AUTO_TEST_SUITE(TestTransport)
@@ -211,7 +212,7 @@
BOOST_CHECK_EQUAL(transport->getExpirationTime(), time::steady_clock::TimePoint::max());
}
-class DummyTransportFixture : public nfd::tests::GlobalIoFixture
+class DummyTransportFixture : public GlobalIoFixture
{
protected:
DummyTransportFixture()
diff --git a/tests/daemon/face/udp-channel-fixture.hpp b/tests/daemon/face/udp-channel-fixture.hpp
index 708813a..81d75f3 100644
--- a/tests/daemon/face/udp-channel-fixture.hpp
+++ b/tests/daemon/face/udp-channel-fixture.hpp
@@ -1,6 +1,6 @@
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
- * Copyright (c) 2014-2018, Regents of the University of California,
+ * Copyright (c) 2014-2019, Regents of the University of California,
* Arizona Board of Regents,
* Colorado State University,
* University Pierre & Marie Curie, Sorbonne University,
@@ -44,7 +44,7 @@
if (port == 0)
port = getNextPort();
- return make_unique<UdpChannel>(udp::Endpoint(addr, port), time::seconds(2), false);
+ return make_unique<UdpChannel>(udp::Endpoint(addr, port), 2_s, false);
}
void
diff --git a/tests/daemon/face/unicast-ethernet-transport.t.cpp b/tests/daemon/face/unicast-ethernet-transport.t.cpp
index a95c3fb..0a4885d 100644
--- a/tests/daemon/face/unicast-ethernet-transport.t.cpp
+++ b/tests/daemon/face/unicast-ethernet-transport.t.cpp
@@ -1,6 +1,6 @@
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
- * Copyright (c) 2014-2018, Regents of the University of California,
+ * Copyright (c) 2014-2019, Regents of the University of California,
* Arizona Board of Regents,
* Colorado State University,
* University Pierre & Marie Curie, Sorbonne University,
@@ -89,7 +89,7 @@
limitedIo.afterOp();
});
- BOOST_REQUIRE_EQUAL(limitedIo.run(1, time::seconds(1)), LimitedIo::EXCEED_OPS);
+ BOOST_REQUIRE_EQUAL(limitedIo.run(1, 1_s), LimitedIo::EXCEED_OPS);
}
BOOST_AUTO_TEST_CASE(IdleClose)
@@ -116,7 +116,7 @@
limitedIo.afterOp();
});
- BOOST_REQUIRE_EQUAL(limitedIo.run(2, time::seconds(5)), LimitedIo::EXCEED_OPS);
+ BOOST_REQUIRE_EQUAL(limitedIo.run(2, 5_s), LimitedIo::EXCEED_OPS);
BOOST_CHECK_EQUAL(nStateChanges, 2);
}
diff --git a/tests/daemon/face/unicast-udp-transport-fixture.hpp b/tests/daemon/face/unicast-udp-transport-fixture.hpp
index 08acd46..dcd99ef 100644
--- a/tests/daemon/face/unicast-udp-transport-fixture.hpp
+++ b/tests/daemon/face/unicast-udp-transport-fixture.hpp
@@ -63,7 +63,7 @@
face = make_unique<Face>(
make_unique<DummyReceiveLinkService>(),
- make_unique<UnicastUdpTransport>(std::move(sock), persistency, time::seconds(3)));
+ make_unique<UnicastUdpTransport>(std::move(sock), persistency, 3_s));
transport = static_cast<UnicastUdpTransport*>(face->getTransport());
receivedPackets = &static_cast<DummyReceiveLinkService*>(face->getLinkService())->receivedPackets;
@@ -90,7 +90,7 @@
}
limitedIo.afterOp();
});
- BOOST_REQUIRE_EQUAL(limitedIo.run(1, time::seconds(1)), LimitedIo::EXCEED_OPS);
+ BOOST_REQUIRE_EQUAL(limitedIo.run(1, 1_s), LimitedIo::EXCEED_OPS);
}
void
@@ -102,7 +102,7 @@
BOOST_REQUIRE_EQUAL(error, boost::system::errc::success);
}
});
- limitedIo.defer(time::seconds(1));
+ limitedIo.defer(1_s);
}
protected:
diff --git a/tests/daemon/face/unicast-udp-transport.t.cpp b/tests/daemon/face/unicast-udp-transport.t.cpp
index a2a3e79..9ef5b95 100644
--- a/tests/daemon/face/unicast-udp-transport.t.cpp
+++ b/tests/daemon/face/unicast-udp-transport.t.cpp
@@ -1,6 +1,6 @@
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
- * Copyright (c) 2014-2018, Regents of the University of California,
+ * Copyright (c) 2014-2019, Regents of the University of California,
* Arizona Board of Regents,
* Colorado State University,
* University Pierre & Marie Curie, Sorbonne University,
@@ -101,7 +101,7 @@
limitedIo.afterOp();
});
- BOOST_REQUIRE_EQUAL(limitedIo.run(2, time::seconds(8)), LimitedIo::EXCEED_OPS);
+ BOOST_REQUIRE_EQUAL(limitedIo.run(2, 8_s), LimitedIo::EXCEED_OPS);
BOOST_CHECK_EQUAL(nStateChanges, 2);
}
@@ -124,7 +124,7 @@
remoteSocket.close();
Transport::Packet pkt(ndn::encoding::makeStringBlock(300, "hello"));
transport->send(std::move(pkt)); // trigger ICMP error
- BOOST_REQUIRE_EQUAL(limitedIo.run(1, time::seconds(1)), LimitedIo::EXCEED_OPS);
+ BOOST_REQUIRE_EQUAL(limitedIo.run(1, 1_s), LimitedIo::EXCEED_OPS);
transport->afterStateChange.connectSingleShot([this] (TransportState oldState, TransportState newState) {
BOOST_CHECK_EQUAL(oldState, TransportState::FAILED);
@@ -132,7 +132,7 @@
this->limitedIo.afterOp();
});
- BOOST_REQUIRE_EQUAL(limitedIo.run(1, time::seconds(1)), LimitedIo::EXCEED_OPS);
+ BOOST_REQUIRE_EQUAL(limitedIo.run(1, 1_s), LimitedIo::EXCEED_OPS);
}
BOOST_FIXTURE_TEST_CASE(RemoteClosePermanent, RemoteCloseFixture)
@@ -146,7 +146,7 @@
BOOST_CHECK_EQUAL(transport->getCounters().nOutPackets, 1);
BOOST_CHECK_EQUAL(transport->getCounters().nOutBytes, block1.size());
- limitedIo.defer(time::seconds(1));
+ limitedIo.defer(1_s);
BOOST_CHECK_EQUAL(transport->getState(), TransportState::UP);
remoteConnect();
@@ -161,7 +161,7 @@
BOOST_REQUIRE_EQUAL(error, boost::system::errc::success);
limitedIo.afterOp();
});
- BOOST_REQUIRE_EQUAL(limitedIo.run(1, time::seconds(1)), LimitedIo::EXCEED_OPS);
+ BOOST_REQUIRE_EQUAL(limitedIo.run(1, 1_s), LimitedIo::EXCEED_OPS);
BOOST_CHECK_EQUAL_COLLECTIONS(readBuf.begin(), readBuf.end(), block1.begin(), block1.end());
diff --git a/tests/daemon/face/unix-stream-channel.t.cpp b/tests/daemon/face/unix-stream-channel.t.cpp
index 8e20a26..fe9d4be 100644
--- a/tests/daemon/face/unix-stream-channel.t.cpp
+++ b/tests/daemon/face/unix-stream-channel.t.cpp
@@ -1,6 +1,6 @@
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
- * Copyright (c) 2014-2018, Regents of the University of California,
+ * Copyright (c) 2014-2019, Regents of the University of California,
* Arizona Board of Regents,
* Colorado State University,
* University Pierre & Marie Curie, Sorbonne University,
@@ -108,7 +108,7 @@
local::stream_protocol::socket client1(g_io);
this->clientConnect(client1);
- BOOST_CHECK_EQUAL(limitedIo.run(2, time::seconds(1)), LimitedIo::EXCEED_OPS);
+ BOOST_CHECK_EQUAL(limitedIo.run(2, 1_s), LimitedIo::EXCEED_OPS);
BOOST_CHECK_EQUAL(listenerChannel->size(), 1);
local::stream_protocol::socket client2(g_io);
@@ -116,7 +116,7 @@
this->clientConnect(client2);
this->clientConnect(client3);
- BOOST_CHECK_EQUAL(limitedIo.run(4, time::seconds(1)), LimitedIo::EXCEED_OPS);
+ BOOST_CHECK_EQUAL(limitedIo.run(4, 1_s), LimitedIo::EXCEED_OPS);
BOOST_CHECK_EQUAL(listenerChannel->size(), 3);
BOOST_CHECK_EQUAL(listenerFaces.size(), 3);
diff --git a/tests/daemon/face/unix-stream-transport-fixture.hpp b/tests/daemon/face/unix-stream-transport-fixture.hpp
index 582db48..74c1b45 100644
--- a/tests/daemon/face/unix-stream-transport-fixture.hpp
+++ b/tests/daemon/face/unix-stream-transport-fixture.hpp
@@ -109,7 +109,7 @@
limitedIo.afterOp();
});
- BOOST_REQUIRE_EQUAL(limitedIo.run(2, time::seconds(1)), LimitedIo::EXCEED_OPS);
+ BOOST_REQUIRE_EQUAL(limitedIo.run(2, 1_s), LimitedIo::EXCEED_OPS);
localEp = sock.local_endpoint();
face = make_unique<Face>(make_unique<DummyReceiveLinkService>(),
@@ -129,7 +129,7 @@
BOOST_REQUIRE_EQUAL(error, boost::system::errc::success);
}
});
- limitedIo.defer(time::seconds(1));
+ limitedIo.defer(1_s);
}
protected:
diff --git a/tests/daemon/face/websocket-transport-fixture.hpp b/tests/daemon/face/websocket-transport-fixture.hpp
index 8b8ee42..07763cd 100644
--- a/tests/daemon/face/websocket-transport-fixture.hpp
+++ b/tests/daemon/face/websocket-transport-fixture.hpp
@@ -56,7 +56,7 @@
*/
void
serverListen(const ip::tcp::endpoint& ep,
- const time::milliseconds& pongTimeout = time::seconds(1))
+ const time::milliseconds& pongTimeout = 1_s)
{
server.clear_access_channels(websocketpp::log::alevel::all);
server.clear_error_channels(websocketpp::log::elevel::all);
@@ -99,15 +99,15 @@
*/
void
initialize(ip::address address,
- time::milliseconds pingInterval = time::seconds(10),
- time::milliseconds pongTimeout = time::seconds(1))
+ time::milliseconds pingInterval = 10_s,
+ time::milliseconds pongTimeout = 1_s)
{
ip::tcp::endpoint ep(address, 20070);
serverListen(ep, pongTimeout);
clientConnect(FaceUri(ep, "ws").toString());
BOOST_REQUIRE_EQUAL(limitedIo.run(2, // serverHandleOpen, clientHandleOpen
- time::seconds(1)), LimitedIo::EXCEED_OPS);
+ 1_s), LimitedIo::EXCEED_OPS);
face = make_unique<Face>(
make_unique<DummyReceiveLinkService>(),
diff --git a/tests/daemon/face/websocket-transport.t.cpp b/tests/daemon/face/websocket-transport.t.cpp
index 66a3d43..657df71 100644
--- a/tests/daemon/face/websocket-transport.t.cpp
+++ b/tests/daemon/face/websocket-transport.t.cpp
@@ -1,6 +1,6 @@
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
- * Copyright (c) 2014-2018, Regents of the University of California,
+ * Copyright (c) 2014-2019, Regents of the University of California,
* Arizona Board of Regents,
* Colorado State University,
* University Pierre & Marie Curie, Sorbonne University,
@@ -92,10 +92,10 @@
BOOST_FIXTURE_TEST_CASE_TEMPLATE(PingPong, T, WebSocketTransportFixtures, T)
{
- TRANSPORT_TEST_INIT(time::milliseconds(500), time::milliseconds(300));
+ TRANSPORT_TEST_INIT(500_ms, 300_ms);
BOOST_CHECK_EQUAL(this->limitedIo.run(2, // clientHandlePing, serverHandlePong
- time::milliseconds(1500)), LimitedIo::EXCEED_OPS);
+ 1500_ms), LimitedIo::EXCEED_OPS);
BOOST_CHECK_EQUAL(this->transport->getState(), TransportState::UP);
BOOST_CHECK_EQUAL(this->transport->getCounters().nOutPings, 1);
@@ -103,7 +103,7 @@
this->clientShouldPong = false;
BOOST_CHECK_EQUAL(this->limitedIo.run(2, // clientHandlePing, serverHandlePongTimeout
- time::seconds(2)), LimitedIo::EXCEED_OPS);
+ 2_s), LimitedIo::EXCEED_OPS);
BOOST_CHECK_MESSAGE(this->transport->getState() == TransportState::FAILED ||
this->transport->getState() == TransportState::CLOSED,
@@ -119,14 +119,14 @@
auto block1 = ndn::encoding::makeStringBlock(300, "hello");
this->transport->send(Transport::Packet{Block{block1}}); // make a copy of the block
BOOST_CHECK_EQUAL(this->limitedIo.run(1, // clientHandleMessage
- time::seconds(1)), LimitedIo::EXCEED_OPS);
+ 1_s), LimitedIo::EXCEED_OPS);
BOOST_CHECK_EQUAL(this->transport->getCounters().nOutPackets, 1);
BOOST_CHECK_EQUAL(this->transport->getCounters().nOutBytes, block1.size());
auto block2 = ndn::encoding::makeStringBlock(301, "world");
this->transport->send(Transport::Packet{Block{block2}}); // make a copy of the block
BOOST_CHECK_EQUAL(this->limitedIo.run(1, // clientHandleMessage
- time::seconds(1)), LimitedIo::EXCEED_OPS);
+ 1_s), LimitedIo::EXCEED_OPS);
BOOST_CHECK_EQUAL(this->transport->getCounters().nOutPackets, 2);
BOOST_CHECK_EQUAL(this->transport->getCounters().nOutBytes, block1.size() + block2.size());
@@ -149,12 +149,12 @@
Block pkt1 = ndn::encoding::makeStringBlock(300, "hello");
this->client.send(this->clientHdl, pkt1.wire(), pkt1.size(), websocketpp::frame::opcode::binary);
BOOST_CHECK_EQUAL(this->limitedIo.run(1, // serverHandleMessage
- time::seconds(1)), LimitedIo::EXCEED_OPS);
+ 1_s), LimitedIo::EXCEED_OPS);
Block pkt2 = ndn::encoding::makeStringBlock(301, "world!");
this->client.send(this->clientHdl, pkt2.wire(), pkt2.size(), websocketpp::frame::opcode::binary);
BOOST_CHECK_EQUAL(this->limitedIo.run(1, // serverHandleMessage
- time::seconds(1)), LimitedIo::EXCEED_OPS);
+ 1_s), LimitedIo::EXCEED_OPS);
BOOST_CHECK_EQUAL(this->transport->getCounters().nInPackets, 2);
BOOST_CHECK_EQUAL(this->transport->getCounters().nInBytes, pkt1.size() + pkt2.size());
@@ -175,7 +175,7 @@
this->client.send(this->clientHdl, pkt1.wire(), pkt1.size() - 1, // truncated
websocketpp::frame::opcode::binary);
BOOST_CHECK_EQUAL(this->limitedIo.run(1, // serverHandleMessage
- time::seconds(1)), LimitedIo::EXCEED_OPS);
+ 1_s), LimitedIo::EXCEED_OPS);
// bad packet is dropped
BOOST_CHECK_EQUAL(this->transport->getState(), TransportState::UP);
@@ -184,7 +184,7 @@
Block pkt2 = ndn::encoding::makeStringBlock(301, "world!");
this->client.send(this->clientHdl, pkt2.wire(), pkt2.size(), websocketpp::frame::opcode::binary);
BOOST_CHECK_EQUAL(this->limitedIo.run(1, // serverHandleMessage
- time::seconds(1)), LimitedIo::EXCEED_OPS);
+ 1_s), LimitedIo::EXCEED_OPS);
// next valid packet is still received normally
BOOST_CHECK_EQUAL(this->transport->getState(), TransportState::UP);
@@ -242,7 +242,7 @@
this->client.close(this->clientHdl, websocketpp::close::status::going_away, "");
BOOST_CHECK_EQUAL(this->limitedIo.run(1, // serverHandleClose
- time::seconds(1)), LimitedIo::EXCEED_OPS);
+ 1_s), LimitedIo::EXCEED_OPS);
BOOST_CHECK_EQUAL(nStateChanges, 2);
}