Skip to content

Commit e252c6d

Browse files
committed
abandon dependent on check_index(check_module) if deleting backend server
1 parent 351f9bc commit e252c6d

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

src/ngx_http_upsync_module.c

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1046,9 +1046,10 @@ ngx_http_upsync_del_peer(ngx_cycle_t *cycle,
10461046
#if (NGX_HTTP_UPSTREAM_CHECK)
10471047
ngx_http_upstream_check_delete_dynamic_peer(
10481048
tmp_peers->name, &us->addrs[j]);
1049-
tmp_peers->peer[i].check_index = NGX_MAX_VALUE;
10501049
#endif
10511050
w -= tmp_peers->peer[i].weight;
1051+
tmp_peers->peer[i].down = NGX_MAX_VALUE;
1052+
10521053
break;
10531054
}
10541055
}
@@ -2742,11 +2743,9 @@ ngx_http_upsync_del_delay_delete(ngx_event_t *event)
27422743
if (tmp_peers != NULL) {
27432744
for (i = 0; i < tmp_peers->number; i++) {
27442745

2745-
#if (NGX_HTTP_UPSTREAM_CHECK)
2746-
if (tmp_peers->peer[i].check_index != NGX_MAX_VALUE) {
2746+
if (tmp_peers->peer[i].down != NGX_MAX_VALUE) {
27472747
continue;
27482748
}
2749-
#endif
27502749

27512750
saddr = tmp_peers->peer[i].sockaddr;
27522751
if (saddr != NULL) {

0 commit comments

Comments
 (0)