Mercurial > hg > orthanc-transfers
annotate Framework/PushMode/ActivePushTransactions.h @ 25:dfc43678aecb
replacing deprecated std::auto_ptr by std::unique_ptr
author | Sebastien Jodogne <s.jodogne@gmail.com> |
---|---|
date | Mon, 06 Jul 2020 16:25:56 +0200 |
parents | 17f775299b4a |
children | 44a0430d7899 |
rev | line source |
---|---|
0 | 1 /** |
2 * Transfers accelerator plugin for Orthanc | |
19
b06103a50c95
upgrade to year 2020
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
12
diff
changeset
|
3 * Copyright (C) 2018-2020 Osimis S.A., Belgium |
0 | 4 * |
5 * This program is free software: you can redistribute it and/or | |
6 * modify it under the terms of the GNU Affero General Public License | |
7 * as published by the Free Software Foundation, either version 3 of | |
8 * the License, or (at your option) any later version. | |
9 * | |
10 * This program is distributed in the hope that it will be useful, but | |
11 * WITHOUT ANY WARRANTY; without even the implied warranty of | |
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU | |
13 * Affero General Public License for more details. | |
14 * | |
15 * You should have received a copy of the GNU Affero General Public License | |
16 * along with this program. If not, see <http://www.gnu.org/licenses/>. | |
17 **/ | |
18 | |
19 | |
20 #pragma once | |
21 | |
22 #include "../TransferBucket.h" | |
23 | |
20 | 24 #include <Cache/LeastRecentlyUsedIndex.h> |
0 | 25 |
26 #include <boost/thread/mutex.hpp> | |
27 | |
28 namespace OrthancPlugins | |
29 { | |
30 class ActivePushTransactions : public boost::noncopyable | |
31 { | |
32 private: | |
33 class Transaction; | |
34 | |
35 typedef Orthanc::LeastRecentlyUsedIndex<std::string> Index; | |
36 typedef std::map<std::string, Transaction*> Content; | |
37 | |
38 boost::mutex mutex_; | |
39 Content content_; | |
40 Index index_; | |
41 size_t maxSize_; | |
42 | |
8
4c3437217518
fix for compatibility with simplified OrthancPluginCppWrapper
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
0
diff
changeset
|
43 void FinalizeTransaction(const std::string& transactionUuid, |
0 | 44 bool commit); |
45 | |
46 public: | |
12 | 47 explicit ActivePushTransactions(size_t maxSize) : |
0 | 48 maxSize_(maxSize) |
49 { | |
50 } | |
51 | |
52 ~ActivePushTransactions(); | |
53 | |
54 void ListTransactions(std::vector<std::string>& target); | |
55 | |
56 std::string CreateTransaction(const std::vector<DicomInstanceInfo>& instances, | |
57 const std::vector<TransferBucket>& buckets, | |
58 BucketCompression compression); | |
59 | |
8
4c3437217518
fix for compatibility with simplified OrthancPluginCppWrapper
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
0
diff
changeset
|
60 void Store(const std::string& transactionUuid, |
0 | 61 size_t bucketIndex, |
62 const void* data, | |
63 size_t size); | |
64 | |
8
4c3437217518
fix for compatibility with simplified OrthancPluginCppWrapper
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
0
diff
changeset
|
65 void Commit(const std::string& transactionUuid) |
0 | 66 { |
8
4c3437217518
fix for compatibility with simplified OrthancPluginCppWrapper
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
0
diff
changeset
|
67 FinalizeTransaction(transactionUuid, true); |
0 | 68 } |
69 | |
70 void Discard(const std::string& transactionUuid) | |
71 { | |
8
4c3437217518
fix for compatibility with simplified OrthancPluginCppWrapper
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
0
diff
changeset
|
72 FinalizeTransaction(transactionUuid, false); |
0 | 73 } |
74 }; | |
75 } |