Add more improvements

Author: Hind-M

src/serialize.cpp

@@ -100,8 +100,8 @@ namespace sparrow_ipc
 
         // arrow_arr.buffers[0] is the validity bitmap
         // arrow_arr.buffers[1] is the data buffer
-        const uint8_t* validity_bitmap = static_cast<const uint8_t*>(arrow_arr.buffers[0]);
-        const uint8_t* data_buffer = static_cast<const uint8_t*>(arrow_arr.buffers[1]);
+        const auto validity_bitmap = static_cast<const uint8_t*>(arrow_arr.buffers[0]);
+        const auto data_buffer = static_cast<const uint8_t*>(arrow_arr.buffers[1]);
 
         // Calculate the size of the validity and data buffers
         int64_t validity_size = (arrow_arr.length + arrow_alignment - 1) / arrow_alignment;
@@ -133,10 +133,10 @@ namespace sparrow_ipc
         batch_builder.Finish(batch_message_offset);
 
         // III - Append the RecordBatch message to the final buffer
-        uint32_t batch_meta_len = batch_builder.GetSize(); // Get the size of the batch metadata
-        int64_t aligned_batch_meta_len = align_to_8(batch_meta_len); // Calculate the padded length
+        const uint32_t batch_meta_len = batch_builder.GetSize(); // Get the size of the batch metadata
+        const int64_t aligned_batch_meta_len = align_to_8(batch_meta_len); // Calculate the padded length
 
-        size_t current_size = final_buffer.size(); // Get the current size (which is the end of the Schema message)
+        const size_t current_size = final_buffer.size(); // Get the current size (which is the end of the Schema message)
         // Resize the buffer to append the new message
         final_buffer.resize(current_size + sizeof(uint32_t) + aligned_batch_meta_len + body_len);
         uint8_t* dst = final_buffer.data() + current_size; // Get a pointer to where the new message will start
@@ -147,7 +147,15 @@ namespace sparrow_ipc
         // Copy the RecordBatch metadata into the buffer
         memcpy(dst, batch_builder.GetBufferPointer(), batch_meta_len);
         // Add padding to align the body to an 8-byte boundary
-        memset(dst + batch_meta_len, 0, aligned_batch_meta_len - batch_meta_len);
+        if (aligned_batch_meta_len >= batch_meta_len)
+        {
+            memset(dst + batch_meta_len, 0, aligned_batch_meta_len - batch_meta_len);
+        }
+        else
+        {
+            throw std::runtime_error("aligned_batch_meta_len should be greater than batch_meta_len");
+        }
+
         dst += aligned_batch_meta_len;
         // Copy the actual data buffers (the message body) into the buffer
         if (validity_bitmap)
@@ -157,7 +165,8 @@ namespace sparrow_ipc
         else
         {
             // If validity_bitmap is null, it means there are no nulls
-            memset(dst, 0xFF, validity_size);
+            constexpr uint8_t no_nulls_bitmap = 0xFF;
+            memset(dst, no_nulls_bitmap, validity_size);
         }
         dst += validity_size;
         if (data_buffer)
@@ -180,7 +189,7 @@ sparrow::primitive_array<T> deserialize_primitive_array(const std::vector<uint8_
     size_t current_offset = 0;
 
     // I - Deserialize the Schema message
-    uint32_t schema_meta_len;
+    uint32_t schema_meta_len = 0;
     memcpy(&schema_meta_len, buf_ptr + current_offset, sizeof(schema_meta_len));
     current_offset += sizeof(uint32_t);
     auto schema_message = org::apache::arrow::flatbuf::GetMessage(buf_ptr + current_offset);
@@ -198,7 +207,7 @@ sparrow::primitive_array<T> deserialize_primitive_array(const std::vector<uint8_
     current_offset += schema_meta_len;
 
     // II - Deserialize the RecordBatch message
-    uint32_t batch_meta_len;
+    uint32_t batch_meta_len = 0;
     memcpy(&batch_meta_len, buf_ptr + current_offset, sizeof(batch_meta_len));
     current_offset += sizeof(uint32_t);
     auto batch_message = org::apache::arrow::flatbuf::GetMessage(buf_ptr + current_offset);
@@ -220,10 +229,10 @@ sparrow::primitive_array<T> deserialize_primitive_array(const std::vector<uint8_
     int64_t validity_len = buffers_meta->Get(0)->length();
     int64_t data_len = buffers_meta->Get(1)->length();
 
-    uint8_t* validity_buffer_copy = new uint8_t[validity_len];
+    auto validity_buffer_copy = new uint8_t[validity_len];
     memcpy(validity_buffer_copy, body_ptr + buffers_meta->Get(0)->offset(), validity_len);
 
-    uint8_t* data_buffer_copy = new uint8_t[data_len];
+    auto data_buffer_copy = new uint8_t[data_len];
     memcpy(data_buffer_copy, body_ptr + buffers_meta->Get(1)->offset(), data_len);
 
     // Get name