#include "RTSP_Player.h"
#include <QThread>


RTSP_Player::RTSP_Player(MyFFmpeg *ffmpeg, QObject *parent)
    : QObject(parent)
    , m_ffmpeg(ffmpeg)
{
    Play();
}

void RTSP_Player::PlayerStart()
{
    //CpuBind(0);
    qDebug("---------------- PlayerStart -----------------");
    qDebug() << QThread::currentThreadId();
    if (m_ffmpeg == NULL){
        emit SigOpenUrlResult(RTSP_Player::FFmpegInitFail);
        QThread::msleep(100);
        return;
    }

    if (m_stopped){
        qDebug("--------------- stop ----------------");
        emit SigOpenUrlResult(RTSP_Player::FFmpegStoped);
        QThread::msleep(100);
        return ;
    }

//    m_ffmpeg->MyFFmpegSetUrl(this->m_playerUrl);
    int ret = m_ffmpeg->MyFFmpegInit();
    if (ret != 0) {
        emit SigOpenUrlResult(RTSP_Player::FFmpegInitFail);
        QThread::msleep(2000);
        return;
    }

    emit SigOpenUrlResult(RTSP_Player::FFmpegInitSucc);

    while (1) {
        if (m_stopped){
            qDebug("--------------- stop ----------------");
            emit SigOpenUrlResult(RTSP_Player::FFmpegStoped);
            break;
        }

        if (!m_ffmpeg) {
            emit SigOpenUrlResult(RTSP_Player::FFmpegInitFail);
            break;
        }
//qDebug() << "AAA  :" << QDateTime::currentMSecsSinceEpoch();
        if (m_ffmpeg->MyFFmpepReadFrame() < 0) {
//            emit SigOpenUrlResult(RTSP_Player::FFmpegInitFail);
//            qDebug("--------------- get frame fail, stop -----------");
//            break;
            QThread::msleep(500);
            continue;
        }

//        m_ffmpeg->MyFFmpegDecodeFrame();
//qDebug() << "BBB  :" << QDateTime::currentMSecsSinceEpoch();
        //QThread::msleep(33);//每秒30帧数 30fps
    }

    m_ffmpeg->MyFFmpegDestroy();
//    emit SigOpenUrlResult(RTSP_Player::FFmpegStoped);
    qDebug("---------------- quit -----------------");

    return;
}

void RTSP_Player::PlayerStop()
{
    m_stopped = true;
}

void RTSP_Player::Play()
{
    m_stopped = false;
}