Skip to content

Commit

Permalink
refactor(HLSStream): refactor createDemuxer func
Browse files Browse the repository at this point in the history
Signed-off-by: pingkai <pingkai010@gmail.com>
  • Loading branch information
pingkai committed Feb 24, 2020
1 parent abd8017 commit 0850096
Showing 1 changed file with 21 additions and 18 deletions.
39 changes: 21 additions & 18 deletions framework/demuxer/play_list/HLSStream.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -319,30 +319,12 @@ namespace Cicada {
ret = createDemuxer();

if (ret >= 0) {
int nbStream = mPDemuxer->GetNbStreams();
AF_LOGI("file have %d streams\n", nbStream);
// open all stream in demuxer
Stream_meta meta{};

for (int i = 0; i < nbStream; ++i) {
mPDemuxer->GetStreamMeta(&meta, i, false);

if (meta.type == mPTracker->getStreamType()
|| mPTracker->getStreamType() == STREAM_TYPE_MIXED) {
mPDemuxer->OpenStream(i);
}

releaseMeta(&meta);
}

mIsOpened_internal = true;
} else {
AF_LOGE("open demuxer error %d\n", ret);
return ret;
}

mPacketFirstPts = getPackedStreamPTS();

// mStatus = status_inited;

if (mPdataSource) {
Expand Down Expand Up @@ -430,6 +412,27 @@ namespace Cicada {
}

ret = mPDemuxer->initOpen();

if (ret >= 0) {
int nbStream = mPDemuxer->GetNbStreams();
AF_LOGI("file have %d streams\n", nbStream);
// open all stream in demuxer
Stream_meta meta{};

for (int i = 0; i < nbStream; ++i) {
mPDemuxer->GetStreamMeta(&meta, i, false);

if (meta.type == mPTracker->getStreamType()
|| mPTracker->getStreamType() == STREAM_TYPE_MIXED) {
mPDemuxer->OpenStream(i);
}

releaseMeta(&meta);
}

mPacketFirstPts = getPackedStreamPTS();
}

return ret;
}

Expand Down

0 comments on commit 0850096

Please sign in to comment.