diff options
Diffstat (limited to 'src/inputstreamer.cc')
| -rw-r--r-- | src/inputstreamer.cc | 16 |
1 files changed, 11 insertions, 5 deletions
diff --git a/src/inputstreamer.cc b/src/inputstreamer.cc index a1d7aa9..495f199 100644 --- a/src/inputstreamer.cc +++ b/src/inputstreamer.cc @@ -26,6 +26,8 @@ */ #include "inputstreamer.h" +#include <QApplication> + #define KEY "123456789012345678901234567890123456789012345678901234567890" #define SSRC 1234567890 #define CSRC_V 42 @@ -65,12 +67,16 @@ void InputStreamer::run() res = lrtp_create_profile(lrtp, PROFILE_OPUS, CSRC_A, OPTION_END); if(res != 0) printf("O:lrtp_create_profile (a) err: %d\n", res); - char packet[16*1024]; + char packet[64*1024]; while(running) { + if(!socket.hasPendingDatagrams()) { + qApp->processEvents(); + usleep(2000); // sleep 2ms + continue; + } qint64 packetsize = - socket.readDatagram(packet, (quint64)sizeof(packet), 0,0); + socket.readDatagram(packet, (quint64)sizeof(packet), 0, 0); if(packetsize < 1) { - usleep(1000); continue; } total += packetsize; @@ -91,13 +97,13 @@ void InputStreamer::run() Frame f(frame, ret); f.ts = ts; emit newImage(f); - printf("v"); fflush(stdout); + //printf("v"); fflush(stdout); } else if(csrc == CSRC_A) { // Audio frame Frame f(frame, ret); f.ts = ts; emit newAudio(f); - printf("a"); fflush(stdout); + //printf("a"); fflush(stdout); } else { printf("Unknown stream: CSRC: %d\n", csrc); } |