From 0f1d1a16a71f9a6a97f036221c6cf5b1d73d469d Mon Sep 17 00:00:00 2001 From: Stephen Birarda Date: Thu, 30 Jul 2015 17:12:42 -0700 Subject: [PATCH] actually call sendReliablePacket for write of reliable --- libraries/networking/src/udt/Socket.cpp | 2 +- tools/udt-test/src/UDTTest.cpp | 4 +++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/libraries/networking/src/udt/Socket.cpp b/libraries/networking/src/udt/Socket.cpp index 99817f9790..810eaa73e2 100644 --- a/libraries/networking/src/udt/Socket.cpp +++ b/libraries/networking/src/udt/Socket.cpp @@ -85,7 +85,7 @@ qint64 Socket::writePacket(const Packet& packet, const HifiSockAddr& sockAddr) { qint64 Socket::writePacket(std::unique_ptr packet, const HifiSockAddr& sockAddr) { if (packet->isReliable()) { - auto connection = findOrCreateConnection(sockAddr); + findOrCreateConnection(sockAddr)->sendReliablePacket(move(packet)); return 0; } diff --git a/tools/udt-test/src/UDTTest.cpp b/tools/udt-test/src/UDTTest.cpp index 810f68ccb6..f6aad9ee8a 100644 --- a/tools/udt-test/src/UDTTest.cpp +++ b/tools/udt-test/src/UDTTest.cpp @@ -143,7 +143,7 @@ void UDTTest::parseArguments() { } void UDTTest::sendInitialPackets() { - static const int NUM_INITIAL_PACKETS = 500; + static const int NUM_INITIAL_PACKETS = 10; int numPackets = std::max(NUM_INITIAL_PACKETS, _maxSendPackets); @@ -187,6 +187,8 @@ void UDTTest::sendPacket() { auto newPacket = udt::Packet::create(packetPayloadSize, _sendReliable); + _totalQueuedBytes += newPacket->getDataSize(); + // queue or send this packet by calling write packet on the socket for our target if (_sendReliable) { _socket.writePacket(std::move(newPacket), _target);