technocloud-public/nginx-unit
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Ruby: error checking during thread creation.

Browse Source 
Application terminates in case of thread creation failure.
This commit is contained in:
Max Romanov
2020-11-05 17:02:55 +03:00
parent fc9a012ceb
commit 2220b8258f
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/ruby/nxt_ruby.c
View File

@@ -1150,6 +1150,8 @@ nxt_ruby_ready_handler(nxt_unit_ctx_t *ctx)
} else { } else {
nxt_unit_alert(ctx, "thread #%d create failed", (int) (i + 1)); nxt_unit_alert(ctx, "thread #%d create failed", (int) (i + 1));
return NXT_UNIT_ERROR;
} }
} }
@@ -1253,7 +1255,7 @@ nxt_ruby_join_threads(nxt_unit_ctx_t *ctx, nxt_ruby_app_conf_t *c)
return; return;
} }
for(i = 0; i < c->threads - 1; i++) { for (i = 0; i < c->threads - 1; i++) {
rctx = &nxt_ruby_ctxs[i]; rctx = &nxt_ruby_ctxs[i];
if (rctx->thread != Qnil) { if (rctx->thread != Qnil) {
@@ -1264,8 +1266,10 @@ nxt_ruby_join_threads(nxt_unit_ctx_t *ctx, nxt_ruby_app_conf_t *c)
} else { } else {
nxt_unit_debug(ctx, "thread #%d not started", (int) (i + 1)); nxt_unit_debug(ctx, "thread #%d not started", (int) (i + 1));
} }
}
nxt_ruby_ctx_done(rctx); for (i = 0; i < c->threads - 1; i++) {
nxt_ruby_ctx_done(&nxt_ruby_ctxs[i]);
} }
nxt_unit_free(ctx, nxt_ruby_ctxs); nxt_unit_free(ctx, nxt_ruby_ctxs);