utils.go 2.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778
  1. package main
  2. import (
  3. "io"
  4. "os"
  5. "os/exec"
  6. "time"
  7. "github.com/docker/docker/pkg/integration"
  8. )
  9. func getExitCode(err error) (int, error) {
  10. return integration.GetExitCode(err)
  11. }
  12. func processExitCode(err error) (exitCode int) {
  13. return integration.ProcessExitCode(err)
  14. }
  15. func isKilled(err error) bool {
  16. return integration.IsKilled(err)
  17. }
  18. func runCommandWithOutput(cmd *exec.Cmd) (output string, exitCode int, err error) {
  19. return integration.RunCommandWithOutput(cmd)
  20. }
  21. func runCommandWithStdoutStderr(cmd *exec.Cmd) (stdout string, stderr string, exitCode int, err error) {
  22. return integration.RunCommandWithStdoutStderr(cmd)
  23. }
  24. func runCommandWithOutputForDuration(cmd *exec.Cmd, duration time.Duration) (output string, exitCode int, timedOut bool, err error) {
  25. return integration.RunCommandWithOutputForDuration(cmd, duration)
  26. }
  27. func runCommandWithOutputAndTimeout(cmd *exec.Cmd, timeout time.Duration) (output string, exitCode int, err error) {
  28. return integration.RunCommandWithOutputAndTimeout(cmd, timeout)
  29. }
  30. func runCommand(cmd *exec.Cmd) (exitCode int, err error) {
  31. return integration.RunCommand(cmd)
  32. }
  33. func runCommandPipelineWithOutput(cmds ...*exec.Cmd) (output string, exitCode int, err error) {
  34. return integration.RunCommandPipelineWithOutput(cmds...)
  35. }
  36. func unmarshalJSON(data []byte, result interface{}) error {
  37. return integration.UnmarshalJSON(data, result)
  38. }
  39. func convertSliceOfStringsToMap(input []string) map[string]struct{} {
  40. return integration.ConvertSliceOfStringsToMap(input)
  41. }
  42. func compareDirectoryEntries(e1 []os.FileInfo, e2 []os.FileInfo) error {
  43. return integration.CompareDirectoryEntries(e1, e2)
  44. }
  45. func listTar(f io.Reader) ([]string, error) {
  46. return integration.ListTar(f)
  47. }
  48. func randomTmpDirPath(s string, platform string) string {
  49. return integration.RandomTmpDirPath(s, platform)
  50. }
  51. func consumeWithSpeed(reader io.Reader, chunkSize int, interval time.Duration, stop chan bool) (n int, err error) {
  52. return integration.ConsumeWithSpeed(reader, chunkSize, interval, stop)
  53. }
  54. func parseCgroupPaths(procCgroupData string) map[string]string {
  55. return integration.ParseCgroupPaths(procCgroupData)
  56. }
  57. func runAtDifferentDate(date time.Time, block func()) {
  58. integration.RunAtDifferentDate(date, block)
  59. }