in testworkflow.go [440:466]
func (t *TestWorkflow) addWaitStep(stepname, vmname string) (*daisy.Step, error) {
serialOutput := &daisy.SerialOutput{}
serialOutput.Port = 1
serialOutput.SuccessMatch = successMatch
instanceSignal := &daisy.InstanceSignal{}
instanceSignal.Name = vmname
instanceSignal.Stopped = false
guestAttribute := &daisy.GuestAttribute{}
guestAttribute.Namespace = utils.GuestAttributeTestNamespace
guestAttribute.KeyName = utils.GuestAttributeTestKey
instanceSignal.SerialOutput = serialOutput
instanceSignal.GuestAttribute = guestAttribute
instanceSignal.Interval = "8s"
waitForInstances := &daisy.WaitForInstancesSignal{instanceSignal}
waitStep, err := t.wf.NewStep("wait-" + stepname)
if err != nil {
return nil, err
}
waitStep.WaitForInstancesSignal = waitForInstances
return waitStep, nil
}