Blinker

src/noarch/Player.cpp   1) /* Blinker

src/noarch/Player.cpp   2)    Copyright 2011-2014 Stefan Schuermans <stefan@blinkenarea.org>

src/noarch/Player.cpp   3)    Copyleft GNU public license - http://www.gnu.org/copyleft/gpl.html
src/noarch/Player.cpp   4)    a blinkenarea.org project */
src/noarch/Player.cpp   5) 
src/noarch/Player.cpp   6) #include <list>
src/noarch/Player.cpp   7) #include <string>
src/noarch/Player.cpp   8) 
src/noarch/Player.cpp   9) #include <BlinkenLib/BlinkenFrame.h>
src/noarch/Player.cpp  10) #include <BlinkenLib/BlinkenMovie.h>
src/noarch/Player.cpp  11) 
src/noarch/Player.cpp  12) #include "Directory.h"
src/noarch/Player.cpp  13) #include "File.h"

src/noarch/Player.cpp  14) #include "InStreamFile.h"

src/noarch/Player.cpp  15) #include "ListTracker.h"
src/noarch/Player.cpp  16) #include "ListTracker_impl.h"

src/noarch/Player.cpp  17) #include "Mgrs.h"

src/noarch/Player.cpp  18) #include "Module.h"

src/noarch/Player.cpp  19) #include "OutStreamFile.h"

src/noarch/Player.cpp  20) #include "Player.h"

src/noarch/Player.cpp  21) #include "PlayerMovie.h"

src/noarch/Player.cpp  22) #include "StreamRecv.h"

src/noarch/Player.cpp  23) #include "Time.h"
src/noarch/Player.cpp  24) #include "TimeCallee.h"
src/noarch/Player.cpp  25) 
src/noarch/Player.cpp  26) namespace Blinker {
src/noarch/Player.cpp  27) 
src/noarch/Player.cpp  28) /**
src/noarch/Player.cpp  29)  * @brief constructor

src/noarch/Player.cpp  30)  * @param[in] name module name

src/noarch/Player.cpp  31)  * @param[in] mgrs managers

src/noarch/Player.cpp  32)  * @param[in] dirBase base directory
src/noarch/Player.cpp  33)  */

src/noarch/Player.cpp  34) Player::Player(const std::string &name, Mgrs &mgrs,

src/noarch/Player.cpp  35)                const Directory &dirBase):

src/noarch/Player.cpp  36)   Module(name, mgrs, dirBase),

src/noarch/Player.cpp  37)   m_fileOutStream(dirBase.getFile("outstream"), mgrs.m_streamMgr),
src/noarch/Player.cpp  38)   m_fileHaltStream(dirBase.getFile("haltstream"), mgrs.m_streamMgr),

src/noarch/Player.cpp  39)   m_playlistTracker(*this, dirBase.getSubdir("playlist")),

src/noarch/Player.cpp  40)   m_curValid(false),

src/noarch/Player.cpp  41)   m_curEntry(m_playlistTracker.m_list.begin()),
src/noarch/Player.cpp  42)   m_curFrame(0),

src/noarch/Player.cpp  43)   m_curChange(false),
src/noarch/Player.cpp  44)   m_halted(false)

src/noarch/Player.cpp  45) {
src/noarch/Player.cpp  46)   // load playlist

src/noarch/Player.cpp  47)   m_fileHaltStream.setStreamRecv(this);

src/noarch/Player.cpp  48)   m_playlistTracker.init();
src/noarch/Player.cpp  49)   checkCurChanged();

src/noarch/Player.cpp  50) }
src/noarch/Player.cpp  51) 
src/noarch/Player.cpp  52) /// virtual destructor
src/noarch/Player.cpp  53) Player::~Player()
src/noarch/Player.cpp  54) {

src/noarch/Player.cpp  55)   // cancel time callback request

src/noarch/Player.cpp  56)   m_mgrs.m_callMgr.cancelTimeCall(this);

src/noarch/Player.cpp  57) 

src/noarch/Player.cpp  58)   // free all movies

src/noarch/Player.cpp  59)   m_playlistTracker.clear();

src/noarch/Player.cpp  60)   m_fileHaltStream.setStreamRecv(NULL);

src/noarch/Player.cpp  61) }
src/noarch/Player.cpp  62) 

src/noarch/Player.cpp  63) /// check for update of configuration
src/noarch/Player.cpp  64) void Player::updateConfig()
src/noarch/Player.cpp  65) {

src/noarch/Player.cpp  66)   // output stream name file was modified -> re-get output stream
src/noarch/Player.cpp  67)   if (m_fileOutStream.checkModified()) {

src/noarch/Player.cpp  68)     m_fileOutStream.update();
src/noarch/Player.cpp  69)     sendFrame();

src/noarch/Player.cpp  70)   }
src/noarch/Player.cpp  71) 

src/noarch/Player.cpp  72)   // halt stream name file was modified -> re-get halt stream
src/noarch/Player.cpp  73)   if (m_fileHaltStream.checkModified())
src/noarch/Player.cpp  74)     m_fileHaltStream.update();
src/noarch/Player.cpp  75) 

src/noarch/Player.cpp  76)   // playlist update
src/noarch/Player.cpp  77)   m_playlistTracker.updateConfig();
src/noarch/Player.cpp  78)   checkCurChanged();

src/noarch/Player.cpp  79) }
src/noarch/Player.cpp  80) 

src/noarch/Player.cpp  81) /**
src/noarch/Player.cpp  82)  * @brief set current frame
src/noarch/Player.cpp  83)  * @param[in] stream stream name
src/noarch/Player.cpp  84)  * @param[in] pFrame current frame (NULL for none)
src/noarch/Player.cpp  85)  */
src/noarch/Player.cpp  86) void Player::setFrame(const std::string &stream, stBlinkenFrame *pFrame)
src/noarch/Player.cpp  87) {
src/noarch/Player.cpp  88)   // this is coming from the halt stream, which will halt the player
src/noarch/Player.cpp  89)   // whenever a frame is available on this halt stream
src/noarch/Player.cpp  90) 
src/noarch/Player.cpp  91)   // halt stream came to life -> halt player
src/noarch/Player.cpp  92)   if (pFrame && !m_halted) {
src/noarch/Player.cpp  93)     m_halted = true;
src/noarch/Player.cpp  94)     if (m_curValid) {
src/noarch/Player.cpp  95)       // store remaining frame time
src/noarch/Player.cpp  96)       m_remainTime = m_nextTime - Time::now();
src/noarch/Player.cpp  97)       if (m_remainTime < Time::zero)
src/noarch/Player.cpp  98)         m_remainTime = Time::zero;
src/noarch/Player.cpp  99)     }
src/noarch/Player.cpp 100)     // cancel time call

src/noarch/Player.cpp 101)     m_mgrs.m_callMgr.cancelTimeCall(this);

src/noarch/Player.cpp 102)   }
src/noarch/Player.cpp 103) 
src/noarch/Player.cpp 104)   // halt stream ended -> continue playing
src/noarch/Player.cpp 105)   else if (!pFrame && m_halted) {
src/noarch/Player.cpp 106)     m_halted = false;
src/noarch/Player.cpp 107)     if (m_curValid) {
src/noarch/Player.cpp 108)       // determine time for next frame
src/noarch/Player.cpp 109)       m_nextTime = Time::now() + m_remainTime;
src/noarch/Player.cpp 110)       // schedule time call

src/noarch/Player.cpp 111)       m_mgrs.m_callMgr.requestTimeCall(this, m_nextTime);

src/noarch/Player.cpp 112)     }
src/noarch/Player.cpp 113)   }
src/noarch/Player.cpp 114) 
src/noarch/Player.cpp 115)   (void)stream; // unused
src/noarch/Player.cpp 116) }
src/noarch/Player.cpp 117) 

src/noarch/Player.cpp 118) /// callback when requested time reached

src/noarch/Player.cpp 119) void Player::timeCall()
src/noarch/Player.cpp 120) {

src/noarch/Player.cpp 121)   // leave if halted
src/noarch/Player.cpp 122)   if (m_halted)
src/noarch/Player.cpp 123)     return;
src/noarch/Player.cpp 124) 

src/noarch/Player.cpp 125)   // leave if time is not yet ready to next frame
src/noarch/Player.cpp 126)   if (Time::now() < m_nextTime) {
src/noarch/Player.cpp 127)     // request call at time for next frame

src/noarch/Player.cpp 128)     m_mgrs.m_callMgr.requestTimeCall(this, m_nextTime);

src/noarch/Player.cpp 129)     return;
src/noarch/Player.cpp 130)   }
src/noarch/Player.cpp 131) 
src/noarch/Player.cpp 132)   // go to next frame
src/noarch/Player.cpp 133)   ++m_curFrame;
src/noarch/Player.cpp 134) 
src/noarch/Player.cpp 135)   // process new current frame
src/noarch/Player.cpp 136)   procFrame();

src/noarch/Player.cpp 137) }
src/noarch/Player.cpp 138) 

src/noarch/Player.cpp 139) /// check if current movie changed and react
src/noarch/Player.cpp 140) void Player::checkCurChanged()

src/noarch/Player.cpp 141) {

src/noarch/Player.cpp 142)   // current movie changed
src/noarch/Player.cpp 143)   if (m_curChange) {
src/noarch/Player.cpp 144)     m_curChange = false;

src/noarch/Player.cpp 145) 
src/noarch/Player.cpp 146)     // go to begin of new current movie and start playing now
src/noarch/Player.cpp 147)     m_curFrame = 0;

src/noarch/Player.cpp 148)     m_remainTime = Time::zero;

src/noarch/Player.cpp 149)     m_nextTime = Time::now();
src/noarch/Player.cpp 150)     procFrame();
src/noarch/Player.cpp 151) 

src/noarch/Player.cpp 152)   } // if (m_curChange)

src/noarch/Player.cpp 153) }
src/noarch/Player.cpp 154) 

src/noarch/Player.cpp 155) /// process current frame
src/noarch/Player.cpp 156) void Player::procFrame()
src/noarch/Player.cpp 157) {

src/noarch/Player.cpp 158)   // movie finished -> next movie
src/noarch/Player.cpp 159)   //   use while loops to handle empty movies / empty playlist

src/noarch/Player.cpp 160)   m_curValid = true;

src/noarch/Player.cpp 161)   bool wrapped = false;
src/noarch/Player.cpp 162)   while (true) {
src/noarch/Player.cpp 163)     // playlist finished -> re-start from beginning

src/noarch/Player.cpp 164)     while (m_curEntry == m_playlistTracker.m_list.end()) {
src/noarch/Player.cpp 165)       m_curEntry = m_playlistTracker.m_list.begin();

src/noarch/Player.cpp 166)       m_curFrame = 0;
src/noarch/Player.cpp 167)       // detect empty playlist or playlist with only empty movies
src/noarch/Player.cpp 168)       if (wrapped) {

src/noarch/Player.cpp 169)         m_curValid = false;
src/noarch/Player.cpp 170)         break;

src/noarch/Player.cpp 171)       }
src/noarch/Player.cpp 172)       wrapped = true;
src/noarch/Player.cpp 173)     }

src/noarch/Player.cpp 174)     if (!m_curValid)
src/noarch/Player.cpp 175)       break;

src/noarch/Player.cpp 176)     // movie not yet finished -> done

src/noarch/Player.cpp 177)     if (m_curEntry->m_pObj->m_pMovie &&
src/noarch/Player.cpp 178)         m_curFrame < BlinkenMovieGetFrameCnt(m_curEntry->m_pObj->m_pMovie))

src/noarch/Player.cpp 179)       break;
src/noarch/Player.cpp 180)     // movie finished -> next movie
src/noarch/Player.cpp 181)     ++m_curEntry;
src/noarch/Player.cpp 182)     m_curFrame = 0;
src/noarch/Player.cpp 183)   }
src/noarch/Player.cpp 184) 

src/noarch/Player.cpp 185)   // send new frame to stream
src/noarch/Player.cpp 186)   sendFrame();

src/noarch/Player.cpp 187) 

src/noarch/Player.cpp 188)   // if a frame is there
src/noarch/Player.cpp 189)   if (m_curValid) {

src/noarch/Player.cpp 190)     // get frame time and calculate absolute time for next frame

src/noarch/Player.cpp 191)     stBlinkenFrame *pFrame =

src/noarch/Player.cpp 192)       BlinkenMovieGetFrame(m_curEntry->m_pObj->m_pMovie, m_curFrame);

src/noarch/Player.cpp 193)     m_remainTime.fromMs(BlinkenFrameGetDuration(pFrame));
src/noarch/Player.cpp 194)     m_nextTime += m_remainTime;

src/noarch/Player.cpp 195)     // request call at time for next frame

src/noarch/Player.cpp 196)     if (!m_halted)

src/noarch/Player.cpp 197)       m_mgrs.m_callMgr.requestTimeCall(this, m_nextTime);

src/noarch/Player.cpp 198)   }
src/noarch/Player.cpp 199) }

src/noarch/Player.cpp 200) 

src/noarch/Player.cpp 201) /// send current frame to output stream
src/noarch/Player.cpp 202) void Player::sendFrame()
src/noarch/Player.cpp 203) {

src/noarch/Player.cpp 204)   // frame available -> send it

src/noarch/Player.cpp 205)   if (m_curValid) {
src/noarch/Player.cpp 206)     stBlinkenFrame *pFrame =

src/noarch/Player.cpp 207)       BlinkenMovieGetFrame(m_curEntry->m_pObj->m_pMovie, m_curFrame);

src/noarch/Player.cpp 208)     m_fileOutStream.setFrame(pFrame);

src/noarch/Player.cpp 209)   }

src/noarch/Player.cpp 210)   // no frame available -> send this information
src/noarch/Player.cpp 211)   else
src/noarch/Player.cpp 212)     m_fileOutStream.setFrame(NULL);