Add locking to ensure events file is concurrency-safe

Signed-off-by: Matthew Heon <matthew.heon@pm.me>

1 files changed, 8 insertions, 0 deletions

diff --git a/libpod/events/events.go b/libpod/events/events.go
index 7db36653e..fad129eff 100644
--- a/libpod/events/events.go
+++ b/libpod/events/events.go
@@ -6,6 +6,7 @@ import (
 	"os"
 	"time"
 
+	"github.com/containers/storage"
 	"github.com/pkg/errors"
 )
 
@@ -122,6 +123,13 @@ func NewEvent(status Status) Event {
 
 // Write will record the event to the given path
 func (e *Event) Write(path string) error {
+	// We need to lock events file
+	lock, err := storage.GetLockfile(path + ".lock")
+	if err != nil {
+		return err
+	}
+	lock.Lock()
+	defer lock.Unlock()
 	f, err := os.OpenFile(path, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0700)
 	if err != nil {
 		return err