commit 3f5655fce5a475894215a63336be1a6466b1a8f6
author Davide Pesavento <davide.pesavento@lip6.fr> Sat Aug 30 21:38:59 2014 +0200
committer Davide Pesavento <davide.pesavento@lip6.fr> Sat Aug 30 21:45:23 2014 +0200
tree dad5cf905ac4c1ed2568cfdc4a223df344d4cc5d
parent 86bc91ae56afea1147e90fb821e5dd32ed8516f8

face: Fix spurious assertion failure in StreamFace

Change-Id: Id487ae8d01ab3dc0ffa647dc69ff594f8a1d3c12
Refs: #1856

tests/daemon/face/tcp.cpp

diff --git a/tests/daemon/face/tcp.cpp b/tests/daemon/face/tcp.cpp
index 80e357d..7b0a77d 100644
--- a/tests/daemon/face/tcp.cpp
+++ b/tests/daemon/face/tcp.cpp
@@ -637,7 +637,6 @@
   shared_ptr<Face> face1;
 };
 
-
 BOOST_FIXTURE_TEST_CASE(FaceCreateTimeout, FaceCreateTimeoutFixture)
 {
   TcpFactory factory;
@@ -653,6 +652,50 @@
   BOOST_CHECK_EQUAL(static_cast<bool>(face1), false);
 }
 
+BOOST_FIXTURE_TEST_CASE(Bug1856, EndToEndFixture)
+{
+  TcpFactory factory1;
+
+  shared_ptr<TcpChannel> channel1 = factory1.createChannel("127.0.0.1", "20070");
+  factory1.createChannel("127.0.0.1", "20071");
+
+  BOOST_CHECK_EQUAL(channel1->isListening(), false);
+
+  channel1->listen(bind(&EndToEndFixture::channel1_onFaceCreated,   this, _1),
+                   bind(&EndToEndFixture::channel1_onConnectFailed, this, _1));
+
+  BOOST_CHECK_EQUAL(channel1->isListening(), true);
+
+  TcpFactory factory2;
+
+  shared_ptr<TcpChannel> channel2 = factory2.createChannel("127.0.0.2", "20070");
+  factory2.createChannel("127.0.0.2", "20071");
+
+  factory2.createFace(FaceUri("tcp://127.0.0.1:20070"),
+                      bind(&EndToEndFixture::channel2_onFaceCreated, this, _1),
+                      bind(&EndToEndFixture::channel2_onConnectFailed, this, _1));
+
+  BOOST_CHECK_MESSAGE(limitedIo.run(2, time::seconds(10)) == LimitedIo::EXCEED_OPS,
+                      "TcpChannel error: cannot connect or cannot accept connection");
+
+  BOOST_REQUIRE(static_cast<bool>(face1));
+  BOOST_REQUIRE(static_cast<bool>(face2));
+
+  std::ostringstream hugeName;
+  hugeName << "/huge-name/";
+  for (size_t i = 0; i < MAX_NDN_PACKET_SIZE; i++)
+    hugeName << 'a';
+
+  shared_ptr<Interest> interest = makeInterest("ndn:/KfczhUqVix");
+  shared_ptr<Interest> hugeInterest = makeInterest(hugeName.str());
+
+  face1->sendInterest(*hugeInterest);
+  face2->sendInterest(*interest);
+  face2->sendInterest(*interest);
+
+  limitedIo.run(LimitedIo::UNLIMITED_OPS, time::seconds(1));
+  BOOST_TEST_MESSAGE("Unexpected assertion test passed");
+}
 
 BOOST_AUTO_TEST_SUITE_END()