pull/5586/head
Matthew Hooker 9 years ago
parent 46f41d1f12
commit 3e3768ec3e
No known key found for this signature in database
GPG Key ID: 7B5F933D9CE8C6A1

@ -194,20 +194,12 @@ func (b *coreBuild) Run(originalUi Ui, cache Cache) ([]Artifact, error) {
// Add a hook for the provisioners if we have provisioners // Add a hook for the provisioners if we have provisioners
if len(b.provisioners) > 0 { if len(b.provisioners) > 0 {
provisioners := make([]Provisioner, len(b.provisioners))
provisionerTypes := make([]string, len(b.provisioners))
for i, p := range b.provisioners {
provisioners[i] = p.provisioner
provisionerTypes[i] = p.pType
}
if _, ok := hooks[HookProvision]; !ok { if _, ok := hooks[HookProvision]; !ok {
hooks[HookProvision] = make([]Hook, 0, 1) hooks[HookProvision] = make([]Hook, 0, 1)
} }
hooks[HookProvision] = append(hooks[HookProvision], &ProvisionHook{ hooks[HookProvision] = append(hooks[HookProvision], &ProvisionHook{
Provisioners: provisioners, Provisioners: b.provisioners,
ProvisionerTypes: provisionerTypes,
}) })
} }

@ -30,8 +30,7 @@ type Provisioner interface {
type ProvisionHook struct { type ProvisionHook struct {
// The provisioners to run as part of the hook. These should already // The provisioners to run as part of the hook. These should already
// be prepared (by calling Prepare) at some earlier stage. // be prepared (by calling Prepare) at some earlier stage.
Provisioners []Provisioner Provisioners []coreBuildProvisioner
ProvisionerTypes []string
lock sync.Mutex lock sync.Mutex
runningProvisioner Provisioner runningProvisioner Provisioner
@ -58,13 +57,19 @@ func (h *ProvisionHook) Run(name string, ui Ui, comm Communicator, data interfac
h.runningProvisioner = nil h.runningProvisioner = nil
}() }()
for i, p := range h.Provisioners { for _, p := range h.Provisioners {
h.lock.Lock() h.lock.Lock()
h.runningProvisioner = p h.runningProvisioner = p.provisioner
h.lock.Unlock() h.lock.Unlock()
ts := CheckpointReporter.AddSpan(h.ProvisionerTypes[i], "provisioner", p) var pConfig interface{}
err := p.Provision(ui, comm) if len(p.config) > 0 {
pConfig = p.config[0]
}
ts := CheckpointReporter.AddSpan(p.pType, "provisioner", pConfig)
err := p.provisioner.Provision(ui, comm)
ts.End(err) ts.End(err)
if err != nil { if err != nil {
return err return err

@ -23,8 +23,10 @@ func TestProvisionHook(t *testing.T) {
var data interface{} = nil var data interface{} = nil
hook := &ProvisionHook{ hook := &ProvisionHook{
Provisioners: []Provisioner{pA, pB}, Provisioners: []coreBuildProvisioner{
ProvisionerTypes: []string{"", ""}, {"", pA, nil},
{"", pB, nil},
},
} }
hook.Run("foo", ui, comm, data) hook.Run("foo", ui, comm, data)
@ -47,8 +49,10 @@ func TestProvisionHook_nilComm(t *testing.T) {
var data interface{} = nil var data interface{} = nil
hook := &ProvisionHook{ hook := &ProvisionHook{
Provisioners: []Provisioner{pA, pB}, Provisioners: []coreBuildProvisioner{
ProvisionerTypes: []string{"", ""}, {"", pA, nil},
{"", pB, nil},
},
} }
err := hook.Run("foo", ui, comm, data) err := hook.Run("foo", ui, comm, data)
@ -74,8 +78,9 @@ func TestProvisionHook_cancel(t *testing.T) {
} }
hook := &ProvisionHook{ hook := &ProvisionHook{
Provisioners: []Provisioner{p}, Provisioners: []coreBuildProvisioner{
ProvisionerTypes: []string{""}, {"", p, nil},
},
} }
finished := make(chan struct{}) finished := make(chan struct{})

Loading…
Cancel
Save