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) }
39) 
40) /// virtual destructor
41) Priority::~Priority()
42) {
43) }
44) 
45) /// check for update of configuration
46) void Priority::updateConfig()
47) {

48)   // input list update
49)   m_inListTracker.updateConfig();

50) 
51)   // output stream name file was modified -> re-get output stream

52)   if (m_fileOutStream.checkModified())
53)     m_fileOutStream.update();

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

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

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

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

79)     // check for frame

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

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

82)       m_fileOutStream.setFrame(pFrame);

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

90)   m_fileOutStream.setFrame(NULL);

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

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

101)     m_fileOutStream.setFrame(pFrame);

102)   // no frame available -> send this information
103)   else

104)     m_fileOutStream.setFrame(NULL);