Skip to content

Commit

Permalink
Add support for mount options to API
Browse files Browse the repository at this point in the history
When creating containers the specialized mount options where not
populated via the API.

Fixes: containers#10831
Signed-off-by: Jhon Honce <jhonce@redhat.com>
  • Loading branch information
jwhonce committed Aug 26, 2021
1 parent 94c37d7 commit 84babac
Show file tree
Hide file tree
Showing 5 changed files with 52 additions and 13 deletions.
46 changes: 37 additions & 9 deletions cmd/podman/common/create_opts.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@ import (
"github.com/containers/podman/v3/pkg/domain/entities"
"github.com/containers/podman/v3/pkg/rootless"
"github.com/containers/podman/v3/pkg/specgen"
"github.com/docker/docker/api/types/mount"
"github.com/pkg/errors"
)

Expand Down Expand Up @@ -210,18 +211,30 @@ func ContainerCreateToContainerCLIOpts(cc handlers.CreateContainerConfig, rtc *c
expose = append(expose, fmt.Sprintf("%s/%s", p.Port(), p.Proto()))
}

// mounts type=tmpfs/bind,source=,dest=,opt=val
// TODO options
// mounts type=tmpfs/bind,source=...,target=...=,opt=val
mounts := make([]string, 0, len(cc.HostConfig.Mounts))
var builder strings.Builder
for _, m := range cc.HostConfig.Mounts {
mount := fmt.Sprintf("type=%s", m.Type)
if len(m.Source) > 0 {
mount += fmt.Sprintf(",source=%s", m.Source)
addField(&builder, "type", string(m.Type))
addField(&builder, "source", m.Source)
addField(&builder, "target", m.Target)
addField(&builder, "ro", strconv.FormatBool(m.ReadOnly))
addField(&builder, "consistency", string(m.Consistency))

// Map any specialized mount options that intersect between *Options and cli options
switch m.Type {
case mount.TypeBind:
addField(&builder, "bind-propagation", string(m.BindOptions.Propagation))
addField(&builder, "bind-nonrecursive", strconv.FormatBool(m.BindOptions.NonRecursive))
case mount.TypeTmpfs:
addField(&builder, "tmpfs-size", strconv.FormatInt(m.TmpfsOptions.SizeBytes, 10))
addField(&builder, "tmpfs-mode", strconv.FormatUint(uint64(m.TmpfsOptions.Mode), 10))
case mount.TypeVolume:
// All current VolumeOpts are handled above
// See vendor/github.com/containers/common/pkg/parse/parse.go:ValidateVolumeOpts()
}
if len(m.Target) > 0 {
mount += fmt.Sprintf(",dst=%s", m.Target)
}
mounts = append(mounts, mount)
mounts = append(mounts, builder.String())
builder.Reset()
}

// dns
Expand Down Expand Up @@ -622,3 +635,18 @@ func logDriver() string {
}
return ""
}

// addField is a helper function to populate mount options
func addField(b *strings.Builder, name string, value string) {
if value == "" {
return
}

if b.Len() > 0 {
b.WriteRune(',')
}
b.WriteString(name)
b.WriteRune('=')
b.WriteString(value)

}
4 changes: 2 additions & 2 deletions cmd/podman/common/volumes.go
Original file line number Diff line number Diff line change
Expand Up @@ -620,9 +620,9 @@ func getTmpfsMounts(tmpfsFlag []string) (map[string]spec.Mount, error) {

mount := spec.Mount{
Destination: filepath.Clean(destPath),
Type: string(define.TypeTmpfs),
Type: define.TypeTmpfs,
Options: options,
Source: string(define.TypeTmpfs),
Source: define.TypeTmpfs,
}
m[destPath] = mount
}
Expand Down
4 changes: 3 additions & 1 deletion pkg/api/handlers/compat/containers_create.go
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,8 @@ func CreateContainer(w http.ResponseWriter, r *http.Request) {

sg := specgen.NewSpecGenerator(imgNameOrID, cliOpts.RootFS)
if err := common.FillOutSpecGen(sg, cliOpts, args); err != nil {
utils.Error(w, "Something went wrong.", http.StatusInternalServerError, errors.Wrap(err, "fill out specgen"))
msg := "failed to translate options to specgen"
utils.Error(w, msg, http.StatusInternalServerError, errors.Wrap(err, msg))
return
}

Expand All @@ -95,5 +96,6 @@ func CreateContainer(w http.ResponseWriter, r *http.Request) {
ID: report.Id,
Warnings: []string{},
}

utils.WriteResponse(w, http.StatusCreated, createResponse)
}
8 changes: 8 additions & 0 deletions test/apiv2/20-containers.at
Original file line number Diff line number Diff line change
Expand Up @@ -366,4 +366,12 @@ t GET containers/$cid/json 200 \
.Config.Healthcheck.Timeout=30000000000 \
.Config.Healthcheck.Retries=3

# compat api: Test for mount options support
payload='{"Mounts":[{"Type":"tmpfs","Target":"/mnt/scratch","TmpfsOptions":{"SizeBytes":1024,"Mode":755}}]}'
t POST containers/create Image=$IMAGE HostConfig="$payload" 201 .Id~[0-9a-f]\\{64\\}
cid=$(jq -r '.Id' <<<"$output")
t GET containers/$cid/json 200 \
.HostConfig.Tmpfs['"/mnt/scratch"']~.*size=1024.* \
.HostConfig.Tmpfs['"/mnt/scratch"']~.*mode=755.*

t DELETE containers/$cid?v=true 204
3 changes: 2 additions & 1 deletion test/apiv2/test-apiv2
Original file line number Diff line number Diff line change
Expand Up @@ -327,7 +327,8 @@ function start_service() {
die "Cannot start service on non-localhost ($HOST)"
fi

$PODMAN_BIN --root $WORKDIR/server_root system service \
$PODMAN_BIN --root $WORKDIR/server_root --syslog=true \
system service \
--time 15 \
tcp:127.0.0.1:$PORT \
&> $WORKDIR/server.log &
Expand Down

0 comments on commit 84babac

Please sign in to comment.