fix(loadtest): apply direct dial IP assignment

2026-10-03 20:35:31 +08:00
parent 80808349fb
commit db92c41241
1 changed files with 1 additions and 3 deletions
@@ -122,9 +122,7 @@ func runAgent(ctx context.Context, cfg *Config, manifest *Manifest, machine, coo
 	if len(accounts) != cfg.UsersPerMachine {
 		return fmt.Errorf("machine %s accounts=%d expected=%d", machine, len(accounts), cfg.UsersPerMachine)
 	}
-	for i := range accounts {
-		accounts[i].Endpoint = cfg.Endpoints[machine][(accounts[i].Index-1)%len(cfg.Endpoints[machine])]
-	}
+	assignAgentEndpoints(cfg, machine, accounts)
 	if !cfg.SkipP2PPreflight {
 		if err = preflightP2P(ctx, cfg, manifest, accounts, apiKey); err != nil {
 			return err