@@ -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