Fix minor issues reported by CodeQL (#421)

apache · Mar 27, 2024 · 763b85c · 763b85c
1 parent 788227e
commit 763b85c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/lib/lz4/lz4.cc b/lib/lz4/lz4.cc
@@ -1175,9 +1175,9 @@ FORCE_INLINE int LZ4_decompress_generic(
                 s = *ip++;
                 length += s;
             } while (likely((endOnInput) ? ip < iend - RUN_MASK : 1) && (s == 255));
-            if ((safeDecode) && unlikely((size_t)(op + length) < (size_t)(op)))
+            if ((safeDecode) && unlikely(length >= (size_t)(oend - op)))
                 goto _output_error; /* overflow detection */
-            if ((safeDecode) && unlikely((size_t)(ip + length) < (size_t)(ip)))
+            if ((safeDecode) && unlikely(length >= (size_t)(iend - ip)))
                 goto _output_error; /* overflow detection */
         }
 
@@ -1220,7 +1220,7 @@ FORCE_INLINE int LZ4_decompress_generic(
                 s = *ip++;
                 length += s;
             } while (s == 255);
-            if ((safeDecode) && unlikely((size_t)(op + length) < (size_t)op))
+            if ((safeDecode) && unlikely(length >= (size_t)(oend - op)))
                 goto _output_error; /* overflow detection */
         }
         length += MINMATCH;

diff --git a/perf/PerfProducer.cc b/perf/PerfProducer.cc
@@ -160,7 +160,7 @@ void startPerfProducer(const Arguments& args, pulsar::ProducerConfiguration& pro
         limiter = std::make_shared<pulsar::RateLimiter>(args.rate);
     }
 
-    producerList.resize(args.numTopics * args.numProducers);
+    producerList.resize((size_t)args.numTopics * args.numProducers);
     for (int i = 0; i < args.numTopics; i++) {
         std::string topic = (args.numTopics == 1) ? args.topic : args.topic + "-" + std::to_string(i);
         LOG_INFO("Adding " << args.numProducers << " producers on topic " << topic);