core_example: close memory leak in FUZZER code

Author: Grok Compression

examples/core/core_decompress.cpp

@@ -580,7 +580,65 @@ int main([[maybe_unused]] int argc, [[maybe_unused]] const char** argv)
   // initialize library
   grk_initialize(nullptr, numThreads);
 
-// #define TEST_FUZZER
+  // initialize decompress parameters
+  grk_decompress_parameters decompressParams = {};
+  decompressParams.core.skip_allocate_composite = !doStore;
+  // differential: disable as it breaks differential decompression
+  if(!doDifferential)
+  {
+    decompressParams.asynchronous = true;
+    decompressParams.simulate_synchronous = true;
+  }
+
+  bool fromBuffer = fileOpt->count() == 0;
+  if(dWindowOpt->count() > 0)
+  {
+    decompressParams.dw_x0 = dwindow[0];
+    decompressParams.dw_y0 = dwindow[1];
+    decompressParams.dw_x1 = dwindow[2];
+    decompressParams.dw_y1 = dwindow[3];
+    printf("Window set to %f,%f,%f,%f\n", dwindow[0], dwindow[1], dwindow[2], dwindow[3]);
+  }
+
+  grk_image* image = nullptr;
+  const char* inputFileStr = nullptr;
+  bool useCallbacks = false;
+  if(useCallbacks && !fromBuffer && isNetwork(inputFilePath))
+  {
+    printf("[WARNING] Disabling callbacks for network file %s\n", inputFilePath.c_str());
+    useCallbacks = false;
+  }
+
+  bool differentialByLayer = true;
+  if(layersOpt->count() > 0 && maxLayers == 0)
+    differentialByLayer = false;
+  bool differentialByResolution = true;
+  if(resOpt->count() > 0 && maxResolutions == 0)
+    differentialByResolution = false;
+
+  // if we store, then no need to cache images, otherwise we choose minimum caching - image
+  uint32_t fullCacheStrategy = doStore ? GRK_TILE_CACHE_NONE : GRK_TILE_CACHE_IMAGE;
+
+  // if true, decompress a particular tile, otherwise decompress
+  // all tiles
+  bool decompressTile = tileOpt->count() > 0;
+
+  grk_object* codec_diff = nullptr;
+  grk_object* codec_full = nullptr;
+  grk_header_info headerInfo = {};
+  std::pair<grk_object*, bool> drc;
+
+  // create j2k file stream
+  inputFileStr = inputFilePath.c_str();
+  if(fromBuffer)
+    printf("Decompressing buffer\n");
+  else
+    printf("Decompressing file %s\n", inputFilePath.c_str());
+
+  grk_stream_params streamParams = {};
+  ReadStreamInfoExample sinfo(&streamParams);
+
+#define TEST_FUZZER
 #ifdef TEST_FUZZER
   {
     grk_header_info headerInfo = {};
@@ -592,6 +650,7 @@ int main([[maybe_unused]] int argc, [[maybe_unused]] const char** argv)
     size_t len = 0;
     uint8_t* buf = nullptr;
     FILE* file = nullptr;
+    size_t bytesRead = 0;
 
     auto cleanup = [&]() {
       if(buf)
@@ -626,7 +685,7 @@ int main([[maybe_unused]] int argc, [[maybe_unused]] const char** argv)
     }
 
     // Read file into buffer
-    size_t bytesRead = fread(buf, 1, len, file);
+    bytesRead = fread(buf, 1, len, file);
     if(bytesRead != len)
     {
       fprintf(stderr, "Failed to read file: %s\n", inputFilePath.c_str());
@@ -636,11 +695,14 @@ int main([[maybe_unused]] int argc, [[maybe_unused]] const char** argv)
 
     // Close the file
     fclose(file);
+    file = nullptr;
 
     // Set stream parameters
     stream_params.buf = buf;
     stream_params.buf_len = len;
 
+    grk_initialize(nullptr, 0);
+
     // Proceed with decompression
     codec = grk_decompress_init(&stream_params, &parameters);
     if(!codec)
@@ -658,66 +720,11 @@ int main([[maybe_unused]] int argc, [[maybe_unused]] const char** argv)
       cleanup();
       return -1;
     }
+    cleanup();
+    goto beach;
   }
 #endif
 
-  // initialize decompress parameters
-  grk_decompress_parameters decompressParams = {};
-  decompressParams.core.skip_allocate_composite = !doStore;
-  // differential: disable as it breaks differential decompression
-  if(!doDifferential)
-  {
-    decompressParams.asynchronous = true;
-    decompressParams.simulate_synchronous = true;
-  }
-
-  bool fromBuffer = fileOpt->count() == 0;
-  if(dWindowOpt->count() > 0)
-  {
-    decompressParams.dw_x0 = dwindow[0];
-    decompressParams.dw_y0 = dwindow[1];
-    decompressParams.dw_x1 = dwindow[2];
-    decompressParams.dw_y1 = dwindow[3];
-    printf("Window set to %f,%f,%f,%f\n", dwindow[0], dwindow[1], dwindow[2], dwindow[3]);
-  }
-
-  grk_image* image = nullptr;
-  const char* inputFileStr = nullptr;
-  bool useCallbacks = false;
-  if(useCallbacks && !fromBuffer && isNetwork(inputFilePath))
-  {
-    printf("[WARNING] Disabling callbacks for network file %s\n", inputFilePath.c_str());
-    useCallbacks = false;
-  }
-
-  bool differentialByLayer = true;
-  if(layersOpt->count() > 0 && maxLayers == 0)
-    differentialByLayer = false;
-  bool differentialByResolution = true;
-  if(resOpt->count() > 0 && maxResolutions == 0)
-    differentialByResolution = false;
-
-  // if we store, then no need to cache images, otherwise we choose minimum caching - image
-  uint32_t fullCacheStrategy = doStore ? GRK_TILE_CACHE_NONE : GRK_TILE_CACHE_IMAGE;
-
-  // if true, decompress a particular tile, otherwise decompress
-  // all tiles
-  bool decompressTile = tileOpt->count() > 0;
-
-  grk_object* codec_diff = nullptr;
-  grk_object* codec_full = nullptr;
-  grk_header_info headerInfo = {};
-  std::pair<grk_object*, bool> drc;
-
-  // create j2k file stream
-  inputFileStr = inputFilePath.c_str();
-  if(fromBuffer)
-    printf("Decompressing buffer\n");
-  else
-    printf("Decompressing file %s\n", inputFilePath.c_str());
-
-  grk_stream_params streamParams = {};
-  ReadStreamInfoExample sinfo(&streamParams);
   if(useCallbacks)
   {
     streamParams.seek_fn = stream_seek_fn;