Skip to content

Commit

Permalink
core: Make manifestID logging more consistent,
Browse files Browse the repository at this point in the history
  • Loading branch information
j0sh committed Feb 12, 2020
1 parent 77327a1 commit 584d38c
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions core/orchestrator.go
Original file line number Diff line number Diff line change
Expand Up @@ -457,7 +457,7 @@ func (n *LivepeerNode) getSegmentChan(md *SegTranscodingMetadata) (SegmentChan,
}

func (n *LivepeerNode) sendToTranscodeLoop(md *SegTranscodingMetadata, seg *stream.HLSSegment) (*TranscodeResult, error) {
glog.V(common.DEBUG).Infof("Starting to transcode segment manifest=%s seqNo=%d", string(md.ManifestID), md.Seq)
glog.V(common.DEBUG).Infof("Starting to transcode segment manifestID=%s seqNo=%d", string(md.ManifestID), md.Seq)
ch, err := n.getSegmentChan(md)
if err != nil {
glog.Error("Could not find segment chan ", err)
Expand Down Expand Up @@ -536,13 +536,13 @@ func (n *LivepeerNode) transcodeSeg(config transcodeConfig, seg *stream.HLSSegme
start := time.Now()
tData, err := transcoder.Transcode(string(md.ManifestID), url, md.Profiles)
if err != nil {
glog.Errorf("Error transcoding manifest=%s segNo=%d segName=%s - %v", string(md.ManifestID), seg.SeqNo, seg.Name, err)
glog.Errorf("Error transcoding manifestID=%s segNo=%d segName=%s - %v", string(md.ManifestID), seg.SeqNo, seg.Name, err)
return terr(err)
}

tSegments := tData.Segments
if len(tSegments) != len(md.Profiles) {
glog.Errorf("Did not receive the correct number of transcoded segments; got %v expected %v manifest=%s seqNo=%d", len(tSegments),
glog.Errorf("Did not receive the correct number of transcoded segments; got %v expected %v manifestID=%s seqNo=%d", len(tSegments),
len(md.Profiles), string(md.ManifestID), seg.SeqNo)
return terr(fmt.Errorf("MismatchedSegments"))
}
Expand All @@ -559,11 +559,11 @@ func (n *LivepeerNode) transcodeSeg(config transcodeConfig, seg *stream.HLSSegme

for i := range md.Profiles {
if tSegments[i].Data == nil || len(tSegments[i].Data) < 25 {
glog.Errorf("Cannot find transcoded segment for manifest=%s seqNo=%d dataLength=%d",
glog.Errorf("Cannot find transcoded segment for manifestID=%s seqNo=%d len=%d",
string(md.ManifestID), seg.SeqNo, len(tSegments[i].Data))
return terr(fmt.Errorf("ZeroSegments"))
}
glog.V(common.DEBUG).Infof("Transcoded segment manifest=%s seqNo=%d profile=%s len=%d",
glog.V(common.DEBUG).Infof("Transcoded segment manifestID=%s seqNo=%d profile=%s len=%d",
string(md.ManifestID), seg.SeqNo, md.Profiles[i].Name, len(tSegments[i].Data))
hash := crypto.Keccak256(tSegments[i].Data)
segHashes[i] = hash
Expand Down

0 comments on commit 584d38c

Please sign in to comment.