source: src/Fragmentation/Automation/FragmentWorker.cpp@ b0b64c

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 b0b64c was b0b64c, checked in by Frederik Heber <heber@…>, 13 years ago

FragmentScheduler now contains a FragmentQueue and serves single jobs therefrom.

  • e.g. currently we only push one job, hence only a single worker is served. Others afterwards don't receive a job.
  • we lack a mechanism to give feedback to the client, i.e. a pseudo job such that he knows that the queue is empty right now. Later this should then indicate a wait (for a specific amount of time).
  • Property mode set to 100644
File size: 3.3 KB
RevLine 
[2eff32]1/*
[cd4a6e]2 * Project: MoleCuilder
3 * Description: creates and alters molecular systems
4 * Copyright (C) 2011 University of Bonn. All rights reserved.
5 * Please see the LICENSE file or "Copyright notice" in builder.cpp for details.
6 */
7
8/*
9 * \file FragmentWorker.cpp
10 *
11 * This file strongly follows the Serialization example from the boost::asio
12 * library (see client.cpp).
[2eff32]13 *
14 * Created on: Nov 18, 2011
15 * Author: heber
16 */
17
[f93842]18// include config.h
19#ifdef HAVE_CONFIG_H
20#include <config.h>
21#endif
22
[00d4fb]23// boost asio needs specific operator new
[2eff32]24#include <boost/asio.hpp>
[00d4fb]25
26#include "CodePatterns/MemDebug.hpp"
27
[2eff32]28#include <boost/bind.hpp>
29#include <iostream>
30#include <vector>
[af3aed]31#include "Connection.hpp" // Must come before boost/serialization headers.
[2eff32]32#include <boost/serialization/vector.hpp>
[af3aed]33#include "CodePatterns/Info.hpp"
[b0b64c]34#include "CodePatterns/Log.hpp"
[31ca5f]35#include "FragmentJob.hpp"
[cd4a6e]36#include "FragmentWorker.hpp"
[2eff32]37
[a636f8]38/// Constructor starts the asynchronous connect operation.
[8c9596]39FragmentWorker::FragmentWorker(
[a636f8]40 boost::asio::io_service& io_service,
41 const std::string& host,
42 const std::string& service) :
43 connection_(io_service)
44{
[af3aed]45 Info info(__FUNCTION__);
[a636f8]46 // Resolve the host name into an IP address.
47 boost::asio::ip::tcp::resolver resolver(io_service);
48 boost::asio::ip::tcp::resolver::query query(host, service);
49 boost::asio::ip::tcp::resolver::iterator endpoint_iterator =
50 resolver.resolve(query);
51 boost::asio::ip::tcp::endpoint endpoint = *endpoint_iterator;
[2eff32]52
[a636f8]53 // Start an asynchronous connect operation.
[e3a9c9]54 std::cout << "Connecting to endpoint " << endpoint << std::endl;
[a636f8]55 connection_.socket().async_connect(endpoint,
[8c9596]56 boost::bind(&FragmentWorker::handle_connect, this,
[e3a9c9]57 boost::asio::placeholders::error, ++endpoint_iterator));
[a636f8]58}
[2eff32]59
[a636f8]60/// Handle completion of a connect operation.
[e3a9c9]61void FragmentWorker::handle_connect(const boost::system::error_code& e,
62 boost::asio::ip::tcp::resolver::iterator endpoint_iterator)
[a636f8]63{
[af3aed]64 Info info(__FUNCTION__);
[a636f8]65 if (!e)
[2eff32]66 {
[a636f8]67 // Successfully established connection. Start operation to read the list
[cd4a6e]68 // of jobs. The connection::async_read() function will automatically
[a636f8]69 // decode the data that is read from the underlying socket.
[b0b64c]70 connection_.async_read(job,
[8c9596]71 boost::bind(&FragmentWorker::handle_read, this,
[a636f8]72 boost::asio::placeholders::error));
[e3a9c9]73 } else if (endpoint_iterator != boost::asio::ip::tcp::resolver::iterator()) {
74 // Try the next endpoint.
75 connection_.socket().close();
76 boost::asio::ip::tcp::endpoint endpoint = *endpoint_iterator;
77 connection_.socket().async_connect(endpoint,
78 boost::bind(&FragmentWorker::handle_connect, this,
79 boost::asio::placeholders::error, ++endpoint_iterator));
80 } else {
[a636f8]81 // An error occurred. Log it and return. Since we are not starting a new
82 // operation the io_service will run out of work to do and the client will
83 // exit.
[b0b64c]84 ELOG(1, e.message());
[2eff32]85 }
[a636f8]86}
[2eff32]87
[a636f8]88/// Handle completion of a read operation.
[8c9596]89void FragmentWorker::handle_read(const boost::system::error_code& e)
[a636f8]90{
[b05673]91 Info info(__FUNCTION__);
[a636f8]92 if (!e)
[2eff32]93 {
[a636f8]94 // Print out the data that was received.
[b0b64c]95 std::cout << "Job output: " << job.outputfile << "\n";
96 std::cout << "Job id: " << job.getId() << "\n";
[2eff32]97 }
[a636f8]98 else
99 {
100 // An error occurred.
[b0b64c]101 ELOG(1, e.message());
[a636f8]102 }
103
104 // Since we are not starting a new operation the io_service will run out of
105 // work to do and the client will exit.
106}
[2eff32]107
Note: See TracBrowser for help on using the repository browser.