Synchronizer.cpp
View Options

			#include "Synchronizer.h"

			#include <stdexcept>

			using namespace std;

			namespace rci {
			namespace oncilla {

			Synchronizer::Synchronizer(const std::string &sname)
			: ::rci::Synchronizer(sname)
			, d_inProcess(false){
			}

			Synchronizer::~Synchronizer() {
			}


			bool Synchronizer::start(){
			d_inProcess = false;
			return rci::Synchronizer::start();
			}


			void Synchronizer::processAsync(){
			if(!tooBusy()){
			start();
			}
			if(d_inProcess){
			throw std::logic_error("Previous processing is not terminated.");
			} else {
			d_inProcess = true;
			}

			ProcessAsyncPrimpl();
			}

			void Synchronizer::waitForProcessAsync(){
			if(!tooBusy()){
			start();
			}

			if(!d_inProcess){
			//just do nothing, since nothing to do;
			return;
			}

			WaitForProcessAsyncPrimpl();

			d_inProcess = false;
			}

			}
			}

liboncilla/src/liboncilla/Synchronizer.cppe398de92a491dev-arne