From 74100ad043723956126ecd14941a2ae0b3bfa124 Mon Sep 17 00:00:00 2001 From: ZappoMan Date: Thu, 15 Aug 2013 12:01:50 -0700 Subject: [PATCH] make threads sleep --- libraries/shared/src/PacketSender.cpp | 4 ++++ libraries/shared/src/ReceivedPacketProcessor.cpp | 4 ++++ 2 files changed, 8 insertions(+) diff --git a/libraries/shared/src/PacketSender.cpp b/libraries/shared/src/PacketSender.cpp index ec3a6cff7f..4c150454a3 100644 --- a/libraries/shared/src/PacketSender.cpp +++ b/libraries/shared/src/PacketSender.cpp @@ -29,6 +29,10 @@ void PacketSender::queuePacket(sockaddr& address, unsigned char* packetData, ssi } bool PacketSender::process() { + if (_packets.size() == 0) { + const uint64_t SEND_THREAD_SLEEP_INTERVAL = (1000 * 1000)/60; // check at 60fps + usleep(SEND_THREAD_SLEEP_INTERVAL); + } while (_packets.size() > 0) { NetworkPacket& packet = _packets.front(); diff --git a/libraries/shared/src/ReceivedPacketProcessor.cpp b/libraries/shared/src/ReceivedPacketProcessor.cpp index 8ab76397a2..3b6ccf5a98 100644 --- a/libraries/shared/src/ReceivedPacketProcessor.cpp +++ b/libraries/shared/src/ReceivedPacketProcessor.cpp @@ -18,6 +18,10 @@ void ReceivedPacketProcessor::queuePacket(sockaddr& address, unsigned char* pack } bool ReceivedPacketProcessor::process() { + if (_packets.size() == 0) { + const uint64_t RECEIVED_THREAD_SLEEP_INTERVAL = (1000 * 1000)/60; // check at 60fps + usleep(RECEIVED_THREAD_SLEEP_INTERVAL); + } while (_packets.size() > 0) { NetworkPacket& packet = _packets.front(); processPacket(packet.getAddress(), packet.getData(), packet.getLength());