doxy/html/DistributedWorker_8h_source.html

/*

    Copyright (C) 2007 - 2011-02-23, Hammersmith Imanet Ltd

    Copyright (C) 2014, University College London

    This file is part of STIR.


    SPDX-License-Identifier: Apache-2.0


    See STIR/LICENSE.txt for details

*/


#ifndef __stir_recon_buildblock_DistributedWorker_h__

#  define __stir_recon_buildblock_DistributedWorker_h__


#  include "stir/shared_ptr.h"

#  include "stir/TimedObject.h"

//#include "stir/ParsingObject.h"

#  include "stir/ProjData.h"

#  include "stir/recon_buildblock/ProjectorByBinPair.h"

#  include "stir/recon_buildblock/distributable.h"

#  include <string>

#  include <vector>


START_NAMESPACE_STIR


class ExamInfo;


template <class TargetT>


class DistributedWorker : public TimedObject //, public ParsingObject

{

private:

  double* log_likelihood_ptr;

  bool zero_seg0_end_planes;

  shared_ptr<ProjectorByBinPair> proj_pair_sptr;

  shared_ptr<ExamInfo> exam_info_sptr;

  shared_ptr<const ProjDataInfo> proj_data_info_sptr;

  shared_ptr<TargetT> target_sptr;


  int image_buffer_size; // to save the image_size


  // cache variables

  bool cache_enabled;

  shared_ptr<ProjData> proj_data_ptr;

  shared_ptr<ProjData> binwise_correction;

  shared_ptr<ProjData> mult_proj_data_sptr;


  int my_rank; // rank of the worker


public:

  // Default constructor

  DistributedWorker();


  // Default destructor

  ~DistributedWorker();


  void start();


protected:

  void set_defaults();


  void setup_distributable_computation();

  void distributable_computation(RPC_process_related_viewgrams_type* RPC_process_related_viewgrams);

};


END_NAMESPACE_STIR


#endif

// __DistributedWorker_h__

ProjData.h
Declaration of class stir::ProjData.

ProjectorByBinPair.h
Declares class stir::ProjectorByBinPair.

TimedObject.h
declares the stir::TimedObject class

stir::DistributedWorker::distributable_computation
void distributable_computation(RPC_process_related_viewgrams_type *RPC_process_related_viewgrams)
this does the actual computation corresponding to distributable_computation()
Definition DistributedWorker.cxx:236

stir::DistributedWorker::setup_distributable_computation
void setup_distributable_computation()
Get basic information from the master.
Definition DistributedWorker.cxx:183

stir::DistributedWorker::set_defaults
void set_defaults()
sets defaults for this object
Definition DistributedWorker.cxx:128

stir::DistributedWorker::start
void start()
Infinite loop waiting for tasks from the master.
Definition DistributedWorker.cxx:137

stir::TimedObject
base class for all objects which need timers. At the moment, there's only a CPU timer.
Definition TimedObject.h:36

distributable.h
Declaration of the main functions that perform parallel processing.

stir::RPC_process_related_viewgrams_type
void RPC_process_related_viewgrams_type(const shared_ptr< ForwardProjectorByBin > &forward_projector_sptr, const shared_ptr< BackProjectorByBin > &back_projector_sptr, RelatedViewgrams< float > *measured_viewgrams_ptr, int &count, int &count2, double *log_likelihood_ptr, const RelatedViewgrams< float > *additive_binwise_correction_ptr, const RelatedViewgrams< float > *mult_viewgrams_ptr)
typedef for callback functions for distributable_computation()
Definition distributable.h:93

shared_ptr.h
Import of std::shared_ptr, std::dynamic_pointer_cast and std::static_pointer_cast into the stir names...