Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 1 | /* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */ |
| 2 | /** |
| 3 | * Copyright (C) 2014 Named Data Networking Project |
| 4 | * See COPYING for copyright and distribution information. |
| 5 | */ |
| 6 | |
Alexander Afanasyev | 0eb7065 | 2014-02-27 18:35:07 -0800 | [diff] [blame] | 7 | #include "face/tcp-factory.hpp" |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 8 | #include <ndn-cpp-dev/security/key-chain.hpp> |
| 9 | |
Junxiao Shi | d9ee45c | 2014-02-27 15:38:11 -0700 | [diff] [blame] | 10 | #include "tests/test-common.hpp" |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 11 | #include "tests/core/limited-io.hpp" |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 12 | |
| 13 | namespace nfd { |
Junxiao Shi | d9ee45c | 2014-02-27 15:38:11 -0700 | [diff] [blame] | 14 | namespace tests { |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 15 | |
Junxiao Shi | d9ee45c | 2014-02-27 15:38:11 -0700 | [diff] [blame] | 16 | BOOST_FIXTURE_TEST_SUITE(FaceTcp, BaseFixture) |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 17 | |
| 18 | BOOST_AUTO_TEST_CASE(ChannelMap) |
| 19 | { |
Alexander Afanasyev | 0eb7065 | 2014-02-27 18:35:07 -0800 | [diff] [blame] | 20 | TcpFactory factory; |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 21 | |
Alexander Afanasyev | d665530 | 2014-02-28 08:41:28 -0800 | [diff] [blame] | 22 | shared_ptr<TcpChannel> channel1 = factory.createChannel("127.0.0.1", "20070"); |
| 23 | shared_ptr<TcpChannel> channel1a = factory.createChannel("127.0.0.1", "20070"); |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 24 | BOOST_CHECK_EQUAL(channel1, channel1a); |
Junxiao Shi | 61e3cc5 | 2014-03-03 20:40:28 -0700 | [diff] [blame] | 25 | BOOST_CHECK_EQUAL(channel1->getUri().toString(), "tcp4://127.0.0.1:20070"); |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 26 | |
Alexander Afanasyev | d665530 | 2014-02-28 08:41:28 -0800 | [diff] [blame] | 27 | shared_ptr<TcpChannel> channel2 = factory.createChannel("127.0.0.1", "20071"); |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 28 | BOOST_CHECK_NE(channel1, channel2); |
Junxiao Shi | 61e3cc5 | 2014-03-03 20:40:28 -0700 | [diff] [blame] | 29 | |
| 30 | shared_ptr<TcpChannel> channel3 = factory.createChannel("::1", "20071"); |
| 31 | BOOST_CHECK_NE(channel2, channel3); |
| 32 | BOOST_CHECK_EQUAL(channel3->getUri().toString(), "tcp6://[::1]:20071"); |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 33 | } |
| 34 | |
Junxiao Shi | d9ee45c | 2014-02-27 15:38:11 -0700 | [diff] [blame] | 35 | class EndToEndFixture : protected BaseFixture |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 36 | { |
| 37 | public: |
| 38 | void |
Alexander Afanasyev | bd220a0 | 2014-02-20 00:29:56 -0800 | [diff] [blame] | 39 | channel1_onFaceCreated(const shared_ptr<Face>& newFace) |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 40 | { |
| 41 | BOOST_CHECK(!static_cast<bool>(m_face1)); |
| 42 | m_face1 = newFace; |
| 43 | m_face1->onReceiveInterest += |
| 44 | bind(&EndToEndFixture::face1_onReceiveInterest, this, _1); |
| 45 | m_face1->onReceiveData += |
| 46 | bind(&EndToEndFixture::face1_onReceiveData, this, _1); |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 47 | m_face1->onFail += |
Alexander Afanasyev | a0a10fb | 2014-02-13 19:56:15 -0800 | [diff] [blame] | 48 | bind(&EndToEndFixture::face1_onFail, this); |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 49 | |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 50 | m_limitedIo.afterOp(); |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 51 | } |
| 52 | |
| 53 | void |
| 54 | channel1_onConnectFailed(const std::string& reason) |
| 55 | { |
| 56 | BOOST_CHECK_MESSAGE(false, reason); |
| 57 | |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 58 | m_limitedIo.afterOp(); |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 59 | } |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 60 | |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 61 | void |
| 62 | face1_onReceiveInterest(const Interest& interest) |
| 63 | { |
| 64 | m_face1_receivedInterests.push_back(interest); |
| 65 | |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 66 | m_limitedIo.afterOp(); |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 67 | } |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 68 | |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 69 | void |
| 70 | face1_onReceiveData(const Data& data) |
| 71 | { |
| 72 | m_face1_receivedDatas.push_back(data); |
| 73 | |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 74 | m_limitedIo.afterOp(); |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 75 | } |
| 76 | |
| 77 | void |
Alexander Afanasyev | a0a10fb | 2014-02-13 19:56:15 -0800 | [diff] [blame] | 78 | face1_onFail() |
| 79 | { |
| 80 | m_face1.reset(); |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 81 | m_limitedIo.afterOp(); |
Alexander Afanasyev | a0a10fb | 2014-02-13 19:56:15 -0800 | [diff] [blame] | 82 | } |
| 83 | |
| 84 | void |
Alexander Afanasyev | bd220a0 | 2014-02-20 00:29:56 -0800 | [diff] [blame] | 85 | channel2_onFaceCreated(const shared_ptr<Face>& newFace) |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 86 | { |
| 87 | BOOST_CHECK(!static_cast<bool>(m_face2)); |
| 88 | m_face2 = newFace; |
| 89 | m_face2->onReceiveInterest += |
| 90 | bind(&EndToEndFixture::face2_onReceiveInterest, this, _1); |
| 91 | m_face2->onReceiveData += |
| 92 | bind(&EndToEndFixture::face2_onReceiveData, this, _1); |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 93 | m_face2->onFail += |
Alexander Afanasyev | a0a10fb | 2014-02-13 19:56:15 -0800 | [diff] [blame] | 94 | bind(&EndToEndFixture::face2_onFail, this); |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 95 | |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 96 | m_limitedIo.afterOp(); |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 97 | } |
| 98 | |
| 99 | void |
| 100 | channel2_onConnectFailed(const std::string& reason) |
| 101 | { |
| 102 | BOOST_CHECK_MESSAGE(false, reason); |
| 103 | |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 104 | m_limitedIo.afterOp(); |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 105 | } |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 106 | |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 107 | void |
| 108 | face2_onReceiveInterest(const Interest& interest) |
| 109 | { |
| 110 | m_face2_receivedInterests.push_back(interest); |
| 111 | |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 112 | m_limitedIo.afterOp(); |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 113 | } |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 114 | |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 115 | void |
| 116 | face2_onReceiveData(const Data& data) |
| 117 | { |
| 118 | m_face2_receivedDatas.push_back(data); |
| 119 | |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 120 | m_limitedIo.afterOp(); |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 121 | } |
| 122 | |
| 123 | void |
Alexander Afanasyev | a0a10fb | 2014-02-13 19:56:15 -0800 | [diff] [blame] | 124 | face2_onFail() |
| 125 | { |
| 126 | m_face2.reset(); |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 127 | m_limitedIo.afterOp(); |
Alexander Afanasyev | a0a10fb | 2014-02-13 19:56:15 -0800 | [diff] [blame] | 128 | } |
| 129 | |
| 130 | void |
Alexander Afanasyev | bd220a0 | 2014-02-20 00:29:56 -0800 | [diff] [blame] | 131 | channel_onFaceCreated(const shared_ptr<Face>& newFace) |
Alexander Afanasyev | a16abd2 | 2014-01-31 18:12:29 -0800 | [diff] [blame] | 132 | { |
| 133 | m_faces.push_back(newFace); |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 134 | m_limitedIo.afterOp(); |
Alexander Afanasyev | a16abd2 | 2014-01-31 18:12:29 -0800 | [diff] [blame] | 135 | } |
| 136 | |
| 137 | void |
| 138 | channel_onConnectFailed(const std::string& reason) |
| 139 | { |
| 140 | BOOST_CHECK_MESSAGE(false, reason); |
| 141 | |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 142 | m_limitedIo.afterOp(); |
Alexander Afanasyev | a16abd2 | 2014-01-31 18:12:29 -0800 | [diff] [blame] | 143 | } |
| 144 | |
| 145 | void |
| 146 | checkFaceList(size_t shouldBe) |
| 147 | { |
| 148 | BOOST_CHECK_EQUAL(m_faces.size(), shouldBe); |
| 149 | } |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 150 | |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 151 | public: |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 152 | LimitedIo m_limitedIo; |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 153 | |
Alexander Afanasyev | bd220a0 | 2014-02-20 00:29:56 -0800 | [diff] [blame] | 154 | shared_ptr<Face> m_face1; |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 155 | std::vector<Interest> m_face1_receivedInterests; |
| 156 | std::vector<Data> m_face1_receivedDatas; |
Alexander Afanasyev | bd220a0 | 2014-02-20 00:29:56 -0800 | [diff] [blame] | 157 | shared_ptr<Face> m_face2; |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 158 | std::vector<Interest> m_face2_receivedInterests; |
| 159 | std::vector<Data> m_face2_receivedDatas; |
Alexander Afanasyev | a16abd2 | 2014-01-31 18:12:29 -0800 | [diff] [blame] | 160 | |
Alexander Afanasyev | bd220a0 | 2014-02-20 00:29:56 -0800 | [diff] [blame] | 161 | std::list< shared_ptr<Face> > m_faces; |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 162 | }; |
| 163 | |
| 164 | |
Alexander Afanasyev | a39b90b | 2014-03-05 15:31:00 +0000 | [diff] [blame] | 165 | BOOST_FIXTURE_TEST_CASE(EndToEnd4, EndToEndFixture) |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 166 | { |
Alexander Afanasyev | 0eb7065 | 2014-02-27 18:35:07 -0800 | [diff] [blame] | 167 | TcpFactory factory; |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 168 | |
Alexander Afanasyev | d665530 | 2014-02-28 08:41:28 -0800 | [diff] [blame] | 169 | shared_ptr<TcpChannel> channel1 = factory.createChannel("127.0.0.1", "20070"); |
Alexander Afanasyev | a39b90b | 2014-03-05 15:31:00 +0000 | [diff] [blame] | 170 | factory.createChannel("127.0.0.1", "20071"); |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 171 | |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 172 | channel1->listen(bind(&EndToEndFixture::channel1_onFaceCreated, this, _1), |
| 173 | bind(&EndToEndFixture::channel1_onConnectFailed, this, _1)); |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 174 | |
Alexander Afanasyev | a39b90b | 2014-03-05 15:31:00 +0000 | [diff] [blame] | 175 | factory.createFace(FaceUri("tcp://127.0.0.1:20070"), |
| 176 | bind(&EndToEndFixture::channel2_onFaceCreated, this, _1), |
| 177 | bind(&EndToEndFixture::channel2_onConnectFailed, this, _1)); |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 178 | |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 179 | BOOST_CHECK_MESSAGE(m_limitedIo.run(2, time::seconds(10)) == LimitedIo::EXCEED_OPS, |
| 180 | "TcpChannel error: cannot connect or cannot accept connection"); |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 181 | |
| 182 | BOOST_REQUIRE(static_cast<bool>(m_face1)); |
| 183 | BOOST_REQUIRE(static_cast<bool>(m_face2)); |
Alexander Afanasyev | bd220a0 | 2014-02-20 00:29:56 -0800 | [diff] [blame] | 184 | |
Alexander Afanasyev | 355c066 | 2014-03-20 18:08:17 -0700 | [diff] [blame^] | 185 | BOOST_CHECK(m_face1->isOnDemand()); |
| 186 | BOOST_CHECK(!m_face2->isOnDemand()); |
| 187 | |
Alexander Afanasyev | a39b90b | 2014-03-05 15:31:00 +0000 | [diff] [blame] | 188 | BOOST_CHECK_EQUAL(m_face2->getUri().toString(), "tcp4://127.0.0.1:20070"); |
| 189 | // face1 has an unknown URI, since the source port is automatically chosen by OS |
| 190 | |
| 191 | BOOST_CHECK_EQUAL(m_face1->isLocal(), true); |
| 192 | BOOST_CHECK_EQUAL(m_face2->isLocal(), true); |
| 193 | |
| 194 | BOOST_CHECK_EQUAL(static_cast<bool>(dynamic_pointer_cast<LocalFace>(m_face1)), true); |
| 195 | BOOST_CHECK_EQUAL(static_cast<bool>(dynamic_pointer_cast<LocalFace>(m_face2)), true); |
| 196 | |
| 197 | // integrated tests needs to check that TcpFace for non-loopback fails these tests... |
| 198 | |
| 199 | Interest interest1("ndn:/TpnzGvW9R"); |
| 200 | Data data1 ("ndn:/KfczhUqVix"); |
| 201 | data1.setContent(0, 0); |
| 202 | Interest interest2("ndn:/QWiIMfj5sL"); |
| 203 | Data data2 ("ndn:/XNBV796f"); |
| 204 | data2.setContent(0, 0); |
| 205 | |
| 206 | ndn::SignatureSha256WithRsa fakeSignature; |
| 207 | fakeSignature.setValue(ndn::dataBlock(tlv::SignatureValue, reinterpret_cast<const uint8_t*>(0), 0)); |
| 208 | |
| 209 | // set fake signature on data1 and data2 |
| 210 | data1.setSignature(fakeSignature); |
| 211 | data2.setSignature(fakeSignature); |
| 212 | |
| 213 | m_face1->sendInterest(interest1); |
Alexander Afanasyev | 7e698e6 | 2014-03-07 16:48:35 +0000 | [diff] [blame] | 214 | m_face1->sendInterest(interest1); |
| 215 | m_face1->sendInterest(interest1); |
Alexander Afanasyev | a39b90b | 2014-03-05 15:31:00 +0000 | [diff] [blame] | 216 | m_face1->sendData (data1 ); |
| 217 | m_face2->sendInterest(interest2); |
| 218 | m_face2->sendData (data2 ); |
Alexander Afanasyev | 7e698e6 | 2014-03-07 16:48:35 +0000 | [diff] [blame] | 219 | m_face2->sendData (data2 ); |
| 220 | m_face2->sendData (data2 ); |
Alexander Afanasyev | a39b90b | 2014-03-05 15:31:00 +0000 | [diff] [blame] | 221 | |
Alexander Afanasyev | 7e698e6 | 2014-03-07 16:48:35 +0000 | [diff] [blame] | 222 | BOOST_CHECK_MESSAGE(m_limitedIo.run(8, time::seconds(10)) == LimitedIo::EXCEED_OPS, |
Alexander Afanasyev | a39b90b | 2014-03-05 15:31:00 +0000 | [diff] [blame] | 223 | "TcpChannel error: cannot send or receive Interest/Data packets"); |
| 224 | |
| 225 | |
| 226 | BOOST_REQUIRE_EQUAL(m_face1_receivedInterests.size(), 1); |
Alexander Afanasyev | 7e698e6 | 2014-03-07 16:48:35 +0000 | [diff] [blame] | 227 | BOOST_REQUIRE_EQUAL(m_face1_receivedDatas .size(), 3); |
| 228 | BOOST_REQUIRE_EQUAL(m_face2_receivedInterests.size(), 3); |
Alexander Afanasyev | a39b90b | 2014-03-05 15:31:00 +0000 | [diff] [blame] | 229 | BOOST_REQUIRE_EQUAL(m_face2_receivedDatas .size(), 1); |
| 230 | |
| 231 | BOOST_CHECK_EQUAL(m_face1_receivedInterests[0].getName(), interest2.getName()); |
| 232 | BOOST_CHECK_EQUAL(m_face1_receivedDatas [0].getName(), data2.getName()); |
| 233 | BOOST_CHECK_EQUAL(m_face2_receivedInterests[0].getName(), interest1.getName()); |
| 234 | BOOST_CHECK_EQUAL(m_face2_receivedDatas [0].getName(), data1.getName()); |
Alexander Afanasyev | 7e698e6 | 2014-03-07 16:48:35 +0000 | [diff] [blame] | 235 | |
| 236 | const FaceCounters& counters1 = m_face1->getCounters(); |
| 237 | BOOST_CHECK_EQUAL(counters1.getInInterest() , 1); |
| 238 | BOOST_CHECK_EQUAL(counters1.getInData() , 3); |
| 239 | BOOST_CHECK_EQUAL(counters1.getOutInterest(), 3); |
| 240 | BOOST_CHECK_EQUAL(counters1.getOutData() , 1); |
| 241 | |
| 242 | const FaceCounters& counters2 = m_face2->getCounters(); |
| 243 | BOOST_CHECK_EQUAL(counters2.getInInterest() , 3); |
| 244 | BOOST_CHECK_EQUAL(counters2.getInData() , 1); |
| 245 | BOOST_CHECK_EQUAL(counters2.getOutInterest(), 1); |
| 246 | BOOST_CHECK_EQUAL(counters2.getOutData() , 3); |
Alexander Afanasyev | a39b90b | 2014-03-05 15:31:00 +0000 | [diff] [blame] | 247 | } |
| 248 | |
| 249 | BOOST_FIXTURE_TEST_CASE(EndToEnd6, EndToEndFixture) |
| 250 | { |
| 251 | TcpFactory factory; |
| 252 | |
| 253 | shared_ptr<TcpChannel> channel1 = factory.createChannel("::1", "20070"); |
| 254 | shared_ptr<TcpChannel> channel2 = factory.createChannel("::1", "20071"); |
| 255 | |
| 256 | channel1->listen(bind(&EndToEndFixture::channel1_onFaceCreated, this, _1), |
| 257 | bind(&EndToEndFixture::channel1_onConnectFailed, this, _1)); |
| 258 | |
| 259 | factory.createFace(FaceUri("tcp://[::1]:20070"), |
| 260 | bind(&EndToEndFixture::channel2_onFaceCreated, this, _1), |
| 261 | bind(&EndToEndFixture::channel2_onConnectFailed, this, _1)); |
| 262 | |
| 263 | BOOST_CHECK_MESSAGE(m_limitedIo.run(2, time::seconds(10)) == LimitedIo::EXCEED_OPS, |
| 264 | "TcpChannel error: cannot connect or cannot accept connection"); |
| 265 | |
| 266 | BOOST_REQUIRE(static_cast<bool>(m_face1)); |
| 267 | BOOST_REQUIRE(static_cast<bool>(m_face2)); |
| 268 | |
| 269 | BOOST_CHECK_EQUAL(m_face2->getUri().toString(), "tcp6://[::1]:20070"); |
| 270 | // face1 has an unknown URI, since the source port is automatically chosen by OS |
| 271 | |
Alexander Afanasyev | bd220a0 | 2014-02-20 00:29:56 -0800 | [diff] [blame] | 272 | BOOST_CHECK_EQUAL(m_face1->isLocal(), true); |
| 273 | BOOST_CHECK_EQUAL(m_face2->isLocal(), true); |
| 274 | |
| 275 | BOOST_CHECK_EQUAL(static_cast<bool>(dynamic_pointer_cast<LocalFace>(m_face1)), true); |
| 276 | BOOST_CHECK_EQUAL(static_cast<bool>(dynamic_pointer_cast<LocalFace>(m_face2)), true); |
| 277 | |
| 278 | // integrated tests needs to check that TcpFace for non-loopback fails these tests... |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 279 | |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 280 | Interest interest1("ndn:/TpnzGvW9R"); |
| 281 | Data data1 ("ndn:/KfczhUqVix"); |
| 282 | data1.setContent(0, 0); |
| 283 | Interest interest2("ndn:/QWiIMfj5sL"); |
| 284 | Data data2 ("ndn:/XNBV796f"); |
| 285 | data2.setContent(0, 0); |
| 286 | |
| 287 | ndn::SignatureSha256WithRsa fakeSignature; |
| 288 | fakeSignature.setValue(ndn::dataBlock(tlv::SignatureValue, reinterpret_cast<const uint8_t*>(0), 0)); |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 289 | |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 290 | // set fake signature on data1 and data2 |
| 291 | data1.setSignature(fakeSignature); |
| 292 | data2.setSignature(fakeSignature); |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 293 | |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 294 | m_face1->sendInterest(interest1); |
| 295 | m_face1->sendData (data1 ); |
| 296 | m_face2->sendInterest(interest2); |
| 297 | m_face2->sendData (data2 ); |
| 298 | |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 299 | BOOST_CHECK_MESSAGE(m_limitedIo.run(4, time::seconds(10)) == LimitedIo::EXCEED_OPS, |
| 300 | "TcpChannel error: cannot send or receive Interest/Data packets"); |
| 301 | |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 302 | |
| 303 | BOOST_REQUIRE_EQUAL(m_face1_receivedInterests.size(), 1); |
| 304 | BOOST_REQUIRE_EQUAL(m_face1_receivedDatas .size(), 1); |
| 305 | BOOST_REQUIRE_EQUAL(m_face2_receivedInterests.size(), 1); |
| 306 | BOOST_REQUIRE_EQUAL(m_face2_receivedDatas .size(), 1); |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 307 | |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 308 | BOOST_CHECK_EQUAL(m_face1_receivedInterests[0].getName(), interest2.getName()); |
| 309 | BOOST_CHECK_EQUAL(m_face1_receivedDatas [0].getName(), data2.getName()); |
| 310 | BOOST_CHECK_EQUAL(m_face2_receivedInterests[0].getName(), interest1.getName()); |
| 311 | BOOST_CHECK_EQUAL(m_face2_receivedDatas [0].getName(), data1.getName()); |
| 312 | } |
| 313 | |
Alexander Afanasyev | a16abd2 | 2014-01-31 18:12:29 -0800 | [diff] [blame] | 314 | BOOST_FIXTURE_TEST_CASE(MultipleAccepts, EndToEndFixture) |
| 315 | { |
Alexander Afanasyev | 0eb7065 | 2014-02-27 18:35:07 -0800 | [diff] [blame] | 316 | TcpFactory factory; |
Alexander Afanasyev | a16abd2 | 2014-01-31 18:12:29 -0800 | [diff] [blame] | 317 | |
Alexander Afanasyev | d665530 | 2014-02-28 08:41:28 -0800 | [diff] [blame] | 318 | shared_ptr<TcpChannel> channel1 = factory.createChannel("127.0.0.1", "20070"); |
| 319 | shared_ptr<TcpChannel> channel2 = factory.createChannel("127.0.0.1", "20071"); |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 320 | |
Alexander Afanasyev | a16abd2 | 2014-01-31 18:12:29 -0800 | [diff] [blame] | 321 | channel1->listen(bind(&EndToEndFixture::channel_onFaceCreated, this, _1), |
| 322 | bind(&EndToEndFixture::channel_onConnectFailed, this, _1)); |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 323 | |
Alexander Afanasyev | a16abd2 | 2014-01-31 18:12:29 -0800 | [diff] [blame] | 324 | channel2->connect("127.0.0.1", "20070", |
| 325 | bind(&EndToEndFixture::channel_onFaceCreated, this, _1), |
| 326 | bind(&EndToEndFixture::channel_onConnectFailed, this, _1), |
Alexander Afanasyev | c1e2ee0 | 2014-02-25 17:02:07 -0800 | [diff] [blame] | 327 | time::seconds(4)); // very short timeout |
Alexander Afanasyev | a16abd2 | 2014-01-31 18:12:29 -0800 | [diff] [blame] | 328 | |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 329 | BOOST_CHECK_MESSAGE(m_limitedIo.run(2, time::seconds(10)) == LimitedIo::EXCEED_OPS, |
| 330 | "TcpChannel error: cannot connect or cannot accept connection"); |
| 331 | |
Alexander Afanasyev | a16abd2 | 2014-01-31 18:12:29 -0800 | [diff] [blame] | 332 | |
| 333 | BOOST_CHECK_EQUAL(m_faces.size(), 2); |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 334 | |
Alexander Afanasyev | d665530 | 2014-02-28 08:41:28 -0800 | [diff] [blame] | 335 | shared_ptr<TcpChannel> channel3 = factory.createChannel("127.0.0.1", "20072"); |
Alexander Afanasyev | a16abd2 | 2014-01-31 18:12:29 -0800 | [diff] [blame] | 336 | channel3->connect("127.0.0.1", "20070", |
| 337 | bind(&EndToEndFixture::channel_onFaceCreated, this, _1), |
| 338 | bind(&EndToEndFixture::channel_onConnectFailed, this, _1), |
Alexander Afanasyev | c1e2ee0 | 2014-02-25 17:02:07 -0800 | [diff] [blame] | 339 | time::seconds(4)); // very short timeout |
Alexander Afanasyev | a16abd2 | 2014-01-31 18:12:29 -0800 | [diff] [blame] | 340 | |
| 341 | |
Alexander Afanasyev | d665530 | 2014-02-28 08:41:28 -0800 | [diff] [blame] | 342 | shared_ptr<TcpChannel> channel4 = factory.createChannel("127.0.0.1", "20073"); |
Alexander Afanasyev | a16abd2 | 2014-01-31 18:12:29 -0800 | [diff] [blame] | 343 | |
| 344 | BOOST_CHECK_NE(channel3, channel4); |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 345 | |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 346 | scheduler::schedule(time::seconds(1), |
| 347 | bind(&TcpChannel::connect, channel4, "127.0.0.1", "20070", |
Alexander Afanasyev | a16abd2 | 2014-01-31 18:12:29 -0800 | [diff] [blame] | 348 | // does not work without static_cast |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 349 | static_cast<TcpChannel::FaceCreatedCallback>( |
| 350 | bind(&EndToEndFixture::channel_onFaceCreated, this, _1)), |
| 351 | static_cast<TcpChannel::ConnectFailedCallback>( |
| 352 | bind(&EndToEndFixture::channel_onConnectFailed, this, _1)), |
| 353 | time::seconds(4))); |
Alexander Afanasyev | a16abd2 | 2014-01-31 18:12:29 -0800 | [diff] [blame] | 354 | |
Alexander Afanasyev | eb3197f | 2014-03-17 19:28:18 -0700 | [diff] [blame] | 355 | scheduler::schedule(time::milliseconds(500), |
Alexander Afanasyev | 7329e02 | 2014-02-27 14:47:22 -0800 | [diff] [blame] | 356 | bind(&EndToEndFixture::checkFaceList, this, 4)); |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 357 | |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 358 | BOOST_CHECK_MESSAGE(m_limitedIo.run(4,// 2 connects and 2 accepts |
| 359 | time::seconds(10)) == LimitedIo::EXCEED_OPS, |
| 360 | "TcpChannel error: cannot connect or cannot accept multiple connections"); |
Alexander Afanasyev | 7329e02 | 2014-02-27 14:47:22 -0800 | [diff] [blame] | 361 | |
Alexander Afanasyev | a16abd2 | 2014-01-31 18:12:29 -0800 | [diff] [blame] | 362 | BOOST_CHECK_EQUAL(m_faces.size(), 6); |
| 363 | } |
| 364 | |
Alexander Afanasyev | a0a10fb | 2014-02-13 19:56:15 -0800 | [diff] [blame] | 365 | |
| 366 | BOOST_FIXTURE_TEST_CASE(FaceClosing, EndToEndFixture) |
| 367 | { |
Alexander Afanasyev | 0eb7065 | 2014-02-27 18:35:07 -0800 | [diff] [blame] | 368 | TcpFactory factory; |
Alexander Afanasyev | a0a10fb | 2014-02-13 19:56:15 -0800 | [diff] [blame] | 369 | |
Alexander Afanasyev | d665530 | 2014-02-28 08:41:28 -0800 | [diff] [blame] | 370 | shared_ptr<TcpChannel> channel1 = factory.createChannel("127.0.0.1", "20070"); |
| 371 | shared_ptr<TcpChannel> channel2 = factory.createChannel("127.0.0.1", "20071"); |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 372 | |
Alexander Afanasyev | a0a10fb | 2014-02-13 19:56:15 -0800 | [diff] [blame] | 373 | channel1->listen(bind(&EndToEndFixture::channel1_onFaceCreated, this, _1), |
| 374 | bind(&EndToEndFixture::channel1_onConnectFailed, this, _1)); |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 375 | |
Alexander Afanasyev | a0a10fb | 2014-02-13 19:56:15 -0800 | [diff] [blame] | 376 | channel2->connect("127.0.0.1", "20070", |
| 377 | bind(&EndToEndFixture::channel2_onFaceCreated, this, _1), |
| 378 | bind(&EndToEndFixture::channel2_onConnectFailed, this, _1), |
Alexander Afanasyev | c1e2ee0 | 2014-02-25 17:02:07 -0800 | [diff] [blame] | 379 | time::seconds(4)); // very short timeout |
Alexander Afanasyev | a0a10fb | 2014-02-13 19:56:15 -0800 | [diff] [blame] | 380 | |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 381 | BOOST_CHECK_MESSAGE(m_limitedIo.run(2, time::seconds(10)) == LimitedIo::EXCEED_OPS, |
| 382 | "TcpChannel error: cannot connect or cannot accept connection"); |
Alexander Afanasyev | a0a10fb | 2014-02-13 19:56:15 -0800 | [diff] [blame] | 383 | |
| 384 | BOOST_CHECK_EQUAL(channel1->size(), 1); |
| 385 | BOOST_CHECK_EQUAL(channel2->size(), 1); |
| 386 | |
Alexander Afanasyev | a0a10fb | 2014-02-13 19:56:15 -0800 | [diff] [blame] | 387 | BOOST_REQUIRE(static_cast<bool>(m_face1)); |
| 388 | BOOST_CHECK(static_cast<bool>(m_face2)); |
| 389 | |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 390 | // Face::close must be invoked during io run to be counted as an op |
Alexander Afanasyev | eb3197f | 2014-03-17 19:28:18 -0700 | [diff] [blame] | 391 | scheduler::schedule(time::milliseconds(100), bind(&Face::close, m_face1)); |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 392 | |
Junxiao Shi | 7e2413b | 2014-03-02 11:15:09 -0700 | [diff] [blame] | 393 | BOOST_CHECK_MESSAGE(m_limitedIo.run(2, time::seconds(10)) == LimitedIo::EXCEED_OPS, |
| 394 | "FaceClosing error: cannot properly close faces"); |
Alexander Afanasyev | a0a10fb | 2014-02-13 19:56:15 -0800 | [diff] [blame] | 395 | |
| 396 | // both faces should get closed |
| 397 | BOOST_CHECK(!static_cast<bool>(m_face1)); |
| 398 | BOOST_CHECK(!static_cast<bool>(m_face2)); |
Alexander Afanasyev | 5f1ec25 | 2014-02-28 10:59:17 -0800 | [diff] [blame] | 399 | |
Alexander Afanasyev | a0a10fb | 2014-02-13 19:56:15 -0800 | [diff] [blame] | 400 | BOOST_CHECK_EQUAL(channel1->size(), 0); |
| 401 | BOOST_CHECK_EQUAL(channel2->size(), 0); |
| 402 | } |
| 403 | |
| 404 | |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 405 | BOOST_AUTO_TEST_SUITE_END() |
| 406 | |
Junxiao Shi | d9ee45c | 2014-02-27 15:38:11 -0700 | [diff] [blame] | 407 | } // namespace tests |
Junxiao Shi | 96dc0c4 | 2014-01-30 23:51:59 -0700 | [diff] [blame] | 408 | } // namespace nfd |