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 <set>
7) 
8) #include <BlinkenLib/BlinkenFrame.h>
9) 
10) #include "Stream.h"
11) #include "StreamRecv.h"
12) 
13) namespace Blinker {
14) 
15) /// constructor

16) Stream::Stream():
17)   m_pFrame(NULL)

18) {
19) }
20) 

21) /// destructor

22) Stream::~Stream()
23) {

24)   // free current frame
25)   if (m_pFrame)
26)     BlinkenFrameFree(m_pFrame);

27) }
28) 
29) /**
30)  * @brief attach a stream receiver
31)  * @param[in] recv stream receiver to attach
32)  */
33) void Stream::attach(StreamRecv *recv)
34) {
35)   m_recvs.insert(recv);

36) 
37)   // send current frame to receiver

38)   recv->setFrame(m_name, m_pFrame);

39) }
40) 
41) /**
42)  * @brief detach a stream receiver
43)  * @param[in] recv stream receiver to detach
44)  */
45) void Stream::detach(StreamRecv *recv)
46) {
47)   m_recvs.erase(recv);
48) }
49) 
50) /**
51)  * @brief set current frame

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

53)  */
54) void Stream::setFrame(stBlinkenFrame *pFrame)
55) {

56)   // leave if frame is already set to an identical one

57)   if (pFrame && m_pFrame && !BlinkenFrameCompare(pFrame, m_pFrame))

58)     return;

59)   if (!pFrame && !m_pFrame)

60)     return;
61) 

62)   // update local copy of current frame

63)   if (m_pFrame) {
64)     BlinkenFrameFree(m_pFrame);
65)     m_pFrame = NULL;
66)   }

67)   if (pFrame) {
68)     m_pFrame = BlinkenFrameClone(pFrame);
69)     // in case of NULL returned: out of memory - got on without frame
70)   }

71) 

72)   // pass frame to all receivers

73)   Recvs::iterator it;
74)   for (it = m_recvs.begin(); it != m_recvs.end(); ++it)

75)     (*it)->setFrame(m_name, m_pFrame);

76) }
77) 

78) /**
79)  * @brief get current frame

80)  * @return current frame (NULL for none)

81)  */

82) stBlinkenFrame * Stream::getCurFrame() const

83) {

84)   return m_pFrame;

85) }
86)