diff options
| author | Max Romanov <max.romanov@nginx.com> | 2020-10-28 00:01:46 +0300 |
|---|---|---|
| committer | Max Romanov <max.romanov@nginx.com> | 2020-10-28 00:01:46 +0300 |
| commit | a5508cec7a55fe04ab66451c7510fab0e0d4577c (patch) | |
| tree | 1bc3aac4a484ed5505c90fba1a3a9587a0649f17 /src | |
| parent | 28ab1de364d048a4cb3f92179adebdd1eb851d65 (diff) | |
| download | unit-a5508cec7a55fe04ab66451c7510fab0e0d4577c.tar.gz unit-a5508cec7a55fe04ab66451c7510fab0e0d4577c.tar.bz2 | |
Libunit: added a function to discern main and worker contexts.
Diffstat (limited to 'src')
| -rw-r--r-- | src/nxt_unit.c | 11 | ||||
| -rw-r--r-- | src/nxt_unit.h | 2 |
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. * |