orthanc-stone: Samples/Sdl/Loader.cpp annotate

annotate Samples/Sdl/Loader.cpp @ 623:42dadae61fa9

renamed IObservable::EmitMessage() as BroadcastMessage()

author	Sebastien Jodogne <s.jodogne@gmail.com>
date	Tue, 07 May 2019 14:16:08 +0200
parents	8a3a25f2d42c
children	2eeb5857eb43

rev	line source
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	1 /**
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	2 * Stone of Orthanc
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	3 * Copyright (C) 2012-2016 Sebastien Jodogne, Medical Physics
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	4 * Department, University Hospital of Liege, Belgium
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	5 * Copyright (C) 2017-2019 Osimis S.A., Belgium
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	6 *
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	7 * This program is free software: you can redistribute it and/or
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	8 * modify it under the terms of the GNU Affero General Public License
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	9 * as published by the Free Software Foundation, either version 3 of
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	10 * the License, or (at your option) any later version.
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	11 *
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	12 * This program is distributed in the hope that it will be useful, but
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	13 * WITHOUT ANY WARRANTY; without even the implied warranty of
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	15 * Affero General Public License for more details.
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	16 *
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	17 * You should have received a copy of the GNU Affero General Public License
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	18 * along with this program. If not, see <http://www.gnu.org/licenses/>.
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	19 **/
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	20
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	21 // From Stone
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	22 #include "../../Framework/StoneInitialization.h"
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	23 #include "../../Framework/Messages/IMessage.h"
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	24 #include "../../Framework/Messages/MessageBroker.h"
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	25 #include "../../Framework/Messages/ICallable.h"
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	26 #include "../../Framework/Messages/IObservable.h"
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	27 #include "../../Framework/Volumes/ImageBuffer3D.h"
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	28
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	29 // From Orthanc framework
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	30 #include <Core/IDynamicObject.h>
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	31 #include <Core/Images/Image.h>
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	32 #include <Core/Images/ImageProcessing.h>
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	33 #include <Core/Images/PngWriter.h>
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	34 #include <Core/Logging.h>
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	35 #include <Core/HttpClient.h>
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	36 #include <Core/MultiThreading/SharedMessageQueue.h>
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	37 #include <Core/OrthancException.h>
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	38
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	39 #include <json/reader.h>
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	40 #include <json/value.h>
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	41 #include <json/writer.h>
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	42
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	43 #include <list>
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	44 #include <stdio.h>
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	45
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	46
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	47
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	48 namespace Refactoring
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	49 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	50 class IOracleCommand : public boost::noncopyable
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	51 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	52 public:
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	53 enum Type
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	54 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	55 Type_OrthancApi
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	56 };
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	57
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	58 virtual ~IOracleCommand()
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	59 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	60 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	61
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	62 virtual Type GetType() const = 0;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	63 };
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	64
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	65
622 8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	66 class IMessageEmitter : public boost::noncopyable
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	67 {
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	68 public:
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	69 virtual ~IMessageEmitter()
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	70 {
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	71 }
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	72
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	73 virtual void EmitMessage(const OrthancStone::IObserver& observer,
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	74 const OrthancStone::IMessage& message) = 0;
622 8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	75 };
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	76
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	77
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	78 class IOracle : public boost::noncopyable
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	79 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	80 public:
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	81 virtual ~IOracle()
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	82 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	83 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	84
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	85 virtual void Schedule(const OrthancStone::IObserver& receiver,
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	86 IOracleCommand* command) = 0; // Takes ownership
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	87 };
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	88
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	89
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	90
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	91
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	92 class OracleCommandWithPayload : public IOracleCommand
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	93 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	94 private:
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	95 std::auto_ptr<Orthanc::IDynamicObject> payload_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	96
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	97 public:
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	98 void SetPayload(Orthanc::IDynamicObject* payload)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	99 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	100 if (payload == NULL)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	101 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	102 throw Orthanc::OrthancException(Orthanc::ErrorCode_NullPointer);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	103 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	104 else
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	105 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	106 payload_.reset(payload);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	107 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	108 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	109
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	110 bool HasPayload() const
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	111 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	112 return (payload_.get() != NULL);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	113 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	114
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	115 const Orthanc::IDynamicObject& GetPayload() const
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	116 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	117 if (HasPayload())
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	118 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	119 return *payload_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	120 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	121 else
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	122 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	123 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	124 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	125 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	126 };
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	127
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	128
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	129
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	130 typedef std::map<std::string, std::string> HttpHeaders;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	131
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	132 class OrthancApiOracleCommand : public OracleCommandWithPayload
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	133 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	134 public:
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	135 class SuccessMessage : public OrthancStone::OriginMessage<OrthancStone::MessageType_HttpRequestSuccess, // TODO
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	136 OrthancApiOracleCommand>
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	137 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	138 private:
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	139 HttpHeaders headers_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	140 std::string answer_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	141
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	142 public:
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	143 SuccessMessage(const OrthancApiOracleCommand& command,
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	144 const HttpHeaders& answerHeaders,
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	145 std::string& answer /* will be swapped to avoid a memcpy() */) :
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	146 OriginMessage(command),
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	147 headers_(answerHeaders),
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	148 answer_(answer)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	149 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	150 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	151
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	152 const std::string& GetAnswer() const
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	153 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	154 return answer_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	155 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	156
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	157 void GetJsonBody(Json::Value& target) const
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	158 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	159 Json::Reader reader;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	160 if (!reader.parse(answer_, target))
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	161 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	162 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadFileFormat);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	163 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	164 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	165
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	166 const HttpHeaders& GetAnswerHeaders() const
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	167 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	168 return headers_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	169 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	170 };
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	171
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	172
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	173 class FailureMessage : public OrthancStone::OriginMessage<OrthancStone::MessageType_HttpRequestError, // TODO
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	174 OrthancApiOracleCommand>
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	175 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	176 private:
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	177 Orthanc::HttpStatus status_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	178
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	179 public:
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	180 FailureMessage(const OrthancApiOracleCommand& command,
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	181 Orthanc::HttpStatus status) :
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	182 OriginMessage(command),
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	183 status_(status)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	184 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	185 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	186
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	187 Orthanc::HttpStatus GetHttpStatus() const
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	188 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	189 return status_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	190 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	191 };
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	192
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	193
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	194 private:
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	195 Orthanc::HttpMethod method_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	196 std::string uri_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	197 std::string body_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	198 HttpHeaders headers_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	199 unsigned int timeout_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	200
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	201 std::auto_ptr< OrthancStone::MessageHandler<SuccessMessage> > successCallback_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	202 std::auto_ptr< OrthancStone::MessageHandler<FailureMessage> > failureCallback_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	203
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	204 public:
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	205 OrthancApiOracleCommand() :
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	206 method_(Orthanc::HttpMethod_Get),
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	207 uri_("/"),
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	208 timeout_(10)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	209 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	210 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	211
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	212 virtual Type GetType() const
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	213 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	214 return Type_OrthancApi;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	215 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	216
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	217 void SetMethod(Orthanc::HttpMethod method)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	218 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	219 method_ = method;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	220 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	221
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	222 void SetUri(const std::string& uri)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	223 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	224 uri_ = uri;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	225 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	226
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	227 void SetBody(const std::string& body)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	228 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	229 body_ = body;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	230 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	231
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	232 void SetBody(const Json::Value& json)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	233 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	234 Json::FastWriter writer;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	235 body_ = writer.write(json);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	236 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	237
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	238 void SetHttpHeader(const std::string& key,
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	239 const std::string& value)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	240 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	241 headers_[key] = value;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	242 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	243
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	244 Orthanc::HttpMethod GetMethod() const
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	245 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	246 return method_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	247 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	248
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	249 const std::string& GetUri() const
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	250 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	251 return uri_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	252 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	253
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	254 const std::string& GetBody() const
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	255 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	256 if (method_ == Orthanc::HttpMethod_Post \|\|
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	257 method_ == Orthanc::HttpMethod_Put)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	258 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	259 return body_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	260 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	261 else
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	262 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	263 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	264 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	265 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	266
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	267 const HttpHeaders& GetHttpHeaders() const
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	268 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	269 return headers_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	270 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	271
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	272 void SetTimeout(unsigned int seconds)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	273 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	274 timeout_ = seconds;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	275 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	276
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	277 unsigned int GetTimeout() const
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	278 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	279 return timeout_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	280 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	281 };
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	282
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	283
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	284
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	285 class NativeOracle : public IOracle
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	286 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	287 private:
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	288 class Item : public Orthanc::IDynamicObject
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	289 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	290 private:
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	291 const OrthancStone::IObserver& receiver_;
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	292 std::auto_ptr<IOracleCommand> command_;
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	293
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	294 public:
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	295 Item(const OrthancStone::IObserver& receiver,
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	296 IOracleCommand* command) :
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	297 receiver_(receiver),
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	298 command_(command)
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	299 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	300 if (command == NULL)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	301 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	302 throw Orthanc::OrthancException(Orthanc::ErrorCode_NullPointer);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	303 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	304 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	305
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	306 const OrthancStone::IObserver& GetReceiver() const
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	307 {
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	308 return receiver_;
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	309 }
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	310
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	311 const IOracleCommand& GetCommand() const
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	312 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	313 assert(command_.get() != NULL);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	314 return *command_;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	315 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	316 };
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	317
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	318
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	319 enum State
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	320 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	321 State_Setup,
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	322 State_Running,
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	323 State_Stopped
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	324 };
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	325
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	326
622 8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	327 IMessageEmitter& emitter_;
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	328 Orthanc::WebServiceParameters orthanc_;
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	329 Orthanc::SharedMessageQueue queue_;
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	330 State state_;
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	331 boost::mutex mutex_;
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	332 std::vector<boost::thread*> workers_;
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	333
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	334
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	335 void Execute(const OrthancStone::IObserver& receiver,
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	336 const OrthancApiOracleCommand& command)
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	337 {
622 8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	338 Orthanc::HttpClient client(orthanc_, command.GetUri());
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	339 client.SetMethod(command.GetMethod());
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	340 client.SetBody(command.GetBody());
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	341 client.SetTimeout(command.GetTimeout());
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	342
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	343 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	344 const HttpHeaders& headers = command.GetHttpHeaders();
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	345 for (HttpHeaders::const_iterator it = headers.begin(); it != headers.end(); it++ )
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	346 {
622 8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	347 client.AddHeader(it->first, it->second);
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	348 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	349 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	350
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	351 std::string answer;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	352 HttpHeaders answerHeaders;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	353
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	354 bool success;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	355 try
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	356 {
622 8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	357 success = client.Apply(answer, answerHeaders);
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	358 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	359 catch (Orthanc::OrthancException& e)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	360 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	361 success = false;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	362 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	363
622 8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	364 if (success)
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	365 {
622 8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	366 OrthancApiOracleCommand::SuccessMessage message(command, answerHeaders, answer);
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	367 emitter_.EmitMessage(receiver, message);
622 8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	368 }
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	369 else
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	370 {
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	371 OrthancApiOracleCommand::FailureMessage message(command, client.GetLastStatus());
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	372 emitter_.EmitMessage(receiver, message);
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	373 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	374 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	375
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	376
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	377
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	378 void Step()
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	379 {
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	380 std::auto_ptr<Orthanc::IDynamicObject> object(queue_.Dequeue(100));
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	381
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	382 if (object.get() != NULL)
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	383 {
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	384 const Item& item = dynamic_cast<Item&>(*object);
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	385
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	386 switch (item.GetCommand().GetType())
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	387 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	388 case IOracleCommand::Type_OrthancApi:
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	389 Execute(item.GetReceiver(),
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	390 dynamic_cast<const OrthancApiOracleCommand&>(item.GetCommand()));
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	391 break;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	392
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	393 default:
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	394 throw Orthanc::OrthancException(Orthanc::ErrorCode_NotImplemented);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	395 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	396 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	397 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	398
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	399
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	400 static void Worker(NativeOracle* that)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	401 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	402 assert(that != NULL);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	403
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	404 for (;;)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	405 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	406 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	407 boost::mutex::scoped_lock lock(that->mutex_);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	408 if (that->state_ != State_Running)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	409 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	410 return;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	411 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	412 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	413
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	414 that->Step();
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	415 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	416 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	417
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	418
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	419 void StopInternal()
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	420 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	421 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	422 boost::mutex::scoped_lock lock(mutex_);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	423
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	424 if (state_ == State_Setup \|\|
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	425 state_ == State_Stopped)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	426 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	427 return;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	428 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	429 else
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	430 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	431 state_ = State_Stopped;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	432 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	433 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	434
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	435 for (size_t i = 0; i < workers_.size(); i++)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	436 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	437 if (workers_[i] != NULL)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	438 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	439 if (workers_[i]->joinable())
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	440 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	441 workers_[i]->join();
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	442 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	443
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	444 delete workers_[i];
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	445 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	446 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	447 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	448
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	449
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	450 public:
622 8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	451 NativeOracle(IMessageEmitter& emitter) :
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	452 emitter_(emitter),
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	453 state_(State_Setup),
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	454 workers_(4)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	455 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	456 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	457
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	458 virtual ~NativeOracle()
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	459 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	460 StopInternal();
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	461 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	462
622 8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	463 void SetOrthancParameters(const Orthanc::WebServiceParameters& orthanc)
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	464 {
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	465 boost::mutex::scoped_lock lock(mutex_);
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	466
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	467 if (state_ != State_Setup)
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	468 {
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	469 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls);
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	470 }
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	471 else
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	472 {
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	473 orthanc_ = orthanc;
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	474 }
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	475 }
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	476
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	477 void SetWorkersCount(unsigned int count)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	478 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	479 boost::mutex::scoped_lock lock(mutex_);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	480
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	481 if (count <= 0)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	482 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	483 throw Orthanc::OrthancException(Orthanc::ErrorCode_ParameterOutOfRange);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	484 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	485 else if (state_ != State_Setup)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	486 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	487 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	488 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	489 else
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	490 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	491 workers_.resize(count);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	492 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	493 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	494
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	495 void Start()
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	496 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	497 boost::mutex::scoped_lock lock(mutex_);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	498
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	499 if (state_ != State_Setup)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	500 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	501 throw Orthanc::OrthancException(Orthanc::ErrorCode_BadSequenceOfCalls);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	502 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	503 else
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	504 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	505 state_ = State_Running;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	506
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	507 for (unsigned int i = 0; i < workers_.size(); i++)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	508 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	509 workers_[i] = new boost::thread(Worker, this);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	510 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	511 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	512 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	513
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	514 void Stop()
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	515 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	516 StopInternal();
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	517 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	518
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	519 virtual void Schedule(const OrthancStone::IObserver& receiver,
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	520 IOracleCommand* command)
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	521 {
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	522 queue_.Enqueue(new Item(receiver, command));
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	523 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	524 };
622 8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	525
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	526
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	527
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	528 class NativeApplicationContext : public IMessageEmitter
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	529 {
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	530 private:
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	531 boost::shared_mutex mutex_;
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	532 OrthancStone::MessageBroker broker_;
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	533 OrthancStone::IObservable oracleObservable_;
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	534
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	535 public:
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	536 NativeApplicationContext() :
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	537 oracleObservable_(broker_)
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	538 {
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	539 }
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	540
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	541
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	542 virtual void EmitMessage(const OrthancStone::IObserver& observer,
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	543 const OrthancStone::IMessage& message)
622 8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	544 {
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	545 boost::unique_lock<boost::shared_mutex> lock(mutex_);
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	546 oracleObservable_.EmitMessage(observer, message);
622 8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	547 }
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	548
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	549
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	550 class ReaderLock : public boost::noncopyable
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	551 {
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	552 private:
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	553 NativeApplicationContext& that_;
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	554 boost::shared_lock<boost::shared_mutex> lock_;
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	555
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	556 public:
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	557 ReaderLock(NativeApplicationContext& that) :
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	558 that_(that),
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	559 lock_(that.mutex_)
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	560 {
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	561 }
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	562 };
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	563
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	564
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	565 class WriterLock : public boost::noncopyable
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	566 {
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	567 private:
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	568 NativeApplicationContext& that_;
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	569 boost::unique_lock<boost::shared_mutex> lock_;
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	570
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	571 public:
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	572 WriterLock(NativeApplicationContext& that) :
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	573 that_(that),
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	574 lock_(that.mutex_)
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	575 {
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	576 }
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	577
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	578 OrthancStone::MessageBroker& GetBroker()
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	579 {
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	580 return that_.broker_;
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	581 }
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	582
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	583 OrthancStone::IObservable& GetOracleObservable()
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	584 {
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	585 return that_.oracleObservable_;
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	586 }
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	587 };
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	588 };
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	589
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	590
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	591
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	592 class AxialVolumeOrthancLoader : public OrthancStone::IObserver
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	593 {
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	594 private:
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	595 void Handle(const Refactoring::OrthancApiOracleCommand::SuccessMessage& message)
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	596 {
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	597 Json::Value v;
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	598 message.GetJsonBody(v);
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	599
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	600 printf("ICI [%s]\n", v.toStyledString().c_str());
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	601 }
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	602
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	603
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	604 std::auto_ptr<OrthancStone::ImageBuffer3D> image_;
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	605
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	606
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	607 public:
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	608 AxialVolumeOrthancLoader(OrthancStone::IObservable& oracle) :
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	609 IObserver(oracle.GetBroker())
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	610 {
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	611 oracle.RegisterObserverCallback(
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	612 new OrthancStone::Callable<AxialVolumeOrthancLoader, OrthancApiOracleCommand::SuccessMessage>
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	613 (*this, &AxialVolumeOrthancLoader::Handle));
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	614 }
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	615 };
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	616
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	617 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	618
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	619
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	620
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	621 class Toto : public OrthancStone::IObserver
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	622 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	623 private:
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	624 void Handle(const Refactoring::OrthancApiOracleCommand::SuccessMessage& message)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	625 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	626 Json::Value v;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	627 message.GetJsonBody(v);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	628
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	629 printf("ICI [%s]\n", v.toStyledString().c_str());
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	630 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	631
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	632 void Handle(const Refactoring::OrthancApiOracleCommand::FailureMessage& message)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	633 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	634 printf("ERROR %d\n", message.GetHttpStatus());
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	635 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	636
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	637 public:
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	638 Toto(OrthancStone::IObservable& oracle) :
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	639 IObserver(oracle.GetBroker())
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	640 {
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	641 oracle.RegisterObserverCallback
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	642 (new OrthancStone::Callable
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	643 <Toto, Refactoring::OrthancApiOracleCommand::SuccessMessage>(*this, &Toto::Handle));
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	644 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	645 };
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	646
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	647
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	648 void Run(Refactoring::NativeApplicationContext& context)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	649 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	650 std::auto_ptr<Toto> toto;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	651
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	652 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	653 Refactoring::NativeApplicationContext::WriterLock lock(context);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	654 toto.reset(new Toto(lock.GetOracleObservable()));
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	655 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	656
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	657 std::auto_ptr<Refactoring::AxialVolumeOrthancLoader> loader;
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	658
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	659 {
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	660 Refactoring::NativeApplicationContext::WriterLock lock(context);
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	661 loader.reset(new Refactoring::AxialVolumeOrthancLoader(lock.GetOracleObservable()));
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	662 }
42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	663
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	664 Refactoring::NativeOracle oracle(context);
622 8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	665
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	666 {
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	667 Orthanc::WebServiceParameters p;
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	668 //p.SetUrl("http://localhost:8043/");
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	669 p.SetCredentials("orthanc", "orthanc");
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	670 oracle.SetOrthancParameters(p);
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	671 }
8a3a25f2d42c uncoupling oracle from context Sebastien Jodogne <s.jodogne@gmail.com> parents: 619 diff changeset	672
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	673 oracle.Start();
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	674
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	675 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	676 Json::Value v = Json::objectValue;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	677 v["Level"] = "Series";
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	678 v["Query"] = Json::objectValue;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	679
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	680 std::auto_ptr<Refactoring::OrthancApiOracleCommand> command(new Refactoring::OrthancApiOracleCommand);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	681 command->SetMethod(Orthanc::HttpMethod_Post);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	682 command->SetUri("/tools/find");
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	683 command->SetBody(v);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	684
623 42dadae61fa9 renamed IObservable::EmitMessage() as BroadcastMessage() Sebastien Jodogne <s.jodogne@gmail.com> parents: 622 diff changeset	685 oracle.Schedule(*toto, command.release());
619 9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	686 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	687
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	688 boost::this_thread::sleep(boost::posix_time::seconds(1));
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	689
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	690 oracle.Stop();
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	691 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	692
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	693
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	694
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	695 /**
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	696 * IMPORTANT: The full arguments to "main()" are needed for SDL on
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	697 * Windows. Otherwise, one gets the linking error "undefined reference
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	698 * to `SDL_main'". https://wiki.libsdl.org/FAQWindows
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	699 **/
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	700 int main(int argc, char* argv[])
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	701 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	702 OrthancStone::StoneInitialize();
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	703 Orthanc::Logging::EnableInfoLevel(true);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	704
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	705 try
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	706 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	707 Refactoring::NativeApplicationContext context;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	708 Run(context);
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	709 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	710 catch (Orthanc::OrthancException& e)
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	711 {
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	712 LOG(ERROR) << "EXCEPTION: " << e.What();
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	713 }
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	714
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	715 OrthancStone::StoneFinalize();
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	716
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	717 return 0;
9cd19b28f011 test: refactoring oracle Sebastien Jodogne <s.jodogne@gmail.com> parents: diff changeset	718 }

Mercurial > hg > orthanc-stone

annotate Samples/Sdl/Loader.cpp @ 623:42dadae61fa9