diff --git a/cmd/vidforward/main.go b/cmd/vidforward/main.go index 95723f50..202463e4 100644 --- a/cmd/vidforward/main.go +++ b/cmd/vidforward/main.go @@ -300,6 +300,7 @@ func (m *broadcastManager) control(w http.ResponseWriter, r *http.Request) { default: m.errorLogWrite(m.log, w, "unhandled http method", "method", r.Method) } + m.log.Info("finished handling control request") } // slate handles slate API requests to upload a new slate video. @@ -447,11 +448,13 @@ func (m *broadcastManager) createOrUpdate(broadcast Broadcast) error { maybeOld = &broadcast } + m.log.Debug("attempting to start init or start pipeline") var err error maybeOld.rv, err = m.initOrStartPipeline(maybeOld.rv, broadcast.urls) if err != nil { return fmt.Errorf("could not get revid pipeline: %w", err) } + m.log.Debug("finished attempting to init or start pipeline") // If the URLS have changed, we need to update the revid pipeline. // We won't enter this if we've just created a new revid pipeline. @@ -462,6 +465,7 @@ func (m *broadcastManager) createOrUpdate(broadcast Broadcast) error { if err != nil { return fmt.Errorf("could not update revid: %w", err) } + m.log.Debug("finished updating pipeline config") } // If the status has changed, we need to update accordingly.