Blinker

1) /* Blinker
2)    Copyright 2011 Stefan Schuermans <stefan@blinkenarea.org>
3)    Copyleft GNU public license - http://www.gnu.org/copyleft/gpl.html
4)    a blinkenarea.org project */
5) 
6) #include <list>
7) #include <string>
8) 
9) #include <BlinkenLib/BlinkenFrame.h>
10) 
11) #include "CallMgr.h"
12) #include "Directory.h"
13) #include "File.h"

14) #include "ListTracker.h"
15) #include "ListTracker_impl.h"

16) #include "Module.h"
17) #include "Priority.h"
18) #include "PriorityInput.h"

19) #include "OutStreamFile.h"

20) #include "StreamMgr.h"
21) #include "StreamRecv.h"
22) 
23) namespace Blinker {
24) 
25) /**
26)  * @brief constructor
27)  * @param[in] callMgr callback manager
28)  * @param[in] streamMgr stream manager
29)  * @param[in] dirBase base directory
30)  */

31) Priority::Priority(CallMgr &callMgr, StreamMgr &streamMgr,
32)                    const Directory &dirBase):

33)   Module(callMgr, streamMgr, dirBase),

34)   m_fileOutStream(dirBase.getFile("outstream"), streamMgr),

35)   m_inListTracker(*this, dirBase.getSubdir("inputs")),
36)   m_itCurIn(m_inListTracker.m_list.rend())

37) {

38)   m_inListTracker.init();

39) }
40) 
41) /// virtual destructor
42) Priority::~Priority()
43) {

44)   m_inListTracker.clear();

45) }
46) 
47) /// check for update of configuration
48) void Priority::updateConfig()
49) {

50)   // input list update
51)   m_inListTracker.updateConfig();

52) 
53)   // output stream name file was modified -> re-get output stream

54)   if (m_fileOutStream.checkModified())
55)     m_fileOutStream.update();

56) }
57) 
58) /**
59)  * @brief select specific input (called by inputs)
60)  * @param[in] input input to select
61)  */
62) void Priority::select(const Input *pInput)
63) {
64)   // search inputs for passed input

65)   m_itCurIn = m_inListTracker.m_list.rbegin();
66)   while (m_itCurIn != m_inListTracker.m_list.rend() &&
67)          m_itCurIn->m_pObj != pInput)

68)     ++m_itCurIn;
69) 
70)   // send current frame
71)   curFrame();
72) }
73) 
74) /// select lower priority input (called by inputs)
75) void Priority::selectLower()
76) {
77)   stBlinkenFrame *pFrame;
78) 
79)   // search inputs with lower priority until a frame is found

80)   while (m_itCurIn != m_inListTracker.m_list.rend()) {

81)     // check for frame

82)     if ((pFrame = m_itCurIn->m_pObj->getCurFrame())) {

83)       // frame found -> keep this input as current, send frame

84)       m_fileOutStream.setFrame(pFrame);

85)       return;
86)     }
87)     // try next input
88)     ++m_itCurIn;
89)   }
90) 
91)   // no input has got a frame -> send no frame

92)   m_fileOutStream.setFrame(NULL);

93) }
94) 
95) /// send current frame to output stream
96) void Priority::curFrame()
97) {
98)   stBlinkenFrame *pFrame;
99) 
100)   // current input available and frame it it available -> send frame

101)   if (m_itCurIn != m_inListTracker.m_list.rend() &&
102)       (pFrame = m_itCurIn->m_pObj->getCurFrame()))

103)     m_fileOutStream.setFrame(pFrame);

104)   // no frame available -> send this information
105)   else

106)     m_fileOutStream.setFrame(NULL);