#include <BasicUsageEnvironment.hh>

#include "liveMedia.hh"

static ServerMediaSession* createNewSMS(UsageEnvironment& env, char const* fileName);

int main()
{
    TaskScheduler* scheduler;
    UsageEnvironment* env ;
    RTSPServer* rtspServer;
    ServerMediaSession* sms;
    //创建任务调用器
    scheduler = BasicTaskScheduler::createNew();
    //创建交互环境
    env = BasicUsageEnvironment::createNew(*scheduler);
    //创建RTSP服务器
    rtspServer = RTSPServer::createNew(*env,554);    //使用554端口
	printf("Use 554 %p\n", rtspServer);
    if(rtspServer == NULL)
    {
        rtspServer = RTSPServer::createNew(*env,8554);   //554端口被占用，就使用8554端口
		printf("Use 8554 %p\n", rtspServer);
    }
    //打印服务器地址
    *env << "Play streams from this server using the URL\n\t"
         << rtspServer->rtspURLPrefix() << "<filename>.\n";
    //创建session
    sms = createNewSMS(*env, "/mnt/media_rw/sdcard0/BACK/movie/mpeg1_mpa.mpg");
	printf("createNewSMS %p\n", sms);
    rtspServer->addServerMediaSession(sms);
	printf("addServerMediaSession %p\n", sms);
    //添加其它文件对应的session...
    //进行事件循环
    env->taskScheduler().doEventLoop(); // does not return
    return 0;
}

static ServerMediaSession* createNewSMS(UsageEnvironment& env, char const* fileName)
{
    char const* extension = strrchr(fileName, '.');
    ServerMediaSession* sms = NULL;
    Boolean reuseSource = False;    //不重用source
	printf("createNewSMS %s\n", fileName);
    sms = ServerMediaSession::createNew(env, fileName);  //创建一个session
	printf("createNew %p\n", sms);
    //
    //在session中添加subssesion
    //
    if(strcmp(extension, ".aac") == 0)
    {
        sms->addSubsession(ADTSAudioFileServerMediaSubsession::createNew(env, fileName, reuseSource));
    }
    else if(strcmp(extension, ".264") == 0)
    {
        sms->addSubsession(H264VideoFileServerMediaSubsession::createNew(env, fileName, reuseSource));
    }
    else if(strcmp(extension, ".mpg") == 0)
    {
		printf("extension mpg\n");
        MPEG1or2FileServerDemux* demux
          = MPEG1or2FileServerDemux::createNew(env, fileName, reuseSource);
		
		printf("createNew demux %p\n", demux);
        sms->addSubsession(demux->newVideoServerMediaSubsession());
        sms->addSubsession(demux->newAudioServerMediaSubsession());
    }

    //添加其它媒体格式支持...
    return sms;
}