Mercurial > hg > orthanc-transfers
comparison Framework/PushMode/PushJob.cpp @ 8:4c3437217518
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); |