1 | /*
|
---|
2 | * FragmentController.hpp
|
---|
3 | *
|
---|
4 | * Created on: Nov 27, 2011
|
---|
5 | * Author: heber
|
---|
6 | */
|
---|
7 |
|
---|
8 | #ifndef FRAGMENTCONTROLLER_HPP_
|
---|
9 | #define FRAGMENTCONTROLLER_HPP_
|
---|
10 |
|
---|
11 | // include config.h
|
---|
12 | #ifdef HAVE_CONFIG_H
|
---|
13 | #include <config.h>
|
---|
14 | #endif
|
---|
15 |
|
---|
16 | #include <boost/asio.hpp>
|
---|
17 | #include <string>
|
---|
18 | #include <vector>
|
---|
19 |
|
---|
20 | #include "Connection.hpp"
|
---|
21 | #include "ExitflagContainer.hpp"
|
---|
22 | #include "JobId.hpp"
|
---|
23 | #include "Jobs/FragmentJob.hpp"
|
---|
24 | #include "Results/FragmentResult.hpp"
|
---|
25 |
|
---|
26 | #include "Operations/OperationRegistry.hpp"
|
---|
27 |
|
---|
28 | /** The FragmentController sends bunches of jobs to a FragmentScheduler,
|
---|
29 | * waits for their calculation and is called when they are done. Then,
|
---|
30 | * he loads the bunch of results from the Scheduler.
|
---|
31 | *
|
---|
32 | * While the FragmentScheduler and FragmentWorker rather act on their own
|
---|
33 | * this is the piece to implant into the user software to allow for
|
---|
34 | * communication with the Server/Worker duo to perform the calculation
|
---|
35 | * of the fragments on distant computers.
|
---|
36 | */
|
---|
37 | class FragmentController : public ExitflagContainer
|
---|
38 | {
|
---|
39 | public:
|
---|
40 | FragmentController(boost::asio::io_service& io_service);
|
---|
41 | ~FragmentController();
|
---|
42 |
|
---|
43 | void requestIds(const std::string &host, const std::string &service, const size_t NumberIds);
|
---|
44 | JobId_t getAvailableId();
|
---|
45 | void addJobs(std::vector<FragmentJob::ptr> &jobs);
|
---|
46 | void sendJobs(const std::string &host, const std::string &service);
|
---|
47 | void checkResults(const std::string &host, const std::string &service);
|
---|
48 | std::pair<size_t, size_t> getJobStatus() const;
|
---|
49 | void removeall(const std::string &host, const std::string &service);
|
---|
50 | void receiveResults(const std::string &host, const std::string &service);
|
---|
51 | std::vector<FragmentResult::ptr> getReceivedResults();
|
---|
52 | void shutdown(const std::string &host, const std::string &service);
|
---|
53 |
|
---|
54 | protected:
|
---|
55 | /// The Connection to the server.
|
---|
56 | Connection connection_;
|
---|
57 |
|
---|
58 | public:
|
---|
59 | //!> registry with all operations of this controller
|
---|
60 | OperationRegistry Commands;
|
---|
61 |
|
---|
62 | private:
|
---|
63 | //!> internally bound function that sets the Exitflag to ErrorFlag
|
---|
64 | boost::function<void ()> failed;
|
---|
65 | };
|
---|
66 |
|
---|
67 | #endif /* FRAGMENTCONTROLLER_HPP_ */
|
---|