nxt_upstream_round_robin.c (20:4dc92b438f58) nxt_upstream_round_robin.c (65:10688b89aa16)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8

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

67 nxt_upstream_peer_t *up;
68 nxt_job_sockaddr_parse_t *jbs;
69 nxt_upstream_round_robin_t *urr;
70 nxt_upstream_round_robin_peer_t *peer;
71
72 jbs = obj;
73 up = jbs->resolve.job.data;
74
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8

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

67 nxt_upstream_peer_t *up;
68 nxt_job_sockaddr_parse_t *jbs;
69 nxt_upstream_round_robin_t *urr;
70 nxt_upstream_round_robin_peer_t *peer;
71
72 jbs = obj;
73 up = jbs->resolve.job.data;
74
75 urr = nxt_mem_zalloc(up->mem_pool, sizeof(nxt_upstream_round_robin_t));
75 urr = nxt_mp_zget(up->mem_pool, sizeof(nxt_upstream_round_robin_t));
76 if (nxt_slow_path(urr == NULL)) {
77 goto fail;
78 }
79
80 urr->npeers = jbs->resolve.count;
81
76 if (nxt_slow_path(urr == NULL)) {
77 goto fail;
78 }
79
80 urr->npeers = jbs->resolve.count;
81
82 peer = nxt_mem_zalloc(up->mem_pool,
83 urr->npeers * sizeof(nxt_upstream_round_robin_peer_t));
82 peer = nxt_mp_zget(up->mem_pool,
83 urr->npeers * sizeof(nxt_upstream_round_robin_peer_t));
84 if (nxt_slow_path(peer == NULL)) {
85 goto fail;
86 }
87
88 urr->peers = peer;
89
90 for (i = 0; i < urr->npeers; i++) {
91 peer[i].weight = 1;

--- 109 unchanged lines hidden ---
84 if (nxt_slow_path(peer == NULL)) {
85 goto fail;
86 }
87
88 urr->peers = peer;
89
90 for (i = 0; i < urr->npeers; i++) {
91 peer[i].weight = 1;

--- 109 unchanged lines hidden ---