mirror of
https://github.com/moby/moby.git
synced 2026-01-11 10:41:43 +00:00
1f5c82b9fa
Add option- and output structs for; - Client.ContainerKill - Client.ContainerPause - Client.ContainerRemove - Client.ContainerResize - Client.ContainerRestart - Client.ContainerStart - Client.ContainerStop - Client.ContainerUnpause Signed-off-by: Sebastiaan van Stijn <github@gone.nl>
87 lines
2.1 KiB
Go
87 lines
2.1 KiB
Go
//go:build windows
|
|
|
|
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"io"
|
|
"math/rand"
|
|
"strings"
|
|
"testing"
|
|
|
|
"github.com/Microsoft/go-winio"
|
|
"github.com/moby/moby/api/types/container"
|
|
"github.com/moby/moby/api/types/mount"
|
|
"github.com/moby/moby/api/types/network"
|
|
"github.com/moby/moby/client"
|
|
"github.com/moby/moby/v2/internal/testutil"
|
|
"github.com/pkg/errors"
|
|
"gotest.tools/v3/assert"
|
|
is "gotest.tools/v3/assert/cmp"
|
|
)
|
|
|
|
func (s *DockerAPISuite) TestContainersAPICreateMountsBindNamedPipe(c *testing.T) {
|
|
// Create a host pipe to map into the container
|
|
hostPipeName := fmt.Sprintf(`\\.\pipe\docker-cli-test-pipe-%x`, rand.Uint64())
|
|
pc := &winio.PipeConfig{
|
|
SecurityDescriptor: "D:P(A;;GA;;;AU)", // Allow all users access to the pipe
|
|
}
|
|
l, err := winio.ListenPipe(hostPipeName, pc)
|
|
if err != nil {
|
|
c.Fatal(err)
|
|
}
|
|
defer l.Close()
|
|
|
|
// Asynchronously read data that the container writes to the mapped pipe.
|
|
var b []byte
|
|
ch := make(chan error)
|
|
go func() {
|
|
conn, err := l.Accept()
|
|
if err == nil {
|
|
b, err = io.ReadAll(conn)
|
|
conn.Close()
|
|
}
|
|
ch <- err
|
|
}()
|
|
|
|
containerPipeName := `\\.\pipe\docker-cli-test-pipe`
|
|
text := "hello from a pipe"
|
|
cmd := fmt.Sprintf("echo %s > %s", text, containerPipeName)
|
|
name := "test-bind-npipe"
|
|
|
|
ctx := testutil.GetContext(c)
|
|
apiClient := testEnv.APIClient()
|
|
_, err = apiClient.ContainerCreate(ctx,
|
|
client.ContainerCreateOptions{
|
|
Config: &container.Config{
|
|
Image: testEnv.PlatformDefaults.BaseImage,
|
|
Cmd: []string{"cmd", "/c", cmd},
|
|
},
|
|
HostConfig: &container.HostConfig{
|
|
Mounts: []mount.Mount{
|
|
{
|
|
Type: "npipe",
|
|
Source: hostPipeName,
|
|
Target: containerPipeName,
|
|
},
|
|
},
|
|
},
|
|
NetworkingConfig: &network.NetworkingConfig{},
|
|
Name: name,
|
|
},
|
|
)
|
|
assert.NilError(c, err)
|
|
|
|
_, err = apiClient.ContainerStart(ctx, name, client.ContainerStartOptions{})
|
|
assert.NilError(c, err)
|
|
|
|
err = <-ch
|
|
assert.NilError(c, err)
|
|
assert.Check(c, is.Equal(text, strings.TrimSpace(string(b))))
|
|
}
|
|
|
|
func mountWrapper(t *testing.T, device, target, mType, options string) error {
|
|
// This should never be called.
|
|
return errors.Errorf("there is no implementation of Mount on this platform")
|
|
}
|