HPCC-30798 Fix potential internal error when large rows serialised in…

… roxie Signed-off-by: Gavin Halliday <[email protected]>
hpcc-systems · Nov 10, 2023 · d2b1a29 · d2b1a29
1 parent 0f3bace
commit d2b1a29
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/roxie/udplib/udptrs.cpp b/roxie/udplib/udptrs.cpp
@@ -1338,6 +1338,11 @@ class CMessagePacker : implements IMessagePacker, public CInterface
         }
         else
         {
+            //Edge case - ensure that the length of a variable length record does not span a packet
+            //this can occur when large rows > data_buffer_size are being appended to the buffer.
+            if (variable && ((data_buffer_size - data_used) < sizeof(RecordLengthType)))
+                flush(false);
+
             while (len)
             {
                 if (!part_buffer)