| [72eaf7f] | 1 | /*
|
|---|
| [926a49] | 2 | * FragmentScheduler.hpp
|
|---|
| [72eaf7f] | 3 | *
|
|---|
| [cd4a6e] | 4 | * Created on: Oct 19, 2011
|
|---|
| [72eaf7f] | 5 | * Author: heber
|
|---|
| 6 | */
|
|---|
| 7 |
|
|---|
| [cd4a6e] | 8 | #ifndef FRAGMENTSCHEDULER_HPP_
|
|---|
| 9 | #define FRAGMENTSCHEDULER_HPP_
|
|---|
| [72eaf7f] | 10 |
|
|---|
| [f93842] | 11 | // include config.h
|
|---|
| 12 | #ifdef HAVE_CONFIG_H
|
|---|
| 13 | #include <config.h>
|
|---|
| 14 | #endif
|
|---|
| 15 |
|
|---|
| [72eaf7f] | 16 | #include <vector>
|
|---|
| [cd4a6e] | 17 | #include <boost/asio.hpp>
|
|---|
| 18 |
|
|---|
| 19 | #include "Connection.hpp"
|
|---|
| [778abb] | 20 | #include "ControllerChoices.hpp"
|
|---|
| [7670865] | 21 | #include "FragmentQueue.hpp"
|
|---|
| [d1dbfc] | 22 | #include "GlobalJobId.hpp"
|
|---|
| [7670865] | 23 | #include "Jobs/FragmentJob.hpp"
|
|---|
| 24 | #include "Results/FragmentResult.hpp"
|
|---|
| [778abb] | 25 | #include "types.hpp"
|
|---|
| [72eaf7f] | 26 |
|
|---|
| [cd4a6e] | 27 | /** FragmentScheduler serves FragmentJobs to Workers.
|
|---|
| 28 | *
|
|---|
| 29 | */
|
|---|
| [926a49] | 30 | class FragmentScheduler
|
|---|
| [72eaf7f] | 31 | {
|
|---|
| 32 | public:
|
|---|
| 33 | /// Constructor opens the acceptor and starts waiting for the first incoming
|
|---|
| [cd4a6e] | 34 | /// Connection.
|
|---|
| [db03d9] | 35 | FragmentScheduler(boost::asio::io_service& io_service, unsigned short workerport, unsigned short controllerport);
|
|---|
| [72eaf7f] | 36 |
|
|---|
| [db03d9] | 37 | enum Exitflag_t{
|
|---|
| 38 | OkFlag = 0,
|
|---|
| [778abb] | 39 | QueueError = 128,
|
|---|
| [3c4a5e] | 40 | ControllerErrorFlag = 254,
|
|---|
| 41 | WorkerErrorFlag = 255
|
|---|
| [db03d9] | 42 | };
|
|---|
| [72eaf7f] | 43 |
|
|---|
| [db03d9] | 44 | /** Getter for Exitflag.
|
|---|
| 45 | *
|
|---|
| 46 | * @return Exitflag of operations
|
|---|
| 47 | */
|
|---|
| 48 | size_t getExitflag() const
|
|---|
| 49 | {
|
|---|
| 50 | return Exitflag;
|
|---|
| 51 | }
|
|---|
| [72eaf7f] | 52 |
|
|---|
| [db03d9] | 53 | protected:
|
|---|
| 54 | /// Handle completion of a accept worker operation.
|
|---|
| 55 | void handle_AcceptWorker(const boost::system::error_code& e, connection_ptr conn);
|
|---|
| 56 |
|
|---|
| 57 | /// Handle completion of a accept controller operation.
|
|---|
| 58 | void handle_AcceptController(const boost::system::error_code& e, connection_ptr conn);
|
|---|
| 59 |
|
|---|
| [778abb] | 60 | /// Handle completion of controller operation to read choice
|
|---|
| 61 | void handle_ReadChoice(const boost::system::error_code& e, connection_ptr conn);
|
|---|
| 62 |
|
|---|
| [db03d9] | 63 | /// Worker callback function when job has been sent.
|
|---|
| 64 | void handle_SendJobtoWorker(const boost::system::error_code& e, connection_ptr conn);
|
|---|
| 65 |
|
|---|
| 66 | /// Worker callback function when result has been received.
|
|---|
| 67 | void handle_ReceiveResultFromWorker(const boost::system::error_code& e, connection_ptr conn);
|
|---|
| 68 |
|
|---|
| 69 | /// Controller callback function when job has been sent.
|
|---|
| 70 | void handle_ReceiveJobs(const boost::system::error_code& e, connection_ptr conn);
|
|---|
| [ef2767] | 71 |
|
|---|
| [72eaf7f] | 72 | private:
|
|---|
| [3c4a5e] | 73 |
|
|---|
| 74 | /// Controller callback function when checking on state of results.
|
|---|
| 75 | void handle_CheckResultState(const boost::system::error_code& e, connection_ptr conn);
|
|---|
| 76 |
|
|---|
| [d1dbfc] | 77 | /// Controller callback function when checking on state of results.
|
|---|
| 78 | void handle_GetNextJobIdState(const boost::system::error_code& e, connection_ptr conn);
|
|---|
| 79 |
|
|---|
| [778abb] | 80 | /// Controller callback function when result has been received.
|
|---|
| 81 | void handle_SendResults(const boost::system::error_code& e, connection_ptr conn);
|
|---|
| 82 |
|
|---|
| [402bde] | 83 | /// internal function to prepare worker connections
|
|---|
| 84 | void initiateWorkerSocket();
|
|---|
| 85 |
|
|---|
| 86 | /// internal function to prepare controller connections
|
|---|
| 87 | void initiateControllerSocket();
|
|---|
| 88 |
|
|---|
| 89 | private:
|
|---|
| [db03d9] | 90 | /// The acceptor object used to accept incoming worker socket connections.
|
|---|
| 91 | boost::asio::ip::tcp::acceptor worker_acceptor_;
|
|---|
| 92 |
|
|---|
| 93 | /// The acceptor object used to accept incoming controller socket connections.
|
|---|
| 94 | boost::asio::ip::tcp::acceptor controller_acceptor_;
|
|---|
| [72eaf7f] | 95 |
|
|---|
| [ef2767] | 96 | /// result that is received from the client.
|
|---|
| [35f587] | 97 | FragmentResult::ptr result;
|
|---|
| [ef2767] | 98 |
|
|---|
| [db03d9] | 99 | /// bunch of jobs received from controller before placed in JobsQueue
|
|---|
| [78ad7d] | 100 | std::vector<FragmentJob::ptr> jobs;
|
|---|
| [db03d9] | 101 |
|
|---|
| [6f2bc7] | 102 | /// number of jobs that are waiting to be and are calculated, required for returning status
|
|---|
| 103 | std::vector<size_t> jobInfo;
|
|---|
| [3c4a5e] | 104 |
|
|---|
| [778abb] | 105 | // choice
|
|---|
| 106 | enum ControllerChoices choice;
|
|---|
| 107 |
|
|---|
| [b0b64c] | 108 | /// Queue with data to be sent to each client.
|
|---|
| 109 | FragmentQueue JobsQueue;
|
|---|
| [c7deca] | 110 |
|
|---|
| 111 | // static entity to indicate to clients that the queue is empty.
|
|---|
| [78ad7d] | 112 | static FragmentJob::ptr NoJob;
|
|---|
| [db03d9] | 113 |
|
|---|
| [d1dbfc] | 114 | // TODO: replace this instance by a IdPool.
|
|---|
| 115 | //!> global id to give next available job id
|
|---|
| 116 | GlobalJobId globalId;
|
|---|
| 117 |
|
|---|
| [db03d9] | 118 | // Exit flag on program exit
|
|---|
| 119 | enum Exitflag_t Exitflag;
|
|---|
| [72eaf7f] | 120 | };
|
|---|
| 121 |
|
|---|
| [cd4a6e] | 122 | #endif /* FRAGMENTSCHEDULER_HPP_ */
|
|---|