Function test_codec

framework/tests/decoder/decoderUnitTest.cpp:16–73

using namespace std;

static void test_codec(const string &url, AFCodecID codec, int flags)
{
    auto source = dataSourcePrototype::create(url);
    source->Open(0);
    auto *demuxer = new demuxer_service(source);
    int ret = demuxer->initOpen();
    Stream_meta smeta{};
    unique_ptr<streamMeta> meta = unique_ptr<streamMeta>(new streamMeta(&smeta));
    unique_ptr<IDecoder> decoder{nullptr};
    for (int i = 0; i < demuxer->GetNbStreams(); ++i) {
        demuxer->GetStreamMeta(meta, i, false);

        if (((Stream_meta *) (*meta))->codec == codec) {
            decoder = decoderFactory::create(*((Stream_meta *) (*meta)), flags, 0 , nullptr);
            ASSERT_TRUE(decoder);
            demuxer->OpenStream(i);
            ret = decoder->open(((Stream_meta *) (*meta)), nullptr, 0, nullptr);
            ASSERT_TRUE(ret >= 0);
            break;
        }
    }

    std::unique_ptr<IAFPacket> packet{nullptr};

    do {
        int decoder_ret;
        ret = demuxer->readPacket(packet, 0);

        if (ret > 0) {
            decoder_ret = decoder->send_packet(packet, 0);
            ASSERT_TRUE(decoder_ret >= 0);
        }

        if (ret == -EAGAIN) {
            af_msleep(10);
            ret = 0;
            continue;
        }

        unique_ptr<IAFFrame> frame{nullptr};
        decoder_ret = decoder->getFrame(frame, 0);

        if (decoder_ret == -EAGAIN) {
            af_msleep(10);
            continue;
        }

        ASSERT_GE(decoder_ret, 0);

        if (frame) {
            frame->dump();
            break;
        }
    } while (ret >= 0);

    delete source;
    delete demuxer;
}