Make sure mOutputQueue capacity is never < 1 (#1680)

Robert Henigan · Henigan · web-flow · commit 2b1822947cc4 · 2021-05-04T13:44:22.000-04:00
Co-authored-by: Henigan &lt;rheniga1@MGC12Z921DLVCG.fbpld77.ford.com&gt;
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
@@ -86,7 +86,7 @@ public StreamPacketizer(IStreamListener streamListener, InputStream is, SessionT
             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
@@ -124,7 +124,7 @@ public RTPH264Packetizer(IStreamListener streamListener,
             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;
 

Original file line number	Diff line number	Diff line change
`@@ -86,7 +86,7 @@ public StreamPacketizer(IStreamListener streamListener, InputStream is, SessionT`
`86`	`86`	`bufferSize = BUFF_READ_SIZE;`
`87`	`87`	`buffer = new byte[bufferSize];`
`88`	`88`	`}`
`89`		`- mOutputQueue = new LinkedBlockingQueue<>(MAX_QUEUE_SIZE / bufferSize);`
	`89`	`+ mOutputQueue = new LinkedBlockingQueue<>(Math.max(MAX_QUEUE_SIZE / bufferSize, 1));`
`90`	`90`	`}`
`91`	`91`
`92`	`92`	`public void start() throws IOException {`
Original file line number	Diff line number	Diff line change
`@@ -124,7 +124,7 @@ public RTPH264Packetizer(IStreamListener streamListener,`
`124`	`124`	`bufferSize = MAX_DATA_SIZE_FOR_ENCRYPTED_SERVICE;`
`125`	`125`	`}`
`126`	`126`
`127`		`- mOutputQueue = new LinkedBlockingQueue<>(MAX_QUEUE_SIZE / bufferSize);`
	`127`	`+ mOutputQueue = new LinkedBlockingQueue<>(Math.max(MAX_QUEUE_SIZE / bufferSize, 1));`
`128`	`128`	`mNALUnitReader = new NALUnitReader();`
`129`	`129`	`mPayloadType = DEFAULT_RTP_PAYLOAD_TYPE;`
`130`	`130`