testing Pre-load streamer plugins before Geant4 creates worker threads

Author: maureeungaro

.github/workflows/dockers_deploy_and_test.yml

@@ -220,7 +220,7 @@ jobs:
 
       - name: Download logs artifacts (all arches)
         if: ${{ always() }}
-        uses: actions/download-artifact@v4
+        uses: actions/download-artifact@v7
         with:
           pattern: logs-${{ env.TAG4 }}-*
           path: ${{ runner.temp }}/downloaded-logs
@@ -248,5 +248,3 @@ jobs:
           name: summary-${{ env.TAG4 }}-manifest
           path: ${{ env.MANIFEST_SUMMARY_FILE }}
           if-no-files-found: warn
-
-

.github/workflows/update-binder.yml

@@ -12,7 +12,7 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - name: Checkout binder-tutorials repo
-        uses: actions/checkout@v4
+        uses: actions/checkout@v6
         with:
           repository: gemc/binder-tutorials
           token: ${{ secrets.BINDER_REPO_PAT }}   # PAT with repo write access

gemc.cc

@@ -15,6 +15,7 @@
 #include "gui.h"
 #include "gdetectorConstruction.h"
 #include "gaction.h"
+#include "gstreamer.h"
 
 int main(int argc, char* argv[]) {
 
@@ -36,6 +37,11 @@ int main(int argc, char* argv[]) {
 	// random engine set by options
 	gemc::start_random_engine(gopts, log);
 
+	// Pre-load streamer plugins before Geant4 creates worker threads. Sanitized Linux
+	// builds can fail late dlopen() calls from workers with static TLS exhaustion.
+	auto preloaded_gstreamer_map = gstreamer::preloadGStreamerPlugins(gopts);
+	(void) preloaded_gstreamer_map;
+
 	// init geant4 run manager with then number of threads coming from options. always fails if unavailable
 	auto runManager = std::unique_ptr<G4RunManager>(G4RunManagerFactory::CreateRunManager(G4RunManagerType::Default, true, nthreads));
 

gstreamer/examples/gstreamer_example.cc

@@ -166,7 +166,12 @@ int main(int argc, char* argv[]) {
 		           "for run number 1 with variation 'default'.");
 	}
 
+	// Load streamer plugins before worker threads start. Sanitized Linux builds can fail
+	// late dlopen() calls from workers with static TLS exhaustion.
+	auto preloaded_gstreamer_map = gstreamer::preloadGStreamerPlugins(gopts);
+	(void) preloaded_gstreamer_map;
+
 	run_simulation_in_threads(nevents, nthreads, log, dynamicRoutinesMap, gopts);
 
 	return EXIT_SUCCESS;
-}
+}

gstreamer/gstreamer.h

@@ -602,4 +602,19 @@ namespace gstreamer {
 		return gstreamers;
 	}
 
-} // namespace gstreamer
+	/**
+	 * \ingroup gstreamer_core_api
+	 * \brief Preload configured streamer plugins before worker threads are started.
+	 *
+	 * Linux sanitizer builds can fail when a plugin with static TLS is first loaded from
+	 * a worker thread. Keeping this map alive preserves the dlopen handles while later
+	 * per-thread streamer instances are created.
+	 *
+	 * \param gopts Parsed options container supplying streamer definitions.
+	 * \return Shared pointer that should be retained until threaded streaming is complete.
+	 */
+	inline std::shared_ptr<const gstreamersMap> preloadGStreamerPlugins(const std::shared_ptr<GOptions>& gopts) {
+		return gstreamersMapPtr(gopts);
+	}
+
+} // namespace gstreamer

releases/0.2.md

@@ -80,4 +80,5 @@ Both x86_64 and ARM64 platforms are supported.
 - Cleaned up Meson test behavior by fixing duplicate test names and making
   ROOT-dependent tests conditional on ROOT availability
 - Using $SIM_HOME instead of $GEMC for installation paths
+- Pre-load streamer plugins before Geant4 creates worker threads 
 - Various code cleanups