Mercurial > hg > orthanc-transfers

comparison Framework/PushMode/PushJob.cpp @ 8:4c3437217518

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix for compatibility with simplified OrthancPluginCppWrapper
author Sebastien Jodogne <s.jodogne@gmail.com>
date Wed, 05 Dec 2018 09:16:51 +0100
parents 95226b754d9e
children 7e207ade2f1a
comparison
equal deleted inserted replaced
7:151e29acbb13 8:4c3437217518
126 JobInfo& info, 126 JobInfo& info,
127 const std::string& transactionUri, 127 const std::string& transactionUri,
128 const std::vector<TransferBucket>& buckets) : 128 const std::vector<TransferBucket>& buckets) :
129 job_(job), 129 job_(job),
130 info_(info), 130 info_(info),
131 transactionUri_(transactionUri), 131 transactionUri_(transactionUri)
132 queue_(job.context_)
133 { 132 {
134 queue_.Reserve(buckets.size()); 133 queue_.Reserve(buckets.size());
135 134
136 for (size_t i = 0; i < buckets.size(); i++) 135 for (size_t i = 0; i < buckets.size(); i++)
137 { 136 {
244 { 243 {
245 return StateUpdate::Next(new CreateTransactionState(*this, info)); 244 return StateUpdate::Next(new CreateTransactionState(*this, info));
246 } 245 }
247 246
248 247
249 PushJob::PushJob(OrthancPluginContext* context, 248 PushJob::PushJob(const TransferQuery& query,
250 const TransferQuery& query,
251 OrthancInstancesCache& cache, 249 OrthancInstancesCache& cache,
252 size_t threadsCount, 250 size_t threadsCount,
253 size_t targetBucketSize) : 251 size_t targetBucketSize) :
254 StatefulOrthancJob(JOB_TYPE_PUSH), 252 StatefulOrthancJob(JOB_TYPE_PUSH),
255 context_(context),
256 cache_(cache), 253 cache_(cache),
257 query_(query), 254 query_(query),
258 threadsCount_(threadsCount), 255 threadsCount_(threadsCount),
259 targetBucketSize_(targetBucketSize), 256 targetBucketSize_(targetBucketSize)
260 peers_(context)
261 { 257 {
262 if (!peers_.LookupName(peerIndex_, query_.GetPeer())) 258 if (!peers_.LookupName(peerIndex_, query_.GetPeer()))
263 { 259 {
264 LOG(ERROR) << "Unknown Orthanc peer: " << query_.GetPeer(); 260 LOG(ERROR) << "Unknown Orthanc peer: " << query_.GetPeer();
265 throw Orthanc::OrthancException(Orthanc::ErrorCode_UnknownResource); 261 throw Orthanc::OrthancException(Orthanc::ErrorCode_UnknownResource);