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
        Candidate_v1.7.0
        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 81c96b6 was             778abb, checked in by Frederik Heber <heber@…>, 13 years ago | 
        
          | 
Added ResultGetter and capabilities to receive calculated results to FragmentController.
 Added enum (and file) ControllerChoices that defines the state of
FragmentScheduler.
depending on what is desired the Scheduler switches between these states and
either receives or sends information. Requires new member variable choice
because receival is of course asynchronous (see note in previous commit).
FragmentController has additional functions connect_get() and
handle_connect_get() to receive results.
connect_calc() and connect_check() now just the choice whereas the actual
sending and receiving is done in handle_... functions.
handle_FinishOperation() is the common final callback function for all three
of these functions.
FragmentScheduler contains an internal list of delivered results.
FragmentScheduler only initiates worker socket when jobs are present.
FIX: FragmentScheduler does only send results that are done and only once.
TESTFIX: Removed third Worker that receives NoJob as socket is powered down
before because queue has run empty and we haven't add new jobs.
 | 
        
          | 
              
Property                 mode
 set to                 100644 | 
        
          | File size:
            1.6 KB | 
      
      
| Line |  | 
|---|
| 1 | /* | 
|---|
| 2 | * Project: MoleCuilder | 
|---|
| 3 | * Description: creates and alters molecular systems | 
|---|
| 4 | * Copyright (C)  2011-2012 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 Server.cpp | 
|---|
| 10 | * | 
|---|
| 11 | * This file strongly follows the Serialization example from the boost::asio | 
|---|
| 12 | * library (see server.cpp) | 
|---|
| 13 | * | 
|---|
| 14 | *  Created on: Oct 21, 2011 | 
|---|
| 15 | *      Author: heber | 
|---|
| 16 | */ | 
|---|
| 17 |  | 
|---|
| 18 | // include config.h | 
|---|
| 19 | #ifdef HAVE_CONFIG_H | 
|---|
| 20 | #include <config.h> | 
|---|
| 21 | #endif | 
|---|
| 22 |  | 
|---|
| 23 | // boost asio needs specific operator new | 
|---|
| 24 | #include <boost/asio.hpp> | 
|---|
| 25 |  | 
|---|
| 26 | #include "CodePatterns/MemDebug.hpp" | 
|---|
| 27 |  | 
|---|
| 28 | #include <boost/lexical_cast.hpp> | 
|---|
| 29 | #include <iostream> | 
|---|
| 30 |  | 
|---|
| 31 | #include "atexit.hpp" | 
|---|
| 32 | #include "CodePatterns/Info.hpp" | 
|---|
| 33 | #include "CodePatterns/Log.hpp" | 
|---|
| 34 | #include "FragmentScheduler.hpp" | 
|---|
| 35 |  | 
|---|
| 36 |  | 
|---|
| 37 | int main(int argc, char* argv[]) | 
|---|
| 38 | { | 
|---|
| 39 | // from this moment on, we need to be sure to deinitialize in the correct order | 
|---|
| 40 | // this is handled by the cleanup function | 
|---|
| 41 | atexit(cleanUp); | 
|---|
| 42 |  | 
|---|
| 43 | setVerbosity(3); | 
|---|
| 44 |  | 
|---|
| 45 | size_t Exitflag = 0; | 
|---|
| 46 | try | 
|---|
| 47 | { | 
|---|
| 48 | // Check command line arguments. | 
|---|
| 49 | if (argc != 3) | 
|---|
| 50 | { | 
|---|
| 51 | std::cerr << "Usage: " << argv[0] << " <worker port> <controller port>" << std::endl; | 
|---|
| 52 | return 1; | 
|---|
| 53 | } | 
|---|
| 54 | unsigned short workerport = boost::lexical_cast<unsigned short>(argv[1]); | 
|---|
| 55 | unsigned short controllerport = boost::lexical_cast<unsigned short>(argv[2]); | 
|---|
| 56 |  | 
|---|
| 57 | boost::asio::io_service io_service; | 
|---|
| 58 | FragmentScheduler Server(io_service, workerport, controllerport); | 
|---|
| 59 | { | 
|---|
| 60 | Info info("io_service"); | 
|---|
| 61 | io_service.run(); | 
|---|
| 62 | } | 
|---|
| 63 | Exitflag = Server.getExitflag(); | 
|---|
| 64 | } | 
|---|
| 65 | catch (std::exception& e) | 
|---|
| 66 | { | 
|---|
| 67 | std::cerr << e.what() << std::endl; | 
|---|
| 68 | } | 
|---|
| 69 |  | 
|---|
| 70 | return Exitflag; | 
|---|
| 71 | } | 
|---|
       
      
  Note:
 See   
TracBrowser
 for help on using the repository browser.