diff --git a/pkg/media/media.go b/pkg/media/media.go index 0c9267b0..28204a7e 100644 --- a/pkg/media/media.go +++ b/pkg/media/media.go @@ -197,8 +197,7 @@ type SegmentMetadata struct { var ErrInvalidMetadata = errors.New("invalid segment metadata") func ParseSegmentAssertions(ctx context.Context, mani *manifeststore.Manifest) (*SegmentMetadata, error) { - ctx, span := otel.Tracer("signer").Start(ctx, "ParseSegmentAssertions") - defer ctx.Done() + _, span := otel.Tracer("signer").Start(ctx, "ParseSegmentAssertions") defer span.End() var ass *manifeststore.ManifestAssertion for _, a := range mani.Assertions { diff --git a/pkg/media/media_data_parser.go b/pkg/media/media_data_parser.go index bbd629bb..2ce55950 100644 --- a/pkg/media/media_data_parser.go +++ b/pkg/media/media_data_parser.go @@ -120,7 +120,7 @@ func ParseSegmentMediaData(ctx context.Context, mp4bs []byte) (*model.SegmentMed go func() { if err := HandleBusMessages(ctx, pipeline); err != nil { - log.Log(ctx, "error handling bus messages", "error", err) + log.Log(ctx, "pipeline error", "error", err) } cancel() }() diff --git a/pkg/media/thumbnail.go b/pkg/media/thumbnail.go index 680492c9..34e09604 100644 --- a/pkg/media/thumbnail.go +++ b/pkg/media/thumbnail.go @@ -57,7 +57,7 @@ func Thumbnail(ctx context.Context, r io.Reader, w io.Writer) error { NewSampleFunc: WriterNewSample(ctx, w), }) - if err := pipeline.BlockSetState(gst.StatePlaying); err != nil { + if err := pipeline.SetState(gst.StatePlaying); err != nil { return fmt.Errorf("error setting pipeline state: %w", err) }