cxReconstructThreads.cpp

Go to the documentation of this file.

/*=========================================================================
This file is part of CustusX, an Image Guided Therapy Application.
                 
Copyright (c) SINTEF Department of Medical Technology.
All rights reserved.
                 
CustusX is released under a BSD 3-Clause license.
                 
See Lisence.txt (https://github.com/SINTEFMedtek/CustusX/blob/master/License.txt) for details.
=========================================================================*/
 
#include "cxReconstructThreads.h"
 
#include "cxImage.h"
#include "cxReconstructPreprocessor.h"
#include "cxReconstructCore.h"
#include "cxPatientModelService.h"
#include "cxViewService.h"
 
//Windows fix
#ifndef M_PI
#define M_PI 3.14159265358979323846
#endif
 
namespace cx
{
 
 
ThreadedTimedReconstructPreprocessor::ThreadedTimedReconstructPreprocessor(PatientModelServicePtr patientModelService, ReconstructPreprocessorPtr input, std::vector<ReconstructCorePtr> cores) :
        cx::ThreadedTimedAlgorithm<void> ("US PreReconstruction", 30),
        mPatientModelService(patientModelService)
{
        mInput = input;
        mUseDefaultMessages = false;
        mCores = cores;
}
 
ThreadedTimedReconstructPreprocessor::~ThreadedTimedReconstructPreprocessor()
{
}
 
void ThreadedTimedReconstructPreprocessor::preProcessingSlot()
{
}
 
void ThreadedTimedReconstructPreprocessor::calculate()
{
        std::vector<bool> angio;
        for (unsigned i=0; i<mCores.size(); ++i)
                angio.push_back(mCores[i]->getInputParams().mAngio);
 
        std::vector<cx::ProcessedUSInputDataPtr> processedInput = mInput->createProcessedInput(angio);
 
        for (unsigned i=0; i<mCores.size(); ++i)
        {
                mCores[i]->initialize(processedInput[i], mInput->getOutputVolumeParams());
        }
}
 
void ThreadedTimedReconstructPreprocessor::postProcessingSlot()
{
}
 
//---------------------------------------------------------
//---------------------------------------------------------
//---------------------------------------------------------
 
 
ThreadedTimedReconstructCore::ThreadedTimedReconstructCore(PatientModelServicePtr patientModelService, ViewServicePtr viewService, ReconstructCorePtr reconstructer) :
        cx::ThreadedTimedAlgorithm<void> ("US Reconstruction", 30),
        mPatientModelService(patientModelService),
        mViewService(viewService)
{
        mUseDefaultMessages = false;
        mReconstructer = reconstructer;
}
 
ThreadedTimedReconstructCore::~ThreadedTimedReconstructCore()
{
}
 
void ThreadedTimedReconstructCore::preProcessingSlot()
{
        mReconstructer->threadedPreReconstruct();
}
 
void ThreadedTimedReconstructCore::calculate()
{
        mReconstructer->threadedReconstruct();
}
 
void ThreadedTimedReconstructCore::postProcessingSlot()
{
        mReconstructer->threadedPostReconstruct();
 
        mPatientModelService->autoSave();
        mViewService->autoShowData(mReconstructer->getOutput());
}
 
}