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 <iostream>
7) #include <stdlib.h>
8) #include <string>
9) 
10) #include <BlinkenLib/BlinkenFrame.h>
11) 
12) #include "Directory.h"
13) #include "File.h"

14) #include "InStreamFile.h"

15) #include "Mgrs.h"

16) #include "Module.h"

17) #include "OutStreamFile.h"

18) #include "Scaler.h"
19) #include "Size.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) Scaler::Scaler(const std::string &name, Mgrs &mgrs,

31)                  const Directory &dirBase):

32)   Module(name, mgrs, dirBase),

33)   m_fileInStream(dirBase.getFile("instream"), mgrs.m_streamMgr),

34)   m_fileSize(dirBase.getFile("size")),

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

36) {
37)   // set up
38)   getSize();

39)   m_fileInStream.setStreamRecv(this);

40) }
41) 
42) /// virtual destructor
43) Scaler::~Scaler()
44) {
45)   // clean up

46)   m_fileInStream.setStreamRecv(NULL);

47) }
48) 
49) /// check for update of configuration
50) void Scaler::updateConfig()
51) {
52)   // stream name or size file was modified -> re-get stream or size

53)   if (m_fileInStream.checkModified())
54)     m_fileInStream.update();
55)   if (m_fileSize.checkModified())

56)     getSize();

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

59) }
60) 
61) /**
62)  * @brief set current frame
63)  * @param[in] stream stream name

64)  * @param[in] pFrame current frame (NULL for none)

65)  */
66) void Scaler::setFrame(const std::string &stream, stBlinkenFrame *pFrame)
67) {
68)   procFrame(pFrame);
69)   (void)stream; // unused
70) }
71) 
72) /// (re-)get size to scale to
73) void Scaler::getSize()
74) {
75)   // read size from size file

76)   m_fileSize.update();

77) 
78)   // send current frame to output stream
79)   sendFrame();
80) }
81) 
82) /// send current frame to output stream
83) void Scaler::sendFrame()
84) {
85)   // get current frame from input stream and process it

86)   procFrame(m_fileInStream.getCurFrame());

87) }
88) 
89) /**
90)  * @brief process frame

91)  * @param[in] pFrame frame to process (NULL for none)

92)  */
93) void Scaler::procFrame(stBlinkenFrame *pFrame)
94) {

95)   int width, height;

96)   stBlinkenFrame *pProcFrame;
97) 

98)   // no frame or no size -> pass "no frame"

99)   if (!pFrame || !m_fileSize.m_valid) {
100)     m_fileOutStream.setFrame(NULL);

101)     return;
102)   }

103)   width = m_fileSize.m_obj.m_width;
104)   height = m_fileSize.m_obj.m_height;

105) 
106)   // size matches -> pass frame directly

107)   if (BlinkenFrameGetWidth(pFrame) == width &&
108)       BlinkenFrameGetHeight(pFrame) == height ) {
109)     m_fileOutStream.setFrame(pFrame);

110)     return;
111)   }
112) 
113)   // clone frame
114)   pProcFrame = BlinkenFrameClone(pFrame);

115)   if (!pProcFrame) {

116)     m_fileOutStream.setFrame(NULL);

117)     return;
118)   }
119) 
120)   // scale frame

121)   BlinkenFrameScale(pProcFrame, height, width);

122) 
123)   // pass process frame to output stream

124)   m_fileOutStream.setFrame(pProcFrame);