builder/amazon/chroot: wait for volume to beecome ready

builder/amazon/chroot/builder.go

@@ -75,6 +75,7 @@ func (b *Builder) Run(ui packer.Ui, hook packer.Hook, cache packer.Cache) (packe
 		&StepInstanceInfo{},
 		&StepSourceAMIInfo{},
 		&StepCreateVolume{},
+		//&StepAttachVolume{},
 	}
 
 	// Run!

builder/amazon/chroot/step_create_volume.go

@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"github.com/mitchellh/goamz/ec2"
 	"github.com/mitchellh/multistep"
+	awscommon "github.com/mitchellh/packer/builder/amazon/common"
 	"github.com/mitchellh/packer/packer"
 	"log"
 )
@@ -59,6 +60,31 @@ func (s *StepCreateVolume) Run(state map[string]interface{}) multistep.StepActio
 
 	// Set the volume ID so we remember to delete it later
 	s.volumeId = createVolumeResp.VolumeId
+	log.Printf("Volume ID: %s", s.volumeId)
+
+	// Wait for the volume to become ready
+	stateChange := awscommon.StateChangeConf{
+		Conn:      ec2conn,
+		Pending:   []string{"creating"},
+		StepState: state,
+		Target:    "available",
+		Refresh: func() (interface{}, string, error) {
+			resp, err := ec2conn.Volumes([]string{s.volumeId}, ec2.NewFilter())
+			if err != nil {
+				return nil, "", err
+			}
+
+			return nil, resp.Volumes[0].Status, nil
+		},
+	}
+
+	_, err = awscommon.WaitForState(&stateChange)
+	if err != nil {
+		err := fmt.Errorf("Error waiting for volume: %s", err)
+		state["error"] = err
+		ui.Error(err.Error())
+		return multistep.ActionHalt
+	}
 
 	return multistep.ActionContinue
 }

builder/amazon/common/instance.go

@@ -12,7 +12,7 @@ import (
 type StateChangeConf struct {
 	Conn      *ec2.EC2
 	Pending   []string
-	Refresh func() (interface{}, string, error)
+	Refresh   func() (interface{}, string, error)
 	StepState map[string]interface{}
 	Target    string
 }

builder/amazon/common/step_run_source_instance.go

@@ -64,7 +64,7 @@ func (s *StepRunSourceInstance) Run(state map[string]interface{}) multistep.Step
 		Conn:      ec2conn,
 		Pending:   []string{"pending"},
 		Target:    "running",
-		Refresh:  InstanceStateRefreshFunc(ec2conn, s.instance),
+		Refresh:   InstanceStateRefreshFunc(ec2conn, s.instance),
 		StepState: state,
 	}
 	latestInstance, err := WaitForState(&stateChange)
@@ -96,10 +96,10 @@ func (s *StepRunSourceInstance) Cleanup(state map[string]interface{}) {
 	}
 
 	stateChange := StateChangeConf{
-		Conn:     ec2conn,
-		Pending:  []string{"pending", "running", "shutting-down", "stopped", "stopping"},
-		Refresh:  InstanceStateRefreshFunc(ec2conn, s.instance),
-		Target:   "running",
+		Conn:    ec2conn,
+		Pending: []string{"pending", "running", "shutting-down", "stopped", "stopping"},
+		Refresh: InstanceStateRefreshFunc(ec2conn, s.instance),
+		Target:  "running",
 	}
 
 	WaitForState(&stateChange)

builder/amazon/ebs/step_stop_instance.go

@@ -31,7 +31,7 @@ func (s *stepStopInstance) Run(state map[string]interface{}) multistep.StepActio
 		Conn:      ec2conn,
 		Pending:   []string{"running", "stopping"},
 		Target:    "stopped",
-		Refresh:  awscommon.InstanceStateRefreshFunc(ec2conn, instance),
+		Refresh:   awscommon.InstanceStateRefreshFunc(ec2conn, instance),
 		StepState: state,
 	}
 	instanceRaw, err := awscommon.WaitForState(&stateChange)