1 | /*
|
---|
2 | * SystemCommandJob.hpp
|
---|
3 | *
|
---|
4 | * Originally taken from my JobMarket project at 1.1.4.
|
---|
5 | *
|
---|
6 | * Created on: Feb 5, 2011
|
---|
7 | * Author: heber
|
---|
8 | */
|
---|
9 |
|
---|
10 | #ifndef SYSTEMCOMMANDJOB_HPP_
|
---|
11 | #define SYSTEMCOMMANDJOB_HPP_
|
---|
12 |
|
---|
13 | // include config.h
|
---|
14 | #ifdef HAVE_CONFIG_H
|
---|
15 | #include <config.h>
|
---|
16 | #endif
|
---|
17 |
|
---|
18 | #include <boost/serialization/export.hpp>
|
---|
19 |
|
---|
20 | #include <string>
|
---|
21 |
|
---|
22 | #ifdef HAVE_JOBMARKET
|
---|
23 | #include "JobMarket/Jobs/FragmentJob.hpp"
|
---|
24 | #else
|
---|
25 | #include "Jobs/JobMarket/FragmentJob.hpp"
|
---|
26 | #endif
|
---|
27 |
|
---|
28 | class SystemCommandJobTest;
|
---|
29 |
|
---|
30 | /** SystemCommandJob is an extension of FragmentJob that executes a system
|
---|
31 | * command operating onto a specific outputfile.
|
---|
32 | *
|
---|
33 | * Implement extractResult() to get the desired result from the captured
|
---|
34 | * output of the system command.
|
---|
35 | *
|
---|
36 | * Important is that this class is fully serializable such that it can be
|
---|
37 | * transfered to a scheduler (server) and be deserialized by the Worker.
|
---|
38 | */
|
---|
39 | class SystemCommandJob : public FragmentJob
|
---|
40 | {
|
---|
41 | //!> grant unit test access
|
---|
42 | friend class SystemCommandJobTest;
|
---|
43 | public:
|
---|
44 | SystemCommandJob(const std::string &_command, const std::string &_outputfile, const JobId_t _JobId);
|
---|
45 | virtual ~SystemCommandJob();
|
---|
46 |
|
---|
47 | FragmentResult::ptr Work();
|
---|
48 |
|
---|
49 | bool operator==(const SystemCommandJob &other) const;
|
---|
50 |
|
---|
51 | bool operator!=(const SystemCommandJob &other) const {
|
---|
52 | return !(*this == other);
|
---|
53 | }
|
---|
54 |
|
---|
55 | private:
|
---|
56 | virtual FragmentResult::ptr extractResult(const std::string &resultstring);
|
---|
57 |
|
---|
58 | //!> string containing the command to launch the solver
|
---|
59 | std::string command;
|
---|
60 |
|
---|
61 | //!> string containing the configuration file for the solver
|
---|
62 | std::string outputfile;
|
---|
63 |
|
---|
64 | protected:
|
---|
65 | //!> private default cstor for serialization only
|
---|
66 | SystemCommandJob();
|
---|
67 |
|
---|
68 | private:
|
---|
69 | friend class boost::serialization::access;
|
---|
70 | // serialization
|
---|
71 | template <typename Archive>
|
---|
72 | void serialize(Archive& ar, const unsigned int version)
|
---|
73 | {
|
---|
74 | ar & boost::serialization::base_object<FragmentJob>(*this);
|
---|
75 | ar & command;
|
---|
76 | ar & outputfile;
|
---|
77 | }
|
---|
78 | };
|
---|
79 |
|
---|
80 | // we need to give this class a unique key for serialization
|
---|
81 | // its is only serialized through its base class FragmentJob
|
---|
82 | BOOST_CLASS_EXPORT_KEY(SystemCommandJob)
|
---|
83 |
|
---|
84 | #endif /* SYSTEMCOMMANDJOB_HPP_ */
|
---|