orthanc-stone: OrthancStone/Sources/Loaders/OracleScheduler.cpp annotate

annotate OrthancStone/Sources/Loaders/OracleScheduler.cpp @ 1983:20fa913272b7

drawing rectangle probe

author	Sebastien Jodogne <s.jodogne@gmail.com>
date	Mon, 31 Oct 2022 12:32:47 +0100
parents	3b2445574705
children	07964689cb0b

rev	line source
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	1 /**
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	2 * Stone of Orthanc
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	3 * Copyright (C) 2012-2016 Sebastien Jodogne, Medical Physics
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	4 * Department, University Hospital of Liege, Belgium
1871 7053b8a0aaec upgrade to year 2022 Sebastien Jodogne <s.jodogne@gmail.com> parents: 1870 diff changeset	5 * Copyright (C) 2017-2022 Osimis S.A., Belgium
7053b8a0aaec upgrade to year 2022 Sebastien Jodogne <s.jodogne@gmail.com> parents: 1870 diff changeset	6 * Copyright (C) 2021-2022 Sebastien Jodogne, ICTEAM UCLouvain, Belgium
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	7 *
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	8 * This program is free software: you can redistribute it and/or
1598 8563ea5d8ae4 relicensing some files, cf. osimis bm26 and chu agreement on 2020-05-20 Sebastien Jodogne <s.jodogne@gmail.com> parents: 1596 diff changeset	9 * modify it under the terms of the GNU Lesser General Public License
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	10 * as published by the Free Software Foundation, either version 3 of
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	11 * the License, or (at your option) any later version.
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	12 *
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	13 * This program is distributed in the hope that it will be useful, but
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	14 * WITHOUT ANY WARRANTY; without even the implied warranty of
1598 8563ea5d8ae4 relicensing some files, cf. osimis bm26 and chu agreement on 2020-05-20 Sebastien Jodogne <s.jodogne@gmail.com> parents: 1596 diff changeset	15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
8563ea5d8ae4 relicensing some files, cf. osimis bm26 and chu agreement on 2020-05-20 Sebastien Jodogne <s.jodogne@gmail.com> parents: 1596 diff changeset	16 * Lesser General Public License for more details.
1596 4fb8fdf03314 removed annoying whitespace Sebastien Jodogne <s.jodogne@gmail.com> parents: 1571 diff changeset	17 *
1598 8563ea5d8ae4 relicensing some files, cf. osimis bm26 and chu agreement on 2020-05-20 Sebastien Jodogne <s.jodogne@gmail.com> parents: 1596 diff changeset	18 * You should have received a copy of the GNU Lesser General Public
8563ea5d8ae4 relicensing some files, cf. osimis bm26 and chu agreement on 2020-05-20 Sebastien Jodogne <s.jodogne@gmail.com> parents: 1596 diff changeset	19 * License along with this program. If not, see
8563ea5d8ae4 relicensing some files, cf. osimis bm26 and chu agreement on 2020-05-20 Sebastien Jodogne <s.jodogne@gmail.com> parents: 1596 diff changeset	20 * <http://www.gnu.org/licenses/>.
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	21 **/
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	22
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	23
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	24 #include "OracleScheduler.h"
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	25
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	26 #include "../Oracle/ParseDicomFromFileCommand.h"
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	27
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	28 namespace OrthancStone
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	29 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	30 class OracleScheduler::ReceiverPayload : public Orthanc::IDynamicObject
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	31 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	32 private:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	33 Priority priority_;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	34 boost::weak_ptr<IObserver> receiver_;
1299 c38c89684d83 replacing std::auto_ptr by std::unique_ptr Sebastien Jodogne <s.jodogne@gmail.com> parents: 1271 diff changeset	35 std::unique_ptr<IOracleCommand> command_;
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	36
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	37 public:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	38 ReceiverPayload(Priority priority,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	39 boost::weak_ptr<IObserver> receiver,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	40 IOracleCommand* command) :
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	41 priority_(priority),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	42 receiver_(receiver),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	43 command_(command)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	44 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	45 if (command == NULL)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	46 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	47 throw Orthanc::OrthancException(Orthanc::ErrorCode_NullPointer);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	48 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	49 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	50
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	51 Priority GetActivePriority() const
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	52 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	53 return priority_;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	54 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	55
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	56 boost::weak_ptr<IObserver> GetOriginalReceiver() const
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	57 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	58 return receiver_;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	59 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	60
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	61 const IOracleCommand& GetOriginalCommand() const
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	62 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	63 assert(command_.get() != NULL);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	64 return *command_;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	65 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	66 };
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	67
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	68
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	69 class OracleScheduler::ScheduledCommand : public boost::noncopyable
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	70 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	71 private:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	72 boost::weak_ptr<IObserver> receiver_;
1299 c38c89684d83 replacing std::auto_ptr by std::unique_ptr Sebastien Jodogne <s.jodogne@gmail.com> parents: 1271 diff changeset	73 std::unique_ptr<IOracleCommand> command_;
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	74
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	75 public:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	76 ScheduledCommand(boost::shared_ptr<IObserver> receiver,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	77 IOracleCommand* command) :
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	78 receiver_(receiver),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	79 command_(command)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	80 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	81 if (command == NULL)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	82 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	83 throw Orthanc::OrthancException(Orthanc::ErrorCode_NullPointer);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	84 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	85 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	86
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	87 boost::weak_ptr<IObserver> GetReceiver()
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	88 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	89 return receiver_;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	90 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	91
1640 52b8b96cb55f cleaning namespaces Sebastien Jodogne <s.jodogne@gmail.com> parents: 1598 diff changeset	92 bool IsSameReceiver(boost::shared_ptr<IObserver> receiver) const
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	93 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	94 boost::shared_ptr<IObserver> lock(receiver_.lock());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	95
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	96 return (lock &&
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	97 lock.get() == receiver.get());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	98 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	99
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	100 IOracleCommand* WrapCommand(Priority priority)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	101 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	102 if (command_.get() == NULL)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	103 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	104 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	105 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	106 else
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	107 {
1299 c38c89684d83 replacing std::auto_ptr by std::unique_ptr Sebastien Jodogne <s.jodogne@gmail.com> parents: 1271 diff changeset	108 std::unique_ptr<IOracleCommand> wrapped(command_->Clone());
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	109 dynamic_cast<OracleCommandBase&>(*wrapped).AcquirePayload(new ReceiverPayload(priority, receiver_, command_.release()));
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	110 return wrapped.release();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	111 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	112 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	113 };
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	114
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	115
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	116
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	117 void OracleScheduler::ClearQueue(Queue& queue)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	118 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	119 for (Queue::iterator it = queue.begin(); it != queue.end(); ++it)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	120 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	121 assert(it->second != NULL);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	122 delete it->second;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	123
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	124 totalProcessed_ ++;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	125 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	126
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	127 queue.clear();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	128 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	129
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	130
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	131 void OracleScheduler::RemoveReceiverFromQueue(Queue& queue,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	132 boost::shared_ptr<IObserver> receiver)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	133 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	134 if (!receiver)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	135 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	136 throw Orthanc::OrthancException(Orthanc::ErrorCode_NullPointer);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	137 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	138
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	139 Queue tmp;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	140
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	141 for (Queue::iterator it = queue.begin(); it != queue.end(); ++it)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	142 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	143 assert(it->second != NULL);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	144
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	145 if (!(it->second->IsSameReceiver(receiver)))
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	146 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	147 // This promise is still active
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	148 tmp.insert(std::make_pair(it->first, it->second));
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	149 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	150 else
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	151 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	152 delete it->second;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	153
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	154 totalProcessed_ ++;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	155 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	156 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	157
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	158 queue = tmp;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	159 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	160
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	161
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	162 void OracleScheduler::CheckInvariants() const
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	163 {
1921 3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	164 #if 0
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	165 char buf[1024];
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	166 sprintf(buf, "active: %d %d %d ; pending: %lu %lu %lu",
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	167 activeHighPriorityCommands_, activeStandardPriorityCommands_, activeLowPriorityCommands_,
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	168 highPriorityQueue_.size(), standardPriorityQueue_.size(), lowPriorityQueue_.size());
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	169 LOG(WARNING) << buf;
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	170 #endif
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	171
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	172 #ifndef NDEBUG
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	173 assert(activeHighPriorityCommands_ <= maxHighPriorityCommands_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	174 assert(activeStandardPriorityCommands_ <= maxStandardPriorityCommands_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	175 assert(activeLowPriorityCommands_ <= maxLowPriorityCommands_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	176 assert(totalProcessed_ <= totalScheduled_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	177
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	178 for (Queue::const_iterator it = standardPriorityQueue_.begin(); it != standardPriorityQueue_.end(); ++it)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	179 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	180 assert(it->first > PRIORITY_HIGH &&
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	181 it->first < PRIORITY_LOW);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	182 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	183
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	184 for (Queue::const_iterator it = highPriorityQueue_.begin(); it != highPriorityQueue_.end(); ++it)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	185 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	186 assert(it->first <= PRIORITY_HIGH);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	187 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	188
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	189 for (Queue::const_iterator it = lowPriorityQueue_.begin(); it != lowPriorityQueue_.end(); ++it)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	190 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	191 assert(it->first >= PRIORITY_LOW);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	192 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	193 #endif
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	194 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	195
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	196
1921 3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	197 void OracleScheduler::ModifyNumberOfActiveCommands(Priority priority,
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	198 int delta)
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	199 {
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	200 switch (priority)
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	201 {
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	202 case Priority_High:
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	203 assert(static_cast<int>(activeHighPriorityCommands_) + delta >= 0);
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	204 activeHighPriorityCommands_ += delta;
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	205 break;
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	206
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	207 case Priority_Standard:
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	208 assert(static_cast<int>(activeStandardPriorityCommands_) + delta >= 0);
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	209 activeStandardPriorityCommands_ += delta;
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	210 break;
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	211
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	212 case Priority_Low:
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	213 assert(static_cast<int>(activeLowPriorityCommands_) + delta >= 0);
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	214 activeLowPriorityCommands_ += delta;
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	215 break;
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	216
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	217 default:
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	218 throw Orthanc::OrthancException(Orthanc::ErrorCode_ParameterOutOfRange);
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	219 }
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	220 }
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	221
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	222
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	223 void OracleScheduler::SpawnFromQueue(Queue& queue,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	224 Priority priority)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	225 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	226 CheckInvariants();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	227
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	228 Queue::iterator item = queue.begin();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	229 assert(item != queue.end());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	230
1299 c38c89684d83 replacing std::auto_ptr by std::unique_ptr Sebastien Jodogne <s.jodogne@gmail.com> parents: 1271 diff changeset	231 std::unique_ptr<ScheduledCommand> command(dynamic_cast<ScheduledCommand*>(item->second));
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	232 queue.erase(item);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	233
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	234 if (command.get() != NULL)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	235 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	236 /**
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	237 * Only schedule the command for execution in the oracle, if its
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	238 * receiver has not been destroyed yet.
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	239 **/
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	240 boost::shared_ptr<IObserver> observer(command->GetReceiver().lock());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	241 if (observer)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	242 {
1921 3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	243 ModifyNumberOfActiveCommands(priority, 1);
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	244
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	245 if (oracle_.Schedule(GetSharedObserver(), command->WrapCommand(priority)))
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	246 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	247 /**
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	248 * Executing this code if "Schedule()" returned "false"
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	249 * above, will result in a memory leak within
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	250 * "OracleScheduler", as the scheduler believes that some
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	251 * command is still active (i.e. pending to be executed by
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	252 * the oracle), hereby stalling the scheduler during its
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	253 * destruction, and not freeing the
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	254 * "shared_ptr<OracleScheduler>" of the Stone context (check
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	255 * out "sjo-playground/WebViewer/Backend/Leak")
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	256 **/
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	257 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	258 else
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	259 {
1921 3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	260 // This is similar to "RemoveActiveCommand()"
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	261 ModifyNumberOfActiveCommands(priority, -1);
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	262 totalProcessed_ ++;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	263 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	264 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	265 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	266 else
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	267 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	268 LOG(ERROR) << "NULL command, should never happen";
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	269 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	270
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	271 CheckInvariants();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	272 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	273
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	274
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	275 void OracleScheduler::SpawnCommands()
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	276 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	277 // Send as many commands as possible to the oracle
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	278 while (!highPriorityQueue_.empty())
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	279 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	280 if (activeHighPriorityCommands_ < maxHighPriorityCommands_)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	281 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	282 // First fill the high-priority lane
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	283 SpawnFromQueue(highPriorityQueue_, Priority_High);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	284 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	285 else if (activeStandardPriorityCommands_ < maxStandardPriorityCommands_)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	286 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	287 // There remain too many high-priority commands for the
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	288 // high-priority lane, schedule them to the standard-priority lanes
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	289 SpawnFromQueue(highPriorityQueue_, Priority_Standard);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	290 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	291 else if (activeLowPriorityCommands_ < maxLowPriorityCommands_)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	292 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	293 SpawnFromQueue(highPriorityQueue_, Priority_Low);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	294 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	295 else
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	296 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	297 return; // No slot available
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	298 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	299 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	300
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	301 while (!standardPriorityQueue_.empty())
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	302 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	303 if (activeStandardPriorityCommands_ < maxStandardPriorityCommands_)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	304 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	305 SpawnFromQueue(standardPriorityQueue_, Priority_Standard);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	306 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	307 else if (activeLowPriorityCommands_ < maxLowPriorityCommands_)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	308 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	309 SpawnFromQueue(standardPriorityQueue_, Priority_Low);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	310 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	311 else
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	312 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	313 return;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	314 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	315 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	316
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	317 while (!lowPriorityQueue_.empty())
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	318 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	319 if (activeLowPriorityCommands_ < maxLowPriorityCommands_)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	320 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	321 SpawnFromQueue(lowPriorityQueue_, Priority_Low);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	322 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	323 else
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	324 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	325 return;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	326 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	327 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	328 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	329
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	330
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	331 void OracleScheduler::RemoveActiveCommand(const ReceiverPayload& payload)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	332 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	333 CheckInvariants();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	334
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	335 totalProcessed_ ++;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	336
1921 3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	337 ModifyNumberOfActiveCommands(payload.GetActivePriority(), -1);
3b2445574705 fix OracleScheduler::SpawnFromQueue() if using cache Sebastien Jodogne <s.jodogne@gmail.com> parents: 1871 diff changeset	338
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	339 SpawnCommands();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	340
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	341 CheckInvariants();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	342 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	343
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	344
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	345 void OracleScheduler::Handle(const GetOrthancImageCommand::SuccessMessage& message)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	346 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	347 assert(message.GetOrigin().HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	348 const ReceiverPayload& payload = dynamic_cast<const ReceiverPayload&>(message.GetOrigin().GetPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	349
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	350 RemoveActiveCommand(payload);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	351
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	352 GetOrthancImageCommand::SuccessMessage bis(
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	353 dynamic_cast<const GetOrthancImageCommand&>(payload.GetOriginalCommand()),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	354 message.GetImage(), message.GetMimeType());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	355 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	356 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	357
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	358
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	359 void OracleScheduler::Handle(const GetOrthancWebViewerJpegCommand::SuccessMessage& message)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	360 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	361 assert(message.GetOrigin().HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	362 const ReceiverPayload& payload = dynamic_cast<const ReceiverPayload&>(message.GetOrigin().GetPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	363
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	364 RemoveActiveCommand(payload);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	365
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	366 GetOrthancWebViewerJpegCommand::SuccessMessage bis(
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	367 dynamic_cast<const GetOrthancWebViewerJpegCommand&>(payload.GetOriginalCommand()),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	368 message.GetImage());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	369 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	370 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	371
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	372
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	373 void OracleScheduler::Handle(const HttpCommand::SuccessMessage& message)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	374 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	375 assert(message.GetOrigin().HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	376 const ReceiverPayload& payload = dynamic_cast<const ReceiverPayload&>(message.GetOrigin().GetPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	377
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	378 RemoveActiveCommand(payload);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	379
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	380 HttpCommand::SuccessMessage bis(
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	381 dynamic_cast<const HttpCommand&>(payload.GetOriginalCommand()),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	382 message.GetAnswerHeaders(), message.GetAnswer());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	383 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	384 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	385
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	386
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	387 void OracleScheduler::Handle(const OrthancRestApiCommand::SuccessMessage& message)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	388 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	389 assert(message.GetOrigin().HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	390 const ReceiverPayload& payload = dynamic_cast<const ReceiverPayload&>(message.GetOrigin().GetPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	391
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	392 RemoveActiveCommand(payload);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	393
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	394 OrthancRestApiCommand::SuccessMessage bis(
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	395 dynamic_cast<const OrthancRestApiCommand&>(payload.GetOriginalCommand()),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	396 message.GetAnswerHeaders(), message.GetAnswer());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	397 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	398 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	399
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	400
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	401 #if ORTHANC_ENABLE_DCMTK == 1
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	402 void OracleScheduler::Handle(const ParseDicomSuccessMessage& message)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	403 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	404 assert(message.GetOrigin().HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	405 const ReceiverPayload& payload = dynamic_cast<const ReceiverPayload&>(message.GetOrigin().GetPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	406
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	407 RemoveActiveCommand(payload);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	408
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	409 ParseDicomSuccessMessage bis(
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	410 dynamic_cast<const OracleCommandBase&>(payload.GetOriginalCommand()),
1484 121d01aa328e SeriesThumbnailsLoader working on raw dicom files Sebastien Jodogne <s.jodogne@gmail.com> parents: 1472 diff changeset	411 message.GetSource(), message.GetDicom(), message.GetFileSize(), message.HasPixelData());
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	412 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	413 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	414 #endif
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	415
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	416
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	417 void OracleScheduler::Handle(const ReadFileCommand::SuccessMessage& message)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	418 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	419 assert(message.GetOrigin().HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	420 const ReceiverPayload& payload = dynamic_cast<const ReceiverPayload&>(message.GetOrigin().GetPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	421
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	422 RemoveActiveCommand(payload);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	423
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	424 ReadFileCommand::SuccessMessage bis(
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	425 dynamic_cast<const ReadFileCommand&>(payload.GetOriginalCommand()),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	426 message.GetContent());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	427 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	428 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	429
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	430
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	431 void OracleScheduler::Handle(const OracleCommandExceptionMessage& message)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	432 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	433 const OracleCommandBase& command = dynamic_cast<const OracleCommandBase&>(message.GetOrigin());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	434
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	435 assert(command.HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	436 const ReceiverPayload& payload = dynamic_cast<const ReceiverPayload&>(command.GetPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	437
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	438 RemoveActiveCommand(payload);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	439
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	440 OracleCommandExceptionMessage bis(payload.GetOriginalCommand(), message.GetException());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	441 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	442 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	443
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	444
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	445 OracleScheduler::OracleScheduler(IOracle& oracle,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	446 IMessageEmitter& emitter,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	447 unsigned int maxHighPriority,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	448 unsigned int maxStandardPriority,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	449 unsigned int maxLowPriority) :
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	450 oracle_(oracle),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	451 emitter_(emitter),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	452 maxHighPriorityCommands_(maxHighPriority),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	453 maxStandardPriorityCommands_(maxStandardPriority),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	454 maxLowPriorityCommands_(maxLowPriority),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	455 activeHighPriorityCommands_(0),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	456 activeStandardPriorityCommands_(0),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	457 activeLowPriorityCommands_(0),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	458 totalScheduled_(0),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	459 totalProcessed_(0)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	460 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	461 assert(PRIORITY_HIGH < 0 &&
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	462 PRIORITY_LOW > 0);
1472 474360793956 DicomResourcesLoader::Create() Sebastien Jodogne <s.jodogne@gmail.com> parents: 1299 diff changeset	463
1571 85e117739eca cppcheck Sebastien Jodogne <s.jodogne@gmail.com> parents: 1512 diff changeset	464 if (maxLowPriority == 0)
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	465 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	466 // There must be at least 1 lane available to deal with low-priority commands
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	467 throw Orthanc::OrthancException(Orthanc::ErrorCode_ParameterOutOfRange);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	468 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	469 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	470
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	471
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	472 boost::shared_ptr<OracleScheduler> OracleScheduler::Create(IOracle& oracle,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	473 IObservable& oracleObservable,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	474 IMessageEmitter& emitter,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	475 unsigned int maxHighPriority,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	476 unsigned int maxStandardPriority,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	477 unsigned int maxLowPriority)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	478 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	479 boost::shared_ptr<OracleScheduler> scheduler
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	480 (new OracleScheduler(oracle, emitter, maxHighPriority, maxStandardPriority, maxLowPriority));
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	481 scheduler->Register<GetOrthancImageCommand::SuccessMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	482 scheduler->Register<GetOrthancWebViewerJpegCommand::SuccessMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	483 scheduler->Register<HttpCommand::SuccessMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	484 scheduler->Register<OrthancRestApiCommand::SuccessMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	485 scheduler->Register<ReadFileCommand::SuccessMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	486 scheduler->Register<OracleCommandExceptionMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	487
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	488 #if ORTHANC_ENABLE_DCMTK == 1
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	489 scheduler->Register<ParseDicomSuccessMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	490 #endif
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	491
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	492 return scheduler;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	493 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	494
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	495
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	496 OracleScheduler::~OracleScheduler()
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	497 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	498 CancelAllRequests();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	499 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	500
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	501
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	502 void OracleScheduler::CancelRequests(boost::shared_ptr<IObserver> receiver)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	503 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	504 RemoveReceiverFromQueue(standardPriorityQueue_, receiver);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	505 RemoveReceiverFromQueue(highPriorityQueue_, receiver);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	506 RemoveReceiverFromQueue(lowPriorityQueue_, receiver);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	507 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	508
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	509
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	510 void OracleScheduler::CancelAllRequests()
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	511 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	512 ClearQueue(standardPriorityQueue_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	513 ClearQueue(highPriorityQueue_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	514 ClearQueue(lowPriorityQueue_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	515 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	516
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	517
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	518 void OracleScheduler::Schedule(boost::shared_ptr<IObserver> receiver,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	519 int priority,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	520 IOracleCommand* command /* Takes ownership */)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	521 {
1299 c38c89684d83 replacing std::auto_ptr by std::unique_ptr Sebastien Jodogne <s.jodogne@gmail.com> parents: 1271 diff changeset	522 std::unique_ptr<ScheduledCommand> pending(new ScheduledCommand(receiver, dynamic_cast<IOracleCommand*>(command)));
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	523
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	524 /**
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	525 * Safeguard to remember that a new "Handle()" method and a call
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	526 * to "scheduler->Register()" must be implemented for each
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	527 * possible oracle command.
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	528 **/
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	529 assert(command->GetType() == IOracleCommand::Type_GetOrthancImage \|\|
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	530 command->GetType() == IOracleCommand::Type_GetOrthancWebViewerJpeg \|\|
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	531 command->GetType() == IOracleCommand::Type_Http \|\|
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	532 command->GetType() == IOracleCommand::Type_OrthancRestApi \|\|
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	533 command->GetType() == IOracleCommand::Type_ParseDicomFromFile \|\|
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	534 command->GetType() == IOracleCommand::Type_ParseDicomFromWado \|\|
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	535 command->GetType() == IOracleCommand::Type_ReadFile);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	536
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	537 if (priority <= PRIORITY_HIGH)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	538 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	539 highPriorityQueue_.insert(std::make_pair(priority, pending.release()));
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	540 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	541 else if (priority >= PRIORITY_LOW)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	542 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	543 lowPriorityQueue_.insert(std::make_pair(priority, pending.release()));
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	544 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	545 else
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	546 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	547 standardPriorityQueue_.insert(std::make_pair(priority, pending.release()));
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	548 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	549
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	550 totalScheduled_ ++;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	551
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	552 SpawnCommands();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	553 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	554 }

Mercurial > hg > orthanc-stone

annotate OrthancStone/Sources/Loaders/OracleScheduler.cpp @ 1983:20fa913272b7