zrepl/zfs/zfscmd/zfscmd_logging.go

package zfscmd

import (
	"os/exec"
	"time"
)

// Implementation Note:
//
// Pre-events logged with debug
// Post-event without error logged with info
// Post-events with error _also_ logged with info
// (Not all errors we observe at this layer) are actual errors in higher-level layers)

func startPreLogging(c *Cmd, now time.Time) {
	c.log().Debug("starting command")
}

func startPostLogging(c *Cmd, err error, now time.Time) {
	if err == nil {
		c.log().Info("started command")
	} else {
		c.log().WithError(err).Error("cannot start command")
	}
}

func waitPreLogging(c *Cmd, now time.Time) {
	c.log().Debug("start waiting")
}

func waitPostLogging(c *Cmd, err error, now time.Time) {

	var total, system, user float64

	total = c.Runtime().Seconds()
	if ee, ok := err.(*exec.ExitError); ok {
		system = ee.ProcessState.SystemTime().Seconds()
		user = ee.ProcessState.UserTime().Seconds()
	} else {
		system = -1
		user = -1
	}

	log := c.log().
		WithField("total_time_s", total).
		WithField("systemtime_s", system).
		WithField("usertime_s", user)

	if err == nil {
		log.Info("command exited without error")
	} else {
		log.WithError(err).Info("command exited with error")
	}
}