Fix possible race condition when reading text file

DataDog · Jun 21, 2024 · 97f9011 · 97f9011
1 parent eca9c9c
commit 97f9011
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/src/pg_tracing_sql_functions.c b/src/pg_tracing_sql_functions.c
@@ -251,6 +251,14 @@ pg_tracing_spans(PG_FUNCTION_ARGS)
 		return (Datum) 0;
 
 	LWLockAcquire(pg_tracing_shared_state->lock, lock_mode);
+	/* There was a new write, reload the text file */
+	if (pg_tracing_shared_state->extent != qbuffer_size)
+	{
+		free(qbuffer);
+		qbuffer = qtext_load_file(&qbuffer_size);
+	}
+	Assert(pg_tracing_shared_state->extent == qbuffer_size);
+
 	for (int i = 0; i < shared_spans->end; i++)
 	{
 		span = shared_spans->spans + i;