@@ -354,19 +354,19 @@ void set_polaris_lb_mode(ngx_http_upstream_polaris_srv_conf_t* srv, ngx_http_req
354
354
ngx_http_upstream_polaris_ctx_t* ctx) {
355
355
switch (srv->polaris_lb_mode) {
356
356
case POLARIS_DEFAULT:
357
- ctx->polaris_lb_mode = polaris::kLoadBalanceTypeDefaultConfig ;
357
+ ctx->polaris_lb_mode = 0 ;
358
358
break;
359
359
case POLARIS_WEIGHTED_RANDOM:
360
- ctx->polaris_lb_mode = polaris::kLoadBalanceTypeWeightedRandom ;
360
+ ctx->polaris_lb_mode = 0 ;
361
361
break;
362
362
case POLARIS_RING_HASH:
363
- ctx->polaris_lb_mode = polaris::kLoadBalanceTypeRingHash ;
363
+ ctx->polaris_lb_mode = 1 ;
364
364
break;
365
365
case POLARIS_L5_CST_HASH:
366
- ctx->polaris_lb_mode = polaris::kLoadBalanceTypeL5CstHash ;
366
+ ctx->polaris_lb_mode = 1 ;
367
367
break;
368
368
default:
369
- ctx->polaris_lb_mode = polaris::kLoadBalanceTypeDefaultConfig ;
369
+ ctx->polaris_lb_mode = 0 ;
370
370
}
371
371
}
372
372
@@ -449,7 +449,9 @@ int polaris_get_addr(ngx_http_upstream_polaris_ctx_t* ctx) {
449
449
polaris::Instance instance;
450
450
polaris::GetOneInstanceRequest request(serviceKey);
451
451
request.SetTimeout(ctx->polaris_timeout);
452
- request.SetLoadBalanceType(ctx->polaris_lb_mode);
452
+ if (ctx->polaris_lb_mode > 0) {
453
+ request.SetLoadBalanceType(polaris::kLoadBalanceTypeRingHash);
454
+ }
453
455
set_request_hash_str(ctx, request);
454
456
455
457
if (ctx->polaris_dynamic_route_enabled) {
0 commit comments