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 "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] mgrs managers

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

29) Priority::Priority(Mgrs &mgrs, const Directory &dirBase):
30)   Module(mgrs, dirBase),
31)   m_fileOutStream(dirBase.getFile("outstream"), mgrs.m_streamMgr),

32)   m_inListTracker(*this, dirBase.getSubdir("inputs")),
33)   m_itCurIn(m_inListTracker.m_list.rend())

34) {

35)   m_inListTracker.init();

36) }
37) 
38) /// virtual destructor
39) Priority::~Priority()
40) {

41)   m_inListTracker.clear();

42) }
43) 
44) /// check for update of configuration
45) void Priority::updateConfig()
46) {

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

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

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

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

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

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

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

78)     // check for frame

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

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

81)       m_fileOutStream.setFrame(pFrame);

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

89)   m_fileOutStream.setFrame(NULL);

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

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

100)     m_fileOutStream.setFrame(pFrame);

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

103)     m_fileOutStream.setFrame(NULL);