mirror of
https://github.com/docker/docs.git
synced 2026-04-01 08:48:56 +07:00
d6db67d0be
With the way that provisioning was implemented, there was an issue getting connection to the UNIX socket to work with the new boot2docker 1.6rc2 ISO. This issue is related to the fact that the docker service was not truly stopped during the provisioning. This PR fixes the issue and provides some tests to help ensure that it does not come up again. Signed-off-by: Nathan LeClaire <nathan.leclaire@gmail.com>
120 lines
2.0 KiB
Go
120 lines
2.0 KiB
Go
package utils
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"io"
|
|
"net"
|
|
"os"
|
|
"path/filepath"
|
|
"runtime"
|
|
"time"
|
|
|
|
log "github.com/Sirupsen/logrus"
|
|
)
|
|
|
|
func GetHomeDir() string {
|
|
if runtime.GOOS == "windows" {
|
|
return os.Getenv("USERPROFILE")
|
|
}
|
|
return os.Getenv("HOME")
|
|
}
|
|
|
|
func GetBaseDir() string {
|
|
baseDir := os.Getenv("MACHINE_STORAGE_PATH")
|
|
if baseDir == "" {
|
|
baseDir = filepath.Join(GetHomeDir(), ".docker", "machine")
|
|
}
|
|
return baseDir
|
|
}
|
|
|
|
func GetDockerDir() string {
|
|
return filepath.Join(GetHomeDir(), ".docker")
|
|
}
|
|
|
|
func GetMachineDir() string {
|
|
return filepath.Join(GetBaseDir(), "machines")
|
|
}
|
|
|
|
func GetMachineCertDir() string {
|
|
return filepath.Join(GetBaseDir(), "certs")
|
|
}
|
|
|
|
func GetMachineCacheDir() string {
|
|
return filepath.Join(GetBaseDir(), "cache")
|
|
}
|
|
|
|
func GetUsername() string {
|
|
u := "unknown"
|
|
osUser := ""
|
|
|
|
switch runtime.GOOS {
|
|
case "darwin", "linux":
|
|
osUser = os.Getenv("USER")
|
|
case "windows":
|
|
osUser = os.Getenv("USERNAME")
|
|
}
|
|
|
|
if osUser != "" {
|
|
u = osUser
|
|
}
|
|
|
|
return u
|
|
}
|
|
|
|
func CopyFile(src, dst string) error {
|
|
in, err := os.Open(src)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
defer in.Close()
|
|
|
|
out, err := os.Create(dst)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if _, err = io.Copy(out, in); err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func WaitForSpecific(f func() bool, maxAttempts int, waitInterval time.Duration) error {
|
|
for i := 0; i < maxAttempts; i++ {
|
|
if f() {
|
|
return nil
|
|
}
|
|
time.Sleep(waitInterval)
|
|
}
|
|
return fmt.Errorf("Maximum number of retries (%d) exceeded", maxAttempts)
|
|
}
|
|
|
|
func WaitFor(f func() bool) error {
|
|
return WaitForSpecific(f, 60, 3*time.Second)
|
|
}
|
|
|
|
func WaitForDocker(ip string, daemonPort int) error {
|
|
return WaitFor(func() bool {
|
|
conn, err := net.Dial("tcp", fmt.Sprintf("%s:%d", ip, daemonPort))
|
|
if err != nil {
|
|
log.Debug("Got an error it was", err)
|
|
return false
|
|
}
|
|
conn.Close()
|
|
return true
|
|
})
|
|
}
|
|
|
|
func DumpVal(vals ...interface{}) {
|
|
for _, val := range vals {
|
|
prettyJSON, err := json.MarshalIndent(val, "", " ")
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
log.Debug(string(prettyJSON))
|
|
}
|
|
}
|