Mercurial > hg > orthanc

comparison OrthancServer/Sources/ServerJobs/ThreadedSetOfInstancesJob.h @ 5137:15109c3f0f7d

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
added sanity checks in DicomModificationJob + automatically reconstruct resources at the end of a DicomModificationJob
author Alain Mazy <am@osimis.io>
date Wed, 18 Jan 2023 17:58:51 +0100
parents e71b22a43c0b
children df040c83796c
comparison
equal deleted inserted replaced
5136:e71b22a43c0b 5137:15109c3f0f7d
50 private: 50 private:
51 std::set<std::string> instancesToProcess_; // the list of source instances ids to process 51 std::set<std::string> instancesToProcess_; // the list of source instances ids to process
52 std::set<std::string> failedInstances_; // the list of source instances ids that failed processing 52 std::set<std::string> failedInstances_; // the list of source instances ids that failed processing
53 std::set<std::string> processedInstances_; // the list of source instances ids that have been processed (including failed ones) 53 std::set<std::string> processedInstances_; // the list of source instances ids that have been processed (including failed ones)
54 54
55 std::set<std::string> parentResources_;
56
57 SharedMessageQueue instancesToProcessQueue_; 55 SharedMessageQueue instancesToProcessQueue_;
58 std::vector<boost::shared_ptr<boost::thread> > instancesWorkers_; 56 std::vector<boost::shared_ptr<boost::thread> > instancesWorkers_;
59 57
60 bool hasPostProcessing_; // final step before "KeepSource" cleanup 58 bool hasPostProcessing_; // final step before "KeepSource" cleanup
61 bool started_; 59 bool started_;
66 size_t workersCount_; 64 size_t workersCount_;
67 65
68 ServerContext& context_; 66 ServerContext& context_;
69 bool keepSource_; 67 bool keepSource_;
70 ErrorCode errorCode_; 68 ErrorCode errorCode_;
69
71 protected: 70 protected:
72 mutable boost::recursive_mutex mutex_; 71 mutable boost::recursive_mutex mutex_;
72 std::set<std::string> parentResources_;
73 73
74 public: 74 public:
75 ThreadedSetOfInstancesJob(ServerContext& context, 75 ThreadedSetOfInstancesJob(ServerContext& context,
76 bool hasTrailingStep, 76 bool hasTrailingStep,
77 bool keepSource, 77 bool keepSource,
115 115
116 const std::string& GetDescription() const; 116 const std::string& GetDescription() const;
117 117
118 void SetKeepSource(bool keep); 118 void SetKeepSource(bool keep);
119 119
120 bool IsKeepSource() const;
121
120 void GetInstances(std::set<std::string>& target) const; 122 void GetInstances(std::set<std::string>& target) const;
121 123
122 void GetFailedInstances(std::set<std::string>& target) const; 124 void GetFailedInstances(std::set<std::string>& target) const;
123 125
124 size_t GetInstancesCount() const; 126 size_t GetInstancesCount() const;