Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

fix mp4 stts box bug. #4190

Closed
wants to merge 4 commits into from
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
24 changes: 23 additions & 1 deletion trunk/src/app/srs_app_dvr.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -642,7 +642,29 @@ srs_error_t SrsDvrPlan::on_video(SrsSharedPtrMessage* shared_video, SrsFormat* f
if (!dvr_enabled) {
return err;
}


// skip any SEI type nalus
if (format->vcodec->id == SrsVideoCodecIdAVC) {
for (int i = 0; i < format->video->nb_samples; ++i) {
SrsSample* sample = &format->video->samples[i];
SrsAvcNaluType avc_nalu_type;

if ((err = SrsVideoFrame::parse_avc_nalu_type(sample, avc_nalu_type)) != srs_success) {
return srs_error_wrap(err, "parse avc nalu_type");
}

if (avc_nalu_type == SrsAvcNaluTypeSEI) {
return err;
}
}
}

// quicktime player compatible: skip the packet without any nalu.
if (!format->is_avc_sequence_header() && format->video->nb_samples == 0) {
srs_warn("skip video segment has empty samples and is not sequence header.");
return err;
}

if ((err = segment->write_video(shared_video, format)) != srs_success) {
return srs_error_wrap(err, "write video");
}
Expand Down
91 changes: 23 additions & 68 deletions trunk/src/kernel/srs_kernel_mp4.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -3962,52 +3962,12 @@ stringstream& SrsMp4SttsEntry::dumps_detail(stringstream& ss, SrsMp4DumpContext
SrsMp4DecodingTime2SampleBox::SrsMp4DecodingTime2SampleBox()
{
type = SrsMp4BoxTypeSTTS;

index = count = 0;
}

SrsMp4DecodingTime2SampleBox::~SrsMp4DecodingTime2SampleBox()
{
}

srs_error_t SrsMp4DecodingTime2SampleBox::initialize_counter()
{
srs_error_t err = srs_success;

// If only sps/pps and no frames, there is no stts entries.
if (entries.empty()) {
return err;
}

index = 0;
if (index >= entries.size()) {
return srs_error_new(ERROR_MP4_ILLEGAL_TIMESTAMP, "illegal ts, empty stts");
}

count = entries[0].sample_count;

return err;
}

srs_error_t SrsMp4DecodingTime2SampleBox::on_sample(uint32_t sample_index, SrsMp4SttsEntry** ppentry)
{
srs_error_t err = srs_success;

if (sample_index + 1 > count) {
index++;

if (index >= entries.size()) {
return srs_error_new(ERROR_MP4_ILLEGAL_TIMESTAMP, "illegal ts, stts overflow, count=%zd", entries.size());
}

count += entries[index].sample_count;
}

*ppentry = &entries[index];

return err;
}

int SrsMp4DecodingTime2SampleBox::nb_header()
{
return SrsMp4FullBox::nb_header() + 4 + 8*(int)entries.size();
Expand Down Expand Up @@ -5062,21 +5022,15 @@ srs_error_t SrsMp4SampleManager::write_track(SrsFrameType track,
if (sample->frame_type == SrsVideoAvcFrameTypeKeyFrame) {
stss_entries.push_back(sample->index + 1);
}

if (stts) {
if (previous) {
uint32_t delta = (uint32_t)(sample->dts - previous->dts);
if (stts_entry.sample_delta == 0 || stts_entry.sample_delta == delta) {
stts_entry.sample_delta = delta;
stts_entry.sample_count++;
} else {
stts_entries.push_back(stts_entry);
stts_entry.sample_count = 1;
stts_entry.sample_delta = delta;
}
} else {
// The first sample always in the STTS table.
stts_entry.sample_count++;

if (stts && previous) {
if (sample->dts >= previous->dts && previous->nb_subsamples > 0) {
uint32_t delta = (uint32_t)(sample->dts - previous->dts) / previous->nb_subsamples;
stts_entry.sample_count = previous->nb_subsamples;
// calcaulate delta in the time-scale of the media.
// moov->mvhd->timescale which is hardcoded to 1000, sample->tbn also being hardcoded to 1000.
stts_entry.sample_delta = delta * previous->tbn / 1000;
stts_entries.push_back(stts_entry);
}
}

Expand All @@ -5097,7 +5051,10 @@ srs_error_t SrsMp4SampleManager::write_track(SrsFrameType track,
previous = sample;
}

if (stts && stts_entry.sample_count) {
if (stts && previous && previous->nb_subsamples > 0) {
stts_entry.sample_count = previous->nb_subsamples;
// Can't calculate last sample duration, so set sample_delta to 1.
stts_entry.sample_delta = 1;
stts_entries.push_back(stts_entry);
}

Expand Down Expand Up @@ -5216,11 +5173,6 @@ srs_error_t SrsMp4SampleManager::load_trak(map<uint64_t, SrsMp4Sample*>& tses, S
// Samples per chunk.
stsc->initialize_counter();

// DTS box.
if ((err = stts->initialize_counter()) != srs_success) {
return srs_error_wrap(err, "stts init counter");
}

// CTS/PTS box.
if (ctts && (err = ctts->initialize_counter()) != srs_success) {
return srs_error_wrap(err, "ctts init counter");
Expand Down Expand Up @@ -5249,13 +5201,14 @@ srs_error_t SrsMp4SampleManager::load_trak(map<uint64_t, SrsMp4Sample*>& tses, S
}
sample_relative_offset += sample_size;

SrsMp4SttsEntry* stts_entry = NULL;
if ((err = stts->on_sample(sample->index, &stts_entry)) != srs_success) {
srs_freep(sample);
return srs_error_wrap(err, "stts on sample");
}
if (previous) {
sample->pts = sample->dts = previous->dts + stts_entry->sample_delta;
uint32_t stts_index = sample->index - 1;
if (stts_index >= 0 && stts_index < stts->entries.size()) {
SrsMp4SttsEntry* stts_entry = &stts->entries[stts_index];
sample->pts = sample->dts = previous->dts + (uint64_t) stts_entry->sample_count * (uint64_t) stts_entry->sample_delta;
} else {
sample->pts = sample->dts = previous->dts;
}
}

SrsMp4CttsEntry* ctts_entry = NULL;
Expand Down Expand Up @@ -5743,7 +5696,7 @@ srs_error_t SrsMp4Encoder::initialize(ISrsWriteSeeker* ws)

ftyp->major_brand = SrsMp4BoxBrandISOM;
ftyp->minor_version = 512;
ftyp->set_compatible_brands(SrsMp4BoxBrandISOM, SrsMp4BoxBrandISO2, SrsMp4BoxBrandMP41);
ftyp->set_compatible_brands(SrsMp4BoxBrandISOM, SrsMp4BoxBrandISO2, SrsMp4BoxBrandAVC1, SrsMp4BoxBrandMP41);

int nb_data = ftyp->nb_bytes();
std::vector<char> data(nb_data);
Expand Down Expand Up @@ -5828,10 +5781,12 @@ srs_error_t SrsMp4Encoder::write_sample(
ps->type = SrsFrameTypeVideo;
ps->frame_type = (SrsVideoAvcFrameType)ft;
ps->index = nb_videos++;
ps->nb_subsamples = format->video->nb_samples;
vduration = dts;
} else if (ht == SrsMp4HandlerTypeSOUN) {
ps->type = SrsFrameTypeAudio;
ps->index = nb_audios++;
ps->nb_subsamples = format->audio->nb_samples;
aduration = dts;
} else {
srs_freep(ps);
Expand Down
15 changes: 5 additions & 10 deletions trunk/src/kernel/srs_kernel_mp4.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -1554,7 +1554,7 @@ class SrsMp4SampleDescriptionBox : public SrsMp4FullBox
};

// 8.6.1.2 Decoding Time to Sample Box (stts), for Audio/Video.
// ISO_IEC_14496-12-base-format-2012.pdf, page 48
// ISO_IEC_14496-12-base-format-2012.pdf, page 36
class SrsMp4SttsEntry
{
public:
Expand All @@ -1581,18 +1581,10 @@ class SrsMp4DecodingTime2SampleBox : public SrsMp4FullBox
public:
// An integer that gives the number of entries in the following table.
std::vector<SrsMp4SttsEntry> entries;
private:
// The index for counter to calc the dts for samples.
uint32_t index;
uint32_t count;

public:
SrsMp4DecodingTime2SampleBox();
virtual ~SrsMp4DecodingTime2SampleBox();
public:
// Initialize the counter.
virtual srs_error_t initialize_counter();
// When got an sample, index starts from 0.
virtual srs_error_t on_sample(uint32_t sample_index, SrsMp4SttsEntry** ppentry);
protected:
virtual int nb_header();
virtual srs_error_t encode_header(SrsBuffer* buf);
Expand Down Expand Up @@ -1893,6 +1885,9 @@ class SrsMp4Sample
// The sample data.
uint32_t nb_data;
uint8_t* data;
// number of nalu|audio-frames in this sample.
uint32_t nb_subsamples;

public:
SrsMp4Sample();
virtual ~SrsMp4Sample();
Expand Down
Loading