fix flaky calltype test

finos · Nov 16, 2024 · 4e01e0d · 4e01e0d
1 parent 880ddeb
commit 4e01e0d
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 6 deletions.
diff --git a/test/integration/emulator/FakeUdpEndpoint.cpp b/test/integration/emulator/FakeUdpEndpoint.cpp
@@ -257,6 +257,7 @@ bool FakeUdpEndpoint::openPort(uint16_t port)
     }
 
     _localPort.setPort(port);
+    logger::info("adding %s to network", "FakeUdpEndpoint", _localPort.toString().c_str());
     _network->addLocal(this);
     _state = Endpoint::State::CREATED;
     return true;
@@ -341,10 +342,6 @@ void FakeUdpEndpoint::onReceive(fakenet::Protocol protocol,
 
 bool FakeUdpEndpoint::hasIp(const transport::SocketAddress& target)
 {
-    if (_state != State::CONNECTED)
-    {
-        return false;
-    }
     return target == _localPort;
 }
 

diff --git a/test/transport/FakeNetwork.cpp b/test/transport/FakeNetwork.cpp
@@ -143,9 +143,18 @@ void Internet::process(const uint64_t timestamp)
                     packet->data,
                     packet->length,
                     timestamp);
+                packet.reset();
                 break;
             }
         }
+        if (packet)
+        {
+            logger::debug("no destination for %s, %zuB, nodes %zu",
+                "Internet",
+                packet->target.toString().c_str(),
+                packet->length,
+                _nodes.size());
+        }
     }
 
     {
@@ -276,7 +285,7 @@ void Firewall::dispatchNAT(const Packet& packet, const uint64_t timestamp)
                     toString(packet.protocol),
                     packet.source.toString().c_str(),
                     packet.target.toString().c_str(),
-                    mapping.first.toString().c_str());
+                    portPair->lanPort.ipToString().c_str());
                 endpoint->onReceive(packet.protocol,
                     packet.source,
                     portPair->lanPort,
@@ -373,7 +382,9 @@ transport::SocketAddress Firewall::acquirePortMapping(const Protocol protocol, c
     }
 
     auto publicAddress = (source.getFamily() == AF_INET6 ? _publicIpv6 : _publicIpv4);
-    while (portMap.contains(transport::SocketAddress(publicAddress, ++_portCount))) {}
+    while (portMap.contains(transport::SocketAddress(publicAddress, ++_portCount)))
+    {
+    }
 
     return addPortMapping(protocol, source, _portCount);
 }
@@ -521,6 +532,7 @@ std::shared_ptr<Internet> InternetRunner::getNetwork()
 void InternetRunner::internetThreadRun()
 {
     concurrency::setThreadName("Internet");
+    logger::info("internet thread started at interval %" PRIu64, "InternetRunner", _tickInterval);
     while (_command != quit)
     {
         if (_command == State::running)
@@ -531,12 +543,14 @@ void InternetRunner::internetThreadRun()
         }
         else if (_command == paused)
         {
+            logger::info("internet thread paused...", "InternetRunner");
             _state = paused;
             while (_command == paused)
             {
                 // check in to TimeTurner if enabled
                 utils::Time::nanoSleep(utils::Time::ms * 10);
             }
+            logger::info("internet thread resumed...", "InternetRunner");
         }
     }
 }