nxt_process.c (65:10688b89aa16) nxt_process.c (77:585861a3a152)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8#include <nxt_master_process.h>

--- 86 unchanged lines hidden (view full) ---

95 if (nxt_event_engine_change(engine, interface, rt->batch) != NXT_OK) {
96 goto fail;
97 }
98
99 nxt_port_read_close(process->master_port);
100 nxt_port_write_enable(task, process->master_port);
101
102 /* A worker process port. */
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8#include <nxt_master_process.h>

--- 86 unchanged lines hidden (view full) ---

95 if (nxt_event_engine_change(engine, interface, rt->batch) != NXT_OK) {
96 goto fail;
97 }
98
99 nxt_port_read_close(process->master_port);
100 nxt_port_write_enable(task, process->master_port);
101
102 /* A worker process port. */
103 nxt_port_create(thread, process->port, process->port_handlers);
103 nxt_port_write_close(process->port);
104 nxt_port_create(task, process->port, process->port_handlers);
104
105 ret = nxt_runtime_thread_pool_create(thread, rt, rt->auxiliary_threads,
106 60000 * 1000000LL);
107 if (ret != NXT_OK) {
108 goto fail;
109 }
110
111 ret = process->start(task, rt);

--- 416 unchanged lines hidden ---
105
106 ret = nxt_runtime_thread_pool_create(thread, rt, rt->auxiliary_threads,
107 60000 * 1000000LL);
108 if (ret != NXT_OK) {
109 goto fail;
110 }
111
112 ret = process->start(task, rt);

--- 416 unchanged lines hidden ---