test

include/grass/defs/gis.h

@@ -668,6 +668,16 @@ void G_percent_reset(void);
 void G_progress(long, int);
 void G_set_percent_routine(int (*)(int));
 void G_unset_percent_routine(void);
+#if defined(G_USE_PROGRESS_NG)
+GProgressContext *G_progress_context_create(size_t, size_t);
+GProgressContext *G_progress_context_create_time(size_t, long);
+GProgressContext *G_progress_context_create_increment(size_t);
+void G_progress_context_destroy(GProgressContext *);
+void G_progress_update(GProgressContext *, size_t);
+void G_progress_log(GProgressContext *, const char *);
+void G_progress_context_set_sink(GProgressContext *, const GProgressSink *);
+void G_progress_increment(GProgressContext *, size_t);
+#endif // G_USE_PROGRESS_NG
 
 /* popen.c */
 void G_popen_clear(struct Popen *);

include/grass/gis.h

@@ -20,6 +20,7 @@
 /*============================= Include Files ==============================*/
 
 /* System include files */
+#include <stdbool.h>
 #include <stdio.h>
 #include <stdarg.h>
 
@@ -59,6 +60,26 @@ static const char *GRASS_copyright UNUSED = "GRASS GNU GPL licensed Software";
 #define FALLTHROUGH ((void)0)
 #endif
 
+/*!
+    \def G_HAS_ATOMICS
+    \brief A macro that signals whether C11 atomic operations are supported.
+ */
+#if __STDC_VERSION__ < 201112L || defined(__STDC_NO_ATOMICS__)
+#define G_HAS_ATOMICS 0
+#else
+#define G_HAS_ATOMICS 1
+#endif
+
+/*!
+    \def G_USE_PROGRESS_NG
+    \brief A macro indicating if concurrency progress reporting can be used.
+ */
+#if defined(G_HAS_ATOMICS) && defined(HAVE_PTHREAD_H)
+#define G_USE_PROGRESS_NG 1
+#else
+#define G_USE_PROGRESS_NG 0
+#endif
+
 /* GRASS version, GRASS date, git short hash of last change in GRASS headers
  * (and anything else in include)
  */
@@ -727,6 +748,42 @@ struct ilist {
     int alloc_values;
 };
 
+#if defined(G_USE_PROGRESS_NG)
+/// Opaque handle that owns telemetry state for one progress-reporting stream.
+///
+/// A `GProgressContext` isolates queued events, progress thresholds, and the
+/// optional consumer thread used by the `G_progress_context_*()` APIs so that
+/// concurrent operations can report progress independently.
+typedef struct GProgressContext GProgressContext;
+
+/// Snapshot of a progress update delivered to sink callbacks.
+///
+/// `GProgressEvent` reports the completed and total work units for a queued
+/// progress emission, together with the derived percentage in the range
+/// `0.0 ... 100.0` and a terminal flag that becomes `true` once completion
+/// reaches the declared total.
+typedef struct {
+    size_t completed;
+    size_t total;
+    double percent;   // 0.0 ... 100.0
+    bool is_terminal; // completed >= total and total > 0
+} GProgressEvent;
+
+typedef void (*GProgressCallback)(const GProgressEvent *event, void *user_data);
+typedef void (*GLogCallback)(const char *message, void *user_data);
+
+/// Callback bundle used to receive progress and log output.
+///
+/// `GProgressSink` lets callers redirect telemetry emitted by the progress
+/// APIs. Each callback is optional; when present, it receives the supplied
+/// `user_data` pointer unchanged for every event dispatched through the sink.
+typedef struct {
+    GProgressCallback on_progress; // optional
+    GLogCallback on_log;           // optional
+    void *user_data;               // opaque sink context
+} GProgressSink;
+#endif // G_USE_PROGRESS_NG
+
 /*============================== Prototypes ================================*/
 
 /* Since there are so many prototypes for the gis library they are stored */