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

annotate OrthancStone/Sources/Loaders/OracleScheduler.cpp @ 1883:fba6e550e0ee

apply rescale slope/intercept in rendering plugin

author	Sebastien Jodogne <s.jodogne@gmail.com>
date	Wed, 12 Jan 2022 18:26:05 +0100
parents	7053b8a0aaec
children	3b2445574705

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 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	164 #ifndef NDEBUG
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	165 /*char buf[1024];
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	166 sprintf(buf, "active: %d %d %d ; pending: %lu %lu %lu",
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	167 activeHighPriorityCommands_, activeStandardPriorityCommands_, activeLowPriorityCommands_,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	168 highPriorityQueue_.size(), standardPriorityQueue_.size(), lowPriorityQueue_.size());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	169 LOG(INFO) << buf;*/
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	170
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	171 assert(activeHighPriorityCommands_ <= maxHighPriorityCommands_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	172 assert(activeStandardPriorityCommands_ <= maxStandardPriorityCommands_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	173 assert(activeLowPriorityCommands_ <= maxLowPriorityCommands_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	174 assert(totalProcessed_ <= totalScheduled_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	175
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	176 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	177 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	178 assert(it->first > PRIORITY_HIGH &&
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	179 it->first < PRIORITY_LOW);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	180 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	181
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	182 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	183 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	184 assert(it->first <= PRIORITY_HIGH);
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
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	187 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	188 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	189 assert(it->first >= PRIORITY_LOW);
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 #endif
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
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 void OracleScheduler::SpawnFromQueue(Queue& queue,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	196 Priority priority)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	197 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	198 CheckInvariants();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	199
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	200 Queue::iterator item = queue.begin();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	201 assert(item != queue.end());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	202
1299 c38c89684d83 replacing std::auto_ptr by std::unique_ptr Sebastien Jodogne <s.jodogne@gmail.com> parents: 1271 diff changeset	203 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	204 queue.erase(item);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	205
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	206 if (command.get() != NULL)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	207 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	208 /**
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	209 * 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	210 * receiver has not been destroyed yet.
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	211 **/
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	212 boost::shared_ptr<IObserver> observer(command->GetReceiver().lock());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	213 if (observer)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	214 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	215 if (oracle_.Schedule(GetSharedObserver(), command->WrapCommand(priority)))
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	216 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	217 /**
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	218 * Executing this code if "Schedule()" returned "false"
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	219 * above, will result in a memory leak within
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	220 * "OracleScheduler", as the scheduler believes that some
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	221 * 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	222 * the oracle), hereby stalling the scheduler during its
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	223 * destruction, and not freeing the
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	224 * "shared_ptr<OracleScheduler>" of the Stone context (check
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	225 * out "sjo-playground/WebViewer/Backend/Leak")
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	226 **/
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 switch (priority)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	229 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	230 case Priority_High:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	231 activeHighPriorityCommands_ ++;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	232 break;
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 case Priority_Standard:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	235 activeStandardPriorityCommands_ ++;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	236 break;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	237
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	238 case Priority_Low:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	239 activeLowPriorityCommands_ ++;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	240 break;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	241
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	242 default:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	243 throw Orthanc::OrthancException(Orthanc::ErrorCode_ParameterOutOfRange);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	244 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	245 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	246 else
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 totalProcessed_ ++;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	249 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	250 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	251 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	252 else
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	253 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	254 LOG(ERROR) << "NULL command, should never happen";
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	255 }
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 CheckInvariants();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	258 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	259
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	260
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	261 void OracleScheduler::SpawnCommands()
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	262 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	263 // 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	264 while (!highPriorityQueue_.empty())
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 if (activeHighPriorityCommands_ < maxHighPriorityCommands_)
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 // First fill the high-priority lane
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	269 SpawnFromQueue(highPriorityQueue_, Priority_High);
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 else if (activeStandardPriorityCommands_ < maxStandardPriorityCommands_)
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 // 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	274 // 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	275 SpawnFromQueue(highPriorityQueue_, Priority_Standard);
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 else if (activeLowPriorityCommands_ < maxLowPriorityCommands_)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	278 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	279 SpawnFromQueue(highPriorityQueue_, Priority_Low);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	280 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	281 else
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	282 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	283 return; // No slot available
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 }
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 while (!standardPriorityQueue_.empty())
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	288 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	289 if (activeStandardPriorityCommands_ < maxStandardPriorityCommands_)
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 SpawnFromQueue(standardPriorityQueue_, Priority_Standard);
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 else if (activeLowPriorityCommands_ < maxLowPriorityCommands_)
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 SpawnFromQueue(standardPriorityQueue_, Priority_Low);
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 else
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 return;
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 }
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 while (!lowPriorityQueue_.empty())
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 if (activeLowPriorityCommands_ < maxLowPriorityCommands_)
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 SpawnFromQueue(lowPriorityQueue_, Priority_Low);
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 else
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 return;
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 }
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 void OracleScheduler::RemoveActiveCommand(const ReceiverPayload& payload)
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 CheckInvariants();
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 totalProcessed_ ++;
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 switch (payload.GetActivePriority())
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 case Priority_High:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	326 assert(activeHighPriorityCommands_ > 0);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	327 activeHighPriorityCommands_ --;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	328 break;
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 case Priority_Standard:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	331 assert(activeStandardPriorityCommands_ > 0);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	332 activeStandardPriorityCommands_ --;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	333 break;
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 case Priority_Low:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	336 assert(activeLowPriorityCommands_ > 0);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	337 activeLowPriorityCommands_ --;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	338 break;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	339
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	340 default:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	341 throw Orthanc::OrthancException(Orthanc::ErrorCode_InternalError);
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 SpawnCommands();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	345
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	346 CheckInvariants();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	347 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	348
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 void OracleScheduler::Handle(const GetOrthancImageCommand::SuccessMessage& message)
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 assert(message.GetOrigin().HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	353 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	354
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	355 RemoveActiveCommand(payload);
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 GetOrthancImageCommand::SuccessMessage bis(
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	358 dynamic_cast<const GetOrthancImageCommand&>(payload.GetOriginalCommand()),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	359 message.GetImage(), message.GetMimeType());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	360 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	361 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	362
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 void OracleScheduler::Handle(const GetOrthancWebViewerJpegCommand::SuccessMessage& message)
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 assert(message.GetOrigin().HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	367 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	368
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	369 RemoveActiveCommand(payload);
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 GetOrthancWebViewerJpegCommand::SuccessMessage bis(
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	372 dynamic_cast<const GetOrthancWebViewerJpegCommand&>(payload.GetOriginalCommand()),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	373 message.GetImage());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	374 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	375 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	376
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 void OracleScheduler::Handle(const HttpCommand::SuccessMessage& message)
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 assert(message.GetOrigin().HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	381 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	382
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	383 RemoveActiveCommand(payload);
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 HttpCommand::SuccessMessage bis(
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	386 dynamic_cast<const HttpCommand&>(payload.GetOriginalCommand()),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	387 message.GetAnswerHeaders(), message.GetAnswer());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	388 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	389 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	390
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 void OracleScheduler::Handle(const OrthancRestApiCommand::SuccessMessage& message)
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 assert(message.GetOrigin().HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	395 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	396
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	397 RemoveActiveCommand(payload);
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 OrthancRestApiCommand::SuccessMessage bis(
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	400 dynamic_cast<const OrthancRestApiCommand&>(payload.GetOriginalCommand()),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	401 message.GetAnswerHeaders(), message.GetAnswer());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	402 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
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
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	405
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	406 #if ORTHANC_ENABLE_DCMTK == 1
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	407 void OracleScheduler::Handle(const ParseDicomSuccessMessage& message)
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 assert(message.GetOrigin().HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	410 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	411
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	412 RemoveActiveCommand(payload);
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 ParseDicomSuccessMessage bis(
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	415 dynamic_cast<const OracleCommandBase&>(payload.GetOriginalCommand()),
1484 121d01aa328e SeriesThumbnailsLoader working on raw dicom files Sebastien Jodogne <s.jodogne@gmail.com> parents: 1472 diff changeset	416 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	417 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
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 #endif
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	420
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 void OracleScheduler::Handle(const ReadFileCommand::SuccessMessage& message)
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 assert(message.GetOrigin().HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	425 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	426
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	427 RemoveActiveCommand(payload);
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 ReadFileCommand::SuccessMessage bis(
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	430 dynamic_cast<const ReadFileCommand&>(payload.GetOriginalCommand()),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	431 message.GetContent());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	432 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	433 }
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
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	436 void OracleScheduler::Handle(const OracleCommandExceptionMessage& message)
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 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	439
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	440 assert(command.HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	441 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	442
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	443 RemoveActiveCommand(payload);
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 OracleCommandExceptionMessage bis(payload.GetOriginalCommand(), message.GetException());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	446 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	447 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	448
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	449
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	450 OracleScheduler::OracleScheduler(IOracle& oracle,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	451 IMessageEmitter& emitter,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	452 unsigned int maxHighPriority,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	453 unsigned int maxStandardPriority,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	454 unsigned int maxLowPriority) :
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	455 oracle_(oracle),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	456 emitter_(emitter),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	457 maxHighPriorityCommands_(maxHighPriority),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	458 maxStandardPriorityCommands_(maxStandardPriority),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	459 maxLowPriorityCommands_(maxLowPriority),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	460 activeHighPriorityCommands_(0),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	461 activeStandardPriorityCommands_(0),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	462 activeLowPriorityCommands_(0),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	463 totalScheduled_(0),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	464 totalProcessed_(0)
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 assert(PRIORITY_HIGH < 0 &&
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	467 PRIORITY_LOW > 0);
1472 474360793956 DicomResourcesLoader::Create() Sebastien Jodogne <s.jodogne@gmail.com> parents: 1299 diff changeset	468
1571 85e117739eca cppcheck Sebastien Jodogne <s.jodogne@gmail.com> parents: 1512 diff changeset	469 if (maxLowPriority == 0)
1228 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 // 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	472 throw Orthanc::OrthancException(Orthanc::ErrorCode_ParameterOutOfRange);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	473 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	474 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	475
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	476
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	477 boost::shared_ptr<OracleScheduler> OracleScheduler::Create(IOracle& oracle,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	478 IObservable& oracleObservable,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	479 IMessageEmitter& emitter,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	480 unsigned int maxHighPriority,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	481 unsigned int maxStandardPriority,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	482 unsigned int maxLowPriority)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	483 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	484 boost::shared_ptr<OracleScheduler> scheduler
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	485 (new OracleScheduler(oracle, emitter, maxHighPriority, maxStandardPriority, maxLowPriority));
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	486 scheduler->Register<GetOrthancImageCommand::SuccessMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	487 scheduler->Register<GetOrthancWebViewerJpegCommand::SuccessMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	488 scheduler->Register<HttpCommand::SuccessMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	489 scheduler->Register<OrthancRestApiCommand::SuccessMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	490 scheduler->Register<ReadFileCommand::SuccessMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	491 scheduler->Register<OracleCommandExceptionMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	492
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	493 #if ORTHANC_ENABLE_DCMTK == 1
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	494 scheduler->Register<ParseDicomSuccessMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	495 #endif
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	496
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	497 return scheduler;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	498 }
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 OracleScheduler::~OracleScheduler()
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	502 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	503 CancelAllRequests();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	504 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	505
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	506
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	507 void OracleScheduler::CancelRequests(boost::shared_ptr<IObserver> receiver)
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 RemoveReceiverFromQueue(standardPriorityQueue_, receiver);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	510 RemoveReceiverFromQueue(highPriorityQueue_, receiver);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	511 RemoveReceiverFromQueue(lowPriorityQueue_, receiver);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	512 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	513
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	514
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	515 void OracleScheduler::CancelAllRequests()
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 ClearQueue(standardPriorityQueue_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	518 ClearQueue(highPriorityQueue_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	519 ClearQueue(lowPriorityQueue_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	520 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	521
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	522
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	523 void OracleScheduler::Schedule(boost::shared_ptr<IObserver> receiver,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	524 int priority,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	525 IOracleCommand* command /* Takes ownership */)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	526 {
1299 c38c89684d83 replacing std::auto_ptr by std::unique_ptr Sebastien Jodogne <s.jodogne@gmail.com> parents: 1271 diff changeset	527 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	528
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	529 /**
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	530 * 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	531 * to "scheduler->Register()" must be implemented for each
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	532 * possible oracle command.
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	533 **/
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	534 assert(command->GetType() == IOracleCommand::Type_GetOrthancImage \|\|
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	535 command->GetType() == IOracleCommand::Type_GetOrthancWebViewerJpeg \|\|
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	536 command->GetType() == IOracleCommand::Type_Http \|\|
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	537 command->GetType() == IOracleCommand::Type_OrthancRestApi \|\|
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	538 command->GetType() == IOracleCommand::Type_ParseDicomFromFile \|\|
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	539 command->GetType() == IOracleCommand::Type_ParseDicomFromWado \|\|
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	540 command->GetType() == IOracleCommand::Type_ReadFile);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	541
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	542 if (priority <= PRIORITY_HIGH)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	543 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	544 highPriorityQueue_.insert(std::make_pair(priority, pending.release()));
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	545 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	546 else if (priority >= PRIORITY_LOW)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	547 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	548 lowPriorityQueue_.insert(std::make_pair(priority, pending.release()));
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 else
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 standardPriorityQueue_.insert(std::make_pair(priority, pending.release()));
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
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	555 totalScheduled_ ++;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	556
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	557 SpawnCommands();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	558 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	559 }

Mercurial > hg > orthanc-stone

annotate OrthancStone/Sources/Loaders/OracleScheduler.cpp @ 1883:fba6e550e0ee