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.Format(time.RFC3339), 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().Format(time.RFC3339), 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 }