Mercurial > hg > orthanc-transfers
annotate Framework/HttpQueries/DetectTransferPlugin.cpp @ 77:1e396fb509ca default
updated copyright, as Orthanc Team now replaces Osimis
author | Sebastien Jodogne <s.jodogne@gmail.com> |
---|---|
date | Thu, 30 May 2024 22:44:10 +0200 |
parents | 44a0430d7899 |
children |
rev | line source |
---|---|
0 | 1 /** |
2 * Transfers accelerator plugin for Orthanc | |
77
1e396fb509ca
updated copyright, as Orthanc Team now replaces Osimis
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
33
diff
changeset
|
3 * Copyright (C) 2018-2023 Osimis S.A., Belgium |
1e396fb509ca
updated copyright, as Orthanc Team now replaces Osimis
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
33
diff
changeset
|
4 * Copyright (C) 2024-2024 Orthanc Team SRL, Belgium |
1e396fb509ca
updated copyright, as Orthanc Team now replaces Osimis
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
33
diff
changeset
|
5 * Copyright (C) 2021-2024 Sebastien Jodogne, ICTEAM UCLouvain, Belgium |
0 | 6 * |
7 * This program is free software: you can redistribute it and/or | |
8 * modify it under the terms of the GNU Affero General Public License | |
9 * as published by the Free Software Foundation, either version 3 of | |
10 * the License, or (at your option) any later version. | |
11 * | |
12 * This program is distributed in the hope that it will be useful, but | |
13 * WITHOUT ANY WARRANTY; without even the implied warranty of | |
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU | |
15 * Affero General Public License for more details. | |
16 * | |
17 * You should have received a copy of the GNU Affero General Public License | |
18 * along with this program. If not, see <http://www.gnu.org/licenses/>. | |
19 **/ | |
20 | |
21 | |
22 #include "DetectTransferPlugin.h" | |
23 | |
24 #include "../TransferToolbox.h" | |
25 #include "HttpQueriesRunner.h" | |
26 | |
30 | 27 #include <Logging.h> |
20 | 28 #include <OrthancException.h> |
31
cfeda58d0c8e
remove calls to deprecated classes of JsonCpp
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
30
diff
changeset
|
29 #include <Toolbox.h> |
0 | 30 |
31 | |
32 namespace OrthancPlugins | |
33 { | |
5
5e6de82bb10f
use of user properties instead of BidirectionalPeers option
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
4
diff
changeset
|
34 DetectTransferPlugin::DetectTransferPlugin(Result& result, |
0 | 35 const std::string& peer) : |
5
5e6de82bb10f
use of user properties instead of BidirectionalPeers option
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
4
diff
changeset
|
36 result_(result), |
0 | 37 peer_(peer), |
38 uri_(URI_PLUGINS) | |
39 { | |
5
5e6de82bb10f
use of user properties instead of BidirectionalPeers option
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
4
diff
changeset
|
40 result_[peer_] = false; |
0 | 41 } |
42 | |
43 | |
44 void DetectTransferPlugin::ReadBody(std::string& body) const | |
45 { | |
46 throw Orthanc::OrthancException(Orthanc::ErrorCode_InternalError); | |
47 } | |
48 | |
49 | |
50 void DetectTransferPlugin::HandleAnswer(const void* answer, | |
51 size_t size) | |
52 { | |
53 Json::Value value; | |
54 | |
10
c9e28e31262e
new option: MaxHttpRetries
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
9
diff
changeset
|
55 bool enabled = false; |
c9e28e31262e
new option: MaxHttpRetries
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
9
diff
changeset
|
56 |
31
cfeda58d0c8e
remove calls to deprecated classes of JsonCpp
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
30
diff
changeset
|
57 if (Orthanc::Toolbox::ReadJson(value, answer, size) && |
0 | 58 value.type() == Json::arrayValue) |
59 { | |
10
c9e28e31262e
new option: MaxHttpRetries
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
9
diff
changeset
|
60 // Loop over the plugins that are enabled on the remote peer |
0 | 61 for (Json::Value::ArrayIndex i = 0; i < value.size(); i++) |
62 { | |
63 if (value[i].type() == Json::stringValue && | |
64 value[i].asString() == PLUGIN_NAME) | |
65 { | |
5
5e6de82bb10f
use of user properties instead of BidirectionalPeers option
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
4
diff
changeset
|
66 result_[peer_] = true; |
10
c9e28e31262e
new option: MaxHttpRetries
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
9
diff
changeset
|
67 enabled = true; |
0 | 68 } |
69 } | |
70 } | |
10
c9e28e31262e
new option: MaxHttpRetries
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
9
diff
changeset
|
71 |
c9e28e31262e
new option: MaxHttpRetries
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
9
diff
changeset
|
72 if (enabled) |
c9e28e31262e
new option: MaxHttpRetries
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
9
diff
changeset
|
73 { |
c9e28e31262e
new option: MaxHttpRetries
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
9
diff
changeset
|
74 LOG(INFO) << "Peer \"" << peer_ << "\" has the transfers accelerator plugin enabled"; |
c9e28e31262e
new option: MaxHttpRetries
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
9
diff
changeset
|
75 } |
c9e28e31262e
new option: MaxHttpRetries
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
9
diff
changeset
|
76 else |
c9e28e31262e
new option: MaxHttpRetries
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
9
diff
changeset
|
77 { |
c9e28e31262e
new option: MaxHttpRetries
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
9
diff
changeset
|
78 LOG(WARNING) << "Peer \"" << peer_ << "\" does *not* have the transfers accelerator plugin enabled"; |
c9e28e31262e
new option: MaxHttpRetries
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
9
diff
changeset
|
79 } |
0 | 80 } |
81 | |
82 | |
5
5e6de82bb10f
use of user properties instead of BidirectionalPeers option
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
4
diff
changeset
|
83 void DetectTransferPlugin::Apply(Result& result, |
0 | 84 size_t threadsCount, |
85 unsigned int timeout) | |
86 { | |
8
4c3437217518
fix for compatibility with simplified OrthancPluginCppWrapper
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
5
diff
changeset
|
87 OrthancPlugins::HttpQueriesQueue queue; |
0 | 88 |
89 queue.GetOrthancPeers().SetTimeout(timeout); | |
90 queue.Reserve(queue.GetOrthancPeers().GetPeersCount()); | |
91 | |
92 for (size_t i = 0; i < queue.GetOrthancPeers().GetPeersCount(); i++) | |
93 { | |
94 queue.Enqueue(new OrthancPlugins::DetectTransferPlugin | |
5
5e6de82bb10f
use of user properties instead of BidirectionalPeers option
Sebastien Jodogne <s.jodogne@gmail.com>
parents:
4
diff
changeset
|
95 (result, queue.GetOrthancPeers().GetPeerName(i))); |
0 | 96 } |
97 | |
98 { | |
99 OrthancPlugins::HttpQueriesRunner runner(queue, threadsCount); | |
100 queue.WaitComplete(); | |
101 } | |
102 } | |
103 } |