diff --git a/trunk/3rdparty/st-srs/event.c b/trunk/3rdparty/st-srs/event.c index c2386b054..4fea5986e 100644 --- a/trunk/3rdparty/st-srs/event.c +++ b/trunk/3rdparty/st-srs/event.c @@ -98,6 +98,7 @@ static struct _st_kqdata { int dellist_size; int dellist_cnt; int kq; + pid_t pid; } *_st_kq_data; #ifndef ST_KQ_MIN_EVTLIST_SIZE @@ -463,6 +464,7 @@ ST_HIDDEN int _st_kq_init(void) goto cleanup_kq; } fcntl(_st_kq_data->kq, F_SETFD, FD_CLOEXEC); + _st_kq_data->pid = getpid(); /* * Allocate file descriptor data array. @@ -698,6 +700,7 @@ ST_HIDDEN void _st_kq_dispatch(void) tsp = &timeout; } + retry_kevent: /* Check for I/O operations */ nfd = kevent(_st_kq_data->kq, _st_kq_data->addlist, _st_kq_data->addlist_cnt, @@ -791,6 +794,23 @@ ST_HIDDEN void _st_kq_dispatch(void) osfd = _st_kq_data->evtlist[i].ident; _ST_KQ_REVENTS(osfd) = 0; } + } else if (nfd < 0) { + if (errno == EBADF && _st_kq_data->pid != getpid()) { + /* We probably forked, reinitialize kqueue */ + if ((_st_kq_data->kq = kqueue()) < 0) { + /* There is nothing we can do here, will retry later */ + return; + } + fcntl(_st_kq_data->kq, F_SETFD, FD_CLOEXEC); + _st_kq_data->pid = getpid(); + /* Re-register all descriptors on ioq with new kqueue */ + memset(_st_kq_data->fd_data, 0, _st_kq_data->fd_data_size * sizeof(_kq_fd_data_t)); + for (q = _ST_IOQ.next; q != &_ST_IOQ; q = q->next) { + pq = _ST_POLLQUEUE_PTR(q); + _st_kq_pollset_add(pq->pds, pq->npds); + } + goto retry_kevent; + } } } diff --git a/trunk/doc/CHANGELOG.md b/trunk/doc/CHANGELOG.md index 3e3e550bf..cf8dfacd1 100644 --- a/trunk/doc/CHANGELOG.md +++ b/trunk/doc/CHANGELOG.md @@ -8,6 +8,8 @@ The changelog for SRS. ## SRS 5.0 Changelog +* v5.0, 2021-10-17, Support daemon(fork twice) for Darwin/OSX [ST#23](https://github.com/ossrs/state-threads/issues/23). v5.0.18 +* v5.0, 2021-10-16, DVR: support mp3 audio codec. (#2593) v5.0.17 * v5.0, 2021-10-03, OpenWRT: Disable mprotect of ST. 5.0.16 * v5.0, 2021-10-03, Actions: Create source tar lik srs-server-5.0.14.tar.gz * v5.0, 2021-10-02, ST: Support Cygwin64 and MIPS. 5.0.13 diff --git a/trunk/src/app/srs_app_dvr.cpp b/trunk/src/app/srs_app_dvr.cpp index e78f8b22c..f12ce74c5 100644 --- a/trunk/src/app/srs_app_dvr.cpp +++ b/trunk/src/app/srs_app_dvr.cpp @@ -462,7 +462,7 @@ srs_error_t SrsDvrMp4Segmenter::encode_audio(SrsSharedPtrMessage* audio, SrsForm SrsAudioChannels channels = format->acodec->sound_type; SrsAudioAacFrameTrait ct = format->audio->aac_packet_type; - if (ct == SrsAudioAacFrameTraitSequenceHeader) { + if (ct == SrsAudioAacFrameTraitSequenceHeader || ct == SrsAudioMp3FrameTrait) { enc->acodec = sound_format; enc->sample_rate = sound_rate; enc->sound_bits = sound_size; diff --git a/trunk/src/core/srs_core_version5.hpp b/trunk/src/core/srs_core_version5.hpp index 479cca7e7..358224cca 100644 --- a/trunk/src/core/srs_core_version5.hpp +++ b/trunk/src/core/srs_core_version5.hpp @@ -9,6 +9,6 @@ #define VERSION_MAJOR 5 #define VERSION_MINOR 0 -#define VERSION_REVISION 16 +#define VERSION_REVISION 18 #endif diff --git a/trunk/src/kernel/srs_kernel_codec.cpp b/trunk/src/kernel/srs_kernel_codec.cpp index e9aed5a8e..70c77c233 100644 --- a/trunk/src/kernel/srs_kernel_codec.cpp +++ b/trunk/src/kernel/srs_kernel_codec.cpp @@ -1388,6 +1388,7 @@ srs_error_t SrsFormat::audio_mp3_demux(SrsBuffer* stream, int64_t timestamp) audio->cts = 0; audio->dts = timestamp; + audio->aac_packet_type = SrsAudioMp3FrameTrait; // @see: E.4.2 Audio Tags, video_file_format_spec_v10_1.pdf, page 76 int8_t sound_format = stream->read_1bytes(); diff --git a/trunk/src/kernel/srs_kernel_codec.hpp b/trunk/src/kernel/srs_kernel_codec.hpp index 179d280d5..942e7007e 100644 --- a/trunk/src/kernel/srs_kernel_codec.hpp +++ b/trunk/src/kernel/srs_kernel_codec.hpp @@ -167,6 +167,11 @@ enum SrsAudioAacFrameTrait SrsAudioOpusFrameTraitRaw = 2, SrsAudioOpusFrameTraitSamplingRate = 4, SrsAudioOpusFrameTraitAudioLevel = 8, + + // 16/32 reserved for g711a/g711u + + // For MP3 + SrsAudioMp3FrameTrait = 64, }; /** diff --git a/trunk/src/kernel/srs_kernel_mp4.cpp b/trunk/src/kernel/srs_kernel_mp4.cpp index 3c62921dc..d45c45139 100644 --- a/trunk/src/kernel/srs_kernel_mp4.cpp +++ b/trunk/src/kernel/srs_kernel_mp4.cpp @@ -1812,11 +1812,16 @@ SrsAudioCodecId SrsMp4TrackBox::soun_codec() if (box->entry_count() == 0) { return SrsAudioCodecIdForbidden; } - - SrsMp4SampleEntry* entry = box->entrie_at(0); - switch(entry->type) { - case SrsMp4BoxTypeMP4A: return SrsAudioCodecIdAAC; - default: return SrsAudioCodecIdForbidden; + + SrsMp4EsdsBox* esds_box = mp4a()->esds(); + switch (esds_box->es->decConfigDescr.objectTypeIndication) { + case SrsMp4ObjectTypeAac: + return SrsAudioCodecIdAAC; + case SrsMp4ObjectTypeMp3: + case SrsMp4ObjectTypeMp1a: + return SrsAudioCodecIdMP3; + default: + return SrsAudioCodecIdForbidden; } } @@ -3429,7 +3434,7 @@ srs_error_t SrsMp4DecoderConfigDescriptor::encode_payload(SrsBuffer* buf) buf->write_3bytes(bufferSizeDB); buf->write_4bytes(maxBitrate); buf->write_4bytes(avgBitrate); - + if (decSpecificInfo && (err = decSpecificInfo->encode(buf)) != srs_success) { return srs_error_wrap(err, "encode des specific info"); } @@ -3440,7 +3445,7 @@ srs_error_t SrsMp4DecoderConfigDescriptor::encode_payload(SrsBuffer* buf) srs_error_t SrsMp4DecoderConfigDescriptor::decode_payload(SrsBuffer* buf) { srs_error_t err = srs_success; - + objectTypeIndication = (SrsMp4ObjectType)buf->read_1bytes(); uint8_t v = buf->read_1bytes(); @@ -5488,7 +5493,7 @@ srs_error_t SrsMp4Decoder::parse_moov(SrsMp4MovieBox* moov) if (vide && !avcc) { return srs_error_new(ERROR_MP4_ILLEGAL_MOOV, "missing video sequence header"); } - if (soun && !asc) { + if (soun && !asc && soun->soun_codec() == SrsAudioCodecIdAAC) { return srs_error_new(ERROR_MP4_ILLEGAL_MOOV, "missing audio sequence header"); } @@ -5910,13 +5915,15 @@ srs_error_t SrsMp4Encoder::flush() es->ES_ID = 0x02; SrsMp4DecoderConfigDescriptor& desc = es->decConfigDescr; - desc.objectTypeIndication = SrsMp4ObjectTypeAac; + desc.objectTypeIndication = get_audio_object_type(); desc.streamType = SrsMp4StreamTypeAudioStream; srs_freep(desc.decSpecificInfo); - SrsMp4DecoderSpecificInfo* asc = new SrsMp4DecoderSpecificInfo(); - desc.decSpecificInfo = asc; - asc->asc = pasc;; + if (SrsMp4ObjectTypeAac == desc.objectTypeIndication) { + SrsMp4DecoderSpecificInfo* asc = new SrsMp4DecoderSpecificInfo(); + desc.decSpecificInfo = asc; + asc->asc = pasc; + } } if ((err = samples->write(moov)) != srs_success) { @@ -6045,6 +6052,18 @@ srs_error_t SrsMp4Encoder::do_write_sample(SrsMp4Sample* ps, uint8_t* sample, ui return err; } +SrsMp4ObjectType SrsMp4Encoder::get_audio_object_type() +{ + switch (acodec) { + case SrsAudioCodecIdAAC: + return SrsMp4ObjectTypeAac; + case SrsAudioCodecIdMP3: + return (srs_flv_srates[sample_rate] > 24000) ? SrsMp4ObjectTypeMp1a : SrsMp4ObjectTypeMp3; // 11172 - 3 + default: + return SrsMp4ObjectTypeForbidden; + } +} + SrsMp4M2tsInitEncoder::SrsMp4M2tsInitEncoder() { writer = NULL; diff --git a/trunk/src/kernel/srs_kernel_mp4.hpp b/trunk/src/kernel/srs_kernel_mp4.hpp index 9557732ea..bd64be650 100644 --- a/trunk/src/kernel/srs_kernel_mp4.hpp +++ b/trunk/src/kernel/srs_kernel_mp4.hpp @@ -1369,6 +1369,10 @@ enum SrsMp4ObjectType SrsMp4ObjectTypeForbidden = 0x00, // Audio ISO/IEC 14496-3 SrsMp4ObjectTypeAac = 0x40, + // Audio ISO/IEC 13818-3 + SrsMp4ObjectTypeMp3 = 0x69, + // Audio ISO/IEC 11172-3 + SrsMp4ObjectTypeMp1a = 0x6B, }; // Table 6 — streamType Values @@ -2072,6 +2076,7 @@ public: private: virtual srs_error_t copy_sequence_header(SrsFormat* format, bool vsh, uint8_t* sample, uint32_t nb_sample); virtual srs_error_t do_write_sample(SrsMp4Sample* ps, uint8_t* sample, uint32_t nb_sample); + virtual SrsMp4ObjectType get_audio_object_type(); }; // A fMP4 encoder, to write the init.mp4 with sequence header. diff --git a/trunk/src/srt/ts_demux.cpp b/trunk/src/srt/ts_demux.cpp index 560a70f4f..d86161753 100644 --- a/trunk/src/srt/ts_demux.cpp +++ b/trunk/src/srt/ts_demux.cpp @@ -5,7 +5,7 @@ // #include "ts_demux.hpp" -#include +#include "srt_log.hpp" #include ts_demux::ts_demux():_data_total(0) @@ -41,11 +41,6 @@ int ts_demux::decode_unit(unsigned char* data_p, std::string key_path, TS_DATA_C pos++; npos = pos; - //printf("ts header(0x%02x) payload_unit_start_indicator:%d, pid:%d, adaptation_field_control:%d, pos:%d\r\n", - // ts_header_info._sync_byte, - // ts_header_info._payload_unit_start_indicator, ts_header_info._PID, - // ts_header_info._adaptation_field_control, pos); - adaptation_field* field_p = &(ts_header_info._adaptation_field_info); // adaptation field // 0x01 No adaptation_field, payload only @@ -153,8 +148,16 @@ int ts_demux::decode_unit(unsigned char* data_p, std::string key_path, TS_DATA_C _pat._section_number = data_p[pos]; pos++; _pat._last_section_number = data_p[pos]; - assert(_pat._table_id == 0x00); - assert((188 - npos) > (_pat._section_length+3)); // PAT = section_length + 3 + + if (_pat._table_id != 0x00) { + srt_log_error("pat table id(0x%02x) error, it must be 0x00", _pat._table_id); + return -1; + } + // PAT = section_length + 3 + if((188 - npos) <= (_pat._section_length + 3)) { + srt_log_error("pat _section_length(%d) error, the left len:%d", _pat._section_length, (188 - npos)); + return -1; + } pos++; _pat._pid_vec.clear(); for (;pos+4 <= _pat._section_length-5-4+9 + npos;) { // 4:CRC, 5:follow section_length item rpos + 4(following unit length) section_length + 9(above field and unit_start_first_byte ) @@ -167,13 +170,11 @@ int ts_demux::decode_unit(unsigned char* data_p, std::string key_path, TS_DATA_C if (pid_info._program_number == 0) { // // network_PID 13 uimsbf pid_info._network_id = (data_p[pos]<<8|data_p[pos+1])&0x1FFF; - //printf("#### network id:%d.\r\n", pid_info._network_id); pos += 2; } else { // // program_map_PID 13 uimsbf pid_info._pid = (data_p[pos]<<8|data_p[pos+1])&0x1FFF; - //printf("#### pmt id:%d.\r\n", pid_info._pid); pos += 2; } _pat._pid_vec.push_back(pid_info); @@ -217,7 +218,12 @@ int ts_demux::decode_unit(unsigned char* data_p, std::string key_path, TS_DATA_C //reserved 4 bslbf _pmt._program_info_length = ((data_p[pos]<<8)|data_p[pos+1])&0x0FFF;//program_info_length 12 uimsbf pos += 2; - assert(_pmt._table_id==0x02); // 0x02, // TS_program_map_section + + //0x02, // TS_program_map_section + if (_pmt._table_id != 0x02) { + srt_log_error("pmt tableid(0x%02x) error, it must be 0x02", _pmt._table_id) + return -1; + } memcpy(_pmt._dscr, data_p+pos, _pmt._program_info_length); // for (i = 0; i < N; i++) { // descriptor() @@ -250,7 +256,6 @@ int ts_demux::decode_unit(unsigned char* data_p, std::string key_path, TS_DATA_C pos += descriptor_length; } // save program_number(stream num) elementary_PID(PES PID) stream_type(stream codec) - //printf("pmt pid:%d, streamtype:%d, pos:%d\r\n", pid_info._elementary_PID, pid_info._stream_type, pos); _pmt._stream_pid_vec.push_back(pid_info); _pmt._pid2steamtype.insert(std::make_pair((unsigned short)pid_info._elementary_PID, pid_info._stream_type)); } @@ -274,8 +279,8 @@ int ts_demux::decode_unit(unsigned char* data_p, std::string key_path, TS_DATA_C on_callback(callback, _last_pid, key_path, _last_dts, _last_pts); int ret = pes_parse(data_p+npos, npos, &ret_data_p, ret_size, dts, pts); - assert(ret <= 188); if (ret > 188) { + srt_log_error("pes length(%d) error", ret); return -1; } @@ -291,9 +296,6 @@ int ts_demux::decode_unit(unsigned char* data_p, std::string key_path, TS_DATA_C } } } - //if(!isFound){ - // printf("unknown PID = %X \n", ts_header_info._PID); - //} } } @@ -380,13 +382,15 @@ int ts_demux::pes_parse(unsigned char* p, size_t npos, pos += 3; int stream_id = p[pos]; //stream_id 8 uimsbf pos++; - //printf("pes parse %02x %02x.\r\n", p[pos], p[pos+1]); + int PES_packet_length = ((unsigned int)p[pos]<<8)|p[pos+1]; //PES_packet_length 16 uimsbf (void)PES_packet_length; pos += 2; - //printf("pes parse packet_start_code_prefix:%d, npos:%lu, PES_packet_length:%d, stream_id:%d.\r\n", - // packet_start_code_prefix, npos, PES_packet_length, stream_id); - assert(0x00000001 == packet_start_code_prefix); + + if (0x00000001 != packet_start_code_prefix) { + srt_log_error("pes packet start code prefix(%06x) error, it must be 0x00 00 01", packet_start_code_prefix); + return 255; + } if (stream_id != 188//program_stream_map 1011 1100 && stream_id != 190//padding_stream 1011 1110 && stream_id != 191//private_stream_2 1011 1111 @@ -397,6 +401,10 @@ int ts_demux::pes_parse(unsigned char* p, size_t npos, && stream_id != 248//ITU-T Rec. H.222.1 type E stream 1111 1000 ) { + if (0x80 != (p[pos] & 0xc0)) { + srt_log_error("the first 2 bits:0x%02x error, it must be 0x80.", (p[pos] & 0xc0)); + return 255; + } //skip 2bits//'10' 2 bslbf int PES_scrambling_control = (p[pos]&30)>>4; //PES_scrambling_control 2 bslbf (void)PES_scrambling_control; @@ -563,9 +571,6 @@ int ts_demux::pes_parse(unsigned char* p, size_t npos, // } *ret_pp = p+pos; ret_size = 188-(npos+pos); - //printf("pes parse body size:%lu, data:0x%02x 0x%02x 0x%02x 0x%02x 0x%02x 0x%02x, dts:%lu(%lu), pts:%lu(%lu)\r\n", - // ret_size, p[pos], p[pos+1], p[pos+2], p[pos+3], p[pos+4], p[pos+5], - // dts, dts/90, pts, pts/90); } else if ( stream_id == 188//program_stream_map 1011 1100 BC || stream_id == 191//private_stream_2 1011 1111 BF diff --git a/trunk/src/utest/srs_utest_kernel.cpp b/trunk/src/utest/srs_utest_kernel.cpp index 87aa4c94d..b3ce712b8 100644 --- a/trunk/src/utest/srs_utest_kernel.cpp +++ b/trunk/src/utest/srs_utest_kernel.cpp @@ -5033,6 +5033,8 @@ VOID TEST(KernelMP4Test, CoverMP4CodecSingleFrame) )); } + enc.acodec = SrsAudioCodecIdAAC; + HELPER_EXPECT_SUCCESS(enc.flush()); //mock_print_mp4(string(f.data(), f.filesize())); } @@ -5147,6 +5149,8 @@ VOID TEST(KernelMP4Test, CoverMP4MultipleVideos) )); } + enc.acodec = SrsAudioCodecIdAAC; + // Flush encoder. HELPER_EXPECT_SUCCESS(enc.flush()); //mock_print_mp4(string(f.data(), f.filesize())); @@ -5245,6 +5249,8 @@ VOID TEST(KernelMP4Test, CoverMP4MultipleCTTs) )); } + enc.acodec = SrsAudioCodecIdAAC; + // Flush encoder. HELPER_EXPECT_SUCCESS(enc.flush()); //mock_print_mp4(string(f.data(), f.filesize())); @@ -5357,6 +5363,8 @@ VOID TEST(KernelMP4Test, CoverMP4MultipleAVs) )); } + enc.acodec = SrsAudioCodecIdAAC; + // Flush encoder. HELPER_EXPECT_SUCCESS(enc.flush()); //mock_print_mp4(string(f.data(), f.filesize())); @@ -5397,6 +5405,120 @@ VOID TEST(KernelMP4Test, CoverMP4MultipleAVs) } } +VOID TEST(KernelMP4Test, CoverMP4MultipleAVsWithMp3) +{ + srs_error_t err; + + MockSrsFileWriter f; + + // Encode frames. + // V-A V-V + if (true) { + SrsMp4Encoder enc; SrsFormat fmt; + HELPER_EXPECT_SUCCESS(enc.initialize(&f)); + HELPER_EXPECT_SUCCESS(fmt.initialize()); + + // Sequence header, V-A + if (true) { + uint8_t raw[] = { + 0x17, 0x00, 0x00, 0x00, 0x00, 0x01, 0x64, 0x00, 0x20, 0xff, 0xe1, 0x00, 0x19, 0x67, 0x64, 0x00, 0x20, 0xac, 0xd9, 0x40, 0xc0, 0x29, 0xb0, 0x11, 0x00, 0x00, 0x03, 0x00, 0x01, 0x00, 0x00, 0x03, 0x00, 0x32, 0x0f, 0x18, 0x31, 0x96, 0x01, 0x00, 0x05, 0x68, 0xeb, 0xec, 0xb2, 0x2c + }; + HELPER_EXPECT_SUCCESS(fmt.on_video(0, (char*)raw, sizeof(raw))); + HELPER_EXPECT_SUCCESS(enc.write_sample( + &fmt, SrsMp4HandlerTypeVIDE, fmt.video->frame_type, fmt.video->avc_packet_type, 0, 0, (uint8_t*)fmt.raw, fmt.nb_raw + )); + EXPECT_EQ(768, (int)enc.width); EXPECT_EQ(320, (int)enc.height); + } + + if (true) { + uint8_t raw[] = { + 0xaf, 0x00, 0x12, 0x10 + }; + HELPER_EXPECT_SUCCESS(fmt.on_audio(0, (char*)raw, sizeof(raw))); + HELPER_EXPECT_SUCCESS(enc.write_sample( + &fmt, SrsMp4HandlerTypeSOUN, 0x00, fmt.audio->aac_packet_type, 0, 0, (uint8_t*)fmt.raw, fmt.nb_raw + )); + } + + // Frame group #0, V-A-A-V + if (true) { + uint8_t raw[] = { + 0x17, 0x01, 0x00, 0x00, 0x50, 0x00, 0x00, 0x00, 0x7b, 0x41, 0x9a, 0x21, 0x6c, 0x42, 0x1f, 0x00, 0x00, 0xf1, 0x68, 0x1a, 0x35, 0x84, 0xb3, 0xee, 0xe0, 0x61, 0xba, 0x4e, 0xa8, 0x52, 0x48, 0x50, 0x59, 0x75, 0x42, 0xd9, 0x96, 0x4a, 0x51, 0x38, 0x2c, 0x63, 0x5e, 0x41, 0xc9, 0x70, 0x60, 0x9d, 0x13, 0x53, 0xc2, 0xa8, 0xf5, 0x45, 0x86, 0xc5, 0x3e, 0x28, 0x1a, 0x69, 0x5f, 0x71, 0x1e, 0x51, 0x74, 0x0e, 0x31, 0x47, 0x3c, 0xd3, 0xd2, 0x10, 0x25, 0x45, 0xc5, 0xb7, 0x31, 0xec, 0x7f, 0xd8, 0x02, 0xae, 0xa4, 0x77, 0x6d, 0xcb, 0xc6, 0x1e, 0x2f, 0xa2, 0xd1, 0x12, 0x08, 0x34, 0x52, 0xea, 0xe8, 0x0b, 0x4f, 0x81, 0x21, 0x4f, 0x71, 0x3f, 0xf2, 0xad, 0x02, 0x58, 0xdf, 0x9e, 0x31, 0x86, 0x9b, 0x1b, 0x41, 0xbf, 0x2a, 0x09, 0x00, 0x43, 0x5c, 0xa1, 0x7e, 0x76, 0x59, 0xef, 0xa6, 0xfc, 0x82, 0xb2, 0x72, 0x5a + }; + HELPER_EXPECT_SUCCESS(fmt.on_video(0, (char*)raw, sizeof(raw))); + HELPER_EXPECT_SUCCESS(enc.write_sample( + &fmt, SrsMp4HandlerTypeVIDE, fmt.video->frame_type, fmt.video->avc_packet_type, 0, 0, (uint8_t*)fmt.raw, fmt.nb_raw + )); + } + + if (true) { + uint8_t raw[] = { + 0xaf, 0x01, 0x21, 0x11, 0x45, 0x00, 0x14, 0x50, 0x01, 0x46, 0xf3, 0xf1, 0x0a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5e + }; + HELPER_EXPECT_SUCCESS(fmt.on_audio(0, (char*)raw, sizeof(raw))); + HELPER_EXPECT_SUCCESS(enc.write_sample( + &fmt, SrsMp4HandlerTypeSOUN, 0x00, fmt.audio->aac_packet_type, 0, 0, (uint8_t*)fmt.raw, fmt.nb_raw + )); + } + + if (true) { + uint8_t raw[] = { + 0xaf, 0x01, 0x21, 0x11, 0x45, 0x00, 0x14, 0x50, 0x01, 0x46, 0xf3, 0xf1, 0x0a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5a, 0x5e + }; + HELPER_EXPECT_SUCCESS(fmt.on_audio(0, (char*)raw, sizeof(raw))); + HELPER_EXPECT_SUCCESS(enc.write_sample( + &fmt, SrsMp4HandlerTypeSOUN, 0x00, fmt.audio->aac_packet_type, 20, 20, (uint8_t*)fmt.raw, fmt.nb_raw + )); + } + + if (true) { + uint8_t raw[] = { + 0x27, 0x01, 0x00, 0x00, 0x50, 0x00, 0x00, 0x00, 0x7b, 0x41, 0x9a, 0x21, 0x6c, 0x42, 0x1f, 0x00, 0x00, 0xf1, 0x68, 0x1a, 0x35, 0x84, 0xb3, 0xee, 0xe0, 0x61, 0xba, 0x4e, 0xa8, 0x52, 0x48, 0x50, 0x59, 0x75, 0x42, 0xd9, 0x96, 0x4a, 0x51, 0x38, 0x2c, 0x63, 0x5e, 0x41, 0xc9, 0x70, 0x60, 0x9d, 0x13, 0x53, 0xc2, 0xa8, 0xf5, 0x45, 0x86, 0xc5, 0x3e, 0x28, 0x1a, 0x69, 0x5f, 0x71, 0x1e, 0x51, 0x74, 0x0e, 0x31, 0x47, 0x3c, 0xd3, 0xd2, 0x10, 0x25, 0x45, 0xc5, 0xb7, 0x31, 0xec, 0x7f, 0xd8, 0x02, 0xae, 0xa4, 0x77, 0x6d, 0xcb, 0xc6, 0x1e, 0x2f, 0xa2, 0xd1, 0x12, 0x08, 0x34, 0x52, 0xea, 0xe8, 0x0b, 0x4f, 0x81, 0x21, 0x4f, 0x71, 0x3f, 0xf2, 0xad, 0x02, 0x58, 0xdf, 0x9e, 0x31, 0x86, 0x9b, 0x1b, 0x41, 0xbf, 0x2a, 0x09, 0x00, 0x43, 0x5c, 0xa1, 0x7e, 0x76, 0x59, 0xef, 0xa6, 0xfc, 0x82, 0xb2, 0x72, 0x5a + }; + HELPER_EXPECT_SUCCESS(fmt.on_video(0, (char*)raw, sizeof(raw))); + HELPER_EXPECT_SUCCESS(enc.write_sample( + &fmt, SrsMp4HandlerTypeVIDE, fmt.video->frame_type, fmt.video->avc_packet_type, 40, 40, (uint8_t*)fmt.raw, fmt.nb_raw + )); + } + + enc.acodec = SrsAudioCodecIdMP3; + + // Flush encoder. + HELPER_EXPECT_SUCCESS(enc.flush()); + //mock_print_mp4(string(f.data(), f.filesize())); + } + + // Decode frames. + if (true) { + MockSrsFileReader fr((const char*)f.data(), f.filesize()); + SrsMp4Decoder dec; HELPER_EXPECT_SUCCESS(dec.initialize(&fr)); + + SrsMp4HandlerType ht; uint16_t ft, ct; uint32_t dts, pts, nb_sample; uint8_t* sample = NULL; + + // Sequence header. + HELPER_EXPECT_SUCCESS(dec.read_sample(&ht, &ft, &ct, &dts, &pts, &sample, &nb_sample)); + EXPECT_EQ(0, (int)dts); EXPECT_EQ(41, (int)nb_sample); EXPECT_EQ(SrsMp4HandlerTypeVIDE, ht); EXPECT_EQ(SrsVideoAvcFrameTraitSequenceHeader, ct); + srs_freepa(sample); + + // Frames order by dts asc. + HELPER_EXPECT_SUCCESS(dec.read_sample(&ht, &ft, &ct, &dts, &pts, &sample, &nb_sample)); + EXPECT_EQ(0, (int)dts); EXPECT_EQ(127, (int)nb_sample); EXPECT_EQ(SrsMp4HandlerTypeVIDE, ht); EXPECT_NE(SrsAudioMp3FrameTrait, ct); + srs_freepa(sample); + + HELPER_EXPECT_SUCCESS(dec.read_sample(&ht, &ft, &ct, &dts, &pts, &sample, &nb_sample)); + EXPECT_EQ(0, (int)dts); EXPECT_EQ(87, (int)nb_sample); EXPECT_EQ(SrsMp4HandlerTypeSOUN, ht); EXPECT_NE(SrsVideoAvcFrameTraitSequenceHeader, ct); + srs_freepa(sample); + + HELPER_EXPECT_SUCCESS(dec.read_sample(&ht, &ft, &ct, &dts, &pts, &sample, &nb_sample)); + EXPECT_EQ(20, (int)dts); EXPECT_EQ(87, (int)nb_sample); EXPECT_EQ(SrsMp4HandlerTypeSOUN, ht); EXPECT_NE(SrsVideoAvcFrameTraitSequenceHeader, ct); + srs_freepa(sample); + + HELPER_EXPECT_SUCCESS(dec.read_sample(&ht, &ft, &ct, &dts, &pts, &sample, &nb_sample)); + EXPECT_EQ(40, (int)dts); EXPECT_EQ(40, (int)pts); EXPECT_EQ(127, (int)nb_sample); EXPECT_EQ(SrsMp4HandlerTypeVIDE, ht); EXPECT_NE(SrsAudioMp3FrameTrait, ct); + srs_freepa(sample); + } +} + VOID TEST(KernelMP4Test, CoverMP4CodecErrorNoFrames) { srs_error_t err;