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 917be8 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.