Make sure mOutputQueue capacity is never < 1bugfix/issue_1667

2 files changed, 2 insertions, 2 deletions

diff --git a/android/sdl_android/src/main/java/com/smartdevicelink/streaming/StreamPacketizer.java b/android/sdl_android/src/main/java/com/smartdevicelink/streaming/StreamPacketizer.java
index 097afd089..5bb682741 100644
--- a/android/sdl_android/src/main/java/com/smartdevicelink/streaming/StreamPacketizer.java
+++ b/android/sdl_android/src/main/java/com/smartdevicelink/streaming/StreamPacketizer.java
@@ -86,7 +86,7 @@ public class StreamPacketizer extends AbstractPacketizer implements IVideoStream
             bufferSize = BUFF_READ_SIZE;

             buffer = new byte[bufferSize];

         }

-        mOutputQueue = new LinkedBlockingQueue<>(MAX_QUEUE_SIZE / bufferSize);

+        mOutputQueue = new LinkedBlockingQueue<>(Math.max(MAX_QUEUE_SIZE / bufferSize, 1));

     }

 

     public void start() throws IOException {

diff --git a/base/src/main/java/com/smartdevicelink/streaming/video/RTPH264Packetizer.java b/base/src/main/java/com/smartdevicelink/streaming/video/RTPH264Packetizer.java
index ce8d900ca..4e46b3632 100644
--- a/base/src/main/java/com/smartdevicelink/streaming/video/RTPH264Packetizer.java
+++ b/base/src/main/java/com/smartdevicelink/streaming/video/RTPH264Packetizer.java
@@ -124,7 +124,7 @@ public class RTPH264Packetizer extends AbstractPacketizer implements IVideoStrea
             bufferSize = MAX_DATA_SIZE_FOR_ENCRYPTED_SERVICE;
         }
 
-        mOutputQueue = new LinkedBlockingQueue<>(MAX_QUEUE_SIZE / bufferSize);
+        mOutputQueue = new LinkedBlockingQueue<>(Math.max(MAX_QUEUE_SIZE / bufferSize, 1));
         mNALUnitReader = new NALUnitReader();
         mPayloadType = DEFAULT_RTP_PAYLOAD_TYPE;