Mirrors/overte
3
0
Fork 0
mirror of https://github.com/overte-org/overte.git synced 2025-08-08 21:36:47 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

rename dest to destination for SendQueue

Browse source
This commit is contained in:
Stephen Birarda 2015-08-17 16:29:21 -07:00
parent feddb613e2
commit fe100695f0
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
libraries/networking/src/udt/SendQueue.cpp
View file

@ -25,14 +25,14 @@
using namespace udt; using namespace udt;
using namespace std::chrono; using namespace std::chrono;
std::unique_ptr<SendQueue> SendQueue::create(Socket* socket, HifiSockAddr dest) { std::unique_ptr<SendQueue> SendQueue::create(Socket* socket, HifiSockAddr destination) {
auto queue = std::unique_ptr<SendQueue>(new SendQueue(socket, dest)); auto queue = std::unique_ptr<SendQueue>(new SendQueue(socket, destination));
Q_ASSERT_X(socket, "SendQueue::create", "Must be called with a valid Socket*"); Q_ASSERT_X(socket, "SendQueue::create", "Must be called with a valid Socket*");
// Setup queue private thread // Setup queue private thread
QThread* thread = new QThread(); QThread* thread = new QThread();
thread->setObjectName("Networking: SendQueue " + dest.objectName()); // Name thread for easier debug thread->setObjectName("Networking: SendQueue " + destination.objectName()); // Name thread for easier debug
connect(thread, &QThread::started, queue.get(), &SendQueue::run); connect(thread, &QThread::started, queue.get(), &SendQueue::run);

2
libraries/networking/src/udt/SendQueue.h
View file

@ -37,7 +37,7 @@ class SendQueue : public QObject {
Q_OBJECT Q_OBJECT
public: public:
static std::unique_ptr<SendQueue> create(Socket* socket, HifiSockAddr dest); static std::unique_ptr<SendQueue> create(Socket* socket, HifiSockAddr destination);
void queuePacket(std::unique_ptr<Packet> packet); void queuePacket(std::unique_ptr<Packet> packet);
int getQueueSize() const { QReadLocker locker(&_packetsLock); return _packets.size(); } int getQueueSize() const { QReadLocker locker(&_packetsLock); return _packets.size(); }