Add checkpoint timestamp based on mtime

Signed-off-by: Michael Crosby <crosbymichael@gmail.com>

README.md

@@ -173,13 +173,15 @@ Response:
       "name" : "test1",
       "unixSockets" : false,
       "tcp" : false,
-      "shell" : false
+      "shell" : false,
+      "timestamp" : "2015-12-04T15:09:14.915868934-08:00"
    },
    {
       "name" : "test2",
       "tcp" : false,
       "unixSockets" : false,
-      "shell" : false
+      "shell" : false,
+      "timestamp" : "2015-12-04T15:09:14.915868934-08:00"
    }
 ]
 ```

api/v1/server.go

@@ -314,6 +314,7 @@ func (s *server) listCheckpoints(w http.ResponseWriter, r *http.Request) {
 			Tcp:         c.Tcp,
 			Shell:       c.Shell,
 			UnixSockets: c.UnixSockets,
+			Timestamp:   c.Timestamp,
 		})
 	}
 	if err := json.NewEncoder(w).Encode(out); err != nil {

api/v1/types.go

@@ -1,5 +1,7 @@
 package v1
 
+import "time"
+
 type State struct {
 	Containers []Container `json:"containers"`
 	Machine    Machine     `json:"machine"`
@@ -59,6 +61,7 @@ type Event struct {
 
 type Checkpoint struct {
 	Name        string    `json:"name,omitempty"`
+	Timestamp   time.Time `json:"timestamp,omitempty"`
 	Exit        bool      `json:"exit,omitempty"`
 	Tcp         bool      `json:"tcp"`
 	UnixSockets bool      `json:"unixSockets"`

delete.go

@@ -13,11 +13,10 @@ func (h *DeleteEvent) Handle(e *Event) error {
 	if container, ok := h.s.containers[e.ID]; ok {
 		if err := h.deleteContainer(container); err != nil {
 			logrus.WithField("error", err).Error("containerd: deleting container")
-		} else {
+		}
 		ContainersCounter.Dec(1)
 		h.s.containerGroup.Done()
 	}
-	}
 	return nil
 }
 

linux/linux.go

@@ -13,7 +13,6 @@ import (
 	"strconv"
 	"strings"
 	"syscall"
-	"time"
 
 	"github.com/docker/containerd/runtime"
 	"github.com/opencontainers/runc/libcontainer"
@@ -203,6 +202,7 @@ func (c *libcontainerContainer) Checkpoints() ([]runtime.Checkpoint, error) {
 	for _, fi := range files {
 		out = append(out, runtime.Checkpoint{
 			Name:      fi.Name(),
+			Timestamp: fi.ModTime(),
 		})
 	}
 	return out, nil
@@ -238,7 +238,6 @@ func (c *libcontainerContainer) Checkpoint(cp runtime.Checkpoint) error {
 	if err := c.c.Checkpoint(opts); err != nil {
 		return err
 	}
-	cp.Timestamp = time.Now()
 	return nil
 }
 

start.go

@@ -9,6 +9,7 @@ func (h *StartEvent) Handle(e *Event) error {
 	if err != nil {
 		return err
 	}
+	h.s.containerGroup.Add(1)
 	h.s.containers[e.ID] = container
 	ContainersCounter.Inc(1)
 	task := &StartTask{

worker.go

@@ -50,7 +50,6 @@ func (w *worker) Start() {
 				continue
 			}
 		}
-		w.s.containerGroup.Add(1)
 		ContainerStartTimer.UpdateSince(started)
 		t.Err <- nil
 	}