From 1b3c14a792bcb5317857403bb1ca87863abefe72 Mon Sep 17 00:00:00 2001 From: Cameron Gutman Date: Fri, 14 May 2021 21:07:14 -0500 Subject: [PATCH] Increase maximum input queue size --- src/InputStream.c | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/InputStream.c b/src/InputStream.c index 724f593..29f0546 100644 --- a/src/InputStream.c +++ b/src/InputStream.c @@ -31,7 +31,9 @@ typedef struct _PACKET_HOLDER { int initializeInputStream(void) { memcpy(currentAesIv, StreamConfig.remoteInputAesIv, sizeof(currentAesIv)); - LbqInitializeLinkedBlockingQueue(&packetQueue, 30); + // Set a high maximum queue size limit to ensure input isn't dropped + // while the input send thread is blocked for short periods. + LbqInitializeLinkedBlockingQueue(&packetQueue, 150); cryptoContext = PltCreateCryptoContext(); return 0;