diff --git a/coordination/election/election.go b/coordination/election/election.go index b1e7d255ed7486ed61da1b41f71dc5b000ec54fd..a26350d1df769a0c4954d5f3634cb7c100e3ba64 100644 --- a/coordination/election/election.go +++ b/coordination/election/election.go @@ -122,12 +122,10 @@ func (e *Election) runOnce(ctx context.Context, data string, op Op) error { } // Invoke the leader operation. - log.Printf("we are now the leader for %s", e.path) err = op(ctx) // Resign, if the session is still valid. Use a standalone // Context to resign even on cancellation. - log.Printf("resigning leadership for %s", e.path) rctx, cancel := context.WithTimeout(context.Background(), 3*time.Second) rerr := e.election.Resign(rctx) cancel() diff --git a/transcoder/transcoder.go b/transcoder/transcoder.go index 1bb2d154a92ba77faf90ee4ba91ca4ba56c69d0f..6f986e567e5e642f252489956609cfaee8746950 100644 --- a/transcoder/transcoder.go +++ b/transcoder/transcoder.go @@ -83,6 +83,8 @@ func (t *transcoder) run(ctx context.Context) error { return err } + log.Printf("starting transcode of %s to %s", t.mount.TranscodeParams.SourcePath, t.mount.Path) + // Start liquidsoap and run until the context is canceled. cmd := exec.CommandContext(ctx, *liquidsoapBin, "-T", "-U", "-v", configFile.Name()) cmd.Stdout = os.Stderr