FilesExpand file tree

 master

/

docker_cli_attach_test.go

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

89 lines (69 loc) · 1.54 KB

 master

/

docker_cli_attach_test.go

Copy path

Top

File metadata and controls

• Code
• Blame

89 lines (69 loc) · 1.54 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

package main

import (

"io"

"os/exec"

"strings"

"sync"

"testing"

"time"

)

const attachWait = 5 * time.Second

func TestAttachMultipleAndRestart(t *testing.T) {

defer deleteAllContainers()

endGroup := &sync.WaitGroup{}

startGroup := &sync.WaitGroup{}

endGroup.Add(3)

startGroup.Add(3)

if err := waitForContainer("attacher", "-d", "busybox", "/bin/sh", "-c", "while true; do sleep 1; echo hello; done"); err != nil {

t.Fatal(err)

}

startDone := make(chan struct{})

endDone := make(chan struct{})

go func() {

endGroup.Wait()

close(endDone)

}()

go func() {

startGroup.Wait()

close(startDone)

}()

for i := 0; i < 3; i++ {

go func() {

c := exec.Command(dockerBinary, "attach", "attacher")

defer func() {

c.Wait()

endGroup.Done()

}()

out, err := c.StdoutPipe()

if err != nil {

t.Fatal(err)

}

if _, err := startCommand(c); err != nil {

t.Fatal(err)

}

buf := make([]byte, 1024)

if _, err := out.Read(buf); err != nil && err != io.EOF {

t.Fatal(err)

}

startGroup.Done()

if !strings.Contains(string(buf), "hello") {

t.Fatalf("unexpected output %s expected hello\n", string(buf))

}

}()

}

select {

case <-startDone:

case <-time.After(attachWait):

t.Fatalf("Attaches did not initialize properly")

}

cmd := exec.Command(dockerBinary, "kill", "attacher")

if _, err := runCommand(cmd); err != nil {

t.Fatal(err)

}

select {

case <-endDone:

case <-time.After(attachWait):

t.Fatalf("Attaches did not finish properly")

}

logDone("attach - multiple attach")

}