/home/tobi/workspace/solarpowerlog/src/Connections/interfaces/IConnect.cpp

Go to the documentation of this file.

/* ----------------------------------------------------------------------------
 solarpowerlog
 Copyright (C) 2009  Tobias Frost

 This file is part of solarpowerlog.

 Solarpowerlog is free software; However, it is dual-licenced
 as described in the file "COPYING".

 For this file (IConnect.cpp), the license terms are:

 You can redistribute it and/or modify it under the terms of the GNU
 General Public License as published by the Free Software Foundation; either
 version 3 of the License, or (at your option) any later version.

 This program is distributed in the hope that it will be useful, but
 WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 Lesser General Public License for more details.

 You should have received a copy of the GNU Library General Public
 License along with this proramm; if not, see
 <http://www.gnu.org/licenses/>.
 ----------------------------------------------------------------------------
 */

#ifdef HAVE_CONFIG_H
#include "config.h"
#endif

#include <string>

#include "IConnect.h"

using namespace std;

IConnect::IConnect(const string& configurationname)
{
     ConfigurationPath = configurationname;
     _thread_is_running = false;
     _thread_term_request = false;

}

void IConnect::SetupLogger(const string &parentlogger, const string & spec)
{
     logger.Setup(parentlogger, spec);
}

IConnect::~IConnect()
{
     mutex.lock();
     if (_thread_is_running) {
          _thread_term_request = true;
          workerthread.interrupt();
          mutex.unlock();
          workerthread.join();
     } else {
          mutex.unlock();
     }
}

void IConnect::StartWorkerThread(void)
{
     mutex.lock();
     if (!_thread_is_running) {
          workerthread = boost::thread(boost::bind(&IConnect::_main, this));
          _thread_is_running = true;
     }
     mutex.unlock();
}

bool IConnect::IsTermRequested(void)
{
     mutex.lock();
     bool ret = _thread_term_request;
     mutex.unlock();
     return ret;
}

bool IConnect::IsThreadRunning(void)
{
     mutex.lock();
     bool ret = _thread_is_running;
     mutex.unlock();
     return ret;
}