diff options
Diffstat (limited to '')
| -rw-r--r-- | src/nxt_upstream_round_robin.c | 194 |
1 files changed, 0 insertions, 194 deletions
diff --git a/src/nxt_upstream_round_robin.c b/src/nxt_upstream_round_robin.c index 09a3bce3..4d53c716 100644 --- a/src/nxt_upstream_round_robin.c +++ b/src/nxt_upstream_round_robin.c @@ -4,197 +4,3 @@ * Copyright (C) NGINX, Inc. */ -#include <nxt_main.h> - - -typedef struct { - int32_t weight; - int32_t effective_weight; - int32_t current_weight; - uint32_t down; /* 1 bit */ - nxt_msec_t last_accessed; - nxt_sockaddr_t *sockaddr; -} nxt_upstream_round_robin_peer_t; - - -typedef struct { - nxt_uint_t npeers; - nxt_upstream_round_robin_peer_t *peers; - nxt_thread_spinlock_t lock; -} nxt_upstream_round_robin_t; - - -static void nxt_upstream_round_robin_create(nxt_task_t *task, void *obj, - void *data); -static void nxt_upstream_round_robin_peer_error(nxt_task_t *task, void *obj, - void *data); -static void nxt_upstream_round_robin_get_peer(nxt_task_t *task, - nxt_upstream_peer_t *up); - - -void -nxt_upstream_round_robin_peer(nxt_task_t *task, nxt_upstream_peer_t *up) -{ - nxt_job_sockaddr_parse_t *jbs; - - if (up->upstream != NULL) { - nxt_upstream_round_robin_get_peer(task, up); - } - - jbs = nxt_job_create(up->mem_pool, sizeof(nxt_job_sockaddr_parse_t)); - if (nxt_slow_path(jbs == NULL)) { - up->ready_handler(task, up); - return; - } - - jbs->resolve.job.task = task; - jbs->resolve.job.data = up; - jbs->resolve.port = up->port; - jbs->resolve.log_level = NXT_LOG_ERR; - jbs->resolve.ready_handler = nxt_upstream_round_robin_create; - jbs->resolve.error_handler = nxt_upstream_round_robin_peer_error; - jbs->addr = up->addr; - - nxt_job_sockaddr_parse(jbs); -} - - -static void -nxt_upstream_round_robin_create(nxt_task_t *task, void *obj, void *data) -{ - nxt_uint_t i; - nxt_sockaddr_t *sa; - nxt_upstream_peer_t *up; - nxt_job_sockaddr_parse_t *jbs; - nxt_upstream_round_robin_t *urr; - nxt_upstream_round_robin_peer_t *peer; - - jbs = obj; - up = jbs->resolve.job.data; - - urr = nxt_mp_zget(up->mem_pool, sizeof(nxt_upstream_round_robin_t)); - if (nxt_slow_path(urr == NULL)) { - goto fail; - } - - urr->npeers = jbs->resolve.count; - - peer = nxt_mp_zget(up->mem_pool, - urr->npeers * sizeof(nxt_upstream_round_robin_peer_t)); - if (nxt_slow_path(peer == NULL)) { - goto fail; - } - - urr->peers = peer; - - for (i = 0; i < urr->npeers; i++) { - peer[i].weight = 1; - peer[i].effective_weight = 1; - - sa = jbs->resolve.sockaddrs[i]; - - /* STUB */ - sa->type = SOCK_STREAM; - - nxt_sockaddr_text(sa); - - nxt_debug(task, "upstream peer: %*s", - (size_t) sa->length, nxt_sockaddr_start(sa)); - - /* TODO: memcpy to shared memory pool. */ - peer[i].sockaddr = sa; - } - - up->upstream = urr; - - /* STUB */ - up->sockaddr = peer[0].sockaddr; - - nxt_job_destroy(task, jbs); - up->ready_handler(task, up); - - //nxt_upstream_round_robin_get_peer(up); - return; - -fail: - - nxt_job_destroy(task, jbs); - - up->ready_handler(task, up); -} - - -static void -nxt_upstream_round_robin_peer_error(nxt_task_t *task, void *obj, void *data) -{ - nxt_upstream_peer_t *up; - nxt_job_sockaddr_parse_t *jbs; - - jbs = obj; - up = jbs->resolve.job.data; - - up->ready_handler(task, up); -} - - -static void -nxt_upstream_round_robin_get_peer(nxt_task_t *task, nxt_upstream_peer_t *up) -{ - int32_t effective_weights; - nxt_uint_t i; - nxt_msec_t now; - nxt_upstream_round_robin_t *urr; - nxt_upstream_round_robin_peer_t *peer, *best; - - urr = up->upstream; - - now = task->thread->engine->timers.now; - - nxt_thread_spin_lock(&urr->lock); - - best = NULL; - effective_weights = 0; - peer = urr->peers; - - for (i = 0; i < urr->npeers; i++) { - - if (peer[i].down) { - continue; - } - -#if 0 - if (peer[i].max_fails != 0 && peer[i].fails >= peer->max_fails) { - good = peer[i].last_accessed + peer[i].fail_timeout; - - if (nxt_msec_diff(now, peer[i].last_accessed) <= 0) { - continue; - } - } -#endif - - peer[i].current_weight += peer[i].effective_weight; - effective_weights += peer[i].effective_weight; - - if (peer[i].effective_weight < peer[i].weight) { - peer[i].effective_weight++; - } - - if (best == NULL || peer[i].current_weight > best->current_weight) { - best = &peer[i]; - } - } - - if (best != NULL) { - best->current_weight -= effective_weights; - best->last_accessed = now; - - up->sockaddr = best->sockaddr; - - } else { - up->sockaddr = NULL; - } - - nxt_thread_spin_unlock(&urr->lock); - - up->ready_handler(task, up); -} |