segmenter.h

// Copyright 2015 Google LLC. All rights reserved.
//
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file or at
// https://developers.google.com/open-source/licenses/bsd
 
#ifndef PACKAGER_MEDIA_FORMATS_WEBM_SEGMENTER_H_
#define PACKAGER_MEDIA_FORMATS_WEBM_SEGMENTER_H_
 
#include <memory>
 
#include <mkvmuxer/mkvmuxer.h>
 
#include <packager/macros/classes.h>
#include <packager/media/base/range.h>
#include <packager/media/formats/webm/mkv_writer.h>
#include <packager/media/formats/webm/seek_head.h>
#include <packager/status.h>
 
namespace shaka {
namespace media {
 
struct MuxerOptions;
 
class AudioStreamInfo;
class MediaSample;
class MuxerListener;
class ProgressListener;
class StreamInfo;
class VideoStreamInfo;
 
namespace webm {
 
class Segmenter {
 public:
  explicit Segmenter(const MuxerOptions& options);
  virtual ~Segmenter();
 
  Status Initialize(const StreamInfo& info,
                    ProgressListener* progress_listener,
                    MuxerListener* muxer_listener);
 
  Status Finalize();
 
  Status AddSample(const MediaSample& sample);
 
  virtual Status FinalizeSegment(int64_t start_timestamp,
                                 int64_t duration_timestamp,
                                 bool is_subsegment,
                                 int64_t segment_number) = 0;
 
  virtual bool GetInitRangeStartAndEnd(uint64_t* start, uint64_t* end) = 0;
 
  virtual bool GetIndexRangeStartAndEnd(uint64_t* start, uint64_t* end) = 0;
 
  // Returns an empty vector if there are no specific ranges for the segments,
  // e.g. the media is in multiple files.
  // Otherwise, a vector of ranges for the media segments are returned.
  virtual std::vector<Range> GetSegmentRanges() = 0;
 
  float GetDurationInSeconds() const;
 
 protected:
  int64_t FromBmffTimestamp(int64_t bmff_timestamp);
  int64_t FromWebMTimecode(int64_t webm_timecode);
  Status WriteSegmentHeader(uint64_t file_size, MkvWriter* writer);
  Status SetCluster(int64_t start_webm_timecode,
                    uint64_t position,
                    MkvWriter* writer);
 
  void UpdateProgress(uint64_t progress);
  void set_progress_target(uint64_t target) { progress_target_ = target; }
 
  const MuxerOptions& options() const { return options_; }
  mkvmuxer::Cluster* cluster() { return cluster_.get(); }
  mkvmuxer::Cues* cues() { return &cues_; }
  MuxerListener* muxer_listener() { return muxer_listener_; }
  SeekHead* seek_head() { return &seek_head_; }
 
  int track_id() const { return track_id_; }
  uint64_t segment_payload_pos() const { return segment_payload_pos_; }
 
  int64_t duration() const { return duration_; }
 
  virtual Status DoInitialize() = 0;
  virtual Status DoFinalize() = 0;
 
 private:
  Status InitializeAudioTrack(const AudioStreamInfo& info,
                              mkvmuxer::AudioTrack* track);
  Status InitializeVideoTrack(const VideoStreamInfo& info,
                              mkvmuxer::VideoTrack* track);
 
  // Writes the previous frame to the file.
  Status WriteFrame(bool write_duration);
 
  // This is called when there needs to be a new (sub)segment.
  // In single-segment mode, a Cluster is a segment and there is no subsegment.
  // In multi-segment mode, a new file is a segment and the clusters in the file
  // are subsegments.
  virtual Status NewSegment(int64_t start_timestamp, bool is_subsegment) = 0;
 
  // Store the previous sample so we know which one is the last frame.
  std::shared_ptr<const MediaSample> prev_sample_;
  // The reference frame timestamp; used to populate the ReferenceBlock element
  // when writing non-keyframe BlockGroups.
  int64_t reference_frame_timestamp_ = 0;
 
  const MuxerOptions& options_;
 
  std::unique_ptr<mkvmuxer::Cluster> cluster_;
  mkvmuxer::Cues cues_;
  SeekHead seek_head_;
  mkvmuxer::SegmentInfo segment_info_;
  mkvmuxer::Tracks tracks_;
 
  MuxerListener* muxer_listener_ = nullptr;
  ProgressListener* progress_listener_ = nullptr;
  uint64_t progress_target_ = 0;
  uint64_t accumulated_progress_ = 0;
 
  int64_t first_timestamp_ = 0;
  int64_t sample_durations_[2] = {0, 0};
  size_t num_samples_ = 0;
 
  // The position (in bytes) of the start of the Segment payload in the init
  // file.  This is also the size of the header before the SeekHead.
  uint64_t segment_payload_pos_ = 0;
 
  // Indicate whether a new segment needed to be created, which is always true
  // in the beginning.
  bool new_segment_ = true;
  // Indicate whether a new subsegment needed to be created.
  bool new_subsegment_ = false;
  int track_id_ = 0;
 
  // The subset of information that we need from StreamInfo
  bool is_encrypted_ = false;
  int64_t time_scale_ = 0;
  int64_t duration_ = 0;
 
  DISALLOW_COPY_AND_ASSIGN(Segmenter);
};
 
}  // namespace webm
}  // namespace media
}  // namespace shaka
 
#endif  // PACKAGER_MEDIA_FORMATS_WEBM_SEGMENTER_H_