summaryrefslogtreecommitdiffhomepage
path: root/src/nxt_cycle.c
diff options
context:
space:
mode:
authorIgor Sysoev <igor@sysoev.ru>2017-02-22 15:10:28 +0300
committerIgor Sysoev <igor@sysoev.ru>2017-02-22 15:10:28 +0300
commitb379dae85e6edcb4af1ac665ab66d99e63bf34f4 (patch)
tree84b1d69d355e4722ebee02748e512306913a92d7 /src/nxt_cycle.c
parent029942f4eb7196c2cff0d0e26bc6ff274138f7d8 (diff)
downloadunit-b379dae85e6edcb4af1ac665ab66d99e63bf34f4.tar.gz
unit-b379dae85e6edcb4af1ac665ab66d99e63bf34f4.tar.bz2
Port changes.
Diffstat (limited to 'src/nxt_cycle.c')
-rw-r--r--src/nxt_cycle.c19
1 files changed, 9 insertions, 10 deletions
diff --git a/src/nxt_cycle.c b/src/nxt_cycle.c
index 81ad8ce2..e95421d2 100644
--- a/src/nxt_cycle.c
+++ b/src/nxt_cycle.c
@@ -344,34 +344,33 @@ nxt_cycle_event_engines(nxt_thread_t *thr, nxt_cycle_t *cycle)
static nxt_int_t
nxt_cycle_processes(nxt_cycle_t *cycle)
{
- nxt_uint_t n;
- nxt_process_port_t *proc, *prev;
+ nxt_uint_t n;
+ nxt_port_t *port, *prev;
/*
* Preallocate double number of previous cycle
* process slots or 2 process slots for initial cycle.
*/
- n = (cycle->previous != NULL) ? cycle->previous->processes->nelts : 1;
+ n = (cycle->previous != NULL) ? cycle->previous->ports->nelts : 1;
- cycle->processes = nxt_array_create(cycle->mem_pool, 2 * n,
- sizeof(nxt_process_port_t));
+ cycle->ports = nxt_array_create(cycle->mem_pool, 2 * n, sizeof(nxt_port_t));
- if (nxt_slow_path(cycle->processes == NULL)) {
+ if (nxt_slow_path(cycle->ports == NULL)) {
return NXT_ERROR;
}
if (cycle->previous != NULL) {
cycle->process_generation = cycle->previous->process_generation;
- prev = cycle->previous->processes->elts;
+ prev = cycle->previous->ports->elts;
while (n != 0) {
- proc = nxt_array_add(cycle->processes);
- if (nxt_slow_path(proc == NULL)) {
+ port = nxt_array_add(cycle->ports);
+ if (nxt_slow_path(port == NULL)) {
return NXT_ERROR;
}
- *proc = *prev++;
+ *port = *prev++;
n--;
}
}