Skip to content

Commit 8a8c557

Browse files
Merge remote-tracking branch 'remotes/from/ce/main'
2 parents 2eb01cc + 2fca81e commit 8a8c557

File tree

2 files changed

+12
-3
lines changed

2 files changed

+12
-3
lines changed

helper/testhelpers/replication/testcluster.go

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -40,9 +40,14 @@ func NewReplicationSetCore(t *testing.T, conf *vault.CoreConfig, opts *vault.Tes
4040
}
4141

4242
r.Builder = func(ctx context.Context, name string, baseLogger hclog.Logger) (testcluster.VaultCluster, error) {
43-
conf, opts := teststorage.ClusterSetup(conf, opts, setup)
44-
opts.Logger = baseLogger.Named(name)
45-
return vault.NewTestCluster(t, conf, opts), nil
43+
newconf, newopts := teststorage.ClusterSetup(conf, opts, setup)
44+
newopts.Logger = baseLogger.Named(name)
45+
if opts.NumCores > 0 {
46+
opts.FirstCoreNumber += opts.NumCores
47+
} else {
48+
opts.FirstCoreNumber += 3
49+
}
50+
return vault.NewTestCluster(t, newconf, newopts), nil
4651
}
4752

4853
a, err := r.Builder(context.TODO(), "A", r.Logger)

vault/core.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4855,3 +4855,7 @@ func (c *Core) SetSealMigrationDone() {
48554855
}
48564856

48574857
var errRemovedHANode = errors.New("node has been removed from the HA cluster")
4858+
4859+
func (c *Core) CoreNumber() int {
4860+
return c.coreNumber
4861+
}

0 commit comments

Comments
 (0)