return int(rand.Uint32() & 0x3)
}
var countCapacityErrors int64
- n := 0
+ vmCount := int32(0)
s.stubDriver.Queue = queue
s.stubDriver.SetupVM = func(stubvm *test.StubVM) error {
if pt := stubvm.Instance().ProviderType(); pt == test.InstanceType(6).ProviderType {
atomic.AddInt64(&countCapacityErrors, 1)
return test.CapacityError{InstanceTypeSpecific: true}
}
- n++
+ n := atomic.AddInt32(&vmCount, 1)
+ c.Logf("SetupVM: instance %s n=%d", stubvm.Instance(), n)
stubvm.Boot = time.Now().Add(time.Duration(rand.Int63n(int64(5 * time.Millisecond))))
stubvm.CrunchRunDetachDelay = time.Duration(rand.Int63n(int64(10 * time.Millisecond)))
stubvm.ExecuteContainer = executeContainer
// 1 instance is completely broken, ensuring
// the boot_outcomes{outcome="failure"} metric
// is not zero
- stubvm.CrunchRunCrashRate = 1
+ stubvm.Broken = time.Now()
default:
stubvm.CrunchRunCrashRate = 0.1
stubvm.ArvMountDeadlockRate = 0.1