Blinker

1) /* Blinker

2)    Copyright 2011-2014 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 "Directory.h"
12) #include "File.h"

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

15) #include "Mgrs.h"

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

19) #include "OutStreamFile.h"

20) #include "StreamRecv.h"
21) 
22) namespace Blinker {
23) 
24) /**
25)  * @brief constructor

26)  * @param[in] name module name

27)  * @param[in] mgrs managers

28)  * @param[in] dirBase base directory
29)  */

30) Priority::Priority(const std::string &name, Mgrs &mgrs,
31)                    const Directory &dirBase):
32)   Module(name, mgrs, dirBase),

33)   m_fileOutStream(dirBase.getFile("outstream"), mgrs.m_streamMgr),

34)   m_inListTracker(*this, dirBase.getSubdir("inputs")),

35)   m_itCurIn(m_inListTracker.m_list.rend()),
36)   m_updateNeeded(false)

37) {

38)   m_inListTracker.init();

39)   updateSelection();

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

45)   m_inListTracker.clear();

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

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

53)   updateSelection();

54) 
55)   // output stream name file was modified -> re-get output stream

56)   if (m_fileOutStream.checkModified())
57)     m_fileOutStream.update();

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

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

70)     ++m_itCurIn;
71) 
72)   // send current frame
73)   curFrame();

74) 
75)   // return if required stream was successfully selected
76)   if (m_itCurIn == m_inListTracker.m_list.rend() ||
77)       m_itCurIn->m_pObj != pInput)
78)     m_updateNeeded = true;

79) }
80) 
81) /// select lower priority input (called by inputs)
82) void Priority::selectLower()
83) {
84)   stBlinkenFrame *pFrame;
85) 
86)   // search inputs with lower priority until a frame is found

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

88)     // check for frame

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

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

91)       m_fileOutStream.setFrame(pFrame);

92)       return;
93)     }
94)     // try next input
95)     ++m_itCurIn;
96)   }
97) 
98)   // no input has got a frame -> send no frame

99)   m_fileOutStream.setFrame(NULL);

100) }
101) 

102) /// update current selection
103) void Priority::updateSelection()
104) {
105)   if (m_updateNeeded) {
106)     m_updateNeeded = false;
107) 
108)     // search for highest priority input with a frame
109)     for (m_itCurIn = m_inListTracker.m_list.rbegin();
110)          m_itCurIn != m_inListTracker.m_list.rend(); ++m_itCurIn)
111)       if (m_itCurIn->m_pObj->getCurFrame())
112)         break;
113) 
114)     // send new frame to output stream
115)     curFrame();
116) 
117)   } // if m_updateNeeded
118) }
119) 

120) /// send current frame to output stream
121) void Priority::curFrame()
122) {
123)   stBlinkenFrame *pFrame;
124) 
125)   // current input available and frame it it available -> send frame

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

128)     m_fileOutStream.setFrame(pFrame);

129)   // no frame available -> send this information
130)   else

131)     m_fileOutStream.setFrame(NULL);