comparison Framework/Oracle/ThreadedOracle.h @ 1077:d7a18a3cd6f9 broker

IOracleRunner
author Sebastien Jodogne <s.jodogne@gmail.com>
date Thu, 17 Oct 2019 16:51:41 +0200
parents 81b29bc7c3d4
children 17660df24c36
comparison
equal deleted inserted replaced
1076:008dbc4ceb62 1077:d7a18a3cd6f9
27 27
28 #if ORTHANC_ENABLE_THREADS != 1 28 #if ORTHANC_ENABLE_THREADS != 1
29 # error This file can only compiled for native targets 29 # error This file can only compiled for native targets
30 #endif 30 #endif
31 31
32 #include "../Messages/IMessageEmitter.h"
33 #include "IOracle.h" 32 #include "IOracle.h"
33 #include "GenericOracleRunner.h"
34 34
35 #include <Core/WebServiceParameters.h>
36 #include <Core/MultiThreading/SharedMessageQueue.h> 35 #include <Core/MultiThreading/SharedMessageQueue.h>
37 36
38 37
39 namespace OrthancStone 38 namespace OrthancStone
40 { 39 {
72 public: 71 public:
73 ThreadedOracle(IMessageEmitter& emitter); 72 ThreadedOracle(IMessageEmitter& emitter);
74 73
75 virtual ~ThreadedOracle(); 74 virtual ~ThreadedOracle();
76 75
77 // The reference is not stored.
78 void SetOrthancParameters(const Orthanc::WebServiceParameters& orthanc); 76 void SetOrthancParameters(const Orthanc::WebServiceParameters& orthanc);
79 77
80 void SetThreadsCount(unsigned int count); 78 void SetThreadsCount(unsigned int count);
81 79
82 void SetSleepingTimeResolution(unsigned int milliseconds); 80 void SetSleepingTimeResolution(unsigned int milliseconds);
87 { 85 {
88 StopInternal(); 86 StopInternal();
89 } 87 }
90 88
91 virtual void Schedule(boost::shared_ptr<IObserver>& receiver, 89 virtual void Schedule(boost::shared_ptr<IObserver>& receiver,
92 IOracleCommand* command); 90 IOracleCommand* command) ORTHANC_OVERRIDE;
93 }; 91 };
94 } 92 }