2 files changed, 13 insertions, 0 deletions
diff --git a/src/nxt_unit.c b/src/nxt_unit.c
index 4b0f5230..6a0657c6 100644
--- a/src/nxt_unit.c
+++ b/src/nxt_unit.c
@@ -4855,6 +4855,17 @@ nxt_unit_run_shared(nxt_unit_ctx_t *ctx)
 
 
 int
+nxt_unit_is_main_ctx(nxt_unit_ctx_t *ctx)
+{
+    nxt_unit_impl_t  *lib;
+
+    lib = nxt_container_of(ctx->unit, nxt_unit_impl_t, unit);
+
+    return (ctx == &lib->main_ctx.ctx);
+}
+
+
+int
 nxt_unit_process_port_msg(nxt_unit_ctx_t *ctx, nxt_unit_port_t *port)
 {
     int  rc;
diff --git a/src/nxt_unit.h b/src/nxt_unit.h
index 52f9bc27..303d5aa1 100644
--- a/src/nxt_unit.h
+++ b/src/nxt_unit.h
@@ -210,6 +210,8 @@ int nxt_unit_run_ctx(nxt_unit_ctx_t *ctx);
 
 int nxt_unit_run_shared(nxt_unit_ctx_t *ctx);
 
+int nxt_unit_is_main_ctx(nxt_unit_ctx_t *ctx);
+
 /*
  * Receive and process one message, invoke configured callbacks.
  *