123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300 |
- package main
- import (
- "fmt"
- "os"
- "path/filepath"
- "sync"
- "syscall"
- "testing"
- "github.com/docker/docker/cliconfig"
- "github.com/docker/docker/pkg/integration/checker"
- "github.com/docker/docker/pkg/reexec"
- "github.com/docker/engine-api/types/swarm"
- "github.com/go-check/check"
- )
- func Test(t *testing.T) {
- reexec.Init() // This is required for external graphdriver tests
- if !isLocalDaemon {
- fmt.Println("INFO: Testing against a remote daemon")
- } else {
- fmt.Println("INFO: Testing against a local daemon")
- }
- check.TestingT(t)
- }
- func init() {
- check.Suite(&DockerSuite{})
- }
- type DockerSuite struct {
- }
- func (s *DockerSuite) TearDownTest(c *check.C) {
- unpauseAllContainers()
- deleteAllContainers()
- deleteAllImages()
- deleteAllVolumes()
- deleteAllNetworks()
- }
- func init() {
- check.Suite(&DockerRegistrySuite{
- ds: &DockerSuite{},
- })
- }
- type DockerRegistrySuite struct {
- ds *DockerSuite
- reg *testRegistryV2
- d *Daemon
- }
- func (s *DockerRegistrySuite) SetUpTest(c *check.C) {
- testRequires(c, DaemonIsLinux, RegistryHosting)
- s.reg = setupRegistry(c, false, "", "")
- s.d = NewDaemon(c)
- }
- func (s *DockerRegistrySuite) TearDownTest(c *check.C) {
- if s.reg != nil {
- s.reg.Close()
- }
- if s.d != nil {
- s.d.Stop()
- }
- s.ds.TearDownTest(c)
- }
- func init() {
- check.Suite(&DockerSchema1RegistrySuite{
- ds: &DockerSuite{},
- })
- }
- type DockerSchema1RegistrySuite struct {
- ds *DockerSuite
- reg *testRegistryV2
- d *Daemon
- }
- func (s *DockerSchema1RegistrySuite) SetUpTest(c *check.C) {
- testRequires(c, DaemonIsLinux, RegistryHosting, NotArm64)
- s.reg = setupRegistry(c, true, "", "")
- s.d = NewDaemon(c)
- }
- func (s *DockerSchema1RegistrySuite) TearDownTest(c *check.C) {
- if s.reg != nil {
- s.reg.Close()
- }
- if s.d != nil {
- s.d.Stop()
- }
- s.ds.TearDownTest(c)
- }
- func init() {
- check.Suite(&DockerRegistryAuthHtpasswdSuite{
- ds: &DockerSuite{},
- })
- }
- type DockerRegistryAuthHtpasswdSuite struct {
- ds *DockerSuite
- reg *testRegistryV2
- d *Daemon
- }
- func (s *DockerRegistryAuthHtpasswdSuite) SetUpTest(c *check.C) {
- testRequires(c, DaemonIsLinux, RegistryHosting)
- s.reg = setupRegistry(c, false, "htpasswd", "")
- s.d = NewDaemon(c)
- }
- func (s *DockerRegistryAuthHtpasswdSuite) TearDownTest(c *check.C) {
- if s.reg != nil {
- out, err := s.d.Cmd("logout", privateRegistryURL)
- c.Assert(err, check.IsNil, check.Commentf(out))
- s.reg.Close()
- }
- if s.d != nil {
- s.d.Stop()
- }
- s.ds.TearDownTest(c)
- }
- func init() {
- check.Suite(&DockerRegistryAuthTokenSuite{
- ds: &DockerSuite{},
- })
- }
- type DockerRegistryAuthTokenSuite struct {
- ds *DockerSuite
- reg *testRegistryV2
- d *Daemon
- }
- func (s *DockerRegistryAuthTokenSuite) SetUpTest(c *check.C) {
- testRequires(c, DaemonIsLinux, RegistryHosting)
- s.d = NewDaemon(c)
- }
- func (s *DockerRegistryAuthTokenSuite) TearDownTest(c *check.C) {
- if s.reg != nil {
- out, err := s.d.Cmd("logout", privateRegistryURL)
- c.Assert(err, check.IsNil, check.Commentf(out))
- s.reg.Close()
- }
- if s.d != nil {
- s.d.Stop()
- }
- s.ds.TearDownTest(c)
- }
- func (s *DockerRegistryAuthTokenSuite) setupRegistryWithTokenService(c *check.C, tokenURL string) {
- if s == nil {
- c.Fatal("registry suite isn't initialized")
- }
- s.reg = setupRegistry(c, false, "token", tokenURL)
- }
- func init() {
- check.Suite(&DockerDaemonSuite{
- ds: &DockerSuite{},
- })
- }
- type DockerDaemonSuite struct {
- ds *DockerSuite
- d *Daemon
- }
- func (s *DockerDaemonSuite) SetUpTest(c *check.C) {
- testRequires(c, DaemonIsLinux)
- s.d = NewDaemon(c)
- }
- func (s *DockerDaemonSuite) TearDownTest(c *check.C) {
- testRequires(c, DaemonIsLinux)
- if s.d != nil {
- s.d.Stop()
- }
- s.ds.TearDownTest(c)
- }
- func (s *DockerDaemonSuite) TearDownSuite(c *check.C) {
- err := filepath.Walk(daemonSockRoot, func(path string, fi os.FileInfo, err error) error {
- if err != nil {
- return err
- }
- if fi.Mode() == os.ModeSocket {
- syscall.Unlink(path)
- }
- return nil
- })
- c.Assert(err, checker.IsNil, check.Commentf("error while cleaning up daemon sockets"))
- err = os.RemoveAll(daemonSockRoot)
- c.Assert(err, checker.IsNil, check.Commentf("could not cleanup daemon socket root"))
- }
- const defaultSwarmPort = 2477
- func init() {
- check.Suite(&DockerSwarmSuite{
- ds: &DockerSuite{},
- })
- }
- type DockerSwarmSuite struct {
- ds *DockerSuite
- daemons []*SwarmDaemon
- daemonsLock sync.Mutex // protect access to daemons
- portIndex int
- }
- func (s *DockerSwarmSuite) SetUpTest(c *check.C) {
- testRequires(c, DaemonIsLinux)
- }
- func (s *DockerSwarmSuite) AddDaemon(c *check.C, joinSwarm, manager bool) *SwarmDaemon {
- d := &SwarmDaemon{
- Daemon: NewDaemon(c),
- port: defaultSwarmPort + s.portIndex,
- }
- d.listenAddr = fmt.Sprintf("0.0.0.0:%d", d.port)
- err := d.StartWithBusybox("--iptables=false", "--swarm-default-advertise-addr=lo") // avoid networking conflicts
- c.Assert(err, check.IsNil)
- if joinSwarm == true {
- if len(s.daemons) > 0 {
- tokens := s.daemons[0].joinTokens(c)
- token := tokens.Worker
- if manager {
- token = tokens.Manager
- }
- c.Assert(d.Join(swarm.JoinRequest{
- RemoteAddrs: []string{s.daemons[0].listenAddr},
- JoinToken: token,
- }), check.IsNil)
- } else {
- c.Assert(d.Init(swarm.InitRequest{}), check.IsNil)
- }
- }
- s.portIndex++
- s.daemonsLock.Lock()
- s.daemons = append(s.daemons, d)
- s.daemonsLock.Unlock()
- return d
- }
- func (s *DockerSwarmSuite) TearDownTest(c *check.C) {
- testRequires(c, DaemonIsLinux)
- s.daemonsLock.Lock()
- for _, d := range s.daemons {
- d.Stop()
- }
- s.daemons = nil
- s.daemonsLock.Unlock()
- s.portIndex = 0
- s.ds.TearDownTest(c)
- }
- func init() {
- check.Suite(&DockerTrustSuite{
- ds: &DockerSuite{},
- })
- }
- type DockerTrustSuite struct {
- ds *DockerSuite
- reg *testRegistryV2
- not *testNotary
- }
- func (s *DockerTrustSuite) SetUpTest(c *check.C) {
- testRequires(c, RegistryHosting, NotaryServerHosting)
- s.reg = setupRegistry(c, false, "", "")
- s.not = setupNotary(c)
- }
- func (s *DockerTrustSuite) TearDownTest(c *check.C) {
- if s.reg != nil {
- s.reg.Close()
- }
- if s.not != nil {
- s.not.Close()
- }
- // Remove trusted keys and metadata after test
- os.RemoveAll(filepath.Join(cliconfig.ConfigDir(), "trust"))
- s.ds.TearDownTest(c)
- }
|