|
|
|
|
|
|
|
|
#include "WorkerPool.hpp"
|
|
|
#include "WorkerPool.hpp"
|
|
|
#include "InputProcessor.hpp"
|
|
|
#include "InputProcessor.hpp"
|
|
|
#include "OutputProcessor.hpp"
|
|
|
#include "OutputProcessor.hpp"
|
|
|
#include "CommandProcessor.hpp"
|
|
|
|
|
|
|
|
|
|
|
|
#include <string>
|
|
|
#include <string>
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
WorkerPool* Workers; // components so they can be
|
|
|
WorkerPool* Workers; // components so they can be
|
|
|
InputProcessor* Input; // created, destroyed and
|
|
|
InputProcessor* Input; // created, destroyed and
|
|
|
OutputProcessor* Output; // connected together.
|
|
|
OutputProcessor* Output; // connected together.
|
|
|
CommandProcessor* Processor;
|
|
|
|
|
|
|
|
|
|
|
|
void initializeOutput(); // These do what they say.
|
|
|
void initializeOutput(); // These do what they say.
|
|
|
void initializeJobPool();
|
|
|
void initializeJobPool();
|
|
|
|
|
|
|
|
|
void shutdownJobPool();
|
|
|
void shutdownJobPool();
|
|
|
void shutdownOutput();
|
|
|
void shutdownOutput();
|
|
|
|
|
|
|
|
|
|
|
|
void dispatchCommand(Command C); // Job + Worker + Command; go!
|
|
|
|
|
|
|
|
|
public:
|
|
|
public:
|
|
|
|
|
|
|
|
|
ExecutiveProcess(string& Version, string& Config); // Simple construction. The d'tor needs
|
|
|
ExecutiveProcess(string& Version, string& Config); // Simple construction. The d'tor needs
|