source: src/Fragmentation/Automation/FragmentJob.cpp@ 142ff5

Action_Thermostats Add_AtomRandomPerturbation Add_FitFragmentPartialChargesAction Add_RotateAroundBondAction Add_SelectAtomByNameAction Added_ParseSaveFragmentResults AddingActions_SaveParseParticleParameters Adding_Graph_to_ChangeBondActions Adding_MD_integration_tests Adding_ParticleName_to_Atom Adding_StructOpt_integration_tests AtomFragments Automaking_mpqc_open AutomationFragmentation_failures Candidate_v1.5.4 Candidate_v1.6.0 Candidate_v1.6.1 ChangeBugEmailaddress ChangingTestPorts ChemicalSpaceEvaluator CombiningParticlePotentialParsing Combining_Subpackages Debian_Package_split Debian_package_split_molecuildergui_only Disabling_MemDebug Docu_Python_wait EmpiricalPotential_contain_HomologyGraph EmpiricalPotential_contain_HomologyGraph_documentation Enable_parallel_make_install Enhance_userguide Enhanced_StructuralOptimization Enhanced_StructuralOptimization_continued Example_ManyWaysToTranslateAtom Exclude_Hydrogens_annealWithBondGraph FitPartialCharges_GlobalError Fix_BoundInBox_CenterInBox_MoleculeActions Fix_ChargeSampling_PBC Fix_ChronosMutex Fix_FitPartialCharges Fix_FitPotential_needs_atomicnumbers Fix_ForceAnnealing Fix_IndependentFragmentGrids Fix_ParseParticles Fix_ParseParticles_split_forward_backward_Actions Fix_PopActions Fix_QtFragmentList_sorted_selection Fix_Restrictedkeyset_FragmentMolecule Fix_StatusMsg Fix_StepWorldTime_single_argument Fix_Verbose_Codepatterns Fix_fitting_potentials Fixes ForceAnnealing_goodresults ForceAnnealing_oldresults ForceAnnealing_tocheck ForceAnnealing_with_BondGraph ForceAnnealing_with_BondGraph_continued ForceAnnealing_with_BondGraph_continued_betteresults ForceAnnealing_with_BondGraph_contraction-expansion FragmentAction_writes_AtomFragments FragmentMolecule_checks_bonddegrees GeometryObjects Gui_Fixes Gui_displays_atomic_force_velocity ImplicitCharges IndependentFragmentGrids IndependentFragmentGrids_IndividualZeroInstances IndependentFragmentGrids_IntegrationTest IndependentFragmentGrids_Sole_NN_Calculation JobMarket_RobustOnKillsSegFaults JobMarket_StableWorkerPool JobMarket_unresolvable_hostname_fix MoreRobust_FragmentAutomation ODR_violation_mpqc_open PartialCharges_OrthogonalSummation PdbParser_setsAtomName PythonUI_with_named_parameters QtGui_reactivate_TimeChanged_changes Recreated_GuiChecks Rewrite_FitPartialCharges RotateToPrincipalAxisSystem_UndoRedo SaturateAtoms_findBestMatching SaturateAtoms_singleDegree StoppableMakroAction Subpackage_CodePatterns Subpackage_JobMarket Subpackage_LinearAlgebra Subpackage_levmar Subpackage_mpqc_open Subpackage_vmg Switchable_LogView ThirdParty_MPQC_rebuilt_buildsystem TrajectoryDependenant_MaxOrder TremoloParser_IncreasedPrecision TremoloParser_MultipleTimesteps TremoloParser_setsAtomName Ubuntu_1604_changes stable
Last change on this file since 142ff5 was 142ff5, checked in by Frederik Heber <heber@…>, 13 years ago

FragmentJob now executes a specific string as command along with an outputfile to work on.

  • stdout is parsed in as FragmentResult::result, return from std::system is placed into FragmentResult::exitflag.
  • createjobs() in controller.cpp uses cat and "Nothing" to mimick the same behavior as before.
  • removed intermediate deadline_timer usage in ::Work().
  • Property mode set to 100644
File size: 2.6 KB
Line 
1/*
2 * Project: MoleCuilder
3 * Description: creates and alters molecular systems
4 * Copyright (C) 2010 University of Bonn. All rights reserved.
5 * Please see the LICENSE file or "Copyright notice" in builder.cpp for details.
6 */
7
8/*
9 * FragmentJob.cpp
10 *
11 * Created on: Oct 19, 2011
12 * Author: heber
13 */
14
15// include config.h
16#ifdef HAVE_CONFIG_H
17#include <config.h>
18#endif
19
20#include "CodePatterns/MemDebug.hpp"
21
22#include <cstdlib>
23#include <fstream>
24#include <string>
25
26#include "CodePatterns/Info.hpp"
27#include "CodePatterns/Log.hpp"
28#include "CodePatterns/toString.hpp"
29#include "FragmentJob.hpp"
30#include "FragmentResult.hpp"
31
32/** Constructor for class FragmentJob.
33 *
34 */
35FragmentJob::FragmentJob() :
36 JobId(-1),
37 outputfile("")
38{}
39
40/** Constructor for class FragmentJob.
41 *
42 * \param _command command to execute
43 * \param _outputfile configuration file for solver
44 * \param _JobId unique id of this job
45 */
46FragmentJob::FragmentJob(const std::string &_command, const std::string &_outputfile, const JobId_t _JobId) :
47 JobId(_JobId),
48 command(_command),
49 outputfile(_outputfile)
50{}
51
52/** Destructor for class FragmentJob.
53 *
54 */
55FragmentJob::~FragmentJob()
56{}
57
58/** Work routine of this FragmentJob.
59 *
60 * This function encapsulates all the work that has to be done to generate
61 * a FragmentResult. Hence, the FragmentWorker does not need to know anything
62 * about the operation: it just receives it and executes this function.
63 *
64 * \return result of this job
65 */
66FragmentResult FragmentJob::Work()
67{
68 Info info((std::string(__FUNCTION__)+std::string(", id #")+toString(getId())).c_str());
69 FragmentResult s(getId());
70
71 // write outputfile to file
72 std::string inputfilename =
73 std::string("/tmp/dummy_")
74 +toString(getId());
75 std::string outputfilename = inputfilename+std::string(".out");
76 inputfilename += std::string(".dat");
77 std::ofstream output(outputfilename.c_str());
78 output << outputfile << std::endl;
79 output.close();
80
81 // fork into subprocess and launch command
82 s.exitflag = std::system((command+std::string(" ")+inputfilename
83 +std::string(" >")+outputfilename).c_str());
84 std::ifstream resultfile;
85 resultfile.open(outputfilename.c_str(), ifstream::in);
86 char line[1024];
87 while (resultfile.good()) {
88 resultfile.getline(line, 1023);
89 s.result += line;
90 }
91 resultfile.close();
92
93 return s;
94}
95
96/** Comparator for class FragmentJob.
97 * \param other instance to compare to
98 * \return every member variable is the same, else - is not
99 */
100bool FragmentJob::operator==(const FragmentJob &other) const
101{
102 return (command == other.command)
103 && (outputfile == other.outputfile)
104 && (getId() == other.getId());
105}
Note: See TracBrowser for help on using the repository browser.