class CYCData: methode delCommands added.
This commit is contained in:
+6
-12
@@ -24,18 +24,6 @@
|
|||||||
|
|
||||||
extern LogInstance& L;
|
extern LogInstance& L;
|
||||||
|
|
||||||
CYCData::CYCData(EBusLoop* ebusloop, Commands* commands)
|
|
||||||
: m_ebusloop(ebusloop), m_commands(commands), m_stop(false)
|
|
||||||
{
|
|
||||||
addCommands(m_commands);
|
|
||||||
}
|
|
||||||
|
|
||||||
CYCData::~CYCData()
|
|
||||||
{
|
|
||||||
for (mapCI_t iter = m_cycDB.begin(); iter != m_cycDB.end(); ++iter)
|
|
||||||
delete iter->second;
|
|
||||||
}
|
|
||||||
|
|
||||||
void* CYCData::run()
|
void* CYCData::run()
|
||||||
{
|
{
|
||||||
bool skipfirst = false;
|
bool skipfirst = false;
|
||||||
@@ -145,3 +133,9 @@ void CYCData::addCommands(Commands* commands)
|
|||||||
L.log(cyc, trace, "%d cycle commands added", m_cycDB.size());
|
L.log(cyc, trace, "%d cycle commands added", m_cycDB.size());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void CYCData::delCommands()
|
||||||
|
{
|
||||||
|
for (mapCI_t iter = m_cycDB.begin(); iter != m_cycDB.end(); ++iter)
|
||||||
|
delete iter->second;
|
||||||
|
}
|
||||||
|
|
||||||
|
|||||||
+5
-2
@@ -35,8 +35,10 @@ class CYCData : public Thread
|
|||||||
{
|
{
|
||||||
|
|
||||||
public:
|
public:
|
||||||
CYCData(EBusLoop* ebusloop, Commands* commands);
|
CYCData(EBusLoop* ebusloop, Commands* commands)
|
||||||
~CYCData();
|
: m_ebusloop(ebusloop), m_commands(commands), m_stop(false)
|
||||||
|
{ addCommands(m_commands); }
|
||||||
|
~CYCData() { delCommands(); }
|
||||||
|
|
||||||
void* run();
|
void* run();
|
||||||
void stop() { m_stop = true; }
|
void stop() { m_stop = true; }
|
||||||
@@ -44,6 +46,7 @@ public:
|
|||||||
std::string getData(int index);
|
std::string getData(int index);
|
||||||
|
|
||||||
void addCommands(Commands* commands);
|
void addCommands(Commands* commands);
|
||||||
|
void delCommands();
|
||||||
|
|
||||||
private:
|
private:
|
||||||
EBusLoop* m_ebusloop;
|
EBusLoop* m_ebusloop;
|
||||||
|
|||||||
Reference in New Issue
Block a user