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

annotate OrthancStone/Sources/Loaders/OracleScheduler.cpp @ 1598:8563ea5d8ae4

relicensing some files, cf. osimis bm26 and chu agreement on 2020-05-20

author	Sebastien Jodogne <s.jodogne@gmail.com>
date	Mon, 26 Oct 2020 20:49:28 +0100
parents	4fb8fdf03314
children	52b8b96cb55f

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
1271 0ca50d275b9a upgrade to year 2020 Sebastien Jodogne <s.jodogne@gmail.com> parents: 1228 diff changeset	5 * Copyright (C) 2017-2020 Osimis S.A., Belgium
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	6 *
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	7 * 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	8 * 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	9 * 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	10 * 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	11 *
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	12 * 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	13 * 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	14 * 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	15 * Lesser General Public License for more details.
1596 4fb8fdf03314 removed annoying whitespace Sebastien Jodogne <s.jodogne@gmail.com> parents: 1571 diff changeset	16 *
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	17 * 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	18 * 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	19 * <http://www.gnu.org/licenses/>.
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	20 **/
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 #include "OracleScheduler.h"
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	24
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	25 #include "../Oracle/ParseDicomFromFileCommand.h"
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	26
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	27 namespace OrthancStone
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	28 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	29 class OracleScheduler::ReceiverPayload : public Orthanc::IDynamicObject
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	30 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	31 private:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	32 Priority priority_;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	33 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	34 std::unique_ptr<IOracleCommand> command_;
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	35
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	36 public:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	37 ReceiverPayload(Priority priority,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	38 boost::weak_ptr<IObserver> receiver,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	39 IOracleCommand* command) :
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	40 priority_(priority),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	41 receiver_(receiver),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	42 command_(command)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	43 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	44 if (command == NULL)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	45 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	46 throw Orthanc::OrthancException(Orthanc::ErrorCode_NullPointer);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	47 }
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 Priority GetActivePriority() const
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	51 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	52 return priority_;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	53 }
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 boost::weak_ptr<IObserver> GetOriginalReceiver() const
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	56 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	57 return receiver_;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	58 }
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 const IOracleCommand& GetOriginalCommand() const
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	61 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	62 assert(command_.get() != NULL);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	63 return *command_;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	64 }
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 class OracleScheduler::ScheduledCommand : public boost::noncopyable
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	69 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	70 private:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	71 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	72 std::unique_ptr<IOracleCommand> command_;
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	73
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	74 public:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	75 ScheduledCommand(boost::shared_ptr<IObserver> receiver,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	76 IOracleCommand* command) :
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	77 receiver_(receiver),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	78 command_(command)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	79 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	80 if (command == NULL)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	81 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	82 throw Orthanc::OrthancException(Orthanc::ErrorCode_NullPointer);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	83 }
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 boost::weak_ptr<IObserver> GetReceiver()
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	87 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	88 return receiver_;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	89 }
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 bool IsSameReceiver(boost::shared_ptr<OrthancStone::IObserver> receiver) const
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	92 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	93 boost::shared_ptr<IObserver> lock(receiver_.lock());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	94
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	95 return (lock &&
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	96 lock.get() == receiver.get());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	97 }
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 IOracleCommand* WrapCommand(Priority priority)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	100 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	101 if (command_.get() == NULL)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	102 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	103 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	104 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	105 else
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	106 {
1299 c38c89684d83 replacing std::auto_ptr by std::unique_ptr Sebastien Jodogne <s.jodogne@gmail.com> parents: 1271 diff changeset	107 std::unique_ptr<IOracleCommand> wrapped(command_->Clone());
1228 c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	108 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	109 return wrapped.release();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	110 }
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 void OracleScheduler::ClearQueue(Queue& queue)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	117 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	118 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	119 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	120 assert(it->second != NULL);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	121 delete it->second;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	122
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	123 totalProcessed_ ++;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	124 }
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 queue.clear();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	127 }
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 void OracleScheduler::RemoveReceiverFromQueue(Queue& queue,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	131 boost::shared_ptr<IObserver> receiver)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	132 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	133 if (!receiver)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	134 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	135 throw Orthanc::OrthancException(Orthanc::ErrorCode_NullPointer);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	136 }
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 Queue tmp;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	139
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	140 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	141 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	142 assert(it->second != NULL);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	143
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	144 if (!(it->second->IsSameReceiver(receiver)))
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	145 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	146 // This promise is still active
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	147 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	148 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	149 else
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	150 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	151 delete it->second;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	152
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	153 totalProcessed_ ++;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	154 }
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 queue = tmp;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	158 }
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 void OracleScheduler::CheckInvariants() const
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	162 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	163 #ifndef NDEBUG
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	164 /*char buf[1024];
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	165 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	166 activeHighPriorityCommands_, activeStandardPriorityCommands_, activeLowPriorityCommands_,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	167 highPriorityQueue_.size(), standardPriorityQueue_.size(), lowPriorityQueue_.size());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	168 LOG(INFO) << buf;*/
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	169
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	170 assert(activeHighPriorityCommands_ <= maxHighPriorityCommands_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	171 assert(activeStandardPriorityCommands_ <= maxStandardPriorityCommands_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	172 assert(activeLowPriorityCommands_ <= maxLowPriorityCommands_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	173 assert(totalProcessed_ <= totalScheduled_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	174
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	175 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	176 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	177 assert(it->first > PRIORITY_HIGH &&
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	178 it->first < PRIORITY_LOW);
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
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	181 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	182 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	183 assert(it->first <= PRIORITY_HIGH);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	184 }
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 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	187 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	188 assert(it->first >= PRIORITY_LOW);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	189 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	190 #endif
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	191 }
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 void OracleScheduler::SpawnFromQueue(Queue& queue,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	195 Priority priority)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	196 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	197 CheckInvariants();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	198
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	199 Queue::iterator item = queue.begin();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	200 assert(item != queue.end());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	201
1299 c38c89684d83 replacing std::auto_ptr by std::unique_ptr Sebastien Jodogne <s.jodogne@gmail.com> parents: 1271 diff changeset	202 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	203 queue.erase(item);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	204
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	205 if (command.get() != NULL)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	206 {
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 * 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	209 * receiver has not been destroyed yet.
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	210 **/
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	211 boost::shared_ptr<IObserver> observer(command->GetReceiver().lock());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	212 if (observer)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	213 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	214 if (oracle_.Schedule(GetSharedObserver(), command->WrapCommand(priority)))
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	215 {
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 * Executing this code if "Schedule()" returned "false"
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	218 * above, will result in a memory leak within
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	219 * "OracleScheduler", as the scheduler believes that some
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	220 * 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	221 * the oracle), hereby stalling the scheduler during its
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	222 * destruction, and not freeing the
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	223 * "shared_ptr<OracleScheduler>" of the Stone context (check
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	224 * out "sjo-playground/WebViewer/Backend/Leak")
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
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	227 switch (priority)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	228 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	229 case Priority_High:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	230 activeHighPriorityCommands_ ++;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	231 break;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	232
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	233 case Priority_Standard:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	234 activeStandardPriorityCommands_ ++;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	235 break;
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 case Priority_Low:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	238 activeLowPriorityCommands_ ++;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	239 break;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	240
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	241 default:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	242 throw Orthanc::OrthancException(Orthanc::ErrorCode_ParameterOutOfRange);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	243 }
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 else
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 totalProcessed_ ++;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	248 }
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 else
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	252 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	253 LOG(ERROR) << "NULL command, should never happen";
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	254 }
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 CheckInvariants();
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
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 void OracleScheduler::SpawnCommands()
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	261 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	262 // 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	263 while (!highPriorityQueue_.empty())
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 if (activeHighPriorityCommands_ < maxHighPriorityCommands_)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	266 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	267 // First fill the high-priority lane
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	268 SpawnFromQueue(highPriorityQueue_, Priority_High);
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 else if (activeStandardPriorityCommands_ < maxStandardPriorityCommands_)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	271 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	272 // 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	273 // 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	274 SpawnFromQueue(highPriorityQueue_, Priority_Standard);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	275 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	276 else if (activeLowPriorityCommands_ < maxLowPriorityCommands_)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	277 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	278 SpawnFromQueue(highPriorityQueue_, Priority_Low);
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 else
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 return; // No slot available
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	283 }
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 while (!standardPriorityQueue_.empty())
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	287 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	288 if (activeStandardPriorityCommands_ < maxStandardPriorityCommands_)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	289 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	290 SpawnFromQueue(standardPriorityQueue_, Priority_Standard);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	291 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	292 else if (activeLowPriorityCommands_ < maxLowPriorityCommands_)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	293 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	294 SpawnFromQueue(standardPriorityQueue_, Priority_Low);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	295 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	296 else
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	297 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	298 return;
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
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	302 while (!lowPriorityQueue_.empty())
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	303 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	304 if (activeLowPriorityCommands_ < maxLowPriorityCommands_)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	305 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	306 SpawnFromQueue(lowPriorityQueue_, Priority_Low);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	307 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	308 else
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	309 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	310 return;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	311 }
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 void OracleScheduler::RemoveActiveCommand(const ReceiverPayload& payload)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	317 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	318 CheckInvariants();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	319
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	320 totalProcessed_ ++;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	321
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	322 switch (payload.GetActivePriority())
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	323 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	324 case Priority_High:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	325 assert(activeHighPriorityCommands_ > 0);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	326 activeHighPriorityCommands_ --;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	327 break;
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 case Priority_Standard:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	330 assert(activeStandardPriorityCommands_ > 0);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	331 activeStandardPriorityCommands_ --;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	332 break;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	333
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	334 case Priority_Low:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	335 assert(activeLowPriorityCommands_ > 0);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	336 activeLowPriorityCommands_ --;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	337 break;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	338
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	339 default:
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	340 throw Orthanc::OrthancException(Orthanc::ErrorCode_InternalError);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	341 }
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 SpawnCommands();
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 CheckInvariants();
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
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 void OracleScheduler::Handle(const GetOrthancImageCommand::SuccessMessage& message)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	350 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	351 assert(message.GetOrigin().HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	352 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	353
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	354 RemoveActiveCommand(payload);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	355
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	356 GetOrthancImageCommand::SuccessMessage bis(
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	357 dynamic_cast<const GetOrthancImageCommand&>(payload.GetOriginalCommand()),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	358 message.GetImage(), message.GetMimeType());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	359 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
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
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 void OracleScheduler::Handle(const GetOrthancWebViewerJpegCommand::SuccessMessage& message)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	364 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	365 assert(message.GetOrigin().HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	366 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	367
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	368 RemoveActiveCommand(payload);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	369
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	370 GetOrthancWebViewerJpegCommand::SuccessMessage bis(
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	371 dynamic_cast<const GetOrthancWebViewerJpegCommand&>(payload.GetOriginalCommand()),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	372 message.GetImage());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	373 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
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
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 void OracleScheduler::Handle(const HttpCommand::SuccessMessage& message)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	378 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	379 assert(message.GetOrigin().HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	380 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	381
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	382 RemoveActiveCommand(payload);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	383
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	384 HttpCommand::SuccessMessage bis(
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	385 dynamic_cast<const HttpCommand&>(payload.GetOriginalCommand()),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	386 message.GetAnswerHeaders(), message.GetAnswer());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	387 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
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
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 void OracleScheduler::Handle(const OrthancRestApiCommand::SuccessMessage& message)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	392 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	393 assert(message.GetOrigin().HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	394 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	395
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	396 RemoveActiveCommand(payload);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	397
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	398 OrthancRestApiCommand::SuccessMessage bis(
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	399 dynamic_cast<const OrthancRestApiCommand&>(payload.GetOriginalCommand()),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	400 message.GetAnswerHeaders(), message.GetAnswer());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	401 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	402 }
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 #if ORTHANC_ENABLE_DCMTK == 1
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	406 void OracleScheduler::Handle(const ParseDicomSuccessMessage& message)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	407 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	408 assert(message.GetOrigin().HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	409 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	410
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	411 RemoveActiveCommand(payload);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	412
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	413 ParseDicomSuccessMessage bis(
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	414 dynamic_cast<const OracleCommandBase&>(payload.GetOriginalCommand()),
1484 121d01aa328e SeriesThumbnailsLoader working on raw dicom files Sebastien Jodogne <s.jodogne@gmail.com> parents: 1472 diff changeset	415 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	416 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	417 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	418 #endif
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	419
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 void OracleScheduler::Handle(const ReadFileCommand::SuccessMessage& message)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	422 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	423 assert(message.GetOrigin().HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	424 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	425
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	426 RemoveActiveCommand(payload);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	427
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	428 ReadFileCommand::SuccessMessage bis(
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	429 dynamic_cast<const ReadFileCommand&>(payload.GetOriginalCommand()),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	430 message.GetContent());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	431 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
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
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 void OracleScheduler::Handle(const OracleCommandExceptionMessage& message)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	436 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	437 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	438
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	439 assert(command.HasPayload());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	440 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	441
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	442 RemoveActiveCommand(payload);
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 OracleCommandExceptionMessage bis(payload.GetOriginalCommand(), message.GetException());
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	445 emitter_.EmitMessage(payload.GetOriginalReceiver(), bis);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	446 }
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 OracleScheduler::OracleScheduler(IOracle& oracle,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	450 IMessageEmitter& emitter,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	451 unsigned int maxHighPriority,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	452 unsigned int maxStandardPriority,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	453 unsigned int maxLowPriority) :
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	454 oracle_(oracle),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	455 emitter_(emitter),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	456 maxHighPriorityCommands_(maxHighPriority),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	457 maxStandardPriorityCommands_(maxStandardPriority),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	458 maxLowPriorityCommands_(maxLowPriority),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	459 activeHighPriorityCommands_(0),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	460 activeStandardPriorityCommands_(0),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	461 activeLowPriorityCommands_(0),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	462 totalScheduled_(0),
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	463 totalProcessed_(0)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	464 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	465 assert(PRIORITY_HIGH < 0 &&
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	466 PRIORITY_LOW > 0);
1472 474360793956 DicomResourcesLoader::Create() Sebastien Jodogne <s.jodogne@gmail.com> parents: 1299 diff changeset	467
1571 85e117739eca cppcheck Sebastien Jodogne <s.jodogne@gmail.com> parents: 1512 diff changeset	468 if (maxLowPriority == 0)
1228 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 // 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	471 throw Orthanc::OrthancException(Orthanc::ErrorCode_ParameterOutOfRange);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	472 }
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 boost::shared_ptr<OracleScheduler> OracleScheduler::Create(IOracle& oracle,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	477 IObservable& oracleObservable,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	478 IMessageEmitter& emitter,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	479 unsigned int maxHighPriority,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	480 unsigned int maxStandardPriority,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	481 unsigned int maxLowPriority)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	482 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	483 boost::shared_ptr<OracleScheduler> scheduler
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	484 (new OracleScheduler(oracle, emitter, maxHighPriority, maxStandardPriority, maxLowPriority));
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	485 scheduler->Register<GetOrthancImageCommand::SuccessMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	486 scheduler->Register<GetOrthancWebViewerJpegCommand::SuccessMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	487 scheduler->Register<HttpCommand::SuccessMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	488 scheduler->Register<OrthancRestApiCommand::SuccessMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	489 scheduler->Register<ReadFileCommand::SuccessMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	490 scheduler->Register<OracleCommandExceptionMessage>(oracleObservable, &OracleScheduler::Handle);
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 #if ORTHANC_ENABLE_DCMTK == 1
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	493 scheduler->Register<ParseDicomSuccessMessage>(oracleObservable, &OracleScheduler::Handle);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	494 #endif
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 return scheduler;
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
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 OracleScheduler::~OracleScheduler()
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 CancelAllRequests();
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
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 void OracleScheduler::CancelRequests(boost::shared_ptr<IObserver> 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 RemoveReceiverFromQueue(standardPriorityQueue_, receiver);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	509 RemoveReceiverFromQueue(highPriorityQueue_, receiver);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	510 RemoveReceiverFromQueue(lowPriorityQueue_, receiver);
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
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 void OracleScheduler::CancelAllRequests()
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 ClearQueue(standardPriorityQueue_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	517 ClearQueue(highPriorityQueue_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	518 ClearQueue(lowPriorityQueue_);
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	519 }
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 void OracleScheduler::Schedule(boost::shared_ptr<IObserver> receiver,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	523 int priority,
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	524 IOracleCommand* command /* Takes ownership */)
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	525 {
1299 c38c89684d83 replacing std::auto_ptr by std::unique_ptr Sebastien Jodogne <s.jodogne@gmail.com> parents: 1271 diff changeset	526 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	527
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 * 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	530 * to "scheduler->Register()" must be implemented for each
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	531 * possible oracle command.
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	532 **/
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	533 assert(command->GetType() == IOracleCommand::Type_GetOrthancImage \|\|
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	534 command->GetType() == IOracleCommand::Type_GetOrthancWebViewerJpeg \|\|
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	535 command->GetType() == IOracleCommand::Type_Http \|\|
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	536 command->GetType() == IOracleCommand::Type_OrthancRestApi \|\|
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	537 command->GetType() == IOracleCommand::Type_ParseDicomFromFile \|\|
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	538 command->GetType() == IOracleCommand::Type_ParseDicomFromWado \|\|
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	539 command->GetType() == IOracleCommand::Type_ReadFile);
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 if (priority <= PRIORITY_HIGH)
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 highPriorityQueue_.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 if (priority >= PRIORITY_LOW)
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 lowPriorityQueue_.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 else
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	550 {
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	551 standardPriorityQueue_.insert(std::make_pair(priority, pending.release()));
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	552 }
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 totalScheduled_ ++;
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	555
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	556 SpawnCommands();
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	557 }
c471a0aa137b adding the next generation of loaders Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	558 }

Mercurial > hg > orthanc-stone

annotate OrthancStone/Sources/Loaders/OracleScheduler.cpp @ 1598:8563ea5d8ae4