1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
|
// Copyright 2012, 2013 Canonical Ltd.
// Licensed under the AGPLv3, see LICENCE file for details.
package worker
import (
"errors"
"launchpad.net/juju-core/environs"
"launchpad.net/juju-core/log"
"launchpad.net/juju-core/state"
"launchpad.net/juju-core/state/watcher"
"launchpad.net/tomb"
)
var ErrTerminateAgent = errors.New("agent should be terminated")
var loadedInvalid = func() {}
// WaitForEnviron waits for an valid environment to arrive from
// the given watcher. It terminates with tomb.ErrDying if
// it receives a value on dying.
func WaitForEnviron(w *state.EnvironConfigWatcher, dying <-chan struct{}) (environs.Environ, error) {
for {
select {
case <-dying:
return nil, tomb.ErrDying
case config, ok := <-w.Changes():
if !ok {
return nil, watcher.MustErr(w)
}
environ, err := environs.New(config)
if err == nil {
return environ, nil
}
log.Errorf("worker: loaded invalid environment configuration: %v", err)
loadedInvalid()
}
}
panic("not reached")
}
|