Merge pull request #3019 from mheon/system_events

Add System event type and renumber, refresh events

libpod/events.go

@@ -50,6 +50,16 @@ func (p *Pod) newPodEvent(status events.Status) {
 	}
 }
 
+// newSystemEvent creates a new event for libpod as a whole.
+func (r *Runtime) newSystemEvent(status events.Status) {
+	e := events.NewEvent(status)
+	e.Type = events.System
+
+	if err := r.eventer.Write(e); err != nil {
+		logrus.Errorf("unable to write system event: %q", err)
+	}
+}
+
 // newVolumeEvent creates a new event for a libpod volume
 func (v *Volume) newVolumeEvent(status events.Status) {
 	e := events.NewEvent(status)

libpod/events/config.go

@@ -84,6 +84,9 @@ const (
 	Image Type = "image"
 	// Pod - event is related to pods
 	Pod Type = "pod"
+	// System - event is related to Podman whole and not to any specific
+	// container/pod/image/volume
+	System Type = "system"
 	// Volume - event is related to volumes
 	Volume Type = "volume"
 
@@ -123,8 +126,14 @@ const (
 	Pull Status = "pull"
 	// Push ...
 	Push Status = "push"
+	// Refresh indicates that the system refreshed the state after a
+	// reboot.
+	Refresh Status = "refresh"
 	// Remove ...
 	Remove Status = "remove"
+	// Renumber indicates that lock numbers were reallocated at user
+	// request.
+	Renumber Status = "renumber"
 	// Restore ...
 	Restore Status = "restore"
 	// Save ...

libpod/events/events.go

@@ -49,6 +49,8 @@ func (e *Event) ToHumanReadable() string {
 		humanFormat = fmt.Sprintf("%s %s %s %s (image=%s, name=%s)", e.Time, e.Type, e.Status, e.ID, e.Image, e.Name)
 	case Image:
 		humanFormat = fmt.Sprintf("%s %s %s %s %s", e.Time, e.Type, e.Status, e.ID, e.Name)
+	case System:
+		humanFormat = fmt.Sprintf("%s %s %s", e.Time, e.Type, e.Status)
 	case Volume:
 		humanFormat = fmt.Sprintf("%s %s %s %s", e.Time, e.Type, e.Status, e.Name)
 	}
@@ -85,10 +87,12 @@ func StringToType(name string) (Type, error) {
 		return Image, nil
 	case Pod.String():
 		return Pod, nil
+	case System.String():
+		return System, nil
 	case Volume.String():
 		return Volume, nil
 	}
-	return "", errors.Errorf("unknown event type %s", name)
+	return "", errors.Errorf("unknown event type %q", name)
 }
 
 // StringToStatus converts a string to an Event Status
@@ -107,7 +111,6 @@ func StringToStatus(name string) (Status, error) {
 	case Commit.String():
 		return Commit, nil
 	case Create.String():
-
 		return Create, nil
 	case Exec.String():
 		return Exec, nil
@@ -135,8 +138,14 @@ func StringToStatus(name string) (Status, error) {
 		return Pull, nil
 	case Push.String():
 		return Push, nil
+	case Refresh.String():
+		return Refresh, nil
 	case Remove.String():
 		return Remove, nil
+	case Renumber.String():
+		return Renumber, nil
+	case Restore.String():
+		return Restore, nil
 	case Save.String():
 		return Save, nil
 	case Start.String():
@@ -154,7 +163,7 @@ func StringToStatus(name string) (Status, error) {
 	case Untag.String():
 		return Untag, nil
 	}
-	return "", errors.Errorf("unknown event status %s", name)
+	return "", errors.Errorf("unknown event status %q", name)
 }
 
 func (e EventLogFile) getTail(options ReadOptions) (*tail.Tail, error) {

libpod/events/events_linux.go

@@ -1,13 +1,16 @@
 package events
 
 import (
-	"github.com/pkg/errors"
 	"strings"
+
+	"github.com/pkg/errors"
+	"github.com/sirupsen/logrus"
 )
 
 // NewEventer creates an eventer based on the eventer type
 func NewEventer(options EventerOptions) (Eventer, error) {
 	var eventer Eventer
+	logrus.Debugf("Initializing event backend %s", options.EventerType)
 	switch strings.ToUpper(options.EventerType) {
 	case strings.ToUpper(Journald.String()):
 		eventer = EventJournalD{options}

libpod/events/journal_linux.go

@@ -7,6 +7,7 @@ import (
 	"github.com/coreos/go-systemd/journal"
 	"github.com/coreos/go-systemd/sdjournal"
 	"github.com/pkg/errors"
+	"github.com/sirupsen/logrus"
 )
 
 // EventJournalD is the journald implementation of an eventer
@@ -87,7 +88,11 @@ func (e EventJournalD) Read(options ReadOptions) error {
 		}
 		newEvent, err := newEventFromJournalEntry(entry)
 		if err != nil {
-			return err
+			// We can't decode this event.
+			// Don't fail hard - that would make events unusable.
+			// Instead, log and continue.
+			logrus.Errorf("Unable to decode event: %v", err)
+			continue
 		}
 		include := true
 		for _, filter := range eventOptions {

libpod/events/logfile.go

@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"os"
 
+	"github.com/containers/storage"
 	"github.com/pkg/errors"
 )
 
@@ -15,6 +16,13 @@ type EventLogFile struct {
 
 // Writes to the log file
 func (e EventLogFile) Write(ee Event) error {
+	// We need to lock events file
+	lock, err := storage.GetLockfile(e.options.LogFilePath + ".lock")
+	if err != nil {
+		return err
+	}
+	lock.Lock()
+	defer lock.Unlock()
 	f, err := os.OpenFile(e.options.LogFilePath, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0700)
 	if err != nil {
 		return err

libpod/runtime.go

@@ -2,7 +2,6 @@ package libpod
 
 import (
 	"fmt"
-	"github.com/containers/libpod/libpod/events"
 	"io/ioutil"
 	"os"
 	"path/filepath"
@@ -12,6 +11,7 @@ import (
 	"github.com/BurntSushi/toml"
 	is "github.com/containers/image/storage"
 	"github.com/containers/image/types"
+	"github.com/containers/libpod/libpod/events"
 	"github.com/containers/libpod/libpod/image"
 	"github.com/containers/libpod/libpod/lock"
 	"github.com/containers/libpod/pkg/firewall"
@@ -754,6 +754,17 @@ func makeRuntime(runtime *Runtime) (err error) {
 		if err != nil {
 			return err
 		}
+
+		defer func() {
+			if err != nil && store != nil {
+				// Don't forcibly shut down
+				// We could be opening a store in use by another libpod
+				_, err2 := store.Shutdown(false)
+				if err2 != nil {
+					logrus.Errorf("Error removing store for partially-created runtime: %s", err2)
+				}
+			}
+		}()
 	}
 
 	runtime.store = store
@@ -780,17 +791,6 @@ func makeRuntime(runtime *Runtime) (err error) {
 	runtime.eventer = eventer
 	ir.Eventer = eventer
 
-	defer func() {
-		if err != nil && store != nil {
-			// Don't forcibly shut down
-			// We could be opening a store in use by another libpod
-			_, err2 := store.Shutdown(false)
-			if err2 != nil {
-				logrus.Errorf("Error removing store for partially-created runtime: %s", err2)
-			}
-		}
-	}()
-
 	// Set up a storage service for creating container root filesystems from
 	// images
 	storageService, err := getStorageService(runtime.store)
@@ -1074,6 +1074,8 @@ func (r *Runtime) refresh(alivePath string) error {
 	}
 	defer file.Close()
 
+	r.newSystemEvent(events.Refresh)
+
 	return nil
 }
 

libpod/runtime_renumber.go

@@ -1,6 +1,7 @@
 package libpod
 
 import (
+	"github.com/containers/libpod/libpod/events"
 	"github.com/pkg/errors"
 )
 
@@ -53,5 +54,7 @@ func (r *Runtime) renumberLocks() error {
 		}
 	}
 
+	r.newSystemEvent(events.Renumber)
+
 	return nil
 }