mirror of
https://github.com/containers/podman
synced 2024-10-21 09:45:32 +00:00
c4fadaba6b
Signed-off-by: haircommander <pehunt@redhat.com> Closes: #1275 Approved by: mheon
136 lines
3.9 KiB
Go
136 lines
3.9 KiB
Go
package varlinkapi
|
|
|
|
import (
|
|
"context"
|
|
"strconv"
|
|
"time"
|
|
|
|
"github.com/containers/libpod/cmd/podman/shared"
|
|
"github.com/containers/libpod/cmd/podman/varlink"
|
|
"github.com/containers/libpod/libpod"
|
|
)
|
|
|
|
// getContext returns a non-nil, empty context
|
|
func getContext() context.Context {
|
|
return context.TODO()
|
|
}
|
|
|
|
func makeListContainer(containerID string, batchInfo shared.BatchContainerStruct) iopodman.ListContainerData {
|
|
var (
|
|
mounts []iopodman.ContainerMount
|
|
ports []iopodman.ContainerPortMappings
|
|
)
|
|
ns := shared.GetNamespaces(batchInfo.Pid)
|
|
|
|
for _, mount := range batchInfo.ConConfig.Spec.Mounts {
|
|
m := iopodman.ContainerMount{
|
|
Destination: mount.Destination,
|
|
Type: mount.Type,
|
|
Source: mount.Source,
|
|
Options: mount.Options,
|
|
}
|
|
mounts = append(mounts, m)
|
|
}
|
|
|
|
for _, pm := range batchInfo.ConConfig.PortMappings {
|
|
p := iopodman.ContainerPortMappings{
|
|
Host_port: strconv.Itoa(int(pm.HostPort)),
|
|
Host_ip: pm.HostIP,
|
|
Protocol: pm.Protocol,
|
|
Container_port: strconv.Itoa(int(pm.ContainerPort)),
|
|
}
|
|
ports = append(ports, p)
|
|
|
|
}
|
|
|
|
// If we find this needs to be done for other container endpoints, we should
|
|
// convert this to a separate function or a generic map from struct function.
|
|
namespace := iopodman.ContainerNameSpace{
|
|
User: ns.User,
|
|
Uts: ns.UTS,
|
|
Pidns: ns.PIDNS,
|
|
Pid: ns.PID,
|
|
Cgroup: ns.Cgroup,
|
|
Net: ns.NET,
|
|
Mnt: ns.MNT,
|
|
Ipc: ns.IPC,
|
|
}
|
|
|
|
lc := iopodman.ListContainerData{
|
|
Id: containerID,
|
|
Image: batchInfo.ConConfig.RootfsImageName,
|
|
Imageid: batchInfo.ConConfig.RootfsImageID,
|
|
Command: batchInfo.ConConfig.Spec.Process.Args,
|
|
Createdat: batchInfo.ConConfig.CreatedTime.String(),
|
|
Runningfor: time.Since(batchInfo.ConConfig.CreatedTime).String(),
|
|
Status: batchInfo.ConState.String(),
|
|
Ports: ports,
|
|
Names: batchInfo.ConConfig.Name,
|
|
Labels: batchInfo.ConConfig.Labels,
|
|
Mounts: mounts,
|
|
Containerrunning: batchInfo.ConState == libpod.ContainerStateRunning,
|
|
Namespaces: namespace,
|
|
}
|
|
if batchInfo.Size != nil {
|
|
lc.Rootfssize = batchInfo.Size.RootFsSize
|
|
lc.Rwsize = batchInfo.Size.RwSize
|
|
}
|
|
return lc
|
|
}
|
|
|
|
func makeListPodContainers(containerID string, batchInfo shared.BatchContainerStruct) iopodman.ListPodContainerInfo {
|
|
lc := iopodman.ListPodContainerInfo{
|
|
Id: containerID,
|
|
Status: batchInfo.ConState.String(),
|
|
Name: batchInfo.ConConfig.Name,
|
|
}
|
|
return lc
|
|
}
|
|
|
|
func makeListPod(pod *libpod.Pod, batchInfo shared.PsOptions) (iopodman.ListPodData, error) {
|
|
var listPodsContainers []iopodman.ListPodContainerInfo
|
|
var errPodData = iopodman.ListPodData{}
|
|
status, err := shared.GetPodStatus(pod)
|
|
if err != nil {
|
|
return errPodData, err
|
|
}
|
|
containers, err := pod.AllContainers()
|
|
if err != nil {
|
|
return errPodData, err
|
|
}
|
|
for _, ctr := range containers {
|
|
batchInfo, err := shared.BatchContainerOp(ctr, batchInfo)
|
|
if err != nil {
|
|
return errPodData, err
|
|
}
|
|
|
|
listPodsContainers = append(listPodsContainers, makeListPodContainers(ctr.ID(), batchInfo))
|
|
}
|
|
listPod := iopodman.ListPodData{
|
|
Createdat: pod.CreatedTime().String(),
|
|
Id: pod.ID(),
|
|
Name: pod.Name(),
|
|
Status: status,
|
|
Cgroup: pod.CgroupParent(),
|
|
Numberofcontainers: strconv.Itoa(len(listPodsContainers)),
|
|
Containersinfo: listPodsContainers,
|
|
}
|
|
return listPod, nil
|
|
}
|
|
|
|
func handlePodCall(call iopodman.VarlinkCall, pod *libpod.Pod, ctrErrs map[string]error, err error) error {
|
|
if err != nil && ctrErrs == nil {
|
|
return call.ReplyErrorOccurred(err.Error())
|
|
}
|
|
if ctrErrs != nil {
|
|
containerErrs := make([]iopodman.PodContainerErrorData, len(ctrErrs))
|
|
for ctr, reason := range ctrErrs {
|
|
ctrErr := iopodman.PodContainerErrorData{Containerid: ctr, Reason: reason.Error()}
|
|
containerErrs = append(containerErrs, ctrErr)
|
|
}
|
|
return call.ReplyPodContainerError(pod.ID(), containerErrs)
|
|
}
|
|
|
|
return nil
|
|
}
|