SourceXtractorPlusPlus  0.13
Please provide a description of the project.
ProgressMediator.cpp
Go to the documentation of this file.
1 
17 /*
18  * Progress.cpp
19  *
20  * Created on: Sep 07, 2018
21  * Author: Alejandro Alvarez Ayllon
22  */
23 
25 
26 namespace SourceXtractor {
27 
28 class ProgressMediator::ProgressCounter : public Observer<SegmentationProgress> {
29 public:
30  ProgressCounter(ProgressMediator& progress_listener, SegmentationProgress& segmentation_progress,
31  std::mutex& mutex) :
32  m_progress_listener(progress_listener), m_segmentation_progress(segmentation_progress),
33  m_mutex(mutex) {
34  }
35 
36  void handleMessage(const SegmentationProgress& progress) override {
37  {
39  m_segmentation_progress = progress;
40  }
42  }
43 
44 private:
48 };
49 
50 class ProgressMediator::SourceCounter : public Observer<std::shared_ptr<SourceInterface>> {
51 public:
52  SourceCounter(ProgressMediator& progress_listener, std::atomic_int& counter) :
53  m_progress_listener(progress_listener), m_counter(counter) {}
54 
56  ++m_counter;
58  }
59 
60 private:
62  std::atomic_int& m_counter;
63 };
64 
65 class ProgressMediator::GroupCounter : public Observer<std::shared_ptr<SourceGroupInterface>> {
66 public:
67  GroupCounter(ProgressMediator& progress_listener, std::atomic_int& counter) :
68  m_progress_listener(progress_listener), m_counter(counter) {}
69 
71  m_counter += group->size();
73  }
74 
75 private:
77  std::atomic_int& m_counter;
78 };
79 
81  m_segmentation_progress{0, 0}, m_detected{0}, m_deblended{0}, m_measured{0},
82  m_segmentation_listener{std::make_shared<ProgressCounter>(*this, m_segmentation_progress, m_mutex)},
83  m_detection_listener{std::make_shared<SourceCounter>(*this, m_detected)},
84  m_deblending_listener{std::make_shared<GroupCounter>(*this, m_deblended)},
85  m_measurement_listener{std::make_shared<GroupCounter>(*this, m_measured)} {
86 }
87 
90 }
91 
93  return m_detection_listener;
94 }
95 
97  return m_deblending_listener;
98 }
99 
101  return m_measurement_listener;
102 }
103 
108  {"Detected", m_detected, -1},
109  {"Deblended", m_deblended, -1},
110  {"Measured", m_measured, m_deblended},
111  });
112 }
113 
117 }
118 
119 } // end SourceXtractor
SourceXtractor::ProgressMediator::ProgressCounter
Definition: ProgressMediator.cpp:28
SourceXtractor::Observable::notifyObservers
void notifyObservers(const T &message) const
Definition: Observable.h:71
std::lock
T lock(T... args)
SourceXtractor::ProgressMediator::m_mutex
std::mutex m_mutex
Definition: ProgressMediator.h:104
SourceXtractor::Observer
Observer interface to be used with Observable to implement the Observer pattern.
Definition: Observable.h:38
SourceXtractor::ProgressMediator::m_detected
std::atomic_int m_detected
Definition: ProgressMediator.h:96
SourceXtractor::ProgressMediator::GroupCounter::GroupCounter
GroupCounter(ProgressMediator &progress_listener, std::atomic_int &counter)
Definition: ProgressMediator.cpp:67
std::shared_ptr
STL class.
std::list
STL class.
SourceXtractor::ProgressMediator::ProgressCounter::m_mutex
std::mutex & m_mutex
Definition: ProgressMediator.cpp:47
SourceXtractor::ProgressMediator::m_segmentation_listener
std::shared_ptr< segmentation_observer_t > m_segmentation_listener
Definition: ProgressMediator.h:98
SourceXtractor::ProgressMediator::SourceCounter
Definition: ProgressMediator.cpp:50
ProgressMediator.h
SourceXtractor::ProgressMediator::ProgressCounter::ProgressCounter
ProgressCounter(ProgressMediator &progress_listener, SegmentationProgress &segmentation_progress, std::mutex &mutex)
Definition: ProgressMediator.cpp:30
SourceXtractor::ProgressMediator::SourceCounter::SourceCounter
SourceCounter(ProgressMediator &progress_listener, std::atomic_int &counter)
Definition: ProgressMediator.cpp:52
SourceXtractor::ProgressMediator::getMeasurementObserver
std::shared_ptr< group_observer_t > & getMeasurementObserver(void)
Definition: ProgressMediator.cpp:100
SourceXtractor::ProgressMediator::m_deblending_listener
std::shared_ptr< group_observer_t > m_deblending_listener
Definition: ProgressMediator.h:100
SourceXtractor::ProgressMediator::m_detection_listener
std::shared_ptr< source_observer_t > m_detection_listener
Definition: ProgressMediator.h:99
SourceXtractor::SegmentationProgress::total
int total
Definition: Segmentation.h:49
SourceXtractor::ProgressMediator::SourceCounter::handleMessage
void handleMessage(const std::shared_ptr< SourceInterface > &) override
Definition: ProgressMediator.cpp:55
std::lock_guard
STL class.
SourceXtractor::ProgressMediator::GroupCounter::m_progress_listener
ProgressMediator & m_progress_listener
Definition: ProgressMediator.cpp:76
SourceXtractor::ProgressMediator::GroupCounter
Definition: ProgressMediator.cpp:65
SourceXtractor::ProgressMediator::m_deblended
std::atomic_int m_deblended
Definition: ProgressMediator.h:96
SourceXtractor
Definition: Aperture.h:30
SourceXtractor::ProgressMediator::update
void update(void)
Definition: ProgressMediator.cpp:104
SourceXtractor::ProgressMediator::SourceCounter::m_counter
std::atomic_int & m_counter
Definition: ProgressMediator.cpp:62
SourceXtractor::ProgressMediator::GroupCounter::m_counter
std::atomic_int & m_counter
Definition: ProgressMediator.cpp:77
SourceXtractor::ProgressMediator::getDetectionObserver
std::shared_ptr< source_observer_t > & getDetectionObserver(void)
Definition: ProgressMediator.cpp:92
SourceXtractor::ProgressMediator::getDeblendingObserver
std::shared_ptr< group_observer_t > & getDeblendingObserver(void)
Definition: ProgressMediator.cpp:96
SourceXtractor::ProgressMediator::getSegmentationObserver
std::shared_ptr< segmentation_observer_t > & getSegmentationObserver(void)
Definition: ProgressMediator.cpp:88
SourceXtractor::ProgressMediator::ProgressMediator
ProgressMediator()
Definition: ProgressMediator.cpp:80
SourceXtractor::ProgressMediator::SourceCounter::m_progress_listener
ProgressMediator & m_progress_listener
Definition: ProgressMediator.cpp:61
SourceXtractor::ProgressMediator::ProgressCounter::m_segmentation_progress
SegmentationProgress & m_segmentation_progress
Definition: ProgressMediator.cpp:46
SourceXtractor::ProgressMediator::ProgressCounter::m_progress_listener
ProgressMediator & m_progress_listener
Definition: ProgressMediator.cpp:45
SourceXtractor::ProgressMediator::m_measured
std::atomic_int m_measured
Definition: ProgressMediator.h:96
std::mutex
STL class.
SourceXtractor::ProgressMediator::GroupCounter::handleMessage
void handleMessage(const std::shared_ptr< SourceGroupInterface > &group) override
Definition: ProgressMediator.cpp:70
SourceXtractor::ProgressMediator::done
void done()
Definition: ProgressMediator.cpp:114
SourceXtractor::ProgressMediator
Definition: ProgressMediator.h:51
SourceXtractor::ProgressMediator::m_segmentation_progress
SegmentationProgress m_segmentation_progress
Definition: ProgressMediator.h:95
SourceXtractor::SegmentationProgress::position
int position
Definition: Segmentation.h:49
SourceXtractor::ProgressMediator::ProgressCounter::handleMessage
void handleMessage(const SegmentationProgress &progress) override
Definition: ProgressMediator.cpp:36
SourceXtractor::SegmentationProgress
Used to notify observers of the progress of the processing of the image.
Definition: Segmentation.h:48
SourceXtractor::ProgressMediator::m_measurement_listener
std::shared_ptr< group_observer_t > m_measurement_listener
Definition: ProgressMediator.h:100